python-fastapi-mm-zhcs-yj-api/models/sharedb.py

# -*- coding: utf-8 -*-
from sqlalchemy import String, Column, Integer, DateTime,Text,BigInteger,Float,Date,TIMESTAMP
from sqlalchemy.dialects.mysql import TINYINT
from sqlalchemy.sql import func
from database import Base
from datetime import datetime

# 危化企业信息表
class ChemicalCompany(Base):
    __tablename__ = 'chemical_company'

    id = Column(BigInteger, primary_key=True,autoincrement=True, comment='主键')
    province = Column(String, default='', comment='省')
    city = Column(String, default='', comment='地市')
    area = Column(String, default='', comment='区县')
    company_name = Column(String, default='', comment='企业名称')
    company_code = Column(String, default='', comment='企业编码')
    company_type = Column(String, default='', comment='企业类型')
    is_import = Column(String, default='', comment='是否涉及进口')
    is_manage = Column(String, default='', comment='是否涉及经营')
    registration_date = Column(String, default='', comment='工商注册时间')
    registration_address = Column(String, default='', comment='工商注册地址')
    credit_code = Column(String, default='', comment='统一社会信用代码')
    industry_classification = Column(String, default='', comment='行业分类')
    production_scale = Column(Text, default='', comment='主要产品及生产规模')
    chemical_park_location = Column(String, default='', comment='所在化工园区')
    emergency_contact_number = Column(String, default='', comment='安全值班电话')
    emergency_response_hotline = Column(String, default='', comment='应急咨询服务电话')
    qyagjgfzr_phone = Column(String, default='', comment='企业安管机构负责人手机号')
    qyfgaqfzr_phone = Column(String, default='', comment='企业分管安全负责人手机号')
    sfqdwxhxpaqscxkz = Column(String, default='', comment='是否取得危险化学品安全生产许可证')
    xkzbh = Column(String, default='', comment='许可证编号')
    sfqdwxhxpjyxkz = Column(String, default='', comment='是否取得危险化学品经营许可证')
    sfqdwxhxpsyxkz = Column(String, default='', comment='是否取得危险化学品使用许可证')
    factory_address = Column(String, default='', comment='厂区地址')
    hazard_source = Column(Text, default='', comment='重大危险源')
    hazardous_chemical_process = Column(Text, default='', comment='危险化工工艺')
    issuance_date = Column(String, default='', comment='发证日期')
    certificate_expiry_date = Column(String, default='', comment='证书有效期')
    company_registration_number = Column(String, default='', comment='企业登记证编码')
    number_of_employees = Column(Integer, default='0', comment='职工人数')
    deregistration_date = Column(String, default='', comment='注销时间')
    scale_of_enterprise = Column(String, default='', comment='企业规模')
    chemical_industry_classification = Column(String, default='', comment='化工行业分类')
    safe_level = Column(String, default='', comment='安全标准化等级')
    priority = Column(String, default='', comment='重点行业')
    longitude = Column(Float, comment='经度')
    latitude = Column(Float, comment='纬度')
    formatted_address = Column(String, default='', comment='地址')
    s_last_updatetime = Column(DateTime, comment='更新时间')
    sign = Column(String, server_default='', default='', comment='HMACSM3数值')

    class Config:
        orm_mode = True


