新增修改动态表单时,刷新redis

boman-api/boman-api-gen/src/main/java/com/boman/gen/api/RemoteGenTableService.java

@@ -1,6 +1,7 @@
 package com.boman.gen.api;
 
 import com.boman.common.core.constant.ServiceNameConstants;
+import com.boman.common.core.web.domain.AjaxResult;
 import com.boman.domain.GenTable;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -33,4 +34,12 @@ public interface RemoteGenTableService {
      */
     @GetMapping(value = "/gen/table/{tableName}")
     GenTable getByTableName(@PathVariable("tableName") String tableName);
+
+    /**
+     * 把所有表信息重新加载到redis
+     * @param genTable
+     * @return
+     */
+    @GetMapping(value = "/loadTable")
+    AjaxResult loadTable(GenTable genTable);
 }

boman-modules/boman-gen/pom.xml

@@ -77,6 +77,12 @@
             <version>2.5.0-SNAPSHOT</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.boman</groupId>
+            <artifactId>boman-api-gen</artifactId>
+            <version>2.5.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>

boman-modules/boman-gen/src/main/java/com/boman/gen/controller/GenTableColumnController.java

@@ -29,6 +29,8 @@ public class GenTableColumnController extends BaseController {
     private IGenTableColumnService genTableColumnService;
 
 
+
+
     /**
      * 查询代码生成列表
      */

boman-modules/boman-gen/src/main/java/com/boman/gen/service/GenTableColumnServiceImpl.java

@@ -11,6 +11,7 @@ import com.boman.domain.constant.FormDataConstant;
 import com.boman.domain.GenTable;
 import com.boman.domain.GenTableColumn;
 import com.boman.domain.TableSql;
+import com.boman.gen.api.RemoteGenTableService;
 import com.boman.gen.mapper.GenTableColumnMapper;
 import com.boman.gen.mapper.GenTableMapper;
 import com.boman.gen.mapper.TableSqlMapper;
@@ -35,6 +36,8 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
     private GenTableMapper genTableMapper;
     @Autowired
     private TableSqlMapper tableSqlMapper;
+    @Autowired
+    private RemoteGenTableService remoteGenTableService;
 
     /**
      * 查询业务字段列表
@@ -64,8 +67,9 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
     }
 
     /**
-     /**
+     * /**
      * 根据字段编号获取字段详细信息, 把此外键对应的名称返回给前台
+     *
      * @param columnId pk
      */
     @Override
@@ -110,6 +114,7 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
         int i = genTableColumnMapper.insertGenTableColumn(genTableColumn);
         isAk(genTableColumn);
         insertCreateLog(genTableColumn, BusinessType.INSERT);
+        remoteGenTableService.loadTable(new GenTable());
         return i;
     }
 
