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 bedc1f6..0a7c5c4 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
@@ -232,12 +232,10 @@ public class OrderInfoServiceImpl implements IOrderInfoService
         orderPayResultDTO.setOrderState(OrderStateEnum.PLACE.getKey());
         orderInfoMapper.updateOrderPayResult(orderPayResultDTO);
         try {
-            if(orderInfoList.get(0).getSourceType().equals(SourceTypeEnum.HT_H5_MOBILE.getKey())) {
-                DeviceMqPersonalUpdateMessageDTO bean = new DeviceMqPersonalUpdateMessageDTO().setUpdatePerson(Math.toIntExact(orderInfoList.get(0).getUserId()),"update");
-                String jsonString = JacksonUtil.writeValueAsString(bean);
-                log.info("账户变动发送mq内容：{}", jsonString);
-                MqUtil.pushToTenantAllDevice(bean, LeMqConstant.Topic.DEVICE_UPDATE_PERSONAL_CONFIG_V4);
-            }
+            DeviceMqPersonalUpdateMessageDTO bean = new DeviceMqPersonalUpdateMessageDTO().setUpdatePerson(Math.toIntExact(orderInfoList.get(0).getUserId()),"update");
+            String jsonString = JacksonUtil.writeValueAsString(bean);
+            log.info("账户变动发送mq内容：{}", jsonString);
+            MqUtil.pushToTenantAllDevice(bean, LeMqConstant.Topic.DEVICE_UPDATE_PERSONAL_CONFIG_V4);
         } catch (Exception e) {
             log.error("发送MQ消息失败", e);
         }