湖北水库项目
blame | history | patch | commit | commitdiff | ignore whitespace
zrj
2024-08-05 672c74b56e067d18256fddcdcfdd0ee3cc67aadf 
 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/sms/service/impl/SmsServiceImpl.java


@@ -87,6 +87,11 @@


   @Autowired


   private NoticeHandle noticeHandle;




   @Override


   public  ComResult<DynSMSSendDataResult> testSend(String tempId, String[][] strss) {


      return sendDynSMSSendDataResultComResult(tempId,strss);


   }




   /**


    * 发送 xx 变量模板短信


    * @param phoneNumbers 手机号集合


@@ -98,7 +103,7 @@


      List<ComResult<SMSSendDataResult>> list = new ArrayList<>();


      if (phoneNumbers.size()>0){


         // 先保存结果记录


         SmsResult smsResult = saveSendResult(null,null,request, phoneNumbers.size());


         SmsResult smsResult = saveSendResult(null,null,null,request, phoneNumbers.size());


         // 遍历发送


         for (String phone : phoneNumbers) {


            request.setUserNumber(phone);


@@ -208,6 +213,7 @@


      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();


      request.setTemplateId(smsTemplate.getTemplateId());


      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();


      AlarmRule alarmRule = smsRequestTemplate.getAlarmRule();


      // 是否同时发送站内信


      Boolean isSendStation = false;


      if (null!=smsRequestTemplate.getIsSendStation()){


@@ -224,7 +230,7 @@


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


         SmsResult smsResult = saveSendResult(alarmRule.getId(),resultComResult.getCode().toString(),resultComResult.getMsg(),request, list.size() - count);


         // 保存详情记录（短信详情，告警详情）


         List<SmsRecord> smsRecordList = saveAlertsAndSmsDetail(smsResult,resultComResult,smsRequestTemplate.getSmsTemplate(),


            templateList,request,smsRequestTemplate.getAlarmRule(),isSendStation);


@@ -300,7 +306,7 @@


               messageRecord.setRecipient(list.get(0));


               // 设置手机号


               request.setUserNumber(list.get(0));


               // 内容处理


               // 内容处理，把括号内容换成%s,后面用format替换，因此括号内容要和list的个数一样


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


               // 短信内容拼接（完成发送的结果信息）


               // 需要删除最前面的手机号


@@ -420,13 +426,14 @@


    * @param number 号码个数


    */


   @Override


   public SmsResult saveSendResult(String code,String msg, SMSSendRequest request, Integer number) {


   public SmsResult saveSendResult(Long alarmRuleId,String code,String msg, SMSSendRequest request, Integer number) {


      // 先保存结果表


      SmsResult smsResult = new SmsResult();


      smsResult.setTemplateId(request.getTemplateId());


      smsResult.setNumber(number);


      smsResult.setResCode(code);


      smsResult.setResMsg(msg);


      smsResult.setAlarmRuleId(alarmRuleId);


      //插入记录


      boolean save = smsResultService.save(smsResult);


      if (save){


@@ -552,7 +559,7 @@


      SMSSendRequest request = new SMSSendRequest();


      request.setTemplateId(templateId);


      // 先保存结果记录


      return saveSendResult(code,msg,request, rows.length);


      return saveSendResult(null,code,msg,request, rows.length);


   }




   /**


@@ -770,13 +777,14 @@


      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();


      request.setTemplateId(smsTemplate.getTemplateId());


      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();


      AlarmRule alarmRule = smsRequestTemplate.getAlarmRule();


      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.setReservoirName(list.get(2));


         temp.setAlarmRecordId(list.get(list.size()-1));


         // 放入临时集合


         tempList.add(temp);


@@ -815,7 +823,7 @@


            //请求参数


            ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(smsTemplate.getTemplateId(), dyns);


            // 先保存结果记录


            SmsResult smsResult = saveSendResult(resultComResult.getCode().toString(),resultComResult.getMsg(),request, 1);


            SmsResult smsResult = saveSendResult(alarmRule.getId(),resultComResult.getCode().toString(),resultComResult.getMsg(),request, 1);


            // 设置手机号


            request.setUserNumber(s);


            // 内容处理


@@ -850,6 +858,247 @@


         }


      });


   }








   @Override


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




      // 取出数据


      SMSSendRequest request = new SMSSendRequest();


      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();


      request.setTemplateId(smsTemplate.getTemplateId());


      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();


      AlarmRule alarmRule = smsRequestTemplate.getAlarmRule();


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


         temp.setCdNm(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(",");




         //按水库再次分组，因为要把测点名称放进水库里


         Map<String, List<Temp>> resCollectGroup = temps.stream().collect(Collectors.groupingBy(Temp::getReservoirCode));




         //这个集合为了存水库和其多个测站


         List<Temp> infoList = new ArrayList<>();


         resCollectGroup.forEach((resCode,temp1)->{


            Temp temp = new Temp();


            temp.setPhone(s);


            temp.setReservoirName(temp1.get(0).getReservoirName());


            temp.setReservoirCode(resCode);


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


            temp1.forEach(info->{


               cdNameList.add("测点" + info.getCdNm());


               temp.setAlarmRecordId(info.getAlarmRecordId());


            });


            temp.setCdNm(String.join("、",cdNameList));


            infoList.add(temp);


         });






         // 如果一人对应水库数量超过30个，则分批发送


         List<List<Temp>> lists = Lists.partition(new ArrayList<>(infoList), 30);


         for (List<Temp> list : lists) {


            List<AlarmRecordDetailVO> alarmRecordDetailList = new ArrayList<>();


            // 遍历


            for (Temp temp : list) {


               builder.append(temp.getReservoirName()+"("+temp.getCdNm() +")").append("，");


               smsRecordBuilder.append(temp.getReservoirName()+"("+temp.getCdNm() +")").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(alarmRule.getId(),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(","));


                  String formatContent = format;


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


               }


               // 保存告警记录详情信息


               try {


                  boolean save = alarmRecordDetailService.saveBatch(alarmRecordDetailArrayList);


               }catch (Exception e){


                  e.printStackTrace();


               }


            }


         }


      });




      return null;


   }




   /**


    * 视频数据接收不到


    * @param smsRequestTemplate


    * @return


    */


   @Override


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




      // 取出数据


      SMSSendRequest request = new SMSSendRequest();


      SmsTemplate smsTemplate = smsRequestTemplate.getSmsTemplate();


      request.setTemplateId(smsTemplate.getTemplateId());


      List<List<String>> templateContent = smsRequestTemplate.getTemplateContent();


      AlarmRule alarmRule = smsRequestTemplate.getAlarmRule();


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


         temp.setCdNm(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(",");




         //按水库再次分组，因为要把测点名称放进水库里


         Map<String, List<Temp>> resCollectGroup = temps.stream().collect(Collectors.groupingBy(Temp::getReservoirCode));




         //这个集合为了存水库和其多个测站


         List<Temp> infoList = new ArrayList<>();


         resCollectGroup.forEach((resCode,temp1)->{


            Temp temp = new Temp();


            temp.setPhone(s);


            temp.setReservoirName(temp1.get(0).getReservoirName());


            temp.setReservoirCode(resCode);


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


            temp1.forEach(info->{


               cdNameList.add( info.getCdNm());


               temp.setAlarmRecordId(info.getAlarmRecordId());


            });


            temp.setCdNm(String.join("、",cdNameList));


            infoList.add(temp);


         });






         // 如果一人对应水库数量超过30个，则分批发送


         List<List<Temp>> lists = Lists.partition(new ArrayList<>(infoList), 15);


         for (List<Temp> list : lists) {


            List<AlarmRecordDetailVO> alarmRecordDetailList = new ArrayList<>();


            // 遍历


            for (Temp temp : list) {


               builder.append(temp.getReservoirName()+"("+temp.getCdNm() +")").append("，");


               smsRecordBuilder.append(temp.getReservoirName()+"("+temp.getCdNm() +")").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(alarmRule.getId(),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(","));


                  String formatContent = format;


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


            }


         }


      });


      return null;


   }






