异步发送短信

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/mscase/impl/MsCaseApplicationServiceImpl.java

 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutorService;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
         application.setUpdateBy(SecurityUtils.getUsername());
         application.setUpdateTime(new Date());
         application.setBatchNumber(null);
-        // 给被申请人发送短信
-        if (affiliateMap.containsKey(application.getId())) {
-            List<MsCaseAffiliate> affiliates = affiliateMap.get(application.getId());
-            // 被申受理分配通知
-            SMSNoticeDO resNotice = new SMSNoticeDO("待缴费通知",
-                    "尊敬的用户，您的" + application.getCaseNum() + "的案件已成功提交，请登录调解系统进行缴费处理。请知晓，如非本人操作，请忽略本短信。",
-                    "2074247",
-                    new String[]{application.getCaseNum()}
-            );
-            SMSNotice notice = new SMSNotice(null,resNotice);
-            caseApplicationService.sendNotice(application,affiliates,false,notice);
-        }
+
         msCaseApplicationMapper.updateByPrimaryKeySelective(application);
         caseApplicationService.nextFlow(application.getId(), req.getCaseFlowId(),req.getLockStatus());
+        ExecutorService executor = ThreadUtil.createThreadPool();
+        CompletableFuture.runAsync(() -> {
+            // 给被申请人发送短信
+            if (affiliateMap.containsKey(application.getId())) {
+                List<MsCaseAffiliate> affiliates = affiliateMap.get(application.getId());
+                // 被申受理分配通知
+                SMSNoticeDO resNotice = new SMSNoticeDO("待缴费通知",
+                        "尊敬的用户，您的" + application.getCaseNum() + "的案件已成功提交，请登录调解系统进行缴费处理。请知晓，如非本人操作，请忽略本短信。",
+                        "2074247",
+                        new String[]{application.getCaseNum()}
+                );
+                SMSNotice notice = new SMSNotice(null,resNotice);
+                caseApplicationService.sendNotice(application,affiliates,false,notice);
+            }}, executor);
     }
 
     /**
         if(selectApplication==null){
             return;
         }
+        ExecutorService executor = ThreadUtil.createThreadPool();
+        CompletableFuture.runAsync(() -> {
         List<String> appPhones=new ArrayList<>();
         List<String> resPhones=new ArrayList<>();
         List<String> appEmails=new ArrayList<>();
                     }
                 }
             }
-        }
+        }}, executor);
     }
 
     /**
         msCaseApplicationMapper.updateByPrimaryKeySelective(application);
         // 根据案件id查询案件
         MsCaseApplication caseApplication = msCaseApplicationMapper.selectByPrimaryKey(application.getId());
-        // 发送开庭短信
-        if(CollectionUtil.isNotEmpty(vo.getHerDates())) {
-            List<MsCaseAffiliate> affiliates = selectAffliatesByCaseId(application.getId());
-            caseApplication.setHearDate(application.getHearDate());
-            // 申请人发送开庭日期短信
-            sendHearDateSms(caseApplication, affiliates);
-
-            // 调解员发送短信,根据调解员id查询用户
-            if (caseApplication.getMediatorId() != null) {
-               // 线下调解 2077966 尊敬的用户，您的{1}案件，线下调解日期已确定为{2}，请知晓，如非本人操作，请忽略本短信。
-                SysUser sysUser = sysUserMapper.selectUserById(caseApplication.getMediatorId());
-                String  content="尊敬的用户，您的" + caseApplication.getCaseNum() + "的案件，线下调解日期已确定为"+application.getHearDate()+"，请知晓，如非本人操作，请忽略本短信。";
-                String templateId="2077966";
-                String subject="开庭日期通知";
-                MsCaseAffiliate meditorAffliate = new MsCaseAffiliate();
-                meditorAffliate.setPhone(sysUser.getPhonenumber());
-                meditorAffliate.setEmail(sysUser.getEmail());
-                String roomUuid=null;
-                // 线上调解
-                if(StrUtil.isNotEmpty(application.getMediationMethod()) && application.getMediationMethod().equals("1")){
-                    // 获取短信链接uuid
-                    MeetingInfoVO meetingInfoVO= MeetingInfoVO.builder().userId(sysUser.getUserId()).userName(sysUser.getUserName()).caseId(application.getId()).roomId(application.getRoomId()).build();
-                     roomUuid = shortMessageService.buildMeetingInfoRecord(meetingInfoVO);
-                    // 短信模板：2130103 线上调解时间和会议通知  尊敬的用户，您的{2}线上开庭时间为{3}，会议链接https://txroom.xayunmei.com/#/home?{4}，请点击链接参加会议，如非本人操作，请忽略本短信.
-
-                    content="尊敬的用户，您的" + caseApplication.getCaseNum() + "线上开庭时间为"+application.getHearDate()+"会议链接https://txroom.xayunmei.com/#/home?"+roomUuid+"，请点击链接参加会议，如非本人操作，请忽略本短信.";
-                    templateId = "2130103";
-                }
-                // 电话号不为空，发送短信，否则发邮箱
-                if (StrUtil.isNotEmpty(sysUser.getPhonenumber())) {
-                    if(roomUuid==null) {
-                        SmsUtils.sendSms(caseApplication, templateId, sysUser.getPhonenumber(),
-                                new String[]{caseApplication.getCaseNum(), application.getHearDate()});
-                    }else {
-                        SmsUtils.sendSms(caseApplication, templateId, sysUser.getPhonenumber(),
-                                new String[]{caseApplication.getCaseNum(), application.getHearDate(),roomUuid});
-                    }
+        long l = System.currentTimeMillis();
+        ExecutorService executor = ThreadUtil.createThreadPool();
+        CompletableFuture.runAsync(() -> {
+                    // 发送开庭短信
+                    if (CollectionUtil.isNotEmpty(vo.getHerDates())) {
+                        List<MsCaseAffiliate> affiliates = selectAffliatesByCaseId(application.getId());
+                        caseApplication.setHearDate(application.getHearDate());
+                        // 申请人发送开庭日期短信
+                        sendHearDateSms(caseApplication, affiliates);
 
 
+                    }
+                }, executor);
+        // 调解员发送短信,根据调解员id查询用户
+        CompletableFuture.runAsync(() -> { if (caseApplication.getMediatorId() != null) {
+            // 线下调解 2077966 尊敬的用户，您的{1}案件，线下调解日期已确定为{2}，请知晓，如非本人操作，请忽略本短信。
+            SysUser sysUser = sysUserMapper.selectUserById(caseApplication.getMediatorId());
+            String content = "尊敬的用户，您的" + caseApplication.getCaseNum() + "的案件，线下调解日期已确定为" + application.getHearDate() + "，请知晓，如非本人操作，请忽略本短信。";
+            String templateId = "2077966";
+            String subject = "开庭日期通知";
+            MsCaseAffiliate meditorAffliate = new MsCaseAffiliate();
+            meditorAffliate.setPhone(sysUser.getPhonenumber());
+            meditorAffliate.setEmail(sysUser.getEmail());
+            String roomUuid = null;
+            // 线上调解
+            if (StrUtil.isNotEmpty(application.getMediationMethod()) && application.getMediationMethod().equals("1")) {
+                // 获取短信链接uuid
+                MeetingInfoVO meetingInfoVO = MeetingInfoVO.builder().userId(sysUser.getUserId()).userName(sysUser.getUserName()).caseId(application.getId()).roomId(application.getRoomId()).build();
+                roomUuid = shortMessageService.buildMeetingInfoRecord(meetingInfoVO);
+                // 短信模板：2130103 线上调解时间和会议通知  尊敬的用户，您的{2}线上开庭时间为{3}，会议链接https://txroom.xayunmei.com/#/home?{4}，请点击链接参加会议，如非本人操作，请忽略本短信.
+
+                content = "尊敬的用户，您的" + caseApplication.getCaseNum() + "线上开庭时间为" + application.getHearDate() + "会议链接https://txroom.xayunmei.com/#/home?" + roomUuid + "，请点击链接参加会议，如非本人操作，请忽略本短信.";
+                templateId = "2130103";
+            }
+            // 电话号不为空，发送短信，否则发邮箱
+            if (StrUtil.isNotEmpty(sysUser.getPhonenumber())) {
+                if (roomUuid == null) {
+                    SmsUtils.sendSms(caseApplication, templateId, sysUser.getPhonenumber(),
+                            new String[]{caseApplication.getCaseNum(), application.getHearDate()});
                 } else {
-                    // 发送邮件
-                    caseApplicationService.sendEmail(caseApplication, meditorAffliate, subject, content);
-
+                    SmsUtils.sendSms(caseApplication, templateId, sysUser.getPhonenumber(),
+                            new String[]{caseApplication.getCaseNum(), application.getHearDate(), roomUuid});
                 }
+
+
+            } else {
+                // 发送邮件
+                caseApplicationService.sendEmail(caseApplication, meditorAffliate, subject, content);
+
             }
-        }
+        } }, executor);
         // 新增日志
-
         CaseLogUtils.insertCaseLog(caseApplication.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(), "");
 
     }
         application.setRejectReason(reason);
         if(application.getCaseFlowId()!=null && application.getCaseFlowId()==4){
             // todo 超过五日还没有受理，给申请操作人发送不受理通知，有手机号发短信，没有手机号发邮箱
-            // 申请人不受理分配通知
+            // 申请人不受理分配通知 // todo 短信异步
+            ExecutorService executor = ThreadUtil.createThreadPool();
+            CompletableFuture.runAsync(() -> {
             String rejectReason = application.getRejectReason() == null ? "" : application.getRejectReason();
             SMSNoticeDO applicantNotice = new SMSNoticeDO("案件不受理通知",
                     "尊敬的用户，您编号为" + application.getCaseNum() + "的案件由于" + rejectReason + "所以不予受理，请知晓，如非本人操作，请忽略本短信。",
 
             SMSNotice notice = new SMSNotice(applicantNotice,null);
             caseApplicationService.sendNotice(application,affiliates,true,notice);
+            }, executor);
                 // 修改案件状态为17,结束
                 MsCaseApplication caseApplication = new MsCaseApplication();
                 caseApplication.setId(id);

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/mscase/impl/MsCasePaymentServiceImpl.java

 import com.ruoyi.common.enums.YesOrNoEnum;
 import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.utils.ThreadUtil;
 import com.ruoyi.common.utils.spring.SpringUtils;
 import com.ruoyi.dto.PayRequest;
 import com.ruoyi.dto.PayResponse;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
         }
         casePaymentRecord.setCaseId(application.getId());
         Example example = new Example(MsCasePaymentRecord.class);
-        example.createCriteria().andEqualTo("caseId", casePaymentRecord.getCaseId());casePaymentRecordMapper.updateByExampleSelective(casePaymentRecord, example);
+        example.createCriteria().andEqualTo("caseId", casePaymentRecord.getCaseId());
+        casePaymentRecordMapper.updateByExampleSelective(casePaymentRecord, example);
         // 更改案件流程id和案件状态
         application.setCaseFlowId(flow.getId());
         application.setCaseStatusName(flow.getCaseStatusName());
         if(CollectionUtil.isEmpty(operatorList)){
             throw new ServiceException("未找到案件操作人员");
         }
+        // 异步发送短信
+        ExecutorService executor = ThreadUtil.createThreadPool();
+        CompletableFuture.runAsync(() -> {
         if(dto.getApplicantConfirm()) {
             List<String> appPhones=new ArrayList<>();
 
 
                 }
             }
-        }
+        }}, executor);
     }