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