yshop3.0-alpha版本

yshop-message/pom.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>yshop</artifactId>
+        <groupId>co.yixiang</groupId>
+        <version>3.0-alpha</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>yshop-message</artifactId>
+    <name>消息队列模块</name>
+
+
+</project>

yshop-message/src/main/java/co/yixiang/message/rocketmq/MqConsumer.java

@@ -0,0 +1,49 @@
+package co.yixiang.message.rocketmq;//package co.yixiang.commonold.rocketmq;
+//
+//import cn.hutool.core.util.ObjectUtil;
+//import co.yixiang.modules.order.entity.YxStoreOrder;
+//import co.yixiang.modules.order.service.YxStoreOrderService;
+//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+//import lombok.AllArgsConstructor;
+//import lombok.extern.slf4j.Slf4j;
+//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+//import org.apache.rocketmq.spring.core.RocketMQListener;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * @ClassName 消费者
+// * @Author hupeng <610796224@qq.com>
+// * @Date 2020/1/1
+// **/
+////@Component
+////@RocketMQMessageListener(
+////        topic = "yshop-topic",
+////        consumerGroup = "yshop-group",
+////        selectorExpression = "*"
+////)
+//@Slf4j
+//@AllArgsConstructor
+//public class MqConsumer implements RocketMQListener<String> {
+//
+//    private final YxStoreOrderService storeOrderService;
+//
+//    @Override
+//    public void onMessage(String msg) {
+//        log.info("系统开始处理延时任务---订单超时未付款---订单id:" + msg);
+//
+//        Integer id = Integer.valueOf(msg);
+//
+//        YxStoreOrder order = storeOrderService.getOne(new QueryWrapper<YxStoreOrder>()
+//                .eq("id", id).eq("is_del",0).eq("paid",0));
+//
+//        if(ObjectUtil.isNull(order)) {
+//            return;
+//        }
+//
+//        storeOrderService.cancelOrderByTask(id);
+//
+//        log.info("=====处理成功======");
+//
+//    }
+//}

yshop-message/src/main/java/co/yixiang/message/rocketmq/MqProducer.java

@@ -0,0 +1,51 @@
+package co.yixiang.message.rocketmq;//package co.yixiang.commonold.rocketmq;
+//
+//import co.yixiang.exception.ErrorRequestException;
+//import lombok.AllArgsConstructor;
+//import org.apache.rocketmq.client.exception.MQBrokerException;
+//import org.apache.rocketmq.client.exception.MQClientException;
+//import org.apache.rocketmq.client.producer.DefaultMQProducer;
+//import org.apache.rocketmq.commonold.message.Message;
+//import org.apache.rocketmq.remoting.exception.RemotingException;
+//import org.apache.rocketmq.spring.core.RocketMQTemplate;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * @ClassName 生成者
+// * @Author hupeng <610796224@qq.com>
+// * @Date 2020/1/1
+// **/
+////@Component
+//@AllArgsConstructor
+//public class MqProducer {
+//     //注入rocketMQ的模板
+//    private final RocketMQTemplate rocketMQTemplate;
+//
+//
+//    /**
+//     * 发送延时消息10分钟
+//     *
+//     * @param topic
+//     * @param msg
+//     */
+//    public void sendMsg(String topic, String msg) {
+//        DefaultMQProducer defaultMQProducer = rocketMQTemplate.getProducer();
+//
+//        Message message = new Message(topic,msg.getBytes());
+//        message.setDelayTimeLevel(14);
+//
+//        try {
+//            defaultMQProducer.send(message);
+//        } catch (MQClientException e) {
+//            throw new ErrorRequestException("RocketMQ服务没启动哦");
+//        } catch (RemotingException e) {
+//            e.printStackTrace();
+//        } catch (MQBrokerException e) {
+//            e.printStackTrace();
+//        } catch (InterruptedException e) {
+//            e.printStackTrace();
+//        }
+//    }
+//
+//}