diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java
index 016bfb7..41720ed 100644
--- a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java
+++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java
@@ -29,10 +29,12 @@ import cn.hutool.json.JSONUtil;
 import com.bonus.canteen.core.account.domain.AccInfoVo;
 import com.bonus.canteen.core.account.domain.AccWalletInfo;
 import com.bonus.canteen.core.account.domain.WalletBalanceVO;
+import com.bonus.canteen.core.common.utils.MqUtil;
 import com.bonus.common.core.exception.ServiceException;
 import com.bonus.common.core.utils.DateUtils;
 import com.bonus.common.houqin.constant.LeCodeUseSceneEnum;
 import com.bonus.common.houqin.constant.SourceTypeEnum;
+import com.bonus.common.houqin.mq.constant.LeMqConstant;
 import com.bonus.common.security.utils.SecurityUtils;
 import com.bonus.system.api.domain.SysUser;
 import com.bonus.common.houqin.utils.SM4EncryptUtils;
@@ -202,7 +204,7 @@ public class AccInfoServiceImpl implements IAccInfoService {
             accWalletInfos.add(accWalletInfo);
         }
 
-        //MqUtil.sendDataChange(sysUser.getUserId(), LeMqConstant.DataChangeType.ADD, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER);
+        MqUtil.sendDataChange(sysUser.getUserId(), LeMqConstant.DataChangeType.ADD, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER);
         return this.accWalletInfoService.batchInsertAccWalletInfo(accWalletInfos);
     }
 
diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/utils/CommonConfiguration.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/utils/CommonConfiguration.java
index 176f7bf..08f9035 100644
--- a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/utils/CommonConfiguration.java
+++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/utils/CommonConfiguration.java
@@ -1,12 +1,15 @@
 package com.bonus.canteen.core.utils;
 
 import com.bonus.common.houqin.i18n.I18nConfiguration;
-import com.bonus.canteen.core.common.utils.SpringContextHolder;
+import com.bonus.common.houqin.mq.MQConfiguration;
+import com.bonus.common.houqin.mq.mqtt.MqttProperties;
+import com.bonus.common.houqin.mq.rabbit.RabbitConfiguration;
+import com.bonus.common.houqin.mq.rocket.RocketConfiguration;
 import com.bonus.common.houqin.utils.id.IdWorkConfiguration;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
 
 @Configuration
-@Import({IdWorkConfiguration.class, I18nConfiguration.class, SpringContextHolder.class})
+@Import({IdWorkConfiguration.class, I18nConfiguration.class, MQConfiguration.class, RabbitConfiguration.class, RocketConfiguration.class, MqttProperties.class})
 public class CommonConfiguration {
 }