caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mq订阅标签规范代码

Browse Source
This commit is contained in:
Chopper 2021-12-01 15:49:28 +08:00
parent 385a4ae618
commit af52a68abc
6 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
consumer/src/main/java/cn/lili/event/impl/FullDiscountExecute.java
View File

@ -26,7 +26,7 @@ import cn.lili.modules.order.trade.entity.dos.OrderLog;
import cn.lili.modules.order.trade.service.OrderLogService; import cn.lili.modules.order.trade.service.OrderLogService;
import cn.lili.modules.promotion.service.MemberCouponService; import cn.lili.modules.promotion.service.MemberCouponService;
import cn.lili.rocketmq.RocketmqSendCallbackBuilder; import cn.lili.rocketmq.RocketmqSendCallbackBuilder;
import cn.lili.rocketmq.tags.MqOrderTagsEnum; import cn.lili.rocketmq.tags.OrderTagsEnum;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -190,7 +190,7 @@ public class FullDiscountExecute implements TradeEvent, OrderStatusChangeEvent {
orderMessage.setPaymentMethod(order.getPaymentMethod()); orderMessage.setPaymentMethod(order.getPaymentMethod());
orderMessage.setNewStatus(OrderStatusEnum.PAID); orderMessage.setNewStatus(OrderStatusEnum.PAID);
String destination = rocketmqCustomProperties.getOrderTopic() + ":" + MqOrderTagsEnum.STATUS_CHANGE.name(); String destination = rocketmqCustomProperties.getOrderTopic() + ":" + OrderTagsEnum.STATUS_CHANGE.name();
//发送订单变更mq消息 //发送订单变更mq消息
rocketMQTemplate.asyncSend(destination, JSONUtil.toJsonStr(orderMessage), RocketmqSendCallbackBuilder.commonCallback()); rocketMQTemplate.asyncSend(destination, JSONUtil.toJsonStr(orderMessage), RocketmqSendCallbackBuilder.commonCallback());

4
consumer/src/main/java/cn/lili/listener/OrderMessageListener.java
View File

@ -2,7 +2,7 @@ package cn.lili.listener;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import cn.lili.cache.Cache; import cn.lili.cache.Cache;
import cn.lili.rocketmq.tags.MqOrderTagsEnum; import cn.lili.rocketmq.tags.OrderTagsEnum;
import cn.lili.event.OrderStatusChangeEvent; import cn.lili.event.OrderStatusChangeEvent;
import cn.lili.event.TradeEvent; import cn.lili.event.TradeEvent;
import cn.lili.modules.order.cart.entity.dto.TradeDTO; import cn.lili.modules.order.cart.entity.dto.TradeDTO;
@ -58,7 +58,7 @@ public class OrderMessageListener implements RocketMQListener<MessageExt> {
*/ */
public void orderStatusEvent(MessageExt messageExt) { public void orderStatusEvent(MessageExt messageExt) {
switch (MqOrderTagsEnum.valueOf(messageExt.getTags())) { switch (OrderTagsEnum.valueOf(messageExt.getTags())) {
//订单创建 //订单创建
case ORDER_CREATE: case ORDER_CREATE:
String key = new String(messageExt.getBody()); String key = new String(messageExt.getBody());

4
framework/src/main/java/cn/lili/modules/order/order/serviceimpl/OrderServiceImpl.java
View File

@ -50,7 +50,7 @@ import cn.lili.common.security.OperationalJudgment;
import cn.lili.mybatis.util.PageUtil; import cn.lili.mybatis.util.PageUtil;
import cn.lili.rocketmq.RocketmqSendCallbackBuilder; import cn.lili.rocketmq.RocketmqSendCallbackBuilder;
import cn.lili.rocketmq.tags.GoodsTagsEnum; import cn.lili.rocketmq.tags.GoodsTagsEnum;
import cn.lili.rocketmq.tags.MqOrderTagsEnum; import cn.lili.rocketmq.tags.OrderTagsEnum;
import cn.lili.trigger.enums.DelayTypeEnums; import cn.lili.trigger.enums.DelayTypeEnums;
import cn.lili.trigger.interfaces.TimeTrigger; import cn.lili.trigger.interfaces.TimeTrigger;
import cn.lili.trigger.message.PintuanOrderMessage; import cn.lili.trigger.message.PintuanOrderMessage;
@ -461,7 +461,7 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
@Override @Override
public void sendUpdateStatusMessage(OrderMessage orderMessage) { public void sendUpdateStatusMessage(OrderMessage orderMessage) {
String destination = rocketmqCustomProperties.getOrderTopic() + ":" + MqOrderTagsEnum.STATUS_CHANGE.name(); String destination = rocketmqCustomProperties.getOrderTopic() + ":" + OrderTagsEnum.STATUS_CHANGE.name();
//发送订单变更mq消息 //发送订单变更mq消息
rocketMQTemplate.asyncSend(destination, JSONUtil.toJsonStr(orderMessage), RocketmqSendCallbackBuilder.commonCallback()); rocketMQTemplate.asyncSend(destination, JSONUtil.toJsonStr(orderMessage), RocketmqSendCallbackBuilder.commonCallback());
} }

2
framework/src/main/java/cn/lili/modules/order/order/serviceimpl/TradeServiceImpl.java
View File

File diff suppressed because one or more lines are too long

4
framework/src/main/java/cn/lili/rocketmq/tags/MqOrderTagsEnum.java → framework/src/main/java/cn/lili/rocketmq/tags/OrderTagsEnum.java
View File

@ -6,7 +6,7 @@ package cn.lili.rocketmq.tags;
* @author paulG * @author paulG
* @since 2020/12/9 * @since 2020/12/9
**/ **/
public enum MqOrderTagsEnum { public enum OrderTagsEnum {
/** /**
* 订单创建 * 订单创建
@ -20,7 +20,7 @@ public enum MqOrderTagsEnum {
private final String description; private final String description;
MqOrderTagsEnum(String description) { OrderTagsEnum(String description) {
this.description = description; this.description = description;
} }

4
manager-api/src/test/java/cn/lili/test/rocketmq/MsgExtRocketMqTest.java
View File

@ -1,7 +1,7 @@
package cn.lili.test.rocketmq; package cn.lili.test.rocketmq;
import cn.lili.rocketmq.RocketmqSendCallbackBuilder; import cn.lili.rocketmq.RocketmqSendCallbackBuilder;
import cn.lili.rocketmq.tags.MqOrderTagsEnum; import cn.lili.rocketmq.tags.OrderTagsEnum;
import cn.lili.common.properties.RocketmqCustomProperties; import cn.lili.common.properties.RocketmqCustomProperties;
import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Assertions;
@ -29,7 +29,7 @@ class MsgExtRocketMqTest {
@Test @Test
void searchAll() { void searchAll() {
String destination = rocketmqCustomProperties.getOrderTopic() + ":" + MqOrderTagsEnum.STATUS_CHANGE.name(); String destination = rocketmqCustomProperties.getOrderTopic() + ":" + OrderTagsEnum.STATUS_CHANGE.name();
Message<String> message = MessageBuilder.withPayload("Context").build(); Message<String> message = MessageBuilder.withPayload("Context").build();
rocketMQTemplate.asyncSend(destination, message, RocketmqSendCallbackBuilder.commonCallback()); rocketMQTemplate.asyncSend(destination, message, RocketmqSendCallbackBuilder.commonCallback());
rocketMQTemplate.send(destination, message); rocketMQTemplate.send(destination, message);