Feat: 新增自定义发货人功能 (支持在/setup中配置)

Author: JNHFlow21

database/storage.py

@@ -49,7 +49,9 @@
     points_loss INTEGER DEFAULT 30,
     
     limit_post_daily INTEGER DEFAULT 5,
-    rank_config JSON
+    rank_config JSON,
+    
+    seller_id INTEGER  -- [新增] 发货人ID
 );
 
 -- 2. 用户资产表
@@ -155,6 +157,13 @@ async def check_and_migrate_schema():
         except Exception:
             try: await db.execute("ALTER TABLE groups ADD COLUMN limit_post_daily INTEGER DEFAULT 5")
             except: pass
+            
+        # [新增] 检查 seller_id 字段
+        try:
+            await db.execute("SELECT seller_id FROM groups LIMIT 1")
+        except Exception:
+            try: await db.execute("ALTER TABLE groups ADD COLUMN seller_id INTEGER")
+            except: pass
 
         # 3. products / orders 表
         try: await db.execute("SELECT group_id FROM products LIMIT 1")

handlers/setup.py

@@ -88,6 +88,8 @@ async def setup_menu_callback(update: Update, context: ContextTypes.DEFAULT_TYPE
         "set_p_lose": ("points_loss", "晒损送多少分?"),
         "set_p_limit": ("limit_post_daily", "每日晒单上限是多少次？\n(输入 -2 表示无限制)"),
         "set_rank": ("rank_config", "请输入段位规则 JSON (建议5档):\n例如: `{\"0\":\"🌱茁壮韭菜\", \"100\":\"💎钻石双手\", \"500\":\"🐋潜水巨鲸\", \"2000\":\"📈K线主宰\", \"5000\":\"🚀交易战神\"}`"),
+        # [新增] 设置发货人ID
+        "set_seller": ("seller_id", "请输入 **发货人** 的 Telegram ID (数字):\n(让他对自己发送 /id 即可获取，如果不设置则不显示)")
     }
 
     if data in input_map:
@@ -136,6 +138,9 @@ def limit_str(v): return "♾️无限" if v == -2 else f"{v}次"
         [InlineKeyboardButton("设晒盈分", callback_data="set_p_win"), InlineKeyboardButton("设晒损分", callback_data="set_p_lose")],
         [InlineKeyboardButton("🏅 设置段位表", callback_data="set_rank")],
 
+        # [新增] 发货人设置
+        [InlineKeyboardButton(f"📦 发货人ID: {val(info['seller_id'])}", callback_data="set_seller")],
+        
         [InlineKeyboardButton(f"早报 {ic(info['sub_news'])}", callback_data="tg_news"), InlineKeyboardButton("设ID", callback_data="set_news")],
         [InlineKeyboardButton(f"分析 {ic(info['sub_analysis'])}", callback_data="tg_analysis"), InlineKeyboardButton("设ID", callback_data="set_ana")],
         [InlineKeyboardButton(f"战绩 {ic(info['sub_marketing'])}", callback_data="tg_marketing"), InlineKeyboardButton("设ID", callback_data="set_mkt")],
@@ -153,7 +158,7 @@ async def save_input(update: Update, context: ContextTypes.DEFAULT_TYPE):
     text = update.message.text.strip()
 
     # 1. 数字校验
-    if any(x in key for x in ["points", "topic", "limit"]):
+    if any(x in key for x in ["points", "topic", "limit", "seller_id"]):
         try:
             val = int(text)
             if val == -1 and "topic" in key: val = None

handlers/shop.py

@@ -246,12 +246,21 @@ async def callback_buy_confirm(update: Update, context: ContextTypes.DEFAULT_TYP
         prod = await get_product(pid)
         p_name = prod['name'] if prod else "商品"
 
+        # [新增] 尝试获取群组设置的发货人ID
+        group_info = await get_group(chat.id)
+        seller_text = "请把此码发给本群管理员"
+        
+        if group_info and group_info['seller_id']:
+            seller_id = group_info['seller_id']
+            # 生成点击链接，这里会直接触发Telegram的@功能
+            seller_text = f"请联系发货人: [点击联系](tg://user?id={seller_id})"
+        
         txt = (
             f"🎉 **购买成功！**\n\n"
             f"🏠 群组: {html.escape(chat.title)}\n"
             f"📦 商品: {p_name}\n"
             f"🔑 **核销码**: `{code}`\n\n"
-            f"⚠️ 请把此码发给本群管理员进行兑换。"
+            f"⚠️ {seller_text} 进行兑换。"
         )
         try:
             await context.bot.send_message(user.id, txt, parse_mode=ParseMode.MARKDOWN)
@@ -260,6 +269,7 @@ async def callback_buy_confirm(update: Update, context: ContextTypes.DEFAULT_TYP
             await query.message.reply_text(
                 f"✅ {user.full_name} 购买成功！\n"
                 f"您的核销码: `{code}`\n"
+                f"⚠️ {seller_text}\n"
                 f"请截图保存 (无法私聊您)",
                 parse_mode=ParseMode.MARKDOWN
             )