Forráskód Böngészése

增加迁移异常处理

欧阳劲驰 3 hete
szülő
commit
d88a44c199

+ 6 - 11
src/main/java/com/shkpr/service/aimodelpower/components/DataMigrator.java

@@ -62,18 +62,13 @@ public class DataMigrator {
         waterVolumeCollector.collectRawData(previousHours, orgName);
 
         //迁移预测库
-        Boolean predictMigrated = waterVolumePredictService.migrateData(orgName);
-        if (!predictMigrated) {
-            long end = System.currentTimeMillis();
+        try {
+            Boolean predictMigrated = waterVolumePredictService.migrateData(orgName);
+            if (!predictMigrated) LogPrintMgr.getInstance().printLogMsg(LogLevelFlag.LOG_INFO, mBizType, mStrClassName
+                    , String.format("执行迁预测数据失败,组织名称:%s", orgName));
+        } catch (Exception e) {
             LogPrintMgr.getInstance().printLogMsg(LogLevelFlag.LOG_INFO, mBizType, mStrClassName
-                    , String.format(
-                            "执行迁移水量数据失败,组织名称:%s,用时(毫秒):%d",
-                            orgName
-                            , (end - begin)
-                    )
-            );
-
-            return;
+                    , String.format("执行迁预测数据异常,组织名称:%s,error:%s", orgName, e));
         }
 
         //训练模型