Browse Source

/*云深处机器狗终止智巡联动,更新为终止状态*/

master
htjcAdmin 3 months ago
parent
commit
3ee3fd6e70
7 changed files with 30 additions and 3 deletions
  1. +3
    -2
      inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java
  2. +9
    -0
      inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java
  3. +1
    -1
      inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/AnalyseRequestServiceImpl.java
  4. +2
    -0
      inspect-main/inspect-main-task/src/main/java/com/inspect/taskstatus/mapper/PatrolTaskStatusMapper.java
  5. +2
    -0
      inspect-main/inspect-main-task/src/main/java/com/inspect/taskstatus/service/IPatrolTaskStatusService.java
  6. +4
    -0
      inspect-main/inspect-main-task/src/main/java/com/inspect/taskstatus/service/impl/PatrolTaskStatusServiceImpl.java
  7. +9
    -0
      inspect-main/inspect-main-task/src/main/resources/mapper/task/PatrolTaskStatusMapper.xml

+ 3
- 2
inspect-main/inspect-main-task/src/main/java/com/inspect/analysis/service/impl/AnalyseResponseServiceImpl.java View File

@ -110,7 +110,7 @@ public class AnalyseResponseServiceImpl implements IAnalyseResponseService {
//redisService.setCacheObject(keyId, "123456789");
} else {
log.info("ANALYSE_REQUEST_ID: DEL {} FROM REDIS!", keyId);
redisService.deleteObject(keyId);
//redisService.deleteObject(keyId);
}
String patrolTaskIdObj = redisService.getCacheObject(keyId);
@ -168,7 +168,8 @@ public class AnalyseResponseServiceImpl implements IAnalyseResponseService {
|| AlgConstants.INFRA_YU3.equals(algType)
|| AlgConstants.INFRA_CAMERA.equals(algType)
|| AlgConstants.INFRA_CAMERA_REVERSE.equals(algType)
|| AlgConstants.INFRARED2.equals(algType))
|| AlgConstants.INFRARED2.equals(algType)
|| "isolator".equals(algType))
) {
/*
* 先检查结果有缺无缺陷如果有缺陷不用判断算法直接调用大模型*


+ 9
- 0
inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java View File

@ -1162,6 +1162,15 @@ public class PatrolResultController extends BaseController {
|| patrolTaskStatusItem.getTaskState().equals(TaskStatus.EXPIRED.getCode()))) {
patrolTaskStatusItem.setTaskState(patrolTaskStatusItem.getTaskState());
patrolTaskStatusItem.setEndTime(DateUtils.parseDateToStr(DateUtils.yyyyMMddHHmmss2, new Date()));
List<PatrolTaskStatus> statusList = patrolTaskStatusService.selectPatrolTaskStatusList(PatrolTaskStatus.builder().taskPatrolledId(patrolTaskStatusItem.getTaskPatrolledId()).build());
if (!statusList.isEmpty()) {
PatrolTaskStatus taskStatus = statusList.get(0);
taskStatus.setTaskState(patrolTaskStatusItem.getTaskState());
taskStatus.setEndTime(DateUtils.parseDateToStr(DateUtils.yyyyMMddHHmmss2, new Date()));
logger.info("GET_INFO_41 UPDATE TASK_STATE TO HALTED taskStatus: {}", taskStatus);
iPatrolTaskStatusService.updatePatrolTaskStatusOfTaskStateAndEndTime(taskStatus);
}
}
List<PatrolTaskStatus> patrolTaskStatusList = iPatrolTaskStatusService.selectPatrolTaskStatusList(patrolTaskStatus);
logger.info("GET_INFO_41 ROBOT_TASK_STATUS patrolTaskStatusList: {}", patrolTaskStatusList);


+ 1
- 1
inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/AnalyseRequestServiceImpl.java View File

@ -56,7 +56,7 @@ public class AnalyseRequestServiceImpl implements IAnalyseRequestService {
String requestId = StringUtils.isNotEmpty(analyseReq.getRequestId()) ?
analyseReq.getRequestId() : UUID.randomUUID().toString().trim().replaceAll(StringUtils.DASH, StringUtils.EMPTY);
String taskPatrolId = analyseReq.getTaskPatrolId();
// redisService.setCacheObject(RedisConst.REQUEST_UUID + requestId, taskPatrolId, requestTimeout, TimeUnit.DAYS);
redisService.setCacheObject(RedisConst.REQUEST_UUID + requestId, taskPatrolId, requestTimeout, TimeUnit.DAYS);
//log.info("CALL_REMOTE_ANALYZE isFilter: {}, requestId: {}, taskPatrolId: {}", isFilter, requestId, taskPatrolId);
analyseReq.setRequestId(requestId);


+ 2
- 0
inspect-main/inspect-main-task/src/main/java/com/inspect/taskstatus/mapper/PatrolTaskStatusMapper.java View File

@ -28,6 +28,8 @@ public interface PatrolTaskStatusMapper {
int updatePatrolTaskStatusOfTaskState(PatrolTaskStatus patrolTaskStatus);
int updatePatrolTaskStatusOfTaskStateAndEndTime(PatrolTaskStatus patrolTaskStatus);
int updatePatrolTaskStatusRunning(PatrolTaskStatus patrolTaskStatus);
int deletePatrolTaskStatusByLineId(Long lineId);


+ 2
- 0
inspect-main/inspect-main-task/src/main/java/com/inspect/taskstatus/service/IPatrolTaskStatusService.java View File

@ -26,6 +26,8 @@ public interface IPatrolTaskStatusService {
int updatePatrolTaskStatusOfTaskState(PatrolTaskStatus patrolTaskStatus);
int updatePatrolTaskStatusOfTaskStateAndEndTime(PatrolTaskStatus patrolTaskStatus);
int updatePatrolTaskStatusRunning(PatrolTaskStatus patrolTaskStatus);
int deletePatrolTaskStatusByLineIds(Long[] lineIds);


+ 4
- 0
inspect-main/inspect-main-task/src/main/java/com/inspect/taskstatus/service/impl/PatrolTaskStatusServiceImpl.java View File

@ -67,6 +67,10 @@ public class PatrolTaskStatusServiceImpl implements IPatrolTaskStatusService {
return this.patrolTaskStatusMapper.updatePatrolTaskStatusOfTaskState(patrolTaskStatus);
}
public int updatePatrolTaskStatusOfTaskStateAndEndTime(PatrolTaskStatus patrolTaskStatus) {
return this.patrolTaskStatusMapper.updatePatrolTaskStatusOfTaskStateAndEndTime(patrolTaskStatus);
}
public int updatePatrolTaskStatusRunning(PatrolTaskStatus patrolTaskStatus) {
return this.patrolTaskStatusMapper.updatePatrolTaskStatusRunning(patrolTaskStatus);
}


+ 9
- 0
inspect-main/inspect-main-task/src/main/resources/mapper/task/PatrolTaskStatusMapper.xml View File

@ -280,6 +280,15 @@
where line_id = #{lineId}
</update>
<update id="updatePatrolTaskStatusOfTaskStateAndEndTime" parameterType="PatrolTaskStatus">
update patrol_task_status
<trim prefix="SET" suffixOverrides=",">
<if test="taskState != null">task_state = #{taskState},</if>
<if test="endTime != null">end_time = #{endTime},</if>
</trim>
where line_id = #{lineId}
</update>
<delete id="deletePatrolTaskStatusByLineId" parameterType="Long">
delete
from patrol_task_status


Loading…
Cancel
Save