diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/dao/mapper/BizSendMsgTemplateMapper.xml b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/dao/mapper/BizSendMsgTemplateMapper.xml index 2d4440d..4f3badd 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/dao/mapper/BizSendMsgTemplateMapper.xml +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/dao/mapper/BizSendMsgTemplateMapper.xml @@ -13,6 +13,7 @@ + \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/entity/BizSendMsgTemplate.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/entity/BizSendMsgTemplate.java index e5939f5..f620cf7 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/entity/BizSendMsgTemplate.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/entity/BizSendMsgTemplate.java @@ -87,6 +87,10 @@ public class BizSendMsgTemplate implements Serializable { @ApiModelProperty(value = "采购方式:procurement_mode_1公开招标,2邀请招标,3公开比选,4公开招募,5竞争性谈判,6单一来源,7公开询价,8竞拍,9单一来源简化流程'") private String purchasingMethod; - + /** + * 是否启用 + */ + @ApiModelProperty(value = "是否启用 0-否 1-是") + private Integer using; } diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizSendMsgTemplateServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizSendMsgTemplateServiceImpl.java index 9c40825..6373ccc 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizSendMsgTemplateServiceImpl.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizSendMsgTemplateServiceImpl.java @@ -65,33 +65,36 @@ public class BizSendMsgTemplateServiceImpl extends ServiceImpl query = new QueryWrapper<>(new BizSendMsgTemplate().setTemplateId(templateId)); //获得短信模板信息 BizSendMsgTemplate msgTemplate = this.getOne(query); - //替换字段,形成需要发送的短信内容 - String magContent = generateMsgFromTemplete(msgTemplate.getContent(), msgInfo.getTempParamMap()); + if(msgTemplate.getUsing()==1){ - //接收人 - List receiverList = msgInfo.getReceiverList(); - receiverList.forEach(receiver -> { - //任务形式:realtime实时;timing-定时 - String taskForm = msgTemplate.getTaskForm(); - if (StringUtils.equals("realtime", taskForm)) { - //发送短信 - sendSms( msgInfo, receiver, magContent, taskForm); - } - else if (StringUtils.equals("timing", taskForm)) { - BizSendMsgLog msgLog = new BizSendMsgLog(); - BeanUtils.copyProperties(msgInfo, msgLog); - msgLog.setReceiverCompanyId(receiver.getReceiverCompanyId()) - .setReceiverCompanyName(receiver.getReceiverCompanyName()) - .setReceiverAccount(receiver.getReceiverAccount()); - LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery(msgLog); - //定时短信,查询当前收信人是或否发送过,发送过则不再发送短信 - List msgLogList = msgLogService.list(queryWrapper); - if (msgLogList.isEmpty()){ + //替换字段,形成需要发送的短信内容 + String magContent = generateMsgFromTemplete(msgTemplate.getContent(), msgInfo.getTempParamMap()); + + //接收人 + List receiverList = msgInfo.getReceiverList(); + receiverList.forEach(receiver -> { + //任务形式:realtime实时;timing-定时 + String taskForm = msgTemplate.getTaskForm(); + if (StringUtils.equals("realtime", taskForm)) { //发送短信 sendSms( msgInfo, receiver, magContent, taskForm); } - } - }); + else if (StringUtils.equals("timing", taskForm)) { + BizSendMsgLog msgLog = new BizSendMsgLog(); + BeanUtils.copyProperties(msgInfo, msgLog); + msgLog.setReceiverCompanyId(receiver.getReceiverCompanyId()) + .setReceiverCompanyName(receiver.getReceiverCompanyName()) + .setReceiverAccount(receiver.getReceiverAccount()); + LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery(msgLog); + //定时短信,查询当前收信人是或否发送过,发送过则不再发送短信 + List msgLogList = msgLogService.list(queryWrapper); + if (msgLogList.isEmpty()){ + //发送短信 + sendSms( msgInfo, receiver, magContent, taskForm); + } + } + }); + } } else if (StringUtils.equals("intraMail", sendType)) { }