# collections - 藏品路由 # Version: 0.0.1 # 更新： import os # Version: 1.2.x # 更新： import os # 更新： import uuid # 更新： import re # 更新： from typing import Optional, List # 更新： from fastapi import APIRouter, Depends, HTTPException, status, Query, UploadFile, File # 更新： from sqlalchemy import func, text # 更新： from sqlalchemy.orm import Session, joinedload # 更新： from app.core.database import get_db # 更新： from app.core.auth import get_current_user # 更新： from app.core.logging_config import logger # 更新： from app.models.models import User, Collection, CollectionImage, Operation # 更新： from app.schemas.schemas import ( # 更新： CollectionCreate, CollectionUpdate, CollectionResponse, # 更新： CollectionListResponse, CollectionImageResponse # 更新： ) # 更新： from app.services.oss import upload_to_oss, get_oss_path, delete_from_oss, get_public_url # 更新： # 更新： router = APIRouter(prefix="/api/collections", tags=["藏品"]) # 更新： # 更新： # 更新： def to_camel_case(data: dict) -> dict: # 更新： """将字段编码转换为 camelCase 格式""" # 更新： if not data: # 更新： return data # 更新： # 更新： mapping = { # 更新： 'f99_90_id': 'id', # 更新： 'f99_91_user_id': 'userId', # 更新： 'f99_92_created_at': 'createdAt', # 更新： 'f99_93_updated_at': 'updatedAt', # 更新： 'f01_01_name': 'name', # 更新： 'f01_02_code': 'code', # 更新： 'f01_03_category': 'category', # 更新： 'f01_04_status': 'status', # 更新： 'f01_05_remark': 'remark', # 更新： 'f02_10_prefix_serial': 'prefixSerial', # 更新： 'f02_11_version': 'version', # 更新： 'f02_12_packaging': 'packaging', # 更新： 'f02_13_rarity': 'rarity', # 更新： 'f02_14_number_category': 'numberCategory', # 更新： 'f03_20_is_graded': 'isGraded', # 更新： 'f03_21_grading_company': 'gradingCompany', # 更新： 'f03_22_grading_score': 'gradingScore', # 更新： 'f03_23_three_star': 'threeStar', # 更新： 'f04_30_special_mark': 'specialMark', # 更新： 'f04_31_serial_feature': 'serialFeature', # 更新： 'f04_32_issuer': 'issuer', # 更新： 'f04_33_issue_year': 'issueYear', # 更新： 'f04_34_material': 'material', # 更新： 'f04_35_denomination': 'denomination', # 更新： 'f04_36_issue_quantity': 'issueQuantity', # 更新： 'f05_40_cost_price': 'costPrice', # 更新： 'f05_41_target_price': 'targetPrice', # 更新： 'f05_42_goal_price': 'goalPrice', # 更新： 'f05_43_repair_fee': 'repairFee', # 更新： 'f05_44_grading_fee': 'gradingFee', # 更新： 'f06_50_purpose': 'purpose', # 更新： 'images': 'images', # 更新： } # 更新： # 更新： return {mapping.get(k, k): v for k, v in data.items()} # 更新： # 更新： # 更新： # 编码生成函数 # 更新： def generate_code(version: str, user_id: str, db: Session) -> str: # 更新： """自动生成藏品编号 - 按用户独立编码""" # 更新： import re # 更新： # 更新： # 查询当前用户的非空编码（不与其他用户混算）- 使用行锁防止并发 # 更新： user_codes = db.query(Collection.f01_02_code).filter( # 更新： Collection.f01_02_code.isnot(None), # 更新： Collection.f99_91_user_id == user_id # 更新： ).with_for_update().all() # 更新： # 更新： max_num = 0 # 更新： for (code,) in user_codes: # 更新： # 处理纯数字编码（支持4位和5位） # 更新： if re.match(r'^\d{4,5}$', code): # 更新： try: # 更新： num = int(code) # 更新： if num > max_num: # 更新： max_num = num # 更新： except (ValueError, TypeError): # 更新： pass # 更新： # 更新： # 当前用户最大号 +1 # 更新： next_num = max_num + 1 # 更新： # 更新： # 如果超过9999，使用5位；否则使用4位 # 更新： if next_num > 9999: # 更新： return str(next_num).zfill(5) # 更新： else: # 更新： return str(next_num).zfill(4) # 更新： # 更新： # 更新： @router.get("/next-code") # 更新： def get_next_code( # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """获取下一个藏品编号""" # 更新： next_code = generate_code("2024 龙", current_user.f99_90_id, db) # 更新： return {"code": 200, "data": {"nextCode": next_code}} # 更新： # 更新： # 更新： @router.get("") # 更新： def get_collections( # 更新： id: str = Query(None, description="filter by collection id"), # 更新： category: Optional[str] = None, # 更新： status: Optional[str] = None, # 更新： search: Optional[str] = None, # 更新： specialMark: Optional[str] = Query(None, description="special mark filter"), # 更新： numberCategory: Optional[str] = Query(None, description="number category filter"), # 更新： gradingCompany: Optional[str] = Query(None, description="grading company filter"), # 更新： gradingScore: Optional[str] = Query(None, description="grading score filter"), # 更新： packaging: Optional[str] = Query(None, description="packaging filter"), # 更新： rarity: Optional[str] = Query(None, description="rarity filter"), # 更新： version: Optional[str] = Query(None, description="version filter"), # 更新： profitLoss: Optional[str] = Query(None, description="profit loss filter: profit or loss"), # 更新： page: int = Query(1, ge=1), # 更新： limit: int = Query(20, ge=1, le=500), # 更新： sortBy: str = Query('createdAt'), # 更新： sortOrder: str = Query('desc'), # 更新： all_users: bool = Query(False, description="return all users data for admin"), # 更新： user_id: str = Query(None, description="filter by user id"), # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """获取藏品列表""" # 更新： # admin 用户可以看到所有藏品，普通用户只能看到自己的 # 更新： # 如果指定 all_users=true，则返回所有用户藏品 # 更新： from sqlalchemy.orm import joinedload # 更新： # 更新： # 管理员默认查看全库，普通用户只看自己，未登录返回空列表 # 更新： if current_user is None or current_user.role != "admin": # 更新： # 非管理员或未登录用户只能查看自己的藏品（如果没有登录则返回空） # 更新： if current_user is None: # 更新： return {"data": [], "total": 0, "page": 1, "limit": 20} # 更新： query = db.query(Collection).filter(Collection.f99_91_user_id == current_user.f99_90_id) # 更新： else: # 更新： # 管理员查看所有藏品 # 更新： query = db.query(Collection, User.f01_01_name.label('owner_name')).join( # 更新： User, Collection.f99_91_user_id == User.f99_90_id, isouter=True # 更新： ) # 更新： # 更新： # 如果指定了user_id参数，则只返回该用户的藏品 # 更新： if user_id: # 更新： query = query.filter(Collection.f99_91_user_id == user_id) # 更新： # 更新： # 按ID精确筛选 # 更新： if id: # 更新： query = query.filter(Collection.f99_90_id == id) # 更新： # 更新： if category: # 更新： query = query.filter(Collection.f01_03_category == category) # 更新： if status: # 更新： query = query.filter(Collection.f01_04_status == status) # 更新： if specialMark: # 更新： query = query.filter(Collection.f04_30_special_mark == specialMark) # 更新： if gradingCompany: # 更新： query = query.filter(Collection.f03_21_grading_company.contains(gradingCompany)) # 更新： if gradingScore: # 更新： query = query.filter(Collection.f03_22_grading_score.contains(gradingScore)) # 更新： if numberCategory: # 更新： query = query.filter(Collection.f02_14_number_category.contains(numberCategory)) # 更新： if packaging: # 更新： query = query.filter(Collection.f02_12_packaging== packaging) # 更新： if rarity: # 更新： query = query.filter(Collection.f02_13_rarity.contains(rarity)) # 更新： if version: # 更新： query = query.filter(Collection.f02_11_version.contains(version)) # 更新： # 更新： # 盈亏筛选（只对已售藏品有效） # 更新： if profitLoss: # 更新： if profitLoss == 'profit': # 更新： # 盈利：售价 > 成本价 # 更新： query = query.filter( # 更新： Collection.f01_04_status == 'sold', # 更新： Collection.f05_42_goal_price > Collection.f05_40_cost_price # 更新： ) # 更新： elif profitLoss == 'loss': # 更新： # 亏损：售价 <= 成本价 # 更新： query = query.filter( # 更新： Collection.f01_04_status == 'sold', # 更新： Collection.f05_42_goal_price <= Collection.f05_40_cost_price # 更新： ) # 更新： # 更新： if search: # 更新： query = query.filter( # 更新： (Collection.f01_01_name.contains(search)) | # 更新： (Collection.f01_05_remark.contains(search)) # 更新： ) # 更新： # 更新： # 总数（应用筛选条件后的数量） # 更新： total = query.count() # 更新： # 更新： # 使用joinedload预加载图片，避免N+1查询问题 # 更新： query = query.options(joinedload(Collection.images)) # 更新： # 更新： # 分页 # 更新： data = query.order_by(Collection.f99_92_created_at.desc()) \ # 更新： .offset((page - 1) * limit) \ # 更新： .limit(limit) \ # 更新： .all() # 更新： # 更新： # 转换为字典列表并转为 camelCase # 更新： data_list = [] # 更新： for item in data: # 更新： # 处理联表查询结果 # 更新： if current_user is not None and current_user.role == "admin": # 更新： collection_item, owner_name = item # 更新： else: # 更新： collection_item = item # 更新： owner_name = None # 更新： # 更新： item_dict = { # 更新： 'f99_90_id': collection_item.f99_90_id, # 更新： 'f99_91_user_id': collection_item.f99_91_user_id, # 更新： 'owner_name': owner_name, # 所属用户名（仅管理员可见） # 更新： 'f01_01_name': collection_item.f01_01_name, # 更新： 'f01_02_code': collection_item.f01_02_code, # 更新： 'f01_03_category': collection_item.f01_03_category, # 更新： 'f01_04_status': collection_item.f01_04_status, # 更新： 'f01_05_remark': collection_item.f01_05_remark, # 更新： 'f02_10_prefix_serial': collection_item.f02_10_prefix_serial, # 更新： 'f02_11_version': collection_item.f02_11_version, # 更新： 'f02_12_packaging': collection_item.f02_12_packaging, # 更新： 'f02_13_rarity': collection_item.f02_13_rarity, # 更新： 'f02_14_number_category': collection_item.f02_14_number_category, # 更新： 'f03_20_is_graded': collection_item.f03_20_is_graded, # 更新： 'f03_21_grading_company': collection_item.f03_21_grading_company, # 更新： 'f03_22_grading_score': collection_item.f03_22_grading_score, # 更新： 'f03_23_three_star': collection_item.f03_23_three_star, # 更新： 'f04_30_special_mark': collection_item.f04_30_special_mark, # 更新： 'f04_31_serial_feature': collection_item.f04_31_serial_feature, # 更新： 'f04_32_issuer': collection_item.f04_32_issuer, # 更新： 'f04_33_issue_year': collection_item.f04_33_issue_year, # 更新： 'f04_34_material': collection_item.f04_34_material, # 更新： 'f04_35_denomination': collection_item.f04_35_denomination, # 更新： 'f04_36_issue_quantity': collection_item.f04_36_issue_quantity, # 更新： 'f05_40_cost_price': float(collection_item.f05_40_cost_price) if collection_item.f05_40_cost_price else None, # 更新： 'f05_41_target_price': float(collection_item.f05_41_target_price) if collection_item.f05_41_target_price else None, # 更新： 'f05_42_goal_price': float(collection_item.f05_42_goal_price) if collection_item.f05_42_goal_price else None, # 更新： 'f05_43_repair_fee': float(collection_item.f05_43_repair_fee) if collection_item.f05_43_repair_fee else None, # 更新： 'f05_44_grading_fee': float(collection_item.f05_44_grading_fee) if collection_item.f05_44_grading_fee else None, # 更新： 'f06_50_purpose': collection_item.f06_50_purpose, # 更新： 'f99_92_created_at': collection_item.f99_92_created_at.isoformat() if collection_item.f99_92_created_at else None, # 更新： 'images': [] # 更新： } # 更新： # 更新： # 直接使用预加载的图片数据，无需再查询 # 更新： for img in collection_item.images: # 更新： item_dict['images'].append({ # 更新： 'id': img.id, # 更新： 'filename': img.filename, # 更新： 'original_name': img.original_name, # 更新： 'path': img.path, # 更新： 'created_at': img.created_at.isoformat() if img.created_at else None # 更新： }) # 更新： # 更新： data_list.append(to_camel_case(item_dict)) # 更新： # 更新： return { # 更新： "data": data_list, # 更新： "pagination": { # 更新： "page": page, # 更新： "limit": limit, # 更新： "total": total, # 更新： "pages": (total + limit - 1) // limit # 更新： } # 更新： } # 更新： # 更新： # 更新： @router.get("/stats") # 更新： def get_stats( # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """获取藏品统计 - 使用SQL聚合查询优化性能""" # 更新： # 更新： # 非管理员或未登录用户只能查看自己的藏品 # 更新： if current_user is None: # 更新： return { # 更新： "totalCount": 0, # 更新： "byCategory": [], # 更新： "byStatus": [], # 更新： "byGrading": [], # 更新： "byPackaging": [], # 更新： "byRarity": [], # 更新： "byVersion": [], # 更新： "byGradingCompany": [], # 更新： "byGradingScore": [], # 更新： "bySpecialMark": [], # 更新： "byNumberCategory": [], # 更新： "byProfitLoss": [], # 更新： "totalCost": 0, # 更新： "totalTarget": 0, # 更新： "expectedProfit": 0, # 更新： "totalRevenue": 0, # 更新： "totalProfit": 0 # 更新： } # 更新： # 更新： # 构建基础查询条件 # 更新： is_admin = current_user.role == "admin" # 更新： # 更新： if not is_admin: # 更新： base_filter = Collection.f99_91_user_id == current_user.f99_90_id # 更新： else: # 更新： base_filter = None # 更新： # 更新： # 总数 - 使用SQL COUNT # 更新： total_count = db.query(func.count(Collection.f99_90_id)).filter( # 更新： base_filter if base_filter is not None else True # 更新： ).scalar() # 更新： if base_filter is not None: # 更新： total_count = db.query(func.count(Collection.f99_90_id)).filter(base_filter).scalar() # 更新： else: # 更新： total_count = db.query(func.count(Collection.f99_90_id)).scalar() # 更新： # 更新： # 按分类统计 - 使用SQL GROUP BY # 更新： if base_filter is not None: # 更新： by_category = db.query( # 更新： Collection.f01_03_category, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter).group_by(Collection.f01_03_category).all() # 更新： # 更新： by_status = db.query( # 更新： Collection.f01_04_status, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter).group_by(Collection.f01_04_status).all() # 更新： # 更新： by_graded = db.query( # 更新： Collection.f03_20_is_graded, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter).group_by(Collection.f03_20_is_graded).all() # 更新： # 更新： by_packaging = db.query( # 更新： Collection.f02_12_packaging, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter, Collection.f02_12_packaging.isnot(None)).group_by(Collection.f02_12_packaging).all() # 更新： # 更新： by_rarity = db.query( # 更新： Collection.f02_13_rarity, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter, Collection.f02_13_rarity.isnot(None)).group_by(Collection.f02_13_rarity).all() # 更新： # 更新： by_version = db.query( # 更新： Collection.f02_11_version, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter, Collection.f02_11_version.isnot(None)).group_by(Collection.f02_11_version).all() # 更新： # 更新： by_grading_company = db.query( # 更新： Collection.f03_21_grading_company, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter, Collection.f03_20_is_graded == True, Collection.f03_21_grading_company.isnot(None)).group_by(Collection.f03_21_grading_company).all() # 更新： # 更新： by_grading_score = db.query( # 更新： Collection.f03_22_grading_score, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter, Collection.f03_20_is_graded == True, Collection.f03_22_grading_score.isnot(None)).group_by(Collection.f03_22_grading_score).all() # 更新： # 更新： by_special_mark = db.query( # 更新： Collection.f04_30_special_mark, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter, Collection.f04_30_special_mark.isnot(None)).group_by(Collection.f04_30_special_mark).all() # 更新： # 更新： by_number_category = db.query( # 更新： Collection.f02_14_number_category, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(base_filter, Collection.f02_14_number_category.isnot(None)).group_by(Collection.f02_14_number_category).all() # 更新： # 更新： # 成本相关统计 - 使用SQL SUM # 更新： cost_result = db.query( # 更新： func.coalesce(func.sum(Collection.f05_40_cost_price), 0) + # 更新： func.coalesce(func.sum(Collection.f05_43_repair_fee), 0) + # 更新： func.coalesce(func.sum(Collection.f05_44_grading_fee), 0) # 更新： ).filter(base_filter).first() # 更新： total_cost = cost_result[0] if cost_result else 0 # 更新： # 更新： # 预期利润 # 更新： expected_profit_result = db.query( # 更新： func.coalesce(func.sum(Collection.f05_41_target_price - Collection.f05_40_cost_price), 0) # 更新： ).filter(base_filter, Collection.f05_41_target_price.isnot(None), Collection.f05_41_target_price > 0).first() # 更新： expected_profit = expected_profit_result[0] if expected_profit_result else 0 # 更新： # 更新： # 已售藏品统计 # 更新： sold_collections = db.query(Collection).filter( # 更新： base_filter, # 更新： Collection.f01_04_status == 'sold', # 更新： Collection.f05_42_goal_price.isnot(None), # 更新： Collection.f05_42_goal_price > 0 # 更新： ).all() # 更新： # 更新： else: # 更新： # 管理员查看所有数据 # 更新： by_category = db.query( # 更新： Collection.f01_03_category, # 更新： func.count(Collection.f99_90_id) # 更新： ).group_by(Collection.f01_03_category).all() # 更新： # 更新： by_status = db.query( # 更新： Collection.f01_04_status, # 更新： func.count(Collection.f99_90_id) # 更新： ).group_by(Collection.f01_04_status).all() # 更新： # 更新： by_graded = db.query( # 更新： Collection.f03_20_is_graded, # 更新： func.count(Collection.f99_90_id) # 更新： ).group_by(Collection.f03_20_is_graded).all() # 更新： # 更新： by_packaging = db.query( # 更新： Collection.f02_12_packaging, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(Collection.f02_12_packaging.isnot(None)).group_by(Collection.f02_12_packaging).all() # 更新： # 更新： by_rarity = db.query( # 更新： Collection.f02_13_rarity, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(Collection.f02_13_rarity.isnot(None)).group_by(Collection.f02_13_rarity).all() # 更新： # 更新： by_version = db.query( # 更新： Collection.f02_11_version, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(Collection.f02_11_version.isnot(None)).group_by(Collection.f02_11_version).all() # 更新： # 更新： by_grading_company = db.query( # 更新： Collection.f03_21_grading_company, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(Collection.f03_20_is_graded == True, Collection.f03_21_grading_company.isnot(None)).group_by(Collection.f03_21_grading_company).all() # 更新： # 更新： by_grading_score = db.query( # 更新： Collection.f03_22_grading_score, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(Collection.f03_20_is_graded == True, Collection.f03_22_grading_score.isnot(None)).group_by(Collection.f03_22_grading_score).all() # 更新： # 更新： by_special_mark = db.query( # 更新： Collection.f04_30_special_mark, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(Collection.f04_30_special_mark.isnot(None)).group_by(Collection.f04_30_special_mark).all() # 更新： # 更新： by_number_category = db.query( # 更新： Collection.f02_14_number_category, # 更新： func.count(Collection.f99_90_id) # 更新： ).filter(Collection.f02_14_number_category.isnot(None)).group_by(Collection.f02_14_number_category).all() # 更新： # 更新： # 总成本 # 更新： cost_result = db.query( # 更新： func.coalesce(func.sum(Collection.f05_40_cost_price), 0) + # 更新： func.coalesce(func.sum(Collection.f05_43_repair_fee), 0) + # 更新： func.coalesce(func.sum(Collection.f05_44_grading_fee), 0) # 更新： ).first() # 更新： total_cost = cost_result[0] if cost_result else 0 # 更新： # 更新： # 预期利润 # 更新： expected_profit_result = db.query( # 更新： func.coalesce(func.sum(Collection.f05_41_target_price - Collection.f05_40_cost_price), 0) # 更新： ).filter(Collection.f05_41_target_price.isnot(None), Collection.f05_41_target_price > 0).first() # 更新： expected_profit = expected_profit_result[0] if expected_profit_result else 0 # 更新： # 更新： # 已售藏品 # 更新： sold_collections = db.query(Collection).filter( # 更新： Collection.f01_04_status == 'sold', # 更新： Collection.f05_42_goal_price.isnot(None), # 更新： Collection.f05_42_goal_price > 0 # 更新： ).all() # 更新： # 更新： # 总收入和总利润（已售藏品） # 更新： total_revenue = sum(c.f05_42_goal_price or 0 for c in sold_collections) # 更新： total_profit = sum( # 更新： (c.f05_42_goal_price or 0) - (c.f05_40_cost_price or 0) - (c.f05_43_repair_fee or 0) - (c.f05_44_grading_fee or 0) # 更新： for c in sold_collections # 更新： ) # 更新： # 更新： # 盈亏统计 # 更新： profit_count = sum(1 for c in sold_collections if c.f05_42_goal_price and c.f05_40_cost_price and c.f05_42_goal_price > c.f05_40_cost_price) # 更新： loss_count = sum(1 for c in sold_collections if c.f05_42_goal_price and c.f05_40_cost_price and c.f05_42_goal_price <= c.f05_40_cost_price) # 更新： # 更新： # 目标价格总和 # 更新： total_target_result = db.query(func.coalesce(func.sum(Collection.f05_41_target_price), 0)).filter( # 更新： base_filter if base_filter is not None else True # 更新： ).first() # 更新： if base_filter is not None: # 更新： total_target_result = db.query(func.coalesce(func.sum(Collection.f05_41_target_price), 0)).filter(base_filter).first() # 更新： else: # 更新： total_target_result = db.query(func.coalesce(func.sum(Collection.f05_41_target_price), 0)).first() # 更新： total_target = total_target_result[0] if total_target_result else 0 # 更新： # 更新： return { # 更新： "totalCount": total_count, # 更新： "byCategory": [{"category": c, "count": n} for c, n in by_category], # 更新： "byStatus": [{"status": s, "count": n} for s, n in by_status], # 更新： "byGrading": [{"isGraded": g, "count": n} for g, n in by_graded], # 更新： "byPackaging": [{"packaging": p, "count": n} for p, n in by_packaging], # 更新： "byRarity": [{"rarity": r, "count": n} for r, n in by_rarity], # 更新： "byVersion": [{"version": v, "count": n} for v, n in by_version], # 更新： "byGradingCompany": [{"company": c, "count": n} for c, n in by_grading_company], # 更新： "byGradingScore": [{"score": s, "count": n} for s, n in by_grading_score], # 更新： "bySpecialMark": [{"mark": m, "count": n} for m, n in by_special_mark], # 更新： "byNumberCategory": [{"numberCategory": n, "count": c} for n, c in by_number_category], # 更新： "byProfitLoss": [ # 更新： {"type": "profit", "label": "盈利", "count": profit_count}, # 更新： {"type": "loss", "label": "亏损", "count": loss_count} # 更新： ], # 更新： "totalCost": total_cost, # 更新： "totalTarget": total_target, # 更新： "expectedProfit": expected_profit, # 更新： "totalRevenue": total_revenue, # 更新： "totalProfit": total_profit # 更新： } # 更新： # 更新： # 更新： @router.get("/{collection_id}") # 更新： def get_collection( # 更新： collection_id: str, # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """获取单个藏品详情""" # 更新： result = db.execute( # 更新： text("SELECT * FROM collections WHERE f99_90_id = :id"), # 更新： {"id": collection_id} # 更新： ).fetchone() # 更新： # 更新： if not result: # 更新： raise HTTPException(status_code=404, detail="E00033: 藏品不存在") # 更新： # 更新： collection = dict(result._mapping) # 更新： # 更新： # 非管理员只能查看自己的藏品 # 更新： if (current_user is None or current_user.role != "admin") and collection.get('f99_91_user_id') != current_user.f99_90_id: # 更新： raise HTTPException(status_code=403, detail="无权访问") # 更新： # 更新： result_dict = { # 更新： 'f99_90_id': collection.get('f99_90_id'), # 更新： 'f99_91_user_id': collection.get('f99_91_user_id'), # 更新： 'f01_01_name': collection.get('f01_01_name'), # 更新： 'f01_02_code': collection.get('f01_02_code'), # 更新： 'f01_03_category': collection.get('f01_03_category'), # 更新： 'f01_04_status': collection.get('f01_04_status'), # 更新： 'f01_05_remark': collection.get('f01_05_remark'), # 更新： 'f02_10_prefix_serial': collection.get('f02_10_prefix_serial'), # 更新： 'f02_11_version': collection.get('f02_11_version'), # 更新： 'f02_12_packaging': collection.get('f02_12_packaging'), # 更新： 'f02_13_rarity': collection.get('f02_13_rarity'), # 更新： 'f02_14_number_category': collection.get('f02_14_number_category'), # 更新： 'f03_20_is_graded': collection.get('f03_20_is_graded'), # 更新： 'f03_21_grading_company': collection.get('f03_21_grading_company'), # 更新： 'f03_22_grading_score': collection.get('f03_22_grading_score'), # 更新： 'f03_23_three_star': collection.get('f03_23_three_star'), # 更新： 'f04_30_special_mark': collection.get('f04_30_special_mark'), # 更新： 'f04_31_serial_feature': collection.get('f04_31_serial_feature'), # 更新： 'f04_32_issuer': collection.get('f04_32_issuer'), # 更新： 'f04_33_issue_year': collection.get('f04_33_issue_year'), # 更新： 'f04_34_material': collection.get('f04_34_material'), # 更新： 'f04_35_denomination': collection.get('f04_35_denomination'), # 更新： 'f04_36_issue_quantity': collection.get('f04_36_issue_quantity'), # 更新： 'f05_40_cost_price': float(collection.get('f05_40_cost_price')) if collection.get('f05_40_cost_price') else None, # 更新： 'f05_41_target_price': float(collection.get('f05_41_target_price')) if collection.get('f05_41_target_price') else None, # 更新： 'f05_42_goal_price': float(collection.get('f05_42_goal_price')) if collection.get('f05_42_goal_price') else None, # 更新： 'f05_43_repair_fee': float(collection.get('f05_43_repair_fee')) if collection.get('f05_43_repair_fee') else None, # 更新： 'f05_44_grading_fee': float(collection.get('f05_44_grading_fee')) if collection.get('f05_44_grading_fee') else None, # 更新： 'f06_50_purpose': collection.get('f06_50_purpose'), # 更新： 'f99_92_created_at': collection.get('f99_92_created_at').isoformat() if collection.get('f99_92_created_at') else None, # 更新： 'images': [] # 更新： } # 更新： # 更新： # 加载图片数据 # 更新： images = db.query(CollectionImage).filter( # 更新： CollectionImage.collection_id == collection_id # 更新： ).all() # 更新： # 更新： for img in images: # 更新： result_dict['images'].append({ # 更新： 'id': img.id, # 更新： 'filename': img.filename, # 更新： 'original_name': img.original_name, # 更新： 'path': img.path, # 更新： 'created_at': img.created_at.isoformat() if img.created_at else None # 更新： }) # 更新： # 更新： return to_camel_case(result_dict) # 更新： # 更新： # 更新： @router.post("") # 更新： def create_collection( # 更新： collection_data: CollectionCreate, # 更新： force: bool = False, # 是否强制保存（忽略重复警告） # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """创建藏品 - 支持冠字号查重""" # 更新： from app.core.logging_config import logger # 更新： # 更新： # 自动生成编码 # 更新： final_code = collection_data.f01_02_code or generate_code( # 更新： collection_data.f02_11_version or '2024 龙', # 更新： current_user.f99_90_id, # 更新： db # 更新： ) # 更新： # 更新： # 编号查重（如果提供了编号且不是强制保存） # 更新： if not force and final_code: # 更新： existing_code = db.query(Collection).filter( # 更新： Collection.f01_02_code == final_code, # 更新： Collection.f99_91_user_id == current_user.f99_90_id # 更新： ).first() # 更新： # 更新： if existing_code: # 更新： logger.warning(f"发现重复编号：{final_code}, 已存在藏品 ID: {existing_code.f99_90_id}") # 更新： return { # 更新： "error": { # 更新： "code": "DUPLICATE_CODE", # 更新： "message": f"藏品编号 {final_code} 已存在，请使用其他编号" # 更新： } # 更新： } # 更新： # 更新： # 冠字号查重（如果提供了冠字号且不是强制保存） # 更新： if not force and collection_data.f02_10_prefix_serial: # 更新： # 查询当前用户是否有相同冠字号的藏品 # 更新： existing = db.query(Collection).filter( # 更新： Collection.f02_10_prefix_serial == collection_data.f02_10_prefix_serial, # 更新： Collection.f99_91_user_id == current_user.f99_90_id # 更新： ).first() # 更新： # 更新： if existing: # 更新： logger.warning(f"发现重复冠字号：{collection_data.f02_10_prefix_serial}, 已存在藏品 ID: {existing.f99_90_id}") # 更新： # 返回警告信息，让前端询问用户是否继续 # 更新： return { # 更新： "warning": { # 更新： "code": "DUPLICATE_SERIAL", # 更新： "message": f"发现重复冠字号：{collection_data.f02_10_prefix_serial}", # 更新： "existing_collection": { # 更新： "id": existing.f99_90_id, # 更新： "name": existing.f01_01_name, # 更新： "code": existing.f01_02_code, # 更新： "prefix_serial": existing.f02_10_prefix_serial # 更新： } # 更新： }, # 更新： "data": { # 更新： "ask_continue": True # 更新： } # 更新： } # 更新： # 更新： # 自动分类：如果未提供号码分类，则根据冠字号自动分类 # 更新： if not collection_data.f02_14_number_category and collection_data.f02_10_prefix_serial: # 更新： from app.utils.number_category import get_number_category # 更新： collection_data.f02_14_number_category = get_number_category(collection_data.f02_10_prefix_serial) # 更新： # 更新： collection = Collection( # 更新： f99_91_user_id=current_user.f99_90_id, # 更新： f01_01_name=collection_data.f01_01_name, # 更新： f01_02_code=final_code, # 更新： f01_03_category=collection_data.f01_03_category, # 更新： f01_04_status=collection_data.f01_04_status or "in_collection", # 更新： f01_05_remark=collection_data.f01_05_remark, # 更新： f02_10_prefix_serial=collection_data.f02_10_prefix_serial, # 更新： f02_11_version=collection_data.f02_11_version, # 更新： f02_12_packaging=collection_data.f02_12_packaging, # 更新： f02_13_rarity=collection_data.f02_13_rarity, # 更新： f02_14_number_category=collection_data.f02_14_number_category, # 更新： f03_20_is_graded=collection_data.f03_20_is_graded or False, # 更新： f03_21_grading_company=collection_data.f03_21_grading_company, # 更新： f03_22_grading_score=collection_data.f03_22_grading_score, # 更新： f03_23_three_star=collection_data.f03_23_three_star or False, # 更新： f04_30_special_mark=collection_data.f04_30_special_mark, # 更新： f04_31_serial_feature=collection_data.f04_31_serial_feature, # 更新： f04_32_issuer=collection_data.f04_32_issuer, # 更新： f04_33_issue_year=collection_data.f04_33_issue_year, # 更新： f04_34_material=collection_data.f04_34_material, # 更新： f04_35_denomination=collection_data.f04_35_denomination, # 更新： f04_36_issue_quantity=collection_data.f04_36_issue_quantity, # 更新： f05_40_cost_price=collection_data.f05_40_cost_price, # 更新： f05_41_target_price=collection_data.f05_41_target_price, # 更新： f05_42_goal_price=collection_data.f05_42_goal_price, # 更新： f05_43_repair_fee=collection_data.f05_43_repair_fee, # 更新： f05_44_grading_fee=collection_data.f05_44_grading_fee, # 更新： f06_50_purpose=collection_data.f06_50_purpose # 更新： ) # 更新： # 更新： db.add(collection) # 更新： db.commit() # 更新： db.refresh(collection) # 更新： # 更新： return { # 更新： 'f99_90_id': collection.f99_90_id, # 更新： 'f99_91_user_id': collection.f99_91_user_id, # 更新： 'f01_01_name': collection.f01_01_name, # 更新： 'f01_02_code': collection.f01_02_code, # 更新： 'f01_03_category': collection.f01_03_category, # 更新： 'f01_04_status': collection.f01_04_status, # 更新： 'f01_05_remark': collection.f01_05_remark, # 更新： 'f99_92_created_at': collection.f99_92_created_at.isoformat() if collection.f99_92_created_at else None, # 更新： 'message': '创建成功' # 更新： } # 更新： # 更新： # 更新： @router.put("/{collection_id}") # 更新： def update_collection( # 更新： collection_id: str, # 更新： collection_data: CollectionUpdate, # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """更新藏品""" # 更新： collection = db.query(Collection).filter( # 更新： Collection.f99_90_id == collection_id, # 更新： Collection.f99_91_user_id == current_user.f99_90_id # 更新： ).first() # 更新： # 更新： if not collection: # 更新： raise HTTPException(status_code=404, detail="E00033: 藏品不存在") # 更新： # 更新： # 更新字段 - 使用 model_fields_set 检查哪些字段被设置 # 更新： for field_name in collection_data.model_fields_set: # 更新： value = getattr(collection_data, field_name) # 更新： if value is not None: # 更新： setattr(collection, field_name, value) # 更新： # 更新： db.commit() # 更新： db.refresh(collection) # 更新： # 更新： return { # 更新： "f99_90_id": collection.f99_90_id, # 更新： "message": "更新成功" # 更新： } # 更新： # 更新： # 更新： @router.delete("/{collection_id}") # 更新： def delete_collection( # 更新： collection_id: str, # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """删除藏品""" # 更新： # 验证权限并检查是否存在 # 更新： collection = db.query(Collection).filter( # 更新： Collection.f99_90_id == collection_id, # 更新： Collection.f99_91_user_id == current_user.f99_90_id # 更新： ).first() # 更新： # 更新： if not collection: # 更新： raise HTTPException(status_code=404, detail="E00033: 藏品不存在") # 更新： # 更新： # 使用原生 SQL 删除（避免 ORM 级联查询字段不匹配问题） # 更新： from sqlalchemy import text # 更新： # 1. 删除关联的 operations（f99_91_user_id 关联到 collections.f99_90_id） # 更新： db.execute(text("DELETE FROM operations WHERE f99_91_user_id = :id"), {"id": collection_id}) # 更新： # 2. 删除关联的图片 # 更新： db.execute(text("DELETE FROM collection_images WHERE collection_id = :id"), {"id": collection_id}) # 更新： # 3. 删除藏品本身 # 更新： db.execute(text("DELETE FROM collections WHERE f99_90_id = :id"), {"id": collection_id}) # 更新： db.commit() # 更新： # 更新： return {"message": "删除成功"} # 更新： # 更新： # 更新： @router.post("/upload-image") # 更新： async def upload_image( # 更新： collection_id: str = None, # 更新： file: UploadFile = File(...), # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """上传藏品图片 - 文件名格式：用户名 - 藏品编号 - 冠字号""" # 更新： try: # 更新： # 验证藏品是否存在 # 更新： collection = db.query(Collection).filter( # 更新： Collection.f99_90_id == collection_id # 更新： ).first() # 更新： # 更新： if not collection: # 更新： raise HTTPException(status_code=404, detail="E00033: 藏品不存在") # 更新： # 更新： # 获取用户信息（用于文件名） # 更新： owner = db.query(User).filter(User.f99_90_id == collection.f99_91_user_id).first() # 更新： username = owner.f01_01_name if owner else "unknown" # 更新： # 更新： # 获取藏品信息（用于文件名） # 更新： code = collection.f01_02_code or "0000" # 更新： prefix_serial = collection.f02_10_prefix_serial or "" # 更新： # 更新： # 检查文件类型 # 更新： if not file.content_type.startswith('image/'): # 更新： raise HTTPException(status_code=400, detail="E00038: 只能上传图片文件") # 更新： # 更新： # 检查文件大小（限制 10MB） # 更新： file_size = 0 # 更新： content = await file.read() # 更新： file_size = len(content) # 更新： if file_size > 10 * 1024 * 1024: # 10MB # 更新： raise HTTPException(status_code=400, detail=f"E00039: 图片大小不能超过 10MB（当前{file_size // 1024 // 1024}MB）") # 更新： # 更新： # 生成OSS存储路径 # 更新： user_id = collection.f99_91_user_id # 更新： file_extension = file.filename.split('.')[-1] if '.' in file.filename else 'jpg' # 更新： # 更新： # 清理特殊字符 # 更新： clean_username = re.sub(r'[^\w\u4e00-\u9fff\-]', '', username) # 更新： clean_serial = re.sub(r'[^\w\u4e00-\u9fff\-]', '', prefix_serial) # 更新： # 更新： # 文件名格式：用户名-藏品编号-冠字号.jpg # 更新： if clean_serial: # 更新： filename = f"{clean_username}-{code}-{clean_serial}.{file_extension}" # 更新： else: # 更新： filename = f"{clean_username}-{code}.{file_extension}" # 更新： # 更新： # 生成OSS key # 更新： oss_key, unique_name = get_oss_path("collections", user_id=user_id, filename=filename) # 更新： # 更新： # 上传到OSS # 更新： image_url = upload_to_oss(content, oss_key) # 更新： # 更新： # 创建图片记录（保存OSS URL） # 更新： image = CollectionImage( # 更新： id=str(uuid.uuid4()), # 更新： collection_id=collection_id, # 更新： filename=unique_name, # 更新： original_name=file.filename, # 更新： path=image_url # 保存OSS URL # 更新： ) # 更新： # 更新： db.add(image) # 更新： db.commit() # 更新： db.refresh(image) # 更新： # 更新： logger.info(f"图片上传成功：{image_url}, collection_id={collection_id}") # 更新： # 更新： return { # 更新： "message": "上传成功", # 更新： "image_id": image.id, # 更新： "filename": unique_name, # 更新： "url": image_url # 更新： } # 更新： except HTTPException: # 更新： raise # 更新： except Exception as e: # 更新： logger.error(f"图片上传失败：{str(e)}") # 更新： raise HTTPException(status_code=500, detail="上传失败") # 更新： # 更新： # 更新： @router.delete("/images/{image_id}") # 更新： async def delete_image( # 更新： image_id: str, # 更新： current_user: User = Depends(get_current_user), # 更新： db: Session = Depends(get_db) # 更新： ): # 更新： """删除藏品图片""" # 更新： try: # 更新： # 查找图片记录 # 更新： image = db.query(CollectionImage).filter( # 更新： CollectionImage.id == image_id # 更新： ).first() # 更新： # 更新： if not image: # 更新： raise HTTPException(status_code=404, detail="E00033: 图片不存在") # 更新： # 更新： # 检查权限 # 更新： collection = db.query(Collection).filter( # 更新： Collection.f99_90_id == image.collection_id # 更新： ).first() # 更新： # 更新： if collection and (current_user is None or current_user.role != "admin") and collection.f99_91_user_id != current_user.f99_90_id: # 更新： raise HTTPException(status_code=403, detail="E00014: 无权删除此图片") # 更新： # 更新： # 删除OSS文件（如果path是OSS URL） # 更新： if image.path and image.path.startswith("https://"): # 更新： # 从OSS URL提取key # 更新： try: # 更新： oss_key = image.path.replace("https://jiachenlong-oss.oss-cn-hangzhou.aliyuncs.com/", "") # 更新： delete_from_oss(oss_key) # 更新： except Exception as e: # 更新： logger.warning(f"OSS文件删除失败: {e}") # 更新： elif image.path and os.path.exists(image.path): # 更新： # 兼容旧的本地上传 # 更新： os.remove(image.path) # 更新： # 更新： # 删除数据库记录 # 更新： db.delete(image) # 更新： db.commit() # 更新： # 更新： return {"message": "删除成功"} # 更新： except HTTPException: # 更新： raise # 更新： except Exception as e: # 更新： logger.error(f"图片删除失败：{str(e)}") # 更新： raise HTTPException(status_code=500, detail="删除失败") # 更新：