From 946d428c8b1055c1310ee077143cfd08181b203f Mon Sep 17 00:00:00 2001 From: lookerzz <1031516901@qq.com> Date: Mon, 21 Sep 2026 19:55:51 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E5=AE=8C=E5=96=84=E7=BB=9F=E8=AE=A1?= =?UTF-8?q?=E6=A8=A1=E5=9D=97=E5=8F=8A=E6=A8=A1=E5=9E=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .gitignore | 7 +- api/statistics.py | 65 ++++++++++- dao/statistics.py | 58 +++++++++- docs/模型与建表改动说明.md | 217 +++++++++++++++++++++++++++++++++++++ models/class_model.py | 12 +- models/class_teacher.py | 33 +++--- models/consultant.py | 9 +- models/employment.py | 17 ++- models/score.py | 22 ++-- models/student.py | 33 ++++-- models/teacher.py | 14 ++- 11 files changed, 428 insertions(+), 59 deletions(-) create mode 100644 docs/模型与建表改动说明.md diff --git a/.gitignore b/.gitignore index bde1ffa..b220eb5 100644 --- a/.gitignore +++ b/.gitignore @@ -15,4 +15,9 @@ env/ # 系统垃圾 .DS_Store -Thumbs.db \ No newline at end of file +Thumbs.db + + +.idea/ +.idea.backup/ +.run/ \ No newline at end of file diff --git a/api/statistics.py b/api/statistics.py index 082f7f4..4875d0f 100644 --- a/api/statistics.py +++ b/api/statistics.py @@ -1,9 +1,10 @@ from fastapi import APIRouter,HTTPException,Depends -from DoubaoTeam.core.database import get_db -from DoubaoTeam.models.student import Student -from DoubaoTeam.models.score import Score -from DoubaoTeam.dao.statistics import * -from DoubaoTeam.schemas.common import SuccessResponse +from core.database import get_db +from models.employment import Employment +from models.student import Student +from models.score import Score +from dao.statistics import * +from schemas.common import SuccessResponse from sqlalchemy.orm import Session @@ -26,3 +27,57 @@ def api_gender_count(db:Session=Depends(get_db)): except NoExist as e: raise HTTPException(status_code=404,detail=str(e)) +@statistics_router.get("/scores/all-above-80",response_model=SuccessResponse) +def all_above_eighty(db:Session=Depends(get_db)): + try: + result = score_over_eighty(Score,Student,db) + return SuccessResponse(status_code=200,msg=result) + except NoExist as e: + raise HTTPException(status_code=404,detail=str(e)) + +@statistics_router.get("/scores/fail-more-than-two",response_model=SuccessResponse) +def fail_two(db:Session=Depends(get_db)): + try: + result = twice_error(Score,Student,db) + return SuccessResponse(status_code=200,msg=result) + except NoExist as e: + raise HTTPException(status_code=404,detail=str(e)) + +@statistics_router.get("/scores/class-average",response_model=SuccessResponse) +def class_average(db:Session=Depends(get_db)): + try: + result = avg_class(Score,Student,db) + return SuccessResponse(status_code=200,msg=result) + except NoExist as e: + raise HTTPException(status_code=404,detail=str(e)) + + +@statistics_router.get("/employments/top5-salary",response_model=SuccessResponse) +def top_salary(db:Session=Depends(get_db)): + try: + result=max_salary(Student,Employment,db) + return SuccessResponse(status_code=200,msg=result) + except NoExist as e: + raise HTTPException(status_code=404,detail=str(e)) + +@statistics_router.get("/employments/student-duration",response_model=SuccessResponse) +def employ_time(db:Session=Depends(get_db)): + try: + result = student_market(Employment,db) + return SuccessResponse(status_code=200,msg=result) + except NoExist as e: + raise HTTPException(status_code=404,detail=str(e)) + +@statistics_router.get("/employments/class-average-duration",response_model=SuccessResponse) +def avg_employ_time(db:Session=Depends(get_db)): + try: + result = avg_class(Employment,Student,db) + return SuccessResponse(status_code=200,msg=result) + except NoExist as e: + raise HTTPException(status_code=404,detail=str(e)) + + + + + + diff --git a/dao/statistics.py b/dao/statistics.py index 6b7c9e8..fdfe20b 100644 --- a/dao/statistics.py +++ b/dao/statistics.py @@ -1,6 +1,6 @@ -from DoubaoTeam.schemas.statistics import NoExist +from schemas.statistics import NoExist from sqlalchemy import func - +from time import time #`GET /statistics/students/age-over-30` #查询所有超过 30 岁的学员信息 @@ -23,8 +23,58 @@ def gender_count(Student,db): #查询每次考试成绩都在 80 分以上的学生编号、姓名和成绩 def score_over_eighty(Score,Student,db): student_list=db.query(Student.id, Student.student_name)\ - .join(Student,Score.student_id==Student.id).group_by(Student.student_no,Student.student_name)\ + .join(Score,Score.student_id==Student.id).group_by(Student.student_no,Student.student_name)\ .having(func.min(Score.score)>80).all() + if not student_list : + raise NoExist('全是学渣') + list1 = [] for i in student_list: - student_list2 = db.query(Student.student_no, Student.student_name,Score.score).join(Student,Score.student_id==Student.id).filter(i.id==Student.id).all() + student_list2 = db.query(Student.student_no, Student.student_name,Score.score).join(Score,Score.student_id==Student.id).filter(i.id==Student.id).all() + if student_list2 : + list1.extend(student_list2) + return list1 +#查询有两次以上不及格的学生姓名、班级和不及格成绩 +def twice_error(Score,Student,db): + student_list=db.query(Score.student_id).filter(Score.score<60).group_by(Score.student_id).having(func.count(Score.id)>1).all() + if not student_list : + raise NoExist('全是学霸') + list1=[] + for i in student_list: + result=db.query(Student.student_name,Student.class_id,Score.score).join(Score, Student.id==Score.student_id)\ + .filter(i.student_id==Score.student_id,Score.score<60).all() + list1.extend(result) + return list1 + +#统计每次考试每个班级的平均分，并按照平均分从高到低排序 +def avg_class(Score,Student,db): + student_list = db.query(Student.class_id,Score.exam_seq,func.avg(Score.score)).join(Score, Student.id == Score.student_id).group_by(Student.class_id,Score.exam_seq).order_by(func.avg(Score.score).desc()).all() + if not student_list : + raise NoExist('招个人吧') + return student_list + +#统计就业薪资最高的前五名学生姓名、班级、就业时间、就业公司 +def max_salary(Student,Employment,db): + student_list = db.query(Student.student_name,Student.class_id,Employment.offer_date,Employment.company_name).join(Employment, Student.id == Employment.student_id).order_by(Employment.salary_max.desc()).limit(5).all() + if not student_list : + raise NoExist('没就业的啊兄弟？') + return student_list + +# - 统计每个学生的就业时长 +# - 就业时长 = `offer_date - employment_open_date` +def student_market(Employment,db): + student_list = db.query(Employment.student_id,func.datediff(Employment.offer_date,Employment.employment_open_date)).all() + return student_list + +# - 统计每个班级的平均就业时长 +# - 只统计有就业开放时间的学生 +def avg_emptime(Employment,Student,db): + student_list = (db.query(Student.class_id,\ + func.avg(func.datediff(Employment.offer_date,Employment.employment_open_date)))\ + .join(Employment, Student.id==Employment.student_id).filter(Employment.employment_open_date.is_not(None)))\ + .group_by(Student.class_id).all() + if not student_list : + raise NoExist('一个就业都没有吗') + return student_list + + diff --git a/docs/模型与建表改动说明.md b/docs/模型与建表改动说明.md new file mode 100644 index 0000000..933eb42 --- /dev/null +++ b/docs/模型与建表改动说明.md @@ -0,0 +1,217 @@ +# 数据库模型与建表工具改动说明 + +本次按照《沃林学生管理系统小组分工说明书 V1》修正模型定义，整理范围为 7 个 Model 文件和 1 个建表脚本。各模块继续使用 `core.database.Base`，保留原有 Python 类名和项目目录。 + +## 一、改动总览 + +| 模块 | 负责人 | 修改文件 | 模型类 | 最终表名 | +|---|---|---|---|---| +| 学生管理 | 李玉杰 | `models/student.py` | `Student` | `students` | +| 班级管理 | 婷婷 | `models/class_model.py` | `Classes` | `classes` | +| 老师管理 | 张义 | `models/teacher.py` | `Teacher` | `teachers` | +| 班级老师关系 | 张义 | `models/class_teacher.py` | `ClassTeachers` | `class_teachers` | +| 顾问管理 | 薄鑫 | `models/consultant.py` | `Consultant` | `consultants` | +| 成绩管理 | 曾凯 | `models/score.py` | `Score` | `scores` | +| 就业管理 | 南方宇 | `models/employment.py` | `Employment` | `employments` | +| 公共建库建表工具 | 张昕浩 | `utils/create database.py` | — | 使用上述全部模型 | + +### 经确认保留的类型 + +本次没有将所有主键统一为文档中的 `BIGINT`，成绩精度也按已确认的要求保留。 + +| 项目 | 当前模型类型 | +|---|---| +| 学生、班级、老师、顾问、成绩表的 `id` | `Integer` | +| 班级老师关系表、就业表的 `id` | `BigInteger` | +| 各表关联其他表的外键字段 | `Integer`，与对应模型的主键一致 | +| 成绩字段 `scores.score` | `DECIMAL(4,1)` | +| 薪资字段 `employments.salary` | `DECIMAL(10,2)` | + +其中 `class_teachers.class_id`、`class_teachers.teacher_id`、`employments.student_id` 原为 `BigInteger`，经确认改为 `Integer`，解决 MySQL 要求外键与被引用主键类型一致的问题。 + +## 二、公共字段调整 + +以下规则落实在各个 Model 文件中，没有增加公共模型文件或额外继承层。 + +| 字段 | 最终定义及作用 | +|---|---| +| `created_at` | `DATETIME`、不可为空；保留 ORM 创建时间默认值，增加数据库默认值 `CURRENT_TIMESTAMP` | +| `updated_at` | `DATETIME`、不可为空；使用 `onupdate=datetime.now`，增加数据库默认值及 `ON UPDATE CURRENT_TIMESTAMP` | +| `is_deleted` | MySQL `TINYINT`、不可为空；ORM 默认值和数据库默认值均为 `0` | + +原先误用 `sqlalchemy.dialects.mssql.TINYINT` 的老师、班级老师关系模型，改为从 `sqlalchemy.dialects.mysql` 导入。 + +`is_deleted` 是逻辑删除标志。Model 中声明这个字段不会自动过滤查询；接口查询仍需添加 `is_deleted == 0`，删除业务记录应更新该标志。 + +## 三、学生管理模块 + +文件：`models/student.py`；负责人：李玉杰。 + +| 修改项 | 修改前 | 修改后 | +|---|---|---| +| 表名 | `student_info_detail` | `students` | +| 学生编号 | 唯一，但允许为空 | 唯一且 `nullable=False` | +| 学生姓名 | 允许为空 | `nullable=False` | +| 班级外键 | `foreign_key='class_info_detail.id'`，不是有效外键声明 | `ForeignKey('classes.id')`，并设为非空 | +| 顾问外键 | `foreign_key='consultant_info_detail.id'`，不是有效外键声明 | `ForeignKey('consultants.id')`，继续允许为空 | +| 毕业院校字段 | `graduation_school` | `graduate_school` | +| 创建时间字段 | `create_at` | `created_at` | +| 更新时间字段 | `update_at` | `updated_at` | +| 逻辑删除 | `Integer`，允许为空 | MySQL `TINYINT`、非空、默认 `0` | + +时间字段按公共规则补齐数据库默认值及非空约束。学生主键、班级外键和顾问外键均保留 `Integer`。 + +## 四、班级管理模块 + +文件：`models/class_model.py`；负责人：婷婷。 + +| 修改项 | 修改前 | 修改后 | +|---|---|---| +| 开课日期 `start_date` | 允许为空 | `nullable=False`，开课时间必填 | +| 更新时间字段 | `update_at` | `updated_at` | +| 备注长度 | `String(100)` | `String(255)` | +| 逻辑删除 | `INTEGER` | MySQL `TINYINT`，补充数据库默认值 `0` | + +时间字段增加数据库默认值和数据库自动更新时间设置。保留表名 `classes`、类名 `Classes`、`Integer` 自增主键，以及班级编号唯一且非空的约束。 + +## 五、老师管理模块 + +文件：`models/teacher.py`；负责人：张义。 + +| 修改项 | 修改前 | 修改后 | +|---|---|---| +| 表名 | `teachers_info_detail` | `teachers` | +| 备注长度 | `VARCHAR(2550)` | `VARCHAR(255)` | +| `TINYINT` 来源 | SQL Server 方言 | MySQL 方言 | +| 更新时间 | 仅设置创建时的默认时间 | 补充 `onupdate=datetime.now` 和数据库自动更新时间 | + +创建时间增加数据库默认值，逻辑删除增加数据库默认值 `0`。保留 `Integer` 自增主键和老师编号唯一约束。 + +## 六、班级老师关系模块 + +文件：`models/class_teacher.py`；负责人：张义。 + +| 修改项 | 修改前 | 修改后 | +|---|---|---| +| 表名 | `class_teachers_info_detail` | `class_teachers` | +| 班级外键目标 | `ForeignKey('class_id')` | `ForeignKey('classes.id')` | +| 老师外键目标 | `ForeignKey('teacher_id')` | `ForeignKey('teachers.id')` | +| 两个外键字段类型 | `BigInteger` | `Integer`，与班级、老师模型主键匹配 | +| 联合唯一约束 | 未设置 | `(class_id, teacher_id, role)` 联合唯一 | +| 联合唯一约束名称 | — | `uk_class_teacher_role` | +| 时间默认值 | `datetime.now()`，导入模型时就求值 | `datetime.now`，插入记录时再求值 | +| `TINYINT` 来源 | SQL Server 方言 | MySQL 方言 | + +补齐时间及逻辑删除的数据库默认值，并为更新时间增加自动更新设置。关系表自身的 `id` 保留 `BigInteger`，类名保留 `ClassTeachers`。 + +联合唯一约束防止同一个老师以同一个角色被重复分配到同一个班级。 + +## 七、顾问管理模块 + +文件：`models/consultant.py`；负责人：薄鑫。 + +| 修改项 | 修改前 | 修改后 | +|---|---|---| +| 联系电话长度 | `String(11)` | `String(20)` | +| 逻辑删除类型 | `Integer` | MySQL `TINYINT` | +| 数据库默认值 | 未声明 | 补充创建时间、更新时间和逻辑删除默认值 | + +保留表名 `consultants`、`Integer` 自增主键、顾问编号唯一且非空的约束，以及其余业务字段。 + +## 八、成绩管理模块 + +文件：`models/score.py`；负责人：曾凯。 + +| 修改项 | 修改前 | 修改后 | +|---|---|---| +| 表名 | `score_info_detail` | `scores` | +| 学生外键目标 | `ForeignKey('student.id')` | `ForeignKey('students.id')` | +| 成绩是否必填 | 允许为空 | `nullable=False` | +| 联合唯一约束名称 | `uk_student_exam_seq` | `uk_scores_student_exam` | +| 备注长度 | `String(225)` | `String(255)` | +| 逻辑删除 | `Integer`，允许为空 | MySQL `TINYINT`、非空、默认 `0` | + +创建时间和更新时间补齐非空约束、数据库默认值及自动更新设置；修正注释，明确联合唯一约束是“学生 ID + 考核序次”。 + +保留 `Integer` 主键及学生外键，成绩精度保留 `DECIMAL(4,1)`，保留成绩范围 `0～100` 的检查约束。一个学生同一次考核只能有一条成绩。 + +## 九、就业管理模块 + +文件：`models/employment.py`；负责人：南方宇。 + +| 修改项 | 修改前 | 修改后 | +|---|---|---| +| 学生外键类型 | `BigInteger` | `Integer`，与学生模型主键匹配 | +| 学生就业唯一约束 | 未设置 | `student_id` 增加 `unique=True` | +| 就业状态长度 | `String(50)` | `String(30)` | +| 就业状态是否必填 | 允许为空 | `nullable=False` | +| 逻辑删除 | `SmallInteger`，允许为空 | MySQL `TINYINT`、非空、默认 `0` | + +创建时间和更新时间补齐非空约束、数据库默认值及自动更新设置。修正薪资字段注释：`DECIMAL` 是定点小数。 + +保留表名 `employments`、`BigInteger` 自增主键、`ForeignKey('students.id')`，以及薪资精度 `DECIMAL(10,2)`。学生外键唯一约束确保每个学生最多对应一条就业信息。 + +## 十、公共建库建表工具 + +文件：`utils/create database.py`；负责人：张昕浩。文件名中包含一个空格。 + +脚本执行流程： + +1. 将项目根目录加入当前进程的导入路径，使直接运行此文件时也能导入 `core` 和 `models`。 +2. 导入全部 7 个模型，将模型表注册到公共 `Base.metadata`。 +3. 检查整数外键与被引用主键的类型是否一致；不一致时列出具体字段并以失败状态退出。 +4. 从现有 `core.database.engine` 读取连接设置，先连接不指定数据库的 MySQL 服务。 +5. 创建缺失的数据库，字符集为 `utf8mb4`、排序规则为 `utf8mb4_unicode_ci`；当前配置库名为 `student_manager`。 +6. 调用 `Base.metadata.create_all(bind=engine)` 创建缺失的表。 +7. 查询实际表名，确认全部模型对应的表均存在。 +8. 释放数据库连接池；发生数据库或检查错误时输出原因，并返回非零退出码。 + +在项目根目录运行： + +```powershell +python "utils/create database.py" +``` + +本机已验证使用的解释器命令： + +```powershell +& 'D:\conda\envs\ai0720\python.exe' -B -X utf8 '.\utils\create database.py' +``` + +脚本只创建缺失的库和表，不清空数据、不删除表，也不自动修改已有表结构。 + +## 十一、验证结果及范围 + +完成三处外键类型修正后，脚本退出码为 `0`，输出如下： + +```text +数据库已就绪：student_manager +已导入的模型表： classes, teachers, consultants, students, class_teachers, scores, employments +建表检查通过：全部模型对应的表均已存在。 +``` + +已经完成的检查包括： + +- 7 个模型可以导入，6 个外键目标均能解析。 +- 外键与被引用主键在模型中的类型检查通过。 +- 7 张表的 MySQL 建表 SQL 可以编译。 +- 字段名、非空设置、字符串长度与本次对照结果一致。 +- 班级老师关系、成绩和就业的必要唯一约束已在模型中定义。 +- 7 个模型可以读取现有数据库中的对应表。 +- 文件差异格式检查通过。 + +本次执行针对已有的 `student_manager` 数据库。`create_all()` 会跳过已有表，因此此结果不等同于已经在全新空库中完成端到端创建测试，也不表示现有数据库已经迁移成当前模型定义。 + +现有库中的相关主外键仍为原来的 `BIGINT`，成绩列仍为原来的 `DECIMAL(5,2)`；本次没有执行 `ALTER TABLE`，模型里经确认保留的 `Integer` 和 `DECIMAL(4,1)` 不会自动改变这些实库类型。 + +## 十二、后续接口联调事项 + +以下配套代码不在本次修改范围内，需要模块负责人继续核对： + +| 位置 | 需要核对的内容 | +|---|---| +| `schemas/class_schema.py` 的 `ClassCreate` | 当前缺少 `start_date`，而模型规定开课日期必填 | +| `schemas/class_schema.py` 的 `ClassUpdate` | 当前仍使用 `update_at`，模型字段已统一为 `updated_at` | +| 学生新增及业务编号生成逻辑 | `student_no` 已设为非空；先以空编号执行 `flush()` 再生成编号会违反非空约束，需要与编号生成方案协调 | + +本次验证覆盖模型和建表工具，尚未完成上述业务接口的联调验证。 diff --git a/models/class_model.py b/models/class_model.py index 8c7935d..0610b8d 100644 --- a/models/class_model.py +++ b/models/class_model.py @@ -1,6 +1,7 @@ from sqlalchemy import * # 导入sqlalchemy模块下所有的类，以便下面创建班级表模型和声明表的字段 from datetime import datetime # 导入datetime模块下的datetime类 from core.database import Base # 从core软件包下的database模块导入Base +from sqlalchemy.dialects.mysql import TINYINT class Classes( Base ): # 在python里的名字 __tablename__ = 'classes' # 在数据库中表的名字 @@ -21,7 +22,7 @@ class Classes( Base ): # 在python里的名字 ) # ————创建班级"开课时间"的字段名———— start_date = Column( DATE # 声明是字段数据类型是日期 - , nullable = True # 声明是'可为空' + , nullable = False # 开课时间必填 ) # ————创建班级"结课时间"的字段名———— end_date = Column( DATE # 声明是字段数据类型是'日期' @@ -30,20 +31,23 @@ class Classes( Base ): # 在python里的名字 # ————创建班级"创建时间"的字段名———— created_at = Column( DATETIME # 声明是字段数据类型是"日期时间" , default=datetime.now # 声明是创建的默认值就是"当前时间" + , server_default=text("CURRENT_TIMESTAMP") , nullable = False # 声明是"非空" ) # ————创建班级"更新时间"的字段名———— - update_at = Column( DATETIME # 声明是字段数据类型是"日期时间" + updated_at = Column( DATETIME # 声明是字段数据类型是"日期时间" , default=datetime.now #声明是第一次更新的时间就是第一次创建的时间一致 , onupdate=datetime.now # 声明"最后修改的时间" + , server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") , nullable = False # 声明是"非空" ) # ————创建班级"备注信息"的字段名———— - remark = Column( String(100) # 声明是字段数据类型是"字符串" + remark = Column( String(255) # 声明是字段数据类型是"字符串" , nullable = True # 声明是"可以为空" ) # ————创建班级"逻辑删除"的字段名———— - is_deleted = Column( INTEGER # 声明是字段数据类型是"数字" + is_deleted = Column( TINYINT # 逻辑删除标记 , default = 0 # 声明默认值是"0，未删除" + , server_default = text("0") , nullable = False # 声明是"非空" ) diff --git a/models/class_teacher.py b/models/class_teacher.py index 537ef65..701b9ce 100644 --- a/models/class_teacher.py +++ b/models/class_teacher.py @@ -1,32 +1,35 @@ from sqlalchemy import (Column, Integer, String, Text, - BigInteger,ForeignKey,VARCHAR,DateTime + BigInteger,ForeignKey,VARCHAR,DateTime,UniqueConstraint,text ) -from sqlalchemy.dialects.mssql import TINYINT +from sqlalchemy.dialects.mysql import TINYINT from core.database import Base from datetime import datetime -#班级老师关系表 class_teachers_info_detail 中间表 ORM 模型完整定义 +#班级老师关系表 class_teachers 中间表 ORM 模型完整定义 #字段包括id,class_id,teacher_id,role,created_at,updated_at,is_deleted class ClassTeachers(Base): - __tablename__ = "class_teachers_info_detail" + __tablename__ = "class_teachers" + __table_args__ = ( + UniqueConstraint("class_id", "teacher_id", "role", name="uk_class_teacher_role"), + ) id = Column( BigInteger ,primary_key=True ,autoincrement=True ,comment='关系') class_id = Column( - BigInteger - ,ForeignKey('class_id') + Integer + ,ForeignKey('classes.id') ,nullable=False - ,comment='关联 class_id' + ,comment='关联 classes.id' ) teacher_id = Column( - BigInteger - ,ForeignKey('teacher_id') + Integer + ,ForeignKey('teachers.id') ,nullable=False - ,comment='关联 teacher_id' + ,comment='关联 teachers.id' ) role = Column( VARCHAR(30) @@ -36,18 +39,22 @@ class ClassTeachers(Base): created_at = Column( DateTime ,nullable=False - ,default=datetime.now() + ,default=datetime.now + ,server_default=text("CURRENT_TIMESTAMP") ,comment='创建时间' ) updated_at = Column( DateTime ,nullable=False - ,default=datetime.now() + ,default=datetime.now + ,onupdate=datetime.now + ,server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") ,comment='更新时间' ) is_deleted = Column( TINYINT ,nullable=False ,default=0 + ,server_default=text("0") ,comment='逻辑删除' - ) \ No newline at end of file + ) diff --git a/models/consultant.py b/models/consultant.py index d51ac3d..d261f52 100644 --- a/models/consultant.py +++ b/models/consultant.py @@ -1,5 +1,6 @@ from sqlalchemy import * +from sqlalchemy.dialects.mysql import TINYINT from datetime import datetime from core.database import Base class Consultant(Base): @@ -8,10 +9,10 @@ class Consultant(Base): id = Column(Integer, primary_key=True, autoincrement=True, comment="主键") consultant_no = Column(String(50), unique=True, nullable=False, comment="顾问编号") consultant_name = Column(String(50), nullable=False, comment="顾问姓名") - phone = Column(String(11), nullable=True, comment="联系电话") + phone = Column(String(20), nullable=True, comment="联系电话") email = Column(String(100), nullable=True, comment="邮箱") remark = Column(String(255), nullable=True, comment="备注") - created_at = Column(DateTime, default=datetime.now, nullable=False, comment="创建时间") - updated_at = Column(DateTime, default=datetime.now, onupdate=datetime.now, nullable=False, comment="更新时间") - is_deleted = Column(Integer, default=0, nullable=False, comment="逻辑删除：0正常，1删除") + created_at = Column(DateTime, default=datetime.now, server_default=text("CURRENT_TIMESTAMP"), nullable=False, comment="创建时间") + updated_at = Column(DateTime, default=datetime.now, onupdate=datetime.now, server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP"), nullable=False, comment="更新时间") + is_deleted = Column(TINYINT, default=0, server_default=text("0"), nullable=False, comment="逻辑删除：0正常，1删除") diff --git a/models/employment.py b/models/employment.py index 69e2706..199d275 100644 --- a/models/employment.py +++ b/models/employment.py @@ -1,4 +1,5 @@ from sqlalchemy import * +from sqlalchemy.dialects.mysql import TINYINT from sqlalchemy.orm import declarative_base,sessionmaker from datetime import datetime from core.database import Base, engine @@ -10,11 +11,13 @@ class Employment(Base): id = Column(BigInteger, primary_key=True # 主键 , autoincrement=True # 声明是自增主键 ,comment="就业信息主键id") - student_id = Column(BigInteger, ForeignKey("students.id") # 外键 -> students.id + student_id = Column(Integer, ForeignKey("students.id") # 外键 -> students.id , nullable=False # 不允许为null + , unique=True # 每个学生只对应一条就业信息 ,comment="关联学生id") - employment_status = Column(String(50) + employment_status = Column(String(30) , default="not_started" + , nullable=False ,comment="就业状态:not_started/job_hunting/offered/employed") employment_open_date = Column(Date ,comment="就业开放时间") @@ -22,19 +25,25 @@ class Employment(Base): ,comment="offer下发时间") company_name = Column(String(100) , comment="就业公司名称") - salary = Column(DECIMAL(10, 2) # 高精度浮点数薪资,最多 10 位数字，小数占 2 位 + salary = Column(DECIMAL(10, 2) # 定点小数薪资，最多10位数字，小数占2位 , comment="就业薪资") remark = Column(String(255) ,default=None , comment="备注信息") created_at = Column(DateTime , default=datetime.now + , server_default=text("CURRENT_TIMESTAMP") + , nullable=False , comment="创建时间") updated_at = Column(DateTime , default=datetime.now , onupdate=datetime.now + , server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") + , nullable=False ,comment="更新时间") - is_deleted = Column(SmallInteger + is_deleted = Column(TINYINT ,default=0 + ,server_default=text("0") + ,nullable=False ,comment="逻辑删除：0正常，1删除") diff --git a/models/score.py b/models/score.py index c7fe39c..c7ebe9d 100644 --- a/models/score.py +++ b/models/score.py @@ -1,20 +1,22 @@ from sqlalchemy import * +from sqlalchemy.dialects.mysql import TINYINT from core.database import Base from datetime import datetime,date class Score(Base): - __tablename__ = "score_info_detail" + __tablename__ = "scores" id = Column(Integer , primary_key=True ,autoincrement=True ,comment="成绩表序号，自增主键" ) student_id = Column(Integer - ,ForeignKey("student.id") + ,ForeignKey("students.id") ,nullable=False ,comment="学生学号" ) score = Column(DECIMAL(4,1) ,CheckConstraint("score between 0 and 100") + ,nullable=False ) exam_seq= Column(Integer , nullable=False @@ -22,25 +24,31 @@ class Score(Base): __table_args__ = ( UniqueConstraint("student_id" , "exam_seq" - , name="uk_student_exam_seq"), - )#学生id和学生姓名应为联合唯一，即一个学生一次考试只能有一个分数 + , name="uk_scores_student_exam"), + )#学生id和考核序次联合唯一，即一个学生一次考试只能有一个分数 exam_date=Column(Date ,default=date.today ,comment="考试日期" ) created_at=Column(DateTime ,default=datetime.now + ,server_default=text("CURRENT_TIMESTAMP") + ,nullable=False ,comment="创建时间" ) updated_at=Column(DateTime ,default=datetime.now ,onupdate=datetime.now + ,server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") + ,nullable=False ,comment="更新时间" ) - remark=Column(String(225) + remark=Column(String(255) ,comment="备注说明" ) - is_deleted=Column(Integer + is_deleted=Column(TINYINT ,default=0 + ,server_default=text("0") + ,nullable=False ,comment="逻辑删除标记：未删除0，已删除1" - ) \ No newline at end of file + ) diff --git a/models/student.py b/models/student.py index 990a693..97a70a9 100644 --- a/models/student.py +++ b/models/student.py @@ -1,27 +1,30 @@ from core.database import Base from sqlalchemy import * +from sqlalchemy.dialects.mysql import TINYINT from datetime import datetime class Student(Base): - __tablename__ = 'student_info_detail' + __tablename__ = 'students' id = Column(Integer , primary_key=True , autoincrement=True , comment = '学生编号，自增主键' ) student_no = Column(VARCHAR(50) - , unique = True) - student_name = Column(VARCHAR(50)) + , unique = True + , nullable = False) + student_name = Column(VARCHAR(50), nullable=False) class_id = Column(Integer - ,foreign_key = 'class_info_detail.id' + ,ForeignKey('classes.id') + ,nullable = False )#外键约束 班级表的主键id，存在这个班级，学生表才可以输入 consultant_id = Column(Integer + ,ForeignKey('consultants.id') ,nullable = True - ,foreign_key = 'consultant_info_detail.id' )#外键约束 顾问表的主键id，存在这个顾问，才可以写入，允许为空 native_place = Column(VARCHAR(100) ,nullable = True) - graduation_school = Column(VARCHAR(100) + graduate_school = Column(VARCHAR(100) ,nullable = True) major = Column(VARCHAR(100) ,nullable = True) @@ -35,11 +38,17 @@ class Student(Base): ,nullable = False) gender = Column(VARCHAR(10) ,nullable = False) - create_at = Column(DATETIME - ,default = datetime.now) - update_at = Column(DATETIME + created_at = Column(DATETIME ,default = datetime.now - ,onupdate = datetime.now) - is_deleted = Column(Integer - ,default = 0)#逻辑删除，默认为0，为1则表示已删除 + ,server_default = text("CURRENT_TIMESTAMP") + ,nullable = False) + updated_at = Column(DATETIME + ,default = datetime.now + ,onupdate = datetime.now + ,server_default = text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") + ,nullable = False) + is_deleted = Column(TINYINT + ,default = 0 + ,server_default = text("0") + ,nullable = False)#逻辑删除，默认为0，为1则表示已删除 diff --git a/models/teacher.py b/models/teacher.py index 47998d0..180d342 100644 --- a/models/teacher.py +++ b/models/teacher.py @@ -1,6 +1,6 @@ -from sqlalchemy import (Column, Integer,VARCHAR,DateTime +from sqlalchemy import (Column, Integer,VARCHAR,DateTime,text ) -from sqlalchemy.dialects.mssql import TINYINT +from sqlalchemy.dialects.mysql import TINYINT from core.database import Base from datetime import datetime @@ -9,7 +9,7 @@ from datetime import datetime # teachers 老师表 ORM 模型 #字段包括id,teacher_no,teacher_name,phone,email,remark,created_at,updated_at,is_deleted class Teacher(Base): - __tablename__ = 'teachers_info_detail' + __tablename__ = 'teachers' id = Column( Integer , primary_key=True @@ -37,26 +37,30 @@ class Teacher(Base): ,comment='邮箱' ) remark = Column( - VARCHAR(2550) + VARCHAR(255) ,nullable=True ,comment='备注' ) created_at = Column( - DateTime + DateTime ,nullable=False ,default=datetime.now + ,server_default=text("CURRENT_TIMESTAMP") ,comment='创建时间' ) updated_at = Column( DateTime ,nullable=False ,default=datetime.now + ,onupdate=datetime.now + ,server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") ,comment='更新时间' ) is_deleted = Column( TINYINT ,nullable=False ,default=0 + ,server_default=text("0") ,comment='逻辑删除' ) From 1c220c2a3e1132a5cccb9e6b9874e5d470927d0d Mon Sep 17 00:00:00 2001 From: lookerzz <1031516901@qq.com> Date: Mon, 21 Sep 2026 19:59:58 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E7=A7=BB=E9=99=A4=E4=B8=8Emain=E5=86=B2?= =?UTF-8?q?=E7=AA=81=E7=9A=84model=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- models/class_teacher.py | 29 +++++++++++------------------ models/employment.py | 21 ++++++--------------- models/score.py | 22 +++++++--------------- models/student.py | 33 ++++++++++++--------------------- models/teacher.py | 15 +++++---------- 5 files changed, 41 insertions(+), 79 deletions(-) diff --git a/models/class_teacher.py b/models/class_teacher.py index 701b9ce..37d1e35 100644 --- a/models/class_teacher.py +++ b/models/class_teacher.py @@ -1,35 +1,32 @@ from sqlalchemy import (Column, Integer, String, Text, - BigInteger,ForeignKey,VARCHAR,DateTime,UniqueConstraint,text + BigInteger,ForeignKey,VARCHAR,DateTime ) -from sqlalchemy.dialects.mysql import TINYINT +from sqlalchemy.dialects.mssql import TINYINT from core.database import Base from datetime import datetime -#班级老师关系表 class_teachers 中间表 ORM 模型完整定义 +#班级老师关系表 class_teachers_info_detail 中间表 ORM 模型完整定义 #字段包括id,class_id,teacher_id,role,created_at,updated_at,is_deleted class ClassTeachers(Base): - __tablename__ = "class_teachers" - __table_args__ = ( - UniqueConstraint("class_id", "teacher_id", "role", name="uk_class_teacher_role"), - ) + __tablename__ = "class_teachers_info_detail" id = Column( - BigInteger + Integer ,primary_key=True ,autoincrement=True ,comment='关系') class_id = Column( Integer - ,ForeignKey('classes.id') + ,ForeignKey('class_info_detail.id') ,nullable=False - ,comment='关联 classes.id' + ,comment='关联 class_id' ) teacher_id = Column( Integer - ,ForeignKey('teachers.id') + ,ForeignKey("teacher_info_detail.id") ,nullable=False - ,comment='关联 teachers.id' + ,comment='关联 teacher_id' ) role = Column( VARCHAR(30) @@ -39,22 +36,18 @@ class ClassTeachers(Base): created_at = Column( DateTime ,nullable=False - ,default=datetime.now - ,server_default=text("CURRENT_TIMESTAMP") + ,default=datetime.now() ,comment='创建时间' ) updated_at = Column( DateTime ,nullable=False - ,default=datetime.now - ,onupdate=datetime.now - ,server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") + ,default=datetime.now() ,comment='更新时间' ) is_deleted = Column( TINYINT ,nullable=False ,default=0 - ,server_default=text("0") ,comment='逻辑删除' ) diff --git a/models/employment.py b/models/employment.py index 199d275..76a1f7c 100644 --- a/models/employment.py +++ b/models/employment.py @@ -1,5 +1,4 @@ from sqlalchemy import * -from sqlalchemy.dialects.mysql import TINYINT from sqlalchemy.orm import declarative_base,sessionmaker from datetime import datetime from core.database import Base, engine @@ -7,17 +6,15 @@ from core.database import Base, engine # 为了符合三范式，就业表只保存 student_id，不保存学生姓名和班级名称。查询返回时通过关联 students 和 classes 带出学生姓名、班级名称。 class Employment(Base): - __tablename__ = "employments" # 实际数据库的表名字 - id = Column(BigInteger, primary_key=True # 主键 + __tablename__ = "employment_info_detail" # 实际数据库的表名字 + id = Column(Integer, primary_key=True # 主键 , autoincrement=True # 声明是自增主键 ,comment="就业信息主键id") - student_id = Column(Integer, ForeignKey("students.id") # 外键 -> students.id + student_id = Column(Integer, ForeignKey("student_info_detail.id") # 外键 -> students.id , nullable=False # 不允许为null - , unique=True # 每个学生只对应一条就业信息 ,comment="关联学生id") - employment_status = Column(String(30) + employment_status = Column(String(50) , default="not_started" - , nullable=False ,comment="就业状态:not_started/job_hunting/offered/employed") employment_open_date = Column(Date ,comment="就业开放时间") @@ -25,25 +22,19 @@ class Employment(Base): ,comment="offer下发时间") company_name = Column(String(100) , comment="就业公司名称") - salary = Column(DECIMAL(10, 2) # 定点小数薪资，最多10位数字，小数占2位 + salary = Column(DECIMAL(10, 2) # 高精度浮点数薪资,最多 10 位数字，小数占 2 位 , comment="就业薪资") remark = Column(String(255) ,default=None , comment="备注信息") created_at = Column(DateTime , default=datetime.now - , server_default=text("CURRENT_TIMESTAMP") - , nullable=False , comment="创建时间") updated_at = Column(DateTime , default=datetime.now , onupdate=datetime.now - , server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") - , nullable=False ,comment="更新时间") - is_deleted = Column(TINYINT + is_deleted = Column(SmallInteger ,default=0 - ,server_default=text("0") - ,nullable=False ,comment="逻辑删除：0正常，1删除") diff --git a/models/score.py b/models/score.py index c7ebe9d..90e9682 100644 --- a/models/score.py +++ b/models/score.py @@ -1,22 +1,20 @@ from sqlalchemy import * -from sqlalchemy.dialects.mysql import TINYINT from core.database import Base from datetime import datetime,date class Score(Base): - __tablename__ = "scores" + __tablename__ = "score_info_detail" id = Column(Integer , primary_key=True ,autoincrement=True ,comment="成绩表序号，自增主键" ) student_id = Column(Integer - ,ForeignKey("students.id") + ,ForeignKey("student_info_detail.id") ,nullable=False ,comment="学生学号" ) score = Column(DECIMAL(4,1) ,CheckConstraint("score between 0 and 100") - ,nullable=False ) exam_seq= Column(Integer , nullable=False @@ -24,31 +22,25 @@ class Score(Base): __table_args__ = ( UniqueConstraint("student_id" , "exam_seq" - , name="uk_scores_student_exam"), - )#学生id和考核序次联合唯一，即一个学生一次考试只能有一个分数 + , name="uk_student_exam_seq"), + )#学生id和学生姓名应为联合唯一，即一个学生一次考试只能有一个分数 exam_date=Column(Date ,default=date.today ,comment="考试日期" ) created_at=Column(DateTime ,default=datetime.now - ,server_default=text("CURRENT_TIMESTAMP") - ,nullable=False ,comment="创建时间" ) updated_at=Column(DateTime ,default=datetime.now ,onupdate=datetime.now - ,server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") - ,nullable=False ,comment="更新时间" ) - remark=Column(String(255) + remark=Column(String(225) ,comment="备注说明" ) - is_deleted=Column(TINYINT + is_deleted=Column(Integer ,default=0 - ,server_default=text("0") - ,nullable=False ,comment="逻辑删除标记：未删除0，已删除1" - ) + ) \ No newline at end of file diff --git a/models/student.py b/models/student.py index 97a70a9..ab805e4 100644 --- a/models/student.py +++ b/models/student.py @@ -1,30 +1,27 @@ from core.database import Base from sqlalchemy import * -from sqlalchemy.dialects.mysql import TINYINT from datetime import datetime class Student(Base): - __tablename__ = 'students' + __tablename__ = 'student_info_detail' id = Column(Integer , primary_key=True , autoincrement=True , comment = '学生编号，自增主键' ) student_no = Column(VARCHAR(50) - , unique = True - , nullable = False) - student_name = Column(VARCHAR(50), nullable=False) + , unique = True) + student_name = Column(VARCHAR(50)) class_id = Column(Integer - ,ForeignKey('classes.id') - ,nullable = False + ,ForeignKey('class_info_detail.id') )#外键约束 班级表的主键id，存在这个班级，学生表才可以输入 consultant_id = Column(Integer - ,ForeignKey('consultants.id') + , ForeignKey('consultant_info_detail.id') ,nullable = True )#外键约束 顾问表的主键id，存在这个顾问，才可以写入，允许为空 native_place = Column(VARCHAR(100) ,nullable = True) - graduate_school = Column(VARCHAR(100) + graduation_school = Column(VARCHAR(100) ,nullable = True) major = Column(VARCHAR(100) ,nullable = True) @@ -38,17 +35,11 @@ class Student(Base): ,nullable = False) gender = Column(VARCHAR(10) ,nullable = False) - created_at = Column(DATETIME + create_at = Column(DATETIME + ,default = datetime.now) + update_at = Column(DATETIME ,default = datetime.now - ,server_default = text("CURRENT_TIMESTAMP") - ,nullable = False) - updated_at = Column(DATETIME - ,default = datetime.now - ,onupdate = datetime.now - ,server_default = text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") - ,nullable = False) - is_deleted = Column(TINYINT - ,default = 0 - ,server_default = text("0") - ,nullable = False)#逻辑删除，默认为0，为1则表示已删除 + ,onupdate = datetime.now) + is_deleted = Column(Integer + ,default = 0)#逻辑删除，默认为0，为1则表示已删除 diff --git a/models/teacher.py b/models/teacher.py index 180d342..9c8c6bf 100644 --- a/models/teacher.py +++ b/models/teacher.py @@ -1,15 +1,14 @@ -from sqlalchemy import (Column, Integer,VARCHAR,DateTime,text +from sqlalchemy import (Column, Integer,VARCHAR,DateTime ) -from sqlalchemy.dialects.mysql import TINYINT +from sqlalchemy.dialects.mssql import TINYINT from core.database import Base from datetime import datetime - # teachers 老师表 ORM 模型 #字段包括id,teacher_no,teacher_name,phone,email,remark,created_at,updated_at,is_deleted class Teacher(Base): - __tablename__ = 'teachers' + __tablename__ = 'teacher_info_detail' id = Column( Integer , primary_key=True @@ -37,30 +36,26 @@ class Teacher(Base): ,comment='邮箱' ) remark = Column( - VARCHAR(255) + VARCHAR(2550) ,nullable=True ,comment='备注' ) created_at = Column( - DateTime + DateTime ,nullable=False ,default=datetime.now - ,server_default=text("CURRENT_TIMESTAMP") ,comment='创建时间' ) updated_at = Column( DateTime ,nullable=False ,default=datetime.now - ,onupdate=datetime.now - ,server_default=text("CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP") ,comment='更新时间' ) is_deleted = Column( TINYINT ,nullable=False ,default=0 - ,server_default=text("0") ,comment='逻辑删除' )