Przeglądaj źródła

msg

release_toaliyun_real
xhxu 4 lat temu
rodzic
commit
179b91511b
2 zmienionych plików z 5 dodań i 6 usunięć
  1. +3
    -0
      mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java
  2. +2
    -6
      mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java

+ 3
- 0
mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java Wyświetl plik

@@ -341,6 +341,9 @@ public class WxMsgServiceImpl implements WxMsgService {
for (int i = 0; i < extracount; i++) { for (int i = 0; i < extracount; i++) {
WxMsg wxMsg1 = new WxMsg(); WxMsg wxMsg1 = new WxMsg();
wxMsg1.setId(wxMsg.getId()); wxMsg1.setId(wxMsg.getId());
wxMsg1.setSignature(wxMsg.getSignature());
wxMsg1.setMsg(wxMsg.getMsg());
wxMsg1.setModelId(wxMsg.getModelId());
if (extra > 0 && i == index) { if (extra > 0 && i == index) {
List<String> phoneList = Arrays.asList(split).subList(i * 1000, length); List<String> phoneList = Arrays.asList(split).subList(i * 1000, length);
String phones = StringUtils.join(phoneList, ","); String phones = StringUtils.join(phoneList, ",");


+ 2
- 6
mallinkService/src/main/java/com/iformall/service/msg/impl/SendCallBackSmsServiceImpl.java Wyświetl plik

@@ -75,16 +75,10 @@ public class SendCallBackSmsServiceImpl implements MsgSendService {
throw new MallinkException(ErrorCode.MSG_CONFIG_ACCOUNT); throw new MallinkException(ErrorCode.MSG_CONFIG_ACCOUNT);
} }
} }
WxCouponInject couponInject = record.getCouponInject();

String secret = wxMsgConfig.getSecret();
String bid = wxMsgConfig.getBid();
String publickey = wxMsgConfig.getPublickey();


String phone = record.getPhones(); String phone = record.getPhones();
String signature = record.getSignature(); String signature = record.getSignature();
String msg = record.getMsg(); String msg = record.getMsg();
String notifyUrl = wxMsgConfig.getNotifyurl();
WxMsgModel wxMsgModel = wxMsgModelMapper.selectById(record.getModelId()); WxMsgModel wxMsgModel = wxMsgModelMapper.selectById(record.getModelId());
Integer modelId = null; Integer modelId = null;
if (wxMsgModel != null) { if (wxMsgModel != null) {
@@ -143,9 +137,11 @@ public class SendCallBackSmsServiceImpl implements MsgSendService {
wxMsgService.addMsgCallback(record, batchNo); wxMsgService.addMsgCallback(record, batchNo);
//wx_msg改为已发送 //wx_msg改为已发送
record.setStatus(EnumMsgStatus.MSG_STATUS_SENDED.getCode()); record.setStatus(EnumMsgStatus.MSG_STATUS_SENDED.getCode());
record.setExpectSendNumber(null);
wxMsgMapper.updateById(record); wxMsgMapper.updateById(record);
} else { } else {
logger.error("发送:{},运营商返回失败:{}",phone,result); logger.error("发送:{},运营商返回失败:{}",phone,result);
record.setExpectSendNumber(null);
wxMsgMapper.updateById(record); wxMsgMapper.updateById(record);
throw new MallinkException(1001,"运营商返回失败:"+result); throw new MallinkException(1001,"运营商返回失败:"+result);
} }


Ładowanie…
Anuluj
Zapisz