feat(valuation): 新增非遗资产估值评估功能模块
实现估值评估的完整功能，包括： 1. 创建估值评估模型及相关字段 2. 实现用户端估值评估的创建、查询和统计功能 3. 实现管理端估值评估的审核、查询和管理功能 4. 添加相关路由和控制器逻辑
This commit is contained in:
parent
bd5b2e5cbb
commit
cf95553adc
@ -4,6 +4,7 @@ from app.core.dependency import DependPermission
|
||||
|
||||
from .apis import apis_router
|
||||
from .app_users import app_users_router
|
||||
from .app_valuations import app_valuations_router
|
||||
from .auditlog import auditlog_router
|
||||
from .base import base_router
|
||||
from .depts import depts_router
|
||||
@ -15,11 +16,13 @@ from .policy.policy import router as policy_router
|
||||
from .roles import roles_router
|
||||
from .third_party_api import third_party_api_router
|
||||
from .users import users_router
|
||||
from .valuations import router as valuations_router
|
||||
|
||||
v1_router = APIRouter()
|
||||
|
||||
v1_router.include_router(base_router, prefix="/base")
|
||||
v1_router.include_router(app_users_router, prefix="/app-user") # AppUser路由，无需权限依赖
|
||||
v1_router.include_router(app_valuations_router, prefix="/app-valuations") # 用户端估值评估路由，需要认证
|
||||
v1_router.include_router(users_router, prefix="/user", dependencies=[DependPermission])
|
||||
v1_router.include_router(roles_router, prefix="/role", dependencies=[DependPermission])
|
||||
v1_router.include_router(menus_router, prefix="/menu", dependencies=[DependPermission])
|
||||
@ -31,3 +34,4 @@ v1_router.include_router(index_router, prefix="/index", dependencies=[DependPerm
|
||||
v1_router.include_router(industry_router, prefix="/industry", dependencies=[DependPermission])
|
||||
v1_router.include_router(policy_router, prefix="/policy", dependencies=[DependPermission])
|
||||
v1_router.include_router(third_party_api_router, prefix="/third_party_api", dependencies=[DependPermission])
|
||||
v1_router.include_router(valuations_router, prefix="/valuations", dependencies=[DependPermission])
|
||||
|
||||
3
app/api/v1/app_valuations/__init__.py
Normal file
3
app/api/v1/app_valuations/__init__.py
Normal file
@ -0,0 +1,3 @@
|
||||
from .app_valuations import app_valuations_router
|
||||
|
||||
__all__ = ["app_valuations_router"]
|
||||
113
app/api/v1/app_valuations/app_valuations.py
Normal file
113
app/api/v1/app_valuations/app_valuations.py
Normal file
@ -0,0 +1,113 @@
|
||||
from fastapi import APIRouter, Depends, HTTPException, status
|
||||
from typing import Optional
|
||||
|
||||
from app.controllers.user_valuation import user_valuation_controller
|
||||
from app.schemas.valuation import (
|
||||
UserValuationCreate,
|
||||
UserValuationQuery,
|
||||
UserValuationList,
|
||||
UserValuationOut,
|
||||
UserValuationDetail
|
||||
)
|
||||
from app.schemas.base import Success, SuccessExtra
|
||||
from app.utils.app_user_jwt import get_current_app_user_id
|
||||
|
||||
app_valuations_router = APIRouter(tags=["用户端估值评估"])
|
||||
|
||||
|
||||
@app_valuations_router.post("/", summary="创建估值评估")
|
||||
async def create_valuation(
|
||||
data: UserValuationCreate,
|
||||
user_id: int = Depends(get_current_app_user_id)
|
||||
):
|
||||
"""
|
||||
用户创建估值评估申请
|
||||
"""
|
||||
try:
|
||||
result = await user_valuation_controller.create_valuation(
|
||||
user_id=user_id,
|
||||
data=data
|
||||
)
|
||||
return Success(data=result, msg="估值评估申请提交成功")
|
||||
except Exception as e:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
|
||||
detail=f"创建估值评估失败: {str(e)}"
|
||||
)
|
||||
|
||||
|
||||
@app_valuations_router.get("/", summary="获取我的估值评估列表")
|
||||
async def get_my_valuations(
|
||||
query: UserValuationQuery = Depends(),
|
||||
user_id: int = Depends(get_current_app_user_id)
|
||||
):
|
||||
"""
|
||||
获取当前用户的估值评估列表
|
||||
"""
|
||||
try:
|
||||
result = await user_valuation_controller.get_user_valuations(
|
||||
user_id=user_id,
|
||||
query=query
|
||||
)
|
||||
return SuccessExtra(
|
||||
data=result.items,
|
||||
total=result.total,
|
||||
page=result.page,
|
||||
size=result.size,
|
||||
pages=result.pages,
|
||||
msg="获取估值评估列表成功"
|
||||
)
|
||||
except Exception as e:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
|
||||
detail=f"获取估值评估列表失败: {str(e)}"
|
||||
)
|
||||
|
||||
|
||||
@app_valuations_router.get("/{valuation_id}", summary="获取估值评估详情")
|
||||
async def get_valuation_detail(
|
||||
valuation_id: int,
|
||||
user_id: int = Depends(get_current_app_user_id)
|
||||
):
|
||||
"""
|
||||
获取指定估值评估的详细信息
|
||||
"""
|
||||
try:
|
||||
result = await user_valuation_controller.get_user_valuation_detail(
|
||||
user_id=user_id,
|
||||
valuation_id=valuation_id
|
||||
)
|
||||
|
||||
if not result:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_404_NOT_FOUND,
|
||||
detail="估值评估记录不存在"
|
||||
)
|
||||
|
||||
return Success(data=result, msg="获取估值评估详情成功")
|
||||
except HTTPException:
|
||||
raise
|
||||
except Exception as e:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
|
||||
detail=f"获取估值评估详情失败: {str(e)}"
|
||||
)
|
||||
|
||||
|
||||
@app_valuations_router.get("/statistics/overview", summary="获取我的估值评估统计")
|
||||
async def get_my_valuation_statistics(
|
||||
user_id: int = Depends(get_current_app_user_id)
|
||||
):
|
||||
"""
|
||||
获取当前用户的估值评估统计信息
|
||||
"""
|
||||
try:
|
||||
result = await user_valuation_controller.get_user_valuation_statistics(
|
||||
user_id=user_id
|
||||
)
|
||||
return Success(data=result, msg="获取统计信息成功")
|
||||
except Exception as e:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
|
||||
detail=f"获取统计信息失败: {str(e)}"
|
||||
)
|
||||
3
app/api/v1/valuations/__init__.py
Normal file
3
app/api/v1/valuations/__init__.py
Normal file
@ -0,0 +1,3 @@
|
||||
from .valuations import valuations_router as router
|
||||
|
||||
__all__ = ["router"]
|
||||
178
app/api/v1/valuations/valuations.py
Normal file
178
app/api/v1/valuations/valuations.py
Normal file
@ -0,0 +1,178 @@
|
||||
from fastapi import APIRouter, HTTPException, Query, Depends
|
||||
from typing import Optional
|
||||
|
||||
from app.controllers.valuation import valuation_controller
|
||||
from app.schemas.valuation import (
|
||||
ValuationAssessmentCreate,
|
||||
ValuationAssessmentUpdate,
|
||||
ValuationAssessmentOut,
|
||||
ValuationAssessmentList,
|
||||
ValuationAssessmentQuery,
|
||||
ValuationApprovalRequest,
|
||||
ValuationAdminNotesUpdate
|
||||
)
|
||||
from app.schemas.base import Success, SuccessExtra
|
||||
from app.core.ctx import CTX_USER_ID
|
||||
|
||||
valuations_router = APIRouter(tags=["估值评估"])
|
||||
|
||||
|
||||
@valuations_router.post("/", summary="创建估值评估")
|
||||
async def create_valuation(data: ValuationAssessmentCreate):
|
||||
"""创建新的估值评估记录"""
|
||||
try:
|
||||
result = await valuation_controller.create(data)
|
||||
return Success(data=result, msg="创建成功")
|
||||
except Exception as e:
|
||||
raise HTTPException(status_code=400, detail=f"创建失败: {str(e)}")
|
||||
|
||||
|
||||
@valuations_router.get("/{valuation_id}", summary="获取估值评估详情")
|
||||
async def get_valuation(valuation_id: int):
|
||||
"""根据ID获取估值评估详情"""
|
||||
result = await valuation_controller.get_by_id(valuation_id)
|
||||
if not result:
|
||||
raise HTTPException(status_code=404, detail="估值评估记录不存在")
|
||||
return Success(data=result, msg="获取成功")
|
||||
|
||||
|
||||
@valuations_router.put("/{valuation_id}", summary="更新估值评估")
|
||||
async def update_valuation(valuation_id: int, data: ValuationAssessmentUpdate):
|
||||
"""更新估值评估记录"""
|
||||
result = await valuation_controller.update(valuation_id, data)
|
||||
if not result:
|
||||
raise HTTPException(status_code=404, detail="估值评估记录不存在")
|
||||
return Success(data=result, msg="更新成功")
|
||||
|
||||
|
||||
@valuations_router.delete("/{valuation_id}", summary="删除估值评估")
|
||||
async def delete_valuation(valuation_id: int):
|
||||
"""软删除估值评估记录"""
|
||||
result = await valuation_controller.delete(valuation_id)
|
||||
if not result:
|
||||
raise HTTPException(status_code=404, detail="估值评估记录不存在")
|
||||
return Success(data={"deleted": True}, msg="删除成功")
|
||||
|
||||
|
||||
@valuations_router.get("/", summary="获取估值评估列表")
|
||||
async def get_valuations(
|
||||
asset_name: Optional[str] = Query(None, description="资产名称"),
|
||||
institution: Optional[str] = Query(None, description="所属机构"),
|
||||
industry: Optional[str] = Query(None, description="所属行业"),
|
||||
heritage_level: Optional[str] = Query(None, description="非遗等级"),
|
||||
status: Optional[str] = Query(None, description="评估状态"),
|
||||
is_active: Optional[bool] = Query(None, description="是否激活"),
|
||||
page: int = Query(1, ge=1, description="页码"),
|
||||
size: int = Query(10, ge=1, le=100, description="每页数量")
|
||||
):
|
||||
"""获取估值评估列表，支持筛选和分页"""
|
||||
query = ValuationAssessmentQuery(
|
||||
asset_name=asset_name,
|
||||
institution=institution,
|
||||
industry=industry,
|
||||
heritage_level=heritage_level,
|
||||
status=status,
|
||||
is_active=is_active,
|
||||
page=page,
|
||||
size=size
|
||||
)
|
||||
result = await valuation_controller.get_list(query)
|
||||
return SuccessExtra(
|
||||
data=result.items,
|
||||
total=result.total,
|
||||
page=result.page,
|
||||
size=result.size,
|
||||
pages=result.pages,
|
||||
msg="获取成功"
|
||||
)
|
||||
|
||||
|
||||
@valuations_router.get("/search/keyword", summary="搜索估值评估")
|
||||
async def search_valuations(
|
||||
keyword: str = Query(..., description="搜索关键词"),
|
||||
page: int = Query(1, ge=1, description="页码"),
|
||||
size: int = Query(10, ge=1, le=100, description="每页数量")
|
||||
):
|
||||
"""根据关键词搜索估值评估记录"""
|
||||
result = await valuation_controller.search(keyword, page, size)
|
||||
return SuccessExtra(
|
||||
data=result.items,
|
||||
total=result.total,
|
||||
page=result.page,
|
||||
size=result.size,
|
||||
pages=result.pages,
|
||||
msg="搜索成功"
|
||||
)
|
||||
|
||||
|
||||
@valuations_router.get("/statistics/overview", summary="获取统计信息")
|
||||
async def get_statistics():
|
||||
"""获取估值评估统计信息"""
|
||||
result = await valuation_controller.get_statistics()
|
||||
return Success(data=result, msg="获取统计信息成功")
|
||||
|
||||
|
||||
# 批量操作接口
|
||||
@valuations_router.post("/batch/delete", summary="批量删除估值评估")
|
||||
async def batch_delete_valuations(valuation_ids: list[int]):
|
||||
"""批量软删除估值评估记录"""
|
||||
success_count = 0
|
||||
failed_ids = []
|
||||
|
||||
for valuation_id in valuation_ids:
|
||||
result = await valuation_controller.delete(valuation_id)
|
||||
if result:
|
||||
success_count += 1
|
||||
else:
|
||||
failed_ids.append(valuation_id)
|
||||
|
||||
return Success(
|
||||
data={
|
||||
"success_count": success_count,
|
||||
"failed_ids": failed_ids,
|
||||
"total_count": len(valuation_ids)
|
||||
},
|
||||
msg=f"批量删除完成，成功删除 {success_count} 条记录"
|
||||
)
|
||||
|
||||
|
||||
# 导出接口
|
||||
@valuations_router.get("/export/excel", summary="导出估值评估数据")
|
||||
async def export_valuations(
|
||||
asset_name: Optional[str] = Query(None, description="资产名称"),
|
||||
institution: Optional[str] = Query(None, description="所属机构"),
|
||||
industry: Optional[str] = Query(None, description="所属行业"),
|
||||
heritage_level: Optional[str] = Query(None, description="非遗等级")
|
||||
):
|
||||
"""导出估值评估数据为Excel文件"""
|
||||
# 这里可以实现Excel导出逻辑
|
||||
# 暂时返回提示信息
|
||||
return Success(data={"message": "导出功能待实现"}, msg="导出请求已接收")
|
||||
|
||||
|
||||
# 审核管理接口
|
||||
@valuations_router.post("/{valuation_id}/approve", summary="审核通过估值评估")
|
||||
async def approve_valuation(valuation_id: int, data: ValuationApprovalRequest):
|
||||
"""审核通过估值评估"""
|
||||
result = await valuation_controller.approve_valuation(valuation_id, data.admin_notes)
|
||||
if not result:
|
||||
raise HTTPException(status_code=404, detail="估值评估记录不存在")
|
||||
return Success(data=result, msg="审核通过成功")
|
||||
|
||||
|
||||
@valuations_router.post("/{valuation_id}/reject", summary="审核拒绝估值评估")
|
||||
async def reject_valuation(valuation_id: int, data: ValuationApprovalRequest):
|
||||
"""审核拒绝估值评估"""
|
||||
result = await valuation_controller.reject_valuation(valuation_id, data.admin_notes)
|
||||
if not result:
|
||||
raise HTTPException(status_code=404, detail="估值评估记录不存在")
|
||||
return Success(data=result, msg="审核拒绝成功")
|
||||
|
||||
|
||||
@valuations_router.put("/{valuation_id}/admin-notes", summary="更新管理员备注")
|
||||
async def update_admin_notes(valuation_id: int, data: ValuationAdminNotesUpdate):
|
||||
"""更新管理员备注"""
|
||||
result = await valuation_controller.update_admin_notes(valuation_id, data.admin_notes)
|
||||
if not result:
|
||||
raise HTTPException(status_code=404, detail="估值评估记录不存在")
|
||||
return Success(data=result, msg="管理员备注更新成功")
|
||||
138
app/controllers/user_valuation.py
Normal file
138
app/controllers/user_valuation.py
Normal file
@ -0,0 +1,138 @@
|
||||
from typing import Optional
|
||||
from tortoise.expressions import Q
|
||||
from tortoise.queryset import QuerySet
|
||||
|
||||
from app.models.valuation import ValuationAssessment
|
||||
from app.schemas.valuation import (
|
||||
UserValuationCreate,
|
||||
UserValuationQuery,
|
||||
UserValuationList,
|
||||
UserValuationOut,
|
||||
UserValuationDetail
|
||||
)
|
||||
|
||||
|
||||
class UserValuationController:
|
||||
"""用户端估值评估控制器"""
|
||||
|
||||
def __init__(self):
|
||||
self.model = ValuationAssessment
|
||||
|
||||
async def create_valuation(self, user_id: int, data: UserValuationCreate) -> UserValuationDetail:
|
||||
"""用户创建估值评估"""
|
||||
valuation_data = data.model_dump()
|
||||
valuation_data['user_id'] = user_id
|
||||
valuation_data['status'] = 'pending' # 默认状态为待审核
|
||||
|
||||
valuation = await self.model.create(**valuation_data)
|
||||
return await self._to_user_detail(valuation)
|
||||
|
||||
async def get_user_valuations(self, user_id: int, query: UserValuationQuery) -> UserValuationList:
|
||||
"""获取用户的估值评估列表"""
|
||||
queryset = self.model.filter(user_id=user_id, is_active=True)
|
||||
|
||||
# 构建查询条件
|
||||
if query.status:
|
||||
queryset = queryset.filter(status=query.status)
|
||||
if query.asset_name:
|
||||
queryset = queryset.filter(asset_name__icontains=query.asset_name)
|
||||
|
||||
# 计算总数
|
||||
total = await queryset.count()
|
||||
|
||||
# 分页查询
|
||||
offset = (query.page - 1) * query.size
|
||||
items = await queryset.offset(offset).limit(query.size).order_by('-created_at')
|
||||
|
||||
# 转换为输出模型
|
||||
user_valuations = [await self._to_user_out(item) for item in items]
|
||||
|
||||
pages = (total + query.size - 1) // query.size
|
||||
|
||||
return UserValuationList(
|
||||
items=user_valuations,
|
||||
total=total,
|
||||
page=query.page,
|
||||
size=query.size,
|
||||
pages=pages
|
||||
)
|
||||
|
||||
async def get_user_valuation_detail(self, user_id: int, valuation_id: int) -> Optional[UserValuationDetail]:
|
||||
"""获取用户的估值评估详情"""
|
||||
valuation = await self.model.filter(
|
||||
id=valuation_id,
|
||||
user_id=user_id,
|
||||
is_active=True
|
||||
).first()
|
||||
|
||||
if not valuation:
|
||||
return None
|
||||
|
||||
return await self._to_user_detail(valuation)
|
||||
|
||||
async def get_user_valuation_statistics(self, user_id: int) -> dict:
|
||||
"""获取用户的估值评估统计信息"""
|
||||
total = await self.model.filter(user_id=user_id, is_active=True).count()
|
||||
pending = await self.model.filter(user_id=user_id, status='pending', is_active=True).count()
|
||||
approved = await self.model.filter(user_id=user_id, status='approved', is_active=True).count()
|
||||
rejected = await self.model.filter(user_id=user_id, status='rejected', is_active=True).count()
|
||||
|
||||
return {
|
||||
'total': total,
|
||||
'pending': pending,
|
||||
'approved': approved,
|
||||
'rejected': rejected
|
||||
}
|
||||
|
||||
async def _to_user_out(self, valuation: ValuationAssessment) -> UserValuationOut:
|
||||
"""转换为用户端输出模型"""
|
||||
return UserValuationOut(
|
||||
id=valuation.id,
|
||||
asset_name=valuation.asset_name,
|
||||
institution=valuation.institution,
|
||||
industry=valuation.industry,
|
||||
status=valuation.status,
|
||||
admin_notes=valuation.admin_notes,
|
||||
created_at=valuation.created_at,
|
||||
updated_at=valuation.updated_at
|
||||
)
|
||||
|
||||
async def _to_user_detail(self, valuation: ValuationAssessment) -> UserValuationDetail:
|
||||
"""转换为用户端详细模型"""
|
||||
return UserValuationDetail(
|
||||
id=valuation.id,
|
||||
asset_name=valuation.asset_name,
|
||||
institution=valuation.institution,
|
||||
industry=valuation.industry,
|
||||
annual_revenue=valuation.annual_revenue,
|
||||
rd_investment=valuation.rd_investment,
|
||||
three_year_income=valuation.three_year_income,
|
||||
funding_status=valuation.funding_status,
|
||||
inheritor_level=valuation.inheritor_level,
|
||||
inheritor_age_count=valuation.inheritor_age_count,
|
||||
inheritor_certificates=valuation.inheritor_certificates,
|
||||
heritage_level=valuation.heritage_level,
|
||||
patent_application_no=valuation.patent_application_no,
|
||||
historical_evidence=valuation.historical_evidence,
|
||||
patent_certificates=valuation.patent_certificates,
|
||||
pattern_images=valuation.pattern_images,
|
||||
application_maturity=valuation.application_maturity,
|
||||
application_coverage=valuation.application_coverage,
|
||||
cooperation_depth=valuation.cooperation_depth,
|
||||
offline_activities=valuation.offline_activities,
|
||||
online_accounts=valuation.online_accounts,
|
||||
sales_volume=valuation.sales_volume,
|
||||
link_views=valuation.link_views,
|
||||
circulation=valuation.circulation,
|
||||
last_market_activity=valuation.last_market_activity,
|
||||
monthly_transaction=valuation.monthly_transaction,
|
||||
price_fluctuation=valuation.price_fluctuation,
|
||||
status=valuation.status,
|
||||
admin_notes=valuation.admin_notes,
|
||||
created_at=valuation.created_at,
|
||||
updated_at=valuation.updated_at
|
||||
)
|
||||
|
||||
|
||||
# 创建控制器实例
|
||||
user_valuation_controller = UserValuationController()
|
||||
192
app/controllers/valuation.py
Normal file
192
app/controllers/valuation.py
Normal file
@ -0,0 +1,192 @@
|
||||
from typing import List, Optional
|
||||
from tortoise.expressions import Q
|
||||
from tortoise.queryset import QuerySet
|
||||
|
||||
from app.models.valuation import ValuationAssessment
|
||||
from app.schemas.valuation import (
|
||||
ValuationAssessmentCreate,
|
||||
ValuationAssessmentUpdate,
|
||||
ValuationAssessmentQuery,
|
||||
ValuationAssessmentOut,
|
||||
ValuationAssessmentList
|
||||
)
|
||||
|
||||
|
||||
class ValuationController:
|
||||
"""估值评估控制器"""
|
||||
|
||||
model = ValuationAssessment
|
||||
|
||||
async def create(self, data: ValuationAssessmentCreate) -> ValuationAssessmentOut:
|
||||
"""创建估值评估"""
|
||||
valuation = await self.model.create(**data.model_dump())
|
||||
return ValuationAssessmentOut.model_validate(valuation)
|
||||
|
||||
async def get_by_id(self, valuation_id: int) -> Optional[ValuationAssessmentOut]:
|
||||
"""根据ID获取估值评估"""
|
||||
valuation = await self.model.filter(id=valuation_id, is_active=True).first()
|
||||
if valuation:
|
||||
return ValuationAssessmentOut.model_validate(valuation)
|
||||
return None
|
||||
|
||||
async def update(self, valuation_id: int, data: ValuationAssessmentUpdate) -> Optional[ValuationAssessmentOut]:
|
||||
"""更新估值评估"""
|
||||
valuation = await self.model.filter(id=valuation_id, is_active=True).first()
|
||||
if not valuation:
|
||||
return None
|
||||
|
||||
update_data = data.model_dump(exclude_unset=True)
|
||||
if update_data:
|
||||
await valuation.update_from_dict(update_data)
|
||||
await valuation.save()
|
||||
|
||||
return ValuationAssessmentOut.model_validate(valuation)
|
||||
|
||||
async def delete(self, valuation_id: int) -> bool:
|
||||
"""软删除估值评估"""
|
||||
valuation = await self.model.filter(id=valuation_id, is_active=True).first()
|
||||
if not valuation:
|
||||
return False
|
||||
|
||||
valuation.is_active = False
|
||||
await valuation.save()
|
||||
return True
|
||||
|
||||
async def get_list(self, query: ValuationAssessmentQuery) -> ValuationAssessmentList:
|
||||
"""获取估值评估列表"""
|
||||
queryset = self._build_query(query)
|
||||
|
||||
# 计算总数
|
||||
total = await queryset.count()
|
||||
|
||||
# 分页查询
|
||||
offset = (query.page - 1) * query.size
|
||||
valuations = await queryset.offset(offset).limit(query.size).order_by('-created_at')
|
||||
|
||||
# 转换为输出模型
|
||||
items = [ValuationAssessmentOut.model_validate(v) for v in valuations]
|
||||
|
||||
# 计算总页数
|
||||
pages = (total + query.size - 1) // query.size
|
||||
|
||||
return ValuationAssessmentList(
|
||||
items=items,
|
||||
total=total,
|
||||
page=query.page,
|
||||
size=query.size,
|
||||
pages=pages
|
||||
)
|
||||
|
||||
def _build_query(self, query: ValuationAssessmentQuery) -> QuerySet:
|
||||
"""构建查询条件"""
|
||||
queryset = self.model.filter(is_active=True)
|
||||
|
||||
if query.asset_name:
|
||||
queryset = queryset.filter(asset_name__icontains=query.asset_name)
|
||||
|
||||
if query.institution:
|
||||
queryset = queryset.filter(institution__icontains=query.institution)
|
||||
|
||||
if query.industry:
|
||||
queryset = queryset.filter(industry__icontains=query.industry)
|
||||
|
||||
if query.heritage_level:
|
||||
queryset = queryset.filter(heritage_level__icontains=query.heritage_level)
|
||||
|
||||
if query.is_active is not None:
|
||||
queryset = queryset.filter(is_active=query.is_active)
|
||||
|
||||
# 添加状态筛选
|
||||
if hasattr(query, 'status') and query.status:
|
||||
queryset = queryset.filter(status=query.status)
|
||||
|
||||
return queryset
|
||||
|
||||
async def get_statistics(self) -> dict:
|
||||
"""获取统计信息"""
|
||||
total_count = await self.model.filter(is_active=True).count()
|
||||
|
||||
# 按行业统计
|
||||
industry_stats = await self.model.filter(is_active=True).group_by('industry').values('industry', count='COUNT(*)')
|
||||
|
||||
# 按非遗等级统计
|
||||
heritage_level_stats = await self.model.filter(
|
||||
is_active=True,
|
||||
heritage_level__isnull=False
|
||||
).group_by('heritage_level').values('heritage_level', count='COUNT(*)')
|
||||
|
||||
return {
|
||||
'total_count': total_count,
|
||||
'industry_distribution': industry_stats,
|
||||
'heritage_level_distribution': heritage_level_stats
|
||||
}
|
||||
|
||||
async def search(self, keyword: str, page: int = 1, size: int = 10) -> ValuationAssessmentList:
|
||||
"""全文搜索"""
|
||||
queryset = self.model.filter(
|
||||
Q(asset_name__icontains=keyword) |
|
||||
Q(institution__icontains=keyword) |
|
||||
Q(industry__icontains=keyword) |
|
||||
Q(heritage_level__icontains=keyword),
|
||||
is_active=True
|
||||
)
|
||||
|
||||
# 计算总数
|
||||
total = await queryset.count()
|
||||
|
||||
# 分页查询
|
||||
offset = (page - 1) * size
|
||||
valuations = await queryset.offset(offset).limit(size).order_by('-created_at')
|
||||
|
||||
# 转换为输出模型
|
||||
items = [ValuationAssessmentOut.model_validate(v) for v in valuations]
|
||||
|
||||
# 计算总页数
|
||||
pages = (total + size - 1) // size
|
||||
|
||||
return ValuationAssessmentList(
|
||||
items=items,
|
||||
total=total,
|
||||
page=page,
|
||||
size=size,
|
||||
pages=pages
|
||||
)
|
||||
|
||||
async def approve_valuation(self, valuation_id: int, admin_notes: Optional[str] = None) -> Optional[ValuationAssessmentOut]:
|
||||
"""审核通过估值评估"""
|
||||
valuation = await self.model.filter(id=valuation_id, is_active=True).first()
|
||||
if not valuation:
|
||||
return None
|
||||
|
||||
update_data = {"status": "approved"}
|
||||
if admin_notes:
|
||||
update_data["admin_notes"] = admin_notes
|
||||
|
||||
await valuation.update_from_dict(update_data).save()
|
||||
return ValuationAssessmentOut.model_validate(valuation)
|
||||
|
||||
async def reject_valuation(self, valuation_id: int, admin_notes: Optional[str] = None) -> Optional[ValuationAssessmentOut]:
|
||||
"""审核拒绝估值评估"""
|
||||
valuation = await self.model.filter(id=valuation_id, is_active=True).first()
|
||||
if not valuation:
|
||||
return None
|
||||
|
||||
update_data = {"status": "rejected"}
|
||||
if admin_notes:
|
||||
update_data["admin_notes"] = admin_notes
|
||||
|
||||
await valuation.update_from_dict(update_data).save()
|
||||
return ValuationAssessmentOut.model_validate(valuation)
|
||||
|
||||
async def update_admin_notes(self, valuation_id: int, admin_notes: str) -> Optional[ValuationAssessmentOut]:
|
||||
"""更新管理员备注"""
|
||||
valuation = await self.model.filter(id=valuation_id, is_active=True).first()
|
||||
if not valuation:
|
||||
return None
|
||||
|
||||
await valuation.update_from_dict({"admin_notes": admin_notes}).save()
|
||||
return ValuationAssessmentOut.model_validate(valuation)
|
||||
|
||||
|
||||
# 创建控制器实例
|
||||
valuation_controller = ValuationController()
|
||||
@ -4,4 +4,5 @@ from .esg import *
|
||||
from .index import *
|
||||
from .industry import *
|
||||
from .policy import *
|
||||
from .user import *
|
||||
from .user import *
|
||||
from .valuation import *
|
||||
59
app/models/valuation.py
Normal file
59
app/models/valuation.py
Normal file
@ -0,0 +1,59 @@
|
||||
from tortoise import fields
|
||||
from tortoise.models import Model
|
||||
|
||||
|
||||
class ValuationAssessment(Model):
|
||||
"""估值评估模型"""
|
||||
|
||||
id = fields.IntField(pk=True, description="主键ID")
|
||||
|
||||
# 基础信息
|
||||
asset_name = fields.CharField(max_length=200, description="资产名称")
|
||||
institution = fields.CharField(max_length=200, description="所属机构")
|
||||
industry = fields.CharField(max_length=100, description="所属行业")
|
||||
|
||||
# 财务状况
|
||||
annual_revenue = fields.CharField(max_length=50, null=True, description="近12个月机构营收/万元")
|
||||
rd_investment = fields.CharField(max_length=50, null=True, description="近12个月机构研发投入/万元")
|
||||
three_year_income = fields.JSONField(null=True, description="近三年机构收益/万元")
|
||||
funding_status = fields.CharField(max_length=500, null=True, description="资产受资助情况")
|
||||
|
||||
# 非遗等级与技术
|
||||
inheritor_level = fields.CharField(max_length=50, null=True, description="非遗传承人等级")
|
||||
inheritor_age_count = fields.JSONField(null=True, description="非遗传承人年龄水平及数量")
|
||||
inheritor_certificates = fields.JSONField(null=True, description="非遗传承人等级证书")
|
||||
heritage_level = fields.CharField(max_length=50, null=True, description="非遗等级")
|
||||
patent_application_no = fields.CharField(max_length=100, null=True, description="非遗资产所用专利的申请号")
|
||||
historical_evidence = fields.JSONField(null=True, description="非遗资产历史证明证据及数量")
|
||||
patent_certificates = fields.JSONField(null=True, description="非遗资产所用专利的证书")
|
||||
pattern_images = fields.JSONField(null=True, description="非遗纹样图片")
|
||||
|
||||
# 非遗应用与推广
|
||||
application_maturity = fields.CharField(max_length=100, null=True, description="非遗资产应用成熟度")
|
||||
application_coverage = fields.CharField(max_length=100, null=True, description="非遗资产应用覆盖范围")
|
||||
cooperation_depth = fields.CharField(max_length=100, null=True, description="非遗资产跨界合作深度")
|
||||
offline_activities = fields.CharField(max_length=50, null=True, description="近12个月线下相关宣讲活动次数")
|
||||
online_accounts = fields.JSONField(null=True, description="线上相关宣传账号信息")
|
||||
|
||||
# 非遗资产衍生商品信息
|
||||
sales_volume = fields.CharField(max_length=50, null=True, description="该商品近12个月销售量")
|
||||
link_views = fields.CharField(max_length=50, null=True, description="该商品近12个月的链接浏览量")
|
||||
circulation = fields.CharField(max_length=50, null=True, description="该商品的发行量")
|
||||
last_market_activity = fields.CharField(max_length=100, null=True, description="该商品最近一次市场活动时间")
|
||||
monthly_transaction = fields.CharField(max_length=50, null=True, description="月交易额")
|
||||
price_fluctuation = fields.CharField(max_length=100, null=True, description="该商品近30天价格波动区间")
|
||||
|
||||
# 系统字段
|
||||
user = fields.ForeignKeyField("models.AppUser", related_name="valuations", description="提交用户")
|
||||
status = fields.CharField(max_length=20, default="pending", description="评估状态: pending(待审核), approved(已通过), rejected(已拒绝)")
|
||||
admin_notes = fields.TextField(null=True, description="管理员备注")
|
||||
created_at = fields.DatetimeField(auto_now_add=True, description="创建时间")
|
||||
updated_at = fields.DatetimeField(auto_now=True, description="更新时间")
|
||||
is_active = fields.BooleanField(default=True, description="是否激活")
|
||||
|
||||
class Meta:
|
||||
table = "valuation_assessments"
|
||||
table_description = "估值评估表"
|
||||
|
||||
def __str__(self):
|
||||
return f"估值评估-{self.asset_name}"
|
||||
184
app/schemas/valuation.py
Normal file
184
app/schemas/valuation.py
Normal file
@ -0,0 +1,184 @@
|
||||
from datetime import datetime
|
||||
from typing import List, Optional, Any
|
||||
from pydantic import BaseModel, Field
|
||||
|
||||
|
||||
class ValuationAssessmentBase(BaseModel):
|
||||
"""估值评估基础模型"""
|
||||
# 基础信息
|
||||
asset_name: str = Field(..., description="资产名称")
|
||||
institution: str = Field(..., description="所属机构")
|
||||
industry: str = Field(..., description="所属行业")
|
||||
|
||||
# 财务状况
|
||||
annual_revenue: Optional[str] = Field(None, description="近12个月机构营收/万元")
|
||||
rd_investment: Optional[str] = Field(None, description="近12个月机构研发投入/万元")
|
||||
three_year_income: Optional[List[Any]] = Field(None, description="近三年机构收益/万元")
|
||||
funding_status: Optional[str] = Field(None, description="资产受资助情况")
|
||||
|
||||
# 非遗等级与技术
|
||||
inheritor_level: Optional[str] = Field(None, description="非遗传承人等级")
|
||||
inheritor_age_count: Optional[List[Any]] = Field(None, description="非遗传承人年龄水平及数量")
|
||||
inheritor_certificates: Optional[List[Any]] = Field(None, description="非遗传承人等级证书")
|
||||
heritage_level: Optional[str] = Field(None, description="非遗等级")
|
||||
patent_application_no: Optional[str] = Field(None, description="非遗资产所用专利的申请号")
|
||||
historical_evidence: Optional[List[Any]] = Field(None, description="非遗资产历史证明证据及数量")
|
||||
patent_certificates: Optional[List[Any]] = Field(None, description="非遗资产所用专利的证书")
|
||||
pattern_images: Optional[List[Any]] = Field(None, description="非遗纹样图片")
|
||||
|
||||
# 非遗应用与推广
|
||||
application_maturity: Optional[str] = Field(None, description="非遗资产应用成熟度")
|
||||
application_coverage: Optional[str] = Field(None, description="非遗资产应用覆盖范围")
|
||||
cooperation_depth: Optional[str] = Field(None, description="非遗资产跨界合作深度")
|
||||
offline_activities: Optional[str] = Field(None, description="近12个月线下相关宣讲活动次数")
|
||||
online_accounts: Optional[List[Any]] = Field(None, description="线上相关宣传账号信息")
|
||||
|
||||
# 非遗资产衍生商品信息
|
||||
sales_volume: Optional[str] = Field(None, description="该商品近12个月销售量")
|
||||
link_views: Optional[str] = Field(None, description="该商品近12个月的链接浏览量")
|
||||
circulation: Optional[str] = Field(None, description="该商品的发行量")
|
||||
last_market_activity: Optional[str] = Field(None, description="该商品最近一次市场活动时间")
|
||||
monthly_transaction: Optional[str] = Field(None, description="月交易额")
|
||||
price_fluctuation: Optional[str] = Field(None, description="该商品近30天价格波动区间")
|
||||
|
||||
|
||||
class ValuationAssessmentCreate(ValuationAssessmentBase):
|
||||
"""创建估值评估模型"""
|
||||
pass
|
||||
|
||||
|
||||
class ValuationAssessmentUpdate(BaseModel):
|
||||
"""更新估值评估模型"""
|
||||
# 基础信息
|
||||
asset_name: Optional[str] = Field(None, description="资产名称")
|
||||
institution: Optional[str] = Field(None, description="所属机构")
|
||||
industry: Optional[str] = Field(None, description="所属行业")
|
||||
|
||||
# 财务状况
|
||||
annual_revenue: Optional[str] = Field(None, description="近12个月机构营收/万元")
|
||||
rd_investment: Optional[str] = Field(None, description="近12个月机构研发投入/万元")
|
||||
three_year_income: Optional[List[Any]] = Field(None, description="近三年机构收益/万元")
|
||||
funding_status: Optional[str] = Field(None, description="资产受资助情况")
|
||||
|
||||
# 非遗等级与技术
|
||||
inheritor_level: Optional[str] = Field(None, description="非遗传承人等级")
|
||||
inheritor_age_count: Optional[List[Any]] = Field(None, description="非遗传承人年龄水平及数量")
|
||||
inheritor_certificates: Optional[List[Any]] = Field(None, description="非遗传承人等级证书")
|
||||
heritage_level: Optional[str] = Field(None, description="非遗等级")
|
||||
patent_application_no: Optional[str] = Field(None, description="非遗资产所用专利的申请号")
|
||||
historical_evidence: Optional[List[Any]] = Field(None, description="非遗资产历史证明证据及数量")
|
||||
patent_certificates: Optional[List[Any]] = Field(None, description="非遗资产所用专利的证书")
|
||||
pattern_images: Optional[List[Any]] = Field(None, description="非遗纹样图片")
|
||||
|
||||
# 非遗应用与推广
|
||||
application_maturity: Optional[str] = Field(None, description="非遗资产应用成熟度")
|
||||
application_coverage: Optional[str] = Field(None, description="非遗资产应用覆盖范围")
|
||||
cooperation_depth: Optional[str] = Field(None, description="非遗资产跨界合作深度")
|
||||
offline_activities: Optional[str] = Field(None, description="近12个月线下相关宣讲活动次数")
|
||||
online_accounts: Optional[List[Any]] = Field(None, description="线上相关宣传账号信息")
|
||||
|
||||
# 非遗资产衍生商品信息
|
||||
sales_volume: Optional[str] = Field(None, description="该商品近12个月销售量")
|
||||
link_views: Optional[str] = Field(None, description="该商品近12个月的链接浏览量")
|
||||
circulation: Optional[str] = Field(None, description="该商品的发行量")
|
||||
last_market_activity: Optional[str] = Field(None, description="该商品最近一次市场活动时间")
|
||||
monthly_transaction: Optional[str] = Field(None, description="月交易额")
|
||||
price_fluctuation: Optional[str] = Field(None, description="该商品近30天价格波动区间")
|
||||
|
||||
is_active: Optional[bool] = Field(None, description="是否激活")
|
||||
|
||||
|
||||
class ValuationAssessmentOut(ValuationAssessmentBase):
|
||||
"""输出估值评估模型"""
|
||||
id: int = Field(..., description="主键ID")
|
||||
user_id: int = Field(..., description="用户ID")
|
||||
status: str = Field(..., description="评估状态")
|
||||
admin_notes: Optional[str] = Field(None, description="管理员备注")
|
||||
created_at: datetime = Field(..., description="创建时间")
|
||||
updated_at: datetime = Field(..., description="更新时间")
|
||||
is_active: bool = Field(..., description="是否激活")
|
||||
|
||||
class Config:
|
||||
from_attributes = True
|
||||
|
||||
|
||||
# 用户端专用模式
|
||||
class UserValuationCreate(ValuationAssessmentBase):
|
||||
"""用户端创建估值评估模型"""
|
||||
pass
|
||||
|
||||
|
||||
class UserValuationOut(BaseModel):
|
||||
"""用户端输出估值评估模型"""
|
||||
id: int = Field(..., description="主键ID")
|
||||
asset_name: str = Field(..., description="资产名称")
|
||||
institution: str = Field(..., description="所属机构")
|
||||
industry: str = Field(..., description="所属行业")
|
||||
status: str = Field(..., description="评估状态")
|
||||
admin_notes: Optional[str] = Field(None, description="管理员备注")
|
||||
created_at: datetime = Field(..., description="创建时间")
|
||||
updated_at: datetime = Field(..., description="更新时间")
|
||||
|
||||
class Config:
|
||||
from_attributes = True
|
||||
|
||||
|
||||
class UserValuationDetail(ValuationAssessmentBase):
|
||||
"""用户端详细估值评估模型"""
|
||||
id: int = Field(..., description="主键ID")
|
||||
status: str = Field(..., description="评估状态")
|
||||
admin_notes: Optional[str] = Field(None, description="管理员备注")
|
||||
created_at: datetime = Field(..., description="创建时间")
|
||||
updated_at: datetime = Field(..., description="更新时间")
|
||||
|
||||
class Config:
|
||||
from_attributes = True
|
||||
|
||||
|
||||
class UserValuationList(BaseModel):
|
||||
"""用户端估值评估列表模型"""
|
||||
items: List[UserValuationOut] = Field(..., description="估值评估列表")
|
||||
total: int = Field(..., description="总数量")
|
||||
page: int = Field(..., description="当前页码")
|
||||
size: int = Field(..., description="每页数量")
|
||||
pages: int = Field(..., description="总页数")
|
||||
|
||||
|
||||
class UserValuationQuery(BaseModel):
|
||||
"""用户端估值评估查询模型"""
|
||||
status: Optional[str] = Field(None, description="评估状态")
|
||||
asset_name: Optional[str] = Field(None, description="资产名称")
|
||||
page: int = Field(1, ge=1, description="页码")
|
||||
size: int = Field(10, ge=1, le=100, description="每页数量")
|
||||
|
||||
|
||||
class ValuationAssessmentList(BaseModel):
|
||||
"""估值评估列表模型"""
|
||||
items: List[ValuationAssessmentOut] = Field(..., description="估值评估列表")
|
||||
total: int = Field(..., description="总数量")
|
||||
page: int = Field(..., description="当前页码")
|
||||
size: int = Field(..., description="每页数量")
|
||||
pages: int = Field(..., description="总页数")
|
||||
|
||||
|
||||
class ValuationAssessmentQuery(BaseModel):
|
||||
"""估值评估查询模型"""
|
||||
asset_name: Optional[str] = Field(None, description="资产名称")
|
||||
institution: Optional[str] = Field(None, description="所属机构")
|
||||
industry: Optional[str] = Field(None, description="所属行业")
|
||||
heritage_level: Optional[str] = Field(None, description="非遗等级")
|
||||
status: Optional[str] = Field(None, description="评估状态: pending(待审核), approved(已通过), rejected(已拒绝)")
|
||||
is_active: Optional[bool] = Field(None, description="是否激活")
|
||||
page: int = Field(1, ge=1, description="页码")
|
||||
size: int = Field(10, ge=1, le=100, description="每页数量")
|
||||
|
||||
|
||||
# 管理端审核相关模型
|
||||
class ValuationApprovalRequest(BaseModel):
|
||||
"""估值评估审核请求模型"""
|
||||
admin_notes: Optional[str] = Field(None, description="管理员备注")
|
||||
|
||||
|
||||
class ValuationAdminNotesUpdate(BaseModel):
|
||||
"""管理员备注更新模型"""
|
||||
admin_notes: str = Field(..., description="管理员备注")
|
||||
35
估值字段.txt
Normal file
35
估值字段.txt
Normal file
@ -0,0 +1,35 @@
|
||||
基础信息
|
||||
资产名称: 字符串类型
|
||||
所属机构: 字符串类型
|
||||
所属行业: 字符串类型
|
||||
|
||||
财务状况
|
||||
近12个月机构营收/万元: 字符串类型
|
||||
近12个月机构研发投入/万元: 字符串类型
|
||||
近三年机构收益/万元: 列表类型
|
||||
资产受资助情况: 字符串类型
|
||||
|
||||
非造等級与技术
|
||||
非遗传承人等级: 字符串类型
|
||||
非遗传承人年龄水平及数量: 列表类型
|
||||
非遗传承人等级证书: 列表类型
|
||||
非遗等级: 字符串类型
|
||||
非遗资产所用专利的申请号: 字符串类型
|
||||
非遗资产历史证明证据及数量: 列表类型
|
||||
非遗资产所用专利的证书: 列表类型
|
||||
非遗纹样图片: 列表类型
|
||||
|
||||
非遗应用与推广
|
||||
非遗资产应用成熟度: 字符串类型
|
||||
非遗资产应用覆盖范围: 字符串类型
|
||||
非遗资产跨界合作深度: 字符串类型
|
||||
近12个月线下相关宣讲活动次数: 字符串类型
|
||||
线上相关宣传账号信息: 列表类型
|
||||
|
||||
非遗资产衍生商品信息
|
||||
该商品近12个月销售量: 字符串类型
|
||||
该商品近12个月的链接浏览量: 字符串类型
|
||||
该商品的发行量: 字符串类型
|
||||
该商品最近一次市场活动时间: 字符串类型
|
||||
月交易額: 字符串类型
|
||||
该商品近30天价格波动区间: 字符串类型
|
||||
Loading…
x
Reference in New Issue
Block a user