@@ -123,7 +128,9 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
     public int updateGenTableColumn(GenTableColumn genTableColumn) {
         isAk(genTableColumn);
         insertCreateLog(genTableColumn, BusinessType.UPDATE);
-        return genTableColumnMapper.updateGenTableColumn(genTableColumn);
+        int i = genTableColumnMapper.updateGenTableColumn(genTableColumn);
+        remoteGenTableService.loadTable(new GenTable());
+        return i;
     }
 
     /**
@@ -137,13 +144,13 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
         StringBuffer sb = new StringBuffer(createLog);
         //ALTER TABLE table_name ADD COLUMN column_name VARCHAR(100) DEFAULT NULL COMMENT '新加字段';
         sb.append("\r\n").append(DateUtils.getTime()).append(" ").append(SecurityUtils.getUsername()).append(" ALTER TABLE ").append(genTable.getTableName());
-        if (BusinessType.INSERT.equals(type)){
+        if (BusinessType.INSERT.equals(type)) {
             sb.append(" ADD COLUMN ").append(genTableColumn.getColumnName()).append(" ").append(genTableColumn.getColumnType());
             sb = genTableColumn.getDefaultValue() == null ? sb.append(" DEFAULT NULL COMMENT ") : sb.append(" DEFAULT '").append(genTableColumn.getDefaultValue()).append("' COMMENT '");
             sb.append(genTableColumn.getColumnComment()).append("';");
-        }else if(BusinessType.UPDATE.equals(type)){
+        } else if (BusinessType.UPDATE.equals(type)) {
             sb.append(" MODIFY ").append(genTableColumn.getColumnName()).append(" ").append(genTableColumn.getColumnType()).append(";");
-        }else if(BusinessType.DELETE.equals(type)){
+        } else if (BusinessType.DELETE.equals(type)) {
             sb.append(" DROP ").append(genTableColumn.getColumnName()).append(";");
         }
         tableSql.setCreateLog(sb.toString());
@@ -165,7 +172,7 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
         if (UserConstants.YES.equals(isIn)) {
             //判断是否已经存在输入字段且不是同一个字段
             for (GenTableColumn tableColumn : genTableColumns) {
-                if (UserConstants.YES.equals(tableColumn.getIsIn()) && !tableColumn.getColumnId().equals(genTableColumn.getColumnId())){
+                if (UserConstants.YES.equals(tableColumn.getIsIn()) && !tableColumn.getColumnId().equals(genTableColumn.getColumnId())) {
                     tableColumn.setIsIn("N");
                     genTableColumnMapper.updateGenTableColumn(tableColumn);
                     break;
@@ -177,7 +184,7 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
         if (UserConstants.YES.equals(isOut)) {
             //判断是否已经存在显示字段且不是同一个字段
             for (GenTableColumn tableColumn : genTableColumns) {
-                if (UserConstants.YES.equals(tableColumn.getIsOut()) && !tableColumn.getColumnId().equals(genTableColumn.getColumnId())){
+                if (UserConstants.YES.equals(tableColumn.getIsOut()) && !tableColumn.getColumnId().equals(genTableColumn.getColumnId())) {
                     tableColumn.setIsOut("N");
                     genTableColumnMapper.updateGenTableColumn(tableColumn);
                     break;
@@ -200,7 +207,9 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
      */
     @Override
     public int deleteGenTableColumnByIds(String ids) {
-        return genTableColumnMapper.deleteGenTableColumnByIds(Convert.toLongArray(ids));
+        int i = genTableColumnMapper.deleteGenTableColumnByIds(Convert.toLongArray(ids));
+        remoteGenTableService.loadTable(new GenTable());
+        return i;
     }
 
     /**
@@ -214,9 +223,11 @@ public class GenTableColumnServiceImpl implements IGenTableColumnService {
         Long[] longs = Convert.toLongArray(ids);
         for (Long aLong : longs) {
             GenTableColumn genTableColumn = genTableColumnMapper.selectGenTableColumnByColumnId(aLong);
-            insertCreateLog(genTableColumn,BusinessType.DELETE);
+            insertCreateLog(genTableColumn, BusinessType.DELETE);
         }
-        return genTableColumnMapper.deleteGenTableColumnByColumnIds(Convert.toLongArray(ids));
+        int i = genTableColumnMapper.deleteGenTableColumnByColumnIds(Convert.toLongArray(ids));
+        remoteGenTableService.loadTable(new GenTable());
+        return i;
     }
 
     /**

boman-modules/boman-gen/src/main/java/com/boman/gen/service/GenTableRelationServiceImpl.java

@@ -1,6 +1,8 @@
 package com.boman.gen.service;
 
+import com.boman.domain.GenTable;
 import com.boman.domain.GenTableRelation;
+import com.boman.gen.api.RemoteGenTableService;
 import com.boman.gen.mapper.GenTableRelationMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -17,6 +19,10 @@ public class GenTableRelationServiceImpl implements IGenTableRelationService {
     @Autowired
     private GenTableRelationMapper genTableRelationMapper;
 
+    @Autowired
+    private RemoteGenTableService remoteGenTableService;
+
+
     /**
      * 查询列表
      *
@@ -49,7 +55,9 @@ public class GenTableRelationServiceImpl implements IGenTableRelationService {
      */
     @Override
     public int insertGenTableRelation(GenTableRelation genTableRelation) {
-        return genTableRelationMapper.insertGenTableRelation(genTableRelation);
+        int i = genTableRelationMapper.insertGenTableRelation(genTableRelation);
+        remoteGenTableService.loadTable(new GenTable());
+        return i;
     }
 
     /**
@@ -60,7 +68,9 @@ public class GenTableRelationServiceImpl implements IGenTableRelationService {
      */
     @Override
     public int updateGenTableRelation(GenTableRelation genTableRelation) {
-        return genTableRelationMapper.updateGenTableRelation(genTableRelation);
+        int i = genTableRelationMapper.updateGenTableRelation(genTableRelation);
+        remoteGenTableService.loadTable(new GenTable());
+        return i;
     }
 
     /**
@@ -71,6 +81,8 @@ public class GenTableRelationServiceImpl implements IGenTableRelationService {
      */
     @Override
     public int deleteGenTableRelation(Long[] ids) {
-        return genTableRelationMapper.deleteGenTableRelation(ids);
+        int i = genTableRelationMapper.deleteGenTableRelation(ids);
+        remoteGenTableService.loadTable(new GenTable());
+        return i;
     }
 }

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

@@ -19,6 +19,7 @@ import com.boman.common.log.enums.BusinessType;
 import com.boman.domain.RoleEnum;
 import com.boman.domain.TableSql;
 
+import com.boman.gen.api.RemoteGenTableService;
 import com.boman.gen.mapper.GenTableRelationMapper;
 import com.boman.system.api.RemoteSysMenuService;
 import com.boman.system.api.domain.SysMenu;
@@ -75,6 +76,9 @@ public class GenTableServiceImpl implements IGenTableService {
     @Autowired
     private GenTableRelationMapper genTableRelationMapper;
 
+    @Autowired
+    private RemoteGenTableService remoteGenTableService;
+
     /**
      * 查询业务信息
      *
@@ -187,6 +191,7 @@ public class GenTableServiceImpl implements IGenTableService {
                 tableColumnService.updateGenTableColumn(cenTableColumn);
             }
         }
+        remoteGenTableService.loadTable(new GenTable());
     }
 
     /**
@@ -203,6 +208,7 @@ public class GenTableServiceImpl implements IGenTableService {
         tableSqlService.deleteTableSqlByTableIds(tableIds);
         //删除关联关系
         genTableRelationMapper.deleteGenTableRelationByParentId(tableIds);
+        remoteGenTableService.loadTable(new GenTable());
     }
 
     /**
@@ -450,6 +456,7 @@ public class GenTableServiceImpl implements IGenTableService {
             TableSql tableSql = new TableSql();
             tableSql.setTableId(genTable.getTableId());
             tableSqlService.insertTableSql(tableSql);
+            remoteGenTableService.loadTable(new GenTable());
             return AjaxResult.success();
         }
         return AjaxResult.error();