模块解释

.env

@@ -0,0 +1,7 @@
+# .env（放项目根目录，每个人自己建，不提交 Git）
+    # 用来修改数据库账户密码
+DB_USER=root
+DB_PASSWORD=420821
+DB_HOST=localhost
+DB_PORT=3306
+DB_NAME=student_manage_system

README.md

@@ -10,35 +10,23 @@
 2.教师信息的新增\
 3.教师信息的更新\
 4.教师信息的逻辑删除\
-    4.1输入id查\
-    4.2输入任意信息查\
-5.学科信息的新增\
 **dao数据筛选文件**\
 1.查询 get_tea_dao:\
 2.新增 add_tea_dao:\
 3.更新 update_tea_dao:\
-4.根据教师id逻辑删除 delete_tea_dao:\
-5.任意信息逻辑删除\
-6.科目信息的新增\
+4.逻辑删除 delete_tea_dao:\
 **tea_model数据库建表文件**\
 1.教师表\
-2.科目表\
 字段名：id、name、sex、class_id、sub（学科）\
 home_place specialty（专业）、start_time（入职时间）\
 work_experience、collage、creat_date、update_date\
-is_delete、delete_time、phone\
+is_delete、delete_time\
 2.学科表\
-字段名：id，name(科目名字)\
+字段名：id，name(科目名字)
 **schema 请求体、响应体**\
-教师表\
-请求体：\
-1.查询、任意逻辑删除调用
-2.新增、更改时调用
-响应体:用于返回给前端\
-科目表：\
-1.请求体：新增科目时调用
-
-
+请求体：设置了两个，一个带自增组件用于查询\
+一个不带自增组件，新增用；\
+响应体:用于返回给前端
 
 
 

StatCalc/api/statcalc_api.py

@@ -2,12 +2,13 @@
 
 from fastapi import APIRouter , Depends , HTTPException
 from StatCalc.dao.statcalc_dao import *
+from StatCalc.model.statcalc_model import *
 from StatCalc.schema.statcalc_request import *
 from databases import *
 
 statcalc_api = APIRouter()
 
