refactor: 动态计算商店前置任务等级

help/base_sys_user_role去重.sql

@@ -0,0 +1,30 @@
+-- base_sys_user_role 角色授权去重
+-- 保留每组 userId + roleId 中 id 最小的一条，删除其余重复记录
+
+-- 1. 执行前查看重复数据
+SELECT
+  "userId",
+  "roleId",
+  COUNT(*) AS cnt,
+  MIN(id) AS keep_id,
+  ARRAY_AGG(id ORDER BY id) AS ids
+FROM base_sys_user_role
+GROUP BY "userId", "roleId"
+HAVING COUNT(*) > 1
+ORDER BY cnt DESC, "userId", "roleId";
+
+-- 2. 删除重复数据
+DELETE FROM base_sys_user_role a
+USING base_sys_user_role b
+WHERE a."userId" = b."userId"
+  AND a."roleId" = b."roleId"
+  AND a.id > b.id;
+
+-- 3. 执行后复查，应返回 0 行
+SELECT
+  "userId",
+  "roleId",
+  COUNT(*) AS cnt
+FROM base_sys_user_role
+GROUP BY "userId", "roleId"
+HAVING COUNT(*) > 1;

help/约束类.sql

@@ -39,4 +39,15 @@ WHERE deleted_at IS NULL;
 --房间索引
 CREATE UNIQUE INDEX uk_player_room_house
 ON player_room_house (player_id, is_vip)
-WHERE deleted_at IS NULL;
+WHERE deleted_at IS NULL;
+
+-- 集市权限角色 联合唯一
+-- 先清理历史重复授权，保留每组 userId + roleId 中 id 最小的一条
+DELETE FROM base_sys_user_role a
+USING base_sys_user_role b
+WHERE a."userId" = b."userId"
+  AND a."roleId" = b."roleId"
+  AND a.id > b.id;
+
+CREATE UNIQUE INDEX IF NOT EXISTS uk_base_sys_user_role_user_role
+ON base_sys_user_role ("userId", "roleId");

modules/player/service/task.go

@@ -5,6 +5,7 @@ import (
 	configservice "blazing/modules/config/service"
 	"blazing/modules/player/model"
 	"errors"
+	"fmt"
 	"strings"
 
 	"github.com/pointernil/bitset32"
@@ -15,17 +16,19 @@ func (s *TaskService) CanShop() bool {
 }
 
 func (s *TaskService) ShopRequirementError() error {
-	var gg *model.Task
+	braveRequireLevel := shopRequiredTowerLevel(configservice.NewTower500Service())
+	var braveTask *model.Task
 
-	s.dbm(s.Model).Where("task_id", 500).Scan(&gg)
-	if gg == nil || !bitset32.From(gg.Data).Test(80) {
-		return errors.New("请先完成勇者任务80")
+	s.dbm(s.Model).Where("task_id", 500).Scan(&braveTask)
+	if braveRequireLevel > 0 && (braveTask == nil || !bitset32.From(braveTask.Data).Test(uint(braveRequireLevel))) {
+		return fmt.Errorf("请先完成勇者任务%d", braveRequireLevel)
 	}
 
-	var ggg *model.Task
-	s.dbm(s.Model).Where("task_id", 600).Scan(&ggg)
-	if ggg == nil || !bitset32.From(ggg.Data).Test(50) {
-		return errors.New("请先完成试炼任务50")
+	trialRequireLevel := shopRequiredTowerLevel(configservice.NewTower600Service())
+	var trialTask *model.Task
+	s.dbm(s.Model).Where("task_id", 600).Scan(&trialTask)
+	if trialRequireLevel > 0 && (trialTask == nil || !bitset32.From(trialTask.Data).Test(uint(trialRequireLevel))) {
+		return fmt.Errorf("请先完成试炼任务%d", trialRequireLevel)
 	}
 
 	var darkTask *model.Task
@@ -44,6 +47,19 @@ func (s *TaskService) ShopRequirementError() error {
 	return nil
 }
 
+func shopRequiredTowerLevel(towerService *configservice.TowerService) uint32 {
+	levels := towerService.EnabledLevels()
+	if len(levels) == 0 {
+		return 0
+	}
+
+	highestLevel := levels[len(levels)-1]
+	if highestLevel <= 10 {
+		return 0
+	}
+	return highestLevel - 10
+}
+
 func (s *TaskService) GetTask(id uint32) (*model.Task, error) {
 	var task *model.Task
 	if err := s.dbm(s.Model).Where("task_id", id).Scan(&task); err != nil {