调整IP、端口地址。

# Conflicts:
#	class_management/dao/class_management_dao.py
#	class_management/main.py
#	students/README_students.md

StatCalc/api/statcalc_api.py

@@ -1,6 +1,6 @@
 # statcalc_api所有统计分析模块的api路由、接口
 
-from fastapi import APIRouter , Depends , HTTPException
+from fastapi import APIRouter , Depends , HTTPException , Query
 from StatCalc.dao.statcalc_dao import *
 from StatCalc.schema.statcalc_request import *
 from databases import *
@@ -9,13 +9,13 @@ statcalc_api = APIRouter()
 
 @statcalc_api.get("/statcalc/age"
     ,summary='人员信息查询'
-    ,description=f'查询所有超过30岁的学员的信息。'
+    ,description=f'查询所有大于等于输入年龄的学员的信息。'
                   )
-def get_students(db=Depends(get_db)):
-    result = get_age_30( db=db )
-    if result:
-        return result
-    raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
+def get_students( age:int = 0 ,db=Depends(get_db)):
+    result = get_age_30( age=age , db=db )
+    if result is None or len(result) == 0:
+        raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
+    return result
 
 @statcalc_api.get("/statcalc/students"
     ,summary='人数统计'
@@ -30,62 +30,72 @@ def get_students(headcount:get_student_dao
     raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
 
 @statcalc_api.get("/statcalc/scores"
-    ,summary='80分以上成绩学生信息查询'
-    ,description=f'查询每次考试成绩都在80分以上的学生的编号，姓名和成绩。'
+    ,summary='优秀成绩学生信息查询'
+    ,description=f'查询所有科目考试成绩都在80分以上的学生。'
                   )
-def get_students(db=Depends(get_db)):
-    result = get_score_80( db=db )
+def get_excellent(sco:int = Query(80,ge=0, le=100,description="优秀成绩设定")
+                  , db=Depends(get_db)
+                  ):
+    result = get_excellent_students(sco=sco, db=db )
     if result:
         return result
     raise HTTPException(status_code=404, detail="没有找到符合条件的学生")
 
 @statcalc_api.get("/statcalc/fail"
     ,summary='不及格成绩查询'
-    ,description=f'查询有两次以上不及格的学生的姓名，班级和不及格成绩。'
+    ,description=f'查询有两次以上低于输入分数的学生的姓名，班级和不及格成绩。'
                   )
-def get_students( db=Depends(get_db)  ):
-    result = get_score_80( db=db )
+def get_students(sco:int = Query(60,ge=0, le=100,description="不及格成绩设定")
+                 , db=Depends(get_db)  ):
+    result = get_score_60( sco=sco ,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)
+def get_class_avg( class_id:int = Query(1,ge=1, le=3,description="查询班级")
+                   , db=Depends(get_db)):
+    result = get_class_avg_dao( class_id , db)
     if not result:
         return []
     return result
 
 
 from stu_jiuye.model import *
+from students.model.students_model import Students
+from class_management.model.class_management_model import ClassInfo
 
 @statcalc_api.get('/statcalc/top',summary='就业薪资Top5')
-def salarytop5(db=Depends(get_db)):
-    q = db.query(Employments,Company.employment_company) \
-    .join(Company, Employments.company_id == Company.id) \
-    .filter(Employments.is_deleted == 0)\
-    .order_by(Employments.employment_salary.desc())\
-    .limit(5) .all()
-    return [{'学生姓名':i.sname,'学生班级编号':i.class_num,'就业时间':i.offer_recived_time,'公司':employment_company} for i,employment_company in q]
+def salarytop5(num:int,db=Depends(get_db)):
+    q = db.query(Employments, Company.employment_company, Students.name.label('sname'), ClassInfo.name.label('class_num')) \
+        .join(Company, Employments.company_id == Company.id) \
+        .join(Students, Employments.stuid == Students.id) \
+        .join(ClassInfo, Employments.class_id == ClassInfo.id) \
+        .filter(Employments.is_deleted == 0) \
+        .order_by(Employments.employment_salary.desc()) \
+        .limit(num).all()
+    # q是4元组 (Employments对象, company_name, sname, class_num)
+    return [{'学生姓名': row[2], '学生班级编号': row[3], '就业时间': str(row[0].offer_recived_time) if row[0].offer_recived_time else None, '公司': row[1]} for row in q]
 
 @statcalc_api.get('/statcalc/job',summary='学生就业时长')
-def worktime(db=Depends(get_db)):
-    q = db.query(Employments)\
-        .filter(Employments.is_deleted==0)\
-            .all()
+def worktime(stuid:int,db=Depends(get_db)):
+    q = db.query(Employments, Students.name.label('sname')) \
+        .join(Students, Employments.stuid == Students.id) \
+        .filter(Employments.stuid == stuid,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
+            {'学生姓名': row[1],
+             '就业时常':f'{row[0].offer_recived_time-row[0].employment_open_time}'
+             if row[0].offer_recived_time and row[0].employment_open_time else '暂无数据'} for row in q
             ]
 
 @statcalc_api.get('/statcalc/avgjob',summary='学生平均就业时长')
 def avgworktime(db=Depends(get_db)):
-    q = db.query(Employments)\
+    q = db.query(Employments) \
         .filter(Employments.employment_open_time.isnot(None)
                 ,Employments.offer_recived_time.isnot(None)
-                ,Employments.is_deleted==0)\
+                ,Employments.is_deleted==0) \
         .all()
     if not q:
         return {'平均就业时常': '暂无数据'}

StatCalc/dao/statcalc_dao.py

@@ -1,15 +1,12 @@
 from pygments.lexers import sql
-from sentry_sdk.integrations import sqlalchemy
 
-from StatCalc.schema.statcalc_request import *
-from fastapi import HTTPException
 from sqlalchemy import *
 
 
 from students.model.students_model import Students
 
-def get_age_30(db):
-    q = db.query(Students).filter(Students.age>=30).all()
+def get_age_30( age , db):
+    q = db.query(Students).filter(Students.age>=age).all()
     return q
 
 
@@ -17,52 +14,78 @@ from class_management.model.class_management_model import ClassInfo
 
 def get_class_count(g , db):
     if g == "班级人数":
-        q = (db.query(ClassInfo.id,ClassInfo.name,func.count(ClassInfo.id) )
+        q = (db.query(ClassInfo.id,ClassInfo.name,func.count(ClassInfo.id).label('count') )
              .join(Students,Students.class_id==ClassInfo.id)
              .group_by(ClassInfo.id,ClassInfo.name,Students.sex)
              .all())
     elif g == "男女人数":
-        q = (db.query(Students.sex,func.count(ClassInfo.id) )
-                 .join(Students,Students.class_id==ClassInfo.id)
-                 .group_by(Students.sex)
-                 .all())
+        q = (db.query(Students.sex, func.count(Students.id).label('count'))
+             .group_by(Students.sex)
+             .all())
     elif g == "班级中男女人数":
-        q = (db.query(ClassInfo.id,ClassInfo.name,Students.sex,func.count(ClassInfo.id) )
+        q = (db.query(ClassInfo.id,ClassInfo.name,Students.sex,func.count(ClassInfo.id).label('count') )
                    .join(Students,Students.class_id==ClassInfo.id)
                    .group_by(ClassInfo.id,ClassInfo.name,Students.sex)
                    .all())
     else:
         return False
-    return q
+    return [row._asdict() for row in q]
 
 
 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()
-         )
-    return q
+def get_excellent_students(sco,db):
+    """查询所有科目都在80分以上的优秀学生"""
+    # 先查总科目数
+    total_subjects = db.execute(text("SELECT COUNT(*) FROM subject")).scalar()
 
-def get_class_avg_dao(db):
+    # 子查询：找出成绩>=80分的科目数等于总科目数的学生
+    sq = db.query(Students.id) \
+        .join(Score, Score.sid == Students.id) \
+        .filter(Score.score >= sco) \
+        .group_by(Students.id) \
+        .having(func.count(Score.id) == total_subjects) \
+        .subquery()
+
+    # 主查询：返回优秀学生信息
+    q = db.query(Students.id, Students.name, ClassInfo.name.label('class_name'), Score.score) \
+        .join(ClassInfo, ClassInfo.id == Students.class_id) \
+        .join(Score, Score.sid == Students.id) \
+        .filter(Students.id.in_(sq.select()), Score.score >= sco) \
+        .all()
+    return [row._asdict() for row in q]
+
+
+from scores.model.score_model import Score
+
+def get_score_60(sco ,db):
+    """查询有两次以上不及格(<60分)的学生"""
+    # 子查询：找出不及格超过2门的学生ID
+    sq = db.query(Students.id) \
+        .join(Score, Score.sid == Students.id) \
+        .filter(Score.score < sco) \
+        .group_by(Students.id) \
+        .having(func.count(Score.id) > 2) \
+        .subquery()
+
+    # 主查询：返回不及格学生信息
+    q = db.query(Students.name, ClassInfo.name.label('class_name'), Score.score) \
+        .join(ClassInfo, ClassInfo.id == Students.class_id) \
+        .join(Score, Score.sid == Students.id) \
+        .filter(Students.id.in_(sq.select()), Score.score < sco) \
+        .all()
+    return [row._asdict() for row in q]
+
+def get_class_avg_dao(class_id , 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)
+        .group_by(Score.num, Score.cid, ClassInfo.name,ClassInfo.id)
+        .having(ClassInfo.id == class_id)
         .order_by(func.avg(Score.score).desc())
         .all())
 

StatCalc/main.py

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

StatCalc/schema/statcalc_request.py

@@ -1,7 +1,5 @@
 # students_schema：请求、响应的模型框架
 
-from pydantic import BaseModel , Field , field_validator
-from datetime import datetime
 import enum
 
 class get_student_dao(str , enum.Enum):

Teachers/README.md

@@ -33,7 +33,7 @@ is_delete、delete_time、phone\
 教师表\
 请求体：\
 1.查询、任意逻辑删除调用
-2.新增、更改时调用
+2.新增、更改时调用\
 响应体:用于返回给前端\
 科目表：\
 1.请求体：新增科目时调用

Teachers/api/tea_api.py

@@ -11,12 +11,13 @@ 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(),db)
+    r = add_tea_dao(tea.model_dump(exclude_unset=True),db)
     if not r:
         raise HTTPException(status_code=500,detail='添加失败！')
     return TeaResponse(totals=1,data=tea.model_dump())
