1、团队积分变动增加对应手机号和日期搜索

2、翻页样式应该放在左下角，别的页面也在左下角吧
3、列表页面显示总使用积分和下载excel
4、团队管理员分配积分的逻辑有问题，团队积分变动不显示，后台显示流水类型也不对，应该增加团队的内部积分变动类型，同步搜索下载
5、调整积分弹窗应该让用户显示增加还是减少的button
6、检查代码是否有不合理的地方，比如枚举是否放在enums里了

video-gen-api/app/api/v1/team.py

@@ -5,6 +5,7 @@ from datetime import datetime
 from fastapi import APIRouter, Depends, HTTPException, Query
 from sqlalchemy import select
 from sqlalchemy.ext.asyncio import AsyncSession
+from starlette.responses import StreamingResponse
 
 from app.config import settings
 from app.dependencies import get_current_user, get_db
@@ -99,6 +100,7 @@ async def transfer_credits(
         current_user.id,
         req.target_user_id,
         req.amount,
+        req.direction or "increase",
         req.description,
     )
     return {"message": "ok"}
@@ -261,9 +263,10 @@ async def list_team_credit_records(
     page: int = Query(1, ge=1),
     page_size: int = Query(20, ge=1, le=100),
     user_id: str | None = Query(None),
-    record_type: str | None = Query(None, pattern="^(recharge|consume|refund|admin)$"),
-    start_date: str | None = Query(None),
-    end_date: str | None = Query(None),
+    phone: str | None = Query(None, description="按手机号搜索"),
+    record_type: str | None = Query(None, pattern="^(recharge|consume|refund|team_internal)$"),
+    start_date: str | None = Query(None, description="起始日期 YYYY-MM-DD"),
+    end_date: str | None = Query(None, description="截止日期 YYYY-MM-DD"),
     current_user: User = Depends(get_current_user),
     db: AsyncSession = Depends(get_db),
 ):
