cxc/yshopb2c
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

移除无用依赖

Browse Source
This commit is contained in:
xuwenbo
2020-12-14 22:16:12 +08:00
parent 0e7b2f46ab
commit a77939eb95
97 changed files with 2 additions and 2857 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
yshop-message/pom.xml
View File

@ -18,11 +18,6 @@
<artifactId>yshop-mall</artifactId>
<version>3.1</version>
</dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.0.4</version>
</dependency>
</dependencies>

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

@ -1,55 +0,0 @@
/**
* Copyright (C) 2018-2020
* All rights reserved, Designed By www.yixiang.co
* 注意：
* 本软件为www.yixiang.co开发研制，未经购买不得使用
* 购买后可获得全部源代码（禁止转卖、分享、上传到码云、github等开源平台）
* 一经发现盗用、分享等行为，将追究法律责任，后果自负
*/
package co.yixiang.message.rocketmq;
import co.yixiang.enums.OrderInfoEnum;
import co.yixiang.modules.order.domain.YxStoreOrder;
import co.yixiang.modules.order.service.YxStoreOrderService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.core.RocketMQListener;
/**
* @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);
Long id = Long.valueOf(msg);
YxStoreOrder order = storeOrderService.lambdaQuery()
.eq(YxStoreOrder::getId, id)
.eq(YxStoreOrder::getPaid, OrderInfoEnum.PAY_STATUS_0.getValue())
.one();
//只有待支付的订单能取消
if(order != null){
storeOrderService.cancelOrder(order.getOrderId(),null);
log.info("订单id:{},未在规定时间支付取消成功",id);
}
log.info("=====处理成功======");
}
}

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

@ -1,57 +0,0 @@
/**
* Copyright (C) 2018-2020
* All rights reserved, Designed By www.yixiang.co
* 注意：
* 本软件为www.yixiang.co开发研制，未经购买不得使用
* 购买后可获得全部源代码（禁止转卖、分享、上传到码云、github等开源平台）
* 一经发现盗用、分享等行为，将追究法律责任，后果自负
*/
package co.yixiang.message.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.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
/**
* @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();
}
}
}