| | |
| | | return content.toString(); |
| | | } |
| | | |
| | | @Autowired |
| | | private ITaskStatusSyncService taskStatusSyncService; |
| | | /** |
| | | * 监听任务状态变更事件 |
| | | * |
| | |
| | | @Async |
| | | @EventListener |
| | | public void handleTaskStatusChangedEvent(TaskStatusChangedEvent event) { |
| | | |
| | | sendTaskStatusToLocal(event); |
| | | sendTaskStatusToLegacy(event.getTaskId()); |
| | | |
| | | } |
| | | |
| | | private void sendTaskStatusToLegacy(Long taskId) { |
| | | try{ |
| | | taskStatusSyncService.syncTaskStatusFromLegacy(taskId); |
| | | }catch (Exception e){ |
| | | log.error("任务状态同步到旧系统异常 taskId:{}",taskId, e); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | private void sendTaskStatusToLocal(TaskStatusChangedEvent event) { |
| | | try { |
| | | log.info("收到任务状态变更事件,任务ID:{},旧状态:{},新状态:{}", |
| | | event.getTaskId(), event.getOldStatus(), event.getNewStatus()); |
| | | |
| | | //发起状态同步 |
| | | // 构建状态变更内容 |
| | | String statusContent = getStatusChangeContent(event.getNewStatus(), event.getNewStatusDesc()); |
| | | |