소스 검색

增加计算进度通知

dsx 2 년 전
부모
커밋
43ce1102fd
1개의 변경된 파일3개의 추가작업 그리고 0개의 파일을 삭제
  1. 3 0
      src/main/java/com/fdkankan/contro/mq/service/impl/BuildSceneProgressServiceImpl.java

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

@@ -93,6 +93,7 @@ public class BuildSceneProgressServiceImpl implements IBuildSceneProgressService
                 JSONObject projectJson = JSON.parseObject(projectJsonStr);
                 JSONObject state = projectJson.getJSONObject("state");
                 complete = state.getBoolean("done");
+                log.info("计算完成状态:{}", complete);
                 if(Objects.isNull(totalTime)){
                     totalTime = state.getLong("expect_time") + buildProgressTime;
                     redisUtil.set(String.format(RedisKey.SCENE_BUILD_EXPECT_TOTAL_TIME_NUM, num), String.valueOf(totalTime), RedisKey.CAMERA_EXPIRE_7_TIME);
@@ -106,6 +107,7 @@ public class BuildSceneProgressServiceImpl implements IBuildSceneProgressService
                     params.put("gps", gps);
                     params.put("totalTime", totalTime);
                     params.put("progress", mainProgress);
+                    log.info("算法完成发送请求,url:{}, param:{}",buildProgressUrl, JSON.toJSONString(params));
                     HttpUtil.post(buildProgressUrl, JSON.toJSONString(params), 2000);
                     watchMonitor.interrupt();
                 }else{
@@ -119,6 +121,7 @@ public class BuildSceneProgressServiceImpl implements IBuildSceneProgressService
                         params.put("gps", gps);
                         params.put("totalTime", totalTime);
                         params.put("progress", progress);
+                        log.info("算法进行中发送请求,url:{}, param:{}",buildProgressUrl, JSON.toJSONString(params));
                         HttpUtil.post(buildProgressUrl, JSON.toJSONString(params), 2000);
                     }
                 }