Merge remote-tracking branch 'origin/jtdev' into jtdev

xieb

2023-10-19 1dd5d8f8a616f5cf3caa7828d46989c7d3dcafc4

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/sms/service/impl/SmsServiceImpl.java

@@ -6,14 +6,19 @@
import cn.com.flaginfo.sdk.cmc.api.sms.send.SMSSendDataResult;
import cn.com.flaginfo.sdk.cmc.api.sms.send.SMSSendRequest;
import cn.gistack.alerts.alarmRule.entity.AlarmRecordDetail;
import cn.gistack.alerts.alarmRule.entity.AlarmRule;
import cn.gistack.alerts.alarmRule.service.AlarmRecordDetailService;
import cn.gistack.alerts.alarmRule.vo.AlarmRecordDetailVO;
import cn.gistack.alerts.notice.service.impl.NoticeHandle;
import cn.gistack.alerts.notice.util.FormatUtil;
import cn.gistack.alerts.sms.constant.MinConstant;
import cn.gistack.alerts.sms.dto.DynSMSSendRequestDTO;
import cn.gistack.alerts.sms.entity.SmsRecord;
import cn.gistack.alerts.sms.entity.SmsRequest;
import cn.gistack.alerts.sms.entity.SmsResult;
import cn.gistack.alerts.sms.entity.SmsTemplate;
import cn.gistack.alerts.sms.excel.SendRainSmsExcel;
import cn.gistack.alerts.sms.excel.SendSmsExcel;
import cn.gistack.alerts.sms.service.ISmsRecordService;
import cn.gistack.alerts.sms.service.ISmsResultService;
import cn.gistack.alerts.sms.service.ISmsTemplateService;
@@ -21,17 +26,24 @@
import cn.gistack.alerts.sms.util.SmsUtils;
import cn.gistack.alerts.sms.vo.SmsRequestTemplate;
import cn.gistack.alerts.sms.vo.SmsResponseVO;
import cn.gistack.alerts.sms.vo.Temp;
import cn.gistack.sm.intelligentCall.entity.CallNotFillRecord;
import cn.gistack.sm.intelligentCall.excel.CallExcel;
import cn.gistack.sm.intelligentCall.feign.OutCallClient;
import cn.gistack.sm.message.entity.MessageRecord;
import cn.gistack.sm.sjztmd.feign.IAttResManagePersonClient;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
import com.google.common.collect.Lists;
import com.google.common.collect.Sets;
import org.jetbrains.annotations.NotNull;
import org.springblade.core.redis.cache.BladeRedis;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.api.R;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.lang.reflect.Array;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.regex.Matcher;
@@ -72,6 +84,9 @@
   @Autowired
   private SmsAsyncService asyncService;

   @Autowired
   private NoticeHandle noticeHandle;

   /**
    * 发送 xx 变量模板短信
    * @param phoneNumbers 手机号集合
@@ -83,7 +98,7 @@
      List<ComResult<SMSSendDataResult>> list = new ArrayList<>();
      if (phoneNumbers.size()>0){
         // 先保存结果记录
         SmsResult smsResult = saveSendResult(null,request, phoneNumbers.size());
         SmsResult smsResult = saveSendResult(null,null,request, phoneNumbers.size());
         // 遍历发送
         for (String phone : phoneNumbers) {
            request.setUserNumber(phone);
@@ -99,8 +114,90 @@
      return list;
   }

//   /**
//    * 发送 具名 变量模板短信（告警定制）-- 动态发送-一个一个发
//    * @param smsRequestTemplate
//    * @return
//    */
//   @Override
//   public Map<String, Object> sendSignMsg(SmsRequestTemplate smsRequestTemplate) {
//      // 取出数据
//      SMSSendRequest request = new SMSSendRequest();
//      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();
//      AlarmRule alarmRule = smsRequestTemplate.getAlarmRule();
//      request.setTemplateId(smsTemplate.getTemplateId());
//      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();
//      // 先保存结果记录
//      SmsResult smsResult = saveSendResult(null,null,request, templateContent.size());
//      List<SmsRecord> smsRecordList = new ArrayList<>();
//      List<MessageRecord> messageRecordList = new ArrayList<>();
//      // 遍历处理
//      for (List<String> list : templateContent) {
//         // 设置站内信记录信息
//         MessageRecord messageRecord = new MessageRecord();
//         messageRecord.setTheme(alarmRule.getRuleName());
//         messageRecord.setSender(AuthUtil.getUserId().toString());
//         messageRecord.setSource("智能告警");
//         messageRecord.setStatus(0);
//
//         AlarmRecordDetail alarmRecordDetail = new AlarmRecordDetail();
//         alarmRecordDetail.setReservoirNumber(list.get(0));
//         alarmRecordDetail.setAlarmRecordId(Long.parseLong(list.get(list.size() - 1)));
//         alarmRecordDetail.setAlarmMode("短信");
//         // 删除 最后一个 告警记录id
//         list.remove(list.size() - 1);
//         // 删除 0 水库编码
//         list.remove(0);
//         // 组装数据
//         String row = String.join(",", list);
//         String[] titleArr = smsRequestTemplate.getTitle().split(",");
//         String[][] dyns = new String[2][titleArr.length];
//         dyns[0] = titleArr;
//         dyns[1] = row.split(",");
//         //请求参数
//         ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(smsTemplate.getTemplateId(), dyns);
//
//         SmsRecord smsRecord = new SmsRecord();
//         if (null != smsResult){
//            alarmRecordDetail.setPhone(list.get(0));
//            // 设置手机号
//            request.setUserNumber(list.get(0));
//            messageRecord.setRecipient(list.get(0));
//            // 内容处理
//            String s = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");
//            // 短信内容拼接（完成发送的结果信息）
//            // 需要删除最前面的手机号
//            list.remove(0);
//            // 格式转换
//            String format = String.format(s, list.toArray());
//            // 设置内容
//            request.setMessageContent(format);
//            messageRecord.setContent(format);
//            messageRecordList.add(messageRecord);
//            // 保存短信发送记录
//            smsRecord = saveSendRecord(request, resultComResult.getCode().toString(), resultComResult.getMsg(), smsResult.getId());
//            if (null != smsRecord){
//               alarmRecordDetail.setAlarmContent(format);
//               alarmRecordDetail.setSendRecordId(smsRecord.getId());
//               alarmRecordDetail.setCreateTime(new Date());
//               // 保存告警记录详情信息
//               boolean save = alarmRecordDetailService.save(alarmRecordDetail);
//            }
//         }
//         smsRecordList.add(smsRecord);
//      }
//      if (null!=smsRequestTemplate.getIsSendStation() && smsRequestTemplate.getIsSendStation()) {
//         // 保存站内信信息
//         noticeHandle.saveMessageRecord(messageRecordList);
//      }
//      Map<String, Object> map = new HashMap<>(2);
//      map.put("smsRecord",smsRecordList.size());
//      // 返回
//      return map;
//   }

   /**
    * 发送 具名 变量模板短信（告警定制）
    * 发送 具名 变量模板短信（告警定制）--动态批量发送
    * @param smsRequestTemplate
    * @return
    */
