diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/account/v3/mq/send/model/AccSendMq.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/account/v3/mq/send/model/AccSendMq.java
deleted file mode 100644
index e3f57024..00000000
--- a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/account/v3/mq/send/model/AccSendMq.java
+++ /dev/null
@@ -1,46 +0,0 @@
-package com.bonus.core.account.v3.mq.send.model;
-
-import com.bonus.core.account.v3.constants.AccStatusEnum;
-import com.bonus.core.account.v3.mapper.AccInfoMapper;
-import com.bonus.core.common.utils.JacksonUtil;
-import com.bonus.core.common.utils.TenantContextHolder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Lazy;
-import org.springframework.context.i18n.LocaleContextHolder;
-import org.springframework.stereotype.Component;
-
-import java.time.LocalDateTime;
-import java.util.List;
-import java.util.Locale;
-import java.util.Map;
-import java.util.function.Function;
-import java.util.stream.Collectors;
-
-@Component
-public class AccSendMq {
-   private static final Logger log = LoggerFactory.getLogger(AccSendMq.class);
-
-   @Autowired
-   @Lazy
-   private AccInfoMapper accInfoMapper;
-
-
-
-   public void accChangeSendHandle(List<Long> custIdList, Integer accStatus) {
-      if (AccStatusEnum.sendMqStatus().contains(accStatus)) {
-         log.info("账户状态变动发送mq_入参人员数量={},accStatus={}", custIdList.size(), accStatus);
-         List<AccStatusChangeModel> resultList = this.accInfoMapper.queryAccStatusByCustIdList(custIdList);
-         Long tenantId = TenantContextHolder.getTenantId();
-         LocalDateTime now = LocalDateTime.now();
-         resultList.forEach((item) -> {
-            item.setMerchantId(tenantId);
-            item.setAccStatus(accStatus);
-            item.setUpDateTime(now);
-            log.info("账户状态变动发送mq内容：{}", JacksonUtil.writeValueAsString(item));
-            //MqUtil.send(JacksonUtil.writeValueAsString(item), LeMqConstant.Topic.ACC_STATUS_CHANGE);
-         });
-      }
-   }
-}
diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/customer/v4/mobile/service/impl/CustPhotoServiceImpl.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/customer/v4/mobile/service/impl/CustPhotoServiceImpl.java
index 34409a63..ce63c0bf 100644
--- a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/customer/v4/mobile/service/impl/CustPhotoServiceImpl.java
+++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/customer/v4/mobile/service/impl/CustPhotoServiceImpl.java
@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.bonus.common.core.exception.ServiceException;
 import com.bonus.common.core.web.domain.AjaxResult;
+import com.bonus.common.redis.service.RedisService;
 import com.bonus.common.security.utils.SecurityUtils;
 import com.bonus.core.account.v3.constants.AccStatusEnum;
 import com.bonus.core.allocation.api.GlobalMetadataApi;
@@ -79,6 +80,8 @@ public class CustPhotoServiceImpl extends ServiceImpl<CustPhotoMapper, CustPhoto
     @Resource
     private DelayedMessageSender delayedMessageSender;
     @Resource
+    private RedisService redisService;
+    @Resource
     DcPushUserDataServiceApi dcPushUserDataServiceApi;
 
     @Value("${system.sysfile.max-upload-file-size}")
@@ -194,9 +197,8 @@ public class CustPhotoServiceImpl extends ServiceImpl<CustPhotoMapper, CustPhoto
         }
 
         this.custInfoService.updateCustPhotoUrl(custId, cutPath);
-        //TODO   替换 123  ->   当前登录人的手机号
        this.custAccTempService.update(
-               new CustAccTemp().setCustId(custId).setCustPhotoUrl(cutPath).setUpby("123"),
+               new CustAccTemp().setCustId(custId).setCustPhotoUrl(cutPath).setUpby(SecurityUtils.getLoginUser().getSysUser().getPhonenumber()),
                new LambdaQueryWrapper<CustAccTemp>().eq(CustAccTemp::getCustId, custId)
                );
         this.delayedMessageSender.asyncDelaySendToDevice(DelayedMessageTypeEnum.PHOTO);