Browse Source

Merge branch 'develop' of gitadmin/tuoheng_lc into release

tags/v1.2.0^2
wanjing 1 year ago
parent
commit
a0742360cb
5 changed files with 7 additions and 16 deletions
  1. +1
    -6
      tuoheng-admin/src/main/java/com/tuoheng/admin/entity/domain/ThMission.java
  2. +2
    -4
      tuoheng-admin/src/main/java/com/tuoheng/admin/service/impl/ThInspectionServiceImpl.java
  3. +1
    -1
      tuoheng-admin/src/main/java/com/tuoheng/admin/service/mission/query/QueryEmergencyListService.java
  4. +1
    -4
      tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/UpdateEmergencyMissionStatusService.java
  5. +2
    -1
      tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/airport/PointFlightService.java

+ 1
- 6
tuoheng-admin/src/main/java/com/tuoheng/admin/entity/domain/ThMission.java View File

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
*/ */

+ 2
- 4
tuoheng-admin/src/main/java/com/tuoheng/admin/service/impl/ThInspectionServiceImpl.java View File

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<>();

+ 1
- 1
tuoheng-admin/src/main/java/com/tuoheng/admin/service/mission/query/QueryEmergencyListService.java View File

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)) {

+ 1
- 4
tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/UpdateEmergencyMissionStatusService.java View File

*/ */
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()) {

+ 2
- 1
tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/airport/PointFlightService.java View File

// 创建应急任务 // 创建应急任务
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);

Loading…
Cancel
Save