Browse Source

增加计算进度通知

dsx 2 years ago
parent
commit
f342f9f129

+ 4 - 0
src/main/java/com/fdkankan/contro/mq/service/impl/BuildSceneProgressServiceImpl.java

@@ -73,6 +73,7 @@ public class BuildSceneProgressServiceImpl implements IBuildSceneProgressService
         }
         redisUtil.set(String.format(RedisKey.SCENE_BUILD_EXPECT_TOTAL_TIME_NUM, num), String.valueOf(totalTime));
         Long intervalTime = totalTime/factor;//发送计算进度时间窗口
+        log.info("推送进度时间窗口:{}", intervalTime);
 
         Map<String, Object> params = new HashMap<>();
         params.put("website", mainUrl.concat(website));
@@ -110,6 +111,9 @@ public class BuildSceneProgressServiceImpl implements IBuildSceneProgressService
                     }
                 }
             }while (!finish);
+            log.info("场景计算完成,删除计算完成redis记录,key:{}", String.format(RedisKey.SCENE_BUILD_FINISH_NUM, num));
+            redisUtil.del(String.format(RedisKey.SCENE_BUILD_FINISH_NUM, num));
+            log.info("推送计算进度结束,num:{}", num);
         });
 
 //            String projectJsonPath = path.concat(File.separator).concat("project.json");