| @@ -35,54 +35,54 @@ public class MqBaseConsumer { | |||||
| public void doMessage(String message) { | public void doMessage(String message) { | ||||
| log.info("received message: {}", message); | log.info("received message: {}", message); | ||||
| // BaseMsg baseMsg = null; | |||||
| // | |||||
| // try { | |||||
| // baseMsg = (BaseMsg)JsonUtil.readValue(message,BaseMsg.class); | |||||
| // | |||||
| // if(EnumMsgRecordType.SMS.getCode().equals(baseMsg.getMsgType())){ | |||||
| // //短信 | |||||
| // sendSmsService.send((WxMsgRecord)JsonUtil.readValue(message,WxMsgRecord.class)); | |||||
| // } else if(EnumMsgRecordType.SMS_CALLBACK.getCode().equals(baseMsg.getMsgType())){ | |||||
| // //业务短信 | |||||
| // sendCallBackSmsService.send((WxMsg)JsonUtil.readValue(message,WxMsg.class)); | |||||
| // } else if(EnumMsgRecordType.EMAIL.getCode().equals(baseMsg.getMsgType())){ | |||||
| // //邮件 | |||||
| // sendEmailService.send((MailMsg)JsonUtil.readValue(message,MailMsg.class)); | |||||
| // } else if(EnumMsgRecordType.SMART_APP.getCode().equals(baseMsg.getMsgType())){ | |||||
| // //微信小程序-模板消息 | |||||
| // sendSmartAppMsgService.send((SmartAppMsg)JsonUtil.readValue(message,SmartAppMsg.class)); | |||||
| // } else if(EnumMsgRecordType.PUBLIC.getCode().equals(baseMsg.getMsgType())) { | |||||
| // //公众号-模板消息 | |||||
| // sendMpMsgService.send((MpAppMsg)JsonUtil.readValue(message,MpAppMsg.class)); | |||||
| // } else if(EnumMsgRecordType.SMART_APP_UNIFORM.getCode().equals(baseMsg.getMsgType())) { | |||||
| // //微信小程序-统一消息 | |||||
| // sendWeappUniformMsgService.send((AppUniformMsg)JsonUtil.readValue(message,AppUniformMsg.class)); | |||||
| // } | |||||
| // baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); | |||||
| // wxMsgRecordMapper.update(baseMsg); | |||||
| // }catch (Exception e){ | |||||
| // try { | |||||
| // log.error("consum received error:{} ", e.getMessage()); | |||||
| // log.error("consum received error: ", e); | |||||
| // //baseMsg.setStatusMessage(e.getMessage()); | |||||
| // baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| // wxMsgRecordMapper.update(baseMsg); | |||||
| // }catch (Exception e1){ | |||||
| // log.error("更新db状态error: ", e1); | |||||
| BaseMsg baseMsg = null; | |||||
| try { | |||||
| baseMsg = (BaseMsg)JsonUtil.readValue(message,BaseMsg.class); | |||||
| if(EnumMsgRecordType.SMS.getCode().equals(baseMsg.getMsgType())){ | |||||
| //短信 | |||||
| sendSmsService.send((WxMsgRecord)JsonUtil.readValue(message,WxMsgRecord.class)); | |||||
| } else if(EnumMsgRecordType.SMS_CALLBACK.getCode().equals(baseMsg.getMsgType())){ | |||||
| //业务短信 | |||||
| sendCallBackSmsService.send((WxMsg)JsonUtil.readValue(message,WxMsg.class)); | |||||
| } else if(EnumMsgRecordType.EMAIL.getCode().equals(baseMsg.getMsgType())){ | |||||
| //邮件 | |||||
| sendEmailService.send((MailMsg)JsonUtil.readValue(message,MailMsg.class)); | |||||
| } else if(EnumMsgRecordType.SMART_APP.getCode().equals(baseMsg.getMsgType())){ | |||||
| //微信小程序-模板消息 | |||||
| sendSmartAppMsgService.send((SmartAppMsg)JsonUtil.readValue(message,SmartAppMsg.class)); | |||||
| } else if(EnumMsgRecordType.PUBLIC.getCode().equals(baseMsg.getMsgType())) { | |||||
| //公众号-模板消息 | |||||
| sendMpMsgService.send((MpAppMsg)JsonUtil.readValue(message,MpAppMsg.class)); | |||||
| } else if(EnumMsgRecordType.SMART_APP_UNIFORM.getCode().equals(baseMsg.getMsgType())) { | |||||
| //微信小程序-统一消息 | |||||
| sendWeappUniformMsgService.send((AppUniformMsg)JsonUtil.readValue(message,AppUniformMsg.class)); | |||||
| } | |||||
| baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); | |||||
| wxMsgRecordMapper.update(baseMsg); | |||||
| }catch (Exception e){ | |||||
| try { | |||||
| log.error("consum received error:{} ", e.getMessage()); | |||||
| log.error("consum received error: ", e); | |||||
| //baseMsg.setStatusMessage(e.getMessage()); | |||||
| baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| wxMsgRecordMapper.update(baseMsg); | |||||
| }catch (Exception e1){ | |||||
| log.error("更新db状态error: ", e1); | |||||
| } | |||||
| // if(null != baseMsg){ | |||||
| // if(baseMsg.getDelayTimeLevel() < 3){ | |||||
| // baseMsg.setDelayTimeLevel(3); //10s后重试 | |||||
| // mqBaseProducer.sendMessage(baseMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); | |||||
| // }else{ | |||||
| // baseMsg.setStatusMessage(e.getMessage()); | |||||
| // baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| // wxMsgRecordMapper.update(baseMsg); | |||||
| // } | |||||
| // } | // } | ||||
| // | |||||
| //// if(null != baseMsg){ | |||||
| //// if(baseMsg.getDelayTimeLevel() < 3){ | |||||
| //// baseMsg.setDelayTimeLevel(3); //10s后重试 | |||||
| //// mqBaseProducer.sendMessage(baseMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); | |||||
| //// }else{ | |||||
| //// baseMsg.setStatusMessage(e.getMessage()); | |||||
| //// baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); | |||||
| //// wxMsgRecordMapper.update(baseMsg); | |||||
| //// } | |||||
| //// } | |||||
| // } | |||||
| } | |||||
| } | } | ||||
| } | } | ||||