yjya_base.py 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151
  1. # -*- coding: utf-8 -*-
  2. from sqlalchemy import String, Column, Integer,DateTime,Text,BigInteger,Boolean,PrimaryKeyConstraint,Index,UniqueConstraint,CHAR,LargeBinary,TIMESTAMP,ForeignKey,Numeric
  3. from sqlalchemy.dialects.mysql import TINYINT
  4. from sqlalchemy.orm import relationship
  5. from sqlalchemy.sql import func
  6. from database import Base
  7. from datetime import datetime
  8. class EmergencyPlan(Base):
  9. __tablename__ = 'emergency_plans' # 表名
  10. # 定义字段
  11. id = Column(Integer, autoincrement=True, primary_key=True) # 主键
  12. plan_id = Column(String(50),comment='预案uid')
  13. plan_number = Column(String(15), comment='预案编号')
  14. plan_name = Column(String(255), nullable=False, comment='预案名称')
  15. plan_type = Column(String(100), nullable=False, comment='预案类型')
  16. plan_type_desc = Column(String(100), comment='预案类型(中文名称)')
  17. publish_date = Column(DateTime, default=datetime.now, comment='发布日期')
  18. organizing_unit = Column(String(255), comment='编制单位')
  19. document_number = Column(String(100), comment='发文字号')
  20. create_time = Column(DateTime, default=datetime.now, comment='数据创建时间')
  21. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='数据更新时间')
  22. create_dept = Column(BigInteger, default=None, comment='创建部门')
  23. create_by = Column(BigInteger, default=None, comment='创建者')
  24. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  25. response_level = Column(String(2), comment='响应级别')
  26. class Config:
  27. orm_mode = True
  28. # def create_new_plan_with_number(session, name):
  29. # new_plan = EmergencyPlan(
  30. # name=name
  31. # )
  32. # session.add(new_plan)
  33. # session.commit()
  34. # session.refresh(new_plan) # 刷新实例以获取数据库分配的 id
  35. # new_plan.plan_number = f'YJYA{str(new_plan.id).zfill(10)}'
  36. # session.commit()
  37. # return new_plan
  38. class EmergencyFile(Base):
  39. __tablename__ = 'emergency_file'
  40. id = Column(Integer, autoincrement=True, primary_key=True)
  41. file_id = Column(String(50), nullable=False, comment='文件id')
  42. file_name = Column(String(255), nullable=False, comment='文件名称')
  43. file_name_desc = Column(String(255), nullable=False, comment='文件名称原名')
  44. file_path = Column(String(255), comment='文件存储路径')
  45. file_size = Column(String(50), comment='文件大小')
  46. status = Column(String(50), comment='文件状态')
  47. foreign_key = Column(String(50), comment='文件外键 --技术字段')
  48. from_scenario = Column(String(50), comment='对应标识 --技术字段')
  49. create_time = Column(DateTime, default=datetime.now, comment='数据创建时间')
  50. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='数据更新时间')
  51. create_dept = Column(BigInteger, default=None, comment='创建部门')
  52. create_by = Column(BigInteger, default=None, comment='创建者')
  53. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)') #更新预案信息的时候 先将原有的进行备注删除
  54. # 关联到 EmergencyPlan 实例
  55. class Config:
  56. orm_mode = True
  57. class EmergencyDrill(Base):
  58. __tablename__ = 'emergency_drills'
  59. id = Column(Integer, autoincrement=True, primary_key=True)
  60. drill_id = Column(String(50), comment='演练uid' )
  61. drill_name = Column(String(255), nullable=False, comment='演练名称')
  62. organizing_unit = Column(String(255), nullable=False, comment='演练单位')
  63. plan_number = Column(String(50), nullable=False,comment='预案编号')
  64. # 前端确认传输什么数据
  65. drill_location = Column(String(255), comment='演练地点')
  66. drillProject = Column(String(255), comment='演练方案')
  67. drill_lon = Column(Numeric(9, 6), comment='演练经度')
  68. drill_lat = Column(Numeric(9, 6), comment='演练纬度')
  69. planned_annual = Column(Integer, comment='计划年度')
  70. planned_time = Column(DateTime, comment='计划演练时间')
  71. create_time = Column(DateTime, default=datetime.now, comment='数据创建时间')
  72. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='数据更新时间')
  73. create_dept = Column(BigInteger, default=None, comment='创建部门')
  74. create_by = Column(BigInteger, default=None, comment='创建者')
  75. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  76. class Config:
  77. orm_mode = True
  78. class EmergencyTrainingSession(Base):
  79. __tablename__ = 'emergency_training_sessions'
  80. id = Column(Integer, autoincrement=True, primary_key=True)
  81. training_id = Column(String(50), nullable=False,comment='培训uid')
  82. training_theme = Column(String(100), nullable=False,comment='培训主题')
  83. training_unit = Column(String(255), nullable=False, comment='培训单位')
  84. participant_count = Column(Integer, comment='参与人数')
  85. training_method = Column(String(255), comment='培训方式')
  86. start_time = Column(DateTime, comment='培训开始时间')
  87. end_time = Column(DateTime, comment='培训结束时间')
  88. training_location = Column(String(255), comment='培训地点')
  89. training_content = Column(Text, nullable=False, comment='培训内容')
  90. training_lon = Column(Numeric(9, 6), comment='培训经度')
  91. training_lat = Column(Numeric(9, 6), comment='培训纬度')
  92. plan_number = Column(String(50), nullable=False,comment='预案编号')
  93. create_time = Column(DateTime, default=datetime.now, comment='数据创建时间')
  94. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='数据更新时间')
  95. create_dept = Column(BigInteger, default=None, comment='创建部门')
  96. create_by = Column(BigInteger, default=None, comment='创建者')
  97. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  98. class Config:
  99. orm_mode = True
  100. class EmergencyResponse(Base):
  101. __tablename__ = 'emergency_responses'
  102. id = Column(Integer, autoincrement=True, primary_key=True)
  103. plan_id = Column(String(50), nullable=False,comment='预案id')
  104. response_id = Column(String(50), nullable=False, comment='响应编号')
  105. event_name = Column(String(255), nullable=False, comment='事件名称')
  106. event_type = Column(String(100), nullable=False, comment='事件类型')
  107. response_unit = Column(String(255), comment='响应单位')
  108. event_address = Column(String(255), comment='事件地点')
  109. response_level = Column(String(100), comment='响应级别')
  110. response_start_time = Column(DateTime, comment='响应开始时间')
  111. response_end_time = Column(DateTime, comment='响应结束时间')
  112. create_time = Column(DateTime, default=datetime.now, comment='数据创建时间')
  113. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='数据更新时间')
  114. create_dept = Column(BigInteger, default=None, comment='创建部门')
  115. create_by = Column(BigInteger, default=None, comment='创建者')
  116. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  117. class Config:
  118. orm_mode = True
  119. class EmergencyUnit(Base):
  120. __tablename__ = 'emergency_unit'
  121. id = Column(Integer, autoincrement=True, primary_key=True)
  122. plan_id = Column(String(50), nullable=False,comment='预案id')
  123. dept_id = Column(Integer, nullable=False,comment='部门id')
  124. dept_name = Column(String(100), nullable=False,comment='部门名称')
  125. content = Column(String(255), nullable=False,comment='单位职责')
  126. dept_order = Column(Integer, comment='排序')
  127. class Config:
  128. orm_mode = True