Browse Source

发送微信订阅 4

dev_shibei_match
liushaowen 5 years ago
parent
commit
1a89da20c9
  1. 3
      epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/WxmpMessageController.java
  2. 9
      epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/WxmpMessageServiceImpl.java

3
epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/WxmpMessageController.java

@ -66,6 +66,9 @@ public class WxmpMessageController {
} }
@PostMapping("sendwxsubscribemessage") @PostMapping("sendwxsubscribemessage")
public Result sendWxSubscribeMessage(@RequestBody List<WxSubscribeMessageFormDTO> msgList){ public Result sendWxSubscribeMessage(@RequestBody List<WxSubscribeMessageFormDTO> msgList){
for (WxSubscribeMessageFormDTO wxSubscribeMessageFormDTO : msgList) {
ValidatorUtils.validateEntity(wxSubscribeMessageFormDTO);
}
wxmpMessageService.sendWxSubscribeMessage(msgList); wxmpMessageService.sendWxSubscribeMessage(msgList);
return new Result(); return new Result();
} }

9
epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/WxmpMessageServiceImpl.java

@ -117,8 +117,6 @@ public class WxmpMessageServiceImpl implements WxmpMessageService {
int succecssCount = 0; int succecssCount = 0;
for (WxSubscribeMessageFormDTO msg : msgList) { for (WxSubscribeMessageFormDTO msg : msgList) {
try { try {
ValidatorUtils.validateEntity(msg);
String userId = msg.getUserId(); String userId = msg.getUserId();
String clientType = msg.getClientType(); String clientType = msg.getClientType();
String customerId = msg.getCustomerId(); String customerId = msg.getCustomerId();
@ -238,9 +236,9 @@ public class WxmpMessageServiceImpl implements WxmpMessageService {
} catch (Exception e) { } catch (Exception e) {
String errMsg = e.getMessage(); String errMsg = e.getMessage();
//ValidateException错误信息为getMsg //ValidateException错误信息为getMsg
if (StringUtils.isBlank(errMsg) && e instanceof ValidateException) { // if (StringUtils.isBlank(errMsg) && e instanceof ValidateException) {
errMsg = ((ValidateException) e).getMsg(); // errMsg = ((ValidateException) e).getMsg();
} // }
if (e instanceof WxSubscribeException){ if (e instanceof WxSubscribeException){
//存表 //存表
WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = initRecord(msg, ((WxSubscribeException) e).getOpenId(), WxmpMessageConstant.ERROR); WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = initRecord(msg, ((WxSubscribeException) e).getOpenId(), WxmpMessageConstant.ERROR);
@ -257,6 +255,7 @@ public class WxmpMessageServiceImpl implements WxmpMessageService {
} }
logger.info("{}条消息中的{}条发送成功", msgList.size(), succecssCount); logger.info("{}条消息中的{}条发送成功", msgList.size(), succecssCount);
} }
//初始化记录对象
private WxmpMsgSendRecordEntity initRecord(WxSubscribeMessageFormDTO msg, String openId, String status){ private WxmpMsgSendRecordEntity initRecord(WxSubscribeMessageFormDTO msg, String openId, String status){
WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = new WxmpMsgSendRecordEntity(); WxmpMsgSendRecordEntity wxmpMsgSendRecordEntity = new WxmpMsgSendRecordEntity();
wxmpMsgSendRecordEntity.setCustomerId(msg.getCustomerId()); wxmpMsgSendRecordEntity.setCustomerId(msg.getCustomerId());

Loading…
Cancel
Save