Merge remote-tracking branch 'origin/conding' into conding

# Conflicts: # PythonProject/api/student_api.py # PythonProject/dao/statistics_dao.py
2026-09-21 18:10:35 +08:00
parent e5c2284ad1 44f2d89f62
commit 21ab22daa6
18 changed files with 378 additions and 111 deletions
@@ -0,0 +1,85 @@
+from model.all_model import ClassManagement
+from fastapi import HTTPException
+from schema.cla_schema import claRequest
+
+
+def add_class_dao(c:claRequest,session):
+    try:
+        data = c.model_dump()
+        d = ClassManagement(**data)
+        session.add(d)
+    except:
+        session.rollback()
+        return '输入有误，请重新添加班级!'
+    else:
+        session.commit()
+        return '添加成功！'
+
+def get_class_dao(session):
+    try:
+        class_list=session.query(ClassManagement).filter(ClassManagement.delete_status==0).all()
+        return class_list
+    except:
+        raise HTTPException(status_code=406,detail="输入查询信息有误，请重新输入！")
+
+def update_class_dao(id:int,req:ClassManagement,session):
+    try:
+        session.query(ClassManagement).filter(ClassManagement.class_id==id)\
+        .filter(ClassManagement.delete_status==0).update(req.model_dump(exclude_unset=True))
+        session.commit()
+    except:
+        raise HTTPException(status_code=400,detail="更新格式错误或参数缺失，请重新输入！")
+    return '更新成功，请核对信息！'
+
+def delete_class(id:int,session):
+    try:
+        session.query(ClassManagement).filter(ClassManagement.class_id==id,ClassManagement.delete_status==0)\
+        .update({'delete_status': 1})
+        session.commit()
+    except:
+        raise HTTPException(status_code=404, detail="删除异常,请重新核对之后删除！")
+    return '删除成功，请核对信息！'
+
+def get_class_for_delete(id: int, session):
+    try:
+        obj = (
+            session.query(ClassManagement).filter(ClassManagement.class_id == id,ClassManagement.delete_status == 0).first()
+        )
+        if not obj:
+            raise HTTPException(status_code=404, detail="班级不存在")
+    except HTTPException:
+        raise
+    except Exception:
+        raise HTTPException(status_code=500, detail="查询异常，请重新核对！")
+
+    return {
+        "class_id": obj.class_id,
+        "class_name": obj.class_name,
+        "start_class_date": obj.start_class_date,
+        "head_teacher_id": obj.head_teacher_id,
+        "class_teacher_id": obj.class_teacher_id,
+    }
+
+
+def hard_delete_class(id: int, session):
+    try:
+        obj = (
+            session.query(ClassManagement).filter(ClassManagement.class_id == id,ClassManagement.delete_status == 0)
+            .first()
+        )
+        if not obj:
+            raise HTTPException(status_code=404, detail="班级不存在")
+
+        session.delete(obj)
+        session.commit()
+    except HTTPException:
+        raise
+    except Exception:
+        session.rollback()
+        raise HTTPException(status_code=500, detail="删除异常，请重新核对之后删除！")
+
+    return '删除成功，请核对信息！'
+
+
+
+
@@ -0,0 +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 EmploymentRequest
+
+def get_employment_dao(stu_id,class_id,db=Depends(get_db())):
+    try:
+        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:
+        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
@@ -2,14 +2,23 @@ from fastapi import Depends,HTTPException

 from util.database import get_db

-from model.grade_model import *
+from model.all_model import *


-def get_grade_dao( stu_id:int
-              ,db=Depends(get_db)):
+def get_grade_dao( stu_id:int , db):

    r1 =db.query(WlScore).filter(WlScore.stu_id == stu_id,WlScore.delete_status == 0).all()
    if r1:
        return r1
    else:
        raise HTTPException(status_code=404,detail="学生不存在")
+
+def add_grade_dao(g,db):
+    try:
+        o1 = WlScore(**g)
+        db.add(o1)
+        db.commit()
+        return o1
+    except Exception:
+        db.rollback()
+        return None
@@ -1,61 +1,93 @@
-from datetime import datetime
-
-from fastapi import HTTPException,Depends
+from fastapi import HTTPException
 from sqlalchemy import func
 from model.all_model import Student_Model,WlScore,Employment_info
