From 00a239a2710d85d57437dc9db4b013f4333e5e35 Mon Sep 17 00:00:00 2001
From: hailin <hailin.zhao@gdzx.xyz>
Date: Sat, 20 Dec 2025 02:37:11 -0800
Subject: [PATCH] =?UTF-8?q?fix(admin-service):=20=E6=B7=BB=E5=8A=A0=20user?=
 =?UTF-8?q?=5Fquery=5Fview=20=E7=AD=89=E8=A1=A8=E7=9A=84=E8=BF=81=E7=A7=BB?=
 =?UTF-8?q?=E6=96=87=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

添加缺失的迁移文件：
- user_query_view 表（用户查询视图）
- event_consumer_offsets 表（事件消费位置追踪）
- processed_events 表（已处理事件记录）

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 .../migration.sql                             | 78 +++++++++++++++++++
 1 file changed, 78 insertions(+)
 create mode 100644 backend/services/admin-service/prisma/migrations/20250120100000_add_user_query_view/migration.sql

diff --git a/backend/services/admin-service/prisma/migrations/20250120100000_add_user_query_view/migration.sql b/backend/services/admin-service/prisma/migrations/20250120100000_add_user_query_view/migration.sql
new file mode 100644
index 00000000..caa4b56e
--- /dev/null
+++ b/backend/services/admin-service/prisma/migrations/20250120100000_add_user_query_view/migration.sql
@@ -0,0 +1,78 @@
+-- CreateTable
+CREATE TABLE "user_query_view" (
+    "user_id" BIGINT NOT NULL,
+    "account_sequence" VARCHAR(12) NOT NULL,
+    "nickname" VARCHAR(100),
+    "avatar_url" TEXT,
+    "phone_number_masked" VARCHAR(20),
+    "inviter_sequence" VARCHAR(12),
+    "kyc_status" VARCHAR(20) NOT NULL DEFAULT 'NOT_VERIFIED',
+    "personal_adoption_count" INTEGER NOT NULL DEFAULT 0,
+    "team_address_count" INTEGER NOT NULL DEFAULT 0,
+    "team_adoption_count" INTEGER NOT NULL DEFAULT 0,
+    "province_adoption_count" INTEGER NOT NULL DEFAULT 0,
+    "city_adoption_count" INTEGER NOT NULL DEFAULT 0,
+    "leaderboard_rank" INTEGER,
+    "status" VARCHAR(20) NOT NULL DEFAULT 'ACTIVE',
+    "is_online" BOOLEAN NOT NULL DEFAULT false,
+    "registered_at" TIMESTAMP(3) NOT NULL,
+    "last_active_at" TIMESTAMP(3),
+    "synced_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "user_query_view_pkey" PRIMARY KEY ("user_id")
+);
+
+-- CreateTable
+CREATE TABLE "event_consumer_offsets" (
+    "id" BIGSERIAL NOT NULL,
+    "consumer_group" VARCHAR(100) NOT NULL,
+    "topic" VARCHAR(100) NOT NULL,
+    "partition" INTEGER NOT NULL,
+    "offset" BIGINT NOT NULL,
+    "updated_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "event_consumer_offsets_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "processed_events" (
+    "id" BIGSERIAL NOT NULL,
+    "event_id" VARCHAR(100) NOT NULL,
+    "event_type" VARCHAR(50) NOT NULL,
+    "processed_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "processed_events_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "user_query_view_account_sequence_key" ON "user_query_view"("account_sequence");
+
+-- CreateIndex
+CREATE INDEX "user_query_view_account_sequence_idx" ON "user_query_view"("account_sequence");
+
+-- CreateIndex
+CREATE INDEX "user_query_view_nickname_idx" ON "user_query_view"("nickname");
+
+-- CreateIndex
+CREATE INDEX "user_query_view_status_idx" ON "user_query_view"("status");
+
+-- CreateIndex
+CREATE INDEX "user_query_view_registered_at_idx" ON "user_query_view"("registered_at");
+
+-- CreateIndex
+CREATE INDEX "user_query_view_personal_adoption_count_idx" ON "user_query_view"("personal_adoption_count");
+
+-- CreateIndex
+CREATE INDEX "user_query_view_inviter_sequence_idx" ON "user_query_view"("inviter_sequence");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "event_consumer_offsets_consumer_group_topic_partition_key" ON "event_consumer_offsets"("consumer_group", "topic", "partition");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "processed_events_event_id_key" ON "processed_events"("event_id");
+
+-- CreateIndex
+CREATE INDEX "processed_events_event_type_idx" ON "processed_events"("event_type");
+
+-- CreateIndex
+CREATE INDEX "processed_events_processed_at_idx" ON "processed_events"("processed_at");