# 建筑工程信息表
class BuildingProjectInfo(Base):
    __tablename__ = 'building_project_info'

    id = Column(BigInteger, primary_key=True,autoincrement=True, comment='主键')
    prjcode = Column(String, default='', comment='项目编号')
    prjname = Column(String, default='', comment='项目名称')
    prjnum = Column(String, default='', comment='投资项目在线审批监管平台统一项目代码')
    letternum = Column(String, default='', comment='立项文号')
    prjlevel = Column(String, default='', comment='立项级别')
    issueby = Column(String, default='', comment='立项批复机关')
    dtissue = Column(DateTime, comment='立项批复时间')
    prjtypename = Column(String, default='', comment='项目类型')
    cityid = Column(String, default='', comment='项目所在地区编码（地市）')
    cityname = Column(String, default='', comment='项目所在地区名称（地市）')
    countyid = Column(Integer, comment='项目所在地区编码（县区）')
    countyname = Column(String, default='', comment='项目所在地区名称（县区）')
    address = Column(String, default='', comment='项目地址')
    longitude = Column(Float, comment='经度')
    latitude = Column(String, comment='纬度')
    prjsizedes = Column(String, default='', comment='建设规模')
    allinvest = Column(Float, default='', comment='总投资（万元）')
    allarea = Column(Float, comment='总面积（平方米）')
    alllength = Column(Float, comment='总长度（米）')
    allspan = Column(Float, comment='总跨度（米）')
    prjpropertyname = Column(String, default='', comment='建设性质')
    prjusefor = Column(String, default='', comment='工程用途')
    dtplans = Column(DateTime, comment='计划开工日期')
    dtplane = Column(DateTime, comment='计划竣工日期')
    ownername = Column(String, default='', comment='建设单位')
    ownerid = Column(String, default='', comment='建设单位统一信用代码（或个人身份证号码）')
    zjlygjzfczzjtz = Column(Float, comment='资金来源-各级政府财政资金投资')
    zjlygyqyzjtz = Column(Float, comment='资金来源-国有企业资金投资')
    zjlygjrz = Column(Float, comment='资金来源-国家融资')
    zjlysygjzzhzwgzfzj = Column(Float, comment='资金来源-使用国际组织或外国政府资金')
    zjlyjtjjzztz = Column(Float, comment='资金来源-集体经济组织投资')
    zjlywstz = Column(Float, comment='资金来源-外商（国）投资')
    zjlyggttz = Column(Float, comment='资金来源-港澳台投资')
    zjlysytz = Column(Float, comment='资金来源-私（民）营投资')
    zjlyqtzjly = Column(Float, comment='资金来源-其他资金来源')
    add_time = Column(DateTime, comment='新增时间')
    cd_time = Column(DateTime, comment='增量时间')
    cd_operation = Column(String, default='', comment='增量标识')
    cd_batch = Column(String, default='', comment='批次号')
    sign = Column(String, server_default='', default='', comment='HMACSM3数值')
    class Config:
        orm_mode = True


class EmergencyExpertInfo(Base):
    __tablename__ = 'emergency_expert_info'

    id = Column(Integer, primary_key=True, autoincrement=True, comment='序号')
    name = Column(String(255), nullable=False, comment='姓名')
    county = Column(String(255), comment='所属区县')
    expert_type = Column(String(255), comment='专家类型')
    honorary_title = Column(String(255), comment='荣誉称号')
    unit = Column(String(255), comment='单位')
    position = Column(String(255), comment='职位')
    professional_title = Column(String(255), comment='职称')
    specialty = Column(String(255), comment='擅长事故类型')
    rescue_experience = Column(Text, comment='救援经历')
    birth_date = Column(Date, comment='出生日期')
    work_start_date = Column(Date, comment='工作时间')
    certificate_issue_date = Column(Date, comment='发证日期')
    professional_group = Column(String(255), comment='专业分组')
    professional_field = Column(String(255), comment='专业领域')
    work_phone = Column(String(20), comment='工作电话')
    home_phone = Column(String(20), comment='住宅电话')
    mobile_phone = Column(String(20), comment='移动电话')
    email = Column(String(255), comment='电子邮箱')
    contact_address = Column(String(255), comment='联系地址')
    longitude = Column(Float, comment='经度')
    latitude = Column(Float, comment='纬度')


class RescueTeams(Base):
    __tablename__ = 'rescue_teams'

    id = Column(Integer, primary_key=True, autoincrement=True, comment='ID')
    name = Column(String(255), nullable=False, comment='名称')
    team_type = Column(String(100), comment='救援单位类型')
    professional_category = Column(String(1000), comment='队伍专业类别')
    team_category = Column(String(100), comment='队伍类别')
    team_attribute = Column(String(100), comment='队伍属性')
    team_level = Column(String(100), comment='队伍层级')
    affiliated_unit = Column(String(255), comment='所属单位')
    leader_name = Column(String(100), comment='负责人姓名')
    leader_phone = Column(String(255), comment='负责人联系电话')
    city = Column(String(100), comment='地市')
    district = Column(String(100), comment='区县')
    main_equipment = Column(String(500), comment='主要装备')
    number_of_people = Column(Integer, comment='人数')
    address = Column(String(255), comment='地址')
    description = Column(Text, comment='描述')
    longitude = Column(Float, comment='经度')
    latitude = Column(Float, comment='纬度')
    s_last_updatetime = Column(DateTime, comment='最后更新时间')
    del_flag = Column(String(2), comment='删除标识，0未删除，2删除')
    create_by = Column(String(255), comment='创建者')
    create_time = Column(DateTime,  comment='创建时间')
    update_by = Column(String(255), comment='更新者')



