Add staged (阶段性) reward tiers to task module (#26)

Author: dengzhaofun

apps/admin/src/components/task/DefinitionForm.tsx

@@ -13,7 +13,11 @@ import {
   SelectTrigger,
   SelectValue,
 } from "#/components/ui/select"
-import type { CreateDefinitionInput, TaskCategory } from "#/lib/types/task"
+import type {
+  CreateDefinitionInput,
+  TaskCategory,
+  TaskRewardTier,
+} from "#/lib/types/task"
 
 interface DefinitionFormProps {
   defaultValues?: Partial<CreateDefinitionInput>
@@ -48,12 +52,34 @@ export function DefinitionForm({
       isHidden: defaultValues?.isHidden ?? false,
       sortOrder: defaultValues?.sortOrder ?? 0,
       activityId: defaultValues?.activityId ?? (null as string | null),
+      rewardTiersJson: JSON.stringify(
+        defaultValues?.rewardTiers ?? [],
+        null,
+        2,
+      ),
     },
     onSubmit: async ({ value }) => {
       const isEventBased =
         value.countingMethod === "event_count" ||
         value.countingMethod === "event_value"
       const trimmedFilter = value.filter.trim()
+
+      let rewardTiers: TaskRewardTier[] = []
+      const rewardTiersRaw = value.rewardTiersJson.trim()
+      if (rewardTiersRaw.length > 0) {
+        try {
+          const parsed = JSON.parse(rewardTiersRaw) as unknown
+          if (!Array.isArray(parsed)) {
+            throw new Error("rewardTiers must be an array")
+          }
+          rewardTiers = parsed as TaskRewardTier[]
+        } catch (err) {
+          throw new Error(
+            `阶段性奖励 JSON 解析失败: ${err instanceof Error ? err.message : String(err)}`,
+          )
+        }
+      }
+
       const input: CreateDefinitionInput = {
         name: value.name,
         alias: value.alias || null,
@@ -72,6 +98,7 @@ export function DefinitionForm({
         sortOrder: value.sortOrder,
         activityId: value.activityId,
         rewards: defaultValues?.rewards ?? [{ type: "item", id: "", count: 1 }],
+        rewardTiers,
       }
       await onSubmit(input)
     },
@@ -384,6 +411,27 @@ export function DefinitionForm({
         )}
       </form.Field>
 
+      <form.Field name="rewardTiersJson">
+        {(field) => (
+          <div className="space-y-2">
+            <Label htmlFor={field.name}>阶段性奖励 (JSON, 可留空)</Label>
+            <Textarea
+              id={field.name}
+              value={field.state.value}
+              onBlur={field.handleBlur}
+              onChange={(e) => field.handleChange(e.target.value)}
+              rows={5}
+              className="font-mono text-xs"
+              placeholder='[{"alias":"tier-1","threshold":3,"rewards":[{"type":"item","id":"gold-uuid","count":100}]}]'
+            />
+            <p className="text-xs text-muted-foreground">
+              到达 threshold 后，该阶段奖励独立结算（autoClaim 任务走邮件自动发放，否则走手动领取）。
+              alias 必须唯一，threshold 必须严格递增且不超过 targetValue。
+            </p>
+          </div>
+        )}
+      </form.Field>
+
       <Button type="submit" disabled={isPending}>
         {isPending ? m.common_saving() : submitLabel}
       </Button>

apps/admin/src/lib/types/task.ts

@@ -11,6 +11,12 @@ export interface TaskNavigation {
   label?: string
 }
 
+export interface TaskRewardTier {
+  alias: string
+  threshold: number
+  rewards: ItemEntry[]
+}
+
 export interface TaskCategory {
   id: string
   organizationId: string
@@ -46,6 +52,7 @@ export interface TaskDefinition {
   parentProgressValue: number
   prerequisiteTaskIds: string[]
   rewards: ItemEntry[]
+  rewardTiers: TaskRewardTier[]
   autoClaim: boolean
   navigation: TaskNavigation | null
   isActive: boolean
@@ -89,6 +96,7 @@ export interface CreateDefinitionInput {
   parentProgressValue?: number
   prerequisiteTaskIds?: string[]
   rewards: ItemEntry[]
+  rewardTiers?: TaskRewardTier[]
   autoClaim?: boolean
   navigation?: TaskNavigation | null
   isActive?: boolean

apps/server/drizzle/0025_rare_network.sql

@@ -0,0 +1,14 @@
+CREATE TABLE "task_user_milestone_claims" (
+	"task_id" uuid NOT NULL,
+	"end_user_id" text NOT NULL,
+	"organization_id" text NOT NULL,
+	"period_key" text NOT NULL,
+	"tier_alias" text NOT NULL,
+	"claimed_at" timestamp DEFAULT now() NOT NULL,
+	CONSTRAINT "task_user_milestone_claims_pk" PRIMARY KEY("task_id","end_user_id","period_key","tier_alias")
+);
+--> statement-breakpoint
+ALTER TABLE "task_definitions" ADD COLUMN "reward_tiers" jsonb DEFAULT '[]'::jsonb NOT NULL;--> statement-breakpoint
+ALTER TABLE "task_user_milestone_claims" ADD CONSTRAINT "task_user_milestone_claims_task_id_task_definitions_id_fk" FOREIGN KEY ("task_id") REFERENCES "public"."task_definitions"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
+CREATE INDEX "task_user_milestone_claims_org_user_idx" ON "task_user_milestone_claims" USING btree ("organization_id","end_user_id");--> statement-breakpoint
+CREATE INDEX "task_user_milestone_claims_user_task_period_idx" ON "task_user_milestone_claims" USING btree ("end_user_id","task_id","period_key");