+
 @tea_api.get('/tea',response_model=TeaResponse,summary='查询老师',description='任意选择输入的信息数量，不输入则查询全部老师')
-def get_tea(t:NewTeaRequest1=Depends(),db=Depends(get_db)):   #开启会话窗口
+def get_tea(t:TeaRequest=Depends(),db=Depends(get_db)):   #开启会话窗口
     r = get_tea_dao(t.model_dump(),db=db)
     if not r:
         raise HTTPException(status_code=404,detail='老师不存在')
@@ -28,13 +29,19 @@ def delete_tea(id:int|None,db=Depends(get_db)):
         raise HTTPException(status_code=500,detail='删除失败！')
     return {'detail':'删除成功！'}
 
-@tea_api.put('/tea/{id}',summary='更新老师信息',description='输入更改的信息，可以为空')
-def update_tea(id:int,tea:NewTeaRequest,db=Depends(get_db)):
-    t = tea.model_dump(exclude_unset= True)
-    r = update_tea_dao(id=id,t=t,db=db)
-    if not r:
-        raise HTTPException(status_code=404,detail='老师不存在')
-    return {'detail':'更新成功'}
+@tea_api.put('/tea/{id}', summary='更新老师信息', description='输入更改的信息，可以为空')
+def update_tea(id: int, tea: NewTeaRequest = Depends(), db=Depends(get_db)):
+    t = tea.model_dump(exclude_unset=True)
+    print(t)
+    r = update_tea_dao(id=id, t=t, db=db)
+    if r == 'NOT_FOUND':
+        raise HTTPException(status_code=404, detail='老师不存在')
+    if r == 'NO_CHANGE':
+        raise HTTPException(status_code=400, detail='没有要更新的内容')
+    if isinstance(r, str) and r.startswith('ERROR'):
+        raise HTTPException(status_code=400, detail=r)
+        #先确认是字符串再调用字符串方法判断是不是以错误开头，是就报错给前端
+    return {'detail': '更新成功'}
 
 #根据任意信息删除
 @tea_api.delete('/tea',summary='根据任意信息逻辑删除',description='输入任意信息删除')
@@ -48,7 +55,7 @@ def delete_other_tea_dao1(t:TeaRequest=Depends(),db=Depends(get_db)):
 @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 not r:
+    if r=='已存在':
         raise HTTPException(status_code=500,detail='科目已存在')
     return TeaResponse(totals=len(r), data=r)
 

Teachers/dao/tea_dao.py

@@ -14,7 +14,9 @@ def add_tea_dao(t,db):
         if existing:
             for key,value in t.items():
                 if hasattr(existing,key) and value is not None and value != '':
+                    #hasattr(existing,key)统计有没有key，返回值是True或False
                     setattr(existing,key,value)
+                    #将value的值赋值到existing的key中，配合循环，让所有输入的信息都覆盖原信息
             existing.is_delete = False
             db.commit()
             return '恢复修改成功'
@@ -29,15 +31,22 @@ def add_tea_dao(t,db):
 
 
 #更新
-def update_tea_dao(id,t, db):
+def update_tea_dao(id, t, db):
     try:
-        row = db.query(Tea).filter(Tea.id == id,Tea.is_delete ==False ).update(t)
-    except:
-        db.rollback()
-        return False
-    else:
+        if not t:
+            return 'NO_CHANGE'
+        obj = db.query(Tea).filter(Tea.id == id, Tea.is_delete == False).first()
+        if not obj:
+            return 'NOT_FOUND'
+        for k, v in t.items():
+            if hasattr(obj, k) and v is not None and v != '':
+                setattr(obj, k, v)
         db.commit()
-        return row
+        return 'OK'
+    except Exception as e:
+        db.rollback()
+        print('更新失败原因', repr(e))
+        return f'ERROR: {e}'
 
 #查询
 def get_tea_dao(t,db):
@@ -50,8 +59,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('sub'):
-        query = query.filter(Tea.sub == t.get('sub') )
+    if t.get('subject_id'):
+        query = query.filter(Tea.subject_id == t.get('subject_id') )
     if t.get('home_place'):
         query = query.filter(Tea.home_place == t.get('home_place') )
     if t.get('specialty'):