@@ -111,115 +208,169 @@
      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();
      request.setTemplateId(smsTemplate.getTemplateId());
      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();
      // 先保存结果记录
      SmsResult smsResult = saveSendResult(null,request, templateContent.size());
      List<SmsRecord> smsRecordList = new ArrayList<>();
      // 遍历处理
      for (List<String> list : templateContent) {
         AlarmRecordDetail alarmRecordDetail = new AlarmRecordDetail();
         alarmRecordDetail.setReservoirNumber(list.get(0));
         alarmRecordDetail.setAlarmRecordId(Long.parseLong(list.get(list.size() - 1)));
         alarmRecordDetail.setAlarmMode("短信");
         // 删除 最后一个 告警记录id
         list.remove(list.size() - 1);
         // 删除 0 水库编码
         list.remove(0);
         // 转换字符串
         String row = String.join(",", list);
         // 组装数据
         String[][] dyns = new String[][]{{smsRequestTemplate.getTitle()}, {row}};
         //请求参数
         ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(smsTemplate.getTemplateId(), dyns);

         SmsRecord smsRecord = new SmsRecord();
         if (null != smsResult){
            alarmRecordDetail.setPhone(list.get(0));
            // 设置手机号
            request.setUserNumber(list.get(0));
            // 内容处理
            String s = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");
            // 短信内容拼接（完成发送的结果信息）
            // 需要删除最前面的手机号
            list.remove(0);
            // 格式转换
            String format = String.format(s, list.toArray());
            // 设置内容
            request.setMessageContent(format);
            // 保存记录
            smsRecord = saveSendRecord(request, resultComResult.getCode().toString(), resultComResult.getMsg(), smsResult.getId());
            if (null != smsRecord){
               alarmRecordDetail.setAlarmContent(format);
               alarmRecordDetail.setSendRecordId(smsRecord.getId());
               alarmRecordDetail.setCreateTime(new Date());
               // 保存告警记录详情信息
               boolean save = alarmRecordDetailService.save(alarmRecordDetail);
            }
         }
         smsRecordList.add(smsRecord);
      // 是否同时发送站内信
      Boolean isSendStation = false;
      if (null!=smsRequestTemplate.getIsSendStation()){
         isSendStation = smsRequestTemplate.getIsSendStation();
      }
      Map<String, Object> map = new HashMap<>(2);
      map.put("smsRecord",smsRecordList.size());
      // 判断 templateContent 个数，个数超过1000 需要分段发送短信
      List<List<List<String>>> lists = Lists.partition(templateContent, 1000);
      int number = 0;
      for (List<List<String>> list : lists) {
         // 临时保存告警记录用
         List<List<String>> templateList = getAlarmList(list);
         // 批量发送短信
         Map<String, Object> map = batchSendAlertsSms(smsRequestTemplate.getSmsTemplate(), list);
         int count = Integer.parseInt(map.get("errCount").toString());
         ComResult<DynSMSSendDataResult> resultComResult =(ComResult<DynSMSSendDataResult>) map.get("resultComResult");
         // 保存短信结果记录
         SmsResult smsResult = saveSendResult(resultComResult.getCode().toString(),resultComResult.getMsg(),request, list.size() - count);
         // 保存详情记录（短信详情，告警详情）
         List<SmsRecord> smsRecordList = saveAlertsAndSmsDetail(smsResult,resultComResult,smsRequestTemplate.getSmsTemplate(),
            templateList,request,smsRequestTemplate.getAlarmRule(),isSendStation);
         // number 累加
         number += smsRecordList.size();
      }
      // 设置返回数据
      Map<String, Object> params = new HashMap<>(1);
      params.put("sendNumber",number);
      // 返回
      return map;
      return params;
   }

   /**
    * 保存站内信记录信息
    * @param smsRequestTemplate
    * 获取用户告警的集合
    * @param list
    * @return
    */
   @Override
   public Map<String, Object> saveInStationInfo(SmsRequestTemplate smsRequestTemplate) {
      // 取出数据
      SMSSendRequest request = new SMSSendRequest();
      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();
      request.setTemplateId(smsTemplate.getTemplateId());
      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();
      // 先保存结果记录
      SmsResult smsResult = saveSendResult(null,request, templateContent.size());
   private List<List<String>> getAlarmList(List<List<String>> list) {
      List<List<String>> arrayList = new ArrayList<>();
      // 值引用
      for (List<String> stringList : list) {
         List<String> child = new ArrayList<>();
         child.addAll(stringList);
         arrayList.add(child);
      }
      // 返回
      return arrayList;
   }

   /**
    * 保存详情记录（短信详情，告警详情）
    * @param smsResult
    * @param resultComResult
    * @param smsTemplate
    * @param templateContent
    * @param request
    * @param request
    * @param request
    * @return
    */
   private List<SmsRecord> saveAlertsAndSmsDetail(SmsResult smsResult,
                              ComResult<DynSMSSendDataResult> resultComResult,
                              SmsTemplate smsTemplate,
                              List<List<String>> templateContent,
                              SMSSendRequest request,
                              AlarmRule alarmRule,
                              Boolean isSendStation) {
      List<SmsRecord> smsRecordList = new ArrayList<>();
      List<MessageRecord> messageRecordList = new ArrayList<>();
      // 遍历处理
      for (List<String> list : templateContent) {
         AlarmRecordDetail alarmRecordDetail = new AlarmRecordDetail();
         alarmRecordDetail.setReservoirNumber(list.get(0));
         alarmRecordDetail.setAlarmRecordId(Long.parseLong(list.get(list.size() - 1)));
         alarmRecordDetail.setAlarmMode("站内信");
         // 未读
         alarmRecordDetail.setStatus(1);
         // 校验手机号，发送短信时已校验
         if (validator(list.get(1))) {
            // 设置站内信记录信息
            MessageRecord messageRecord = new MessageRecord();
            messageRecord.setTheme(alarmRule.getRuleName());
            messageRecord.setSender(AuthUtil.getUserId().toString());
            messageRecord.setSource("智能告警");
            messageRecord.setStatus(0);
            // 设置告警记录信息
            AlarmRecordDetail alarmRecordDetail = new AlarmRecordDetail();
            alarmRecordDetail.setReservoirNumber(list.get(0));
            alarmRecordDetail.setAlarmRecordId(Long.parseLong(list.get(list.size() - 1)));
            alarmRecordDetail.setAlarmMode("短信");
            // 删除 最后一个 告警记录id
            list.remove(list.size() - 1);
            // 删除 0 水库编码
            list.remove(0);
            SmsRecord smsRecord = new SmsRecord();
            if (null != smsResult) {
               alarmRecordDetail.setPhone(list.get(0));
               messageRecord.setRecipient(list.get(0));
               // 设置手机号
               request.setUserNumber(list.get(0));
               // 内容处理
               String s = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");
               // 短信内容拼接（完成发送的结果信息）
               // 需要删除最前面的手机号
               list.remove(0);
               // 格式转换
               String format = String.format(s, list.toArray());
               // 设置内容
               request.setMessageContent(format);
               messageRecord.setContent(format);
               messageRecordList.add(messageRecord);
               // 保存短信发送记录
               smsRecord = saveSendRecord(request, resultComResult.getCode().toString(), resultComResult.getMsg(), smsResult.getId());
               if (null != smsRecord) {
                  alarmRecordDetail.setAlarmContent(format);
                  alarmRecordDetail.setSendRecordId(smsRecord.getId());
                  alarmRecordDetail.setCreateTime(new Date());
                  // 保存告警记录详情信息
                  boolean save = alarmRecordDetailService.save(alarmRecordDetail);
               }
            }
            smsRecordList.add(smsRecord);
         }
      }
      if (isSendStation) {
         // 保存站内信信息
         noticeHandle.saveMessageRecord(messageRecordList);
      }
      // 返回
      return smsRecordList;
   }

   /**
    * 批量发送告警短信
    * @param smsTemplate
    * @param templateContent
    */
   private Map<String, Object> batchSendAlertsSms(SmsTemplate smsTemplate, List<List<String>> templateContent) {
      Map<String, Object> map = new HashMap<>(2);
      int count = 0;
      StringBuilder builder = new StringBuilder();
      // 拼接短信标题数组
      String [] titleArr = getSmsTitleArr(smsTemplate);
      // 遍历，拼接短信
      for (List<String> list : templateContent) {
         // 删除 最后一个 告警记录id
         list.remove(list.size() - 1);
         // 删除 0 水库编码
         list.remove(0);

         SmsRecord smsRecord = new SmsRecord();
         if (null != smsResult){
            alarmRecordDetail.setPhone(list.get(0));
            // 设置手机号
            request.setUserNumber(list.get(0));
            // 内容处理
            String s = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");
            // 需要删除最前面的手机号
            list.remove(0);
            // 格式转换
            String format = String.format(s, list.toArray());
            // 设置内容
            request.setMessageContent(format);
            // 保存记录
            smsRecord = saveSendRecord(request, "", "", smsResult.getId());
            if (null != smsRecord){
               alarmRecordDetail.setAlarmContent(format);
               alarmRecordDetail.setSendRecordId(smsRecord.getId());
               alarmRecordDetail.setCreateTime(new Date());
               // 保存告警记录详情信息
               boolean save = alarmRecordDetailService.save(alarmRecordDetail);
            }
         String join = String.join(",", list);
         // 转换,校验手机号码
         if (validator(list.get(0))){
            builder.append(join).append(";");
         }else {
            count++;
         }
         smsRecordList.add(smsRecord);
      }
      Map<String, Object> map = new HashMap<>(2);
      map.put("smsRecord",smsRecordList);
      map.put("smsResult",smsResult);
      // 返回
      String datas = builder.toString();
      String[] rows = datas.split(";");
      String[][] dyns = new String[rows.length + 1][titleArr.length];
      dyns[0] = titleArr;
      int rowNum = 1;
      for (String row : rows) {
         String[] cols = row.split(",");
         dyns[rowNum++] = cols;
      }
      //请求参数
      ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(smsTemplate.getTemplateId(), dyns);
      map.put("resultComResult",resultComResult);
      map.put("errCount",count);
      //返回
      return map;
   }

@@ -242,42 +393,40 @@
      for (String phone : phones) {
         hashSet.add(phone);
      }
      // 批量发送短信
      Map<String, Object> batchSendSmsMap = batchSendSms(hashSet, titleArr, data, smsTemplate,errPhones);
      ComResult<DynSMSSendDataResult> resultComResult = (ComResult<DynSMSSendDataResult>)batchSendSmsMap.get("resultComResult");
      errPhones = (List<String>) batchSendSmsMap.get("errPhones");
      // 分割
      List<List<String>> partition = Lists.partition(new ArrayList<>(hashSet), 1000);
      int errNumber = 0;
      // 遍历
      for (List<String> list : partition) {
         // 批量发送短信
         Map<String, Object> batchSendSmsMap = batchSendSms(new HashSet<>(list), titleArr, data, smsTemplate,errPhones);
         errPhones = (List<String>) batchSendSmsMap.get("errPhones");
         errNumber += errPhones.size();
      }
      // 计算差值
      Integer diff = phones.size() - hashSet.size();
      if (resultComResult.getCode()==0){
         String successMsg = "发送成功!共提交号码 "+phones.size()+" 个，其中重复号码 "+diff+" 个，错误号码 "
            +errPhones.size()+" 个，发送成功号码 "+ hashSet.size() + " 个。";
         // 返回
         return R.data(200,successMsg,null);
      }
      String errorMsg = "发送失败!共提交号码 "+phones.size()+" 个，其中重复号码 "+diff+" 个，错误号码 "+errPhones.size()+
         " 个，发送异常号码 "+ hashSet.size()+" 个，异常原因" + resultComResult.getMsg() + "。";
      String successMsg = "发送成功!共提交号码 "+phones.size()+" 个，其中重复号码 "+diff+" 个，错误号码 "
         + errNumber +" 个，发送成功号码 "+ (hashSet.size()-errNumber) + " 个。";
      // 返回
      return R.data(400,errorMsg,null);
      return R.data(200,successMsg,null);
   }


   /**
    * 发送记录保存
    * @param smsResponse 响应消息
    * @param code 响应消息code
    * @param msg 响应消息
    * @param request 发送信息
    * @param number 号码个数
    */
   @Override
   public SmsResult saveSendResult(SmsResponseVO smsResponse, SMSSendRequest request, Integer number) {
   public SmsResult saveSendResult(String code,String msg, SMSSendRequest request, Integer number) {
      // 先保存结果表
      SmsResult smsResult = new SmsResult();
      smsResult.setTemplateId(request.getTemplateId());
      smsResult.setContent(request.getMessageContent());
      smsResult.setNumber(number);
      if (null!= smsResponse) {
         smsResult.setResCode(smsResponse.getCode());
         smsResult.setResMsg(smsResponse.getMsg());
      }
      smsResult.setResCode(code);
      smsResult.setResMsg(msg);
      //插入记录
      boolean save = smsResultService.save(smsResult);
      if (save){
@@ -361,10 +510,7 @@
                  dyns[rowNum++] = cols;
               }
               ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(templateId, dyns);
               SmsResponseVO smsResponse = new SmsResponseVO();
               smsResponse.setCode(resultComResult.getCode().toString());
               smsResponse.setMsg(resultComResult.getMsg());
               SmsResult smsResult = getSaveSmsResult(smsResponse,templateId, rows, "");
               SmsResult smsResult = getSaveSmsResult(resultComResult.getCode().toString(),resultComResult.getMsg(),templateId, rows);
               if (null != smsResult) {
                  List<SmsRecord> smsRecordList = new ArrayList<>();
                  Pattern compile = Pattern.compile("[^0-9]");
@@ -396,19 +542,17 @@

   /**
    * 保存短信发送结果
    * @param smsResponse
    * @param code
    * @param msg
    * @param templateId
    * @param rows
    * @param content
    * @return
    */
   private SmsResult getSaveSmsResult(SmsResponseVO smsResponse,String templateId, String[] rows, String content) {
   private SmsResult getSaveSmsResult(String code,String msg,String templateId, String[] rows) {
      SMSSendRequest request = new SMSSendRequest();
      request.setTemplateId(templateId);
      request.setMessageContent(content);
      request.setUserNumber("");
      // 先保存结果记录
      return saveSendResult(smsResponse,request, rows.length);
      return saveSendResult(code,msg,request, rows.length);
   }

   /**
@@ -419,7 +563,10 @@
    */
   private ComResult<DynSMSSendDataResult> sendDynSMSSendDataResultComResult(String templateId, String[][] dyns) {
      //请求参数
      DynSMSSendRequest sendRequest = new DynSMSSendRequest();
      DynSMSSendRequestDTO sendRequest = new DynSMSSendRequestDTO();
//      DynSMSSendRequest sendRequest = new DynSMSSendRequest();
      // 相同号码，不同内容，不需要去重处理
      sendRequest.setDuplicateRemoval("1");
      sendRequest.setTemplateId(templateId);
      sendRequest.setDynData(dyns);
      // 发送
@@ -514,12 +661,20 @@
      String param = startTime + "-" + endTime;
      // 拼接短信标题数组
      String [] titleArr = getSmsTitleArr(smsTemplate);
      // 批量发送短信
      Map<String, Object> batchSendSmsMap = batchSendSms(personList, titleArr, param, smsTemplate,errPhones);
      ComResult<DynSMSSendDataResult> resultComResult = (ComResult<DynSMSSendDataResult>)batchSendSmsMap.get("resultComResult");
      errPhones = (List<String>) batchSendSmsMap.get("errPhones");
      // 分割
      List<List<String>> partition = Lists.partition(new ArrayList<>(personList), 1000);
      int errNumber = 0;
      ComResult<DynSMSSendDataResult> resultComResult = new ComResult();
      // 遍历
      for (List<String> list1 : partition) {
         // 批量发送短信
         Map<String, Object> batchSendSmsMap = batchSendSms(new HashSet<>(list1), titleArr, param, smsTemplate,errPhones);
         resultComResult = (ComResult<DynSMSSendDataResult>)batchSendSmsMap.get("resultComResult");
         errPhones = (List<String>) batchSendSmsMap.get("errPhones");
         errNumber += errPhones.size();
      }
      // 计算差值
      Integer diff = size - errPhones.size();
      Integer diff = personList.size() - errNumber;
      if (resultComResult.getCode()==0){
         String successMsg = "发送成功!共导入水库个数 "+ size +" 个，其中发送号码 "+ diff + " 个。";
         // 返回
@@ -542,7 +697,7 @@
   }

   /**
    * 批量发送动态短信
    * 批量发送动态短信--该方法只适合除手机号外只有一个动态参数并且是内容一致的情况
    * @param phoneList
    * @param titleArr 示例： [手机号码,水库名称，水位值]
    * @param param 示例： ***水库，15.12
@@ -572,12 +727,10 @@
         String[] cols = row.split(",");
         dyns[rowNum++] = cols;
      }
      //请求参数
      //请求发送短信
      ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(smsTemplate.getTemplateId(), dyns);
      SmsResponseVO smsResponse = new SmsResponseVO();
      smsResponse.setCode(resultComResult.getCode().toString());
      smsResponse.setMsg(resultComResult.getMsg());
      SmsResult smsResult = getSaveSmsResult(smsResponse,smsTemplate.getTemplateId(), rows, "");
      // 保存发送结果
      SmsResult smsResult = getSaveSmsResult(resultComResult.getCode().toString(),resultComResult.getMsg(),smsTemplate.getTemplateId(), rows);
      // 异步记录发送记录
      asyncService.batchSaveSendRecord(smsResult,rows,smsTemplate,resultComResult);
      // 返回
@@ -587,7 +740,7 @@
   }

   /**
    * 发送邮件提醒短信
    * 发送待办提醒短信
    * @param list
    */
   @Override
@@ -605,4 +758,313 @@
      // 批量发送短信
      Map<String, Object> batchSendSmsMap = batchSendSms(hashSet, titleArr, param, smsTemplate,errPhones);
   }

   /**
    * 发送合并水库名短信
    * @param smsRequestTemplate
    */
   @Override
   public void sendMergeSignMsg(SmsRequestTemplate smsRequestTemplate) {
      // 取出数据
      SMSSendRequest request = new SMSSendRequest();
      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();
      request.setTemplateId(smsTemplate.getTemplateId());
      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();
      List<Temp> tempList = new ArrayList<>();
      // 合并数据
      for (List<String> list : templateContent) {
         Temp temp = new Temp();
         temp.setPhone(list.get(1));
         temp.setReservoirCode(list.get(0));
         temp.setReservoirName(list.get(3));
         temp.setAlarmRecordId(list.get(list.size()-1));
         // 放入临时集合
         tempList.add(temp);
      }
      // 按手机号分组
      Map<String, List<Temp>> listMap = tempList.stream().collect(Collectors.groupingBy(Temp::getPhone));
      // 遍历 map 发送短信
      listMap.forEach((s, temps) -> {
         StringBuilder builder = new StringBuilder();
         StringBuilder smsRecordBuilder = new StringBuilder();
         builder.append(s).append(",");
         // 如果一人对应水库数量超过30个，则分批发送
         List<List<Temp>> lists = Lists.partition(new ArrayList<>(temps), 30);
         for (List<Temp> list : lists) {
            List<AlarmRecordDetailVO> alarmRecordDetailList = new ArrayList<>();
            // 遍历
            for (Temp temp : list) {
               builder.append(temp.getReservoirName()).append("，");
               smsRecordBuilder.append(temp.getReservoirName()).append("，");
               AlarmRecordDetailVO alarmRecordDetail = new AlarmRecordDetailVO();
               alarmRecordDetail.setReservoirNumber(temp.getReservoirCode());
               alarmRecordDetail.setAlarmRecordId(Long.parseLong(temp.getAlarmRecordId()));
               alarmRecordDetail.setAlarmMode("短信");
               alarmRecordDetail.setPhone(temp.getPhone());
               alarmRecordDetail.setReservoirName(temp.getReservoirName());
               // 加入集合
               alarmRecordDetailList.add(alarmRecordDetail);
            }

            String row = builder.substring(0, builder.length() - 1);
            // 组装数据
            String[] titleArr = smsRequestTemplate.getTitle().split(",");
            String[][] dyns = new String[2][titleArr.length];
            dyns[0] = titleArr;
            dyns[1] = row.split(",");
            //请求参数
            ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(smsTemplate.getTemplateId(), dyns);
            // 先保存结果记录
            SmsResult smsResult = saveSendResult(resultComResult.getCode().toString(),resultComResult.getMsg(),request, 1);
            // 设置手机号
            request.setUserNumber(s);
            // 内容处理
            String str = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");
            // 短信内容拼接（完成发送的结果信息）
            String substring = smsRecordBuilder.substring(0, smsRecordBuilder.length() - 1);
            // 格式转换
            String format = String.format(str, substring.split(","));
            // 设置内容
            request.setMessageContent(format);
            // 保存短信发送记录
            SmsRecord smsRecord = saveSendRecord(request, resultComResult.getCode().toString(), resultComResult.getMsg(), smsResult.getId());
            //保存告警记录详情信息
            if (null != smsRecord) {
               List<AlarmRecordDetail> alarmRecordDetailArrayList = new ArrayList<>();
               for (AlarmRecordDetailVO alarmRecordDetail : alarmRecordDetailList) {
                  AlarmRecordDetail alarmRecordDetail1 = new AlarmRecordDetail();
                  // 短信内容拼接（完成发送的结果信息）
                  String formatContent = String.format(str, alarmRecordDetail.getReservoirName().split(","));
                  alarmRecordDetail1.setAlarmContent(formatContent);
                  alarmRecordDetail1.setSendRecordId(smsRecord.getId());
                  alarmRecordDetail1.setCreateTime(new Date());
                  alarmRecordDetail1.setReservoirNumber(alarmRecordDetail.getReservoirNumber());
                  alarmRecordDetail1.setAlarmRecordId(alarmRecordDetail.getAlarmRecordId());
                  alarmRecordDetail1.setAlarmMode(alarmRecordDetail.getAlarmMode());
                  alarmRecordDetail1.setPhone(alarmRecordDetail.getPhone());
                  alarmRecordDetailArrayList.add(alarmRecordDetail1);
               }
               // 保存告警记录详情信息
               boolean save = alarmRecordDetailService.saveBatch(alarmRecordDetailArrayList);
            }
         }
      });
   }

//   /**
//    * 发送合并水库名短信
//    * @param smsRequestTemplate
//    */
//   @Override
//   public void sendMergeSignMsg(SmsRequestTemplate smsRequestTemplate) {
//      // 取出数据
//      SMSSendRequest request = new SMSSendRequest();
//      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();
//      request.setTemplateId(smsTemplate.getTemplateId());
//      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();
//      List<Temp> tempList = new ArrayList<>();
//      // 合并数据
//      for (List<String> list : templateContent) {
//         Temp temp = new Temp();
//         temp.setPhone(list.get(1));
//         temp.setReservoirCode(list.get(0));
//         temp.setReservoirName(list.get(3));
//         temp.setAlarmRecordId(list.get(list.size()-1));
//         // 放入临时集合
//         tempList.add(temp);
//      }
//      // 按手机号分组
//      Map<String, List<Temp>> listMap = tempList.stream().collect(Collectors.groupingBy(Temp::getPhone));
//      // 短信发送行数据
//      List<String> rowList = new ArrayList<>();
//      // 告警记录详情数据
//      List<AlarmRecordDetailVO> alarmRecordDetailList = new ArrayList<>();
//      // 遍历 map 发送短信，组装数据
//      listMap.forEach((s, temps) -> {
//         StringBuilder builder = new StringBuilder();
//         StringBuilder smsRecordBuilder = new StringBuilder();
//         builder.append(s).append(",");
//         // 如果一人对应水库数量超过30个，则分批发送
//         List<List<Temp>> lists = Lists.partition(new ArrayList<>(temps), 30);
//         for (List<Temp> list : lists) {
//            // 遍历
//            for (Temp temp : list) {
//               builder.append(temp.getReservoirName()).append("，");
//               smsRecordBuilder.append(temp.getReservoirName()).append("，");
//               AlarmRecordDetailVO alarmRecordDetail = new AlarmRecordDetailVO();
//               alarmRecordDetail.setReservoirNumber(temp.getReservoirCode());
//               alarmRecordDetail.setAlarmRecordId(Long.parseLong(temp.getAlarmRecordId()));
//               alarmRecordDetail.setAlarmMode("短信");
//               alarmRecordDetail.setPhone(temp.getPhone());
//               alarmRecordDetail.setReservoirName(temp.getReservoirName());
//               // 加入集合
//               alarmRecordDetailList.add(alarmRecordDetail);
//            }
//            String row = builder.substring(0, builder.length() - 1);
//            rowList.add(row);
//         }
//      });
//      // 批量发送短信
//      mergeBatchSendSms(smsRequestTemplate,request,smsTemplate,rowList,alarmRecordDetailList);
//   }

   /**
    * 批量发送合并水库的短信
    */
   public void mergeBatchSendSms(SmsRequestTemplate smsRequestTemplate,
                          SMSSendRequest request,
                          SmsTemplate smsTemplate,
                          List<String> rowList,
                          List<AlarmRecordDetailVO> alarmRecordDetailList) {
      // 组装数据
      String[] titleArr = smsRequestTemplate.getTitle().split(",");
      String[][] dyns = new String[rowList.size() + 1][titleArr.length];
      dyns[0] = titleArr;
      int rowNum = 1;
      for (String row : rowList) {
         String[] cols = row.split(",");
         dyns[rowNum++] = cols;
      }
      //请求参数
      ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(smsTemplate.getTemplateId(), dyns);
      // 先保存结果记录
      SmsResult smsResult = saveSendResult(resultComResult.getCode().toString(),resultComResult.getMsg(),request, rowList.size());
      List<AlarmRecordDetail> alarmRecordDetailArrayList = new ArrayList<>();
      // 遍历
      for (AlarmRecordDetailVO alarmRecordDetailVO : alarmRecordDetailList) {
         // 设置手机号
         request.setUserNumber(alarmRecordDetailVO.getPhone());
         // 内容处理
         String str = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");
         // 格式转换
         String formatContent = String.format(str, alarmRecordDetailVO.getReservoirName().split(","));
         // 设置内容
         request.setMessageContent(formatContent);
         // 保存短信发送记录
         SmsRecord smsRecord = saveSendRecord(request, resultComResult.getCode().toString(), resultComResult.getMsg(), smsResult.getId());
         AlarmRecordDetail alarmRecordDetail1 = new AlarmRecordDetail();
         // 短信内容拼接（完成发送的结果信息）
         alarmRecordDetail1.setAlarmContent(formatContent);
         alarmRecordDetail1.setSendRecordId(smsRecord.getId());
         alarmRecordDetail1.setCreateTime(new Date());
         alarmRecordDetail1.setReservoirNumber(alarmRecordDetailVO.getReservoirNumber());
         alarmRecordDetail1.setAlarmRecordId(alarmRecordDetailVO.getAlarmRecordId());
         alarmRecordDetail1.setAlarmMode(alarmRecordDetailVO.getAlarmMode());
         alarmRecordDetail1.setPhone(alarmRecordDetailVO.getPhone());
         alarmRecordDetailArrayList.add(alarmRecordDetail1);
      }
      // 保存告警记录详情信息
      boolean save = alarmRecordDetailService.saveBatch(alarmRecordDetailArrayList);
   }

   /**
    * 批量发送短信（集合数据）
    * @param map (保护参数 1:短信模板id  2:数据集合 list<Map<String,Object>>)
    * @return
    */
   @Override
   public Object batchSendSms(Map<String, Object> map) {
      // 获取模板id
      String templateId = map.get("templateId").toString();
      // 获取手机号集合
      List<String> list = (List<String>) map.get("phones");
      // 获取发送的动态内容（msg）
      String param = (String) map.get("content");
      // 创建错误手机号集合
      List<String> errPhones = new ArrayList<>();
      // 去重
      Set<String> hashSet = new HashSet<>(list);
      // 查询短信模板
      SmsTemplate smsTemplate = smsTemplateService.getOne(new QueryWrapper<SmsTemplate>().eq("template_id", templateId));
      // 拼接短信标题数组
      String [] titleArr = getSmsTitleArr(smsTemplate);
      // 批量发送短信
      Map<String, Object> batchSendSmsMap = batchSendSms(hashSet, titleArr, param, smsTemplate,errPhones);
      // 返回
      return batchSendSmsMap;
   }

   /**
    * 导入表格发送预警短信
    * @param list 集合数据
    * @param templateId 模板id
    * @param param 通用参数
    * @param content 发送内容
    * @return
    */
   @Override
   public Object importSendSms(List<SendSmsExcel> list,String templateId,String param, String content) {
      // 查询短信模板
      SmsTemplate smsTemplate = smsTemplateService.getOne(new QueryWrapper<SmsTemplate>().eq("template_id", templateId));
      // 判断模板是否为具名变量模板（目前已筛选出都是具名变量模板）
      // 判断模板中是否包含参数，如果无参数，对比是否传参数
      boolean validate = validatorParam(smsTemplate,param);
      if (!validate){
         return R.data(400,"参数个数不对应，请检查后修改导入!",null);
      }
      // 转换
      List<String> stringList = list.stream().map(SendSmsExcel::getPhone).collect(Collectors.toList());
      // 获取水库个数
      List<String> errPhones = new ArrayList<>();
      // 去重
      Set<String> hashSet = new HashSet<>(stringList);
      // 拼接短信标题数组
      String [] titleArr = getSmsTitleArr(smsTemplate);
      // 批量发送不能超过1000 个号码，需分组发送
      List<String> arrayList = new ArrayList<>(hashSet);
      List<List<String>> partition = Lists.partition(arrayList, 1000);
      int i = 0;
      String errMsg = "";
      for (List<String> phoneList : partition) {
         HashSet<String> sets = new HashSet<>(phoneList);
         // 批量发送短信
         Map<String, Object> batchSendSmsMap = batchSendSms(sets, titleArr, param, smsTemplate,errPhones);
         // 取出发送结果
         ComResult<DynSMSSendDataResult> resultComResult = (ComResult<DynSMSSendDataResult>) batchSendSmsMap.get("resultComResult");
         //
         if(!resultComResult.getCode().equals(0)){
            i++;
            errMsg = resultComResult.getMsg();
            break;
         }
      }
      if (i>0){
         // 返回resultComResult
         return R.data(400,"发送失败!" + errMsg,null);
      }
      // 返回resultComResult
      return R.data(200,"发送成功!",null);
   }

   /**
    * 校验参数
    * @param smsTemplate
    * @param param
    */
   private boolean validatorParam(SmsTemplate smsTemplate, String param) {
      int length = 0;
      if (null!= param && !param.equals("")) {
         length = Arrays.asList(param.split(",")).size();
      }
      // 解析模板
      String str = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");
      int countChar = countChar(str, '%');
      if (length==countChar){
         return true;
      }else {
         return false;
      }
   }

   /**
    * 计算某个字符在字符串中的个数
    * @param str 字符串
    * @param target 字符
    * @return
    */
   public int countChar(String str, char target) {
      String targetStr = String.valueOf(target);
      String replacedStr = str.replaceAll(targetStr, "");
      return str.length() - replacedStr.length();
   }
}