Bläddra i källkod

update account-service AccountRepository

reghao 6 månader sedan
förälder
incheckning
8c22e7bd2e

+ 2 - 1
account/account-service/src/main/java/cn/reghao/tnb/account/app/db/repository/AccountRepository.java

@@ -123,7 +123,8 @@ public class AccountRepository {
     }
 
     public UserAccount getUserAccountByUserId(long userId) {
-        return userAccountMapper.findByUserId(userId);
+        UserAccount userAccount = userAccountMapper.findByUserId(userId);
+        return userAccount != null ? setAccountAuthorities(userAccount) : null;
     }
 
     public UserAccount getUserAccountByUsername(String username) {

+ 2 - 1
message/message-service/src/main/java/cn/reghao/tnb/message/app/ws/WsConnection.java

@@ -33,8 +33,9 @@ import java.util.Map;
 @Slf4j
 @Component
 public class WsConnection {
-    @DubboReference(check = false)
+    @DubboReference(check = false, retries = 0, timeout = 60_000)
     private AccountQuery accountQuery;
+
     private final RabbitProducer rabbitProducer;
     // userId -> session
     private final Map<String, WebSocketSession> userSessions = new HashMap<>();