From 955cf1e61b5a6cd94bd3fb2a0dbfdf1d9677c11c Mon Sep 17 00:00:00 2001 From: luozukai Date: Tue, 23 Apr 2019 14:09:26 +0800 Subject: [PATCH] =?UTF-8?q?[=E7=9F=AD=E4=BF=A1][=E4=BF=AE=E6=94=B9][?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=89=A3=E5=87=8F=E5=89=A9=E4=BD=99=E6=9D=A1?= =?UTF-8?q?=E6=95=B0]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iformall/service/impl/WxMsgValidationcodeServiceImpl.java | 3 --- .../iformall/service/msg/impl/SendCallBackSmsServiceImpl.java | 3 +++ .../java/com/iformall/service/msg/impl/SendSmsServiceImpl.java | 3 +++ 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeServiceImpl.java index 0ad0e5511..be0ba10a4 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeServiceImpl.java @@ -1,6 +1,5 @@ package com.iformall.service.impl; -import com.alibaba.fastjson.JSONObject; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.iformall.common.ErrorCode; @@ -13,13 +12,11 @@ import com.iformall.enums.*; import com.iformall.mapper.*; import com.iformall.mq.MqBaseProducer; import com.iformall.service.WxMsgValidationcodeService; -import com.iformall.utils.*; import org.apache.commons.collections.map.HashedMap; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; - import java.util.*; import java.util.stream.Collectors; diff --git a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java index cd4f9f9f6..fa8776c97 100644 --- a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java @@ -91,6 +91,9 @@ public class SendCallBackSmsServiceImpl implements MsgSendService { if (ret.equals(EnumMsgSendStatus.MSG_SEND_SUCCESS.getCode().toString())) { record.setSendstatus(EnumMsgSendStatus.MSG_SEND_SUCCESS.getCode()); + //扣减剩余条数 + wxMsgConfig.setRemains(1l); + wxMsgConfigMapper.updateRemains(wxMsgConfig); } else { record.setSendstatus(EnumMsgSendStatus.MSG_SEND_FAIL.getCode()); } diff --git a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java index 5a6fa9e9b..e0460d9bc 100644 --- a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java @@ -102,6 +102,9 @@ public class SendSmsServiceImpl implements MsgSendService { } wxMsgValidationcodeMapper.insertSelective(wxMsgValidationcode); wxMsgValidationcodeService.addMsgCallback(wxMsgValidationcode,batchNo); + //扣减剩余条数 + wxMsgConfig.setRemains(1l); + wxMsgConfigMapper.updateRemains(wxMsgConfig); }else{ throw new MallinkException(1001,"运营商返回失败:"+result); }