123

ruoyi-admin/src/main/resources/application-prod.yml

@@ -97,5 +97,5 @@ agora:
   key: a57912561f1e42d280395fd68b02fcc9
   secret: e0343e9d98fa4bc198dfbee8b63cd131
 yunxin:
-  app-key: 748496374b04344194c68b53e411e09c
-  app-secret: 77c09917d2de
+  app-key: 0aaefeb8a80a9889987c5346244b58e2
+  app-secret: 470345ca2832

ruoyi-admin/src/test/java/com/ruoyi/test/business/UserTest.java

@@ -1,11 +1,17 @@
 package com.ruoyi.test.business;
 
+import com.alibaba.fastjson2.JSON;
 import com.ruoyi.cai.domain.User;
 import com.ruoyi.cai.domain.UserCount;
 import com.ruoyi.cai.im.ImManager;
 import com.ruoyi.cai.service.DynamicService;
 import com.ruoyi.cai.service.UserCountService;
 import com.ruoyi.cai.service.UserService;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.yunxin.client.ImUserClient;
+import com.ruoyi.yunxin.req.CreateUserReq;
+import com.ruoyi.yunxin.req.UpdateTokenReq;
+import com.ruoyi.yunxin.resp.YxCommonR;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -44,7 +50,34 @@ public class UserTest {
     public void refreshIm(){
         List<User> list = userService.list();
         for (User user : list) {
+            this.register(user.getId(),user.getToken(),user.getNickname());
             imManager.updateImInfo(user.getId(),user.getAvatar(),user.getNickname(),user.getGender());
         }
     }
+
+    @Autowired
+    private ImUserClient imUserClient;
+
+    public void register(Long userId,String token,String nickname){
+        CreateUserReq req = new CreateUserReq();
+        req.setAccid(userId+"");
+        req.setToken(token);
+        req.setName(nickname);
+        YxCommonR r = imUserClient.createUser(req);
+        if(!r.isSuccess()){
+            if(r.getCode() == 414){
+                UpdateTokenReq req1 = new UpdateTokenReq();
+                req1.setAccid(userId+"");
+                req1.setToken(token);
+                YxCommonR commonR = imUserClient.updateToken(req1);
+                if(!commonR.isSuccess()){
+                    log.error("刷新云token失败,{}", JSON.toJSONString(commonR));
+                    throw new ServiceException("注册失败，云信异常");
+                }
+            }else{
+                log.error("创建云信账号失败,{}", JSON.toJSONString(r));
+                throw new ServiceException("注册失败，云信异常");
+            }
+        }
+    }
 }