ソースを参照

补充日志信息,便于跟踪

yucheng 3 年 前
コミット
fac7db24b9

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

@@ -54,6 +54,7 @@ public class DigitalMigrateServiceImpl implements IDigitalMigrateService {
             for(String projectId:projectIdSet) {
                 doMigrate(oldSchema, groupCode, projectId);
             }
+            log.info(StrUtil.format("结束处理{}集团:迁移完成!!!", groupCode));
         }
     }
 
@@ -69,9 +70,13 @@ public class DigitalMigrateServiceImpl implements IDigitalMigrateService {
         // 变小写
         groupCode = groupCode.toLowerCase();
         // 迁移
+        log.info(StrUtil.format("正在处理{}集团:迁移类型定义数据...", groupCode));
         dao.migrateDefineType(schema, groupCode);
+        log.info(StrUtil.format("正在处理{}集团:迁移信息点定义数据...", groupCode));
         dao.migrateDefineInfo(schema, groupCode);
+        log.info(StrUtil.format("正在处理{}集团:迁移图定义数据...", groupCode));
         dao.migrateDefineGraph(schema, groupCode);
+        log.info(StrUtil.format("正在处理{}集团:迁移边定义数据...", groupCode));
         dao.migrateDefineRel(schema, groupCode);
     }
 
@@ -86,7 +91,9 @@ public class DigitalMigrateServiceImpl implements IDigitalMigrateService {
         groupCode = groupCode.toLowerCase();
         projectId = projectId.toLowerCase();
         // 迁移
+        log.info(StrUtil.format("正在处理{}集团{}项目:迁移对象数据...", groupCode, projectId));
         dao.migrateObject(schema, groupCode, projectId);
+        log.info(StrUtil.format("正在处理{}集团{}项目:迁移关系数据...", groupCode, projectId));
         dao.migrateRelation(schema, groupCode, projectId);
     }