risk_management.py 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292
  1. from sqlalchemy import create_engine, Column, BigInteger, String, Text, DateTime, CHAR,Integer,Float
  2. from database import Base
  3. from datetime import datetime
  4. class RiskManagementInspectionUser(Base):
  5. __tablename__ = 'risk_management_inspection_user'
  6. id = Column(BigInteger, primary_key=True, autoincrement=True, comment='ID')
  7. user_id = Column(BigInteger, nullable=False, comment='用户ID')
  8. dept_id = Column(BigInteger, nullable=True, comment='部门ID')
  9. dept_name = Column(String(30), nullable=True, comment='部门名称')
  10. ancestors_names = Column(Text, nullable=True, comment='部门路径')
  11. user_name = Column(String(30), nullable=False, comment='用户账号')
  12. nick_name = Column(String(30), nullable=False, comment='用户昵称')
  13. phonenumber = Column(String(11), default='', comment='手机号码')
  14. area_code = Column(String(11), default='', comment='责任区划编码')
  15. area = Column(String(11), default='', comment='责任区划')
  16. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  17. create_dept = Column(BigInteger, default=None, comment='创建部门')
  18. create_by = Column(BigInteger, default=None, comment='创建者')
  19. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  20. update_by = Column(BigInteger, default=None, comment='更新者')
  21. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  22. remark = Column(String(500), default=None, comment='备注')
  23. yzy_account = Column(String(50), default=None, comment='粤政易账号')
  24. class RiskManagementInspectionTask(Base):
  25. __tablename__ = 'risk_management_inspection_task'
  26. id = Column(BigInteger, primary_key=True, autoincrement=True, comment='ID')
  27. task_number = Column(String(50), comment='任务编号')
  28. inspection_business = Column(String(255), nullable=True, comment='巡查业务,城市隐患巡查、森林防火巡查、重点危化企业巡查、重点水库水位巡查')
  29. start_time = Column(DateTime, nullable=True, comment='巡查开始时间')
  30. end_time = Column(DateTime, nullable=True, comment='巡查结束时间')
  31. inspection_cycle = Column(String(50), nullable=True, comment='巡查周期,每年、每月、每周、每日、一次')
  32. corn_expression = Column(String(100), nullable=True, comment='corn表达式')
  33. inspection_range = Column(String(50), nullable=True, comment='巡查范围,市级、区县级、镇街级、村居级')
  34. task_status = Column(String(20), nullable=True, comment='任务状态,未开始、进行中、未完成、已完结')
  35. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  36. create_dept = Column(BigInteger, default=None, comment='创建部门')
  37. create_by = Column(BigInteger, default=None, comment='创建者')
  38. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  39. update_by = Column(BigInteger, default=None, comment='更新者')
  40. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  41. remark = Column(String(500), default=None, comment='备注')
  42. class RiskManagementInspectionTaskChildrenTask(Base):
  43. __tablename__ = 'risk_management_inspection_task_children_task'
  44. id = Column(String(50), primary_key=True, comment='ID,uuid')
  45. task_id = Column(BigInteger, nullable=False, comment='ID,任务基础表id')
  46. task_number = Column(String(50), nullable=True, comment='任务编号')
  47. type = Column(String(255), nullable=True, comment='巡查业务,城市隐患巡查、森林防火巡查、重点危化企业巡查、重点水库水位巡查')
  48. tsak_time = Column(DateTime, nullable=True, comment='要求巡查时间')
  49. cycle = Column(String(50), nullable=True, comment='巡查周期,每年、每月、每周、每日、一次')
  50. task_range = Column(String(50), nullable=True, comment='巡查范围,市级、区县级、镇街级、村居级')
  51. task_num = Column(Integer, nullable=False, comment='任务数')
  52. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  53. create_dept = Column(BigInteger, default=None, comment='创建部门')
  54. create_by = Column(BigInteger, default=None, comment='创建者')
  55. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  56. update_by = Column(BigInteger, default=None, comment='更新者')
  57. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  58. remark = Column(String(500), default=None, comment='备注')
  59. class RiskManagementInspectionTaskChildrenTaskLog(Base):
  60. __tablename__ = 'risk_management_inspection_task_children_task_log'
  61. id = Column(String(50), primary_key=True, comment='ID,uuid')
  62. children_task_id = Column(String(50), nullable=False, comment='ID,子任务表id')
  63. area_code = Column(String(50), nullable=True, comment='区划编码')
  64. area = Column(Text, nullable=True, comment='区划')
  65. task_status = Column(String(2), nullable=True, comment='任务进展,已完成、未完成')
  66. user_id = Column(String(50), nullable=True, comment='用户id')
  67. nick_name = Column(String(50), nullable=True, comment='巡查人员')
  68. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  69. create_dept = Column(BigInteger, default=None, comment='创建部门')
  70. create_by = Column(BigInteger, default=None, comment='创建者')
  71. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  72. update_by = Column(BigInteger, default=None, comment='更新者')
  73. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  74. remark = Column(String(500), default=None, comment='备注')
  75. class RiskManagementInspectionTaskChildrenTaskResult(Base):
  76. __tablename__ = 'risk_management_inspection_task_children_task_result'
  77. id = Column(String(50), primary_key=True, comment='ID,uuid')
  78. children_task_id = Column(String(50), nullable=False, comment='ID,子任务表id')
  79. longitude = Column(Float, nullable=True, comment='经度')
  80. latitude = Column(Float, nullable=True, comment='纬度')
  81. inspection_point_name = Column(Text, nullable=True, comment='巡查点')
  82. area_code = Column(String(50), nullable=True, comment='区划编码')
  83. inspection_result = Column(String(2), nullable=True, comment='巡查结果,正常、异常')
  84. user_id = Column(String(50), nullable=True, comment='用户id')
  85. nick_name = Column(String(50), nullable=True, comment='巡查人员')
  86. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  87. create_dept = Column(BigInteger, default=None, comment='创建部门')
  88. create_by = Column(BigInteger, default=None, comment='创建者')
  89. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  90. update_by = Column(BigInteger, default=None, comment='更新者')
  91. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  92. remark = Column(String(500), default=None, comment='备注')
  93. class RiskManagementFile(Base):
  94. __tablename__ = 'risk_management_file'
  95. id = Column(Integer, primary_key=True, autoincrement=True)
  96. file_id = Column(String(50), nullable=False, comment='文件id')
  97. file_name = Column(String(255), nullable=False, comment='文件名称')
  98. file_name_desc = Column(String(255), nullable=False, comment='文件名称原名')
  99. file_path = Column(String(255), nullable=True, comment='文件存储路径')
  100. file_size = Column(String(50), nullable=True, comment='文件大小')
  101. status = Column(String(50), nullable=True, comment='文件状态')
  102. foreign_key = Column(String(50), nullable=True, comment='文件外键 --技术字段')
  103. from_scenario = Column(String(50), nullable=True, comment='对应标识 --技术字段')
  104. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  105. create_dept = Column(BigInteger, default=None, comment='创建部门')
  106. create_by = Column(BigInteger, default=None, comment='创建者')
  107. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  108. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  109. class RiskManagementRiskTask(Base):
  110. __tablename__ = 'risk_management_risk_task'
  111. id = Column(BigInteger, primary_key=True, autoincrement=True, comment='ID')
  112. task_number = Column(String(50), nullable=True, comment='任务编号')
  113. risk_type = Column(String(255), nullable=True, comment='风险源类型,风险源排查、隐患源排查、危险源排查')
  114. start_time = Column(DateTime, nullable=True, comment='排查开始时间')
  115. end_time = Column(DateTime, nullable=True, comment='排查结束时间')
  116. task_cycle = Column(String(50), nullable=True, comment='排查周期,每年、每月、每周、每日、一次')
  117. corn_expression = Column(String(100), nullable=True, comment='corn表达式')
  118. task_range = Column(String(50), nullable=True, comment='巡查范围,市级、区县级、镇街级、村居级')
  119. task_status = Column(String(20), nullable=True, comment='任务状态,未开始、进行中、未完成、已完结')
  120. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  121. create_dept = Column(BigInteger, default=None, comment='创建部门')
  122. create_by = Column(BigInteger, default=None, comment='创建者')
  123. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  124. update_by = Column(BigInteger, default=None, comment='更新者')
  125. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  126. remark = Column(String(500), default=None, comment='备注')
  127. class RiskManagementRiskTaskChildrenTask(Base):
  128. __tablename__ = 'risk_management_risk_task_children_task'
  129. id = Column(String(50), primary_key=True, comment='ID,uuid')
  130. task_id = Column(BigInteger, nullable=False, comment='ID,任务基础表id')
  131. task_number = Column(String(50), nullable=True, comment='任务编号')
  132. type = Column(String(255), nullable=True, comment='排查业务,城市隐患巡查、森林防火巡查、重点危化企业巡查、重点水库水位巡查')
  133. tsak_time = Column(DateTime, nullable=True, comment='要求排查时间')
  134. cycle = Column(String(50), nullable=True, comment='排查周期,每年、每月、每周、每日、一次')
  135. task_range = Column(String(50), nullable=True, comment='排查范围,市级、区县级、镇街级、村居级')
  136. task_num = Column(Integer, nullable=False, comment='任务数')
  137. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  138. create_dept = Column(BigInteger, default=None, comment='创建部门')
  139. create_by = Column(BigInteger, default=None, comment='创建者')
  140. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  141. update_by = Column(BigInteger, default=None, comment='更新者')
  142. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  143. remark = Column(String(500), default=None, comment='备注')
  144. class RiskManagementRiskTaskChildrenTaskLog(Base):
  145. __tablename__ = 'risk_management_risk_task_children_task_log'
  146. id = Column(String(50), primary_key=True, comment='ID,uuid')
  147. children_task_id = Column(String(50), nullable=False, comment='ID,子任务表id')
  148. area_code = Column(String(50), nullable=True, comment='区划编码')
  149. area = Column(Text, nullable=True, comment='区划')
  150. task_status = Column(String(2), nullable=True, comment='任务进展,已完成、未完成')
  151. user_id = Column(String(50), nullable=True, comment='用户id')
  152. nick_name = Column(String(50), nullable=True, comment='排查人员')
  153. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  154. create_dept = Column(BigInteger, default=None, comment='创建部门')
  155. create_by = Column(BigInteger, default=None, comment='创建者')
  156. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  157. update_by = Column(BigInteger, default=None, comment='更新者')
  158. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  159. remark = Column(String(500), default=None, comment='备注')
  160. class RiskManagementRiskTaskChildrenTaskResult(Base):
  161. __tablename__ = 'risk_management_risk_task_children_task_result'
  162. id = Column(String(50), primary_key=True, comment='ID,uuid')
  163. children_task_id = Column(String(50), nullable=False, comment='ID,子任务表id')
  164. longitude = Column(Float, nullable=True, comment='经度')
  165. latitude = Column(Float, nullable=True, comment='纬度')
  166. inspection_point_name = Column(Text, nullable=True, comment='巡查点')
  167. area_code = Column(String(50), nullable=True, comment='区划编码')
  168. inspection_result = Column(String(2), nullable=True, comment='排查结果,正常、异常')
  169. user_id = Column(String(50), nullable=True, comment='用户id')
  170. nick_name = Column(String(50), nullable=True, comment='排查人员')
  171. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  172. create_dept = Column(BigInteger, default=None, comment='创建部门')
  173. create_by = Column(BigInteger, default=None, comment='创建者')
  174. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  175. update_by = Column(BigInteger, default=None, comment='更新者')
  176. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  177. remark = Column(String(500), default=None, comment='备注')
  178. class RiskManagementRescueResourcesTask(Base):
  179. __tablename__ = 'risk_management_rescue_resources_task'
  180. id = Column(BigInteger, primary_key=True, autoincrement=True, comment='ID')
  181. task_number = Column(String(50), nullable=True, comment='任务编号')
  182. type = Column(String(255), nullable=True, comment='采集业务,庇护场所、救援队伍、救援设备')
  183. start_time = Column(DateTime, nullable=True, comment='采集开始时间')
  184. end_time = Column(DateTime, nullable=True, comment='采集结束时间')
  185. task_cycle = Column(String(50), nullable=True, comment='采集周期,每年、每月、每周、每日、一次')
  186. corn_expression = Column(String(100), nullable=True, comment='corn表达式')
  187. task_range = Column(String(50), nullable=True, comment='巡查范围,市级、区县级、镇街级、村居级')
  188. task_status = Column(String(20), nullable=True, comment='任务状态,未开始、进行中、未完成、已完结')
  189. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  190. create_dept = Column(BigInteger, default=None, comment='创建部门')
  191. create_by = Column(BigInteger, default=None, comment='创建者')
  192. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  193. update_by = Column(BigInteger, default=None, comment='更新者')
  194. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  195. remark = Column(String(500), default=None, comment='备注')
  196. class RiskManagementRescueResourcesTaskChildrenTask(Base):
  197. __tablename__ = 'risk_management_rescue_resources_task_children_task'
  198. id = Column(String(50), primary_key=True, comment='ID,uuid')
  199. task_id = Column(BigInteger, nullable=False, comment='ID,任务基础表id')
  200. task_number = Column(String(50), nullable=True, comment='任务编号')
  201. type = Column(String(255), nullable=True, comment='采集业务,庇护场所、救援队伍、救援设备')
  202. tsak_time = Column(DateTime, nullable=True, comment='要求采集时间')
  203. cycle = Column(String(50), nullable=True, comment='采集周期,每年、每月、每周、每日、一次')
  204. task_range = Column(String(50), nullable=True, comment='采集范围,市级、区县级、镇街级、村居级')
  205. task_num = Column(Integer, nullable=False, comment='任务数')
  206. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  207. create_dept = Column(BigInteger, default=None, comment='创建部门')
  208. create_by = Column(BigInteger, default=None, comment='创建者')
  209. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  210. update_by = Column(BigInteger, default=None, comment='更新者')
  211. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  212. remark = Column(String(500), default=None, comment='备注')
  213. class RiskManagementRescueResourcesTaskChildrenTaskLog(Base):
  214. __tablename__ = 'risk_management_rescue_resources_task_children_task_log'
  215. id = Column(String(50), primary_key=True, comment='ID,uuid')
  216. children_task_id = Column(String(50), nullable=False, comment='ID,子任务表id')
  217. area_code = Column(String(50), nullable=True, comment='区划编码')
  218. area = Column(Text, nullable=True, comment='区划')
  219. task_status = Column(String(2), nullable=True, comment='任务进展,已完成、未完成')
  220. user_id = Column(String(50), nullable=True, comment='用户id')
  221. nick_name = Column(String(50), nullable=True, comment='采集人员')
  222. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  223. create_dept = Column(BigInteger, default=None, comment='创建部门')
  224. create_by = Column(BigInteger, default=None, comment='创建者')
  225. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  226. update_by = Column(BigInteger, default=None, comment='更新者')
  227. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  228. remark = Column(String(500), default=None, comment='备注')
  229. class RiskManagementRescueResourcesTaskChildrenTaskResult(Base):
  230. __tablename__ = 'risk_management_rescue_resources_task_children_task_result'
  231. id = Column(String(50), primary_key=True, comment='ID,uuid')
  232. children_task_id = Column(String(50), nullable=False, comment='ID,子任务表id')
  233. longitude = Column(Float, nullable=True, comment='经度')
  234. latitude = Column(Float, nullable=True, comment='纬度')
  235. inspection_point_name = Column(Text, nullable=True, comment='巡查点')
  236. area_code = Column(String(50), nullable=True, comment='区划编码')
  237. inspection_result = Column(String(2), nullable=True, comment='采集结果,正常、异常')
  238. user_id = Column(String(50), nullable=True, comment='用户id')
  239. nick_name = Column(String(50), nullable=True, comment='采集人员')
  240. del_flag = Column(String(1), default='0', comment='删除标志(0代表存在 2代表删除)')
  241. create_dept = Column(BigInteger, default=None, comment='创建部门')
  242. create_by = Column(BigInteger, default=None, comment='创建者')
  243. create_time = Column(DateTime, default=datetime.now, comment='创建时间')
  244. update_by = Column(BigInteger, default=None, comment='更新者')
  245. update_time = Column(DateTime, default=datetime.now, onupdate=datetime.now, comment='更新时间')
  246. remark = Column(String(500), default=None, comment='备注')