From fff88d032394123a1b942e6039a4b9f5506f3be0 Mon Sep 17 00:00:00 2001 From: hailin Date: Wed, 24 Dec 2025 16:43:19 -0800 Subject: [PATCH] =?UTF-8?q?chore(db):=20=E6=B7=BB=E5=8A=A0=E7=94=A8?= =?UTF-8?q?=E6=88=B7=E7=94=BB=E5=83=8F=E7=B3=BB=E7=BB=9F=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93=E8=BF=81=E7=A7=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 新增表： - tag_categories: 标签分类 - user_tags: 用户标签定义 - user_tag_assignments: 用户-标签关联 - user_classification_rules: 分类规则 - user_features: 用户特征 (RFM等) - audience_segments: 人群包 - user_tag_logs: 标签变更日志 - notification_tag_targets: 通知-标签关联 - notification_user_targets: 通知-用户关联 新增枚举： - TagType, TagValueType, TagAction, SegmentUsageType, TargetLogic 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 --- .../migration.sql | 255 ++++++++++++++++++ 1 file changed, 255 insertions(+) create mode 100644 backend/services/admin-service/prisma/migrations/20250124100000_add_user_profile_system/migration.sql diff --git a/backend/services/admin-service/prisma/migrations/20250124100000_add_user_profile_system/migration.sql b/backend/services/admin-service/prisma/migrations/20250124100000_add_user_profile_system/migration.sql new file mode 100644 index 00000000..28b856a7 --- /dev/null +++ b/backend/services/admin-service/prisma/migrations/20250124100000_add_user_profile_system/migration.sql @@ -0,0 +1,255 @@ +-- ============================================================================= +-- User Profile System Migration +-- 用户画像系统：标签管理、分类规则、人群包 +-- ============================================================================= + +-- ----------------------------------------------------------------------------- +-- 1. 枚举类型 +-- ----------------------------------------------------------------------------- + +-- 标签类型 +CREATE TYPE "TagType" AS ENUM ('MANUAL', 'AUTO', 'COMPUTED', 'SYSTEM'); + +-- 标签值类型 +CREATE TYPE "TagValueType" AS ENUM ('BOOLEAN', 'ENUM', 'NUMBER', 'STRING'); + +-- 标签变更操作 +CREATE TYPE "TagAction" AS ENUM ('ASSIGN', 'UPDATE', 'REMOVE', 'EXPIRE'); + +-- 人群包用途 +CREATE TYPE "SegmentUsageType" AS ENUM ('GENERAL', 'NOTIFICATION', 'ADVERTISING', 'ANALYTICS'); + +-- ----------------------------------------------------------------------------- +-- 2. 标签分类表 +-- ----------------------------------------------------------------------------- + +CREATE TABLE "tag_categories" ( + "id" TEXT NOT NULL, + "code" VARCHAR(50) NOT NULL, + "name" VARCHAR(100) NOT NULL, + "description" TEXT, + "sort_order" INTEGER NOT NULL DEFAULT 0, + "is_enabled" BOOLEAN NOT NULL DEFAULT true, + "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP, + "updated_at" TIMESTAMP(3) NOT NULL, + + CONSTRAINT "tag_categories_pkey" PRIMARY KEY ("id") +); + +CREATE UNIQUE INDEX "tag_categories_code_key" ON "tag_categories"("code"); +CREATE INDEX "tag_categories_code_idx" ON "tag_categories"("code"); +CREATE INDEX "tag_categories_is_enabled_idx" ON "tag_categories"("is_enabled"); + +-- ----------------------------------------------------------------------------- +-- 3. 用户分类规则表 (必须在 user_tags 之前创建，因为有外键引用) +-- ----------------------------------------------------------------------------- + +CREATE TABLE "user_classification_rules" ( + "id" TEXT NOT NULL, + "name" VARCHAR(100) NOT NULL, + "description" TEXT, + "conditions" JSONB NOT NULL, + "is_enabled" BOOLEAN NOT NULL DEFAULT true, + "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP, + "updated_at" TIMESTAMP(3) NOT NULL, + + CONSTRAINT "user_classification_rules_pkey" PRIMARY KEY ("id") +); + +-- ----------------------------------------------------------------------------- +-- 4. 用户标签定义表 +-- ----------------------------------------------------------------------------- + +CREATE TABLE "user_tags" ( + "id" TEXT NOT NULL, + "category_id" TEXT, + "code" VARCHAR(50) NOT NULL, + "name" VARCHAR(100) NOT NULL, + "description" TEXT, + "color" VARCHAR(20), + "type" "TagType" NOT NULL DEFAULT 'MANUAL', + "value_type" "TagValueType" NOT NULL DEFAULT 'BOOLEAN', + "enum_values" JSONB, + "rule_id" TEXT, + "is_advertisable" BOOLEAN NOT NULL DEFAULT true, + "estimated_users" INTEGER, + "is_enabled" BOOLEAN NOT NULL DEFAULT true, + "sort_order" INTEGER NOT NULL DEFAULT 0, + "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP, + "updated_at" TIMESTAMP(3) NOT NULL, + + CONSTRAINT "user_tags_pkey" PRIMARY KEY ("id") +); + +CREATE UNIQUE INDEX "user_tags_code_key" ON "user_tags"("code"); +CREATE UNIQUE INDEX "user_tags_rule_id_key" ON "user_tags"("rule_id"); +CREATE INDEX "user_tags_category_id_idx" ON "user_tags"("category_id"); +CREATE INDEX "user_tags_code_idx" ON "user_tags"("code"); +CREATE INDEX "user_tags_type_idx" ON "user_tags"("type"); +CREATE INDEX "user_tags_is_enabled_idx" ON "user_tags"("is_enabled"); +CREATE INDEX "user_tags_is_advertisable_idx" ON "user_tags"("is_advertisable"); + +-- 外键约束 +ALTER TABLE "user_tags" ADD CONSTRAINT "user_tags_category_id_fkey" + FOREIGN KEY ("category_id") REFERENCES "tag_categories"("id") ON DELETE SET NULL ON UPDATE CASCADE; + +ALTER TABLE "user_tags" ADD CONSTRAINT "user_tags_rule_id_fkey" + FOREIGN KEY ("rule_id") REFERENCES "user_classification_rules"("id") ON DELETE SET NULL ON UPDATE CASCADE; + +-- ----------------------------------------------------------------------------- +-- 5. 用户-标签关联表 +-- ----------------------------------------------------------------------------- + +CREATE TABLE "user_tag_assignments" ( + "id" TEXT NOT NULL, + "account_sequence" VARCHAR(12) NOT NULL, + "tag_id" TEXT NOT NULL, + "value" VARCHAR(100), + "assigned_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP, + "assigned_by" TEXT, + "expires_at" TIMESTAMP(3), + "source" VARCHAR(50), + + CONSTRAINT "user_tag_assignments_pkey" PRIMARY KEY ("id") +); + +CREATE UNIQUE INDEX "user_tag_assignments_account_sequence_tag_id_key" ON "user_tag_assignments"("account_sequence", "tag_id"); +CREATE INDEX "user_tag_assignments_account_sequence_idx" ON "user_tag_assignments"("account_sequence"); +CREATE INDEX "user_tag_assignments_tag_id_idx" ON "user_tag_assignments"("tag_id"); +CREATE INDEX "user_tag_assignments_value_idx" ON "user_tag_assignments"("value"); +CREATE INDEX "user_tag_assignments_expires_at_idx" ON "user_tag_assignments"("expires_at"); + +ALTER TABLE "user_tag_assignments" ADD CONSTRAINT "user_tag_assignments_tag_id_fkey" + FOREIGN KEY ("tag_id") REFERENCES "user_tags"("id") ON DELETE CASCADE ON UPDATE CASCADE; + +-- ----------------------------------------------------------------------------- +-- 6. 用户特征表 +-- ----------------------------------------------------------------------------- + +CREATE TABLE "user_features" ( + "id" TEXT NOT NULL, + "account_sequence" VARCHAR(12) NOT NULL, + "rfm_recency" INTEGER, + "rfm_frequency" INTEGER, + "rfm_monetary" DECIMAL(18,2), + "rfm_score" INTEGER, + "active_level" VARCHAR(20), + "last_active_at" TIMESTAMP(3), + "value_level" VARCHAR(20), + "lifetime_value" DECIMAL(18,2), + "lifecycle_stage" VARCHAR(20), + "custom_features" JSONB, + "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP, + "updated_at" TIMESTAMP(3) NOT NULL, + + CONSTRAINT "user_features_pkey" PRIMARY KEY ("id") +); + +CREATE UNIQUE INDEX "user_features_account_sequence_key" ON "user_features"("account_sequence"); +CREATE INDEX "user_features_rfm_score_idx" ON "user_features"("rfm_score"); +CREATE INDEX "user_features_active_level_idx" ON "user_features"("active_level"); +CREATE INDEX "user_features_value_level_idx" ON "user_features"("value_level"); +CREATE INDEX "user_features_lifecycle_stage_idx" ON "user_features"("lifecycle_stage"); + +-- ----------------------------------------------------------------------------- +-- 7. 人群包表 +-- ----------------------------------------------------------------------------- + +CREATE TABLE "audience_segments" ( + "id" TEXT NOT NULL, + "name" VARCHAR(100) NOT NULL, + "description" TEXT, + "conditions" JSONB NOT NULL, + "estimated_users" INTEGER, + "last_calculated" TIMESTAMP(3), + "usage_type" "SegmentUsageType" NOT NULL DEFAULT 'GENERAL', + "is_enabled" BOOLEAN NOT NULL DEFAULT true, + "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP, + "updated_at" TIMESTAMP(3) NOT NULL, + "created_by" TEXT NOT NULL, + + CONSTRAINT "audience_segments_pkey" PRIMARY KEY ("id") +); + +CREATE INDEX "audience_segments_usage_type_idx" ON "audience_segments"("usage_type"); +CREATE INDEX "audience_segments_is_enabled_idx" ON "audience_segments"("is_enabled"); + +-- ----------------------------------------------------------------------------- +-- 8. 标签变更日志表 +-- ----------------------------------------------------------------------------- + +CREATE TABLE "user_tag_logs" ( + "id" TEXT NOT NULL, + "account_sequence" VARCHAR(12) NOT NULL, + "tag_code" VARCHAR(50) NOT NULL, + "action" "TagAction" NOT NULL, + "old_value" VARCHAR(100), + "new_value" VARCHAR(100), + "reason" VARCHAR(200), + "operator_id" TEXT, + "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP, + + CONSTRAINT "user_tag_logs_pkey" PRIMARY KEY ("id") +); + +CREATE INDEX "user_tag_logs_account_sequence_created_at_idx" ON "user_tag_logs"("account_sequence", "created_at"); +CREATE INDEX "user_tag_logs_tag_code_idx" ON "user_tag_logs"("tag_code"); +CREATE INDEX "user_tag_logs_action_idx" ON "user_tag_logs"("action"); +CREATE INDEX "user_tag_logs_created_at_idx" ON "user_tag_logs"("created_at"); + +-- ----------------------------------------------------------------------------- +-- 9. 通知-标签关联表 (用于 BY_TAG 定向) +-- ----------------------------------------------------------------------------- + +CREATE TABLE "notification_tag_targets" ( + "id" TEXT NOT NULL, + "notification_id" TEXT NOT NULL, + "tag_id" TEXT NOT NULL, + + CONSTRAINT "notification_tag_targets_pkey" PRIMARY KEY ("id") +); + +CREATE UNIQUE INDEX "notification_tag_targets_notification_id_tag_id_key" ON "notification_tag_targets"("notification_id", "tag_id"); +CREATE INDEX "notification_tag_targets_tag_id_idx" ON "notification_tag_targets"("tag_id"); + +ALTER TABLE "notification_tag_targets" ADD CONSTRAINT "notification_tag_targets_notification_id_fkey" + FOREIGN KEY ("notification_id") REFERENCES "notifications"("id") ON DELETE CASCADE ON UPDATE CASCADE; + +ALTER TABLE "notification_tag_targets" ADD CONSTRAINT "notification_tag_targets_tag_id_fkey" + FOREIGN KEY ("tag_id") REFERENCES "user_tags"("id") ON DELETE CASCADE ON UPDATE CASCADE; + +-- ----------------------------------------------------------------------------- +-- 10. 通知-用户关联表 (用于 SPECIFIC 定向) +-- ----------------------------------------------------------------------------- + +CREATE TABLE "notification_user_targets" ( + "id" TEXT NOT NULL, + "notification_id" TEXT NOT NULL, + "account_sequence" VARCHAR(12) NOT NULL, + + CONSTRAINT "notification_user_targets_pkey" PRIMARY KEY ("id") +); + +CREATE UNIQUE INDEX "notification_user_targets_notification_id_account_sequence_key" ON "notification_user_targets"("notification_id", "account_sequence"); +CREATE INDEX "notification_user_targets_account_sequence_idx" ON "notification_user_targets"("account_sequence"); + +ALTER TABLE "notification_user_targets" ADD CONSTRAINT "notification_user_targets_notification_id_fkey" + FOREIGN KEY ("notification_id") REFERENCES "notifications"("id") ON DELETE CASCADE ON UPDATE CASCADE; + +-- ----------------------------------------------------------------------------- +-- 11. 修改通知表：添加 target_logic 字段，修改 targetType 枚举 +-- ----------------------------------------------------------------------------- + +-- 先更新 TargetType 枚举添加新值 +ALTER TYPE "TargetType" ADD VALUE IF NOT EXISTS 'BY_TAG'; +ALTER TYPE "TargetType" ADD VALUE IF NOT EXISTS 'SPECIFIC'; + +-- 创建 TargetLogic 枚举 +DO $$ BEGIN + CREATE TYPE "TargetLogic" AS ENUM ('ANY', 'ALL'); +EXCEPTION + WHEN duplicate_object THEN null; +END $$; + +-- 添加 target_logic 列 +ALTER TABLE "notifications" ADD COLUMN IF NOT EXISTS "target_logic" "TargetLogic" NOT NULL DEFAULT 'ANY';