zycandClaude Fable 5
216a711291
后端: - 新增 celery_health 生成前置闸——无 worker 在线时图片/视频生成入口 一律 503,防"提交到 ARK 后无人轮询、结果悬空+额度冻结"的数据丢失 - 拼接导出:帧率跟随源众数、字幕逐句重映射、原声/BGM 混音修复 - 资金核算审计脚本 + genesis 账目回填 + 滞留预留清理命令 - 接入 yunqi provider 与豆包 TTS 模型(catalog/migrations/bootstrap 命令) 前端:全站页面更新(pipeline/library/products/projects/team/account 等), 新增共享 pager 分页组件 QA:刷新 function-audit 全量输出,新增 full-qa 报告 文档:BP 产品介绍资料、design/CLAUDE.md Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
104 lines
4.0 KiB
Python
104 lines
4.0 KiB
Python
from rest_framework import serializers
|
|
|
|
from apps.billing.models import CreditAccount, CreditLedger
|
|
|
|
from .models import LoginSession, Team, TeamMember, User, UserPreference
|
|
|
|
|
|
class UserSerializer(serializers.ModelSerializer):
|
|
class Meta:
|
|
model = User
|
|
fields = ["id", "username", "first_name", "last_name", "email", "phone", "avatar_url", "status"]
|
|
read_only_fields = ["id", "status"]
|
|
|
|
|
|
class UserPreferenceSerializer(serializers.ModelSerializer):
|
|
class Meta:
|
|
model = UserPreference
|
|
fields = ["notify", "two_factor_enabled", "creation_defaults", "display", "updated_at"]
|
|
read_only_fields = ["updated_at"]
|
|
|
|
|
|
class LoginSessionSerializer(serializers.ModelSerializer):
|
|
is_current = serializers.SerializerMethodField()
|
|
|
|
class Meta:
|
|
model = LoginSession
|
|
fields = ["id", "user_agent", "ip_address", "last_seen_at", "created_at", "is_current"]
|
|
read_only_fields = fields
|
|
|
|
def get_is_current(self, obj) -> bool:
|
|
ctx = self.context or {}
|
|
return bool(obj.ip_address and obj.ip_address == ctx.get("current_ip") and obj.user_agent == ctx.get("current_ua"))
|
|
|
|
|
|
class TeamSerializer(serializers.ModelSerializer):
|
|
class Meta:
|
|
model = Team
|
|
fields = ["id", "name", "status", "owner", "created_at", "updated_at"]
|
|
read_only_fields = ["id", "status", "owner", "created_at", "updated_at"]
|
|
|
|
|
|
class TeamMemberSerializer(serializers.ModelSerializer):
|
|
user = UserSerializer(read_only=True)
|
|
# 本月已消费(自然月,按 CreditLedger CHARGE 流水按人聚合);由 view 经 context 注入 charged_map
|
|
month_charged = serializers.SerializerMethodField()
|
|
|
|
class Meta:
|
|
model = TeamMember
|
|
fields = ["id", "team", "user", "role", "status", "monthly_credit_limit", "month_charged"]
|
|
read_only_fields = ["id", "team", "user", "status"]
|
|
|
|
def get_month_charged(self, obj):
|
|
charged_map = self.context.get("charged_map") or {}
|
|
return str(charged_map.get(obj.user_id, 0))
|
|
|
|
|
|
class RegisterSerializer(serializers.Serializer):
|
|
username = serializers.CharField(max_length=150)
|
|
password = serializers.CharField(min_length=8, write_only=True)
|
|
email = serializers.EmailField(required=False, allow_blank=True)
|
|
team_name = serializers.CharField(max_length=128, required=False, allow_blank=True)
|
|
|
|
def validate_username(self, value):
|
|
if User.objects.filter(username=value).exists():
|
|
raise serializers.ValidationError("username already exists")
|
|
return value
|
|
|
|
def create(self, validated_data):
|
|
from decimal import Decimal
|
|
|
|
from django.conf import settings
|
|
from django.db import transaction
|
|
|
|
with transaction.atomic():
|
|
user = User.objects.create_user(
|
|
username=validated_data["username"],
|
|
password=validated_data["password"],
|
|
email=validated_data.get("email", ""),
|
|
)
|
|
team = Team.objects.create(
|
|
name=validated_data.get("team_name") or f"{user.username}'s Team",
|
|
owner=user,
|
|
)
|
|
TeamMember.objects.create(team=team, user=user, role=TeamMember.Role.OWNER)
|
|
trial = Decimal(str(settings.DEFAULT_TRIAL_CREDITS))
|
|
CreditAccount.objects.create(team=team, balance=trial)
|
|
# 开户赠送额度必须进流水,否则这笔钱在账单里查无凭证、无法对账(余额从第一条起就可追溯)
|
|
if trial > 0:
|
|
CreditLedger.objects.create(
|
|
team=team,
|
|
user=user,
|
|
ledger_type=CreditLedger.Type.RECHARGE,
|
|
amount=trial,
|
|
balance_after=trial,
|
|
reason="新用户试用额度赠送",
|
|
metadata={"kind": "trial_grant"},
|
|
)
|
|
return {"user": user, "team": team}
|
|
|
|
|
|
class LoginSerializer(serializers.Serializer):
|
|
username = serializers.CharField()
|
|
password = serializers.CharField(write_only=True)
|