Преглед изворни кода

[短信][修改][添加扣减剩余条数]

release_toaliyun_real
luozukai пре 7 година
родитељ
комит
955cf1e61b
3 измењених фајлова са 6 додато и 3 уклоњено
  1. +0
    -3
      mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeServiceImpl.java
  2. +3
    -0
      mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java
  3. +3
    -0
      mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java

+ 0
- 3
mallinkService/src/main/java/com/iformall/service/impl/WxMsgValidationcodeServiceImpl.java Прегледај датотеку

@@ -1,6 +1,5 @@
package com.iformall.service.impl; package com.iformall.service.impl;


import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.iformall.common.ErrorCode; import com.iformall.common.ErrorCode;
@@ -13,13 +12,11 @@ import com.iformall.enums.*;
import com.iformall.mapper.*; import com.iformall.mapper.*;
import com.iformall.mq.MqBaseProducer; import com.iformall.mq.MqBaseProducer;
import com.iformall.service.WxMsgValidationcodeService; import com.iformall.service.WxMsgValidationcodeService;
import com.iformall.utils.*;
import org.apache.commons.collections.map.HashedMap; import org.apache.commons.collections.map.HashedMap;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

import java.util.*; import java.util.*;
import java.util.stream.Collectors; import java.util.stream.Collectors;




+ 3
- 0
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())) { if (ret.equals(EnumMsgSendStatus.MSG_SEND_SUCCESS.getCode().toString())) {
record.setSendstatus(EnumMsgSendStatus.MSG_SEND_SUCCESS.getCode()); record.setSendstatus(EnumMsgSendStatus.MSG_SEND_SUCCESS.getCode());
//扣减剩余条数
wxMsgConfig.setRemains(1l);
wxMsgConfigMapper.updateRemains(wxMsgConfig);
} else { } else {
record.setSendstatus(EnumMsgSendStatus.MSG_SEND_FAIL.getCode()); record.setSendstatus(EnumMsgSendStatus.MSG_SEND_FAIL.getCode());
} }


+ 3
- 0
mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmsServiceImpl.java Прегледај датотеку

@@ -102,6 +102,9 @@ public class SendSmsServiceImpl implements MsgSendService {
} }
wxMsgValidationcodeMapper.insertSelective(wxMsgValidationcode); wxMsgValidationcodeMapper.insertSelective(wxMsgValidationcode);
wxMsgValidationcodeService.addMsgCallback(wxMsgValidationcode,batchNo); wxMsgValidationcodeService.addMsgCallback(wxMsgValidationcode,batchNo);
//扣减剩余条数
wxMsgConfig.setRemains(1l);
wxMsgConfigMapper.updateRemains(wxMsgConfig);
}else{ }else{
throw new MallinkException(1001,"运营商返回失败:"+result); throw new MallinkException(1001,"运营商返回失败:"+result);
} }


Loading…
Откажи
Сачувај