| | |
|---|
| | | if (pushResult != null && !pushResult.isSuccess()) { |
|---|
| | | String errorMsg = pushResult.getMsg(); |
|---|
| | | log.error("推送星图飞行任务失败: {}", errorMsg); |
|---|
| | | throw new RuntimeException("推送星图飞行任务失败: " + errorMsg); |
|---|
| | | throw new RuntimeException(errorMsg + "，请更改执行时间重新提交。"); |
|---|
| | | } |
|---|
| | | // 查询同一个工单下的所有子任务 |
|---|
| | | List<GdPatrolTaskEntity> subTasks = list(Wrappers.<GdPatrolTaskEntity>lambdaQuery() |
|---|
| | |
|---|
| | | // 1. 更新当前任务状态 |
|---|
| | | boolean updateResult = updateById(auditParam); |
|---|
| | | if (!updateResult) { |
|---|
| | | log.warn("更新任务失败，任务ID: {}"); |
|---|
| | | log.warn("更新任务失败，任务ID: {}", auditParam.getId()); |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | GdPatrolTaskEntity patrolTaskEntity = Optional.ofNullable(getById(auditParam.getId())) |
|---|
| | | .orElseThrow(() -> new RuntimeException("任务不存在，任务ID: " + auditParam.getId())); |
|---|
| | | |
|---|
| | | // 3. 保存巡查工单流转 |
|---|
| | | saveWorkOrderFlow(patrolTaskEntity.getWorkOrderId(), PatrolTaskStatusEnum.PENDING_ACCEPTANCE, null, null); |
|---|
| | | // 3. 保存巡查工单流转（使用传入的实际状态） |
|---|
| | | PatrolTaskStatusEnum statusEnum = PatrolTaskStatusEnum.getByValue(auditParam.getTaskStatus()); |
|---|
| | | if (statusEnum != null) { |
|---|
| | | saveWorkOrderFlow(patrolTaskEntity.getId(), statusEnum, null, patrolTaskEntity.getAreaCode()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 4. 查询同一个工单下的所有子任务 |
|---|
| | | List<GdPatrolTaskEntity> subTasks = list(Wrappers.<GdPatrolTaskEntity>lambdaQuery() |
|---|
