公会优化-加入家族-发送公会消息

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/clan/ClanManageService.java

@@ -144,9 +144,9 @@ public class ClanManageService extends BaseService {
             if (record.getId() != null) {
                 applyBucket.set(link, 3L, TimeUnit.DAYS);
 
-                sendApplySysMsgToClanOwner(record.getId(), clan.getClanElderUid(), hallId);
+                sendApplySysMsgToClanOwner(record.getId(), clan.getClanElderUid(), uid);
             }
-        } catch (Exception e) {
+        } catch (InterruptedException e) {
             logger.error("apply clan join failed,uid={},clanId={},e={}", uid, clanId, e);
             throw new ServiceException(BusiStatus.SERVER_BUSY.getReasonPhrase(), e);
         } finally {
@@ -156,7 +156,6 @@ public class ClanManageService extends BaseService {
         }
     }
 
-    @Async
     public void sendApplySysMsgToClanOwner(Long recordId, Long clanOwnerId, Long hallOwnerId) {
         // 发送申请消息
         String url = Constant.ClanMessageUrl.DEAL_APPLY + recordId;
@@ -186,7 +185,6 @@ public class ClanManageService extends BaseService {
         sendSysMsgService.sendMsg(params);
     }
 
-    @Async
     public void sendApprovalSysMsgToHallOwner(Long hallOwnerId, Byte type, String clanName) {
         // 发送申请消息
         NeteaseSendMsgParam params = new NeteaseSendMsgParam();
@@ -294,7 +292,7 @@ public class ClanManageService extends BaseService {
                 //修改操作记录
                 this.updateOperateRecord(record, Constant.HallOperateStatus.AGREE);
                 //给申请者发送消息
-                sendApprovalSysMsgToHallOwner(hallOwner.getUid(), Constant.HallOperateStatus.REJECT, clan.getName());
+                sendApprovalSysMsgToHallOwner(hallOwner.getUid(), Constant.HallOperateStatus.AGREE, clan.getName());
 
             } else if (type.equals(Constant.ClanApproveType.REJECT)) {//拒绝
                 if (record.getType().equals(Constant.ClanOperateType.APPLY_CLAN)) {//拒绝申请加入模厅

accompany-business/accompany-business-web/src/main/java/com/accompany/business/controller/clan/ClanManageController.java

@@ -39,7 +39,7 @@ public class ClanManageController extends BaseController {
      * 申请加入家族
      */
     @PostMapping("/apply")
-    @Authorization
+    //@Authorization
     public BusiResult<Void> applyClan(Long uid, Long clanId) {
         log.info("applyClan, uid={}, clanId={}", uid, clanId);
         if (uid == null || clanId == null) {

accompany-business/accompany-business-web/src/main/resources/application-native.yml

@@ -50,9 +50,11 @@ spring:
         singleServerConfig:
           address: redis://118.194.255.128:6200
           password: anan@dev@redis@#!
+          connectionMinimumIdleSize: 16
+          timeout: 10000
         threads: 16
         nettyThreads: 32
-        codec: !<org.redisson.codec.MarshallingCodec> {}
+        codec: !<org.redisson.codec.JsonJacksonCodec> {}
         transportMode: "NIO"
 
 ##activemq 配置
@@ -71,4 +73,7 @@ elasticsearch:
   username: elastic
   password: xuanyin@es123
   roomIndex: yinyou_dev_room
-  userIndex: yinyou_dev_users_202204121516
+  userIndex: yinyou_dev_users_202204121516
+
+server:
+  port: 8081

pom.xml

@@ -109,7 +109,7 @@
         <jackson-module-kotlin.version>2.9.7</jackson-module-kotlin.version>
         <jackson-mapper-asl.version>1.9.13</jackson-mapper-asl.version>
         <sud-mgp-auth-java.version>1.0.2</sud-mgp-auth-java.version>
-        <redisson.version>3.16.3</redisson.version>
+        <redisson.version>3.16.8</redisson.version>
         <kotlin.compiler.incremental>true</kotlin.compiler.incremental>
         <esayexcel.version>3.1.1</esayexcel.version>
     </properties>
@@ -1012,11 +1012,11 @@
             <artifactId>spring-boot-starter-data-redis</artifactId>
         </dependency>
 
-        <dependency>
+        <!--<dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-devtools</artifactId>
             <scope>runtime</scope>
-        </dependency>
+        </dependency>-->
 
         <dependency>
             <groupId>io.springfox</groupId>