From 9b4e3cfe069b2b8866cdfa9857980d131217dc64 Mon Sep 17 00:00:00 2001 From: 00MSJ1122 <1253313142@qq.com> Date: Mon, 21 Sep 2026 16:32:11 +0800 Subject: [PATCH 01/11] 1 --- PythonProject/dao/statistics_dao.py | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/PythonProject/dao/statistics_dao.py b/PythonProject/dao/statistics_dao.py index bb9c068..de2fd06 100644 --- a/PythonProject/dao/statistics_dao.py +++ b/PythonProject/dao/statistics_dao.py @@ -1,6 +1,8 @@ +from datetime import datetime + from fastapi import HTTPException,Depends from sqlalchemy import func -from model.all_model import Student_Model,WlScore +from model.all_model import Student_Model,WlScore,Employment_info from util.database import get_db # 实现根据年龄查询学生信息的功能 @@ -43,4 +45,17 @@ def select_score(min_score,max_score,session=Depends(get_db)): except HTTPException: raise except Exception: - raise HTTPException(status_code=500,detail="查询异常") \ No newline at end of file + raise HTTPException(status_code=500,detail="查询异常") + +#实现查询每个学生的就业时长 +def select_emp_duration(stu_id:int,session): + try: + l2 = session.query(Employment_info,Student_Model.name.label('stu_name'),).join(Student_Model,stu_id==Student_Model.stu_id).filter(Employment_info.stu_id == stu_id,Employment_info.delete_status == 0).all() + list=[] + today=datetime.today() + for i in l2: + duration_days = (today - i.start_date).days + list.append({Employment_info.stu_id:i.stu_id, + + Employment_info.offer_issuance_date:i.offer_issuance_date, + Employment_info.company_name:i.company_name}) From 9a47e485db8503116ba78cc81282e2ea124bd4a9 Mon Sep 17 00:00:00 2001 From: Windows <2209639385@qq.com> Date: Mon, 21 Sep 2026 17:19:20 +0800 Subject: [PATCH 02/11] nb --- PythonProject/api/grade_api.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/PythonProject/api/grade_api.py b/PythonProject/api/grade_api.py index c0a33f0..5872b26 100644 --- a/PythonProject/api/grade_api.py +++ b/PythonProject/api/grade_api.py @@ -16,6 +16,11 @@ def get_grade(stu_id: int,db=Depends(get_db)): @gradeAPI.post('/{stu_id}',response_model=GradeResponse,summary='添加学生成绩') def post_grade(o:GradeRequest=Form(),db=Depends(get_db)): + + exist_obj = get_grade_dao(db,o.stu_id) + if exist_obj: + raise HTTPException(status_code=409, detail="该学生此考核序次成绩已存在！") + d=o.model_dump() r=add_grade_dao(g=d,db=db) if not r: From f97b46961aed57f52496cf308f9e1655ac4e1690 Mon Sep 17 00:00:00 2001 From: maruizhi <3088243241@qq.com> Date: Mon, 21 Sep 2026 17:31:25 +0800 Subject: [PATCH 03/11] mrz --- PythonProject/model/all_model.py | 1 - 1 file changed, 1 deletion(-) diff --git a/PythonProject/model/all_model.py b/PythonProject/model/all_model.py index 74f785d..422cb09 100644 --- a/PythonProject/model/all_model.py +++ b/PythonProject/model/all_model.py @@ -159,7 +159,6 @@ class WlScore(Base): stu_id = Column( Integer ,ForeignKey('wl_student.stu_id') - ,autoincrement=True #自增主建 ,comment='学生编号') exam_order = Column(Integer From 87e6083295f3dafcc96345d0d5c19925e0c7c45b Mon Sep 17 00:00:00 2001 From: maruizhi <3088243241@qq.com> Date: Mon, 21 Sep 2026 17:47:50 +0800 Subject: [PATCH 04/11] mrz --- PythonProject/api/employment_api.py | 2 +- PythonProject/api/statistics_api.py | 27 +++++++++-- PythonProject/dao/statistics_dao.py | 56 +++++++++++++++++++++-- PythonProject/main.py | 4 +- PythonProject/schema/statistics_schema.py | 11 +++++ 5 files changed, 87 insertions(+), 13 deletions(-) create mode 100644 PythonProject/schema/statistics_schema.py diff --git a/PythonProject/api/employment_api.py b/PythonProject/api/employment_api.py index 68cc125..71a8ca5 100644 --- a/PythonProject/api/employment_api.py +++ b/PythonProject/api/employment_api.py @@ -27,4 +27,4 @@ def get_emp_info2(class_id: int,db=Depends(get_db)): @app.post('employment/students/{stu_id}') def create_emp_info(stu_id: int,db=Depends(get_db)): - + pass diff --git a/PythonProject/api/statistics_api.py b/PythonProject/api/statistics_api.py index aff954a..ab3141d 100644 --- a/PythonProject/api/statistics_api.py +++ b/PythonProject/api/statistics_api.py @@ -1,21 +1,38 @@ from fastapi import APIRouter,Depends -from dao.statistics_dao import select_all,select_age,select_score +from dao.statistics_dao import select_all,select_age,select_score,select_avg_score,select_salary,select_days from schema.student_schema import StudentResponse +from schema.statistics_schema import AllStuResponse,AvgDayResponse from util.database import get_db StatisticsAPI = APIRouter() -@StatisticsAPI.get("/age",response_model=list[StudentResponse],tags=['统计分析模块'],description='根据年龄查询学生信息') +@StatisticsAPI.get("/age",response_model=list[StudentResponse],tags=['统计分析模块'],summary='根据年龄查询学生信息') def get_students(min_age:int|None=None,max_age:int|None=None,db=Depends(get_db)): l = select_age(min_age,max_age,db) return l -@StatisticsAPI.get("/all",response_model=StudentResponse,tags=['统计分析模块'],description='统计每个班级的学员总数和男女生总数') +@StatisticsAPI.get("/all",response_model=list[AllStuResponse],tags=['统计分析模块'],summary='统计每个班级的学员总数和男女生总数') def get_students(db=Depends(get_db)): l = select_all(db) - return [i for i in l] + return l -@StatisticsAPI.get("/score",response_model=StudentResponse,tags=['统计分析模块'],description='根据成绩查询学生信息') +@StatisticsAPI.get("/score",response_model=StudentResponse,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] + +@StatisticsAPI.get("/avg_score",response_model=StudentResponse,tags=['统计分析模块'],summary='统计每次考试每个班级的平均分并排序') +def get_scores(db=Depends(get_db)): + l = select_avg_score(db) + return [i for i in l] + +@StatisticsAPI.get("/salary",response_model=list[StudentResponse],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) + return l + diff --git a/PythonProject/dao/statistics_dao.py b/PythonProject/dao/statistics_dao.py index 249e6d1..774fb74 100644 --- a/PythonProject/dao/statistics_dao.py +++ b/PythonProject/dao/statistics_dao.py @@ -1,7 +1,6 @@ -from fastapi import HTTPException,Depends +from fastapi import HTTPException from sqlalchemy import func -from model.all_model import Student_Model,WlScore -from util.database import get_db +from model.all_model import Student_Model,WlScore,Employment_info # 实现根据年龄查询学生信息的功能 def select_age(min_age,max_age,db): @@ -23,7 +22,8 @@ def select_age(min_age,max_age,db): # 实现统计每个班级的学员总数以及男女生的总数的功能 def select_all(db): try: - l1 = db.query(Student_Model.class_id,Student_Model.gender,func.count(1)).group_by(Student_Model.class_id,Student_Model.gender).all() + 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 except Exception: raise HTTPException(status_code=500,detail="查询异常") @@ -34,7 +34,8 @@ def select_score(min_score,max_score,db): 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)\ - .join(WlScore,WlScore.stu_id == Student_Model.stu_id,WlScore.delete_status==0,WlScore.delete_status == 0) + .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: @@ -45,3 +46,48 @@ def select_score(min_score,max_score,db): except Exception: raise HTTPException(status_code=500,detail="查询异常") +# 实现统计每次考试每个班级的平均分并排序的功能 +def select_avg_score(db): + try: + l1 = db.query(func.avg(WlScore.score))\ + .join(Student_Model,WlScore.stu_id == Student_Model.stu_id)\ + .filter(WlScore.delete_status==0,Student_Model.delete_status == 0)\ + .group_by(Student_Model.class_id)\ + .order_by(func.avg(WlScore.score)).all() + return l1 + except Exception: + raise HTTPException(status_code=500,detail="查询异常") + +# 实现统计薪资最高的前五名的学员信息 +def select_salary(db): + try: + l1 = db.query(Student_Model,Employment_info.salary)\ + .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())\ + .limit(5).all() + return l1 + except Exception: + raise HTTPException(status_code=500,detail="查询异常") + +# 实现统计每个班级的平均就业时长 +def select_days(db): + try: + l1 = db.query(Student_Model.class_id, + func.coalesce( + func.avg( + func.datediff( + Employment_info.offer_issuance_date, Employment_info.employment_opening_date + ) + ),0).label("avg_days") + ).join(Employment_info,Employment_info.stu_id == Student_Model.stu_id)\ + .filter(Student_Model.delete_status == 0, + Employment_info.delete_status == 0, + Employment_info.employment_opening_date.isnot(None), + Employment_info.offer_issuance_date.isnot(None),)\ + .group_by( Student_Model.class_id)\ + .order_by(func.avg(func.datediff(Employment_info.offer_issuance_date,Student_Model.admission_date)).desc()).all() + return l1 + except Exception: + raise HTTPException(status_code=500, detail="查询异常") + diff --git a/PythonProject/main.py b/PythonProject/main.py index b2aef0b..2ac3247 100644 --- a/PythonProject/main.py +++ b/PythonProject/main.py @@ -3,7 +3,7 @@ from api.student_api import StudentAPI from api.statistics_api import StatisticsAPI from api.teacher_api import teacher_api from api.grade_api import gradeAPI -app = FastAPI() +app = FastAPI(title='沃林学⽣管理系统') app.include_router(StudentAPI) app.include_router(StatisticsAPI) @@ -14,4 +14,4 @@ app.include_router(teacher_api) if __name__ == '__main__': import uvicorn uvicorn.run("main:app",host='0.0.0.0',port=12310) -app.include_router(gradeAPI) \ No newline at end of file +app.include_router(gradeAPI) diff --git a/PythonProject/schema/statistics_schema.py b/PythonProject/schema/statistics_schema.py new file mode 100644 index 0000000..4c967e0 --- /dev/null +++ b/PythonProject/schema/statistics_schema.py @@ -0,0 +1,11 @@ +from pydantic import BaseModel + +class AllStuResponse(BaseModel): + class_id: int + gender: str | None + cnt: int + +class AvgDayResponse(BaseModel): + class_id: int + avg_days: str | None + From 3f75a75f7667dbe058bf2585544c120ec79a7d4d Mon Sep 17 00:00:00 2001 From: wolin_chenyulin001 <123@163.com> Date: Mon, 21 Sep 2026 17:48:26 +0800 Subject: [PATCH 05/11] =?UTF-8?q?=E5=B0=B1=E4=B8=9Aget=E6=AC=A1=E6=98=82?= =?UTF-8?q?=E7=AE=A1=E7=9A=84dao=E5=B1=82=E5=92=8Capi=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- PythonProject/api/employment_api.py | 11 ++--- PythonProject/dao/employment_dao.py | 74 ++++++++++++++++------------- 2 files changed, 45 insertions(+), 40 deletions(-) diff --git a/PythonProject/api/employment_api.py b/PythonProject/api/employment_api.py index 71a8ca5..a5ee446 100644 --- a/PythonProject/api/employment_api.py +++ b/PythonProject/api/employment_api.py @@ -13,7 +13,7 @@ def get_emp_info1(stu_id: int,db=Depends(get_db)): if stu_id: return employment_dao.get_employment_info() except: - raise HTTPException(status_code=404, detail='就业信息不存在') + raise HTTPException(status_code=404, detail='该学生就业信息不存在') @app.get('employment/class/{class_id}',summary='获取班级学生就业信息') def get_emp_info2(class_id: int,db=Depends(get_db)): @@ -21,10 +21,9 @@ def get_emp_info2(class_id: int,db=Depends(get_db)): if class_id: return employment_dao.get_employment_info() except: - raise HTTPException(status_code=404, detail='就业信息不存在') + raise HTTPException(status_code=404, detail='该班级就业信息不存在') - - -@app.post('employment/students/{stu_id}') -def create_emp_info(stu_id: int,db=Depends(get_db)): +# @app.post('employment/students/{stu_id}') +# def create_emp_info(stu_id: int,db=Depends(get_db)): +# try: pass diff --git a/PythonProject/dao/employment_dao.py b/PythonProject/dao/employment_dao.py index 47275fb..3bed3a2 100644 --- a/PythonProject/dao/employment_dao.py +++ b/PythonProject/dao/employment_dao.py @@ -1,40 +1,46 @@ - +from fastapi import HTTPException,Depends from model.all_model import Employment_info, ClassManagement, Student_Model from util.database import get_db from schema.employment_schema import EmlpoymentRequest -def get_employment_dao(stu_id,class_id,db): - q = db.query(Employment_info).\ - join(ClassManagement,ClassManagement.stu_id == Employment_info.stu_id).\ - filter(Employment_info.delete_status == 0).\ - filter(Student_Model.delete_status == 0).\ - filter(ClassManagement.delete_status == 0) - if stu_id is not None: - q = q.filter(Employment_info.stu_id == stu_id) - if class_id is not None: - q = q.filter(ClassManagement.class_id == class_id) - r = q.all() - if r: - return [{'emp_id':i.emp_id - ,'stu_id': i.stu_id - ,'stu_name':i.stu_name - ,'class_id':i.class_id - ,'email':i.email - ,'employment_opening_date':i.employment_opening_date - ,'offer_issuance_date':i.offer_issuance_date - ,'company_name':i.company_name - ,'company_address':i.company_address - ,'salary':i.salary - }for i in r - ] - -def add_employment_dao(e:EmlpoymentRequest,db,stu_id): +def get_employment_dao(stu_id,class_id,db=Depends(get_db())): try: - e1 = Employment_info(**e) - db.add(e1) + q = db.query(Employment_info).\ + join(Student_Model,Employment_info.stu_id == Student_Model.stu_id).\ + join(ClassManagement,Student_Model.class_id == ClassManagement.class_id).\ + filter(Employment_info.delete_status == 0).\ + filter(Student_Model.delete_status == 0).\ + filter(ClassManagement.delete_status == 0) + if stu_id is not None: + q = q.filter(Employment_info.stu_id == stu_id) + if class_id is not None: + q = q.filter(ClassManagement.class_id == class_id) + r = q.all() + if r: + return [{'emp_id':i.emp_id + ,'stu_id': i.stu_id + ,'stu_name':i.stu_name + ,'class_id':i.class_id + ,'email':i.email + ,'employment_opening_date':i.employment_opening_date + ,'offer_issuance_date':i.offer_issuance_date + ,'company_name':i.company_name + ,'company_address':i.company_address + ,'salary':i.salary + }for i in r + ] except: - db.rollback() - return False - else: - db.commit() - return True + raise HTTPException(status_code=404,detail='信息不存在！') + +# def add_employment_dao(e:EmlpoymentRequest,db=Depends(get_db()),stu_id): +# try: +# r = db.query(Employment_info).filter(Employment_info.stu_id == stu_id).all() +# if r: +# e1 = Employment_info(**e) +# db.add(e1) +# except: +# db.rollback() +# return False +# else: +# db.commit() +# return True From 0e0b4125ec9826bcd019f83c1af0a9e8df7db74e Mon Sep 17 00:00:00 2001 From: wolin_chenyulin001 <123@163.com> Date: Mon, 21 Sep 2026 17:50:29 +0800 Subject: [PATCH 06/11] =?UTF-8?q?=E5=B0=B1=E4=B8=9Aget=E6=AC=A1=E6=98=82?= =?UTF-8?q?=E7=AE=A1=E7=9A=84dao=E5=B1=82=E5=92=8Capi=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- PythonProject/api/employment_api.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/PythonProject/api/employment_api.py b/PythonProject/api/employment_api.py index a5ee446..351187c 100644 --- a/PythonProject/api/employment_api.py +++ b/PythonProject/api/employment_api.py @@ -6,8 +6,8 @@ from schema.employment_schema import EmlpoymentRequest,EmploymentResponse from model.all_model import ClassManagement,Employment_info from util.database import get_db -app = FastAPI() -@app.get('employment/students/{stu_id}',response_model=EmploymentResponse,summary='获取学生就业信息') +emp_api = FastAPI() +@emp_api.get('employment/students/{stu_id}',response_model=EmploymentResponse,summary='获取学生就业信息') def get_emp_info1(stu_id: int,db=Depends(get_db)): try: if stu_id: @@ -15,7 +15,7 @@ def get_emp_info1(stu_id: int,db=Depends(get_db)): except: raise HTTPException(status_code=404, detail='该学生就业信息不存在') -@app.get('employment/class/{class_id}',summary='获取班级学生就业信息') +@emp_api.get('employment/class/{class_id}',summary='获取班级学生就业信息') def get_emp_info2(class_id: int,db=Depends(get_db)): try: if class_id: From 9b2de683f73e9fa039b233ba4c6d679d04ff327a Mon Sep 17 00:00:00 2001 From: wolin_chenyulin001 <123@163.com> Date: Mon, 21 Sep 2026 17:53:58 +0800 Subject: [PATCH 07/11] =?UTF-8?q?=E5=B0=B1=E4=B8=9Aget=E6=AC=A1=E6=98=82?= =?UTF-8?q?=E7=AE=A1=E7=9A=84dao=E5=B1=82=E5=92=8Capi=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- PythonProject/main.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/PythonProject/main.py b/PythonProject/main.py index 2ac3247..9223bc4 100644 --- a/PythonProject/main.py +++ b/PythonProject/main.py @@ -1,4 +1,6 @@ from fastapi import FastAPI + +from api.employment_api import emp_api from api.student_api import StudentAPI from api.statistics_api import StatisticsAPI from api.teacher_api import teacher_api @@ -9,6 +11,7 @@ app.include_router(StudentAPI) app.include_router(StatisticsAPI) app.include_router(teacher_api) +app.include_router(emp_api) if __name__ == '__main__': From 44f2d89f62ce229caad086a3297ce11ec001abbc Mon Sep 17 00:00:00 2001 From: wolin_chenyulin001 <123@163.com> Date: Mon, 21 Sep 2026 18:02:12 +0800 Subject: [PATCH 08/11] =?UTF-8?q?=E5=B0=B1=E4=B8=9Aget=E6=AC=A1=E6=98=82?= =?UTF-8?q?=E7=AE=A1=E7=9A=84dao=E5=B1=82=E5=92=8Capi=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- PythonProject/api/employment_api.py | 10 +++++----- PythonProject/dao/employment_dao.py | 2 +- PythonProject/schema/employment_schema.py | 2 +- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/PythonProject/api/employment_api.py b/PythonProject/api/employment_api.py index 351187c..22095c7 100644 --- a/PythonProject/api/employment_api.py +++ b/PythonProject/api/employment_api.py @@ -1,12 +1,12 @@ -from fastapi import FastAPI,APIRouter,Depends,HTTPException +from fastapi import APIRouter,Depends,HTTPException from dao import employment_dao from dao.employment_dao import get_employment_dao -from schema.employment_schema import EmlpoymentRequest,EmploymentResponse +from schema.employment_schema import EmploymentRequest,EmploymentResponse from model.all_model import ClassManagement,Employment_info from util.database import get_db -emp_api = FastAPI() +emp_api = APIRouter() @emp_api.get('employment/students/{stu_id}',response_model=EmploymentResponse,summary='获取学生就业信息') def get_emp_info1(stu_id: int,db=Depends(get_db)): try: @@ -23,7 +23,7 @@ def get_emp_info2(class_id: int,db=Depends(get_db)): except: raise HTTPException(status_code=404, detail='该班级就业信息不存在') -# @app.post('employment/students/{stu_id}') +# @emp_api.post('employment/students/{stu_id}') # def create_emp_info(stu_id: int,db=Depends(get_db)): # try: - pass +# pass diff --git a/PythonProject/dao/employment_dao.py b/PythonProject/dao/employment_dao.py index 3bed3a2..426452b 100644 --- a/PythonProject/dao/employment_dao.py +++ b/PythonProject/dao/employment_dao.py @@ -1,7 +1,7 @@ from fastapi import HTTPException,Depends from model.all_model import Employment_info, ClassManagement, Student_Model from util.database import get_db -from schema.employment_schema import EmlpoymentRequest +from schema.employment_schema import EmploymentRequest def get_employment_dao(stu_id,class_id,db=Depends(get_db())): try: diff --git a/PythonProject/schema/employment_schema.py b/PythonProject/schema/employment_schema.py index d353b40..4e93d2c 100644 --- a/PythonProject/schema/employment_schema.py +++ b/PythonProject/schema/employment_schema.py @@ -3,7 +3,7 @@ from pydantic import BaseModel, field_validator from datetime import date from typing import Optional -class EmlpoymentRequest(BaseModel): +class EmploymentRequest(BaseModel): stu_id: int=Query(ge=1) email: str|None employment_opening_date:date From e5c2284ad187e0fd8620fb2c88fe69f0320caf58 Mon Sep 17 00:00:00 2001 From: 00MSJ1122 <1253313142@qq.com> Date: Mon, 21 Sep 2026 18:04:38 +0800 Subject: [PATCH 09/11] 1 --- PythonProject/api/student_api.py | 47 ++++++++++++++------------ PythonProject/dao/student_dao.py | 33 ++++++++++-------- PythonProject/schema/student_schema.py | 46 +++++++++++++++++-------- 3 files changed, 74 insertions(+), 52 deletions(-) diff --git a/PythonProject/api/student_api.py b/PythonProject/api/student_api.py index 3e4a874..04a4719 100644 --- a/PythonProject/api/student_api.py +++ b/PythonProject/api/student_api.py @@ -1,28 +1,41 @@ from fastapi import APIRouter,Depends,HTTPException -from dao.student_dao import delete_student_dao,add_student_dao,update_student_dao,get_student_dao -from schema.student_schema import StudentRequest,StudentResponse,StugetResponse +from dao.student_dao import * +from schema.student_schema import * from util.database import get_db StudentAPI = APIRouter() -@StudentAPI.get('/',description='查询学生信息') +@StudentAPI.get('/',response_model=list[StudentPageResponse],description='查询学生信息') def get_students(stu_id:int|None=None ,stu_name:str|None=None ,class_id:int|None=None ,db=Depends(get_db) ,page:int=1 ,page_size:int=10): - r=get_student_dao(stu_id,stu_name,class_id,db,page,page_size) - if r: - return r - raise HTTPException(status_code=404,detail='学生不存在') + r, total = get_student_dao(stu_id=stu_id + ,stu_name=stu_name + ,class_id=class_id + ,page=page + ,page_size=page_size + ,db=db) + + if not r: + raise HTTPException(status_code=404,detail='学生不存在') + return {'code': 200 + , 'detail': 'ok' + , 'page': page + , 'page_size': page_size + , 'total': total + , 'data': r} @StudentAPI.put('/{stu_id}') def update_students(s:StudentRequest ,stu_id:int ,db=Depends(get_db)): d = s.model_dump(exclude_unset=True) + if not d: + raise HTTPException(status_code=400, detail='更新内容不能为空！') r = update_student_dao( stu_id=stu_id,update_data=d,db=db ) if not r: raise HTTPException(status_code=500, detail='没有更新！') @@ -36,23 +49,13 @@ def del_students(stu_id:int raise HTTPException(status_code=500,detail='没有删除') return {'code':200,'totals':rows,'detail':'删除成功'} -@StudentAPI.post('/',response_model=list[StugetResponse]) +@StudentAPI.post('/',response_model=StugetResponse,description='新增学生') def add_students(s:StudentRequest ,db=Depends(get_db)): - d=s.model_dump(exclude_unset=True) - r=add_student_dao(o=d,db=db) - if not r: + d=s.model_dump(exclude_unset=False) + stu_new=add_student_dao(o=d,db=db) + if not stu_new: raise HTTPException(status_code=500,detail='添加失败') + return stu_new -@StudentAPI.put('/') -def get_students(stu_id:int|None = None - ,stu_name:str|None = None - ,class_id:int|None=None - ,db=Depends(get_db) - ,page:int=1 - ,page_size:int=10): - r = get_student_dao(stu_id,stu_name,class_id,db,page,page_size ) - if r: - return r - raise HTTPException(status_code=404,detail='学生不存在！') diff --git a/PythonProject/dao/student_dao.py b/PythonProject/dao/student_dao.py index 5cd585e..e896579 100644 --- a/PythonProject/dao/student_dao.py +++ b/PythonProject/dao/student_dao.py @@ -3,7 +3,7 @@ from util.database import get_db from model.all_model import Student_Model from typing import List, Optional, Dict, Any -def add_student_dao(o,db=Depends(get_db)): +def add_student_dao(o,db): try: o1 = Student_Model( **o) db.add(o1) @@ -14,7 +14,7 @@ def add_student_dao(o,db=Depends(get_db)): db.commit() return True -def delete_student_dao(stu_id,db=Depends(get_db)): +def delete_student_dao(stu_id,db): try: rows = db.query(Student_Model).filter(Student_Model.stu_id == stu_id,Student_Model.delete_status == 0)\ .update({'delete_status':1}) @@ -25,7 +25,7 @@ def delete_student_dao(stu_id,db=Depends(get_db)): finally: return rows -def update_student_dao(stu_id,update_data,db=Depends(get_db)): +def update_student_dao(stu_id,update_data,db): try: rows = db.query( Student_Model ).filter( Student_Model.stu_id == stu_id,Student_Model.delete_status == 0).update( update_data ) except: @@ -40,16 +40,19 @@ def get_student_dao(stu_id:Optional[int] ,class_id:Optional[int] ,page: int ,page_size: int - ,db=Depends(get_db) + ,db ) -> tuple[List[Dict[str, Any]], int]: - q = db.query(Student_Model) - if stu_id: - q = q.filter(Student_Model.stu_id == stu_id,Student_Model.delete_status == 0) - if stu_name: - q = q.filter(Student_Model.stu_name.like(f"%{stu_name}%"),Student_Model.delete_status == 0) - if class_id: - q= q.filter(Student_Model.class_id == class_id,Student_Model.delete_status == 0) - total = q.count() - r = q.offset((page - 1) * page_size).limit(page_size).all() - - return r + try: + q = db.query(Student_Model) + if stu_id: + q = q.filter(Student_Model.stu_id == stu_id,Student_Model.delete_status == 0) + if stu_name and stu_name.strip() != "": + q = q.filter(Student_Model.stu_name.like(f"%{stu_name}%"),Student_Model.delete_status == 0) + if class_id: + q= q.filter(Student_Model.class_id == class_id,Student_Model.delete_status == 0) + total = q.count() + r = q.offset((page - 1) * page_size).limit(page_size).all() + return total,r + except: + db.rollback() + return [],0 diff --git a/PythonProject/schema/student_schema.py b/PythonProject/schema/student_schema.py index 307b556..2d9c631 100644 --- a/PythonProject/schema/student_schema.py +++ b/PythonProject/schema/student_schema.py @@ -1,5 +1,5 @@ from datetime import date -from typing import Self +from typing import Self,List from pydantic import BaseModel, field_serializer, field_validator,model_validator @@ -10,12 +10,12 @@ class StudentRequest(BaseModel): age:int |None = None gender:str |None = None native_place:str |None = None - birthday:date + birthday:date |None = None school:str |None = None major:str |None = None degree:str |None = None - admission_date:date - graduation_date:date + admission_date:date |None = None + graduation_date:date |None = None @field_validator('age') @classmethod def check_age(cls, v): @@ -51,16 +51,32 @@ class StudentResponse(BaseModel): class StugetResponse(BaseModel): code:int = 200 detail:str = 'ok' + class_id: int | None = None + stu_name: str | None = None + age: int | None = None + gender: str | None = None + native_place: str | None = None + birthday: date | 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(cls, progress: int): + d1 = { + 0: '学习中', + 1: '求职中', + 2: '已就业' + } + return d1.get(progress, '暂不明确') + +class StudentPageResponse(BaseModel): + code: int = 200 + detail: str = "ok" page: int page_size: int - class_id: int - stu_name: str - age: int - gender: str - native_place: str - birthday: date - school: str - major: str - degree: str - admission_date: date - graduation_date: date \ No newline at end of file + total: int + data: List[StugetResponse] \ No newline at end of file From a47b79770bcc8d5e657430cf4ccd767da1ea5920 Mon Sep 17 00:00:00 2001 From: maruizhi <3088243241@qq.com> Date: Mon, 21 Sep 2026 18:14:20 +0800 Subject: [PATCH 10/11] mrz --- PythonProject/api/statistics_api.py | 7 +++---- PythonProject/dao/statistics_dao.py | 2 +- PythonProject/main.py | 8 +------- PythonProject/schema/statistics_schema.py | 4 ++++ 4 files changed, 9 insertions(+), 12 deletions(-) diff --git a/PythonProject/api/statistics_api.py b/PythonProject/api/statistics_api.py index ab3141d..f934c21 100644 --- a/PythonProject/api/statistics_api.py +++ b/PythonProject/api/statistics_api.py @@ -1,7 +1,7 @@ from fastapi import APIRouter,Depends from dao.statistics_dao import select_all,select_age,select_score,select_avg_score,select_salary,select_days from schema.student_schema import StudentResponse -from schema.statistics_schema import AllStuResponse,AvgDayResponse +from schema.statistics_schema import AllStuResponse,AvgDayResponse,AcgScoreResponse from util.database import get_db StatisticsAPI = APIRouter() @@ -21,10 +21,10 @@ def get_students(min_score:int|None=None,max_score:int|None=None,db=Depends(get_ l = select_score(min_score,max_score,db) return [i for i in l] -@StatisticsAPI.get("/avg_score",response_model=StudentResponse,tags=['统计分析模块'],summary='统计每次考试每个班级的平均分并排序') +@StatisticsAPI.get("/avg_score",response_model=list[AcgScoreResponse],tags=['统计分析模块'],summary='统计每次考试每个班级的平均分并排序') def get_scores(db=Depends(get_db)): l = select_avg_score(db) - return [i for i in l] + return l @StatisticsAPI.get("/salary",response_model=list[StudentResponse],tags=['统计分析模块'],summary='统计薪资最高的前五名的学员信息') def get_scores(db=Depends(get_db)): @@ -35,4 +35,3 @@ def get_scores(db=Depends(get_db)): def get_days(db=Depends(get_db)): l = select_days(db) return l - diff --git a/PythonProject/dao/statistics_dao.py b/PythonProject/dao/statistics_dao.py index 774fb74..52658c8 100644 --- a/PythonProject/dao/statistics_dao.py +++ b/PythonProject/dao/statistics_dao.py @@ -49,7 +49,7 @@ def select_score(min_score,max_score,db): # 实现统计每次考试每个班级的平均分并排序的功能 def select_avg_score(db): try: - l1 = db.query(func.avg(WlScore.score))\ + l1 = db.query(Student_Model.class_id,func.avg(WlScore.score).label('avg_score'))\ .join(Student_Model,WlScore.stu_id == Student_Model.stu_id)\ .filter(WlScore.delete_status==0,Student_Model.delete_status == 0)\ .group_by(Student_Model.class_id)\ diff --git a/PythonProject/main.py b/PythonProject/main.py index 9223bc4..c944c14 100644 --- a/PythonProject/main.py +++ b/PythonProject/main.py @@ -1,5 +1,4 @@ from fastapi import FastAPI - from api.employment_api import emp_api from api.student_api import StudentAPI from api.statistics_api import StatisticsAPI @@ -9,12 +8,7 @@ app = FastAPI(title='沃林学⽣管理系统') app.include_router(StudentAPI) app.include_router(StatisticsAPI) - app.include_router(teacher_api) app.include_router(emp_api) - - -if __name__ == '__main__': - import uvicorn - uvicorn.run("main:app",host='0.0.0.0',port=12310) +app.include_router(gradeAPI) app.include_router(gradeAPI) diff --git a/PythonProject/schema/statistics_schema.py b/PythonProject/schema/statistics_schema.py index 4c967e0..ab8e87b 100644 --- a/PythonProject/schema/statistics_schema.py +++ b/PythonProject/schema/statistics_schema.py @@ -5,6 +5,10 @@ class AllStuResponse(BaseModel): gender: str | None cnt: int +class AcgScoreResponse(BaseModel): + class_id: int + avg_score: float + class AvgDayResponse(BaseModel): class_id: int avg_days: str | None From b23fe9eafd6c4d0edd1cdb0d9a412cb0e93063f6 Mon Sep 17 00:00:00 2001 From: maruizhi <3088243241@qq.com> Date: Mon, 21 Sep 2026 18:21:31 +0800 Subject: [PATCH 11/11] mrz --- 需求文档.md | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/需求文档.md b/需求文档.md index d6eb866..4e1059b 100644 --- a/需求文档.md +++ b/需求文档.md @@ -18,10 +18,6 @@ wl_class（班级编号，开课时间，删除状态(0：已删除,1：初始 ⽼师管理表 **sgt 做完了** wl_teacher（老师编号，姓名，性别，年龄，删除状态(0：已删除,1：初始值)，职位，作成时间，更新时间） -dao层（每一个功能就是一个函数，判断能否功能复用） - -通用模块 - 学生模块 实现增加学生的功能 **msj 做成中** 实现查询学生的功能：需要能进行多条件查询 **msj 做成中** @@ -56,8 +52,8 @@ dao层（每一个功能就是一个函数，判断能否功能复用） 实现根据年龄查询学生信息的功能 **mrz 已作成** 实现统计每个班级的学员总数以及男女生的总数的功能 **mrz 已作成** 实现根据成绩查询学员信息的功能 **mrz 已作成** -实现统计每次考试每个班级的平均分并排序的功能 **mrz 做成中** -实现统计薪资最高的前五名的学员信息 **mrz 做成中** +实现统计每次考试每个班级的平均分并排序的功能 **mrz 已作成** +实现统计薪资最高的前五名的学员信息 **mrz 已作成** 实现查询每个学生的就业时长 **msj 做成中** -实现统计每个班级的平均就业时长 **xxx 做成中** +实现统计每个班级的平均就业时长 **xxx 已作成**