private String name; | private String name; | ||||
/** | /** | ||||
* 巡检任务类型 1 日常,2 应急巡检 | |||||
* 任务类型:1:巡检任务 2:应急任务 | |||||
*/ | */ | ||||
private Integer type; | private Integer type; | ||||
*/ | */ | ||||
private String requestId; | private String requestId; | ||||
/** | |||||
* 任务类型:0:巡检任务 1:应急任务 | |||||
*/ | |||||
private Integer accidentTask; | |||||
/** | /** | ||||
* 应急任务关联数据任务ID | * 应急任务关联数据任务ID | ||||
*/ | */ |
public List<InspectionVO> track(Integer id) { | public List<InspectionVO> track(Integer id) { | ||||
ThMission mission = missionMapper.selectOne(new LambdaQueryWrapper<ThMission>() | ThMission mission = missionMapper.selectOne(new LambdaQueryWrapper<ThMission>() | ||||
.eq(ThMission::getId, id) | .eq(ThMission::getId, id) | ||||
.eq(ThMission::getMark, 1)); | |||||
.eq(ThMission::getMark, MarkTypeEnum.VALID.getCode())); | |||||
if (ObjectUtil.isNull(mission)) { | if (ObjectUtil.isNull(mission)) { | ||||
throw new ServiceException("没有该任务记录"); | throw new ServiceException("没有该任务记录"); | ||||
} | } | ||||
if (ObjectUtil.isNotNull(mission.getAccidentTask()) | |||||
&& AccidentTaskEnum.ACCIDENT_TASK.getCode() == mission.getAccidentTask() | |||||
&& mission.getEmergencyDataMissionId() != 0) { | |||||
if (2 == mission.getType() && mission.getEmergencyDataMissionId() != 0) { | |||||
id = mission.getEmergencyDataMissionId(); | id = mission.getEmergencyDataMissionId(); | ||||
} | } | ||||
LambdaQueryWrapper<ThInspection> lambdaQueryWrapper = new LambdaQueryWrapper<>(); | LambdaQueryWrapper<ThInspection> lambdaQueryWrapper = new LambdaQueryWrapper<>(); |
List<ThMission> missionList = thMissionMapper.selectList(new LambdaQueryWrapper<ThMission>() | List<ThMission> missionList = thMissionMapper.selectList(new LambdaQueryWrapper<ThMission>() | ||||
.eq(ThMission::getMark, MarkEnum.VALID.getCode()) | .eq(ThMission::getMark, MarkEnum.VALID.getCode()) | ||||
.eq(ThMission::getTenantId, tenantId) | .eq(ThMission::getTenantId, tenantId) | ||||
.eq(ThMission::getAccidentTask, AccidentTaskEnum.ACCIDENT_TASK.getCode()) | |||||
.eq(ThMission::getType, 2) | |||||
.in(CollectionUtil.isNotEmpty(request.getStatusList()), ThMission::getStatus, request.getStatusList())); | .in(CollectionUtil.isNotEmpty(request.getStatusList()), ThMission::getStatus, request.getStatusList())); | ||||
if (CollectionUtil.isEmpty(missionList)) { | if (CollectionUtil.isEmpty(missionList)) { |
*/ | */ | ||||
public void updateStatus(ThMission oldMission, Integer status) { | public void updateStatus(ThMission oldMission, Integer status) { | ||||
log.info("进入修改应急任务数据"); | log.info("进入修改应急任务数据"); | ||||
if (ObjectUtil.isNull(oldMission.getAccidentTask())) { | |||||
return; | |||||
} | |||||
if (AccidentTaskEnum.INSPECTION_TASK.getCode() == oldMission.getAccidentTask()) { | |||||
if (1 == oldMission.getType()) { | |||||
return; | return; | ||||
} | } | ||||
if (0 == oldMission.getEmergencyDataMissionId()) { | if (0 == oldMission.getEmergencyDataMissionId()) { |
// 创建应急任务 | // 创建应急任务 | ||||
ThMission mission = this.createMission(user, request); | ThMission mission = this.createMission(user, request); | ||||
// 调用机场平台 | // 调用机场平台 | ||||
// 修改原巡检任务状态为已完成 | // 修改原巡检任务状态为已完成 | ||||
if (TaskStatusEnum.COMPLETE.getCode() == mission.getStatus()) { | if (TaskStatusEnum.COMPLETE.getCode() == mission.getStatus()) { | ||||
mission.setCode(code); | mission.setCode(code); | ||||
mission.setName("应急任务" + code); | mission.setName("应急任务" + code); | ||||
mission.setTenantId(user.getTenantId()); | mission.setTenantId(user.getTenantId()); | ||||
mission.setStatus(2); | |||||
mission.setInspectionType(InspectionTypeEnum.AIRPORT.getCode()); | mission.setInspectionType(InspectionTypeEnum.AIRPORT.getCode()); | ||||
mission.setAirportId(request.getAirportId()); | mission.setAirportId(request.getAirportId()); | ||||
mission.setAirportName(request.getAirportName()); | mission.setAirportName(request.getAirportName()); | ||||
mission.setInspectionLineName(""); | mission.setInspectionLineName(""); | ||||
mission.setExecutionStartTime(DateUtils.now()); | mission.setExecutionStartTime(DateUtils.now()); | ||||
mission.setStatus(TaskStatusEnum.FLIGHT.getCode()); // 设置应急任务状态为飞行中 | mission.setStatus(TaskStatusEnum.FLIGHT.getCode()); // 设置应急任务状态为飞行中 | ||||
mission.setAccidentTask(AccidentTaskEnum.ACCIDENT_TASK.getCode()); | |||||
mission.setCreateUser(user.getId()); | mission.setCreateUser(user.getId()); | ||||
mission.setCreateTime(DateUtils.now()); | mission.setCreateTime(DateUtils.now()); | ||||
Integer count = missionMapper.insert(mission); | Integer count = missionMapper.insert(mission); |