| @@ -30,6 +30,8 @@ public class MqBaseConsumer { | |||||
| private SendMpMsgServiceImpl sendMpMsgService; | private SendMpMsgServiceImpl sendMpMsgService; | ||||
| @Autowired | @Autowired | ||||
| private SendWeappUniformMsgServiceImpl sendWeappUniformMsgService; | private SendWeappUniformMsgServiceImpl sendWeappUniformMsgService; | ||||
| @Autowired | |||||
| private FmInsideOrderSuccessMsgServiceImpl fmInsideOrderSuccessMsgService; | |||||
| public void doMessage(String message) { | public void doMessage(String message) { | ||||
| log.info("received message: {}", message); | log.info("received message: {}", message); | ||||
| @@ -65,7 +67,7 @@ public class MqBaseConsumer { | |||||
| } else if(EnumMsgRecordType.INSIDE_ORDER_SUCCESS.getCode().equals(baseMsg.getMsgType())) { | } else if(EnumMsgRecordType.INSIDE_ORDER_SUCCESS.getCode().equals(baseMsg.getMsgType())) { | ||||
| // 内部消息 - 下订单成功 | // 内部消息 - 下订单成功 | ||||
| FmInsideOrderSuccessMsg msg = (FmInsideOrderSuccessMsg)JsonUtil.readValue(message,FmInsideOrderSuccessMsg.class); | FmInsideOrderSuccessMsg msg = (FmInsideOrderSuccessMsg)JsonUtil.readValue(message,FmInsideOrderSuccessMsg.class); | ||||
| fmInsideOrderSuccessMsgService.send(msg); | |||||
| } | } | ||||
| baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); | baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); | ||||
| wxMsgRecordMapper.update(baseMsg); | wxMsgRecordMapper.update(baseMsg); | ||||