From 83c1ce85e7a0e7519a5e8d7ee778ed3be324aab8 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Mon, 11 Nov 2019 19:50:08 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=A0=B8=E9=94=80=E5=BC=82=E5=B8=B8][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9]:=E6=A0=B8=E9=94=80=E5=A4=B1=E8=B4=A5?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=87=8D=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/controller/msg/WxMsgRecordController.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgRecordController.java b/mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgRecordController.java index 810a9a14b..4bb69b2c8 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgRecordController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/msg/WxMsgRecordController.java @@ -103,6 +103,13 @@ public class WxMsgRecordController extends BaseController { msg.setReceiver(wxMsgRecord.getReceiver()); msg.updateTenantInfo(tenantEntity); mqBaseProducer.sendMessage(msg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + }else if(EnumMsgRecordType.INSIDE_COUPON_VERIFY.getCode().equals(wxMsgRecord.getMsgType())){ + //内部消息 - 券核销 + FmInsideCouponVerifyMsg msg = (FmInsideCouponVerifyMsg) JsonUtil.readValue(wxMsgRecord.getMsgJson(),FmInsideCouponVerifyMsg.class); + msg.setMsgType(wxMsgRecord.getMsgType()); + msg.setReceiver(wxMsgRecord.getReceiver()); + msg.setTenantId(wxMsgRecord.getTenantId()); + mqBaseProducer.sendMessage(msg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); } } return new ResultData();