@@ -273,13 +276,97 @@ async def list_team_credit_records(
         raise HTTPException(status_code=403, detail="只有团队管理人可查看")
 
     from app.services.admin_credit_record_service import list_admin_credit_records
+
+    # 如果传了 phone，先找到对应的 user_id
+    resolved_user_id = user_id
+    if phone and not user_id:
+        phone_result = await db.execute(
+            select(User.id).where(
+                User.team_id == team.id,
+                User.phone == phone,
+                User.is_active.is_(True),
+            ).limit(1)
+        )
+        resolved_user_id = phone_result.scalar_one_or_none()
+        if not resolved_user_id:
+            return {"items": [], "total": 0, "summary": {}}
+
     return await list_admin_credit_records(
         db,
         page=page,
         page_size=page_size,
         team_id=team.id,
-        user_id=user_id,
+        user_id=resolved_user_id,
         record_type=record_type,
         start_date=start_date,
         end_date=end_date,
     )
+
+
+# ── 团队积分导出 Excel ──────────────────────────────────
+@router.get("/credit-records/export")
+async def export_team_credit_records(
+    user_id: str | None = Query(None),
+    phone: str | None = Query(None),
+    record_type: str | None = Query(None, pattern="^(recharge|consume|refund|team_internal)$"),
+    start_date: str | None = Query(None),
+    end_date: str | None = Query(None),
+    current_user: User = Depends(get_current_user),
+    db: AsyncSession = Depends(get_db),
+):
+    """导出团队积分变动记录为 Excel（仅管理人）。"""
+    team = await get_managed_team(db, current_user.id)
+    if not team:
+        raise HTTPException(status_code=403, detail="只有团队管理人可查看")
+
+    from app.services.admin_credit_record_service import list_admin_credit_records
+
+    resolved_user_id = user_id
+    if phone and not user_id:
+        phone_result = await db.execute(
+            select(User.id).where(
+                User.team_id == team.id,
+                User.phone == phone,
+                User.is_active.is_(True),
+            ).limit(1)
+        )
+        resolved_user_id = phone_result.scalar_one_or_none()
+
+    # 拉取全部记录（不分页）
+    result = await list_admin_credit_records(
+        db,
+        page=1,
+        page_size=10000,
+        team_id=team.id,
+        user_id=resolved_user_id,
+        record_type=record_type,
+        start_date=start_date,
+        end_date=end_date,
+    )
+
+    # 生成 CSV（兼容 Excel 打开）
+    import csv
+    import io
+
+    output = io.StringIO()
+    writer = csv.writer(output)
+    writer.writerow(["用户名", "手机号", "类型", "积分变动", "余额", "说明", "时间"])
+    for item in result.get("items", []):
+        writer.writerow([
+            item.get("username") or "-",
+            item.get("phone") or "-",
+            item.get("record_type_label") or item.get("type") or "-",
+            item.get("amount", 0),
+            item.get("balance_after", 0),
+            item.get("description") or "-",
+            item.get("created_at") or "-",
+        ])
+
+    from starlette.responses import StreamingResponse
+    output.seek(0)
+    filename = f"team_credits_{team.id}_{datetime.now().strftime('%Y%m%d_%H%M%S')}.csv"
+    return StreamingResponse(
+        iter([output.getvalue()]),
+        media_type="text/csv; charset=utf-8-sig",
+        headers={"Content-Disposition": f"attachment; filename*=UTF-8''{filename}"},
+    )

video-gen-api/app/enums/credit_record.py

@@ -5,6 +5,7 @@ class CreditRecordType(str, Enum):
     RECHARGE = "recharge"
     CONSUME = "consume"
     REFUND = "refund"
+    TEAM_INTERNAL = "team_internal"  # 团队内部积分流转（管理人分配）
 
 
 class CreditRecordOwnerType(str, Enum):
@@ -111,6 +112,7 @@ CREDIT_RECORD_TYPE_LABELS = {
     CreditRecordType.RECHARGE.value: "充值",
     CreditRecordType.CONSUME.value: "消费",
     CreditRecordType.REFUND.value: "回退",
+    CreditRecordType.TEAM_INTERNAL.value: "团队内部",
 }
 
 CREDIT_RECORD_SUBJECT_LABELS = {

video-gen-api/app/schemas/team_manager.py

@@ -21,6 +21,7 @@ class TeamMemberOut(BaseModel):
 class ManagerTransferRequest(BaseModel):
     target_user_id: str = Field(..., description="接收积分的成员用户ID")
     amount: float = Field(gt=0, description="转账积分数量（正数）")
+    direction: str = Field(default="increase", pattern="^(increase|decrease)$", description="increase=管理人转给成员；decrease=从成员扣减回管理人")
     description: str | None = Field(None, max_length=256, description="转账说明")
 
 

video-gen-api/app/services/team_manager_service.py

@@ -129,11 +129,19 @@ async def transfer_credits_to_member(
     manager_id: str,
     target_member_id: str,
     amount: float,
+    direction: str = "increase",  # "increase" 管理人→成员; "decrease" 成员扣减
     description: str | None = None,
 ) -> None:
-    """管理人从自己余额转积分给团队成员。"""
+    """管理人为团队成员增加或扣减积分。
+
+    direction:
+      - "increase": 管理人从自己余额转积分给成员（管理人减少，成员增加）
+      - "decrease": 从成员扣积分回到管理人（成员减少，管理人增加）
+    """
     if amount <= 0:
-        raise HTTPException(status_code=400, description="转账积分必须大于0")
+        raise HTTPException(status_code=400, description="积分数量必须大于0")
+    if direction not in ("increase", "decrease"):
+        raise HTTPException(status_code=400, description="无效操作方向")
 
     # 获取管理人
     manager_result = await db.execute(
@@ -155,7 +163,7 @@ async def transfer_credits_to_member(
     if not manager.team_id:
         raise HTTPException(status_code=400, detail="您不在任何团队中")
     if member.team_id != manager.team_id:
-        raise HTTPException(status_code=400, detail="只能转账给同团队成员")
+        raise HTTPException(status_code=400, detail="只能操作同团队成员")
 
     team_result = await db.execute(
         select(Team).where(Team.id == manager.team_id, Team.deleted_at.is_(None)).limit(1)
@@ -164,22 +172,44 @@ async def transfer_credits_to_member(
     if not team or team.manager_id != manager_id:
         raise HTTPException(status_code=403, detail="只有团队管理人才能分配积分")
 
-    desc = description or "团队积分发放"
+    desc = description or ("团队积分发放" if direction == "increase" else "团队积分扣减")
+    xfer_id = generate_id()
 
-    # 从管理人扣减
-    await deduct_credits(
-        db,
-        manager_id,
-        amount,
-        f"分配给成员 {member.username}: {desc}",
-        biz_key=f"mgr_xfer_out:{manager_id}:{target_member_id}:{generate_id()}",
-    )
-    # 给成员增加
-    await add_credits(
-        db,
-        target_member_id,
-        amount,
-        f"来自团队管理人: {desc}",
-        record_type="admin",
-        biz_key=f"mgr_xfer_in:{manager_id}:{target_member_id}:{generate_id()}",
-    )
+    if direction == "increase":
+        # 管理人扣减
+        await deduct_credits(
+            db,
+            manager_id,
+            amount,
+            f"分配给成员 {member.username}: {desc}",
+            record_type="team_internal",
+            biz_key=f"mgr_xfer_out:{manager_id}:{target_member_id}:{xfer_id}",
+        )
+        # 成员增加
+        await add_credits(
+            db,
+            target_member_id,
+            amount,
+            f"来自团队管理人: {desc}",
+            record_type="team_internal",
+            biz_key=f"mgr_xfer_in:{manager_id}:{target_member_id}:{xfer_id}",
+        )
+    else:
+        # 成员扣减
+        await deduct_credits(
+            db,
+            target_member_id,
+            amount,
+            f"扣减给团队管理人: {desc}",
+            record_type="team_internal",
+            biz_key=f"mgr_deduct_out:{manager_id}:{target_member_id}:{xfer_id}",
+        )
+        # 管理人增加
+        await add_credits(
+            db,
+            manager_id,
+            amount,
+            f"来自成员 {member.username}: {desc}",
+            record_type="team_internal",
+            biz_key=f"mgr_deduct_in:{manager_id}:{target_member_id}:{xfer_id}",
+        )