From 19fed0ff2ab9ecfc0a8f084ed7fa14383d0c4ca8 Mon Sep 17 00:00:00 2001 From: hokli <2629910752@qq.com> Date: Thu, 4 Sep 2025 16:14:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=97=A5=E5=B8=B8=E4=BB=BB=E5=8A=A1-=E5=BC=82?= =?UTF-8?q?=E6=AD=A5=E7=BA=BF=E7=A8=8B=E6=B1=A0=E8=8E=B7=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/guildtask/GuildTaskService.java | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/guildtask/GuildTaskService.java b/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/guildtask/GuildTaskService.java index a60a8b562..5b05d7252 100644 --- a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/guildtask/GuildTaskService.java +++ b/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); + } + }