-from util.database import get_db

 # 实现根据年龄查询学生信息的功能
-def select_age(min_age,max_age,session=Depends(get_db)):
+def select_age(min_age,max_age,db):
    try:
        if min_age is None and max_age is None:
            raise HTTPException(status_code=400, detail="请至少传入一个参数")
-        session = session.query(Student_Model)
+        db = db.query(Student_Model)
        if min_age is not None:
-            session = session.filter(Student_Model.age >= min_age,Student_Model.delete_status == 0)
+            db = db.filter(Student_Model.age >= min_age,Student_Model.delete_status == 0)
        if max_age is not None:
-            session = session.filter(Student_Model.age <= max_age,Student_Model.delete_status == 0)
-        return session.all()
+            db = db.filter(Student_Model.age <= max_age,Student_Model.delete_status == 0)
+        print('abc',db.all())
+        return db.all()
    except HTTPException:
        raise
    except Exception:
        raise HTTPException(status_code=500,detail="查询异常")

 # 实现统计每个班级的学员总数以及男女生的总数的功能
-def select_all(session=Depends(get_db)):
-    print('1234')
+def select_all(db):
    try:
-        l1 = session.query(Student_Model.class_id,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="查询异常")

 # 实现根据成绩查询学员信息的功能
-def select_score(min_score,max_score,session=Depends(get_db)):
+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="请至少传入一个参数")
-        session = session.query(Student_Model,WlScore.score,WlScore.score)\
-            .join(WlScore,WlScore.stu_id == Student_Model.stu_id,WlScore.delete_status==0,WlScore.delete_status == 0)
+        db = db.query(Student_Model,WlScore.score,WlScore.score)\
+                .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:
-            session = session.filter(WlScore.score >= min_score)
+            db = db.filter(WlScore.score >= min_score)
        if min_score is not None:
-            session = session.filter(WlScore.score <= max_score)
-        return session.all()
+            db = db.filter(WlScore.score <= max_score)
+        return db.all()
    except HTTPException:
        raise
    except Exception:
        raise HTTPException(status_code=500,detail="查询异常")

-#实现查询每个学生的就业时长
-def select_emp_duration(stu_id:int,session):
+# 实现统计每次考试每个班级的平均分并排序的功能
+def select_avg_score(db):
    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,
+        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="查询异常")

-                    Employment_info.offer_issuance_date:i.offer_issuance_date,
-                    Employment_info.company_name:i.company_name})
@@ -3,7 +3,7 @@ from model.all_model import Teacher_Model
 from util.database import *
 from schema.teacher_schema import Teacher_RequestModel

-def add_teacher(req:Teacher_RequestModel,session=Depends(get_db)):
+def add_teacher(req:Teacher_RequestModel,session):
    try:
        data=req.model_dump()
        session.add(Teacher_Model(**data))
@@ -12,14 +12,14 @@ def add_teacher(req:Teacher_RequestModel,session=Depends(get_db)):
        raise HTTPException(status_code=500,detail="添加异常！")
    return req.model_dump()

-def select_teacher(session=Depends(get_db)):
+def get_teacher(session):
    try:
        teacher_list=session.query(Teacher_Model).filter(Teacher_Model.delete_status==0).all()
        return teacher_list
    except:
        raise HTTPException(status_code=500,detail="查询异常！")

-def update_teacher(id:int,req:Teacher_RequestModel,session=Depends(get_db)):
+def update_teacher(id:int,req:Teacher_RequestModel,session):
    try:
        session.query(Teacher_Model).filter(Teacher_Model.teac_id==id)\
        .filter(Teacher_Model.delete_status==0).update(req.model_dump(exclude_unset=True))
@@ -27,7 +27,7 @@ def update_teacher(id:int,req:Teacher_RequestModel,session=Depends(get_db)):
    except:
        raise HTTPException(status_code=500,detail="更新异常！")

-def delete_teacher(id:int,session=Depends(get_db)):
+def delete_teacher(id:int,session):
    try:
        session.query(Teacher_Model).filter(Teacher_Model.teac_id==id,Teacher_Model.delete_status==0)\
            .update({'delete_status':1})