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


@@ -7,18 +7,28 @@


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.sms.constant.MinConstant;


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


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


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


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


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


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


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 com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.toolkit.IdWorker;


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.util.*;


import java.util.regex.Matcher;


import java.util.regex.Pattern;




/**


 * 短信发送服务实现层


@@ -36,6 +46,12 @@




   @Autowired


   private ISmsResultService smsResultService;




   @Autowired


   private ISmsTemplateService smsTemplateService;




   @Autowired


   private BladeRedis bladeRedis;




   /**


    * 发送 xx 变量模板短信


@@ -56,7 +72,7 @@


            ComResult<SMSSendDataResult> result = SmsUtils.sendMsg(request);


            if(null != smsResult) {


               // 保存记录


               saveSendRecord(request, result.getCode(), result.getMsg(), smsResult.getId());


               saveSendRecord(request, result.getCode().toString(), result.getMsg(), smsResult.getId());


            }


            list.add(result);


         }


@@ -65,12 +81,12 @@


   }




   /**


    * 发送 具名 变量模板短信


    * 发送 具名 变量模板短信（告警定制）


    * @param smsRequestTemplate


    * @return


    */


   @Override


   public Object sendSignMsg(SmsRequestTemplate smsRequestTemplate) {


   public Map<String, Object> sendSignMsg(SmsRequestTemplate smsRequestTemplate) {


      // 取出数据


      SMSSendRequest request = new SMSSendRequest();


      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();


@@ -115,7 +131,66 @@


            // 设置内容


            request.setMessageContent(format);


            // 保存记录


            smsRecord = saveSendRecord(request, resultComResult.getCode(), resultComResult.getMsg(), smsResult.getId());


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


      }


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


      map.put("smsRecord",smsRecordList.size());


      // 返回


      return map;


   }




   /**


    * 保存站内信记录信息


    * @param smsRequestTemplate


    * @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(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("站内信");


         // 未读


         alarmRecordDetail.setStatus(1);


         // 删除 最后一个 告警记录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());


@@ -133,14 +208,35 @@


      return map;


   }






   /**


    * 发送 具名 变量模板短信--批量一次发送


    * @param title 具名变量头


    * 发送降雨短信--批量一次发送


    * @param params 具名变量头


    * @return


    */


   public Object sendSignMsg(String title, String datas, SMSSendRequest request, Integer type, SmsTemplate smsTemplate) {


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


   @Override


   public Object sendSignRainMsg(Map<String, Object> params) {


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


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


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


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


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


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


      // 手机号去重


      Set<String> hashSet = new HashSet<>();


      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;


@@ -151,22 +247,45 @@


      }


      //请求参数


      DynSMSSendRequest sendRequest = new DynSMSSendRequest();


      sendRequest.setTemplateId(request.getTemplateId());


      sendRequest.setTemplateId(templateId);


      sendRequest.setDynData(dyns);


      // 发送


      ComResult<DynSMSSendDataResult> resultComResult = SmsUtils.dynSendMethod(sendRequest);


      SMSSendRequest request = new SMSSendRequest();


      request.setTemplateId(templateId);


      request.setMessageContent(content);


      request.setUserNumber("");


      // 先保存结果记录


      SmsResult smsResult = saveSendResult(request, rows.length);


      SmsRecord smsRecord = new SmsRecord();


      if (null != smsResult){


         // 保存记录


         smsRecord = saveSendRecord(request, resultComResult.getCode(), resultComResult.getMsg(), smsResult.getId());


         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> map = new HashMap<>(2);


      map.put("smsRecord",smsRecord);


      map.put("smsResult",smsResult);


      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() + "。";


      // 返回


      return map;


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


   }






@@ -200,18 +319,133 @@


    * @param resultId


    */


   @Override


   public SmsRecord saveSendRecord(SMSSendRequest request, Integer code, String sendMsg, Long resultId) {


   public SmsRecord saveSendRecord(SMSSendRequest request, String code, String sendMsg, Long resultId) {


      // 在保存明细


      SmsRecord smsRecord = new SmsRecord();


      smsRecord.setTel(request.getUserNumber());


      smsRecord.setContent(request.getMessageContent());


      smsRecord.setTemplateId(request.getTemplateId());


      smsRecord.setResultId(resultId);


      smsRecord.setResponseStatus(code.toString());


      smsRecord.setResponseStatus(code);


      smsRecord.setResponseMsg(sendMsg);


      //插入记录


      smsRecordService.save(smsRecord);


      // 返回


      return smsRecord;


   }




   /**


    * 外呼未接通-发送短信


    * @param taskId


    * @param time


    * @return


    */


   @Override


   public String sendSmsByOutCallNotConnect(String taskId,String time) {


      String templateId = "2431012249882";


      // 查询当前任务未接通的人员信息（包含水库编号）


      List<Map<String, Object>> list = smsTemplateService.getNotConnectPatrolPersonList(taskId);


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


      if (list.size()>0) {


         List<Map<String, Object>> newList = new ArrayList<>();


         // 比对


         for (Map<String, Object> map : list) {


            // 获取验证码


            String redisByTaskId = bladeRedis.get(MinConstant.is_send_prefix + map.get("userPhone").toString() + ":" + map.get("waterCode").toString());


            // 如果为null,并且不能匹配，加入发送短信集合


            if (redisByTaskId == null || !StringUtil.equalsIgnoreCase(redisByTaskId, taskId)) {


               newList.add(map);


            }


         }


         if (newList.size() > 0) {


            // 组装短信数据


            StringBuilder builder = new StringBuilder();


            // 遍历


            for (Map<String, Object> map : newList) {


               builder.append(map.get("userPhone") + ",")


                  .append(time + ",")


                  .append(MinConstant.fillWaterInfoUrl + ",")


                  .append(map.get("waterName"))


                  .append(";");


            }


            String datas = builder.toString();


            String title = "手机号码,时间范围,链接地址,水库名称";


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


            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;


            }


            //请求参数


            DynSMSSendRequest sendRequest = new DynSMSSendRequest();


            sendRequest.setTemplateId(templateId);


            sendRequest.setDynData(dyns);


            // 发送


            ComResult<DynSMSSendDataResult> resultComResult = SmsUtils.dynSendMethod(sendRequest);


            SMSSendRequest request = new SMSSendRequest();


            request.setTemplateId(templateId);


            request.setMessageContent("");


            request.setUserNumber("");


            // 先保存结果记录


            SmsResult smsResult = saveSendResult(request, rows.length);


            if (null != smsResult) {


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


               Pattern compile = Pattern.compile("[^0-9]");


               Integer result = Integer.parseInt(compile.matcher(time).replaceAll("").trim());


               // 分钟或小时


               Long validTime = time.contains("分钟") ? 60L * result : 60L * 60 * result;


               // 遍历保存


               for (Map<String, Object> map : newList) {


                  SmsRecord smsRecord = new SmsRecord();


                  smsRecord.setId(IdWorker.getId());


                  smsRecord.setTel(map.get("userPhone").toString());


                  // 内容处理


                  String s = smsTemplate.getContent().replaceAll("\\{.+?\\}", "%s");


                  // 拼接内容


                  String arrString = time + "," + MinConstant.fillWaterInfoUrl + "," + map.get("waterName").toString();


                  // 格式转换


                  String format = String.format(s, arrString.split(","));


                  smsRecord.setContent(format);


                  smsRecord.setTemplateId(templateId);


                  smsRecord.setResultId(smsResult.getId());


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


                  smsRecord.setResponseMsg(resultComResult.getMsg());


                  // 保存redis


                  bladeRedis.setEx(MinConstant.is_send_prefix + map.get("userPhone").toString() + ":" + map.get("waterCode").toString(), taskId, 2 * 60 * 60L);


                  bladeRedis.setEx(MinConstant.fill_info_prefix + map.get("userPhone").toString(), taskId, validTime);


                  // 加入集合


                  smsRecordList.add(smsRecord);


               }


               // 批量保存记录


               Integer count = smsRecordService.batchSaveSendRecord(smsRecordList);


               // 返回


               return count.toString();


            }


         }


      }


      return null;


   }




   /**


    * 校验手机号码


    */


   public static boolean validator(String phone) {


      if (null!=phone && !phone.equals("")) {


         String regex = "^((13[0-9])|(14[5,7,9])|(15([0-3]|[5-9]))|(166)|(17[0,1,3,5,6,7,8])|(18[0-9])|(19[8|9]))\\d{8}$";


         if (phone.length() != 11) {


            return false;


         } else {


            Pattern p = Pattern.compile(regex);


            Matcher m = p.matcher(phone);


            boolean isMatch = m.matches();


            return isMatch;


         }


      }


      return false;


   }






}