-@statcalc_api.get("/statcalc/age"
+@statcalc_api.get("/statcalc"
     ,summary='人员信息查询'
     ,description=f'查询所有超过30岁的学员的信息。'
                   )
@@ -17,49 +18,95 @@ def get_students(db=Depends(get_db)):
         return result
     raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
 
-@statcalc_api.get("/statcalc/students"
+@statcalc_api.get("/statcalc"
     ,summary='人数统计'
     ,description=f'统计每个班级的人数以及男生女生的人数。'
                   )
-def get_students(headcount:get_student_dao
+def get_students(g:get_student_dao = Depends()
                  ,db=Depends(get_db)
                  ):
-    result = get_class_count( g=headcount , db=db )
+    result = get_class_count( g=g , db=db )
     if result:
         return result
     raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
 
-@statcalc_api.get("/statcalc/scores"
+@statcalc_api.get("/statcalc"
     ,summary='80分以上成绩学生信息查询'
     ,description=f'查询每次考试成绩都在80分以上的学生的编号，姓名和成绩。'
                   )
 def get_students(db=Depends(get_db)):
-    result = get_score_80( db=db )
+    result = get_student_dao( db=db )
     if result:
         return result
     raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
 
-@statcalc_api.get("/statcalc/fail"
+@statcalc_api.get("/statcalc"
     ,summary='不及格成绩查询'
     ,description=f'查询有两次以上不及格的学生的姓名，班级和不及格成绩。'
                   )
-def get_students( db=Depends(get_db)  ):
-    result = get_score_80( db=db )
+def get_students( stu:StudentsQuery = Depends()
+                 , db=Depends(get_db)
+                  ):
+    s_dict = stu.model_dump(exclude_unset=True) # 没值的不要
+    result = get_student_dao( s=s_dict , db=db )
     if result:
         return result
     raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
 
-@statcalc_api.get('/statcalc/average', summary='统计每次考试每个班级的平均分')
-def get_class_avg(db=Depends(get_db)):
-    result = get_class_avg_dao(db)
-    if not result:
-        return []
-    return result
+@statcalc_api.get("/statcalc"
+    ,summary='班级平均分查询'
+    ,description=f'统计每次考试每个班级的平均分，按照从高到低排序。'
+                  )
+def get_students( stu:StudentsQuery = Depends()
+                 , db=Depends(get_db)
+                  ):
+    s_dict = stu.model_dump(exclude_unset=True) # 没值的不要
+    result = get_student_dao( s=s_dict , db=db )
+    if result:
+        return result
+    raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
+
+@statcalc_api.get("/statcalc"
+    ,summary='排名前五的学生信息'
+    ,description=f'统计就业薪资最高的前五名学生的姓名，班级和就业时间，就业公司。'
+                  )
+def get_students( stu:StudentsQuery = Depends()
+                 , db=Depends(get_db)
+                  ):
+    s_dict = stu.model_dump(exclude_unset=True) # 没值的不要
+    result = get_student_dao( s=s_dict , db=db )
+    if result:
+        return result
+    raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
+
+@statcalc_api.get("/statcalc"
+    ,summary='就业时长统计'
+    ,description=f'统计每个学生的就业时长（offer下发时间-就业开放时间）。'
+                  )
+def get_students( stu:StudentsQuery = Depends()
+                 , db=Depends(get_db)
+                  ):
+    s_dict = stu.model_dump(exclude_unset=True) # 没值的不要
+    result = get_student_dao( s=s_dict , db=db )
+    if result:
+        return result
+    raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
+
+@statcalc_api.get("/statcalc"
+    ,summary='班级的平均就业时长'
+    ,description=f'统计每个班级的平均就业时长（只统计进入就业阶段的学生，也就是有就业开放时间）'
+                  )
+def get_students( stu:StudentsQuery = Depends()
+                 , db=Depends(get_db)
+                  ):
+    s_dict = stu.model_dump(exclude_unset=True) # 没值的不要
+    result = get_student_dao( s=s_dict , db=db )
+    if result:
+        return result
+    raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
 
 
-from stu_jiuye.model import *
-
-@statcalc_api.get('/statcalc/top',summary='就业薪资Top5')
+@CURD.get('/Top5',summary='就业薪资Top5')
 def salarytop5(db=Depends(get_db)):
     q = db.query(Employments,Company.employment_company) \
     .join(Company, Employments.company_id == Company.id) \
@@ -68,19 +115,16 @@ def salarytop5(db=Depends(get_db)):
     .limit(5) .all()
     return [{'学生姓名':i.sname,'学生班级编号':i.class_num,'就业时间':i.offer_recived_time,'公司':employment_company} for i,employment_company in q]
 
-@statcalc_api.get('/statcalc/job',summary='学生就业时长')
+@CURD.get('/worktime',summary='学生就业时常')
 def worktime(db=Depends(get_db)):
     q = db.query(Employments)\
         .filter(Employments.is_deleted==0)\
             .all()
 
-    return [
-            {'学生姓名':i.sname
-            ,'就业时常':f'{i.offer_recived_time-i.employment_open_time}'
-            if i.offer_recived_time and i.employment_open_time else '暂无数据'} for i in q
-            ]
+    return [{'学生姓名':i.sname,'就业时常':f'{i.offer_recived_time-i.employment_open_time}' if i.offer_recived_time and i.employment_open_time else '暂无数据'} for i in q]
 
-@statcalc_api.get('/statcalc/avgjob',summary='学生平均就业时长')
+
+@CURD.get('/avgworktime',summary='学生平均就业时常')
 def avgworktime(db=Depends(get_db)):
     q = db.query(Employments)\
         .filter(Employments.employment_open_time.isnot(None)
@@ -95,4 +139,3 @@ def avgworktime(db=Depends(get_db)):
         '人数': len(q),
         '平均就业时常(天)': round(avg_days, 2)
     }
-

StatCalc/dao/statcalc_dao.py

@@ -39,38 +39,10 @@ def get_class_count(g , db):
 from scores.model.score_model import Score
 
 def get_score_80(db):
-    sq = ( db.query(Students.id)
-           .join(Score, Score.sid == Students.id)
-           .filer(Score.score < 80 )
-           .group_by(Students.id)
-           .having(func.count(Score.id) > 2 )
-           .sq()
-         )
-
-    q = ( db.query(Students.name,ClassInfo.name,Score.score )
-          .join(ClassInfo, ClassInfo.id == Students.class_id)
-          .join(Score, Score.sid == Students.id)
-          .filer(Students.id.in_(sq),Score.score < 80)
-          .all()
-         )
+    q = (db.query(Score)
+         .filter(Score.score>=80)
+         .all())
     return q
 
-def get_class_avg_dao(db):
-    results = (db.query(Score.num,
-            Score.cid,
-            ClassInfo.name.label("class_name"),
-            func.avg(Score.score).label("avg_score"))
-        .join(ClassInfo, Score.cid == ClassInfo.id)
-        .filter(Score.is_deleted == 0)
-        .group_by(Score.num, Score.cid, ClassInfo.name)
-        .order_by(func.avg(Score.score).desc())
-        .all())
-
-    return [ {"num": r.num,
-            "cid": r.cid,
-            "class_name": r.class_name,
-            "avg_score": round(float(r.avg_score), 2),}
-        for r in results]
-
 
 

StatCalc/main.py

@@ -1,6 +1,7 @@
 from fastapi import FastAPI,APIRouter
 from StatCalc.api.statcalc_api import statcalc_api
 from databases import *
+from StatCalc.model import statcalc_model
 from contextlib import asynccontextmanager
 
 StatCalc_API = APIRouter()

StatCalc/schema/statcalc_request.py

@@ -4,7 +4,7 @@ from pydantic import BaseModel , Field , field_validator
 from datetime import datetime
 import enum
 
-class get_student_dao(str , enum.Enum):
+class get_student_dao(enum.Enum):
     get_class = "班级人数"
     get_sex = "男女人数"
     get_class_sex = "班级中男女人数"

Teachers/api/tea_api.py

@@ -3,15 +3,14 @@ from Teachers.schema import *
 from Teachers.database  import *
 from Teachers.model.tea_model import *
 from Teachers.dao.tea_dao import *
-from Teachers.schema.tea_request import TeaRequest,NewTeaRequest,NewTeaRequest1,SubRequest
+from Teachers.schema.tea_request import TeaRequest,NewTeaRequest,NewTeaRequest1
 from Teachers.schema.tea_response import TeaResponse
 
-
 tea_api = APIRouter()
 
 @tea_api.post('/tea',response_model=TeaResponse,summary='新增老师',description='输入新增的老师信息，除去姓名外可以为空')
 def add_tea(tea: NewTeaRequest=Depends(),db=Depends(get_db)):
-    r = add_tea_dao(tea.model_dump(exclude_unset=True),db)
+    r = add_tea_dao(tea.model_dump(),db)
     if not r:
         raise HTTPException(status_code=500,detail='添加失败！')
     return TeaResponse(totals=1,data=tea.model_dump())
@@ -44,12 +43,4 @@ def delete_other_tea_dao1(t:TeaRequest=Depends(),db=Depends(get_db)):
         raise HTTPException(status_code=404,detail='没有找到符合条件的老师')
     return{'code':200,'data':row1}
 
-#新增科目
-@tea_api.post('/subject',summary='新增科目',description='输入新增的科目')
-def add_sub(t:SubRequest=Depends(),db=Depends(get_db)):   #开启会话窗口
-    r = add_subject_dao(t.model_dump(),db=db)
-    if r=='已存在':
-        raise HTTPException(status_code=500,detail='科目已存在')
-    return TeaResponse(totals=len(r), data=r)
-
 

Teachers/dao/tea_dao.py

@@ -1,6 +1,4 @@
-from sys import excepthook
-
-from Teachers.model.tea_model import Tea,Sub
+from Teachers.model.tea_model import Tea
 from datetime import datetime
 
 #增加
@@ -50,8 +48,8 @@ def get_tea_dao(t,db):
         query = query.filter(Tea.sex == t.get('sex') )
     if t.get('class_id'):
         query = query.filter(Tea.class_id == t.get('class_id') )
-    if t.get('subject_id'):
-        query = query.filter(Tea.subject_id == t.get('subject_id') )
+    if t.get('sub'):
+        query = query.filter(Tea.sub == t.get('sub') )
     if t.get('home_place'):
         query = query.filter(Tea.home_place == t.get('home_place') )
     if t.get('specialty'):
@@ -67,7 +65,7 @@ def get_tea_dao(t,db):
     if t.get('phone'):
         query = query.filter(Tea.phone == t.get('phone') )
     r = query.all()
-    return [{'id':i.id,'name':i.name,'class_id':i.class_id,'sub':i.subject_id,'sex':i.sex,'home_place':i.home_place
+    return [{'id':i.id,'name':i.name,'class_id':i.class_id,'sub':i.sub,'sex':i.sex,'home_place':i.home_place
                 ,'specialty':i.specialty,'start_time':i.start_time,'work_experience':i.work_experience
                 ,'collage':i.collage,'phone':i.phone} for i in r]
 
@@ -98,8 +96,8 @@ def delete_other_tea_dao(t,db):
             query1 = query1.filter(Tea.sex == t.get('sex'))
         if t.get('class_id'):
             query1 = query1.filter(Tea.class_id == t.get('class_id'))
-        if t.get('subject_id'):
-            query1 = query1.filter(Tea.subject_id == t.get('subject_id'))
+        if t.get('sub'):
+            query1 = query1.filter(Tea.sub == t.get('sub'))
         if t.get('home_place'):
             query1 = query1.filter(Tea.home_place == t.get('home_place'))
         if t.get('collage'):
@@ -124,21 +122,3 @@ def delete_other_tea_dao(t,db):
 
 
 
-def add_subject_dao(t,db):
-    try:
-        t1 = db.query(Sub).filter(Sub.name == t.get('name')).first()
-        if t1:
-            return'已存在'
-        s1 = Sub(**t)
-        db.add(s1)
-        db.commit()
-        return '[s1]'
-    except InterruptedError as e:
-        db.rollback()
-        print('失败的原因',e)
-        return False
-    except Exception as e:
-        db.rollback()
-        return f'{e}'
-
-

Teachers/database.py

@@ -24,5 +24,4 @@ def get_db():
         yield db
     finally:
         db.close()
-#建表
 Base.metadata.create_all(engine1)

Teachers/main.py

@@ -9,13 +9,13 @@ Teachers_API.include_router(tea_api)
 
 # 自测接口
 app = FastAPI()
+app.include_router(tea_api,tags=["老师"])
+
+Base.metadata.create_all(engine1)
 
 if __name__ == "__main__":
-    app.include_router(tea_api, tags=["老师"])
-    Base.metadata.create_all(engine1)
-
     import uvicorn
-    uvicorn.run('main:app', host='0.0.0.0', port=57000)
+    uvicorn.run('main:app', host='0.0.0.0', port=55000)
     """
     IPv4 地址 . . . . . . . . . . . . : 192.168.1.51
     子网掩码  . . . . . . . . . . . . : 255.255.255.0

Teachers/model/tea_model.py

@@ -16,14 +16,17 @@ class Tea(Base_all):
                     ,autoincrement=True
                     ,comment='id')
     name = Column(String(50)
+                      ,nullable=False
                       ,comment='姓名')
     sex = Column(Enum(Gender),default='未知'
                      ,comment='性别')
     class_id = Column(Integer
+                      ,nullable=False
                       ,comment='班级id')
     phone = Column(String(50))
     subject_id = Column(Integer
                         , ForeignKey('subject.id')
+                       ,nullable=False
                        ,comment='教学科目')
     home_place = Column(String(50)
                         ,comment='家乡')

Teachers/schema/tea_request.py

@@ -1,4 +1,4 @@
-from pydantic import BaseModel,Field
+from pydantic import BaseModel
 from Teachers.model.tea_model import *
 
 #查询使用请求体，都可以为空
@@ -7,8 +7,8 @@ class TeaRequest(BaseModel):
     name: str|None = None
     sex: Gender|None = None
     class_id: int | None = None
-    subject_id: str|None = None
-    phone: str | None
+    sub: str|None = None
+    phone: str|None = None
     home_place: str|None = None
     collage: str|None = None
     education: str|None = None
@@ -22,9 +22,9 @@ class NewTeaRequest(BaseModel):
     name: str | None = None
     sex: Gender|None = None
     class_id: int | None = None
-    subject_id: int | None = None
+    sub: str | None = None
     home_place: str | None = None
-    phone: str | None = Field(default=None, min_length=11, max_length=11)
+    phone: str
     collage: str | None = None
     education: str | None = None
     work_experience: str | None = None
@@ -35,14 +35,11 @@ class NewTeaRequest1(BaseModel):
     name: str | None = None
     sex: Gender|None = None
     class_id: int | None = None
-    subject_id: int | None = None
+    sub: str | None = None
     home_place: str | None = None
-    phone: str | None = Field(default=None, min_length=11, max_length=11)
+    phone: str|None = None
     collage: str | None = None
     education: str | None = None
     work_experience: str | None = None
     start_time: datetime | None = None
     specialty: str | None = None
-
-class SubRequest(BaseModel):
-    name: str

class_management/api/class_management_api.py

@@ -7,52 +7,24 @@ from class_management.schema.class_management_request import ClassCreate, ClassR
 class_api = APIRouter(prefix='/classes')
 # ,tags=['班级管理模块']
 
-#新增接口
+
 @class_api.post("",summary='新增班级')
 def add_class(cla:ClassCreate,db=Depends(get_db)):
     c_dict = cla.model_dump()
-    res = add_class_dao(c=c_dict,db=db)
-    if not res:
-        raise HTTPException(status_code=400,detail='新增失败，班级已存在')
-    return ClassResponse(detail='新增成功',totals=1,data=c_dict)
+    r = add_class_dao(c=c_dict,db=db)
+    if not r:
+        raise HTTPException(status_code=500,detail='服务器繁忙，请稍后添加!')
+    return ClassResponse(totals=1,data=c_dict)
 
 
-#更新接口
-@class_api.put("/{class_id}",summary='修改班级信息')
-def update_class(class_id:int
-                 ,update_info:ClassUpdate
-                 ,db=Depends(get_db)
-                 ):
-    update_dict=update_info.model_dump(exclude_unset=True)
-    if not update_dict:
-        raise HTTPException(status_code=400, detail="没有传入要修改的字段")
-    row_count = update_class_dao(cid=class_id, update_data=update_dict, db=db)
-    if not row_count :
-        raise HTTPException(status_code=404, detail="班级不存在，修改失败")
-    return ClassResponse(detail="修改成功", data={"id": class_id})
-
-
-#删除接口
-@class_api.delete('/{class_id}',summary='逻辑删除班级')
-def remove_class(class_id:int,db=Depends(get_db)):
-    del_rows = delete_class_dao(cid = class_id,db=db)
-    if not del_rows:
-        raise HTTPException(status_code=404, detail="班级不存在，删除失败")
-    return ClassResponse(detail='删除成功',data={'id':class_id})
-
-
-
-#单条查询接口
-@class_api.get('/{class_id}',summary='根据id查询班级')
-def get_one_class(class_id:int,db=Depends(get_db)):
-    res = get_class_dao(c={'id':class_id},db=db)
+@class_api.get('/{id}',summary='根据id查询班级')
+def get_one_class(id:int,db=Depends(get_db)):
+    res = get_class_dao(c={'id':id},db=db)
     if not res:
         raise HTTPException(status_code=404, detail="该班级不存在或已删除")
     return ClassResponse(totals=1,data=res[0])
 
-
-#分类查询
-@class_api.get('',summary='多字段分页查询班级')
+@class_api.get('',summary='多字段查询班级')
 def get_some_classes( num:str|None = Query(None,description='班级编号')
                      ,name:str|None = Query(None,description='班级名称')
                      ,head_teacher_id:int|None = Query(None,description='班主任')
@@ -61,9 +33,10 @@ def get_some_classes( num:str|None = Query(None,description='班级编号')
                      ,class_start_time:date|None = Query(None, description="开班日期，格式YYYY‑MM‑DD")
                      ,class_end_time: date|None = Query(None, description="结课日期，格式YYYY‑MM‑DD")
                      ,page:int = Query(1,ge=1,description='页码，从1开始')
-                     ,page_size:int = Query(5,ge=1,le=20,description='每页信息条数')
+                     ,page_size:int = Query(5,ge=1,le=50,description='每页信息条数')
                      ,db=Depends(get_db)
                      ):
+
     c_dict = {
         'num': num,
         'name': name,
@@ -79,7 +52,7 @@ def get_some_classes( num:str|None = Query(None,description='班级编号')
     res = get_class_dao(c=c_dict,db=db)
     total = len(res)
 
-    #分页
+    #内存分页
     start_index = (page-1)*page_size
     page_data = res[start_index:start_index + page_size]
 
@@ -88,3 +61,23 @@ def get_some_classes( num:str|None = Query(None,description='班级编号')
 
 
 
+@class_api.put("/{class_id}",summary='修改班级信息')
+def update_class(class_id:int
+                 ,update_info:ClassUpdate
+                 ,db=Depends(get_db)
+                 ):
+    update_dict=update_info.model_dump(exclude_unset=True)
+    if not update_dict:
+        raise HTTPException(status_code=400, detail="没有传入要修改的字段")
+    row_count = update_class_dao(cid=class_id, update_data=update_dict, db=db)
+    if row_count <= 0:
+        raise HTTPException(status_code=404, detail="班级不存在，修改失败")
+    return ClassResponse(detail="修改成功", data={"class_id": id})
+
+
+@class_api.delete('/{id}',summary='逻辑删除班级')
+def remove_class(id:int,db=Depends(get_db)):
+    del_rows = delete_class_dao(id,db)
+    if del_rows <= 0:
+        raise HTTPException(status_code=404, detail="班级不存在，删除失败")
+    return ClassResponse(detail='删除成功',data={'id':id})

class_management/dao/class_management_dao.py

@@ -1,46 +1,6 @@
 from class_management.model.class_management_model import ClassInfo
 from sqlalchemy.orm import Session
 
-#新增班级
-def add_class_dao(c,db):
-    try:
-        c1 = ClassInfo(**c)
-        db.add(c1)
-    except:
-        db.rollback()
-        return False
-    else:
-        db.commit()
-        return True
-
-
-#更新班级信息
-def update_class_dao(cid,update_data,db):
-    try:
-        rows = db.query(ClassInfo)\
-            .filter(ClassInfo.id == cid
-                    ,ClassInfo.is_delete==0)\
-            .update(update_data)
-    except :
-        db.rollback()
-        return False
-    else:
-        db.commit()
-        return rows
-
-
-#删除(逻辑删除)
-def delete_class_dao(cid,db):
-    try:
-        rows = db.query(ClassInfo)\
-            .filter(ClassInfo.id == cid,ClassInfo.is_delete==0)\
-            .update({'is_delete':1})
-        db.commit()
-        return rows
-    except Exception as e:
-        db.rollback()
-        print('删除失败',e)
-        return 0
 
 
 #查询
@@ -74,6 +34,64 @@ def get_class_dao(c:dict,db:Session) :
         ,'tutor_teacher_id':i.tutor_teacher_id
         ,'class_start_time':i.class_start_time
         ,'class_end_time':i.class_end_time
+        ,"is_delete": i.is_delete
+        ,"create_time": i.create_time
+        ,"update_time": i.update_time
         } for i in res
             ]
 
+
+#新增班级
+def add_class_dao(c:dict,db:Session):
+    try:
+        exist_class = db.query(ClassInfo)\
+            .filter(ClassInfo.name == c['name']
+                    ,ClassInfo.is_delete == 0)\
+            .first()
+        if exist_class:
+            msg = '班级名称已存在'
+            print(msg)
+            return (False,msg)
+        c1 = ClassInfo(**c)
+        db.add(c1)
+        db.commit()
+        db.refresh(c1)
+        return (True,None)
+
+    except Exception as e:
+        db.rollback()
+        err_msg = f'数据库异常：{str(e)}'
+        print(err_msg)
+        return (False,err_msg)
+
+
+#修改
+def update_class_dao(cid:int,update_data,db):
+    try:
+        rows = db.query(ClassInfo)\
+            .filter(ClassInfo.id == cid
+                    ,ClassInfo.is_delete==0)\
+            .update(update_data)
+        db.commit()
+        return rows
+
+    except Exception as e:
+        db.rollback()
+        print(f"update_class_dao异常:{e}")
+        return 0
+
+
+
+#删除(逻辑删除)
+def delete_class_dao(cid,db):
+    try:
+        rows = db.query(ClassInfo)\
+            .filter(ClassInfo.id == cid,ClassInfo.is_delete==0)\
+            .update({'is_delete':1})
+        db.commit()
+        return rows
+    except Exception as e:
+        db.rollback()
+        print(f"delete_class_dao异常:{e}")
+        rows = 0
+

class_management/database.py

@@ -11,13 +11,14 @@ DB_HOST = os.getenv("DB_HOST", "localhost")
 DB_PORT = os.getenv("DB_PORT", "3306")
 DB_NAME = os.getenv("DB_NAME", "student_manage_system")
 
-class_management_url = "mysql+pymysql://root:123456@localhost:3306/student_manage_system?charset=utf8mb4"
+class_management_rul = f"mysql+pymysql://{DB_USER}:{DB_PASSWORD}@{DB_HOST}:{DB_PORT}/{DB_NAME}?charset=utf8mb4"
 
-engine = create_engine(class_management_url)
+engine = create_engine(class_management_rul)
 SessionLocal = sessionmaker(bind=engine,autocommit=False, autoflush=False)
 Base = declarative_base()
 
 # 获取数据库会话依赖
+
 def get_db():
     db = SessionLocal()
     try :

class_management/main.py

@@ -3,7 +3,6 @@ from class_management.api.class_management_api import class_api
 from class_management.model.class_management_model import ClassInfo
 from class_management.database import Base,engine
 
-
 # 合并接口
 Classes_API = APIRouter()
 Classes_API.include_router(class_api)
@@ -13,8 +12,8 @@ app = FastAPI()
 
 app.include_router(class_api)
 
-if __name__ =='__main__':
-    Base.metadata.create_all(engine)
+Base.metadata.create_all(engine)
 
+if __name__ =='__main__':
     import uvicorn
     uvicorn.run('main:app',host='127.0.0.1',port=12345)

class_management/model/class_management_model.py

@@ -14,7 +14,6 @@ class ClassInfo(Base_all):
                 )
     num = Column(String(50)
                  ,nullable=False
-                 ,unique=True
                  ,comment='班级编号'
                  )
     name = Column(String(50)
@@ -22,18 +21,26 @@ class ClassInfo(Base_all):
                         ,comment='班级名称'
                         )
     head_teacher_id = Column(Integer
-                            ,ForeignKey('teacher.id')
+                            # ,ForeignKey('teacher.id')
                             ,comment='班主任编号'
                             )
 
     coach_teacher_id = Column(Integer
-                              ,ForeignKey('teacher.id')
+                              # ,ForeignKey('teacher.id')
                               ,comment='授课老师编号'
                               )
     tutor_teacher_id = Column(Integer
-                              ,ForeignKey('teacher.id')
+                              # ,ForeignKey('teacher.id')
                               ,comment='助教老师编号'
                               )
+    # class_teacher = Column(String(50)
+    #                        ,nullable=False
+    #                        ,comment='班主任'
+    #                        )
+    # class_lecturer = Column(String(50)
+    #                         ,nullable=False
+    #                         ,comment='授课老师'
+    #                         )
     class_start_time = Column(Date
                               ,comment='开班日期'
                               )

class_management/schema/class_management_request.py

@@ -12,14 +12,17 @@ class ClassBase(BaseModel):
     class_start_time:date|None = Field(None,description='开班日期 YYYY‑MM‑DD')
     class_end_time:date|None = Field(None,description='结课日期 YYYY‑MM‑DD')
 
-#新增班级请求体：继承父类ClassBase
+#新增班级请求体：num,name必填，其余继承父类ClassBase
 class ClassCreate(ClassBase):
-    pass
+    num:str = Field(...,description='班级编号')
+    name:str = Field(...,description='班级名称')
 
 #修改班级请求体,继承ClassBase,全部字段可选，传哪个就更新哪个
 class ClassUpdate(ClassBase):
     pass
 
+
+
 class ClassResponse(BaseModel):
     code:int = 200
     detail:str = 'OK'

main.py

@@ -4,7 +4,7 @@ from scores.main import Scores_API
 from stu_jiuye.main import Shtudent_Jiuye
 from students.main import Students_API
 from Teachers.main import Teachers_API
-from StatCalc.main import StatCalc_API
+# from StatCalc.main import StatCalc_API
 from databases import *
 app = FastAPI(title="学生管理系统")
 
@@ -14,12 +14,12 @@ app.include_router(Scores_API,tags=["scores"])
 app.include_router(Shtudent_Jiuye,tags=["Employments"])
 app.include_router(Students_API,tags=["students"])
 app.include_router(Teachers_API,tags=["teachers"])
-app.include_router(StatCalc_API,tags=["StatCalc"])
+# app.include_router(StatCalc_API,tags=["StatCalc"])
 
 
+Base_all.metadata.create_all(bind=engine_all)
+
 if __name__ == "__main__":
-    Base_all.metadata.create_all(bind=engine_all)
-
     def main():
         print("Hello from student-manage-system!")
 

scores/README_scores.md

@@ -0,0 +1,61 @@
+#scores模块解释
+
+##项目层
+
+web框架：FastAPI(生成接口)
+
+ORM：sqlalchemy
+
+校验：MYSQL(通过PyMysql驱动)
+
+运行：uvicorn，端口12346
+
+用FastAPI显露HTTP接口 ，对MysQL的scores表进行一个增，删，改，查的动作，删除是软删除，
+
+api是接口层，成绩信息的增加，删除，更新，查询
+
+dao是数据操作层，查询get_scores_dao
+
+              更新add_scores_dao
+
+              增加update_scores_dao
+
+              删除delete_scores_dao
+
+统计查询80分以上的get_top_students_dao
+
+   查询连续两次不及格的get_failing_students_dao
+
+   班级平均分get_class_avg_dao
+
+model是数据库表模型层，字段信息   id           *pk*
+
+                            sid           链接学生表的学生ID
+
+                            cid           链接班级表的班级ID
+
+                            num           考试序次
+
+                            score         考试成绩
+
+                            t_subject     链接科目表的科目ID
+
+                            create_date   创建数据的时间
+
+                            update_date   更新数据的是时间
+
+                            is_deleted    逻辑删除
+
+                            deleted_date  删除的时间
+
+schema是请求体和响应体模型层，   查询的ScoreQuery
+
+                            更新，增加，删除的ScoreRequest
+
+databases是数据库定义配置文件， 链接引擎对象db_url，链接地址engine，
+
+                           建表的基类Base，数据库会话管理Session
+
+                           会话实例def get_db()
+
+main是主程序文件，将配置文件的接口导入，创建接口运行

stu_jiuye/main.py

@@ -8,12 +8,15 @@ Shtudent_Jiuye = APIRouter()
 Shtudent_Jiuye.include_router(CURD)
 
 # 自测接口
+
+
 app=FastAPI()
+Base.metadata.create_all(engine)
+app.include_router(CURD,tags=['就业管理系统'])
+
+
 
 if __name__=='__main__':
-    app.include_router(CURD, tags=['就业管理系统'])
-    Base.metadata.create_all(engine)
-
     import uvicorn
     uvicorn.run('main:app', host='127.0.0.1', port=12395)
 

students/main.py

@@ -8,7 +8,6 @@ from contextlib import asynccontextmanager
 Students_API = APIRouter()
 Students_API.include_router(s_api)
 
-
 # 自测接口
 @asynccontextmanager
 async def S_Fastapi(app: FastAPI):
@@ -16,11 +15,11 @@ async def S_Fastapi(app: FastAPI):
     yield
     engine1.dispose()
 
-app = FastAPI(title="学生管理系统", lifespan=S_Fastapi)  # 这里必须把上面写的加上
+app = FastAPI(title="学生管理系统",lifespan=S_Fastapi) # 这里必须把上面写的加上
+app.include_router(s_api,tags=["students"])
+
 
 if __name__ == "__main__":
-    app.include_router(s_api, tags=["students"])
-
     def main():
         print("Hello from student-manage-system!")
 

students/schema/students_request.py

@@ -4,7 +4,7 @@ from pydantic import BaseModel , Field , field_validator
 from datetime import datetime
 import enum
 
-class SexEnum(str , enum.Enum):
+class SexEnum(enum.Enum):
     m = '男'
     f = '女'
 
@@ -27,7 +27,7 @@ class StudentsQuery(BaseModel):
     # 额外字段
     phone:str | None = None
 
-class EducationEnum(str , enum.Enum):
+class EducationEnum(enum.Enum):
     z = '专科'
     ben = '本科'
     s = '硕士'