diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/UserPictureAuditServiceImpl.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/UserPictureAuditServiceImpl.java index 6020a1c7..4c52ba73 100644 --- a/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/UserPictureAuditServiceImpl.java +++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/UserPictureAuditServiceImpl.java @@ -1,5 +1,6 @@ package com.ruoyi.cai.service.impl; +import com.alibaba.fastjson2.JSON; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -7,11 +8,17 @@ import com.ruoyi.cai.domain.User; import com.ruoyi.cai.domain.UserPictureAudit; import com.ruoyi.cai.dto.admin.vo.user.UserPictureAuditAdminVo; import com.ruoyi.cai.enums.AuditStatusEnum; +import com.ruoyi.cai.enums.SystemConfigEnum; +import com.ruoyi.cai.manager.SystemConfigManager; import com.ruoyi.cai.mapper.UserPictureAuditMapper; import com.ruoyi.cai.service.AnchorApplyService; import com.ruoyi.cai.service.UserPictureAuditService; import com.ruoyi.cai.service.UserService; import com.ruoyi.common.core.domain.PageQuery; +import com.ruoyi.yunxin.client.ImUserRefClient; +import com.ruoyi.yunxin.req.UpdateUinfoReq; +import com.ruoyi.yunxin.resp.YxCommonR; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -25,10 +32,15 @@ import java.time.LocalDateTime; * @date 2024-02-01 */ @Service +@Slf4j public class UserPictureAuditServiceImpl extends ServiceImpl implements UserPictureAuditService { @Autowired private AnchorApplyService anchorApplyService; + @Autowired + private SystemConfigManager systemConfigManager; + @Autowired + private ImUserRefClient userRefClient; @Override public UserPictureAudit getOneUserAuditRunningPic(Integer type, Long userId) { @@ -61,6 +73,18 @@ public class UserPictureAuditServiceImpl extends ServiceImpl implements Us private CaiLoginManager caiLoginManager; @Autowired private UserBlacklistService userBlacklistService; + @Autowired + private SystemConfigManager systemConfigManager; @Override public User getByUsername(String username) { @@ -309,13 +313,14 @@ public class UserServiceImpl extends ServiceImpl implements Us if(genderEnum == null){ return; } + String cosDomain = systemConfigManager.getSystemConfig(SystemConfigEnum.COS_DOMAIN); this.update(Wrappers.lambdaUpdate(User.class) .eq(User::getId,user.getId()) .set(User::getAvatar,genderEnum.getDefaultAvatar()) .set(User::getAvatarState, 0)); UpdateUinfoReq uinfoReq = new UpdateUinfoReq(); uinfoReq.setAccid(user.getId()+""); - uinfoReq.setIcon(genderEnum.getDefaultAvatar()); + uinfoReq.setIcon(cosDomain + genderEnum.getDefaultAvatar()); YxCommonR r = userRefClient.updateUinfo(uinfoReq); if(!r.isSuccess()){ log.error("云信更新失败,需要检查!{}", JSON.toJSONString(r)); diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/util/WebSocketUtils.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/util/WebSocketUtils.java index 9a44f8f3..78f7c1b7 100644 --- a/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/util/WebSocketUtils.java +++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/util/WebSocketUtils.java @@ -68,6 +68,9 @@ public class WebSocketUtils { } else { try { session.sendMessage(message); + if(message instanceof TextMessage){ + log.info("调试日志: 发送websocket数据 message={}",message.getPayload()); + } } catch (IOException e) { log.error("[send] session({}) 发送消息({}) 异常", session, message, e); }