content: package com.ruoyi.generator.service.impl;
  
  import java.io.ByteArrayOutputStream;
  import java.io.IOException;
  import java.io.StringWriter;
  import java.util.LinkedHashMap;
  import java.util.List;
  import java.util.Map;
  import java.util.zip.ZipEntry;
  import java.util.zip.ZipOutputStream;
  import org.apache.commons.io.IOUtils;
  import org.apache.velocity.Template;
  import org.apache.velocity.VelocityContext;
  import org.apache.velocity.app.Velocity;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.stereotype.Service;
  import org.springframework.transaction.annotation.Transactional;
  import com.alibaba.fastjson.JSON;
  import com.alibaba.fastjson.JSONObject;
  import com.ruoyi.common.constant.Constants;
  import com.ruoyi.common.constant.GenConstants;
  import com.ruoyi.common.core.text.Convert;
  import com.ruoyi.common.exception.BusinessException;
  import com.ruoyi.common.utils.StringUtils;
  import com.ruoyi.generator.domain.GenTable;
  import com.ruoyi.generator.domain.GenTableColumn;
  import com.ruoyi.generator.mapper.GenTableColumnMapper;
  import com.ruoyi.generator.mapper.GenTableMapper;
  import com.ruoyi.generator.service.IGenTableService;
  import com.ruoyi.generator.util.GenUtils;
  import com.ruoyi.generator.util.VelocityInitializer;
  import com.ruoyi.generator.util.VelocityUtils;
  
  /**
   * 业务 服务层实现
   * 
   * @author ruoyi
   */
  @Service
  public class GenTableServiceImpl implements IGenTableService
  {
      private static final Logger log = LoggerFactory.getLogger(GenTableServiceImpl.class);
  
      @Autowired
      private GenTableMapper genTableMapper;
  
      @Autowired
      private GenTableColumnMapper genTableColumnMapper;
  
      /**
       * 查询业务信息
       * 
       * @param id 业务ID
       * @return 业务信息
       */
      @Override
      public GenTable selectGenTableById(Long id)
      {
          GenTable genTable = genTableMapper.selectGenTableById(id);
          setTableFromOptions(genTable);
          return genTable;
      }
  
      /**
       * 查询业务列表
       * 
       * @param genTable 业务信息
       * @return 业务集合
       */
      @Override
      public List<GenTable> selectGenTableList(GenTable genTable)
      {
          return genTableMapper.selectGenTableList(genTable);
      }
  
      /**
       * 查询据库列表
       * 
       * @param genTable 业务信息
       * @return 数据库表集合
       */
      public List<GenTable> selectDbTableList(GenTable genTable)
      {
          return genTableMapper.selectDbTableList(genTable);
      }
  
      /**
       * 查询据库列表
       * 
       * @param tableNames 表名称组
       * @return 数据库表集合
       */
      public List<GenTable> selectDbTableListByNames(String[] tableNames)
      {
          return genTableMapper.selectDbTableListByNames(tableNames);
      }
  
      /**
       * 修改业务
       * 
       * @param genTable 业务信息
       * @return 结果
       */
      @Override
      @Transactional
      public void updateGenTable(GenTable genTable)
      {
          String options = JSON.toJSONString(genTable.getParams());
          genTable.setOptions(options);
          int row = genTableMapper.updateGenTable(genTable);
          if (row > 0)
          {
              for (GenTableColumn cenTableColumn : genTable.getColumns())
              {
                  genTableColumnMapper.updateGenTableColumn(cenTableColumn);
              }
          }
      }
  
      /**
       * 删除业务对象
       * 
       * @param ids 需要删除的数据ID
       * @return 结果
       */
      @Override
      @Transactional
      public void deleteGenTableByIds(String ids)
      {
          genTableMapper.deleteGenTableByIds(Convert.toLongArray(ids));
          genTableColumnMapper.deleteGenTableColumnByIds(Convert.toLongArray(ids));
      }
  
      /**
       * 导入表结构
       * 
       * @param tableList 导入表列表
       * @param operName 操作人员
       */
      @Override
      @Transactional
      public void importGenTable(List<GenTable> tableList, String operName)
      {
          for (GenTable table : tableList)
          {
              try
              {
                  String tableName = table.getTableName();
                  GenUtils.initTable(table, operName);
                  int row = genTableMapper.insertGenTable(table);
                  if (row > 0)
                  {
                      // 保存列信息
                      List<GenTableColumn> genTableColumns = genTableColumnMapper.selectDbTableColumnsByName(tableName);
                      for (GenTableColumn column : genTableColumns)
                      {
                          GenUtils.initColumnField(column, table);
                          genTableColumnMapper.insertGenTableColumn(column);
                      }
                  }
              }
              catch (Exception e)
              {
                  log.error("表名 " + table.getTableName() + " 导入失败：", e);
              }
          }
      }
  
      /**
       * 预览代码
       * 
       * @param tableId 表编号
       * @return 预览数据列表
       */
      public Map<String, String> previewCode(Long tableId)
      {
          Map<String, String> dataMap = new LinkedHashMap<>();
          // 查询表信息
          GenTable table = genTableMapper.selectGenTableById(tableId);
          // 查询列信息
          List<GenTableColumn> columns = table.getColumns();
          setPkColumn(table, columns);
          VelocityInitializer.initVelocity();
  
          VelocityContext context = VelocityUtils.prepareContext(table);
  
          // 获取模板列表
          List<String> templates = VelocityUtils.getTemplateList(table.getTplCategory());
          for (String template : templates)
          {
              // 渲染模板
              StringWriter sw = new StringWriter();
              Template tpl = Velocity.getTemplate(template, Constants.UTF8);
              tpl.merge(context, sw);
              dataMap.put(template, sw.toString());
          }
          return dataMap;
      }
  
      /**
       * 生成代码
       * 
       * @param tableName 表名称
       * @return 数据
       */
      @Override
      public byte[] generatorCode(String tableName)
      {
          ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
          ZipOutputStream zip = new ZipOutputStream(outputStream);
          generatorCode(tableName, zip);
          IOUtils.closeQuietly(zip);
          return outputStream.toByteArray();
      }
  
      /**
       * 批量生成代码
       * 
       * @param tableNames 表数组
       * @return 数据
       */
      @Override
      public byte[] generatorCode(String[] tableNames)
      {
          ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
          ZipOutputStream zip = new ZipOutputStream(outputStream);
          for (String tableName : tableNames)
          {
              generatorCode(tableName, zip);
          }
          IOUtils.closeQuietly(zip);
          return outputStream.toByteArray();
      }
  
      /**
       * 查询表信息并生成代码
       */
      private void generatorCode(String tableName, ZipOutputStream zip)
      {
          // 查询表信息
          GenTable table = genTableMapper.selectGenTableByName(tableName);
          // 查询列信息
          List<GenTableColumn> columns = table.getColumns();
          setPkColumn(table, columns);
  
          VelocityInitializer.initVelocity();
  
          VelocityContext context = VelocityUtils.prepareContext(table);
  
          // 获取模板列表
          List<String> templates = VelocityUtils.getTemplateList(table.getTplCategory());
          for (String template : templates)
          {
              // 渲染模板
              StringWriter sw = new StringWriter();
              Template tpl = Velocity.getTemplate(template, Constants.UTF8);
              tpl.merge(context, sw);
              try
              {
                  // 添加到zip
                  zip.putNextEntry(new ZipEntry(VelocityUtils.getFileName(template, table)));
                  IOUtils.write(sw.toString(), zip, Constants.UTF8);
                  IOUtils.closeQuietly(sw);
                  zip.flush();
                  zip.closeEntry();
              }
              catch (IOException e)
              {
                  log.error("渲染模板失败，表名：" + table.getTableName(), e);
              }
          }
      }
  
      /**
       * 修改保存参数校验
       * 
       * @param genTable 业务信息
       */
      public void validateEdit(GenTable genTable)
      {
          if (GenConstants.TPL_TREE.equals(genTable.getTplCategory()))
          {
              String options = JSON.toJSONString(genTable.getParams());
              JSONObject paramsObj = JSONObject.parseObject(options);
              if (StringUtils.isEmpty(paramsObj.getString(GenConstants.TREE_CODE)))
              {
                  throw new BusinessException("树编码字段不能为空");
              }
              else if (StringUtils.isEmpty(paramsObj.getString(GenConstants.TREE_PARENT_CODE)))
              {
                  throw new BusinessException("树父编码字段不能为空");
              }
              else if (StringUtils.isEmpty(paramsObj.getString(GenConstants.TREE_NAME)))
              {
                  throw new BusinessException("树名称字段不能为空");
              }
          }
      }
  
      /**
       * 设置主键列信息
       * 
       * @param genTable 业务表信息
       * @param columns 业务字段列表
       */
      public void setPkColumn(GenTable table, List<GenTableColumn> columns)
      {
          for (GenTableColumn column : columns)
          {
              if (column.isPk())
              {
                  table.setPkColumn(column);
                  break;
              }
          }
          if (StringUtils.isNull(table.getPkColumn()))
          {
              table.setPkColumn(columns.get(0));
          }
      }
  
      /**
       * 设置代码生成其他选项值
       * 
       * @param genTable 设置后的生成对象
       */
      public void setTableFromOptions(GenTable genTable)
      {
          JSONObject paramsObj = JSONObject.parseObject(genTable.getOptions());
          if (StringUtils.isNotNull(paramsObj))
          {
              String treeCode = paramsObj.getString(GenConstants.TREE_CODE);
              String treeParentCode = paramsObj.getString(GenConstants.TREE_PARENT_CODE);
              String treeName = paramsObj.getString(GenConstants.TREE_NAME);
              genTable.setTreeCode(treeCode);
              genTable.setTreeParentCode(treeParentCode);
              genTable.setTreeName(treeName);
          }
      }
  }