maruizhi/SST
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mrz

Browse Source
This commit is contained in:
maruizhi
2026-09-22 11:49:44 +08:00
parent 751d430e3e
commit bff10de7fa
4 changed files with 98 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
PythonProject/api/statistics_api.py
+5 -7
View File
@@ -1,6 +1,5 @@
from fastapi import APIRouter,Depends,Query
from dao.statistics_dao import *
from schema.student_schema import StudentResponse
from schema.statistics_schema import *
from util.database import get_db
@@ -16,28 +15,27 @@ def get_students(db=Depends(get_db)):
l = select_all(db)
return l
@StatisticsAPI.get("/score",response_model=StudentResponse,tags=['统计分析模块'],summary='根据成绩查询学生信息')
@StatisticsAPI.get("/score",response_model=list[GetScoreResponse],tags=['统计分析模块'],summary='根据成绩查询学生信息')
def get_students(min_score:int|None=None,max_score:int|None=None,db=Depends(get_db)):
l = select_score(min_score,max_score,db)
return [i for i in l]
return l
@StatisticsAPI.get("/avg_score",response_model=list[AcgScoreResponse],tags=['统计分析模块'],summary='统计每次考试每个班级的平均分并排序')
def get_scores(db=Depends(get_db)):
l = select_avg_score(db)
return l
@StatisticsAPI.get("/salary",response_model=list[StudentResponse],tags=['统计分析模块'],summary='统计薪资最高的前五名的学员信息')
@StatisticsAPI.get("/salary",response_model=list[GetStuResponse],tags=['统计分析模块'],summary='统计薪资最高的前五名的学员信息')
def get_scores(db=Depends(get_db)):
l = select_salary(db)
return l
@StatisticsAPI.get("/avg_day",response_model=list[AvgDayResponse],tags=['统计分析模块'],summary='统计每个班级的平均就业时长')
def get_days(db=Depends(get_db)):
l = select_days(db)
l = select_avg_days(db)
return l
@StatisticsAPI.get('/emp',response_model=AllEmpResponse,tags=['统计分析模块'],summary='统计每个学生的就业时长')
def get_emp(db=Depends(get_db)):
l= select_days2(db)
l= select_days(db)
return l
PythonProject/dao/statistics_dao.py
+37 -6
View File
@@ -23,7 +23,17 @@ def select_all(db):
try:
l1 = db.query(Student_Model.class_id,Student_Model.gender,func.count(1).label('cnt'))\
.group_by(Student_Model.class_id,Student_Model.gender).all()
return l1
all_cnt = sum(i.cnt for i in l1)
l2 = []
for i in l1:
l2.append({
"all_cnt": all_cnt,
"class_id": i.class_id,
"gender": i.gender,
"cnt": i.cnt
})
return l2
except Exception:
raise HTTPException(status_code=500,detail="查询异常")
@@ -32,12 +42,23 @@ def select_score(min_score,max_score,db):
try:
if min_score is None and max_score is None:
raise HTTPException(status_code=400, detail="请至少传入一个参数")
db = db.query(Student_Model,WlScore.score,WlScore.score)\
db = db.query(WlScore.score
,Student_Model.stu_name
,Student_Model.age
,Student_Model.gender
,Student_Model.native_place
,Student_Model.school
,Student_Model.major
,Student_Model.degree
,Student_Model.admission_date
,Student_Model.graduation_date
,Student_Model.progress
)\
.join(WlScore,WlScore.stu_id == Student_Model.stu_id)\
.filter(WlScore.delete_status==0,Student_Model.delete_status == 0)
if min_score is not None:
db = db.filter(WlScore.score >= min_score)
if min_score is not None:
if max_score is not None:
db = db.filter(WlScore.score <= max_score)
return db.all()
except HTTPException:
@@ -60,7 +81,17 @@ def select_avg_score(db):
# 实现统计薪资最高的前五名的学员信息
def select_salary(db):
try:
l1 = db.query(Student_Model,Employment_info.salary)\
l1 = db.query(Employment_info.salary
,Student_Model.stu_name
,Student_Model.age
,Student_Model.gender
,Student_Model.native_place
,Student_Model.school
,Student_Model.major
,Student_Model.degree
,Student_Model.admission_date
,Student_Model.graduation_date
,Student_Model.progress)\
.join(Employment_info,Employment_info.stu_id==Student_Model.stu_id)\
.filter(Employment_info.delete_status==0,Student_Model.delete_status == 0)\
.order_by(Employment_info.salary.desc())\
@@ -70,7 +101,7 @@ def select_salary(db):
raise HTTPException(status_code=500,detail="查询异常")
# 实现统计每个班级的平均就业时长
def select_days(db):
def select_avg_days(db):
try:
l1 = db.query(Student_Model.class_id,
func.coalesce(
@@ -91,7 +122,7 @@ def select_days(db):
raise HTTPException(status_code=500, detail="查询异常")
#统计每个学⽣的就业时⻓
def select_days2(db):
def select_days(db):
try:
l2 =db.query(
Employment_info.stu_id
PythonProject/schema/statistics_schema.py
+53 -6
View File
@@ -1,8 +1,10 @@
from pydantic import BaseModel,Field
from pydantic import BaseModel,field_serializer
from datetime import date
from typing import List, Optional
from typing import List
from schema.student_schema import StudentResponse
class AllStuResponse(BaseModel):
all_cnt: int
class_id: int
gender: str | None
cnt: int
@@ -11,12 +13,57 @@ class AcgScoreResponse(BaseModel):
class_id: int
avg_score: float
class GetScoreResponse(BaseModel):
code:int = 200
detail:str = 'ok'
score:float
stu_name: str | None = None
age: int | None = None
gender: str | None = None
native_place: str | None = None
school: str | None = None
major: str | None = None
degree: str | None = None
admission_date: date | None = None
graduation_date: date | None = None
progress: int = 0
@field_serializer('progress')
def int_to_string(self, progress: int):
d1 = {
0: '学习中',
1: '求职中',
2: '已就业'
}
return d1.get(progress, '暂不明确')
class GetStuResponse(BaseModel):
code:int = 200
detail:str = 'ok'
salary:float
stu_name: str | None = None
age: int | None = None
gender: str | None = None
native_place: str | None = None
school: str | None = None
major: str | None = None
degree: str | None = None
admission_date: date | None = None
graduation_date: date | None = None
progress: int = 0
@field_serializer('progress')
def int_to_string(self, progress: int):
d1 = {
0: '学习中',
1: '求职中',
2: '已就业'
}
return d1.get(progress, '暂不明确')
class AvgDayResponse(BaseModel):
class_id: int
avg_days: str | None
class EmpRequest(BaseModel):
stu_id: int
avg_days: float | None
class EmpItem(BaseModel):
stu_id: int
PythonProject/schema/student_schema.py
+1 -1
View File
@@ -67,7 +67,7 @@ class StugetResponse(BaseModel):
progress: int = 0
@field_serializer('progress')
def int_to_string(cls, progress: int):
def int_to_string(self, progress: int):
d1 = {
0: '学习中',
1: '求职中',