class YzyMsgQueueSk(Base):
    """
    粤政易消息队列(数科)
    """
    __tablename__ = "yzy_msg_queue_sk"

    id = Column(Integer, primary_key=True, autoincrement=True)
    request_id = Column(String, default='', server_default='', comment='消息ID')
    yzy_userid = Column(String, default='', server_default='', comment='粤政易用户ID')
    title = Column(String, default='', server_default='', comment='标题')
    content = Column(Text, default='', server_default='', comment='消息体')
    detail_url = Column(String, default='', server_default='', comment='跳转URL')
    create_time = Column(DateTime, server_default=func.now(), comment='数据创建时间')
    sent_time = Column(String, comment='发送时间')
    sent_status = Column(Integer, default=0, server_default='0', comment='发送状态 0 待发 1发送中 2 发送成功 9 发送失败')
    errcode = Column(Integer, default=0, server_default='0', comment='错误代码')
    errmsg = Column(String, default='', server_default='', comment='错误提示')
    
    class Config:
        orm_mode = True

class MiningCompany(Base):
    __tablename__ = 'mining_company'

    id = Column(Integer, primary_key=True, comment='id')
    company_name = Column(String(255), comment='矿山企业名称')
    usci = Column(String(18), comment='企业统一社会信用代码')
    province = Column(String(50), comment='省')
    city = Column(String(50), comment='市')
    area = Column(String(50), comment='县')
    production_status = Column(String(50), comment='生产状态')
    primary_mineral_types = Column(String(50), comment='主要矿种')
    mining_method = Column(String(50), comment='开采方式')
    development_method = Column(String(50), comment='开拓方式')
    scale = Column(String(50), comment='矿山规模')
    name = Column(String(50), comment='姓名')
    phone = Column(String(20), comment='联系方式')
    longitude = Column(Float, comment='经度')
    latitude = Column(Float, comment='纬度')
    formatted_address = Column(String(255), comment='地址')
    safety_mgmt_headcount = Column(Integer, comment='安全管理人数')
    mining_license_start = Column(Date, comment='采矿证起始日期')
    mining_license_end = Column(Date, comment='采矿证失效日期')
    production_capacity = Column(String(100), comment='生产规模')
    mining_area = Column(Float, comment='矿区面积(km²)')
    safety_license_start = Column(Date, comment='安全生产许可证起始日期')
    safety_license_end = Column(Date, comment='安全生产许可证失效日期')
    safety_license_no = Column(String(50), comment='安全生产许可证证号')
    license_scope = Column(Text, comment='许可范围')
    issuing_authority = Column(String(100), comment='发证单位')
    economic_type = Column(String(50), comment='企业经济类型')
    business_scope = Column(Text, comment='生产经营范围')
    seismic_intensity = Column(String(10), comment='地震烈度')
    net_fixed_assets = Column(Float, comment='固定资产净值(万元)')
    max_underground_headcount = Column(Integer, comment='设计最大单班下井人数')
    safety_staff_count = Column(Integer, comment='安全管理人员数量')
    daily_production_staff = Column(Integer, comment='日常生产人员数量')
    special_operation_staff = Column(Integer, comment='特种作业人员数量')
    hydrogeological_condition = Column(String(50), comment='水文地质条件')
    safety_risk_level = Column(String(20), comment='安全风险等级')
    remark = Column(Text, comment='备注')
    s_last_updatetime = Column(TIMESTAMP, server_default=func.current_timestamp(), comment='最后更新时间')

class MiningAccidentDetail(Base):
    __tablename__ = 'mining_accident_detail'

    id                      = Column(BigInteger, primary_key=True, comment='主键')
    accident_name           = Column(String(200), comment='事故名称')
    company_name            = Column(String(200), comment='事发企业')
    district                = Column(String(100), comment='区县')
    longitude               = Column(Float, comment='经度')  # 9位小数，可按需调整
    latitude                = Column(Float, comment='纬度')
    accident_type           = Column(String(50), comment='事故类别')
    mgmt_category           = Column(String(50), comment='管理分类')
    sector                  = Column(String(50), comment='门类')
    major_category          = Column(String(50), comment='大类')
    accident_summary        = Column(Text, comment='事故概况')
    accident_level          = Column(String(20), comment='事故等级')
    accident_time           = Column(DateTime, comment='事发时间')
    accident_cause          = Column(Text, comment='事发原因')
    secondary_accident      = Column(String(50), default='0', comment='次生衍生事故')
    accident_location       = Column(String(255), comment='事发地点')
    injured_count           = Column(Integer, default=0, comment='受伤人数')
    missing_count           = Column(Integer, default=0, comment='失踪人数')
    death_count             = Column(Integer, default=0, comment='死亡人数')
    direct_economic_loss    = Column(Float, default=0.00, comment='直接经济损失(万元)')
    disposal_process        = Column(Text, comment='处置过程')
    remark                  = Column(Text, comment='备注')
    s_last_updatetime       = Column(DateTime, server_default=func.current_timestamp(), comment='最后更新时间')