新增updatestartPageuser 定时任务

rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/scheduler/UpdateStartPageUserTask.java

@@ -0,0 +1,144 @@
+package com.red.circle.other.app.scheduler;
+
+import com.red.circle.common.business.core.enums.SysOriginPlatformEnum;
+import com.red.circle.component.redis.annotation.TaskCacheLock;
+import com.red.circle.other.domain.ranking.RankingActivityType;
+import com.red.circle.other.domain.ranking.RankingCycleType;
+import com.red.circle.other.infra.database.mongo.entity.activity.RankingActivityRecord;
+import com.red.circle.other.infra.database.rds.entity.sys.StartPageUser;
+import com.red.circle.other.infra.database.rds.service.sys.StartPageUserService;
+import com.red.circle.other.infra.gateway.RankingActivityGateway;
+import com.red.circle.tool.core.collection.CollectionUtils;
+import com.red.circle.tool.core.date.DateFormatConstant;
+import com.red.circle.tool.core.date.ZonedDateTimeAsiaRiyadhUtils;
+import com.red.circle.tool.core.date.ZonedDateTimeUtils;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.sql.Timestamp;
+import java.time.ZonedDateTime;
+import java.util.List;
+
+/**
+ * 更新启动页用户定时任务
+ * 每周一查询上周排名第一的用户并更新到启动页
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class UpdateStartPageUserTask {
+
+    private final RankingActivityGateway rankingActivityGateway;
+    private final StartPageUserService startPageUserService;
+
+    private static final String START_PAGE_TYPE = "KING_GAMES";
+    private static final Integer EXPIRE_DAYS = 7;
+
+    /**
+     * 每周一 0点5分执行
+     */
+    @Scheduled(cron = "0 5 0 ? * MON", zone = "Asia/Riyadh")
+    @TaskCacheLock(key = "UPDATE_START_PAGE_USER_TASK", expireSecond = 86400)
+    @Transactional(rollbackFor = Exception.class)
+    public void updateStartPageUser() {
+        long startTime = System.currentTimeMillis();
+        log.warn("========== 更新启动页用户定时任务开始 ==========");
+
+        try {
+            String sysOrigin = SysOriginPlatformEnum.LIKEI.name();
+            String lastWeekDate = getLastWeekDate();
+
+            Long topUserId = getLastWeekTopUser(sysOrigin, lastWeekDate);
+
+            if (topUserId == null) {
+                log.warn("未找到上周排名第一的用户，跳过更新");
+                return;
+            }
+
+            updateOrCreateStartPageUser(sysOrigin, topUserId);
+
+            log.warn("========== 更新启动页用户定时任务完成，耗时：{} ms，用户ID：{} ==========",
+                    System.currentTimeMillis() - startTime, topUserId);
+
+        } catch (Exception e) {
+            log.error("========== 更新启动页用户定时任务异常 ==========", e);
+            throw e;
+        }
+    }
+
+    /**
+     * 获取上周排名第一的用户
+     */
+    private Long getLastWeekTopUser(String sysOrigin, String lastWeekDate) {
+        List<RankingActivityRecord> records = rankingActivityGateway.getRankingList(
+                sysOrigin,
+                RankingActivityType.KING_GAMES,
+                RankingCycleType.WEEKLY,
+                lastWeekDate,
+                null,
+                1
+        );
+
+        if (CollectionUtils.isEmpty(records)) {
+            log.warn("上周排行榜为空，日期：{}", lastWeekDate);
+            return null;
+        }
+
+        RankingActivityRecord topRecord = records.get(0);
+        log.info("上周排名第一用户ID：{}，数量：{}", topRecord.getUserId(), topRecord.getQuantity());
+
+        return topRecord.getUserId();
+    }
+
+    /**
+     * 更新或创建启动页用户记录
+     */
+    private void updateOrCreateStartPageUser(String sysOrigin, Long userId) {
+        StartPageUser existingUser = startPageUserService.query()
+                .eq(StartPageUser::getSysOrigin, sysOrigin)
+                .eq(StartPageUser::getType, START_PAGE_TYPE)
+                .last("LIMIT 1")
+                .getOne();
+
+        Timestamp expireTime = calculateExpireTime();
+
+        if (existingUser != null) {
+            existingUser.setUserId(userId);
+            existingUser.setExpireTime(expireTime);
+            startPageUserService.updateSelectiveById(existingUser);
+            log.info("更新启动页用户成功，ID：{}，用户ID：{}，过期时间：{}", 
+                    existingUser.getId(), userId, expireTime);
+        } else {
+            StartPageUser newUser = new StartPageUser();
+            newUser.setSysOrigin(sysOrigin);
+            newUser.setType(START_PAGE_TYPE);
+            newUser.setUserId(userId);
+            newUser.setSort(1);
+            newUser.setExpireTime(expireTime);
+            startPageUserService.save(newUser);
+            log.info("创建启动页用户成功，用户ID：{}，过期时间：{}", userId, expireTime);
+        }
+    }
+
+    /**
+     * 计算过期时间（当前时间 + 7天）
+     */
+    private Timestamp calculateExpireTime() {
+        ZonedDateTime now = ZonedDateTimeAsiaRiyadhUtils.now();
+        ZonedDateTime expireDateTime = now.plusDays(EXPIRE_DAYS);
+        return Timestamp.from(expireDateTime.toInstant());
+    }
+
+    /**
+     * 获取上周一的日期（格式：yyyyMMdd）
+     */
+    private String getLastWeekDate() {
+        return ZonedDateTimeUtils.format(
+                ZonedDateTimeAsiaRiyadhUtils.getLastWeekMonday(),
+                DateFormatConstant.yyyyMMdd
+        );
+    }
+}