From f9d16d60d2a4f5259f85db79c9b59879488d3164 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Tue, 6 Aug 2019 11:49:30 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=8F=91=E5=88=B8=E6=B6=88=E6=81=AF][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9]:=E5=8F=91=E5=88=B8=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E5=88=86=E7=A6=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/WxCouponSendServiceImpl.java | 67 ++++++++++--------- 1 file changed, 37 insertions(+), 30 deletions(-) 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 fdd15eb99..ae18fdda8 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponSendServiceImpl.java @@ -261,6 +261,40 @@ public class WxCouponSendServiceImpl implements WxCouponSendService { } private void sendMsgForSendCoupon(String tenantId, WxCouponSend send, WxCouponOrder couponOrder, WxCUser user) { + // 发送微信模板消息(公众号模板消息/小程序统一消息/小程序模板消息) + sendMpMsgForSendCoupon(send, couponOrder, user); + + // 发送短信 + if (send.getSendSms().equals(EnumCouponSendSms.YES.getCode())) { + logger.info("》》》》》》》》》》》"); + logger.info("场景投放发送短信开始"); + logger.info("》》》》》》》》》》》"); + //券名 + String title = send.getTitle(); + //找出用户手机号 + 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()); + logger.info("》》》》》》》》》》》"); + logger.info("场景投放发送短信结束"); + logger.info("》》》》》》》》》》》"); + } + } + + private boolean sendMpMsgForSendCoupon(WxCouponSend send, WxCouponOrder couponOrder, WxCUser user) { // 发送 公众号 模板消息 SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS"); String gotopage = "pages/index/index?type=mc"; @@ -275,7 +309,7 @@ public class WxCouponSendServiceImpl implements WxCouponSendService { msgLimit.setLimitId(user.getMpOpenId()); if(wxMsgLimitService.checkIsLimit(msgLimit)) { logger.error("用户公众号模板消息超限" + user.getId()); - return; + return true; } // 已关注公众号 @@ -324,7 +358,7 @@ public class WxCouponSendServiceImpl implements WxCouponSendService { msgLimit.setLimitId(user.getOpenId()); if(wxMsgLimitService.checkIsLimit(msgLimit)) { logger.error("用户小程序统一模板消息超限:" + user.getId()); - return; + return true; } // 获取小程序关联的服务号 WxAuthorizerInfo authQ = new WxAuthorizerInfo(); @@ -356,34 +390,7 @@ public class WxCouponSendServiceImpl implements WxCouponSendService { } } } - // 发送短信 - if (send.getSendSms().equals(EnumCouponSendSms.YES.getCode())) { - logger.info("》》》》》》》》》》》"); - logger.info("场景投放发送短信开始"); - logger.info("》》》》》》》》》》》"); - //券名 - String title = send.getTitle(); - //找出用户手机号 - 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()); - logger.info("》》》》》》》》》》》"); - logger.info("场景投放发送短信结束"); - logger.info("》》》》》》》》》》》"); - } + return false; } @Override