Browse Source

联合巡视任务报告修改还原

master
lijiuwei 8 months ago
parent
commit
52721e75ba
6 changed files with 13 additions and 16 deletions
  1. +3
    -2
      inspect-base/inspect-base-core/src/main/java/com/inspect/base/core/constant/RedisConst.java
  2. +0
    -1
      inspect-job/src/main/java/com/inspect/job/task/JobMainTask.java
  3. +1
    -0
      inspect-main/inspect-main-task-exec/src/main/java/com/inspect/exec/controller/PatrolTaskExecuteSchedulerController.java
  4. +1
    -7
      inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java
  5. +5
    -3
      inspect-main/inspect-main-task/src/main/java/com/inspect/task/controller/PatrolTaskController.java
  6. +3
    -3
      inspect-main/inspect-main-task/src/main/java/com/inspect/taskstatus/controller/PatrolTaskStatusController.java

+ 3
- 2
inspect-base/inspect-base-core/src/main/java/com/inspect/base/core/constant/RedisConst.java View File

@ -6,8 +6,9 @@ public class RedisConst {
public static final String TASK_CODE = "TASK_CODE@";//已经和taskcode关联
public static final String REQUEST_UUID = "REQUEST_UUID@";//已经和uuid关联
public static final String TASK_PATROL_ID = "TASK_PATROL_ID";
public static final String TASK_PATROL_STATE = "TASK_PATROL_STATE";
public static final String TASK_PATROL_ID = "TASK_PATROL_ID";//应该没用到
public static final String TASK_PATROL_STATE = "TASK_PATROL_STATE";//应该没用到
public static final String TASK_RECORD_CNT = "TASK_RECORD_CNT";
public static final String TASK_CURRENT_CODE = "TASK_CURRENT_CODE@";
public static final String IMMEDIATELY_EXEC_TASK_TIME = "IMMEDIATELY_EXEC_TASK_TIME";


+ 0
- 1
inspect-job/src/main/java/com/inspect/job/task/JobMainTask.java View File

@ -726,7 +726,6 @@ public class JobMainTask {
totalProgress,
TaskStatus.DONE.getCode()/*点位全部执行成功,上报进度100%*/
);
//在不知道其它record是否执行完毕的情况下不能把TASK_CURRENT_CODE锁删除
final int redisRecCnt = redisService.getCacheObject(RedisConst.TASK_RECORD_CNT);
log.info(Color.MAGENTA + "[JOB] TIMES 0, execRecordCounter: {}, redisRecCnt: {}" + Color.END, execRecordCounter, redisRecCnt);
if (execRecordCounter == redisRecCnt) {


+ 1
- 0
inspect-main/inspect-main-task-exec/src/main/java/com/inspect/exec/controller/PatrolTaskExecuteSchedulerController.java View File

@ -99,6 +99,7 @@ public class PatrolTaskExecuteSchedulerController extends BaseController {
@Autowired
AccessFeign accessFeign;
//和JobMainTask完全重复
@PostMapping({"/immediatelyExecTask"})
public void immediatelyExecTask(PatrolTask patrolTask) {
PatrolTaskInfo patrolTaskInfo = new PatrolTaskInfo();


+ 1
- 7
inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java View File

@ -1194,15 +1194,9 @@ public class PatrolResultController extends BaseController {
List<PatrolTask> tasks = patrolTaskService.selectPatrolTaskList(PatrolTask.builder().taskCode(code).build());
String datetype;
if (!tasks.isEmpty()) {
int devCount = tasks.get(0).getDevNo().split(",").length;
PatrolTaskResultMain taskResultMain = new PatrolTaskResultMain();
taskResultMain.setTaskId(String.valueOf(tasks.get(0).getTaskId()));
if(devCount > 1) {
taskResultMain.setFileStatus("0");
} else {
taskResultMain.setTaskPatrolledId(eqList.get(0).getTaskPatrolledId());
}
taskResultMain.setTaskPatrolledId(eqList.get(0).getTaskPatrolledId());
logger.info("taskResultMain: {}", taskResultMain);
listEqpBook = iPatrolTaskResultMainService.selectPatrolTaskResultMainList(taskResultMain);
if (!listEqpBook.isEmpty()) {


+ 5
- 3
inspect-main/inspect-main-task/src/main/java/com/inspect/task/controller/PatrolTaskController.java View File

@ -678,12 +678,12 @@ public class PatrolTaskController extends BaseController {
}
public void issueTask(PatrolTask patrolTask) {
String rebootCode = patrolTaskService.selectConfigByKey("rebootCode");
String uavCode = patrolTaskService.selectConfigByKey("uavCode");
String rebootCode = patrolTaskService.selectConfigByKey("rebootCode");//robotCode
String uavCode = patrolTaskService.selectConfigByKey("uavCode");//droneCode
String receiveCode = "";
String sendCode = "";
BasedataEqpBookMoMain based = new BasedataEqpBookMoMain();
based.setType("20");
based.setType("20");//巡视主机
List<BasedataEqpBookMoMain> basedataEqpBookMoMains = patrolResultService.selectBasedataEqpBookList(based);
if (!basedataEqpBookMoMains.isEmpty()) {
sendCode = basedataEqpBookMoMains.get(0).getPatrolDeviceCode();
@ -882,6 +882,7 @@ public class PatrolTaskController extends BaseController {
String str = JSONObject.toJSONString(sendTask);
logger.info("-----------------sendTask: " + str);
if (StringUtils.isEmpty(receiveCode)) {
//手工巡视任务会进入这里不下发
continue;
}
feignTaskClient.sendCommand(str);
@ -1085,6 +1086,7 @@ public class PatrolTaskController extends BaseController {
String str = JSONObject.toJSONString(sendTask);
System.out.println(str);
if (StringUtils.isEmpty(receiveCode)) {
//手工巡视任务会进入这里不下发
return;
}
feignTaskClient.sendCommand(str);


+ 3
- 3
inspect-main/inspect-main-task/src/main/java/com/inspect/taskstatus/controller/PatrolTaskStatusController.java View File

@ -176,7 +176,6 @@ public class PatrolTaskStatusController extends BaseController {
}
ResultAnalysis resultAnalysis = new ResultAnalysis();
log.info(Color.GREEN + "[TASK STATUS] taskPatrolledId: {}" + Color.END, item.getTaskPatrolledId());
resultAnalysis.setTaskPatrolledId(item.getTaskPatrolledId());
ResultAnalysis analysisRes = resultAnalysisService.selectTaskAbnormalData(resultAnalysis);
@ -701,8 +700,9 @@ public class PatrolTaskStatusController extends BaseController {
return toAjax(res);
}
//没有用到
public void issueTask(PatrolTaskStatus patrolTaskStatus) {
String posType = patrolTaskStatus.getPosType();
String posType = patrolTaskStatus.getPosType();//预置位类型 0-视频 1-机器人 2-无人机
if (StringUtils.isEmpty(posType)) {
log.warn("[TASK] posType is null");
return;
@ -750,7 +750,7 @@ public class PatrolTaskStatusController extends BaseController {
/**
* Calc wrj code
*/
Set<String> wrjCode = new HashSet<>();
Set<String> wrjCode = new HashSet<>();//droneCode
for (BasedataEqpBookMoMain book : bookList) {
final String type = book.getType();
if (!type.equals("1") && !type.equals("2") && !type.equals("3") && !type.equals("13")) {


Loading…
Cancel
Save