|
@@ -96,11 +96,13 @@ public class BuildSceneProgressServiceImpl implements IBuildSceneProgressService
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
String finishStr = redisUtil.get(String.format(RedisKey.SCENE_BUILD_FINISH_NUM, num));
|
|
|
+ log.info("场景计算是否完成,num:{},是否完成:{}", num, StrUtil.isBlank(finishStr) ? false : true);
|
|
|
//计算结果处理消费者消费完毕后,会发送一次进度为100的消息,这里就不需要再做任务操作,
|
|
|
if(StrUtil.isNotEmpty(finishStr)){
|
|
|
finish = true;
|
|
|
}else{
|
|
|
mainProgress += factor;
|
|
|
+ log.info("mainProgress:{}", mainProgress);
|
|
|
//如果预估的时间比实际的时间要慢,那么这里的进度条会草超过100,所以当超过100时,不需要再发送进度了,只需要等计算结果处理监听中的计算完毕去发送100即可
|
|
|
if(mainProgress >= 100){
|
|
|
finish = true;
|