| | |
| | | import com.ruoyi.task.domain.SendMagParam; |
| | | import com.ruoyi.task.service.IServiceSubtaskRecordService; |
| | | import com.ruoyi.task.mapper.ServiceSubtaskPreachformMapper; |
| | | import com.ruoyi.task.event.FollowupCompletedEventPublisher; |
| | | import com.ruoyi.patarchive.mapper.PatArchiveMapper; |
| | | @Slf4j |
| | | @Component//监听此队列 |
| | |
| | | |
| | | @Value("${req_path}") |
| | | private String req_path; |
| | | |
| | | @Autowired |
| | | private FollowupCompletedEventPublisher followupCompletedEventPublisher; |
| | | |
| | | @Autowired |
| | | private IServiceOutPathService iServiceOutPathService; |
| | |
| | | serviceSubtask.setSendstate(6L); |
| | | } |
| | | serviceSubtaskMapper.updateServiceSubtask(serviceSubtask); |
| | | if (Long.valueOf(6L).equals(serviceSubtask.getSendstate())) { |
| | | followupCompletedEventPublisher.publish(serviceSubtask.getId()); |
| | | } |
| | | |
| | | // 更新当前发送方式明细;发送成功时允许当前行已经是 sendstate=2。 |
| | | currentPreachformRow.setSendstate(failSendstate); |