From 34aceacf620ce97ff980a083e2ef6fbeb45acf64 Mon Sep 17 00:00:00 2001 From: winter Date: Mon, 8 Jan 2024 13:03:42 +0800 Subject: [PATCH] fix --- .../iformall/mapper/WxMsgConfigMapper.java | 2 ++ .../impl/WxMsgCallbackServiceImpl.java | 23 ++++++++++++++++++- .../resources/mapper/WxMsgConfigMapper.xml | 4 ++++ 3 files changed, 28 insertions(+), 1 deletion(-) diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxMsgConfigMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxMsgConfigMapper.java index 4ee98d525..ce34d0589 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxMsgConfigMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxMsgConfigMapper.java @@ -16,5 +16,7 @@ public interface WxMsgConfigMapper extends CommonMapper { */ void updateRemains(WxMsgConfig wxMsgConfig); + void addRemains(WxMsgConfig wxMsgConfig); + } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgCallbackServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgCallbackServiceImpl.java index 6def2fcdd..e7b281db1 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgCallbackServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgCallbackServiceImpl.java @@ -3,14 +3,18 @@ package com.iformall.service.impl; import com.alibaba.fastjson.JSONArray; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; +import com.iformall.common.ErrorCode; import com.iformall.common.IdWorker; import com.iformall.domain.po.*; import com.iformall.enums.EnumCouponPasswordStatus; import com.iformall.enums.EnumMsgModelStatus; import com.iformall.enums.EnumMsgSendStatus; +import com.iformall.exception.MallinkException; import com.iformall.mapper.*; import com.iformall.service.WxMsgCallbackService; import com.iformall.utils.HMACSHA256; + +import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -216,7 +220,24 @@ public class WxMsgCallbackServiceImpl implements WxMsgCallbackService { } wxMsgCallback.setStatusMsg(param.get("err_msg")); wxMsgCallbackMapper.updateByBatchNo(wxMsgCallback); - + //回滚数量 + WxMsgCallback wxMsgCallbackq = new WxMsgCallback(); + wxMsgCallbackq.setBatchNo(wxMsgCallback.getBatchNo()); + wxMsgCallbackq.setPhone(wxMsgCallback.getPhone()); + List mclist = wxMsgCallbackMapper.findList(wxMsgCallbackq); + if (null != mclist && mclist.size() > 0 ) { + WxMsgCallback mc = mclist.get(0); + WxMsgConfig wxMsgConfig = new WxMsgConfig(); + wxMsgConfig.setTenantId(mc.getTenantId()); + List wxMsgConfigs = wxMsgConfigMapper.findList(wxMsgConfig); + if (wxMsgConfigs.size() == 0){ + logger.error("您还未接入短信运营商,请联系平台管理员"); + }else{ + WxMsgConfig mconfig = wxMsgConfigs.get(0); + mconfig.setRemains(1L); + wxMsgConfigMapper.addRemains(mconfig); + } + } } public boolean checksign(String tenantId,Map param){ diff --git a/mallinkService/src/main/resources/mapper/WxMsgConfigMapper.xml b/mallinkService/src/main/resources/mapper/WxMsgConfigMapper.xml index 9456c59e8..ceb0a2e71 100644 --- a/mallinkService/src/main/resources/mapper/WxMsgConfigMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxMsgConfigMapper.xml @@ -136,6 +136,10 @@ + + update wx_msg_config set remains = remains + #{remains} where id = #{id} + +