From b375f8b9c4a21eb817ac3cc78ca8034c617a6db3 Mon Sep 17 00:00:00 2001 From: xhxu Date: Thu, 2 Sep 2021 16:04:17 +0800 Subject: [PATCH] msg --- .../java/com/iformall/service/impl/WxMsgServiceImpl.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java index 3e8e19dd2..b67e805bf 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java @@ -148,15 +148,16 @@ public class WxMsgServiceImpl implements WxMsgService { wxMsg.setCouponInject(null); wxMsg.setMsgType(EnumMsgRecordType.SMS_CALLBACK.getCode()); wxMsg.setReceiver(wxMsg.getPhones()); + wxMsgMapper.insert(wxMsg); mqBaseProducer.sendMessage(wxMsg, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),null); } }else if(wxMsg.getWay() == EnumSendWay.APPINFOR.getCode()){ + wxMsgMapper.insert(wxMsg); batchSendAppinfo(wxMsg); }else{ return new ResultData(ErrorCode.MSG_REQUEST_PARAMS_ERROR); } - wxMsgMapper.insert(wxMsg); return new ResultData(Result.SUCCESS, "消息已发送"); } else { wxMsg.setStatus(EnumMsgStatus.MSG_STATUS_NOT_SEND.getCode()); @@ -182,14 +183,16 @@ public class WxMsgServiceImpl implements WxMsgService { wxMsg.setWxMsgConfig(wxMsgConfig); wxMsg.setMsgType(EnumMsgRecordType.SMS_CALLBACK.getCode()); wxMsg.setReceiver(wxMsg.getPhones()); + wxMsgMapper.updateById(wxMsg); mqBaseProducer.sendMessage(wxMsg, EnumMsgMqTopic.DEFAULT.getCode(),EnumMsgMqTag.DEFAULT.getCode(),EnumMsgMqKey.DEFAULT.getCode()); } }else if(wxMsg.getWay() == EnumSendWay.APPINFOR.getCode()){ + wxMsgMapper.updateById(wxMsg); batchSendAppinfo(wxMsg); }else{ return new ResultData(ErrorCode.MSG_REQUEST_PARAMS_ERROR); } - wxMsgMapper.updateById(wxMsg); + return new ResultData(Result.SUCCESS, "消息已发送"); } else { //定时