代码生成支持同步数据库

RuoYi

2020-09-21 f4f89f9de6047051b64626ca6b58d5f287577d9a

代码生成支持同步数据库

 ruoyi-modules/ruoyi-gen/src/main/java/com/ruoyi/gen/controller/GenController.java

@@ -164,13 +164,25 @@
    @PreAuthorize(hasPermi = "tool:gen:code")

    @Log(title = "代码生成", businessType = BusinessType.GENCODE)

    @GetMapping("/genCode/{tableName}")

    public AjaxResult genCode(HttpServletResponse response, @PathVariable("tableName") String tableName)

    public AjaxResult genCode(@PathVariable("tableName") String tableName)

    {

        genTableService.generatorCode(tableName);

        return AjaxResult.success();

    }



    /**

     * 同步数据库

     */

    @PreAuthorize(hasPermi = "tool:gen:edit")

    @Log(title = "代码生成", businessType = BusinessType.UPDATE)

    @GetMapping("/synchDb/{tableName}")

    public AjaxResult synchDb(@PathVariable("tableName") String tableName)

    {

        genTableService.synchDb(tableName);

        return AjaxResult.success();

    }



    /**

     * 批量生成代码

     */

    @PreAuthorize(hasPermi = "tool:gen:code")


 ruoyi-modules/ruoyi-gen/src/main/java/com/ruoyi/gen/mapper/GenTableColumnMapper.java

@@ -41,6 +41,14 @@
     * @return 结果

     */

    public int updateGenTableColumn(GenTableColumn genTableColumn);



    /**

     * 删除业务字段

     * 
     * @param genTableColumns 列数据

     * @return 结果

     */

    public int deleteGenTableColumns(List<GenTableColumn> genTableColumns);



    /**

     * 批量删除业务字段


 ruoyi-modules/ruoyi-gen/src/main/java/com/ruoyi/gen/service/GenTableServiceImpl.java

@@ -7,6 +7,7 @@
import java.util.LinkedHashMap;

import java.util.List;

import java.util.Map;

import java.util.stream.Collectors;

import java.util.zip.ZipEntry;

import java.util.zip.ZipOutputStream;

import org.apache.commons.io.IOUtils;

@@ -223,7 +224,6 @@
     * 生成代码（自定义路径）

     * 

     * @param tableName 表名称

     * @return 数据

     */

    @Override

    public void generatorCode(String tableName)

@@ -262,6 +262,37 @@
    }



    /**

     * 同步数据库

     * 
     * @param tableName 表名称

     */

    @Override

    @Transactional

    public void synchDb(String tableName)

    {

        GenTable table = genTableMapper.selectGenTableByName(tableName);

        List<GenTableColumn> tableColumns = table.getColumns();

        List<String> tableColumnNames = tableColumns.stream().map(GenTableColumn::getColumnName).collect(Collectors.toList());



        List<GenTableColumn> dbTableColumns = genTableColumnMapper.selectDbTableColumnsByName(tableName);

        List<String> dbTableColumnNames = dbTableColumns.stream().map(GenTableColumn::getColumnName).collect(Collectors.toList());



        dbTableColumns.forEach(column -> {

            if (!tableColumnNames.contains(column.getColumnName()))

            {

                GenUtils.initColumnField(column, table);

                genTableColumnMapper.insertGenTableColumn(column);

            }

        });



        List<GenTableColumn> delColumns = tableColumns.stream().filter(column -> !dbTableColumnNames.contains(column.getColumnName())).collect(Collectors.toList());

        if (StringUtils.isNotEmpty(delColumns))

        {

            genTableColumnMapper.deleteGenTableColumns(delColumns);

        }

    }



    /**

     * 批量生成代码（下载方式）

     * 

     * @param tableNames 表数组


 ruoyi-modules/ruoyi-gen/src/main/java/com/ruoyi/gen/service/IGenTableService.java

@@ -91,6 +91,13 @@
    public void generatorCode(String tableName);



    /**

     * 同步数据库

     * 
     * @param tableName 表名称

     */

    public void synchDb(String tableName);



    /**

     * 批量生成代码（下载方式）

     * 

     * @param tableNames 表数组


 ruoyi-modules/ruoyi-gen/src/main/resources/mapper/generator/GenTableColumnMapper.xml

@@ -117,4 +117,11 @@
        </foreach>

    </delete>

    

    <delete id="deleteGenTableColumns">

        delete from gen_table_column where column_id in 
        <foreach collection="list" item="item" open="(" separator="," close=")">

            #{item.columnId}

        </foreach>

    </delete>



</mapper>

 ruoyi-modules/ruoyi-gen/src/main/resources/mapper/generator/GenTableMapper.xml

 ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml

@@ -75,7 +75,7 @@
            AND date_format(u.create_time,'%y%m%d') &lt;= date_format(#{endTime},'%y%m%d')

        </if>

        <if test="deptId != null and deptId != 0">

            AND (u.dept_id = #{deptId} OR u.dept_id IN ( SELECT t.dept_id FROM sys_dept t WHERE FIND_IN_SET (#{deptId},ancestors) ))

            AND (u.dept_id = #{deptId} OR u.dept_id IN ( SELECT t.dept_id FROM sys_dept t WHERE find_in_set(#{deptId}, ancestors) ))

        </if>

        <!-- 数据范围过滤 -->

        ${params.dataScope}


 ruoyi-ui/src/api/tool/gen.js

@@ -66,3 +66,11 @@
    method: 'get'

  })

}



// 同步数据库

export function synchDb(tableName) {

  return request({

    url: '/code/gen/synchDb/' + tableName,

    method: 'get'

  })

}


 ruoyi-ui/src/views/tool/gen/index.vue

@@ -135,6 +135,13 @@
          <el-button

            type="text"

            size="small"

            icon="el-icon-refresh"

            @click="handleSynchDb(scope.row)"

            v-hasPermi="['tool:gen:edit']"

          >同步</el-button>

          <el-button

            type="text"

            size="small"

            icon="el-icon-download"

            @click="handleGenTable(scope.row)"

            v-hasPermi="['tool:gen:code']"

@@ -167,7 +174,7 @@
</template>



<script>

import { listTable, previewTable, delTable, genCode } from "@/api/tool/gen";

import { listTable, previewTable, delTable, genCode, synchDb } from "@/api/tool/gen";

import importTable from "./importTable";

import { downLoadZip } from "@/utils/zipdownload";

export default {

@@ -252,6 +259,19 @@
          downLoadZip("/code/gen/batchGenCode?tables=" + tableNames, "ruoyi");

      }

    },

    /** 同步数据库操作 */

    handleSynchDb(row) {

      const tableName = row.tableName;

      this.$confirm('确认要强制同步"' + tableName + '"表结构吗？', "警告", {

        confirmButtonText: "确定",

        cancelButtonText: "取消",

        type: "warning"

      }).then(function() {

          return synchDb(tableName);

      }).then(() => {

          this.msgSuccess("同步成功");

      }).catch(function() {});

    },

    /** 打开导入表弹窗 */

    openImportTable() {

      this.$refs.import.show();