From 7acdce51e4986d1f1abe56333cb23082e74d2e1c Mon Sep 17 00:00:00 2001 From: gaowdong Date: Mon, 19 May 2025 13:33:27 +0800 Subject: [PATCH] =?UTF-8?q?=E9=80=80=E5=8D=95=E5=8F=91mq=E7=BB=99=E5=8F=8C?= =?UTF-8?q?=E5=B1=8F=E6=9C=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/bonus/common/houqin/mq/constant/LeMqConstant.java | 1 + .../canteen/core/order/mq/bo/DeviceRefundOrderBO.java | 8 ++++++++ .../core/order/service/impl/OrderInfoServiceImpl.java | 8 ++++++++ 3 files changed, 17 insertions(+) create mode 100644 bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/order/mq/bo/DeviceRefundOrderBO.java diff --git a/bonus-common-biz/src/main/java/com/bonus/common/houqin/mq/constant/LeMqConstant.java b/bonus-common-biz/src/main/java/com/bonus/common/houqin/mq/constant/LeMqConstant.java index 4c63ad6..d6a8bd1 100644 --- a/bonus-common-biz/src/main/java/com/bonus/common/houqin/mq/constant/LeMqConstant.java +++ b/bonus-common-biz/src/main/java/com/bonus/common/houqin/mq/constant/LeMqConstant.java @@ -158,6 +158,7 @@ public interface LeMqConstant { DEVICE_ONLINE_REPORT_V4("device-online-report-v4", "通知商户下所有设备设备上下线"), DEVICE_ORDER_DISHES_STATE_UPDATE_V4("device-order-dishes-state-update-v4", "推送订单制作配送状态更新"), DEVICE_LOCKER_STATUS_V4("device-locker-status-v4", "推送更新智能餐柜状态"), + DEVICE_UPDATE_ORDER_STATE_V4("device-update-order-state-v4", "推送取消设备订单"), BACK_DEVICE_IOT_GATEWAY_V4("back-device-iot-gateway-v4", "后场推送网关设备信息"), BACK_DEVICE_UPDATE_PERSONAL_CONFIG_V4("back-device-update-person-config-v4", "通知设备后场人员和特征值更新"), BACK_CABINET_UPDATE_SETTING_CONFIG_V4("back-cabinet-update-setting-config-v4", "通知设备留样柜基础设置更新"), diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/order/mq/bo/DeviceRefundOrderBO.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/order/mq/bo/DeviceRefundOrderBO.java new file mode 100644 index 0000000..6db0945 --- /dev/null +++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/order/mq/bo/DeviceRefundOrderBO.java @@ -0,0 +1,8 @@ +package com.bonus.canteen.core.order.mq.bo; + +import lombok.Data; + +@Data +public class DeviceRefundOrderBO { + private String deviceOrderId; +} diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/order/service/impl/OrderInfoServiceImpl.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/order/service/impl/OrderInfoServiceImpl.java index 48d6bc2..99365cd 100644 --- a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/order/service/impl/OrderInfoServiceImpl.java +++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/order/service/impl/OrderInfoServiceImpl.java @@ -24,6 +24,7 @@ import com.bonus.canteen.core.order.constants.OrderStateEnum; import com.bonus.canteen.core.order.domain.*; import com.bonus.canteen.core.order.domain.param.*; import com.bonus.canteen.core.order.mapper.OrderInfoMapper; +import com.bonus.canteen.core.order.mq.bo.DeviceRefundOrderBO; import com.bonus.canteen.core.order.mq.utils.OrderMQUtils; import com.bonus.canteen.core.order.service.IOrderDetailService; import com.bonus.canteen.core.order.service.IOrderInfoService; @@ -429,6 +430,13 @@ public class OrderInfoServiceImpl implements IOrderInfoService String jsonString = JacksonUtil.writeValueAsString(bean); log.info("账户变动发送mq内容：{}", jsonString); MqUtil.pushToTenantAllDevice(bean, LeMqConstant.Topic.DEVICE_UPDATE_PERSONAL_CONFIG_V4); + if(StringUtils.isNotBlank(orderInfo.getDeviceOrderId())) { + DeviceRefundOrderBO deviceRefundOrderBO = new DeviceRefundOrderBO(); + deviceRefundOrderBO.setDeviceOrderId(orderInfo.getDeviceOrderId()); + String deviceJsonString = JacksonUtil.writeValueAsString(deviceRefundOrderBO); + log.info("设备订单退款发送mq内容：{}", deviceJsonString); + MqUtil.pushToTenantAllDevice(deviceRefundOrderBO, LeMqConstant.Topic.DEVICE_UPDATE_ORDER_STATE_V4); + } } catch (Exception e) { log.error("发送MQ消息失败", e); }