湖北水库项目
blame | history | patch | commit | commitdiff | ignore whitespace
zhongrj
2023-06-30 b1d7e4ca2e5f50ab40bb2b223861baf1e5231af7 
 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/sms/service/impl/SmsServiceImpl.java


@@ -7,6 +7,7 @@


import cn.com.flaginfo.sdk.cmc.api.sms.send.SMSSendRequest;


import cn.gistack.alerts.alarmRule.entity.AlarmRecordDetail;


import cn.gistack.alerts.alarmRule.service.AlarmRecordDetailService;


import cn.gistack.alerts.notice.util.FormatUtil;


import cn.gistack.alerts.sms.constant.MinConstant;


import cn.gistack.alerts.sms.entity.SmsRecord;


import cn.gistack.alerts.sms.entity.SmsResult;


@@ -18,7 +19,6 @@


import cn.gistack.alerts.sms.service.SmsService;


import cn.gistack.alerts.sms.util.SmsUtils;


import cn.gistack.alerts.sms.vo.SmsRequestTemplate;


import cn.gistack.common.cache.CacheNames;


import cn.gistack.sm.intelligentCall.entity.CallNotFillRecord;


import cn.gistack.sm.intelligentCall.feign.OutCallClient;


import cn.gistack.sm.sjztmd.feign.IAttResManagePersonClient;


@@ -27,16 +27,14 @@


import org.jetbrains.annotations.NotNull;


import org.springblade.core.redis.cache.BladeRedis;


import org.springblade.core.tool.api.R;


import org.springblade.core.tool.utils.StringUtil;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;




import java.io.UnsupportedEncodingException;


import java.net.URLEncoder;


import java.text.SimpleDateFormat;


import java.util.*;


import java.util.regex.Matcher;


import java.util.regex.Pattern;


import java.util.stream.Collectors;




/**


 * 短信发送服务实现层


@@ -66,6 +64,9 @@




   @Autowired


   private IAttResManagePersonClient attResManagePersonClient;




   @Autowired


   private SmsAsyncService asyncService;




   /**


    * 发送 xx 变量模板短信


@@ -228,6 +229,8 @@


      String[] titleArr = params.get("title").toString().split(",");


      String data = params.get("data").toString();


      String templateId = params.get("templateId").toString();


      // 查询短信模板


      SmsTemplate smsTemplate = smsTemplateService.getOne(new QueryWrapper<SmsTemplate>().eq("template_id", templateId));


      String content = params.get("content").toString();


      List<String> phones = (List<String>)params.get("phones");


      List<String> errPhones = new ArrayList<>();


@@ -236,46 +239,11 @@


      for (String phone : phones) {


         hashSet.add(phone);


      }


      StringBuilder builder = new StringBuilder();


      // 变量


      for (String phone : hashSet) {


         if (validator(phone)){


            builder.append(phone+","+data).append(";");


         }else {


            // 异常手机号


            errPhones.add(phone);


         }


      }


      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(templateId, dyns);


      SmsResult smsResult = getSaveSmsResult(templateId, rows, content);


      if (null != smsResult){


         List<SmsRecord> list = new ArrayList<>();


         // 遍历保存


         for (String phone : hashSet) {


            SmsRecord smsRecord = new SmsRecord();


            smsRecord.setId(IdWorker.getId());


            smsRecord.setTel(phone);


            smsRecord.setContent(content);


            smsRecord.setTemplateId(templateId);


            smsRecord.setResultId(smsResult.getId());


            smsRecord.setResponseStatus(resultComResult.getCode().toString());


            smsRecord.setResponseMsg(resultComResult.getMsg());


            // 加入集合


            list.add(smsRecord);


         }


         // 批量保存记录


         smsRecordService.batchSaveSendRecord(list);


      }


      // 批量发送短信


      Map<String, Object> batchSendSmsMap = batchSendSms(hashSet, titleArr, data, smsTemplate,errPhones);


      ComResult<DynSMSSendDataResult> resultComResult = (ComResult<DynSMSSendDataResult>)batchSendSmsMap.get("resultComResult");


      errPhones = (List<String>) batchSendSmsMap.get("errPhones");


      // 计算差值


      Integer diff = phones.size() - hashSet.size();


      if (resultComResult.getCode()==0){


         String successMsg = "发送成功!共提交号码 "+phones.size()+" 个，其中重复号码 "+diff+" 个，错误号码 "


@@ -538,13 +506,87 @@


    */


   @Override


   public Object importSendRainSms(List<SendRainSmsExcel> list,String startTime,String endTime) {


      String templateId = "2431012251309";


      // 获取水库个数


      Integer size = list.size();


      List<String> errPhones = new ArrayList<>();


      // 转换


      List<String> stringList = list.stream().map(SendRainSmsExcel::getWaterCode).collect(Collectors.toList());


      // 通过水库代码获取巡查责任人及技术责任人手机号


//      Set<String> personList = attResManagePersonClient.getPersonListByWaterCodeList(list);






      Set<String> personList = attResManagePersonClient.getPersonListByWaterCodeList(stringList);


      // 查询短信模板


      SmsTemplate smsTemplate = smsTemplateService.getOne(new QueryWrapper<SmsTemplate>().eq("template_id", templateId));


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


      // 计算差值


      Integer diff = size - errPhones.size();


      if (resultComResult.getCode()==0){


         String successMsg = "发送成功!共导入水库个数 "+ size +" 个，其中发送号码 "+ diff + " 个。";


         // 返回


         return R.data(200,successMsg,null);


      }


      String errorMsg = "发送失败!共导入水库个数 "+ size +" 个，发送异常号码 "+ diff + " 个，异常原因" + resultComResult.getMsg() + "。";


      // 返回


      return null;


      return R.data(400,errorMsg,null);


   }




   /**


    * 拼接短信标题数组


    * @param smsTemplate


    * @return


    */


   private String[] getSmsTitleArr(SmsTemplate smsTemplate) {


      String title = FormatUtil.composeMessage(smsTemplate.getContent());


      // 返回


      return title.split(",");


   }




   /**


    * 批量发送动态短信


    * @param phoneList


    * @param titleArr 示例： [手机号码,水库名称，水位值]


    * @param param 示例： ***水库，15.12


    * @param smsTemplate


    * @return


    */


   private Map<String, Object> batchSendSms(Set<String> phoneList,String[] titleArr,String param,SmsTemplate smsTemplate,List<String> errPhones){


      Map<String, Object> map = new HashMap<>();


      StringBuilder builder = new StringBuilder();


      // 遍历，拼接短信


      if (phoneList.size()>0){


         for (String phone : phoneList) {


            if (validator(phone)){


               builder.append(phone+","+ param).append(";");


            }else {


               // 异常手机号


               errPhones.add(phone);


            }


         }


      }


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


      SmsResult smsResult = getSaveSmsResult(smsTemplate.getTemplateId(), rows, "");


      // 异步记录发送记录


      asyncService.batchSaveSendRecord(smsResult,rows,smsTemplate,resultComResult);


      // 返回


      map.put("errPhones",errPhones);


      map.put("resultComResult",resultComResult);


      return map;


   }






}