diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java index f1ca1f662..569781bca 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java @@ -30,6 +30,8 @@ public class MqBaseConsumer { private SendMpMsgServiceImpl sendMpMsgService; @Autowired private SendWeappUniformMsgServiceImpl sendWeappUniformMsgService; + @Autowired + private FmInsideOrderSuccessMsgServiceImpl fmInsideOrderSuccessMsgService; public void doMessage(String message) { log.info("received message: {}", message); @@ -65,7 +67,7 @@ public class MqBaseConsumer { } else if(EnumMsgRecordType.INSIDE_ORDER_SUCCESS.getCode().equals(baseMsg.getMsgType())) { // 内部消息 - 下订单成功 FmInsideOrderSuccessMsg msg = (FmInsideOrderSuccessMsg)JsonUtil.readValue(message,FmInsideOrderSuccessMsg.class); - + fmInsideOrderSuccessMsgService.send(msg); } baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); wxMsgRecordMapper.update(baseMsg);