diff --git a/yshop-common/src/main/java/co/yixiang/event/TemplateListenEnum.java b/yshop-common/src/main/java/co/yixiang/event/TemplateListenEnum.java index bc2ef7f7..6d05b545 100644 --- a/yshop-common/src/main/java/co/yixiang/event/TemplateListenEnum.java +++ b/yshop-common/src/main/java/co/yixiang/event/TemplateListenEnum.java @@ -19,8 +19,8 @@ public enum TemplateListenEnum { TYPE_3("3","发货成功通知"), TYPE_4("4","充值成功通知"), TYPE_5("5","在线买单/收款成功通知"), - TYPE_6("6","商家收款通知"); - + TYPE_6("6","商家收款通知"), + TYPE_7("7","用户下单未支付通知"); private String value; private String desc; diff --git a/yshop-mall/src/main/java/co/yixiang/modules/order/service/impl/YxStoreOrderServiceImpl.java b/yshop-mall/src/main/java/co/yixiang/modules/order/service/impl/YxStoreOrderServiceImpl.java index da56465a..7fc1e74c 100644 --- a/yshop-mall/src/main/java/co/yixiang/modules/order/service/impl/YxStoreOrderServiceImpl.java +++ b/yshop-mall/src/main/java/co/yixiang/modules/order/service/impl/YxStoreOrderServiceImpl.java @@ -202,8 +202,6 @@ public class YxStoreOrderServiceImpl extends BaseServiceImpl redisTemplate; @@ -565,9 +563,6 @@ public class YxStoreOrderServiceImpl extends BaseServiceImplyshop-mall 3.1 + + + co.yixiang + yshop-message + 3.1 + compile + + + co.yixiang + yshop-mall + + + diff --git a/yshop-weixin/src/main/java/co/yixiang/modules/mp/listener/TemplateListener.java b/yshop-weixin/src/main/java/co/yixiang/modules/mp/listener/TemplateListener.java index 13ae5535..561c93c2 100644 --- a/yshop-weixin/src/main/java/co/yixiang/modules/mp/listener/TemplateListener.java +++ b/yshop-weixin/src/main/java/co/yixiang/modules/mp/listener/TemplateListener.java @@ -13,6 +13,7 @@ import co.yixiang.enums.PayTypeEnum; import co.yixiang.event.TemplateBean; import co.yixiang.event.TemplateEvent; import co.yixiang.event.TemplateListenEnum; +import co.yixiang.message.rocketmq.MqProducer; import co.yixiang.modules.mp.service.WeiXinSubscribeService; import co.yixiang.modules.mp.service.WeixinPayService; import co.yixiang.modules.mp.service.WeixinTemplateService; @@ -39,6 +40,8 @@ public class TemplateListener implements SmartApplicationListener { private WeixinPayService weixinPayService; @Autowired private WeiXinSubscribeService weiXinSubscribeService; + //@Autowired + //private MqProducer mqProducer; @Override public boolean supportsEventType(Class aClass) { @@ -79,9 +82,14 @@ public class TemplateListener implements SmartApplicationListener { weixinTemplateService.rechargeSuccessNotice(templateBean.getTime(),templateBean.getPrice(), templateBean.getUid()); break; - default: - //todo - } + case TYPE_7: + //使用MQ延时消息 + //mqProducer.sendMsg("yshop-topic", templateBean.getOrderId()); + log.info("投递延时订单id: [{}]:", templateBean.getOrderId()); + break; + default: + //todo + } }