短信发送修改

zhongrj

2023-06-01 dc5a0d769ba6c352d89c04c67b66ed1869ec1049

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

@@ -5,16 +5,20 @@
import cn.com.flaginfo.sdk.cmc.api.sms.dynsend.DynSMSSendRequest;
import cn.com.flaginfo.sdk.cmc.api.sms.send.SMSSendDataResult;
import cn.com.flaginfo.sdk.cmc.api.sms.send.SMSSendRequest;
import cn.gistack.sm.alarmRule.entity.AlarmRecordDetail;
import cn.gistack.sm.alarmRule.service.AlarmRecordDetailService;
import cn.gistack.sm.sms.entity.SmsRecord;
import cn.gistack.sm.sms.entity.SmsResult;
import cn.gistack.sm.sms.entity.SmsTemplate;
import cn.gistack.sm.sms.service.ISmsRecordService;
import cn.gistack.sm.sms.service.ISmsResultService;
import cn.gistack.sm.sms.service.SmsService;
import cn.gistack.sm.sms.util.SmsUtils;
import cn.gistack.sm.sms.vo.SmsRequestTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;

import java.util.*;

/**
 * 短信发送服务实现层
@@ -26,6 +30,9 @@

   @Autowired
   private ISmsRecordService smsRecordService;

   @Autowired
   private AlarmRecordDetailService alarmRecordDetailService;

   @Autowired
   private ISmsResultService smsResultService;
@@ -59,14 +66,81 @@

   /**
    * 发送 具名 变量模板短信
    * @param title 具名变量头
    * @param content 内容对象
    * @param smsRequestTemplate
    * @return
    */
   @Override
   public Object sendSignMsg(String title, String content, SMSSendRequest request) {
   public Object sendSignMsg(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("短信");
         // 删除 最后一个 告警记录id
         list.remove(list.size() - 1);
         // 删除 0 水库编码
         list.remove(0);
         // 转换字符串
         String row = String.join(",", list);
         // 组装数据
         String[][] dyns = new String[][]{{smsRequestTemplate.getTitle()}, {row}};
         //请求参数
         DynSMSSendRequest sendRequest = new DynSMSSendRequest();
         sendRequest.setTemplateId(smsTemplate.getTemplateId());
         sendRequest.setDynData(dyns);
         // 发送
         ComResult<DynSMSSendDataResult> resultComResult = SmsUtils.dynSendMethod(sendRequest);

         SmsRecord smsRecord = new SmsRecord();
         if (null != smsResult){
            // 设置手机号
            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 = saveSmsRecord(request, resultComResult.getCode(), 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);
      map.put("smsResult",smsResult);
      // 返回
      return map;
   }


   /**
    * 发送 具名 变量模板短信--批量一次发送
    * @param title 具名变量头
    * @return
    */
   public Object sendSignMsg(String title, String datas, SMSSendRequest request, Integer type, SmsTemplate smsTemplate) {
      String[] titleArr = title.split(",");
      String[] rows = content.split(";");
      String[] rows = datas.split(";");
      String[][] dyns = new String[rows.length + 1][titleArr.length];
      dyns[0] = titleArr;
      int rowNum = 1;
@@ -82,12 +156,16 @@
      ComResult<DynSMSSendDataResult> resultComResult = SmsUtils.dynSendMethod(sendRequest);
      // 先保存结果记录
      SmsResult smsResult = saveSendResult(request, rows.length);
      SmsRecord smsRecord = new SmsRecord();
      if (null != smsResult){
         // 保存记录
         saveSmsRecord(request,resultComResult.getCode(),resultComResult.getMsg(),smsResult.getId());
         smsRecord = saveSmsRecord(request, resultComResult.getCode(), resultComResult.getMsg(), smsResult.getId());
      }
      Map<String, Object> map = new HashMap<>(2);
      map.put("smsRecord",smsRecord);
      map.put("smsResult",smsResult);
      // 返回
      return resultComResult;
      return map;
   }

   /**
@@ -97,7 +175,7 @@
    * @param msg 响应消息
    * @param resultId
    */
   private void saveSmsRecord(SMSSendRequest request,Integer code,String msg, Long resultId) {
   private SmsRecord saveSmsRecord(SMSSendRequest request,Integer code,String msg, Long resultId) {
      // 在保存明细
      SmsRecord smsRecord = new SmsRecord();
      smsRecord.setTel(request.getUserNumber());
@@ -108,6 +186,8 @@
      smsRecord.setResponseMsg(msg);
      //插入记录
      smsRecordService.save(smsRecord);
      // 返回
      return smsRecord;
   }

   /**