@@ -67,7 +76,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.sub,'sex':i.sex,'home_place':i.home_place
+    return [{'id':i.id,'name':i.name,'class_id':i.class_id,'sub':i.subject_id,'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 +107,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('sub'):
-            query1 = query1.filter(Tea.sub == t.get('sub'))
+        if t.get('subject_id'):
+            query1 = query1.filter(Tea.subject_id == t.get('subject_id'))
         if t.get('home_place'):
             query1 = query1.filter(Tea.home_place == t.get('home_place'))
         if t.get('collage'):
@@ -128,15 +137,17 @@ def add_subject_dao(t,db):
     try:
         t1 = db.query(Sub).filter(Sub.name == t.get('name')).first()
         if t1:
-            print('科目已存在')
-            raise Exception('科目已存在')
+            return'已存在'
         s1 = Sub(**t)
         db.add(s1)
         db.commit()
-        return '添加成功'
-    except Exception as e:
+        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,4 +24,5 @@ def get_db():
         yield db
     finally:
         db.close()
+#建表
 Base.metadata.create_all(engine1)

Teachers/main.py

@@ -15,7 +15,7 @@ if __name__ == "__main__":
     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=56000)
     """
     IPv4 地址 . . . . . . . . . . . . : 192.168.1.51
     子网掩码  . . . . . . . . . . . . : 255.255.255.0

Teachers/model/tea_model.py

@@ -16,17 +16,14 @@ 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

@@ -7,8 +7,8 @@ class TeaRequest(BaseModel):
     name: str|None = None
     sex: Gender|None = None
     class_id: int | None = None
-    sub: str|None = None
-    phone: str | None
+    subject_id: str|None = None
+    phone: str | None = None
     home_place: str|None = None
     collage: str|None = None
     education: str|None = None
@@ -22,7 +22,7 @@ class NewTeaRequest(BaseModel):
     name: str | None = None
     sex: Gender|None = None
     class_id: int | None = None
-    sub: str | None = None
+    subject_id: int | None = None
     home_place: str | None = None
     phone: str | None = Field(default=None, min_length=11, max_length=11)
     collage: str | None = None
@@ -35,7 +35,7 @@ class NewTeaRequest1(BaseModel):
     name: str | None = None
     sex: Gender|None = None
     class_id: int | None = None
-    sub: str | None = None
+    subject_id: int | None = None
     home_place: str | None = None
     phone: str | None = Field(default=None, min_length=11, max_length=11)
     collage: str | None = None
@@ -45,4 +45,4 @@ class NewTeaRequest1(BaseModel):
     specialty: str | None = None
 
 class SubRequest(BaseModel):
-    name: str | None = None
+    name: str

class_management/database.py

@@ -11,9 +11,9 @@ 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_rul = f"mysql+pymysql://{DB_USER}:{DB_PASSWORD}@{DB_HOST}:{DB_PORT}/{DB_NAME}?charset=utf8mb4"
+class_management_url = "mysql+pymysql://root:123456@localhost:3306/student_manage_system?charset=utf8mb4"
 
-engine = create_engine(class_management_rul)
+engine = create_engine(class_management_url)
 SessionLocal = sessionmaker(bind=engine,autocommit=False, autoflush=False)
 Base = declarative_base()
 

class_management/main.py

@@ -3,16 +3,18 @@ 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)
 
+
+# 自测接口
+app = FastAPI()
+
+app.include_router(class_api)
+
 if __name__ =='__main__':
-    # 自测接口
-    app = FastAPI()
-
-    app.include_router(class_api)
-
     Base.metadata.create_all(engine)
 
     import uvicorn

class_management/readme.md

@@ -0,0 +1,206 @@
+========================================
+Class Management 班级管理模块
+========================================
+
+基于 FastAPI + SQLAlchemy + MySQL 的班级管理模块，
+提供班级的增删改查、多字段分页查询、逻辑删除等能力。
+
+----------------------------------------
+一、目录结构
+----------------------------------------
+
+class_management/
+  api/
+    class_management_api.py       # 路由层：定义 HTTP 接口
+  dao/
+    class_management_dao.py       # 数据访问层：封装数据库操作
+  model/
+    class_management_model.py     # ORM 模型：映射数据库表
+  schema/
+    class_management_request.py   # Pydantic 模型：请求/响应体
+  database.py                     # 数据库连接、Session、Base
+
+分层职责：
+  api     接收请求、参数校验、返回响应，不直接写 SQL
+  dao     封装 CRUD、事务控制，不处理 HTTP 状态码
+  model   定义表结构、字段约束，不写业务逻辑
+  schema  定义请求/响应格式，不碰数据库
+
+----------------------------------------
+二、数据表结构
+----------------------------------------
+
+表名：classes
+
+字段                类型         约束                    说明
+------------------  -----------  ----------------------  ------------------
+id                  Integer      PK, Auto Increment      班级主键
+num                 String(50)   NOT NULL, UNIQUE        班级编号
+name                String(50)   NOT NULL                班级名称
+head_teacher_id     Integer      FK -> teachers.id       班主任编号
+coach_teacher_id    Integer      FK -> teachers.id       授课老师编号
+tutor_teacher_id    Integer      FK -> teachers.id       助教老师编号
+class_start_time    Date         可空                    开班日期
+class_end_time      Date         可空                    结课日期
+is_delete           Integer      默认 0                  逻辑删除 0未删 1已删
+create_time         DATETIME     默认 now                创建时间
+update_time         DATETIME     默认 now, onupdate now  更新时间
+
+注意：head_teacher_id / coach_teacher_id / tutor_teacher_id 是外键，
+      插入前需保证 teachers 表中存在对应 id。
+
+----------------------------------------
+三、API 接口
+----------------------------------------
+
+基础前缀：/classes
+
+[1] 新增班级
+    POST /classes
+
+    请求体：
+    {
+      "num": "C001",
+      "name": "Python01班",
+      "head_teacher_id": 1,
+      "coach_teacher_id": 2,
+      "tutor_teacher_id": 3,
+      "class_start_time": "2025-01-01",
+      "class_end_time": "2025-06-30"
+    }
+
+    字段说明：
+      num                 string  班级编号，唯一
+      name                string  班级名称
+      head_teacher_id     int     班主任 ID
+      coach_teacher_id    int     授课老师 ID
+      tutor_teacher_id    int     助教老师 ID
+      class_start_time    date    格式 YYYY-MM-DD
+      class_end_time      date    格式 YYYY-MM-DD
+
+    响应：
+    {
+      "code": 200,
+      "detail": "新增成功",
+      "totals": 1,
+      "data": { ... }
+    }
+
+    错误：
+      400  班级编号已存在
+
+
+[2] 根据 ID 查询班级
+    GET /classes/{class_id}
+
+    响应：
+    {
+      "code": 200,
+      "detail": "OK",
+      "totals": 1,
+      "data": {
+        "id": 1,
+        "num": "C001",
+        "name": "Python01班",
+        "head_teacher_id": 1,
+        "coach_teacher_id": 2,
+        "tutor_teacher_id": 3,
+        "class_start_time": "2025-01-01",
+        "class_end_time": "2025-06-30"
+      }
+    }
+
+    错误：
+      404  该班级不存在或已删除
+
+[3] 多字段分页查询
+    GET /classes
+
+    Query 参数：
+      num                string  班级编号（精确匹配）
+      name               string  班级名称（精确匹配）
+      head_teacher_id    int     班主任 ID
+      coach_teacher_id   int     授课老师 ID
+      tutor_teacher_id   int     助教老师 ID
+      class_start_time   date    开班日期
+      class_end_time     date    结课日期
+      page               int     页码，默认 1，>=1
+      page_size          int     每页条数，默认 5，1~20
+
+    请求示例：
+      GET /classes?name=Python01班&page=1&page_size=5
+
+    响应：
+    {
+      "code": 200,
+      "detail": "OK",
+      "totals": 1,
+      "data": [
+        { "id": 1, "num": "C001", "name": "Python01班", ... }
+      ]
+    }
+
+    注意：当前为内存分页，先查出所有匹配记录再切片。
+          数据量大时建议改成 DB 层 offset/limit。
+
+[4] 修改班级信息
+    PUT /classes/{class_id}
+
+    请求体（只传要改的字段）：
+    {
+      "head_teacher_id": 5,
+      "class_end_time": "2025-12-31"
+    }
+
+    响应：
+    {
+      "code": 200,
+      "detail": "修改成功",
+      "data": { "id": 1 }
+    }
+
+    错误：
+      400  没有传入要修改的字段
+      404  班级不存在，修改失败
+
+[5] 逻辑删除班级
+    DELETE /classes/{class_id}
+
+    响应：
+    {
+      "code": 200,
+      "detail": "删除成功",
+      "data": { "id": 1 }
+    }
+
+    错误：
+      404  班级不存在，删除失败
+
+    说明：逻辑删除，只把 is_delete 置为 1，不物理删除记录。
+
+----------------------------------------
+五、约定与规范
+----------------------------------------
+
+返回值约定：
+
+  DAO 函数            成功返回    失败返回        API 判断
+  ------------------  ----------  ------------  ------------------
+  add_class_dao       None        错误字符串      if res:
+  update_class_dao    int >= 1    0             if not row_count:
+  delete_class_dao    int >= 1    0             if not del_rows:
+  get_class_dao       list        []            if not res:
+
+逻辑删除：
+  所有查询默认过滤 is_delete = 0，
+  删除操作用 UPDATE is_delete = 1，不做物理删除。
+
+分页：
+  page 从 1 开始
+  page_size 范围 1~20
+  返回 totals 为总条数，data 为当前页数据
+
+
+
+模块负责人：cyf
+最后更新：2026-09-22

init_test_data.py

@@ -0,0 +1,246 @@
+"""
+测试数据初始化脚本
+使用纯SQL直接向数据库插入测试数据，不修改任何原有项目文件
+用法: python init_test_data.py
+"""
+from datetime import date
+from databases import engine_all, Session
+from sqlalchemy import text
+
+Session_ = Session()
+
+
+def seed():
+    print("=== 开始插入测试数据 ===\n")
+
+    # ── 1. 科目 ──────────────────────────────────────────
+    subjects = ["Python程序设计", "数据结构", "数据库原理", "人工智能导论", "计算机网络", "操作系统"]
+    sub_ids = {}
+    for name in subjects:
+        r = Session_.execute(text("SELECT id FROM subject WHERE name = :name"), {"name": name}).fetchone()
+        if r:
+            sub_ids[name] = r[0]
+        else:
+            result = Session_.execute(text("INSERT INTO subject (name) VALUES (:name)"), {"name": name})
+            sub_ids[name] = result.lastrowid
+            print(f"  [科目] {name}")
+    Session_.commit()
+
+    # ── 2. 教师 ──────────────────────────────────────────
+    teachers = [
+        ("张伟", "m", sub_ids["Python程序设计"], 1, "北京", "Python", "博士", "清华", date(2018, 3, 1), "6年"),
+        ("李芳", "f", sub_ids["数据结构"], 1, "上海", "算法", "博士", "北大", date(2019, 9, 1), "4年"),
+        ("王强", "m", sub_ids["数据库原理"], 2, "广州", "MySQL", "硕士", "中山大学", date(2020, 2, 1), "3年"),
+        ("陈静", "f", sub_ids["人工智能导论"], 2, "深圳", "机器学习", "博士", "华南理工", date(2017, 7, 1), "7年"),
+        ("刘洋", "m", sub_ids["计算机网络"], 3, "杭州", "网络", "硕士", "浙江大学", date(2021, 1, 1), "2年"),
+        ("赵敏", "f", sub_ids["操作系统"], 3, "南京", "Linux", "博士", "南京大学", date(2019, 3, 1), "5年"),
+    ]
+    teacher_ids = []
+    for t in teachers:
+        phone = f"1380000{len(teacher_ids):04d}"
+        r = Session_.execute(
+            text("SELECT id FROM teachers WHERE phone = :phone AND is_delete = 0"),
+            {"phone": phone}
+        ).fetchone()
+        if r:
+            teacher_ids.append(r[0])
+        else:
+            result = Session_.execute(text("""
+                INSERT INTO teachers (name, sex, class_id, phone, subject_id, home_place, specialty,
+                                      education, collage, start_time, work_experience, is_delete)
+                VALUES (:name, :sex, :class_id, :phone, :subject_id, :home_place, :specialty,
+                        :education, :collage, :start_time, :work_experience, 0)
+            """), {
+                "name": t[0], "sex": t[1], "class_id": t[3], "phone": phone,
+                "subject_id": t[2], "home_place": t[4], "specialty": t[5],
+                "education": t[6], "collage": t[7], "start_time": t[8], "work_experience": t[9],
+            })
+            teacher_ids.append(result.lastrowid)
+            print(f"  [教师] {t[0]} ({t[1]}) - {t[5]}")
+    Session_.commit()
+
+    # ── 3. 班级 ──────────────────────────────────────────
+    classes = [
+        ("CS202401", "计算机科学2401班", teacher_ids[0], teacher_ids[1], teacher_ids[2], date(2024, 9, 1), date(2028, 6, 30)),
+        ("CS202402", "计算机科学2402班", teacher_ids[3], teacher_ids[4], teacher_ids[5], date(2024, 9, 1), date(2028, 6, 30)),
+        ("AI202501", "人工智能2501班",  teacher_ids[0], teacher_ids[3], teacher_ids[5], date(2025, 9, 1), date(2029, 6, 30)),
+    ]
+    class_ids = []
+    for c in classes:
+        r = Session_.execute(
+            text("SELECT id FROM classes WHERE num = :num AND is_delete = 0"),
+            {"num": c[0]}
+        ).fetchone()
+        if r:
+            class_ids.append(r[0])
+        else:
+            result = Session_.execute(text("""
+                INSERT INTO classes (num, name, head_teacher_id, coach_teacher_id, tutor_teacher_id,
+                                     class_start_time, class_end_time, is_delete)
+                VALUES (:num, :name, :head_teacher_id, :coach_teacher_id, :tutor_teacher_id,
+                        :class_start_time, :class_end_time, 0)
+            """), {
+                "num": c[0], "name": c[1], "head_teacher_id": c[2],
+                "coach_teacher_id": c[3], "tutor_teacher_id": c[4],
+                "class_start_time": c[5], "class_end_time": c[6],
+            })
+            class_ids.append(result.lastrowid)
+            print(f"  [班级] {c[1]}")
+    Session_.commit()
+
+    # ── 4. 学生 ──────────────────────────────────────────
+    first_names = ["志强", "丽华", "建国", "美玲", "文博", "晓燕", "浩然", "雨桐", "子轩", "思涵",
+                   "俊杰", "雅琪", "宇航", "欣怡", "天翊", "诗涵", "一诺", "浩宇", "梓萱", "博文"]
+    home_places = ["北京", "上海", "广州", "深圳", "杭州", "成都", "武汉", "西安"]
+    colleges = ["清华大学", "北京大学", "复旦大学", "上海交通大学", "浙江大学", "南京大学", "武汉大学", "华中科技大学"]
+    specialties = ["计算机科学", "软件工程", "数据科学", "人工智能"]
+    student_count = 0
+    for i in range(20):
+        class_idx = i % 3
+        enrollment = date(2024, 9, 1) if class_idx != 2 else date(2025, 9, 1)
+        graduate = date(2028, 6, 30) if class_idx != 2 else date(2029, 6, 30)
+        phone = f"1390000{1000+i}"
+        r = Session_.execute(
+            text("SELECT id FROM students WHERE phone = :phone AND is_deleted = 0"),
+            {"phone": phone}
+        ).fetchone()
+        if r:
+            continue
+        Session_.execute(text("""
+            INSERT INTO students (num, name, age, sex, home_Place, college, specialty,
+                                  enrollment_time, graduate_time, education,
+                                  class_id, advisor_id, phone, is_deleted)
+            VALUES (:num, :name, :age, :sex, :home_Place, :college, :specialty,
+                    :enrollment_time, :graduate_time, '本科',
+                    :class_id, :advisor_id, :phone, 0)
+        """), {
+            "num": f"2024{1001+i}",
+            "name": first_names[i],
+            "age": 18 + (i % 4),
+            "sex": "男" if i % 2 == 0 else "女",
+            "home_Place": home_places[i % 8],
+            "college": colleges[i % 8],
+            "specialty": specialties[i % 4],
+            "enrollment_time": enrollment,
+            "graduate_time": graduate,
+            "class_id": class_ids[class_idx],
+            "advisor_id": teacher_ids[i % 6],
+            "phone": phone,
+        })
+        student_count += 1
+        print(f"  [学生] {first_names[i]} (2024{1001+i}) - {'男' if i%2==0 else '女'} - 班级{class_idx+1}")
+    Session_.commit()
+
+    # ── 5. 成绩 ──────────────────────────────────────────
+    all_students = Session_.execute(
+        text("SELECT id, class_id FROM students WHERE is_deleted = 0")
+    ).fetchall()
+    all_subjects = Session_.execute(text("SELECT id FROM subject")).fetchall()
+    score_count = 0
+    for idx, st in enumerate(all_students):
+        for subj_idx, sub in enumerate(all_subjects):
+            score_val = 60 + (idx * 7 + subj_idx * 13) % 41
+            # 让前3名学生部分课程不及格（用于统计接口测试）
+            if idx < 3 and subj_idx < 2:
+                score_val = 30 + (idx * 5) % 25
+            existing = Session_.execute(
+                text("SELECT id FROM scores WHERE sid = :sid AND cid = :cid AND num = 1 AND t_subject = :t_subject AND is_deleted = 0"),
+                {"sid": st[0], "cid": st[1], "t_subject": sub[0]}
+            ).fetchone()
+            if not existing:
+                Session_.execute(text("""
+                    INSERT INTO scores (sid, cid, num, score, t_subject, is_deleted)
+                    VALUES (:sid, :cid, 1, :score, :t_subject, 0)
+                """), {"sid": st[0], "cid": st[1], "score": score_val, "t_subject": sub[0]})
+                score_count += 1
+    print(f"  [成绩] 为 {len(all_students)} 名学生插入了 {score_count} 条成绩记录")
+    Session_.commit()
+
+    # ── 6. 公司地址 ────────────────────────────────────────
+    addresses = ["北京市海淀区", "上海市浦东新区", "深圳市南山区", "杭州市西湖区", "广州市天河区"]
+    address_ids = []
+    for addr in addresses:
+        r = Session_.execute(
+            text("SELECT id FROM Address WHERE somewhere = :where"),
+            {"where": addr}
+        ).fetchone()
+        if r:
+            address_ids.append(r[0])
+        else:
+            result = Session_.execute(
+                text("INSERT INTO Address (somewhere) VALUES (:where)"),
+                {"where": addr}
+            )
+            address_ids.append(result.lastrowid)
+            print(f"  [地址] {addr}")
+    Session_.commit()
+
+    # ── 7. 公司 ────────────────────────────────────────────
+    companies = [
+        ("字节跳动", address_ids[2]),
+        ("阿里巴巴", address_ids[3]),
+        ("腾讯",     address_ids[2]),
+        ("华为",     address_ids[4]),
+        ("百度",     address_ids[0]),
+    ]
+    company_ids = []
+    for comp in companies:
+        r = Session_.execute(
+            text("SELECT id FROM Company WHERE employment_company = :name"),
+            {"name": comp[0]}
+        ).fetchone()
+        if r:
+            company_ids.append(r[0])
+        else:
+            result = Session_.execute(
+                text("INSERT INTO Company (employment_company, address_id) VALUES (:name, :addr_id)"),
+                {"name": comp[0], "addr_id": comp[1]}
+            )
+            company_ids.append(result.lastrowid)
+            print(f"  [公司] {comp[0]}")
+    Session_.commit()
+
+    # ── 8. 就业信息 ────────────────────────────────────────
+    employment_data = [
+        (all_students[0][0], all_students[0][1], company_ids[0], 35000, date(2028, 3, 1), date(2028, 4, 15)),
+        (all_students[1][0], all_students[1][1], company_ids[1], 32000, date(2028, 3, 1), date(2028, 5, 1)),
+        (all_students[2][0], all_students[2][1], company_ids[2], 30000, date(2028, 3, 1), date(2028, 4, 20)),
+        (all_students[3][0], all_students[3][1], company_ids[3], 28000, date(2028, 3, 1), date(2028, 5, 10)),
+        (all_students[4][0], all_students[4][1], company_ids[4], 25000, date(2028, 3, 1), date(2028, 6, 1)),
+        (all_students[5][0], all_students[5][1], company_ids[0], 33000, date(2028, 3, 1), date(2028, 4, 25)),
+        (all_students[6][0], all_students[6][1], company_ids[1], 29000, date(2028, 3, 1), None),
+        (all_students[7][0], all_students[7][1], company_ids[2], 31000, date(2028, 3, 1), date(2028, 5, 5)),
+    ]
+    emp_count = 0
+    for emp in employment_data:
+        r = Session_.execute(
+            text("SELECT id FROM Employments WHERE stuid = :stuid AND is_deleted = 0"),
+            {"stuid": emp[0]}
+        ).fetchone()
+        if not r:
+            Session_.execute(text("""
+                INSERT INTO Employments (stuid, class_id, company_id, employment_salary,
+                                         employment_open_time, offer_recived_time, is_deleted)
+                VALUES (:stuid, :class_id, :company_id, :salary, :open_time, :offer_time, 0)
+            """), {
+                "stuid": emp[0], "class_id": emp[1], "company_id": emp[2],
+                "salary": emp[3], "open_time": emp[4], "offer_time": emp[5],
+            })
+            emp_count += 1
+    print(f"  [就业] 插入 {emp_count} 条就业记录")
+    Session_.commit()
+
+    # ── 完成 ───────────────────────────────────────────────
+    Session_.close()
+    print("\n=== 测试数据初始化完成！共插入:")
+    print(f"  • 科目: {len(subjects)} 门")
+    print(f"  • 教师: {len(teachers)} 位")
+    print(f"  • 班级: {len(classes)} 个")
+    print(f"  • 学生: {student_count} 名")
+    print(f"  • 成绩: {score_count} 条")
+    print(f"  • 公司: {len(companies)} 家")
+    print(f"  • 就业: {emp_count} 条")
+
+
+if __name__ == "__main__":
+    seed()

main.py

@@ -6,8 +6,19 @@ from students.main import Students_API
 from Teachers.main import Teachers_API
 from StatCalc.main import StatCalc_API
 from databases import *
+from seed_data import seed_test_data
 app = FastAPI(title="学生管理系统")
 
+from fastapi.middleware.cors import CORSMiddleware
+
+# 配置CORS - 接前端
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],  # 允许所有来源
+    allow_credentials=True,
+    allow_methods=["*"],  # 允许所有方法
+    allow_headers=["*"],  # 允许所有头部
+)
 
 app.include_router(Classes_API,tags=["班级管理模块"])
 app.include_router(Scores_API,tags=["学生考核成绩管理模块"])
@@ -23,10 +34,12 @@ if __name__ == "__main__":
     def main():
         print("Hello from student-manage-system!")
 
+    seed_test_data()
+
     import uvicorn
-    uvicorn.run("main:app", host="0.0.0.0", port=59000)
+    uvicorn.run("main:app", host="0.0.0.0", port=58000)
     """
     IPv4 地址 . . . . . . . . . . . . : 192.168.6.40
     子网掩码  . . . . . . . . . . . . : 255.255.255.0
     默认网关. . . . . . . . . . . . . : 192.168.6.1
-    """
+    """

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是主程序文件，将配置文件的接口导入，创建接口运行

scores/dao/statistic_dao.py

@@ -50,11 +50,9 @@ def get_failing_students_dao(db):
         .order_by(ClassInfo.id, Score.num)
         .all())
 
