日常任务-异步线程池获取

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/guildtask/GuildTaskService.java

@@ -23,6 +23,7 @@ import com.accompany.business.vo.guild.GuildTaskLevelInfoVo;
 import com.accompany.common.result.BusiResult;
 import com.accompany.common.status.BusiStatus;
 import com.accompany.common.utils.DateTimeUtil;
+import com.accompany.core.base.SpringContextHolder;
 import com.accompany.core.enumeration.BillObjTypeEnum;
 import com.accompany.core.enumeration.I18nAlertEnum;
 import com.accompany.core.enumeration.PartitionEnum;
@@ -31,16 +32,15 @@ import com.accompany.core.util.I18NMessageSourceUtil;
 import org.apache.commons.collections.CollectionUtils;
 import org.redisson.api.RMap;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
-import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.time.DayOfWeek;
 import java.time.Duration;
 import java.time.ZonedDateTime;
 import java.time.temporal.TemporalAdjusters;
 import java.util.*;
-import java.util.concurrent.ThreadPoolExecutor;
 import java.util.stream.Collectors;
 
 @Service
@@ -65,8 +65,6 @@ public class GuildTaskService {
     private UserGoldBeanService userGoldBeanService;
     @Autowired
     private RewardUtil rewardUtil;
-    @Resource(name = "bizExecutor")
-    private ThreadPoolExecutor bizExecutor;
     @Autowired
     private BaseSendService baseSendService;
 
@@ -490,12 +488,15 @@ public class GuildTaskService {
         if (needSendMessage) {
             String tip = I18NMessageSourceUtil.getMessage(I18nAlertEnum.GUILD_CREATE_TASK_MSG, partitionId);
             for (GuildTaskLevelRewardRecord rewardRecord : rewardRecords) {
-                bizExecutor.execute(()->{
-                    baseSendService.sendSystemMsg(rewardRecord.getUid().toString(), tip);
-                });
+                SpringContextHolder.getBean(GuildTaskService.class).sendTip(rewardRecord.getUid().toString(), tip);
             }
         }
-
         return BusiResult.success();
     }
+
+    @Async
+    public void sendTip(String uidStr, String tip) {
+        baseSendService.sendSystemMsg(uidStr, tip);
+    }
+
 }