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 b8caa707a..d175db730 100644 --- a/mallinkService/src/main/java/com/simple/service/impl/WxMsgCallbackServiceImpl.java +++ b/mallinkService/src/main/java/com/simple/service/impl/WxMsgCallbackServiceImpl.java @@ -58,16 +58,18 @@ public class WxMsgCallbackServiceImpl implements WxMsgCallbackService { wxMsgConfig.setBid(bid); String tenantid=null; List list = wxMsgConfigMapper.findList(wxMsgConfig); - if(list.size()==1){ - tenantid=list.get(0).getTenantId(); - } - List wxMsgCallbacks = JSONArray.parseArray(item, WxMsgCallback.class); + if(list.size()==1) { + List wxMsgCallbacks = JSONArray.parseArray(item, WxMsgCallback.class); + wxMsgConfig = list.get(0); + wxMsgConfig.setRemains(wxMsgConfig.getRemains() - wxMsgCallbacks.size()); + wxMsgConfigMapper.updateByPrimaryKeySelective(wxMsgConfig); - for(WxMsgCallback wxMsgCallback:wxMsgCallbacks){ - wxMsgCallback.setTenantId(tenantid); - wxMsgCallback.setSign(sign); - wxMsgCallback.setCreatetime(new Date()); - wxMsgCallbackMapper.insertSelective(wxMsgCallback); + for (WxMsgCallback wxMsgCallback : wxMsgCallbacks) { + wxMsgCallback.setTenantId(tenantid); + wxMsgCallback.setSign(sign); + wxMsgCallback.setCreatetime(new Date()); + wxMsgCallbackMapper.insertSelective(wxMsgCallback); + } } }