From ff812e298d265a17d39943cf53223068a3a9c9cb Mon Sep 17 00:00:00 2001
From: sxu <602087911@qq.com>
Date: Fri, 11 Apr 2025 13:20:27 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E7=94=A8=E6=88=B7=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../core/account/service/impl/AccInfoServiceImpl.java        | 5 +++++
 1 file changed, 5 insertions(+)

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 5790d6a..309efb1 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
@@ -34,6 +34,7 @@ import com.bonus.canteen.core.account.utils.AccRedisUtils;
 import com.bonus.canteen.core.common.utils.MqUtil;
 import com.bonus.canteen.core.pay.constants.PayChannelEnum;
 import com.bonus.canteen.core.pay.constants.PayTypeEnum;
+import com.bonus.canteen.core.user.domain.DeviceMqPersonalUpdateMessageDTO;
 import com.bonus.common.core.exception.ServiceException;
 import com.bonus.common.core.utils.DateUtils;
 import com.bonus.common.houqin.constant.LeCodeUseSceneEnum;
@@ -184,6 +185,8 @@ public class AccInfoServiceImpl implements IAccInfoService {
             Long userId = users.get(i).getUserId();
             accWalletInfoService.deleteAccWalletInfoByUserId(userId);
             MqUtil.sendDataChange(userId, LeMqConstant.DataChangeType.REMOVE, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER);
+            DeviceMqPersonalUpdateMessageDTO bean = new DeviceMqPersonalUpdateMessageDTO().setUpdatePersonPhoto(Math.toIntExact(userId));
+            MqUtil.pushToTenantAllDevice(bean, LeMqConstant.Topic.DEVICE_UPDATE_PERSONAL_CONFIG_V4);
             count += accInfoMapper.deleteAccInfoByUserId(userId);
         }
         return count;
@@ -210,6 +213,8 @@ public class AccInfoServiceImpl implements IAccInfoService {
         }
 
         MqUtil.sendDataChange(sysUser.getUserId(), LeMqConstant.DataChangeType.ADD, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER);
+        DeviceMqPersonalUpdateMessageDTO bean = new DeviceMqPersonalUpdateMessageDTO().setUpdatePersonPhoto(Math.toIntExact(sysUser.getUserId()));
+        MqUtil.pushToTenantAllDevice(bean, LeMqConstant.Topic.DEVICE_UPDATE_PERSONAL_CONFIG_V4);
         return this.accWalletInfoService.batchInsertAccWalletInfo(accWalletInfos);
     }