impleme
wrapper.like(TtUser::getUserName, ttUserBody.getUserName());
if (StringUtils.isNotNull(ttUserBody.getNickName()))
wrapper.like(TtUser::getNickName, ttUserBody.getNickName());
- if (StringUtils.isNotNull(ttUserBody.getUserType())) wrapper.eq(TtUser::getUserType, ttUserBody.getUserType());
+ if (StringUtils.isNotEmpty(ttUserBody.getUserType())) {
+ wrapper.eq(TtUser::getUserType, ttUserBody.getUserType());
+ } else {
+ // 用户列表默认排除机器人(userType=03)，机器人在独立的机器人管理页显式传 userType=03 查询
+ wrapper.and(w -> w.isNull(TtUser::getUserType).or().ne(TtUser::getUserType, "03"));
+ }
if (StringUtils.isNotEmpty(ttUserBody.getPhoneNumber()))
wrapper.likeRight(TtUser::getPhoneNumber, ttUserBody.getPhoneNumber());
if (StringUtils.isNotEmpty(ttUserBody.getStatus())) wrapper.eq(TtUser::getStatus, ttUserBody.getStatus());
diff --git a/skins-service/service-admin/src/main/java/com/ruoyi/admin/task/OfficialRollTask.java b/skins-service/service-admin/src/main/java/com/ruoyi/admin/task/OfficialRollTask.java
new file mode 100644
index 0000000..7b3a27d
--- /dev/null
+++ b/skins-service/service-admin/src/main/java/com/ruoyi/admin/task/OfficialRollTask.java
@@ -0,0 +1,201 @@
+package com.ruoyi.admin.task;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.ruoyi.admin.domain.body.AddRobotBody;
+import com.ruoyi.admin.service.TtOfficialRollConfigService;
+import com.ruoyi.admin.service.TtRollCdkService;
+import com.ruoyi.admin.service.TtRollService;
+import com.ruoyi.admin.service.TtUserService;
+import com.ruoyi.admin.service.impl.TtOfficialRollConfigServiceImpl;
+import com.ruoyi.domain.entity.roll.TtOfficialRollConfig;
+import com.ruoyi.domain.entity.roll.TtRoll;
+import com.ruoyi.domain.entity.sys.TtUser;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.math.BigDecimal;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 官方周期Roll房定时创建任务。
+ *
+ * 注册到 RuoYi 系统监控-定时任务（由 sys_job 统一调度，不加 @Scheduled）：
+ * - 任务名称：官方日Roll生成 调用目标：officialRollTask.generateDailyRolls() 默认cron：0 0 10 * * ?（每天10:00）
+ *
+ * 复用官方房（roll_type=0）语义，直接创建 tt_roll，并按配置的机器人数量自动加入机器人。
+ */
+@Slf4j
+@Component("officialRollTask")
+public class OfficialRollTask {
+
+ /** 官方房类型 */
+ private static final String ROLL_TYPE_OFFICIAL = "0";
+ /** 未开奖状态 */
+ private static final String ROLL_STATUS_OPEN = "0";
+ /** 官方房创建者ID（0=官方） */
+ private static final Integer OFFICIAL_USER_ID = 0;
+ /** 机器人用户类型 */
+ private static final String ROBOT_USER_TYPE = "03";
+
+ @Autowired
+ private TtOfficialRollConfigService configService;
+
+ @Autowired
+ private TtRollService rollService;
+
+ @Autowired
+ private TtUserService userService;
+
+ @Autowired
+ private TtRollCdkService rollCdkService;
+
+ /**
+ * 每天为所有启用的 DAILY 配置创建当日官方roll房并自动加入机器人。
+ * 充值统计起点=当天0点（今日充值），开奖=当日23:59:59。
+ */
+ public void generateDailyRolls() {
+ Date start = todayStart();
+ Date end = todayEnd();
+ generate(TtOfficialRollConfigServiceImpl.PERIOD_DAILY, start, end);
+ }
+
+ private void generate(String periodType, Date rechargeStartTime, Date endTime) {
+ log.info("[官方周期Roll] 开始生成 period={}, start={}, end={}", periodType, rechargeStartTime, endTime);
+
+ LambdaQueryWrapper query = Wrappers.lambdaQuery();
+ query.eq(TtOfficialRollConfig::getStatus, "0")
+ .eq(TtOfficialRollConfig::getPeriodType, periodType);
+ List configs = configService.list(query);
+
+ if (configs == null || configs.isEmpty()) {
+ log.info("[官方周期Roll] 无启用的 {} 配置，跳过", periodType);
+ return;
+ }
+
+ int created = 0;
+ int skipped = 0;
+ for (TtOfficialRollConfig config : configs) {
+ try {
+ // 幂等：同一配置 + 同一充值统计起点 至多生成一个房间
+ long exists = rollService.count(Wrappers.lambdaQuery()
+ .eq(TtRoll::getOfficialConfigId, config.getId())
+ .eq(TtRoll::getRechargeStartTime, rechargeStartTime));
+ if (exists > 0) {
+ skipped++;
+ log.info("[官方周期Roll] 配置{}({})本周期房间已存在，跳过", config.getId(), config.getConfigName());
+ continue;
+ }
+
+ TtRoll roll = TtRoll.builder()
+ .jackpotId(config.getJackpotId())
+ .userId(OFFICIAL_USER_ID)
+ .rollType(ROLL_TYPE_OFFICIAL)
+ .rollName(config.getRoomName())
+ .description(config.getDescription())
+ .endTime(endTime)
+ .peopleNum(config.getPeopleNum())
+ .rollPassword(config.getRollPassword())
+ .minRecharge(config.getMinRecharge() != null ? config.getMinRecharge() : BigDecimal.ZERO)
+ .rechargeStartTime(rechargeStartTime)
+ .sortBy(config.getSortBy())
+ .rollStatus(ROLL_STATUS_OPEN)
+ .officialConfigId(config.getId())
+ .createBy("system")
+ .createTime(new Date())
+ .build();
+ rollService.save(roll);
+
+ // 自动加入机器人：数量取配置值，且不超过可用机器人总数；addRobot 会自动跳过该房已有机器人
+ addRobots(roll.getId(), config);
+
+ // 按配置数量为房间生成CDK（0则不生成，使用普通密码）
+ generateCdks(roll.getId(), config);
+
+ // 回写上次生成时间（幂等辅助/可观测）
+ TtOfficialRollConfig update = new TtOfficialRollConfig();
+ update.setId(config.getId());
+ update.setLastGenerateTime(new Date());
+ configService.updateById(update);
+
+ created++;
+ log.info("[官方周期Roll] 配置{}({}) 已生成房间 rollId={}，起点={}，开奖={}",
+ config.getId(), config.getConfigName(), roll.getId(), rechargeStartTime, endTime);
+ } catch (Exception e) {
+ log.error("[官方周期Roll] 配置{}生成房间失败：{}", config.getId(), e.getMessage(), e);
+ }
+ }
+
+ log.info("[官方周期Roll] 生成完成 period={}, 配置数={}, 新建={}, 跳过={}",
+ periodType, configs.size(), created, skipped);
+ }
+
+ /**
+ * 为指定房间按配置数量加入机器人。数量取 min(配置机器人数, 可用机器人总数)，避免"可用机器人数量不足"导致一个都不加。
+ */
+ private void addRobots(Integer rollId, TtOfficialRollConfig config) {
+ Integer robotNum = config.getRobotNum();
+ if (rollId == null || robotNum == null || robotNum <= 0) {
+ return;
+ }
+ try {
+ long robotTotal = userService.count(new QueryWrapper().eq("user_type", ROBOT_USER_TYPE));
+ int toAdd = (int) Math.min(robotNum.longValue(), robotTotal);
+ if (toAdd <= 0) {
+ log.warn("[官方周期Roll] 配置{}需要{}个机器人，但用户表无可用机器人，跳过加入", config.getId(), robotNum);
+ return;
+ }
+ AddRobotBody body = new AddRobotBody();
+ body.setRollId(rollId);
+ body.setRobotNum(toAdd);
+ rollService.addRobot(body);
+ log.info("[官方周期Roll] 配置{} 房间{} 已尝试加入{}个机器人", config.getId(), rollId, toAdd);
+ } catch (Exception e) {
+ log.error("[官方周期Roll] 配置{} 房间{} 加入机器人失败：{}", config.getId(), rollId, e.getMessage(), e);
+ }
+ }
+
+ /**
+ * 按配置数量为房间生成CDK；0或空则不生成（使用普通密码）。
+ */
+ private void generateCdks(Integer rollId, TtOfficialRollConfig config) {
+ Integer cdkCount = config.getCdkCount();
+ if (rollId == null || cdkCount == null || cdkCount <= 0) {
+ return;
+ }
+ try {
+ rollCdkService.generateCdks(rollId, cdkCount);
+ log.info("[官方周期Roll] 配置{} 房间{} 已生成{}个CDK", config.getId(), rollId, cdkCount);
+ } catch (Exception e) {
+ log.error("[官方周期Roll] 配置{} 房间{} 生成CDK失败：{}", config.getId(), rollId, e.getMessage(), e);
+ }
+ }
+
+ /** 今天0点 */
+ private Date todayStart() {
+ Calendar c = Calendar.getInstance();
+ clearTime(c);
+ return c.getTime();
+ }
+
+ /** 今天23:59:59 */
+ private Date todayEnd() {
+ Calendar c = Calendar.getInstance();
+ c.set(Calendar.HOUR_OF_DAY, 23);
+ c.set(Calendar.MINUTE, 59);
+ c.set(Calendar.SECOND, 59);
+ c.set(Calendar.MILLISECOND, 0);
+ return c.getTime();
+ }
+
+ private void clearTime(Calendar c) {
+ c.set(Calendar.HOUR_OF_DAY, 0);
+ c.set(Calendar.MINUTE, 0);
+ c.set(Calendar.SECOND, 0);
+ c.set(Calendar.MILLISECOND, 0);
+ }
+}
diff --git a/skins-service/service-playingmethod/src/main/java/com/ruoyi/playingmethod/scheduled/fightTask.java b/skins-service/service-playingmethod/src/main/java/com/ruoyi/playingmethod/scheduled/fightTask.java
index 174eb4e..cd63990 100644
--- a/skins-service/service-playingmethod/src/main/java/com/ruoyi/playingmethod/scheduled/fightTask.java
+++ b/skins-service/service-playingmethod/src/main/java/com/ruoyi/playingmethod/scheduled/fightTask.java
@@ -50,7 +50,7 @@ public class fightTask {
private Executor customThreadPoolExecutor;
// 定时更新超时未结束的对局
- @Scheduled(cron = "0/6 * * * * ?")
+ //@Scheduled(cron = "0/6 * * * * ?")
private void refreshDayTask() {
log.info("定时更新超时未结束的对局");
// Timestamp now = new Timestamp(System.currentTimeMillis());