| | |
| | | // 异步保存任务明细信息并发送短信 |
| | | CompletableFuture.runAsync(() -> { |
| | | smsTaskDetailService.saveBatch(smsTaskDetailDOList); |
| | | sendSmsToAll(smsTaskDetailDOList, smsTaskDO.getSmsTemplateId()); |
| | | sendSmsToAll(smsTaskDetailDOList, smsTaskDO.getSmsTemplateId(),smsTaskDTO.getId()); |
| | | }); |
| | | } |
| | | |
| | |
| | | }).collect(Collectors.toList()); |
| | | } |
| | | |
| | | private void sendSmsToAll(List<SmsTaskDetailDO> smsTaskDetailDOList, Long smsTemplateId) { |
| | | private void sendSmsToAll(List<SmsTaskDetailDO> smsTaskDetailDOList, Long smsTemplateId,Long id) { |
| | | SmsTemplateDO smsTemplateDO = smsTemplateMapper.selectById(smsTemplateId); |
| | | String templateCode = smsTemplateDO.getCode(); |
| | | for (SmsTaskDetailDO detail : smsTaskDetailDOList) { |
| | |
| | | } finally { |
| | | //无论如何都更新结果 |
| | | smsTaskDetailMapper.updateById(detail); |
| | | SmsTaskDO smsTaskDO = smsTaskMapper.selectById(id); |
| | | smsTaskDO.setStatus(Constants.SMS_TASK_STATUS.complete.name()); |
| | | smsTaskMapper.updateById(smsTaskDO); |
| | | } |
| | | } |
| | | } |