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) {