123

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<UserPictureAuditMapper,UserPictureAudit> 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<UserPictureAuditMap
                     .eq(User::getId, userPictureAudit.getUserId())
                     .set(User::getAvatar, userPictureAudit.getUrl())
                     .set(User::getAvatarState, 1));
+            try {
+                String cosDomain = systemConfigManager.getSystemConfig(SystemConfigEnum.COS_DOMAIN);
+                UpdateUinfoReq uinfoReq = new UpdateUinfoReq();
+                uinfoReq.setAccid(userPictureAudit.getUserId()+"");
+                uinfoReq.setIcon(cosDomain + userPictureAudit.getUrl());
+                YxCommonR r = userRefClient.updateUinfo(uinfoReq);
+                if(!r.isSuccess()){
+                    log.error("云信更新失败，需要检查！{}", JSON.toJSONString(r));
+                }
+            }catch (Exception e){
+                log.error("云信调用失败!",e);
+            }
             try {
                 anchorApplyService.checkAnchorAuto(userPictureAudit.getUserId());
             }catch (Exception e){

ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/UserServiceImpl.java

@@ -13,6 +13,8 @@ import com.ruoyi.cai.dto.app.query.index.UserMapperQuery;
 import com.ruoyi.cai.dto.app.query.index.UserQuery;
 import com.ruoyi.cai.dto.app.vo.user.*;
 import com.ruoyi.cai.enums.GenderEnum;
+import com.ruoyi.cai.enums.SystemConfigEnum;
+import com.ruoyi.cai.manager.SystemConfigManager;
 import com.ruoyi.cai.mapper.UserMapper;
 import com.ruoyi.cai.notice.YunxinHttpService;
 import com.ruoyi.cai.service.*;
@@ -81,6 +83,8 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> 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<UserMapper, User> 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));

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);
             }