|
|
|
@ -835,6 +835,10 @@ public class AnalyseResponseServiceImpl implements IAnalyseResponseService { |
|
|
|
} |
|
|
|
|
|
|
|
// 计算初筛算法的进度 |
|
|
|
log.info("BEFORE_FILTER_PROGRESS CALC filter: {}, totalNumber: {}, resultList: {}", |
|
|
|
analyseResult.getFilter(), |
|
|
|
analyseResult.getTotalNumber(), |
|
|
|
analyseResult.getResultList()); |
|
|
|
if ("1".equals(analyseResult.getFilter()) && !analyseResult.getResultList().isEmpty()) { |
|
|
|
final String objectId = analyseResult.getResultList().get(0).getObjectId(); |
|
|
|
calcRemoteAlgorithmProgress(analyseResult.getTaskPatrolId(), objectId, analyseResult.getTotalNumber()); |
|
|
|
@ -887,6 +891,7 @@ public class AnalyseResponseServiceImpl implements IAnalyseResponseService { |
|
|
|
} |
|
|
|
|
|
|
|
private void calcRemoteAlgorithmProgress(final String taskPatrolledId, final String objectId, final int totalNumber) { |
|
|
|
log.info("CALC_REMOTE_ALGORITHM_PROGRESS taskPatrolId: {}, objectId: {}, totalNumber: {}", taskPatrolledId, objectId, totalNumber); |
|
|
|
ResultAnalysis resultAnalysis = new ResultAnalysis(); |
|
|
|
resultAnalysis.setTaskPatrolId(taskPatrolledId); |
|
|
|
resultAnalysis.setFilter("1"); |
|
|
|
@ -898,6 +903,7 @@ public class AnalyseResponseServiceImpl implements IAnalyseResponseService { |
|
|
|
PatrolTaskStatus patrolTaskStatus = new PatrolTaskStatus(); |
|
|
|
patrolTaskStatus.setTaskPatrolledId(taskPatrolledId); |
|
|
|
List<PatrolTaskStatus> patrolTaskStatusList = patrolTaskStatusService.selectPatrolTaskStatusList(patrolTaskStatus); |
|
|
|
log.info("CALC_REMOTE_ALGORITHM_PROGRESS patrolTaskStatusList size: {}", patrolTaskStatusList.size()); |
|
|
|
if (!patrolTaskStatusList.isEmpty()) { |
|
|
|
patrolTaskStatus = patrolTaskStatusList.get(0); |
|
|
|
patrolTaskStatus.setTaskEstimatedTime(algorithmProgress); |
|
|
|
|