瀏覽代碼

迁移逻辑中添加迁移DMP中台有但BDTP中台没有的标准信息点定义逻辑

lijie 3 年之前
父節點
當前提交
d522df5b8a

+ 9 - 0
dmp-business/dmp-rwd/src/main/java/com/persagy/dmp/rwd/migrate/dao/DigitalMigrateMapper.java

@@ -61,4 +61,13 @@ public interface DigitalMigrateMapper {
      * Update By lijie 2021/10/25 11:57
      */
     void migrateStandardDefineType(String schema);
+    /***
+     * Description: 迁移DMP已有但BDTP没有的标准信息点定义
+     * @param schema : DMP的库名称
+     * @return : void
+     * @author : lijie
+     * @date :2021/10/25 11:57
+     * Update By lijie 2021/10/25 11:57
+     */
+    void migrateStandardDefineInfo(String schema);
 }

+ 11 - 3
dmp-business/dmp-rwd/src/main/java/com/persagy/dmp/rwd/migrate/service/impl/DigitalMigrateServiceImpl.java

@@ -32,7 +32,7 @@ public class DigitalMigrateServiceImpl implements IDigitalMigrateService {
         // 项目数据迁移
         for(String projectId:projectIds) {
             projectId = projectId.toLowerCase();
-            doMigrate(schema, groupCode, projectId);
+            //doMigrate(schema, groupCode, projectId);
         }
     }
 
@@ -43,11 +43,11 @@ public class DigitalMigrateServiceImpl implements IDigitalMigrateService {
      */
     private void doMigrate(String schema, String groupCode) {
         // 1.迁移旧DMP中台与新BDTP中台差异的标准类型定义数据
-        log.info(StrUtil.format("正在处理{}集团:迁移类型定义数据...", groupCode));
+        log.info(StrUtil.format("正在处理{}集团:迁移标准类型定义数据...", groupCode));
         try {
             dao.migrateStandardDefineType(schema);
         } catch (Exception e) {
-            log.error(StrUtil.format("正在处理{}集团:迁移类型定义数据失败:{}", groupCode, e.getMessage()));
+            log.error(StrUtil.format("正在处理{}集团:迁移标准类型定义数据失败:{}", groupCode, e.getMessage()));
         }
         // 2.迁移集团自定义的类型定义数据
         log.info(StrUtil.format("正在处理{}集团:迁移类型定义数据...", groupCode));
@@ -56,6 +56,14 @@ public class DigitalMigrateServiceImpl implements IDigitalMigrateService {
         } catch (Exception e) {
             log.error(StrUtil.format("正在处理{}集团:迁移类型定义数据失败:{}", groupCode, e.getMessage()));
         }
+        // 3.迁移旧DMP中台与新BDTP中台差异的标准信息点定义数据
+        log.info(StrUtil.format("正在处理{}集团:迁移标准信息点定义数据...", groupCode));
+        try {
+            dao.migrateStandardDefineInfo(schema);
+        } catch (Exception e) {
+            log.error(StrUtil.format("正在处理{}集团:迁移标准信息点定义数据失败:{}", groupCode, e.getMessage()));
+        }
+        // 4.迁移集团自定义的信息点定义数据
         log.info(StrUtil.format("正在处理{}集团:迁移信息点定义数据...", groupCode));
         try {
             dao.migrateDefineInfo(schema, groupCode);

File diff suppressed because it is too large
+ 4115 - 4
dmp-business/dmp-rwd/src/main/resources/db/init/data.sql


+ 29 - 11
dmp-business/dmp-rwd/src/main/resources/mapper/DigitalMigrateMapper.xml

@@ -77,17 +77,35 @@
                `alias_name`,`obj_type`,`group_code`,`project_id`,`major_code`,
                `system_code`,`equipment_code`,`parent_code`,null,'0',
                date_format(now(), '%Y%m%d%h%i%s'),null,null,1
-        FROM (
-         SELECT
-             *
-         FROM
-             `${schema}`.rwd_def_class AS rdc
-         WHERE
-             CONCAT( rdc.CODE, '_', rdc.obj_type ) NOT IN ( SELECT CONCAT( CODE, '_', obj_type ) FROM dt_define_type WHERE group_code = '0' AND project_id = '0' )
-         ORDER BY
-             rdc.obj_type
-         )
-
+        FROM (SELECT * FROM `${schema}`.rwd_def_class AS rdc
+         WHERE CONCAT( rdc.CODE, '_', rdc.obj_type ) NOT IN ( SELECT CONCAT( CODE, '_', obj_type ) FROM dt_define_type WHERE group_code = '0' AND project_id = '0' )
+         ) AS define_type
+    </insert>
+    <insert id="migrateStandardDefineInfo">
+        replace into `dt_define_info`(`id`,`code`,`name`,`alias_code`,
+                                      `alias_name`,`class_code`,`group_code`,`project_id`,`category`,
+                                      `first_tag`,`second_tag`,`priority`,`input_mode`,`unit`,`data_type`,
+                                      `is_multiple`,`is_region`,`formater`,`data_source`,`remark`,
+                                      `sub_flag`,`weak_point`,`show_order`,`version`,
+                                      `creator`,`creation_time`,`modifier`,`modified_time`,`valid`)
+        SELECT `id`,`code`,`name`,`alias_code`,
+               `alias_name`,`class_code`,`group_code`,`project_id`,`category`,
+               `first_tag`,`second_tag`,`priority`,`input_mode`,`unit`,`data_type`,
+               `is_multiple`,`is_region`,`formater`,`data_source`,`note`,
+               `sub_flag`,`weak_point`,null,null,
+               '0',date_format(now(), '%Y%m%d%h%i%s'),null,null,1
+        FROM (SELECT * FROM `${schema}`.rwd_def_funcid AS rdf
+             WHERE
+                     CONCAT( rdf.CODE, '_', rdf.class_code, '_', rdf.group_code, '_', rdf.project_id ) NOT IN (
+                     SELECT
+                         CONCAT( CODE, '_', class_code, '_', group_code, '_', project_id )
+                     FROM
+                         dt_define_info
+                     WHERE
+                         group_code = '0'
+                       AND project_id = '0'
+                 )
+        ) AS define_info
     </insert>
 
 </mapper>