From c0063fc2bc29721434c5496a28585a51b7fc807f Mon Sep 17 00:00:00 2001 From: gongbiao Date: Wed, 5 Sep 2018 13:01:05 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=A0=87=E7=AD=BE=E7=9F=AD=E4=BF=A1][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9]=E5=9B=9E=E8=B0=83=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/simple/controller/WxMsgCallbackController.java | 5 +++-- .../main/java/com/simple/service/WxMsgCallbackService.java | 4 ++-- .../com/simple/service/impl/WxMsgCallbackServiceImpl.java | 6 ++++-- 3 files changed, 9 insertions(+), 6 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/simple/controller/WxMsgCallbackController.java b/mallinkAdmin/src/main/java/com/simple/controller/WxMsgCallbackController.java index 70bdb852b..f2c57aa9a 100644 --- a/mallinkAdmin/src/main/java/com/simple/controller/WxMsgCallbackController.java +++ b/mallinkAdmin/src/main/java/com/simple/controller/WxMsgCallbackController.java @@ -73,14 +73,15 @@ public class WxMsgCallbackController extends BaseController //解析param数据插入数据库中 String item = param.get("item"); String sign = param.get("sign"); - wxMsgCallbackService.saveOrUpdate(bid,item,sign); + String tenantId=getTenantId(); + wxMsgCallbackService.saveOrUpdate(tenantId,bid,item,sign); } @RequestMapping(value = "/receivemodel/{bid}") public void receivemodel(@PathVariable String bid, @RequestParam Map param) { //解析param数据插入数据库中 - wxMsgCallbackService.receivemodel(bid,param); + wxMsgCallbackService.receivemodel(getTenantId(),bid,param); } diff --git a/mallinkService/src/main/java/com/simple/service/WxMsgCallbackService.java b/mallinkService/src/main/java/com/simple/service/WxMsgCallbackService.java index 9204cc7f4..f60d823e5 100644 --- a/mallinkService/src/main/java/com/simple/service/WxMsgCallbackService.java +++ b/mallinkService/src/main/java/com/simple/service/WxMsgCallbackService.java @@ -39,9 +39,9 @@ public interface WxMsgCallbackService { void deleteById(Long id); - void saveOrUpdate(String bid, String item, String sign); + void saveOrUpdate(String tenantId, String bid, String item, String sign); - void receivemodel(String bid, Map param); + void receivemodel(String tenantId, String bid, Map param); void receiveverifymodel(String bid, Map param); diff --git a/mallinkService/src/main/java/com/simple/service/impl/WxMsgCallbackServiceImpl.java b/mallinkService/src/main/java/com/simple/service/impl/WxMsgCallbackServiceImpl.java index dfae67d34..beb9fe8c1 100644 --- a/mallinkService/src/main/java/com/simple/service/impl/WxMsgCallbackServiceImpl.java +++ b/mallinkService/src/main/java/com/simple/service/impl/WxMsgCallbackServiceImpl.java @@ -63,9 +63,10 @@ public class WxMsgCallbackServiceImpl implements WxMsgCallbackService { } @Override - public void saveOrUpdate(String bid, String item, String sign) { + public void saveOrUpdate(String tenantId,String bid, String item, String sign) { WxMsgConfig wxMsgConfig = new WxMsgConfig(); + wxMsgConfig.setTenantId(tenantId); wxMsgConfig.setBid(bid); List list = wxMsgConfigMapper.findList(wxMsgConfig); if(list.size()==1) { @@ -84,8 +85,9 @@ public class WxMsgCallbackServiceImpl implements WxMsgCallbackService { } @Override - public void receivemodel(String bid, Map param) { + public void receivemodel(String tenantId, String bid, Map param) { WxMsgConfig wxMsgConfig = new WxMsgConfig(); + wxMsgConfig.setTenantId(tenantId); wxMsgConfig.setBid(bid); List list = wxMsgConfigMapper.findList(wxMsgConfig); if(list.size()==1) {