短信指定楼栋发送

linwe

2024-08-09 37be14fc1e419396af3441da0701e2bf99f47112

 src/main/java/org/springblade/modules/sms/service/impl/SmsSendServiceImpl.java

@@ -16,6 +16,7 @@
 */
package org.springblade.modules.sms.service.impl;

import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -32,14 +33,15 @@
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.modules.resource.entity.Sms;
import org.springblade.modules.resource.service.ISmsService;
import org.springblade.modules.sms.entity.SmsRecordEntity;
import org.springblade.modules.sms.entity.SmsTemplateEntity;
import org.springblade.modules.sms.mapper.SmsTemplateMapper;
import org.springblade.modules.sms.service.ISmsRecordService;
import org.springblade.modules.sms.service.ISmsSendService;
import org.springblade.modules.sms.service.ISmsTemplateService;
import org.springblade.modules.sms.entity.SmsRecordEntity;
import org.springblade.modules.sms.service.ISmsRecordService;
import org.springblade.modules.smsTask.entity.SmsTaskEntity;
import org.springblade.modules.smsTask.service.ISmsTaskService;
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserService;
import org.springblade.modules.system.vo.UserVO;
import org.springblade.modules.task.entity.TaskPlaceSelfCheckEntity;
@@ -358,6 +360,11 @@
   public Boolean batchSendNotice(Long smsTaskId) {
      ISmsTaskService taskService = SpringUtils.getBean(ISmsTaskService.class);
      SmsTaskEntity smsTaskEntity = taskService.getById(smsTaskId);
      List<User> phoneList = taskService.selectSmsTaskListByPhone(smsTaskEntity);
      if (CollectionUtil.isEmpty(phoneList)) {
         logger.error("未查询到电话好好");
         return false;
      }

      Sms serviceOne = iSmsService.getOne(Wrappers.<Sms>lambdaQuery().eq(Sms::getStatus, 2));
      if (serviceOne == null) {
@@ -370,11 +377,12 @@
         logger.error("未找到对应的短信模板");
         return false;
      }

      Boolean aBoolean = false;
      for (User user : phoneList) {
      //发送的手机号
      List<Map> phonesList = new ArrayList<>();
      Map phoneMap = new HashMap();
      // phoneMap.put("phone", phone);
         phoneMap.put("phone", user.getPhone());
      List<String> varList = new ArrayList<>();
      // 设置参数
      phoneMap.put("varList", varList);
@@ -400,8 +408,10 @@
      //创建人主键
      params.put("sop_create_by", serviceOne.getSmsCode());
      //短信发送记录
      // saveSmsRecord(phone, serviceOne, placeSelfCheckEntity.getPlaceName(), content);
      Boolean aBoolean = sendSmsGet(serviceOne, params);
         saveSmsRecord(user.getPhone(), serviceOne, user.getName(), content);
         aBoolean = sendSmsGet(serviceOne, params);
      }

      return aBoolean;

   }