|
|
|
@@ -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<WxMsgCallback> mclist = wxMsgCallbackMapper.findList(wxMsgCallbackq); |
|
|
|
if (null != mclist && mclist.size() > 0 ) { |
|
|
|
WxMsgCallback mc = mclist.get(0); |
|
|
|
WxMsgConfig wxMsgConfig = new WxMsgConfig(); |
|
|
|
wxMsgConfig.setTenantId(mc.getTenantId()); |
|
|
|
List<WxMsgConfig> 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<String, String> param){ |
|
|
|
|