diff --git a/mallinkService/src/main/java/com/iformall/enums/EnumMsgModel.java b/mallinkService/src/main/java/com/iformall/enums/EnumMsgModel.java index 27dadc8b4..936a8b9fd 100644 --- a/mallinkService/src/main/java/com/iformall/enums/EnumMsgModel.java +++ b/mallinkService/src/main/java/com/iformall/enums/EnumMsgModel.java @@ -13,7 +13,8 @@ public enum EnumMsgModel { FLOW_REJECT_NODIFY(5, "驳回通知"), VALIDATION_CODE(6, "验证码"), BILL_WAIT_PAY(7, "账单待缴通知"), - BILL_OWE(8, "账单欠缴通知") + BILL_OWE(8, "账单欠缴通知"), + COUPON_SEND(9, "场景投放"), ; public static EnumMsgModel getEnum(Integer code) { diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java index a3974c5f4..0d98440aa 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java @@ -5,13 +5,12 @@ import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.iformall.common.IdWorker; import com.iformall.domain.po.*; +import com.iformall.domain.po.msg.WxMsgRecord; import com.iformall.domain.vo.WxCouponSendVo; import com.iformall.enums.*; import com.iformall.exception.MallinkException; -import com.iformall.mapper.WxCouponOrderMapper; -import com.iformall.mapper.WxCouponSendConfigMapper; -import com.iformall.mapper.WxCouponSendMapper; -import com.iformall.mapper.WxMerchantBUserMapper; +import com.iformall.mapper.*; +import com.iformall.mq.MqBaseProducer; import com.iformall.service.*; import com.iformall.utils.DateUtils; import org.slf4j.Logger; @@ -22,7 +21,9 @@ import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import java.util.Date; +import java.util.HashMap; import java.util.List; +import java.util.Map; @Service public class WxCouponSendServiceImpl implements WxCouponSendService { @@ -46,7 +47,12 @@ public class WxCouponSendServiceImpl implements WxCouponSendService { WxMerchantBUserMapper wxMerchantBUserMapper; @Autowired PushLimitService pushLimitService; - + @Autowired + private MqBaseProducer mqBaseProducer; + @Autowired + WxCUserMapper wxCUserMapper; + @Autowired + WxAppinfoService wxAppinfoService; @Override public PageInfo listAsPage(WxCouponSend record, Integer pageIndex, Integer pageSize) { @@ -224,6 +230,30 @@ public class WxCouponSendServiceImpl implements WxCouponSendService { } catch (Exception e) { logger.error(e.getMessage()); } + + // 发送短信 + if (send.getSendSms().equals(EnumCouponSendSms.YES.getCode())) { + //券名 + String title = send.getTitle(); + //找出用户手机号 + WxCUser user = wxCUserMapper.selectByPrimaryKey(cUserId); + String phone = user.getPhone(); + //小程序名称 + WxAppinfo appInfo = wxAppinfoService.getCAppInfo(tenantId); + String appName = appInfo.getName(); + Map msgReplaceMap = new HashMap(); + msgReplaceMap.put("title", title); + msgReplaceMap.put("app", appName); + + WxMsgRecord wxMsgRecord = new WxMsgRecord(); + wxMsgRecord.setMsgType(EnumMsgRecordType.SMS.getCode()); + wxMsgRecord.setModelType(EnumMsgModel.COUPON_SEND.getCode()); + wxMsgRecord.setReceiver(phone); + wxMsgRecord.setTenantId(tenantId); + wxMsgRecord.setDynamicContentMap(msgReplaceMap); + mqBaseProducer.sendMessage(wxMsgRecord, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + + } } return bRet;