//   /**


//    * 发送合并水库名短信


@@ -916,6 +1165,7 @@


                          SmsTemplate smsTemplate,


                          List<String> rowList,


                          List<AlarmRecordDetailVO> alarmRecordDetailList) {


      AlarmRule alarmRule = smsRequestTemplate.getAlarmRule();


      // 组装数据


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


      String[][] dyns = new String[rowList.size() + 1][titleArr.length];


@@ -928,7 +1178,7 @@


      //请求参数


      ComResult<DynSMSSendDataResult> resultComResult = sendDynSMSSendDataResultComResult(smsTemplate.getTemplateId(), dyns);


      // 先保存结果记录


      SmsResult smsResult = saveSendResult(resultComResult.getCode().toString(),resultComResult.getMsg(),request, rowList.size());


      SmsResult smsResult = saveSendResult(alarmRule.getId(),resultComResult.getCode().toString(),resultComResult.getMsg(),request, rowList.size());


      List<AlarmRecordDetail> alarmRecordDetailArrayList = new ArrayList<>();


      // 遍历


      for (AlarmRecordDetailVO alarmRecordDetailVO : alarmRecordDetailList) {


@@ -1036,6 +1286,7 @@


      return R.data(200,"发送成功!",null);


   }






   /**


    * 校验参数


    * @param smsTemplate