微调

integrate-system/src/main/java/com/system/serivce/impl/DatabaseTableServiceImpl.java

 package com.system.serivce.impl;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.system.dao.DatabaseTableMapper;
-import com.system.dao.KingDeeCommonConfigMapper;
-import com.system.dao.KingDeeFieldMappingMapper;
-import com.system.dao.PlatformProductRelationMapper;
+import com.system.dao.*;
 import com.system.enums.ProductAdapterEnum;
 import com.system.serivce.IDatabaseTableService;
 import com.system.transfer.kingdee.KingDeeCommonConfigListOutVoRecords;
 import com.system.transfer.kingdee.KingDeeFieldMappingListOutVoRecords;
+import com.system.transfer.mall.MallCommonConfigListOutVoRecords;
+import com.system.transfer.mall.MallFieldMappingListOutVoRecords;
 import com.system.transfer.product.PlatformProductRelationListOutVoRecords;
 import com.system.transfer.response.RestResponse;
 import com.system.transfer.table.*;
@@ -41,6 +40,12 @@ public class DatabaseTableServiceImpl implements IDatabaseTableService {
     private KingDeeFieldMappingMapper kingDeeFieldMappingMapper;
 
     @Autowired
+    private MallCommonConfigMapper mallCommonConfigMapper;
+
+    @Autowired
+    private MallFieldMappingMapper mallFieldMappingMapper;
+
+    @Autowired
     private PlatformProductRelationMapper platformProductRelationMapper;
 
 
@@ -167,17 +172,27 @@ public class DatabaseTableServiceImpl implements IDatabaseTableService {
         if (ProductAdapterEnum.KING_DEE_QUARTZ_JOB.getKey().equals(records.getProductBeforeCode())) {
             KingDeeCommonConfigListOutVoRecords temp01 = kingDeeCommonConfigMapper.getKingDeeCommonConfigById(inVo.getConfigId());
             if (StringUtil.isNull(temp01)) {
-                return RestResponse.fail("通用配置不存在");
+                return RestResponse.fail("金蝶通用配置不存在");
             }
-            List<KingDeeFieldMappingListOutVoRecords> recordsList = kingDeeFieldMappingMapper.getKingdeeFieldMappingListByConfigIdList(Stream.of(temp01.getId()).collect(Collectors.toList()));
+            List<KingDeeFieldMappingListOutVoRecords> fieldList = kingDeeFieldMappingMapper.getKingdeeFieldMappingListByConfigIdList(Stream.of(temp01.getId()).collect(Collectors.toList()));
 
-            String formJson = TableStructureUtil.getFormGenerator(temp01.getDocType(), temp01.getSFormId(), temp01.getName(), recordsList);
+            String formJson = TableStructureUtil.getFormGeneratorByKingDee(temp01.getDocType(), temp01.getSFormId(), temp01.getName(), fieldList);
             databaseTableMapper.tableStructureCreate(new TableStructureCreateInVo(temp01.getDocType(), temp01.getSFormId().toLowerCase(), temp01.getName(), formJson));
 
             TableStructureCreateInVo temp02 = new TableStructureCreateInVo(temp01.getSFormId().toLowerCase(), "'" + temp01.getName() + "'");
-            databaseTableMapper.databaseTableCreateByCommonConfig(temp02, TableStructureUtil.getDbTableFiledDataByKingDee(recordsList));
+            databaseTableMapper.databaseTableCreateByCommonConfig(temp02, TableStructureUtil.getDbTableFiledDataByKingDee(fieldList));
         } else if (ProductAdapterEnum.MALL_QUARTZ_JOB.getKey().equals(records.getProductBeforeCode())) {
+            MallCommonConfigListOutVoRecords temp01 = mallCommonConfigMapper.getMallCommonConfigById(inVo.getConfigId());
+            if (StringUtil.isNull(temp01)) {
+                return RestResponse.fail("商城通用配置不存在");
+            }
+            List<MallFieldMappingListOutVoRecords> fieldList = mallFieldMappingMapper.getMallFieldMappingListByConfigIdList(Stream.of(temp01.getId()).collect(Collectors.toList()));
+
+            String formJson = TableStructureUtil.getFormGeneratorByMall(temp01.getDocType(), temp01.getSFormId(), temp01.getName(), fieldList);
+            databaseTableMapper.tableStructureCreate(new TableStructureCreateInVo(temp01.getDocType(), temp01.getSFormId().toLowerCase(), temp01.getName(), formJson));
 
+            TableStructureCreateInVo temp02 = new TableStructureCreateInVo(temp01.getSFormId().toLowerCase(), "'" + temp01.getName() + "'");
+            databaseTableMapper.databaseTableCreateByCommonConfig(temp02, TableStructureUtil.getDbTableFiledDataByMall(fieldList));
         }
 
         return RestResponse.success();

integrate-system/src/main/java/com/system/utils/TableStructureUtil.java

 package com.system.utils;
 
 import com.system.transfer.kingdee.KingDeeFieldMappingListOutVoRecords;
+import com.system.transfer.mall.MallFieldMappingListOutVoRecords;
 import com.system.transfer.table.TableStructureCreateInVo;
 import com.system.transfer.table.TableStructureCreateInVoRecords;
 import com.system.transfer.table.TableStructureDataOutVoRecords;
@@ -19,7 +20,7 @@ public class TableStructureUtil {
     private final static String FIELD = "{\"label\":\"\",\"type\":\"input\",\"options\":{\"width\":\"100%\",\"defaultValue\":\"\",\"placeholder\":\"\",\"maxlength\":null,\"prefix\":\"\",\"suffix\":\"\",\"prepend\":\"\",\"append\":\"\",\"disabled\":false,\"clearable\":false,\"readonly\":false,\"rules\":{\"trigger\":\"blur\",\"enum\":\"\",\"message\":\"\",\"pattern\":\"\",\"required\":false,\"type\":\"any\"}},\"key\":\"\",\"model\":\"\",\"rules\":[],\"dbFieldName\":\"\",\"dbFieldComment\":\"\"}";
 
 
-    public static String getFormGenerator(String docType, String sFormId, String name, List<KingDeeFieldMappingListOutVoRecords> recordsList) {
+    public static String getFormGeneratorByKingDee(String docType, String sFormId, String name, List<KingDeeFieldMappingListOutVoRecords> recordsList) {
         Map<String, Object> result = new LinkedHashMap<>();
 
         Map<String, Object> temp01 = JsonUtil.toMap(CONFIG, String.class, Object.class);
@@ -51,6 +52,38 @@ public class TableStructureUtil {
         return JsonUtil.toString(result);
     }
 
+    public static String getFormGeneratorByMall(String docType, String sFormId, String name, List<MallFieldMappingListOutVoRecords> recordsList) {
+        Map<String, Object> result = new LinkedHashMap<>();
+
+        Map<String, Object> temp01 = JsonUtil.toMap(CONFIG, String.class, Object.class);
+        temp01.put("formId", docType);
+        temp01.put("dbTableName", sFormId.toLowerCase());
+        temp01.put("dbTableComment", name);
+        result.put("config", temp01);
+
+        List<Map<String, Object>> list = new ArrayList<>();
+        Map<String, Object> temp02 = JsonUtil.toMap(FIELD, String.class, Object.class);
+        temp02.put("label", "唯一标识");
+        temp02.put("key", UUID.randomUUID().toString().replace("-", ""));
+        temp02.put("model", "queue_id");
+        temp02.put("dbFieldName", "queue_id");
+        temp02.put("dbFieldComment", "唯一标识");
+        list.add(temp02);
+
+        for (MallFieldMappingListOutVoRecords records : recordsList) {
+            Map<String, Object> temp03 = JsonUtil.toMap(FIELD, String.class, Object.class);
+            temp03.put("label", records.getFieldBeforeMappingName());
+            temp03.put("key", UUID.randomUUID().toString().replace("-", ""));
+            temp03.put("model", records.getFieldBeforeMapping().toLowerCase());
+            temp03.put("dbFieldName", records.getFieldBeforeMapping().toLowerCase());
+            temp03.put("dbFieldComment", records.getFieldBeforeMappingName());
+            list.add(temp03);
+        }
+
+        result.put("list", list);
+        return JsonUtil.toString(result);
+    }
+
     public static List<TableStructureCreateInVoRecords> getDbTableFiledDataByKingDee(List<KingDeeFieldMappingListOutVoRecords> recordsList) {
         List<TableStructureCreateInVoRecords> tempList = new ArrayList<>();
 
@@ -67,6 +100,22 @@ public class TableStructureUtil {
         return tempList;
     }
 
+    public static List<TableStructureCreateInVoRecords> getDbTableFiledDataByMall(List<MallFieldMappingListOutVoRecords> recordsList) {
+        List<TableStructureCreateInVoRecords> tempList = new ArrayList<>();
+
+        for (MallFieldMappingListOutVoRecords records : recordsList) {
+            TableStructureCreateInVoRecords temp = new TableStructureCreateInVoRecords();
+            temp.setDbFieldName(records.getFieldBeforeMapping());
+            temp.setDbFieldType(getDbTableFieldType(records.getFieldType()));
+            temp.setDbFieldDefault("NULL");
+            temp.setDbFieldComment("'" + records.getFieldBeforeMappingName() + "'");
+
+            tempList.add(temp);
+        }
+
+        return tempList;
+    }
+
     private static String getDbTableFieldType(String fieldType) {
         switch (fieldType) {
             case "数值":