-    return [{"sid": r.sid,
+    return [{
             "name": r.name,
             "class_name": r.class_name,
-            "num": r.num,
-            "t_subject": r.tsub,
             "score": r.score,}
         for r in results]
 

seed_data.py

@@ -0,0 +1,260 @@
+"""
+种子数据初始化模块
+在 main.py 启动时自动调用，向数据库注入测试数据
+幂等设计：已存在数据则跳过，不重复插入
+"""
+from datetime import date
+from sqlalchemy import text
+from databases import engine_all, Base_all, Session
+
+
+def seed_test_data():
+    """启动时自动注入测试数据（幂等）"""
+    db = Session()
+    try:
+        # 临时关闭外键检查，避免 class_management_model.py 的 FK bug
+        db.execute(text("SET FOREIGN_KEY_CHECKS = 0"))
+
+        # 导入所有模型以获取 metadata（触发 Base_all.metadata.create_all）
+        import students.model.students_model
+        import Teachers.model.tea_model
+        import scores.model.score_model
+        import stu_jiuye.model
+
+        # 创建所有表（临时关闭外键检查）
+        db.execute(text("SET FOREIGN_KEY_CHECKS = 0"))
+        Base_all.metadata.create_all(bind=engine_all)
+
+        # 手动建 classes 表（因 FK bug 无法通过 ORM 建表）
+        db.execute(text("""
+            CREATE TABLE IF NOT EXISTS classes (
+                id INT AUTO_INCREMENT PRIMARY KEY,
+                num VARCHAR(50) NOT NULL UNIQUE,
+                name VARCHAR(50) NOT NULL,
+                head_teacher_id INT,
+                coach_teacher_id INT,
+                tutor_teacher_id INT,
+                class_start_time DATE,
+                class_end_time DATE,
+                is_delete INT DEFAULT 0,
+                create_time DATETIME,
+                update_time DATETIME,
+                FOREIGN KEY (head_teacher_id) REFERENCES teachers(id),
+                FOREIGN KEY (coach_teacher_id) REFERENCES teachers(id),
+                FOREIGN KEY (tutor_teacher_id) REFERENCES teachers(id)
+            )
+        """))
+
+        # 恢复外键检查
+        db.execute(text("SET FOREIGN_KEY_CHECKS = 1"))
+        db.commit()
+
+        # 幂等检查：科目表有数据就跳过全部
+        if db.execute(text("SELECT COUNT(*) FROM subject")).scalar() > 0:
+            return
+
+        print("  [种子] 开始注入测试数据...")
+
+        # ── 1. 科目 ──────────────────────────────────────
+        subjects = ["Python程序设计", "数据结构", "数据库原理",
+                    "人工智能导论", "计算机网络", "操作系统"]
+        sub_ids = {}
+        for name in subjects:
+            result = db.execute(
+                text("INSERT INTO subject (name) VALUES (:name)"),
+                {"name": name}
+            )
+            sub_ids[name] = result.lastrowid
+
+        # ── 2. 教师 ──────────────────────────────────────
+        teachers = [
+            ("张伟", "m", 1, sub_ids["Python程序设计"],
+             "北京", "Python", "博士", "清华", date(2018, 3, 1), "6年"),
+            ("李芳", "f", 1, sub_ids["数据结构"],
+             "上海", "算法", "博士", "北大", date(2019, 9, 1), "4年"),
+            ("王强", "m", 2, sub_ids["数据库原理"],
+             "广州", "MySQL", "硕士", "中山大学", date(2020, 2, 1), "3年"),
+            ("陈静", "f", 2, sub_ids["人工智能导论"],
+             "深圳", "机器学习", "博士", "华南理工", date(2017, 7, 1), "7年"),
+            ("刘洋", "m", 3, sub_ids["计算机网络"],
+             "杭州", "网络", "硕士", "浙江大学", date(2021, 1, 1), "2年"),
+            ("赵敏", "f", 3, sub_ids["操作系统"],
+             "南京", "Linux", "博士", "南京大学", date(2019, 3, 1), "5年"),
+        ]
+        teacher_ids = []
+        for t in teachers:
+            phone = f"1380000{len(teacher_ids):04d}"
+            result = db.execute(text("""
+                INSERT INTO teachers (name, sex, class_id, phone, subject_id,
+                                      home_place, specialty, education, collage,
+                                      start_time, work_experience, is_delete)
+                VALUES (:name, :sex, :class_id, :phone, :subject_id,
+                        :home_place, :specialty, :education, :collage,
+                        :start_time, :work_experience, 0)
+            """), {
+                "name": t[0], "sex": t[1], "class_id": t[2],
+                "phone": phone, "subject_id": t[3],
+                "home_place": t[4], "specialty": t[5],
+                "education": t[6], "collage": t[7],
+                "start_time": t[8], "work_experience": t[9],
+            })
+            teacher_ids.append(result.lastrowid)
+
+        # ── 3. 班级 ──────────────────────────────────────
+        classes = [
+            ("CS202401", "计算机科学2401班", teacher_ids[0],
+             teacher_ids[1], teacher_ids[2],
+             date(2024, 9, 1), date(2028, 6, 30)),
+            ("CS202402", "计算机科学2402班", teacher_ids[3],
+             teacher_ids[4], teacher_ids[5],
+             date(2024, 9, 1), date(2028, 6, 30)),
+            ("AI202501", "人工智能2501班",  teacher_ids[0],
+             teacher_ids[3], teacher_ids[5],
+             date(2025, 9, 1), date(2029, 6, 30)),
+        ]
+        class_ids = []
+        for c in classes:
+            result = db.execute(text("""
+                INSERT INTO classes (num, name, head_teacher_id, coach_teacher_id,
+                                     tutor_teacher_id, class_start_time,
+                                     class_end_time, is_delete)
+                VALUES (:num, :name, :head_teacher_id, :coach_teacher_id,
+                        :tutor_teacher_id, :class_start_time,
+                        :class_end_time, 0)
+            """), {
+                "num": c[0], "name": c[1],
+                "head_teacher_id": c[2], "coach_teacher_id": c[3],
+                "tutor_teacher_id": c[4],
+                "class_start_time": c[5], "class_end_time": c[6],
+            })
+            class_ids.append(result.lastrowid)
+
+        # ── 4. 学生 ──────────────────────────────────────
+        first_names = ["志强", "丽华", "建国", "美玲", "文博", "晓燕",
+                       "浩然", "雨桐", "子轩", "思涵",
+                       "俊杰", "雅琪", "宇航", "欣怡", "天翊",
+                       "诗涵", "一诺", "浩宇", "梓萱", "博文"]
+        home_places = ["北京", "上海", "广州", "深圳", "杭州", "成都", "武汉", "西安"]
+        colleges = ["清华大学", "北京大学", "复旦大学", "上海交通大学",
+                    "浙江大学", "南京大学", "武汉大学", "华中科技大学"]
+        specialties = ["计算机科学", "软件工程", "数据科学", "人工智能"]
+
+        for i in range(20):
+            class_idx = i % 3
+            enrollment = date(2024, 9, 1) if class_idx != 2 else date(2025, 9, 1)
+            graduate = date(2028, 6, 30) if class_idx != 2 else date(2029, 6, 30)
+            phone = f"1390000{1000 + i}"
+            # 前3个学生年龄设大一些，用于30岁以上统计测试
+            age = 30 + i if i < 3 else 18 + (i % 4)
+            db.execute(text("""
+                INSERT INTO students (num, name, age, sex, home_Place, college,
+                                      specialty, enrollment_time, graduate_time,
+                                      education, class_id, advisor_id, phone, is_deleted)
+                VALUES (:num, :name, :age, :sex, :home_Place, :college,
+                        :specialty, :enrollment_time, :graduate_time,
+                        'ben', :class_id, :advisor_id, :phone, 0)
+            """), {
+                "num": f"2024{1001 + i}",
+                "name": first_names[i],
+                "age": age,
+                "sex": "m" if i % 2 == 0 else "f",
+                "home_Place": home_places[i % 8],
+                "college": colleges[i % 8],
+                "specialty": specialties[i % 4],
+                "enrollment_time": enrollment,
+                "graduate_time": graduate,
+                "class_id": class_ids[class_idx],
+                "advisor_id": teacher_ids[i % 6],
+                "phone": phone,
+            })
+
+        # ── 5. 成绩 ──────────────────────────────────────
+        all_students = db.execute(
+            text("SELECT id, class_id FROM students WHERE is_deleted = 0")
+        ).fetchall()
+        all_subjects = db.execute(
+            text("SELECT id FROM subject")
+        ).fetchall()
+
+        for idx, st in enumerate(all_students):
+            for subj_idx, sub in enumerate(all_subjects):
+                # 前3名学生设大年龄（用于30岁以上统计）
+                # 前2名学生所有科目80分以上（用于优秀成绩统计）
+                # 最后2名学生部分科目不及格（用于不及格统计）
+                if idx < 2:
+                    # 优秀学生：所有科目85-95分
+                    score_val = 85 + (idx * 5 + subj_idx * 3) % 11
+                elif idx >= 18:
+                    # 不及格学生：部分科目50-60分
+                    if subj_idx < 3:
+                        score_val = 50 + (idx * 3 + subj_idx) % 11
+                    else:
+                        score_val = 75 + (idx * 2 + subj_idx) % 16
+                else:
+                    score_val = 60 + (idx * 7 + subj_idx * 13) % 41
+                db.execute(text("""
+                    INSERT INTO scores (sid, cid, num, score, t_subject, is_deleted)
+                    VALUES (:sid, :cid, 1, :score, :t_subject, 0)
+                """), {
+                    "sid": st[0], "cid": st[1],
+                    "score": score_val, "t_subject": sub[0],
+                })
+
+        # ── 6. 地址 ──────────────────────────────────────
+        addresses = ["北京市海淀区", "上海市浦东新区", "深圳市南山区",
+                     "杭州市西湖区", "广州市天河区"]
+        address_ids = []
+        for addr in addresses:
+            result = db.execute(
+                text("INSERT INTO Address (somewhere) VALUES (:where)"),
+                {"where": addr}
+            )
+            address_ids.append(result.lastrowid)
+
+        # ── 7. 公司 ──────────────────────────────────────
+        companies = ["字节跳动", "阿里巴巴", "腾讯", "华为", "百度"]
+        company_ids = []
+        for idx, comp_name in enumerate(companies):
+            result = db.execute(
+                text("INSERT INTO Company (employment_company) VALUES (:name)"),
+                {"name": comp_name}
+            )
+            company_ids.append(result.lastrowid)
+
+        # ── 8. 就业信息 ───────────────────────────────────
+        # 添加更多就业记录，确保统计接口有数据
+        employment_data = []
+        for i in range(min(15, len(all_students))):
+            company_idx = i % len(company_ids)
+            address_idx = i % len(address_ids)
+            salary = 25000 + (i * 2000) % 15000
+            # 前10个学生有offer时间，后5个没有（测试不同情况）
+            offer_time = date(2028, 4, 15 + i) if i < 10 else None
+            employment_data.append((
+                all_students[i][0], all_students[i][1], company_ids[company_idx],
+                address_ids[address_idx], salary, date(2028, 3, 1), offer_time
+            ))
+        for idx, emp in enumerate(employment_data):
+            db.execute(text("""
+                INSERT INTO Employments (stuid, class_id, company_id, address_id,
+                                         employment_salary, employment_open_time,
+                                         offer_recived_time, is_deleted)
+                VALUES (:stuid, :class_id, :company_id, :addr_id, :salary,
+                        :open_time, :offer_time, 0)
+            """), {
+                "stuid": emp[0], "class_id": emp[1],
+                "company_id": emp[2], "addr_id": emp[3],
+                "salary": emp[4], "open_time": emp[5], "offer_time": emp[6],
+            })
+
+        db.commit()
+        print(f"  [种子] 完成！插入 {len(subjects)} 科目、{len(teachers)} 教师、"
+              f"{len(classes)} 班级、20 学生、{len(all_students)*len(all_subjects)} 成绩、"
+              f"{len(companies)} 公司、{len(employment_data)} 就业")
+
+    except Exception as e:
+        db.rollback()
+        print(f"  [种子] 失败: {e}")
+        raise
+    finally:
+        db.close()

stu_jiuye/CURD_api.py

@@ -15,10 +15,10 @@ def get_stuinfo(                                    #查询学生就业信息
                 ,min_salary:int|None=Query(None,description='最小薪资范围')
                 ,max_salary:int|None=Query(None,description='最大薪资范围')
                 ,somewhere:str|None=Query(None,description='公司地区')
-                ,employment_open_start: date | None = Query(None,description='就业开放起始时间')
-                ,employment_open_end: date | None = Query(None,description='就业开放结束时间')
-                ,offer_recived_start: date | None = Query(None,description='offer下发起始时间')
-                ,offer_recived_end: date | None = Query(None,description='offer下发结束时间')
+                ,employment_open_start: date|None = Query(None,description='就业开放起始时间')
+                ,employment_open_end: date|None = Query(None,description='就业开放结束时间')
+                ,offer_recived_start: date|None = Query(None,description='offer下发起始时间')
+                ,offer_recived_end: date|None = Query(None,description='offer下发结束时间')
                 ,db=Depends(get_db)
                 ):                                  #查询条件
     r=get_emp_dao(                                  #调用函数

stu_jiuye/dao.py

@@ -85,7 +85,7 @@ def get_emp_dao(                                                 #获取学生
                    # ,page
                    # ,page_size
                    ):                                           #根据选择条件获取信息
-    q = (db.query(Employments,Company.employment_company,Address.somewhere)
+    q = (db.query(Employments, Students.name, Company.employment_company, Address.somewhere)
         .outerjoin(Students, Students.id == Employments.stuid)
         .outerjoin(ClassInfo, ClassInfo.id == Employments.class_id)
         .outerjoin(Company,Employments.company_id==Company.id)
@@ -118,13 +118,13 @@ def get_emp_dao(                                                 #获取学生
     r= q.all()
     if r:
         return [ {"id": i.id,
-                  '学生姓名':sname,
+                  '学生姓名':sname or '-',
                   '学生班级编号':i.class_id,
                  "公司": employment_company or '未就业',
                   "公司区域":somewhere or '-',
                   "薪资":i.employment_salary or '-',
-                  "就业开放时间":i.employment_open_time.strftime('%Y-%m-%d') ,
-                  "offer下发时间":i.offer_recived_time.strftime('%Y-%m-%d')
+                  "就业开放时间":i.employment_open_time.strftime('%Y-%m-%d') if i.employment_open_time else '-',
+                  "offer下发时间":i.offer_recived_time.strftime('%Y-%m-%d') if i.offer_recived_time else '-'
                 # , "创建时间": i.create_time,
                 # "更新时间": i.update_time,
                 #  "是否删除":i.is_deleted

students/README_students.md

@@ -16,48 +16,231 @@ ORM：sqlalchemy
 
 ## main：学生管理系统的主程序文件、测试接口
 1. 下面所有配置文件的接口全部导入并建表
-2. 创建fastapi接口并本地运行
+2. 创建合并接口APIRouter
+3. 创建fastapi接口并本地运行
 
 ## databases：链接数据库配置文件
 1. 链接本地mysql，实例化mysql，创建引擎，创建基类，实例化数据库会话
 2. 创建函数，调用数据库会话
+3. 因为后期多代码合并，每个人的databases都不同链接也不同，所以导入了.env文件
+   1. 这样在每个人有差异的数据可以直接保存在本地，不用反复同步相互覆盖了
+   2. 另外一个原因就是model层大家建表要使用同一个基类
+      1. 所以接入了.env文件随时入参
+      2. 这样更加方便，而且高频同步和拉取也不用重新配置
+
+## 分层代码书写顺序：
+1. model层：
+   1. 确认你的业务需要哪些字段
+   2. 确认小组的字段名、表名、库名一致
+   3. 确认主键、唯一键、字段数据类型、外键等关键字内容
+2. 请求体
+   1. 搞清楚业务需求，需要用到哪些字段
+   2. 增删改查的具体逻辑
+3. api
+   1. 写好接收变量
+   2. 装饰器设定
+   3. 输出规则
+   4. 一次写好基本上就不会再改了
+4. dao
+   1. 工作量最大的层，所有的业务逻辑都写在这里面
+   2. 所有的业务逻辑都在这个层里
 
 ## api.students_api：接口文件
 ### 学生表students的功能接口:
 1. 学生信息的查询
+   1. 仅保存入参标量，代码都在逻辑层，建好了基本不用修改，方便维护
 2. 学生信息的新增
+    1. 仅保存入参标量，代码都在逻辑层，建好了基本不用修改，方便维护
 3. 学生信息的更新
+    1. 仅保存入参标量，代码都在逻辑层，建好了基本不用修改，方便维护
 4. 学生信息的逻辑删除
+    1. 仅保存入参标量，代码都在逻辑层，建好了基本不用修改，方便维护
 
 ## dao.students_dao：数据筛选文件
 ### 数据库的逻辑筛选文件:
 1. 查询：get_student_dao
+   1. 筛选所有非空内容，过滤逻辑删除数据，输出学生完整字段
 2. 新增：add_student_dao
+   1. 关键字段限制
+   2. 过滤各种报错，反馈报错问题
+   3. 无报错即可全部插入
+   4. 注意逻辑删除的数据，其实也会占用唯一键，所以有唯一键重复时，直接拉出旧数据进行清空翻新。
 3. 更新：update_student_dao
+   1. 主要过滤掉没有输入的字段，除非输入才可以被覆盖，不能每次更新清空全部内容
+   2. 唯一字段过滤，比如电话号码，在业务逻辑上电话号码不能重复
 4. 逻辑删除：delete_student_dao
+   1. 逻辑删除可以用所有字段进行精确或者范围删除
+   2. 但是不可以全为空删除我的整个库
 
 ## model.students_model：数据库建表文件
 1. 数据表建表代码
-2. 字段信息： sid **PK**
-          , student_name 
-          , student_phone 
-          , class_name 
-          , job_open_time 
-          , offer_issue_time 
-          , company_name 
-          , salary 
-          , create_date 
-          , update_date 
-          , is_deleted 
-          , deleted_date
-          , **待建FK:** class_id/teacher_id/score_id/company_id/
-
+2. 字段信息： `id`:***PK***
+            `num`：***UNI***
+            `name`
+            `age`
+            `sex`:*ENUM*
+            `home_Place`
+            `college`
+            `specialty`
+            `enrollment_time`
+            `graduate_time`
+            `education`:*ENUM*
+            ***外键字段***
+            `class_id`:***FK***
+            `advisor_id`:***FK***
+            ***额外字段***
+            `phone`:***UNI***
+            ***通用字段***
+            `create_date`
+            `update_date`
+            `is_deleted`
+            `deleted_date`
 
 ## schema.students_request：请求体、数据过滤
 请求体根据业务要求有不同调整，方便后续维护和更改需求
 1. 查询：StudentsQuery
+   1. 所有字段都可以进行查询
+   2. 随便填哪个都可以进行精确查询或者范围查询
+   3. 全为空即查询全部
 2. 新增：StudentsResponse
+   1. 新增有必填项、不可重复项等，保证数据干净
 3. 更新：StudentsUpdate
+   1. 以ID作为查询字段，更新其他内容
+   2. 会过滤掉重复值
 4. 逻辑删除：StudentsDelete
+   1. 所有字段都可以进行删除
+   2. 随便填哪个都可以进行精确删除或者范围删除
+   3. 不可全字段为空
+
+## StatCalc：统计分析模块
+- 除了没有model以外没有什么太大的区别
+- 因为接口都有具体需求，所以直接一键呼出，不用填写筛选内容
+1. 请求体
+   1. 搞清楚业务需求，需要用到哪些字段
+   2. 增删改查的具体逻辑
+2. api
+   1. 写好接收变量
+   2. 装饰器设定
+   3. 输出规则
+   4. 一次写好基本上就不会再改了
+3. dao
+   1. 工作量最大的层，所有的业务逻辑都写在这里面
+   2. 所有的业务逻辑都在这个层里
+
+## 学生管理系统修改报错记录
+### 1. 合并修改记录：
+1. main.py
+    1. 所有子模块中的main新增了APIRouter，用来拉到主main进行运行
+    2. stu_jiuye
+        1. stu_jiuye\main.py
+            1. 新增为加粗倾斜处
+            2. from ***sut_jiuye***.文件名 import 调用名
+        2. CURD_api.py
+            1. 新增为加粗倾斜处
+            2. from ***sut_jiuye***.文件名 import 调用名
+2. databases.py
+    1. 所有人的db_url账号密码IP端口和名称全部存入了.env文件
+    2. 导入了load_dotenv进行调用
+        1. from dotenv import load_dotenv
+        2. load_dotenv( )
+        3. DB_USER = os.getenv("DB_USER", "root")  
+        4. DB_PASSWORD = os.getenv("DB_PASSWORD", "")  
+        5. DB_HOST = os.getenv("DB_HOST", "localhost")  
+        6. DB_PORT = os.getenv("DB_PORT", "3306")  
+        7. DB_NAME = os.getenv("DB_NAME", "student_manage_system")
+    3. 修改了部分url名称，自行检查
+3. class文件夹下导入修改
+    1. 新增为加粗倾斜处
+        1. from ***class_management***.文件名 import 调用名
+            1. 改动文件：
+                1. class_management_api.py
+                2. class_management_dao.py
+                3. class_management_model.py
+
+### 2. 合并完成
+1. 新增.env文件，设置好账号密码等
+    1. 可以一次运行创建好所有表格
+    2. 但是注意，没办法创建库，也就是student_manage_system
+    3. 如果没有建库的话会报错
+2. 表外键写完之后，可以用SQL语句删除所有表
+    1. 再重新运行***main.py***文件
+        1. 这个main.py特指最外层的运行主程序main.py
+
+### 3. 分支测试
+1. 阶段完成后
+    1. 如果不擅长保存版本，可以在自己的分支下面再建新分支
+    2. 方便切换版本和查询bug，理解逻辑，以免修改后bug更多了
+    3. 完成后可以将子分支变基到主线
+    4. 变基（覆盖）完成后可以继续使用子分支进行修改整合
+2. 注意云端仓库，没有修改的文件是不会反复上传的
+    1. 所以看距离时间最近的基本都是被修改过的
+    2. 可以用来进行版本对比
+
+### 4. 外键创建
+1. 外键必须要来自同一个基类，不然会报错
+    1. 新增主程序的databases.py文件，统一基类
+
+### 5. 外键报错
+1. 在新建字段时，依赖主表的外键必须要已经建立，不然在提交时都会报错
+2. 所以新增接口的报错逻辑需要特别优化，将各个阶段可能报错的内容都捕获下来
 
 
+## hermes agent协作内容：
+### 1. 测试数据脚本 — init_test_data.py/seed_data.py
+直接正常运行主程序文件 main.py 即可插入
+
+直接插入前提：
+1. 保证数据库 student_manage_system 存在
+2. 数据表字段对应
+3. 建议直接删库建库 students\StudentsQuery.sql 里有相应需求的语句
+
+向数据库插入了完整的测试数据，没有修改任何原有项目文件：
+数据类型
+数量
+科目	6 门（Python程序设计、数据结构、数据库原理等）
+教师	6 位（张伟、李芳、王强、陈静、刘洋、赵敏）
+班级	3 个（CS2401、CS2402、AI2501）
+学生	20 名（涵盖3个班级，男女各半）
+成绩	120 条（每名学生6门课，含部分不及格记录）
+公司	5 家（字节跳动、阿里巴巴、腾讯、华为、百度）
+就业信息	8 条（含薪资、offer时间等）
+
+### 2. 前端页面 - frontend/index.html - 双击运行
+单文件完整前端，包含：
+
+首页：问候 Banner + 快捷卡片（查课表/查成绩/校园卡/报修）+ 校园动态信息流
+学生管理：表格列表、搜索过滤、新增/编辑/删除（含二次确认弹窗）
+成绩查询：学期切换 Tab、成绩卡片展示、Chart.js 柱状图
+教师管理：教师列表、搜索、新增
+就业管理：就业信息列表、状态标签（已就业/待就业）
+个人中心：蓝色背景头像区 + 功能菜单列表
+
+交互特性：
+✅ 卡片点击缩放反馈（95% 回弹，150ms）
+✅ 页面切换从右侧滑入（300ms）
+✅ 删除二次确认弹窗
+✅ Toast 提示（成功/失败/信息）
+✅ 鼠标悬停按钮/卡片颜色加深、阴影加深
+✅ 隔行变色表格 + 表头排序
+
+启动后端后直接浏览器打开 frontend/index.html 即可使用。
+
+### 移植
+只动几个文件，都不需要改代码：
+
+移动的文件：
+
+seed_data.py       →  新项目的根目录
+init_test_data.py  →  新项目的根目录
+frontend/          →  新项目的根目录（整个文件夹）
+
+要改的唯一参数： frontend/index.html 
+
+const API_BASE = 'http://localhost:59000';
+改成新项目实际运行的端口即可。
+
+其他都不用动：
+
+init_test_data.py 完全独立，连接的是 databases.py 里的 .env 配置，新项目只要 DB 信息对就能直接跑
+frontend/index.html 纯静态页面，不依赖任何项目代码
+如果新项目用了不同的端口（比如 8000），改那一行就行

students/StudentsQuery.sql

@@ -10,16 +10,30 @@ drop database  student_manage_system;
 
 drop table students;
 
-select * from students limit 50;
+select * from students limit 200;
+
+select * from scores limit 200;
+
+select * from address limit 200;
+
+select * from classes limit 200;
+
+select * from company limit 200;
+
+select * from employments limit 200;
+
+select * from teachers limit 200;
+
+select * from subject limit 200;
 
 desc students;
 
 
-select *
-from cast(student_manage_system as BINARY)
-where age >30
-join on
-group by
-having
-order by
-limit
+# select *
+# from cast(student_manage_system as BINARY)
+# where age >30
+# join on
+# group by
+# having
+# order by
+# limit

students/api/students_api.py

@@ -1,6 +1,6 @@
 # students_api所有students的api路由、接口
 
-from fastapi import APIRouter , Depends , HTTPException
+from fastapi import APIRouter , Depends , HTTPException , Body
 from students.dao.students_dao import *
 from students.model.students_model import *
 from students.schema.students_request import *
@@ -30,8 +30,8 @@ def get_students( stu:StudentsQuery = Depends()
                  f'注意事项：\n'
                  f'时间格式：YYYY-MM-DD\n'
                  f'班级ID和顾问ID必须已经存在才可以绑定'
-    ,response_model=StudentsResponse )
-def add_student( stu:StudentsResponse = Depends()
+            )
+def add_student( stu:StudentsResponse =Depends()
                 , db=Depends(get_db)
                  ):
     s_dict = stu.model_dump(exclude_unset=True)
@@ -43,7 +43,7 @@ def add_student( stu:StudentsResponse = Depends()
     ,description=f'请输入需要更新信息的学生ID，学生手机号不可重复，填写即更新，为空即不更新。\n '
                  f'时间格式：YYYY-MM-DD'
     ,response_model=StudentsUpdate )
-def get_students( stu:StudentsUpdate = Depends()
+def update_students( stu:StudentsUpdate =Depends()
                  , db=Depends(get_db)
                  ):
     s_dict = stu.model_dump(exclude_unset=True)
@@ -54,10 +54,10 @@ def get_students( stu:StudentsUpdate = Depends()
 
 @s_api.delete("/students"
     ,summary='删除学生资料'
-    ,description=f'输入需要删除的学生信息，删除条件任选，但不可全为空，工资筛选能删除大于等于输入工资的所有人。\n '
+    ,description=f'输入需要删除的学生信息，删除条件任选，但不可全为空。\n '
                  f'时间格式：YYYY-MM-DD'
     ,response_model=list[StudentsDelete] ) # 逻辑删除/软删除
-def delete_students( stu:StudentsDelete = Depends()
+def delete_students( stu:StudentsDelete =Depends()
                     , db=Depends(get_db)
                    ):
     s_dict = stu.model_dump(exclude_unset=True)

students/dao/students_dao.py

@@ -66,7 +66,16 @@ def add_student_dao( s , db):
         if not phone:
             raise ValueError("手机号不能为空")
         if not s.get("class_id") or not s.get("advisor_id"):
-            raise ValueError("班级ID和顾问ID必须已经存在才可以绑定")
+            raise ValueError("班级ID和顾问ID不能为空")
+        # 查询 classes 表确认 class_id 存在
+        from Teachers.model.tea_model import Tea
+        s1_class_id = db.query(Tea).filter(Tea.id == s.get("class_id")).first()
+        # 查询 teachers 表确认 advisor_id 存在
+        s1_advisor_id = db.query(Tea).filter(Tea.id == s.get("advisor_id")).first()
+        if not s1_class_id:
+            raise ValueError(f"班级ID {s.get('class_id')} 不存在，请先创建班级")
+        if not s1_advisor_id:
+            raise ValueError(f"顾问ID {s.get('advisor_id')} 不存在，请先创建顾问")
         if s1_deleted and s1_deleted.is_deleted == True:
             s1_deleted.name = s.get("name")
             s1_deleted.age = s.get("age")
@@ -90,18 +99,22 @@ def add_student_dao( s , db):
             db.commit()
             db.refresh(s1_deleted)  # 从数据库再拉一次数据
             return s1_deleted
-        s1 = Students( **s )
+        s1 = Students(**s)
+        # 显式设置时间，避免 SQLAlchemy 字典构建时跳过 default
+        now = datetime.now()
+        s1.create_date = now
+        s1.update_date = now
         db.add(s1)
+        db.commit()
     except ValueError as e:
         # 业务校验异常：回滚并返回错误信息
         db.rollback()
         return {"code": 400, "msg": str(e)}
-    except Exception:
+    except Exception as e:
         # 这里可以加日志
         db.rollback()
         return {"code": 500, "msg": f"系统异常: {str(e)}"}
     else:
-        db.commit()
         db.refresh(s1)
         return s1
 
@@ -120,7 +133,7 @@ def update_student_dao( s , db):
         if not s1_id:
             raise HTTPException(status_code=404, detail=f'学生不存在：id={s.get("id")}')
         if s.get("num") is not None:
-            s1_id.name = s.get("num")
+            s1_id.num = s.get("num")
         if s.get("name") is not None:
             s1_id.name = s.get("name")
         if s.get("age") is not None:
@@ -146,15 +159,15 @@ def update_student_dao( s , db):
             s1_id.advisor_id = s.get("advisor_id")
         # 额外字段
         if s.get("phone") is not None:
-            s1_id.student_phone = s.get("phone")
+            s1_id.phone = s.get("phone")
+        s1_id.update_date = datetime.now()
+        db.commit()
     except HTTPException:
         raise
     except Exception:
         db.rollback()
         raise
     else:
-        s1_id.update_date = datetime.now()
-        db.commit()
         db.refresh(s1_id)  # 从数据库再拉一次数据
         return s1_id
 
@@ -204,7 +217,7 @@ def delete_student_dao( s , db):
         if s.get('class_id'):
             q = q.filter(Students.class_id == s.get("class_id") )
         if s.get('advisor_id'):
-            q = q.filter(Students.advisor_id == s.get("v") )
+            q = q.filter(Students.advisor_id == s.get("advisor_id") )
         if s.get("phone"):
             q = q.filter(Students.phone == s.get("phone") )
         s1_delete = q.all()

students/model/students_model.py

@@ -30,7 +30,7 @@ class Students(Base_all):
                  , comment='年龄'
                  , nullable=False)
 
-    sex = Column(Enum(SexEnum, values_callable=lambda e: [i.value for i in e])
+    sex = Column(Enum(SexEnum)
                  , comment='性别'
                  , nullable=False)
 
@@ -49,7 +49,7 @@ class Students(Base_all):
     graduate_time = Column(DATETIME
                            , comment='毕业时间')
 
-    education = Column(Enum(EducationEnum, values_callable=lambda e: [i.value for i in e])
+    education = Column(Enum(EducationEnum)
                        , comment='学历'
                        , nullable=True)
 

students/schema/students_request.py

@@ -1,6 +1,6 @@
 # students_schema：请求、响应的模型框架
 
-from pydantic import BaseModel , Field , field_validator
+from pydantic import BaseModel , Field
 from datetime import datetime
 import enum
 
@@ -8,6 +8,12 @@ class SexEnum(str , enum.Enum):
     m = '男'
     f = '女'
 
+class EducationEnum(str , enum.Enum):
+    z = '专科'
+    ben = '本科'
+    s = '硕士'
+    bo = '博士'
+
 # 查询
 class StudentsQuery(BaseModel):
     id:int | None = None
@@ -20,18 +26,14 @@ class StudentsQuery(BaseModel):
     specialty:str | None = None
     enrollment_time:datetime | None = None
     graduate_time:datetime | None = None
-    education:str | None = None
+    education:EducationEnum | None = None
     # 外键字段
     class_id:int | None = None
     advisor_id:int | None = None
     # 额外字段
     phone:str | None = None
 
-class EducationEnum(str , enum.Enum):
-    z = '专科'
-    ben = '本科'
-    s = '硕士'
-    bo = '博士'
+
 
 # 新建
 class StudentsResponse(BaseModel):
@@ -47,7 +49,7 @@ class StudentsResponse(BaseModel):
     education:EducationEnum
     # 外键字段
     class_id:int = Field(..., gt=0, description='班级ID')
-    advisor_id:int | None = None
+    advisor_id:int = Field(..., gt=0, description='班级ID')
     # 额外字段
     phone:str = Field(...,min_length=11,max_length=11,description='学生手机号')
 
@@ -63,7 +65,7 @@ class StudentsUpdate(BaseModel):
     specialty:str | None = None
     enrollment_time:datetime | None = None
     graduate_time:datetime | None = None
-    education:str | None = None
+    education:EducationEnum | None = None
     # 外键字段
     class_id:int | None = None
     advisor_id:int | None = None
@@ -82,7 +84,7 @@ class StudentsDelete(BaseModel):
     specialty:str | None = None
     enrollment_time:datetime | None = None
     graduate_time:datetime | None = None
-    education:str | None = None
+    education:EducationEnum | None = None
     # 外键字段
     class_id:int | None = None
     advisor_id:int | None = None