| | |
| | | * @return 是否推送成功 |
| | | */ |
| | | @Override |
| | | @Transactional |
| | | public boolean pushTaskStatusToLegacy(Long taskId) { |
| | | if (!legacyConfig.isEnabled()) { |
| | | // log.info("旧系统同步已禁用,跳过状态推送,任务ID: {}", taskId); |
| | |
| | | // 转换为旧系统状态码 |
| | | Integer targetStatusCode = TaskStatusPushConverter.convertToLegacyStatus(newTaskStatus); |
| | | if (targetStatusCode == null) { |
| | | // log.debug("【新推旧】任务状态不需要推送到旧系统,任务ID: {}, 状态: {}", |
| | | // taskId, newTaskStatus.getInfo()); |
| | | log.debug("【新推旧】任务状态不需要推送到旧系统,任务ID: {}, 状态: {}", |
| | | taskId, newTaskStatus.getInfo()); |
| | | return false; |
| | | } |
| | | |
| | |
| | | // 推送状态到旧系统 |
| | | boolean result = updateLegacyTaskStatus(emergency.getLegacyDispatchOrdId(), targetStatusCode); |
| | | |
| | | if (!result) { |
| | | // log.info("【新推旧】任务状态推送成功,任务ID: {}, DispatchOrdID: {}, 旧状态: {} ({}), 新状态: {} ({})", |
| | | // taskId, emergency.getLegacyDispatchOrdId(), |
| | | // currentLegacyStatus, TaskStatusPushConverter.getLegacyStatusDescription(currentLegacyStatus), |
| | | // targetStatusCode, TaskStatusPushConverter.getLegacyStatusDescription(targetStatusCode)); |
| | | // } else { |
| | | if (result) { |
| | | log.info("【新推旧】任务状态推送成功,任务ID: {}, DispatchOrdID: {}, 旧状态: {} ({}), 新状态: {} ({})", |
| | | taskId, emergency.getLegacyDispatchOrdId(), |
| | | currentLegacyStatus, TaskStatusPushConverter.getLegacyStatusDescription(currentLegacyStatus), |
| | | targetStatusCode, TaskStatusPushConverter.getLegacyStatusDescription(targetStatusCode)); |
| | | } else { |
| | | log.error("【新推旧】任务状态推送失败,任务ID: {}, DispatchOrdID: {}", |
| | | taskId, emergency.getLegacyDispatchOrdId()); |
| | | } |