d3i-szct/models/dcm_task_form_datum.py

import random
from typing import Union, Optional, Callable

import pandas as pd
from sqlalchemy import select, delete
from tornado_swagger.model import register_swagger_model
from wtforms import StringField, TextAreaField, IntegerField, FloatField
from wtforms.validators import Length

import models
from models.common_model import CommonModel
from models.db_models import TD3iDcmTaskFormDatum
from paste.core.logging import echo_log
from paste.util.pagination import Pagination
from paste.web.form import ModelForm


class DcmTaskFormDatumForm(ModelForm):
    """
    企业待办表单数据验证类（完全映射 TD3iDcmTaskFormDatum 字段）。

    用于验证和处理数字化城市管理信息系统中企业待办的表单数据。
    字段完全对应数据库表 t_d3i_dcm_task_form_data 的结构。
    """

    # 基础信息
    id = IntegerField('主键ID')
    rec_id = IntegerField('记录ID')
    rec_disp_num = StringField('显示编号', validators=[Length(max=50, message='显示编号长度不能超过50字符')])
    rec_type_id = IntegerField('类型ID')
    rec_type_name = StringField('案件类型', validators=[Length(max=100, message='案件类型长度不能超过100字符')])

    # 任务信息
    task_num = StringField('任务号', validators=[Length(max=50, message='任务号长度不能超过50字符')])
    other_task_num = StringField('第三方任务号', validators=[Length(max=100, message='第三方任务号长度不能超过100字符')])
    act_property_id = IntegerField('任务属性ID')

    # 业务信息
    biz_id = IntegerField('业务ID')
    biz_name = StringField('业务名称', validators=[Length(max=200, message='业务名称长度不能超过200字符')])
    sys_id = IntegerField('系统ID')

    # 地址与坐标
    address = TextAreaField('地址描述', validators=[Length(max=65535, message='地址描述长度不能超过65535字符')])
    district_name = StringField('所属区域', validators=[Length(max=50, message='所属区域长度不能超过50字符')])
    coordinate_x = FloatField('经度')
    coordinate_y = FloatField('纬度')
    lonlat_x = FloatField('经纬度X')
    lonlat_y = FloatField('经纬度Y')

    # 事件信息
    event_type_id = IntegerField('问题类型ID')
    event_type_name = StringField('问题类型', validators=[Length(max=100, message='问题类型长度不能超过100字符')])
    event_src_id = IntegerField('问题来源ID')
    event_src_name = StringField('问题来源', validators=[Length(max=100, message='问题来源长度不能超过100字符')])
    event_desc = TextAreaField('问题描述', validators=[Length(max=65535, message='问题描述长度不能超过65535字符')])
    max_event_type_id = IntegerField('最大事件类型ID')
    max_event_type_name = StringField('最大事件类型名称', validators=[Length(max=200, message='最大事件类型名称长度不能超过200字符')])

    # 分类信息
    main_type_id = IntegerField('大类ID')
    main_type_name = StringField('大类名称', validators=[Length(max=100, message='大类名称长度不能超过100字符')])
    sub_type_id = IntegerField('小类ID')
    sub_type_name = StringField('小类名称', validators=[Length(max=100, message='小类名称长度不能超过100字符')])
    third_type_id = IntegerField('第三级类型ID')
    third_type_name = StringField('第三级类型名称', validators=[Length(max=100, message='第三级类型名称长度不能超过100字符')])
    forth_type_id = IntegerField('第四级类型ID')
    forth_type_name = StringField('第四级类型名称', validators=[Length(max=100, message='第四级类型名称长度不能超过100字符')])
    fifth_type_id = IntegerField('第五级类型ID')
    fifth_type_name = StringField('第五级类型名称', validators=[Length(max=100, message='第五级类型名称长度不能超过100字符')])
    sixth_type_id = IntegerField('第六级类型ID')
    sixth_type_name = StringField('第六级类型名称', validators=[Length(max=100, message='第六级类型名称长度不能超过100字符')])
    seventh_type_id = IntegerField('第七级类型ID')
    seventh_type_name = StringField('第七级类型名称', validators=[Length(max=100, message='第七级类型名称长度不能超过100字符')])

    # 时间与状态
    create_time = IntegerField('创建时间戳')
    update_time = IntegerField('更新时间戳')
    deadline_time = IntegerField('处理截止时间戳')
    warning_time = IntegerField('处理预警时间戳')
    occur_time = IntegerField('发生时间戳')
    dispatch_time = IntegerField('派遣时间戳')
    archive_time = IntegerField('归档时间戳')
    cancel_time = IntegerField('取消时间戳')
    refresh_time = IntegerField('刷新时间戳')
    refresh_start_time = IntegerField('刷新开始时间戳')
    check_send_time = IntegerField('核查发送时间戳')
    check_reply_time = IntegerField('核查回复时间戳')
    func_deadline = IntegerField('职能部门截止时间戳')
    func_deal_time = IntegerField('职能部门处理时间戳')
    proc_start_time = IntegerField('处理开始时间戳')
    custom_deadline = IntegerField('自定义截止时间戳')
    patroltask_deadline_time = IntegerField('巡查任务截止时间戳')

    # 时限描述
    deadline_char = StringField('时限描述', validators=[Length(max=50, message='时限描述长度不能超过50字符')])
    func_limit_char = StringField('职能部门时限描述', validators=[Length(max=50, message='职能部门时限描述长度不能超过50字符')])
    rec_remain_char = StringField('记录剩余时间描述', validators=[Length(max=50, message='记录剩余时间描述长度不能超过50字符')])
    rec_used_char = StringField('记录已用时间描述', validators=[Length(max=50, message='记录已用时间描述长度不能超过50字符')])

    # 数值型字段
    rec_remain = FloatField('记录剩余时间')
    rec_used = FloatField('记录已用时间')
    rec_warning = FloatField('记录预警时间')
    rec_deadline = FloatField('记录时限')

    # 部门与网格
    func_part_id = IntegerField('职能部门ID')
    func_part_name = StringField('职能部门名称', validators=[Length(max=200, message='职能部门名称长度不能超过200字符')])
    func_part_list_id = StringField('职能部门列表ID', validators=[Length(max=100, message='职能部门列表ID长度不能超过100字符')])
    func_part_list_name = StringField('职能部门列表名称', validators=[Length(max=200, message='职能部门列表名称长度不能超过200字符')])
    specify_func_id = IntegerField('指定职能部门ID')
    specify_func_name = StringField('指定职能部门名称', validators=[Length(max=200, message='指定职能部门名称长度不能超过200字符')])
    specify_competent_func_id = IntegerField('指定主管职能部门ID')
    specify_competent_func_name = StringField('指定主管职能部门名称', validators=[Length(max=200, message='指定主管职能部门名称长度不能超过200字符')])
    first_depart_name = StringField('一级专业部门', validators=[Length(max=100, message='一级专业部门长度不能超过100字符')])
    second_depart_name = StringField('二级专业部门', validators=[Length(max=100, message='二级专业部门长度不能超过100字符')])

    # 地理信息
    district_id = IntegerField('区域ID')
    street_id = IntegerField('街道ID')
    street_name = StringField('街道名称', validators=[Length(max=200, message='街道名称长度不能超过200字符')])
    community_id = IntegerField('社区ID')
    community_name = StringField('社区名称', validators=[Length(max=200, message='社区名称长度不能超过200字符')])
    duty_grid_id = IntegerField('责任网格ID')
    duty_grid_name = StringField('责任网格名称', validators=[Length(max=200, message='责任网格名称长度不能超过200字符')])
    duty_region_id = IntegerField('责任区域ID')
    duty_region_name = StringField('责任区域名称', validators=[Length(max=200, message='责任区域名称长度不能超过200字符')])
    duty_district_id = IntegerField('责任区域ID')
    duty_district_name = StringField('责任区域名称', validators=[Length(max=200, message='责任区域名称长度不能超过200字符')])
    duty_street_id = IntegerField('责任街道ID')
    duty_street_name = StringField('责任街道名称', validators=[Length(max=200, message='责任街道名称长度不能超过200字符')])
    duty_community_id = IntegerField('责任社区ID')
    duty_community_name = StringField('责任社区名称', validators=[Length(max=200, message='责任社区名称长度不能超过200字符')])
    law_duty_grid_id = IntegerField('法律责任网格ID')
    law_duty_grid_name = StringField('法律责任网格名称', validators=[Length(max=200, message='法律责任网格名称长度不能超过200字符')])
    deal_duty_grid_id = IntegerField('处置责任网格ID')
    deal_duty_grid_name = StringField('处置责任网格名称', validators=[Length(max=200, message='处置责任网格名称长度不能超过200字符')])

    # 人员信息
    patrol_id = IntegerField('巡查员ID')
    patrol_name = StringField('巡查员名称', validators=[Length(max=200, message='巡查员名称长度不能超过200字符')])
    accepter_id = IntegerField('受理人ID')
    accepter_name = StringField('受理人姓名', validators=[Length(max=100, message='受理人姓名长度不能超过100字符')])
    human_id = IntegerField('操作人ID')
    human_name = StringField('操作人名称', validators=[Length(max=255, message='操作人名称长度不能超过255字符')])
    reporter_name = StringField('举报人姓名', validators=[Length(max=100, message='举报人姓名长度不能超过100字符')])
    reporter_contact = StringField('举报电话', validators=[Length(max=50, message='举报电话长度不能超过50字符')])
    tell_num = StringField('联系电话', validators=[Length(max=50, message='联系电话长度不能超过50字符')])

    # 状态与标识
    read_flag = IntegerField('是否已读（0未读，1已读）')
    reply_intime = IntegerField('是否两小时回复（0无需回复，1待回复，2已回复，3超时，4无需回复已恢复）')
    return_visit_flag = IntegerField('回访标识（0无需，1待回访，2已回访）')
    urgency_level = IntegerField('紧急程度（0正常，1紧急）')
    urgent_flag = IntegerField('紧急标识')
    func_forbid_reporter_info_flag = IntegerField('是否禁止举报人信息')
    public_flag = IntegerField('公开标志')
    locked_flag = IntegerField('锁定标识')
    transited_flag = IntegerField('转交标识')
    split_rec_flag = IntegerField('拆分记录标识')
    enable_check_msg = IntegerField('启用核查消息')
    no_return_visit_flag = IntegerField('无需回访标识')
    common_rec_type_flag = StringField('通用记录类型标识', validators=[Length(max=50, message='通用记录类型标识长度不能超过50字符')])
    common_rec_attr_flag = StringField('通用记录属性标识', validators=[Length(max=50, message='通用记录属性标识长度不能超过50字符')])
    send_pub_check_task_flag = IntegerField('发送公共核查任务标识')
    reply_flag = StringField('回复标识', validators=[Length(max=50, message='回复标识长度不能超过50字符')])
    whistle_flag = StringField('吹哨标识', validators=[Length(max=50, message='吹哨标识长度不能超过50字符')])
    repeat_state = StringField('重复状态', validators=[Length(max=50, message='重复状态长度不能超过50字符')])
    report_state = StringField('上报状态', validators=[Length(max=50, message='上报状态长度不能超过50字符')])
    dispose_state = IntegerField('处置状态')
    pre_dispose_state = StringField('预处置状态', validators=[Length(max=50, message='预处置状态长度不能超过50字符')])
    undertake_user_name = StringField('承办人员', validators=[Length(max=50, message='承办人员长度不能超过50字符')])
    undertake_phone = StringField('联系电话', validators=[Length(max=50, message='联系电话长度不能超过50字符')])
    deal_person_org = StringField('承办部门', validators=[Length(max=50, message='承办部门长度不能超过50字符')])

    # 媒体信息
    media_upload_num = IntegerField('媒体上传数量')
    media_upload_total_num = IntegerField('媒体上传总数')
    media_upload_state = StringField('媒体上传状态', validators=[Length(max=50, message='媒体上传状态长度不能超过50字符')])
    media_check_num = IntegerField('媒体核查数量')
    media_check_total_num = IntegerField('媒体核查总数')
    media_verify_num = IntegerField('媒体核实数量')
    media_verify_total_num = IntegerField('媒体核实总数')
    media_self_deal_num = IntegerField('自行处置媒体数量')
    media_self_deal_total_num = IntegerField('自行处置媒体总数')
    media_review_num = IntegerField('复核媒体数量')
    media_review_total_num = IntegerField('复核媒体总数')
    report_pic_num = IntegerField('上报图片数量')
    report_pic_total_num = IntegerField('上报图片总数')
    report_video_num = IntegerField('上报视频数量')
    report_video_total_num = IntegerField('上报视频总数')
    report_wav_num = IntegerField('上报音频数量')
    report_wav_total_num = IntegerField('上报音频总数')
    check_pic_num = IntegerField('核查图片数量')
    check_pic_total_num = IntegerField('核查图片总数')
    check_video_num = IntegerField('核查视频数量')
    check_video_total_num = IntegerField('核查视频总数')
    check_wav_num = IntegerField('核查音频数量')
    check_wav_total_num = IntegerField('核查音频总数')
    verify_pic_num = IntegerField('核实图片数量')
    verify_pic_total_num = IntegerField('核实图片总数')
    verify_video_num = IntegerField('核实视频数量')
    verify_video_total_num = IntegerField('核实视频总数')
    verify_wav_num = IntegerField('核实音频数量')
    verify_wav_total_num = IntegerField('核实音频总数')
    self_deal_pic_num = IntegerField('自行处置图片数量')
    self_deal_pic_total_num = IntegerField('自行处置图片总数')
    self_deal_video_num = IntegerField('自行处置视频数量')
    self_deal_video_total_num = IntegerField('自行处置视频总数')
    self_deal_wav_num = IntegerField('自行处置音频数量')
    self_deal_wav_total_num = IntegerField('自行处置音频总数')
    review_pic_num = IntegerField('复核图片数量')
    review_video_total_num = IntegerField('复核视频总数')
    review_wav_num = IntegerField('复核音频数量')
    review_wav_total_num = IntegerField('复核音频总数')

    # 媒体路径与属性
    media_url = StringField('内部访问URL', validators=[Length(max=512, message='内部访问URL长度不能超过512字符')])
    mms_pic_path = StringField('彩信图片路径', validators=[Length(max=500, message='彩信图片路径长度不能超过500字符')])
    media_path = StringField('服务器存储路径', validators=[Length(max=512, message='服务器存储路径长度不能超过512字符')])
    media_type = StringField('媒体类型', validators=[Length(max=50, message='媒体类型长度不能超过50字符')])
    media_usage = StringField('使用场景', validators=[Length(max=100, message='使用场景长度不能超过100字符')])
    media_server_name = StringField('媒体服务器名称', validators=[Length(max=100, message='媒体服务器名称长度不能超过100字符')])
    media_property = IntegerField('媒体属性')
    media_uploaded_name = StringField('上传时的原始文件名', validators=[Length(max=255, message='上传时的原始文件名长度不能超过255字符')])
    media_shot = StringField('截图标识或路径', validators=[Length(max=255, message='截图标识或路径长度不能超过255字符')])
    media_label_type_id = IntegerField('标签类型ID')
    media_default_url = StringField('外部可访问URL', validators=[Length(max=512, message='外部可访问URL长度不能超过512字符')])
    display_order = IntegerField('显示顺序')
    store_type_id = IntegerField('存储类型ID')
    special_item_image_type = StringField('特殊图片类型', validators=[Length(max=100, message='特殊图片类型长度不能超过100字符')])
    height = IntegerField('图片高度')
    width = IntegerField('图片宽度')
    send_flag = IntegerField('发送标志')
    public_flag = IntegerField('公开标志')
    gen_thumb = IntegerField('是否生成缩略图')
    can_delete = IntegerField('是否可删除')
    delete_flag = IntegerField('删除标记')
    delete_reason = TextAreaField('删除原因', validators=[Length(max=65535, message='删除原因长度不能超过65535字符')])

    # 地理与位置
    pos_type = StringField('位置类型', validators=[Length(max=50, message='位置类型长度不能超过50字符')])
    view_angle = StringField('视角', validators=[Length(max=100, message='视角长度不能超过100字符')])
    view_image_name = StringField('视图图片名称', validators=[Length(max=200, message='视图图片名称长度不能超过200字符')])
    view_image_x = FloatField('视图图片X坐标')
    view_image_y = FloatField('视图图片Y坐标')
    view_pos_x = FloatField('视图位置X坐标')
    view_pos_y = FloatField('视图位置Y坐标')

    # 附件与标识
    attach_rec_flag = StringField('附件记录标识', validators=[Length(max=50, message='附件记录标识长度不能超过50字符')])
    gather_flag = StringField('汇总标识', validators=[Length(max=50, message='汇总标识长度不能超过50字符')])
    link_field_value = StringField('关联字段值', validators=[Length(max=500, message='关联字段值长度不能超过500字符')])
    link_field_display_value = StringField('关联字段显示值', validators=[Length(max=500, message='关联字段显示值长度不能超过500字符')])
    unique_id = StringField('唯一标识', validators=[Length(max=100, message='唯一标识长度不能超过100字符')])
    third_unique_id = StringField('第三方唯一标识', validators=[Length(max=100, message='第三方唯一标识长度不能超过100字符')])
    equal_group_id = IntegerField('等值组ID')
    rec_category_id = IntegerField('记录类别ID')

    # 处置与审核
    dispatch_opinion = StringField('派遣意见', validators=[Length(max=500, message='派遣意见长度不能超过500字符')])
    revise_opinion = StringField('修订意见', validators=[Length(max=500, message='修订意见长度不能超过500字符')])
    reply_opinion = StringField('回复意见', validators=[Length(max=500, message='回复意见长度不能超过500字符')])
    new_inst_advise = StringField('立案建议', validators=[Length(max=500, message='立案建议长度不能超过500字符')])
    new_inst_cond_id = IntegerField('立案条件ID')
    new_inst_cond_name = StringField('立案条件', validators=[Length(max=200, message='立案条件长度不能超过200字符')])
    case_closure_condition = StringField('结案条件', validators=[Length(max=200, message='结案条件长度不能超过200字符')])

    # 特殊字段
    event_marks = StringField('事件标记', validators=[Length(max=500, message='事件标记长度不能超过500字符')])
    deduction = StringField('扣减', validators=[Length(max=100, message='扣减长度不能超过100字符')])
    event_property_id = IntegerField('事件属性ID')
    event_property_name = StringField('事件属性名称', validators=[Length(max=200, message='事件属性名称长度不能超过200字符')])
    city_village_flag = StringField('城乡标识', validators=[Length(max=50, message='城乡标识长度不能超过50字符')])
    force_handle_flag = StringField('强制处理标识', validators=[Length(max=50, message='强制处理标识长度不能超过50字符')])
    auto_check_count = IntegerField('自动核查次数')
    deal_evaluate_ids = StringField('处置评价ID列表', validators=[Length(max=200, message='处置评价ID列表长度不能超过200字符')])
    newinst_no_transit = StringField('立案不转交', validators=[Length(max=50, message='立案不转交长度不能超过50字符')])
    super_rec_id = IntegerField('上级记录ID')
    site_num = StringField('站点编号', validators=[Length(max=50, message='站点编号长度不能超过50字符')])
    difficult_type_id = IntegerField('困难类型ID')
    event_district_grade_id = IntegerField('事件区域等级ID')
    event_district_grade_name = StringField('事件区域等级名称', validators=[Length(max=100, message='事件区域等级名称长度不能超过100字符')])
    cus_grid_code = StringField('自定义网格编码', validators=[Length(max=100, message='自定义网格编码长度不能超过100字符')])
    site_id = IntegerField('站点ID')
    shop_id = IntegerField('商铺ID')
    shop_name = StringField('商铺名称', validators=[Length(max=200, message='商铺名称长度不能超过200字符')])
    spec_type_id = IntegerField('特殊类型ID')
    spec_type_name = StringField('特殊类型名称', validators=[Length(max=100, message='特殊类型名称长度不能超过100字符')])
    proc_account_state_id = IntegerField('处理账户状态ID')
    check_type_id = IntegerField('核查类型ID')
    rec_analysis_type_id = IntegerField('记录分析类型ID')
    proc_time_state_id = IntegerField('处理流程状态ID')
    proc_ard_state_id = IntegerField('处理仲裁状态ID')
    proc_enq_state_id = IntegerField('处理询问状态ID')
    proc_sup_state_id = IntegerField('处理监督状态ID')
    func_time_state_id = IntegerField('职能部门时间状态ID')
    check_msg_state_id = IntegerField('核查消息状态ID')
    verify_msg_state_id = IntegerField('核实消息状态ID')
    regather_msg_state_id = IntegerField('重新采集消息状态ID')
    supervision_check_state_id = IntegerField('监督核查状态ID')
    self_deal_msg_state_id = IntegerField('自行处置消息状态ID')
    review_msg_state_id = IntegerField('复核消息状态ID')
    proc_press_state_id = IntegerField('处理压力状态ID')
    hot_area = StringField('热点区域', validators=[Length(max=100, message='热点区域长度不能超过100字符')])
    cg_area = StringField('城管区域', validators=[Length(max=100, message='城管区域长度不能超过100字符')])
    hw_area = StringField('环卫区域', validators=[Length(max=100, message='环卫区域长度不能超过100字符')])
    sz_area = StringField('市政区域', validators=[Length(max=100, message='市政区域长度不能超过100字符')])
    device_guid = StringField('设备GUID', validators=[Length(max=100, message='设备GUID长度不能超过100字符')])
    jx_id = IntegerField('警讯ID')
    jx_jxmc = StringField('警讯名称', validators=[Length(max=200, message='警讯名称长度不能超过200字符')])
    jx_design_type = StringField('警讯设计类型', validators=[Length(max=100, message='警讯设计类型长度不能超过100字符')])
    report_time_segment_id = IntegerField('上报时段ID')
    archive_cond_id = IntegerField('归档条件ID')
    archive_cond = StringField('归档条件', validators=[Length(max=100, message='归档条件长度不能超过100字符')])
    archive_type_id = IntegerField('归档类型ID')
    road_type_id = IntegerField('道路类型ID')
    road_name = StringField('道路名称', validators=[Length(max=200, message='道路名称长度不能超过200字符')])
    road_id = IntegerField('道路ID')
    road_type_name = StringField('道路类型名称', validators=[Length(max=100, message='道路类型名称长度不能超过100字符')])
    area_type_id = IntegerField('区域类型ID')
    duty_grid_type_id = IntegerField('责任网格类型ID')
    deal_duty_grid_type_id = IntegerField('处置责任网格类型ID')
    time_area_id = IntegerField('时段ID')
    time_area_name = StringField('时段名称', validators=[Length(max=100, message='时段名称长度不能超过100字符')])
    card_num = StringField('证件号码', validators=[Length(max=100, message='证件号码长度不能超过100字符')])
    cell_id = IntegerField('单元格ID')
    cell_name = StringField('单元格名称', validators=[Length(max=200, message='单元格名称长度不能超过200字符')])
    damage_grade_id = IntegerField('损毁等级ID')
    damage_grade_name = StringField('损毁等级名称', validators=[Length(max=100, message='损毁等级名称长度不能超过100字符')])
    event_grade_id = IntegerField('事件等级ID')
    event_grade_name = StringField('事件等级名称', validators=[Length(max=100, message='事件等级名称长度不能超过100字符')])
    event_level_id = IntegerField('事件级别ID')
    event_level_name = StringField('事件级别名称', validators=[Length(max=100, message='事件级别名称长度不能超过100字符')])
    event_district_id = IntegerField('事件区域ID')
    event_district_name = StringField('事件区域名称', validators=[Length(max=100, message='事件区域名称长度不能超过100字符')])
    display_property = StringField('显示属性', validators=[Length(max=200, message='显示属性长度不能超过200字符')])
    display_style_id = IntegerField('显示样式ID')
    refresh_flag = IntegerField('刷新标识')
    video_device_id = IntegerField('视频设备ID')
    video_param = StringField('视频参数', validators=[Length(max=500, message='视频参数长度不能超过500字符')])
    video_device_id = IntegerField('视频设备ID')
    video_param = StringField('视频参数', validators=[Length(max=500, message='视频参数长度不能超过500字符')])
    patrol_deal_flag = IntegerField('巡查处置标识')
    send_from_type = StringField('发送来源类型', validators=[Length(max=50, message='发送来源类型长度不能超过50字符')])
    reply_intime_deadline = IntegerField('两小时回复截止时间戳')
    accept_status = StringField('受理状态', validators=[Length(max=50, message='受理状态长度不能超过50字符')])
    squadron_id = IntegerField('中队ID')
    squadron_name = StringField('中队名称', validators=[Length(max=200, message='中队名称长度不能超过200字符')])
    property_company_id = IntegerField('物业公司ID')
    act_record_id = IntegerField('操作记录ID')
    main_rec_id = IntegerField('主记录ID')
    force_handle_flag = StringField('强制处理标识', validators=[Length(max=50, message='强制处理标识长度不能超过50字符')])
    func_custom_limit = StringField('职能部门自定义时限', validators=[Length(max=50, message='职能部门自定义时限长度不能超过50字符')])

    def process(self, formdata=None, obj=None, **kwargs):
        """
        处理表单数据，在数据绑定前进行预处理。

        主要功能：
            - 遍历所有表单字段
            - 对字符串类型的值去除两端空白字符
            - 调用父类的process方法继续处理
        """
        if formdata:
            for name, values in formdata.items():
                if isinstance(values, list) and values:
                    formdata[name] = [v.strip() if isinstance(v, str) else v for v in values]
                elif isinstance(values, str):
                    formdata[name] = values.strip()
        super().process(formdata, obj, **kwargs)


class DcmTaskFormDatumBase(TD3iDcmTaskFormDatum, CommonModel):
    """
    企业待办表单数据基础类（完全映射 TD3iDcmTaskFormDatum 字段）。

    封装所有与企业待办表单数据相关的通用操作方法。
    """

    FieldMapping = {
        'id': 'id',
        'rec_id': 'rec_id',
        'rec_disp_num': 'rec_disp_num',
        'rec_type_id': 'rec_type_id',
        'rec_type_name': 'rec_type_name',
        'task_num': 'task_num',
        'other_task_num': 'other_task_num',
        'act_property_id': 'act_property_id',
        'biz_id': 'biz_id',
        'biz_name': 'biz_name',
        'sys_id': 'sys_id',
        'address': 'address',
        'district_name': 'district_name',
        'coordinate_x': 'coordinate_x',
        'coordinate_y': 'coordinate_y',
        'lonlat_x': 'lonlat_x',
        'lonlat_y': 'lonlat_y',
        'event_type_id': 'event_type_id',
        'event_type_name': 'event_type_name',
        'event_src_id': 'event_src_id',
        'event_src_name': 'event_src_name',
        'event_desc': 'event_desc',
        'max_event_type_id': 'max_event_type_id',
        'max_event_type_name': 'max_event_type_name',
        'main_type_id': 'main_type_id',
        'main_type_name': 'main_type_name',
        'sub_type_id': 'sub_type_id',
        'sub_type_name': 'sub_type_name',
        'third_type_id': 'third_type_id',
        'third_type_name': 'third_type_name',
        'forth_type_id': 'forth_type_id',
        'forth_type_name': 'forth_type_name',
        'fifth_type_id': 'fifth_type_id',
        'fifth_type_name': 'fifth_type_name',
        'sixth_type_id': 'sixth_type_id',
        'sixth_type_name': 'sixth_type_name',
        'seventh_type_id': 'seventh_type_id',
        'seventh_type_name': 'seventh_type_name',
        'create_time': 'create_time',
        'update_time': 'update_time',
        'deadline_time': 'deadline_time',
        'warning_time': 'warning_time',
        'occur_time': 'occur_time',
        'dispatch_time': 'dispatch_time',
        'archive_time': 'archive_time',
        'cancel_time': 'cancel_time',
        'refresh_time': 'refresh_time',
        'refresh_start_time': 'refresh_start_time',
        'check_send_time': 'check_send_time',
        'check_reply_time': 'check_reply_time',
        'func_deadline': 'func_deadline',
        'func_deal_time': 'func_deal_time',
        'proc_start_time': 'proc_start_time',
        'custom_deadline': 'custom_deadline',
        'patroltask_deadline_time': 'patroltask_deadline_time',
        'deadline_char': 'deadline_char',
        'func_limit_char': 'func_limit_char',
        'rec_remain_char': 'rec_remain_char',
        'rec_used_char': 'rec_used_char',
        'rec_remain': 'rec_remain',
        'rec_used': 'rec_used',
        'rec_warning': 'rec_warning',
        'rec_deadline': 'rec_deadline',
        'func_part_id': 'func_part_id',
        'func_part_name': 'func_part_name',
        'func_part_list_id': 'func_part_list_id',
        'func_part_list_name': 'func_part_list_name',
        'specify_func_id': 'specify_func_id',
        'specify_func_name': 'specify_func_name',
        'specify_competent_func_id': 'specify_competent_func_id',
        'specify_competent_func_name': 'specify_competent_func_name',
        'first_depart_name': 'first_depart_name',
        'second_depart_name': 'second_depart_name',
        'district_id': 'district_id',
        'street_id': 'street_id',
        'street_name': 'street_name',
        'community_id': 'community_id',
        'community_name': 'community_name',
        'duty_grid_id': 'duty_grid_id',
        'duty_grid_name': 'duty_grid_name',
        'duty_region_id': 'duty_region_id',
        'duty_region_name': 'duty_region_name',
        'duty_district_id': 'duty_district_id',
        'duty_district_name': 'duty_district_name',
        'duty_street_id': 'duty_street_id',
        'duty_street_name': 'duty_street_name',
        'duty_community_id': 'duty_community_id',
        'duty_community_name': 'duty_community_name',
        'law_duty_grid_id': 'law_duty_grid_id',
        'law_duty_grid_name': 'law_duty_grid_name',
        'deal_duty_grid_id': 'deal_duty_grid_id',
        'deal_duty_grid_name': 'deal_duty_grid_name',
        'patrol_id': 'patrol_id',
        'patrol_name': 'patrol_name',
        'accepter_id': 'accepter_id',
        'accepter_name': 'accepter_name',
        'human_id': 'human_id',
        'human_name': 'human_name',
        'reporter_name': 'reporter_name',
        'reporter_contact': 'reporter_contact',
        'tell_num': 'tell_num',
        'read_flag': 'read_flag',
        'reply_intime': 'reply_intime',
        'return_visit_flag': 'return_visit_flag',
        'urgency_level': 'urgency_level',
        'urgent_flag': 'urgent_flag',
        'func_forbid_reporter_info_flag': 'func_forbid_reporter_info_flag',
        'public_flag': 'public_flag',
        'locked_flag': 'locked_flag',
        'transited_flag': 'transited_flag',
        'split_rec_flag': 'split_rec_flag',
        'enable_check_msg': 'enable_check_msg',
        'no_return_visit_flag': 'no_return_visit_flag',
        'common_rec_type_flag': 'common_rec_type_flag',
        'common_rec_attr_flag': 'common_rec_attr_flag',
        'send_pub_check_task_flag': 'send_pub_check_task_flag',
        'reply_flag': 'reply_flag',
        'whistle_flag': 'whistle_flag',
        'repeat_state': 'repeat_state',
        'report_state': 'report_state',
        'dispose_state': 'dispose_state',
        'pre_dispose_state': 'pre_dispose_state',
        'undertake_user_name': 'undertake_user_name',
        'undertake_phone': 'undertake_phone',
        'deal_person_org': 'deal_person_org',
        'media_upload_num': 'media_upload_num',
        'media_upload_total_num': 'media_upload_total_num',
        'media_upload_state': 'media_upload_state',
        'media_check_num': 'media_check_num',
        'media_check_total_num': 'media_check_total_num',
        'media_verify_num': 'media_verify_num',
        'media_verify_total_num': 'media_verify_total_num',
        'media_self_deal_num': 'media_self_deal_num',
        'media_self_deal_total_num': 'media_self_deal_total_num',
        'media_review_num': 'media_review_num',
        'media_review_total_num': 'media_review_total_num',
        'report_pic_num': 'report_pic_num',
        'report_pic_total_num': 'report_pic_total_num',
        'report_video_num': 'report_video_num',
        'report_video_total_num': 'report_video_total_num',
        'report_wav_num': 'report_wav_num',
        'report_wav_total_num': 'report_wav_total_num',
        'check_pic_num': 'check_pic_num',
        'check_pic_total_num': 'check_pic_total_num',
        'check_video_num': 'check_video_num',
        'check_video_total_num': 'check_video_total_num',
        'check_wav_num': 'check_wav_num',
        'check_wav_total_num': 'check_wav_total_num',
        'verify_pic_num': 'verify_pic_num',
        'verify_pic_total_num': 'verify_pic_total_num',
        'verify_video_num': 'verify_video_num',
        'verify_video_total_num': 'verify_video_total_num',
        'verify_wav_num': 'verify_wav_num',
        'verify_wav_total_num': 'verify_wav_total_num',
        'self_deal_pic_num': 'self_deal_pic_num',
        'self_deal_pic_total_num': 'self_deal_pic_total_num',
        'self_deal_video_num': 'self_deal_video_num',
        'self_deal_video_total_num': 'self_deal_video_total_num',
        'self_deal_wav_num': 'self_deal_wav_num',
        'self_deal_wav_total_num': 'self_deal_wav_total_num',
        'review_pic_num': 'review_pic_num',
        'review_pic_total_num': 'review_pic_total_num',
        'review_video_num': 'review_video_num',
        'review_video_total_num': 'review_video_total_num',
        'review_wav_num': 'review_wav_num',
        'review_wav_total_num': 'review_wav_total_num',
        'media_url': 'media_url',
        'mms_pic_path': 'mms_pic_path',
        'media_path': 'media_path',
        'media_type': 'media_type',
        'media_usage': 'media_usage',
        'media_server_name': 'media_server_name',
        'media_property': 'media_property',
        'media_uploaded_name': 'media_uploaded_name',
        'media_shot': 'media_shot',
        'media_label_type_id': 'media_label_type_id',
        'media_default_url': 'media_default_url',
        'display_order': 'display_order',
        'store_type_id': 'store_type_id',
        'special_item_image_type': 'special_item_image_type',
        'height': 'height',
        'width': 'width',
        'send_flag': 'send_flag',
        'public_flag': 'public_flag',
        'gen_thumb': 'gen_thumb',
        'can_delete': 'can_delete',
        'delete_flag': 'delete_flag',
        'delete_reason': 'delete_reason',
        'pos_type': 'pos_type',
        'view_angle': 'view_angle',
        'view_image_name': 'view_image_name',
        'view_image_x': 'view_image_x',
        'view_image_y': 'view_image_y',
        'view_pos_x': 'view_pos_x',
        'view_pos_y': 'view_pos_y',
        'attach_rec_flag': 'attach_rec_flag',
        'gather_flag': 'gather_flag',
        'link_field_value': 'link_field_value',
        'link_field_display_value': 'link_field_display_value',
        'unique_id': 'unique_id',
        'third_unique_id': 'third_unique_id',
        'equal_group_id': 'equal_group_id',
        'rec_category_id': 'rec_category_id',
        'dispatch_opinion': 'dispatch_opinion',
        'revise_opinion': 'revise_opinion',
        'reply_opinion': 'reply_opinion',
        'new_inst_advise': 'new_inst_advise',
        'new_inst_cond_id': 'new_inst_cond_id',
        'new_inst_cond_name': 'new_inst_cond_name',
        'case_closure_condition': 'case_closure_condition',
        'event_marks': 'event_marks',
        'deduction': 'deduction',
        'event_property_id': 'event_property_id',
        'event_property_name': 'event_property_name',
        'city_village_flag': 'city_village_flag',
        'force_handle_flag': 'force_handle_flag',
        'auto_check_count': 'auto_check_count',
        'deal_evaluate_ids': 'deal_evaluate_ids',
        'newinst_no_transit': 'newinst_no_transit',
        'super_rec_id': 'super_rec_id',
        'site_num': 'site_num',
        'difficult_type_id': 'difficult_type_id',
        'event_district_grade_id': 'event_district_grade_id',
        'event_district_grade_name': 'event_district_grade_name',
        'cus_grid_code': 'cus_grid_code',
        'site_id': 'site_id',
        'shop_id': 'shop_id',
        'shop_name': 'shop_name',
        'spec_type_id': 'spec_type_id',
        'spec_type_name': 'spec_type_name',
        'proc_account_state_id': 'proc_account_state_id',
        'check_type_id': 'check_type_id',
        'rec_analysis_type_id': 'rec_analysis_type_id',
        'proc_time_state_id': 'proc_time_state_id',
        'proc_ard_state_id': 'proc_ard_state_id',
        'proc_enq_state_id': 'proc_enq_state_id',
        'proc_sup_state_id': 'proc_sup_state_id',
        'func_time_state_id': 'func_time_state_id',
        'check_msg_state_id': 'check_msg_state_id',
        'verify_msg_state_id': 'verify_msg_state_id',
        'regather_msg_state_id': 'regather_msg_state_id',
        'supervision_check_state_id': 'supervision_check_state_id',
        'self_deal_msg_state_id': 'self_deal_msg_state_id',
        'review_msg_state_id': 'review_msg_state_id',
        'proc_press_state_id': 'proc_press_state_id',
        'hot_area': 'hot_area',
        'cg_area': 'cg_area',
        'hw_area': 'hw_area',
        'sz_area': 'sz_area',
        'device_guid': 'device_guid',
        'jx_id': 'jx_id',
        'jx_jxmc': 'jx_jxmc',
        'jx_design_type': 'jx_design_type',
        'report_time_segment_id': 'report_time_segment_id',
        'archive_cond_id': 'archive_cond_id',
        'archive_cond': 'archive_cond',
        'archive_type_id': 'archive_type_id',
        'road_type_id': 'road_type_id',
        'road_name': 'road_name',
        'road_id': 'road_id',
        'road_type_name': 'road_type_name',
        'area_type_id': 'area_type_id',
        'duty_grid_type_id': 'duty_grid_type_id',
        'deal_duty_grid_type_id': 'deal_duty_grid_type_id',
        'time_area_id': 'time_area_id',
        'time_area_name': 'time_area_name',
        'card_num': 'card_num',
        'cell_id': 'cell_id',
        'cell_name': 'cell_name',
        'damage_grade_id': 'damage_grade_id',
        'damage_grade_name': 'damage_grade_name',
        'event_grade_id': 'event_grade_id',
        'event_grade_name': 'event_grade_name',
        'event_level_id': 'event_level_id',
        'event_level_name': 'event_level_name',
        'event_district_id': 'event_district_id',
        'event_district_name': 'event_district_name',
        'display_property': 'display_property',
        'display_style_id': 'display_style_id',
        'refresh_flag': 'refresh_flag',
        'video_device_id': 'video_device_id',
        'video_param': 'video_param',
        'patrol_deal_flag': 'patrol_deal_flag',
        'send_from_type': 'send_from_type',
        'reply_intime_deadline': 'reply_intime_deadline',
        'accept_status': 'accept_status',
        'squadron_id': 'squadron_id',
        'squadron_name': 'squadron_name',
        'property_company_id': 'property_company_id',
        'act_record_id': 'act_record_id',
        'main_rec_id': 'main_rec_id',
        'func_custom_limit': 'func_custom_limit',
    }

    @classmethod
    async def exist_other(cls, id: Union[str, int], rec_id: Union[str, int]):
        """
        检查是否存在除当前任务外的其他同记录ID的任务。

        :param id: 当前任务ID
        :param rec_id: 记录ID
        :return: 存在返回任务对象，不存在返回None
        """
        _query = select(cls).where(cls.id != id, cls.rec_id == rec_id)
        _task: cls = await cls.query_first(_query)
        return _task

    @classmethod
    async def find_by_ids(cls, ids: list[Union[str, int]]):
        """
        根据ID列表批量查找任务数据。
        """
        _query = select(cls).where(cls.id.in_(ids))
        _task_list: list[cls] = (await cls.orm_execute_scalars(_query)).all()
        return _task_list

    @classmethod
    async def is_exist(cls, rec_id: Union[str, int]):
        """
        检查任务是否已经存在（根据记录ID）。
        """
        _query = select(cls).where(cls.rec_id == rec_id)
        _task: cls = await cls.query_first(_query)
        return _task

    @classmethod
    async def search_base(cls, is_paging=True, **kwargs):
        """
        按参数搜索任务数据的基础方法。

        支持字段：
            - task_num, rec_disp_num, event_type_name, district_name, urgency_level, read_flag 等
            - 支持模糊匹配：event_type_name, rec_type_name, event_src_name, first_depart_name, second_depart_name
            - 支持精确匹配：biz_id, sys_id, urgency_level, read_flag, rec_type_id, deadline_time 等

        :param is_paging: 是否分页
        :param kwargs: 查询参数
        :key int page_number: 页码（缺省随机1~100）
        :key int page_size: 每页数量（缺省20）
        :key dict sort_clause: 排序配置，如 {'task_num': 'asc'}
        :key str task_num: 精确匹配任务号
        :key str rec_disp_num: 精确匹配显示编号
        :key str event_type_name: 模糊匹配问题类型
        :key str district_name: 精确匹配区域
        :key int urgency_level: 精确匹配紧急程度
        :key int read_flag: 精确匹配是否已读
        :key int biz_id: 精确匹配业务ID
        :key int sys_id: 精确匹配系统ID
        :key int rec_type_id: 精确匹配类型ID
        :key int deadline_time: 精确匹配处理截止时间戳
        :return: (DataFrame, Pagination)
        """
        page_number = kwargs.get('page_number', random.randint(1, 100))
        page_size = kwargs.get('page_size', 20)
        kwargs.update({'page_number': page_number, 'page_size': page_size})

        # 模糊查询字段
        _name_likes = {
            cls.event_type_name.key: '%{}%',
            cls.rec_type_name.key: '%{}%',
            cls.event_src_name.key: '%{}%',
            cls.first_depart_name.key: '%{}%',
            cls.second_depart_name.key: '%{}%',
            cls.district_name.key: '%{}%',
            cls.street_name.key: '%{}%',
            cls.community_name.key: '%{}%',
            cls.func_part_name.key: '%{}%',
            cls.specify_func_name.key: '%{}%',
            cls.specify_competent_func_name.key: '%{}%',
            cls.main_type_name.key: '%{}%',
            cls.sub_type_name.key: '%{}%',
            cls.third_type_name.key: '%{}%',
            cls.forth_type_name.key: '%{}%',
            cls.fifth_type_name.key: '%{}%',
            cls.sixth_type_name.key: '%{}%',
            cls.seventh_type_name.key: '%{}%',
            cls.duty_grid_name.key: '%{}%',
            cls.duty_region_name.key: '%{}%',
            cls.duty_district_name.key: '%{}%',
            cls.duty_street_name.key: '%{}%',
            cls.duty_community_name.key: '%{}%',
            cls.law_duty_grid_name.key: '%{}%',
            cls.deal_duty_grid_name.key: '%{}%',
            cls.patrol_name.key: '%{}%',
            cls.accepter_name.key: '%{}%',
            cls.human_name.key: '%{}%',
            cls.reporter_name.key: '%{}%',
            cls.shop_name.key: '%{}%',
            cls.spec_type_name.key: '%{}%',
            cls.squadron_name.key: '%{}%',
            cls.road_name.key: '%{}%',
            cls.time_area_name.key: '%{}%',
            cls.hot_area.key: '%{}%',
            cls.cg_area.key: '%{}%',
            cls.hw_area.key: '%{}%',
            cls.sz_area.key: '%{}%',
            cls.event_district_grade_name.key: '%{}%',
        }

        _query = select(cls).where(
            *cls.search_wheres(likes=_name_likes, **kwargs)
        ).group_by(cls.id)

        _paging = None
        if is_paging:
            _row_count = await cls.query_count(_query)
            _paging = Pagination(_row_count).paging(page_number, page_size)
            _data_query = _query.limit(page_size).offset(_paging.offset_size)
        else:
            _data_query = _query.where()

        _sort_clause = cls.sort_clauses(kwargs.get('sort_clause', {}))
        if _sort_clause:
            _data_query = _data_query.order_by(*_sort_clause)
        else:
            _data_query = _data_query.order_by(cls.task_num, cls.rec_disp_num)

        _task_df = await cls.query_as_df(_data_query)
        if not _task_df.empty:
            _task_df.replace(models.EmptyInDF + models.EmptyDatetimeInDF, '', inplace=True)
            _task_df[cls.id.key] = _task_df[cls.id.key].astype(str)

        return _task_df, _paging

    @classmethod
    async def search(cls, **kwargs):
        """
        按参数搜索任务数据，返回分页格式数据。
        """
        _task_df, _paging = await cls.search_base(**kwargs)
        return {
            'total': _paging.row_count,
            'rows': _task_df.to_dict('records'),
            'pagination': {
                'page_number': _paging.page_number,
                'page_count': _paging.page_count,
                'page_size': _paging.page_size,
            },
        }

    @classmethod
    async def exists_rec_id(cls, data_df: pd.DataFrame):
        """
        查找 data_df 中在数据库中已存在和不存在的记录。根据 rec_id 字段判断。

        :param data_df: 输入的数据框架，必须包含 rec_id 列
        :return: (exists_df: pd.DataFrame, latest_df: pd.DataFrame)
            - exists_df: 在数据库中存在的记录
            - latest_df: 在数据库中不存在的记录
        """
        if data_df.empty:
            return pd.DataFrame(), pd.DataFrame()

        # 获取待查询的 rec_id 列表（去重）
        rec_ids = data_df[cls.rec_id.key].unique().tolist()
        if not rec_ids:
            return pd.DataFrame(), data_df.copy()

        # 查询数据库中已存在的 rec_id
        _query = select(cls.id, cls.rec_id).where(cls.rec_id.in_(rec_ids))
        rec_ids_df = await cls.query_as_df(_query)

        if rec_ids_df.empty:
            return pd.DataFrame(), data_df.copy()

        # 构建 rec_id -> id 的映射字典
        rec_id_to_id_map = dict(zip(rec_ids_df[cls.rec_id.key], rec_ids_df[cls.id.key]))

        # 根据 rec_id 是否在数据库中，划分数据
        mask_exists = data_df[cls.rec_id.key].isin(rec_ids_df[cls.rec_id.key])
        # 数据库已经有的记录
        exists_df = data_df[mask_exists].copy()
        # 自动补充从数据库查到的 id 字段
        exists_df[cls.id.key] = exists_df[cls.rec_id.key].map(rec_id_to_id_map)
        # 新的数据
        latest_df = data_df[~mask_exists].copy()
        return exists_df, latest_df

    @classmethod
    async def fill_form_datum(cls, data_df: pd.DataFrame, index_field: str = 'id',
                              column_name: str = 'datums',
                              preprocessing: Optional[Callable] = None):
        """
        填充详细数据到数据框架。

        用于在查询结果中添加关联的详细信息。

        :param pandas.DataFrame data_df: 待填充的数据框架
        :param str index_field: 索引字段，一般是任务ID
        :param str column_name: 填充时，新增加的列名称，默认为`datums`
        :param preprocessing: 预处理，注意预处理必须要返回处理后的结果
        :return: 详细数据框架（已填充）
        :rtype: pandas.DataFrame
        """
        if data_df.empty:
            return pd.DataFrame()

        _task_ids = list(set(data_df[index_field].unique().tolist()))
        if not _task_ids:
            return pd.DataFrame()

        _query = select(cls).where(cls.dcm_task_id.in_(_task_ids))
        _datum_df: pd.DataFrame = await cls.query_as_df(_query)
        if not _datum_df.empty:
            _datum_df.replace(models.EmptyInDF+models.EmptyDatetimeInDF, '', inplace=True)
            # 整理输出数据类型
            _datum_df[cls.id.key] = _datum_df[cls.id.key].astype(str)
            _datum_df[cls.dcm_task_id.key] = _datum_df[cls.dcm_task_id.key].astype(str)

            # 设置索引
            _datum_df['index_id'] = _datum_df[cls.id.key]
            _datum_df.set_index(['index_id'], inplace=True)
            # 对数据进行预处理
            if isinstance(preprocessing, Callable):
                _datum_df = preprocessing(_datum_df)
            # 增加数据填充列
            data_df[column_name] = data_df[index_field].apply(
                lambda x: _datum_df.query(f"{cls.dcm_task_id.key}=='{x}'").to_dict('records')
            )
        else:
            data_df[column_name] = [[] for _ in range(len(data_df))]

        return _datum_df


@register_swagger_model
class DcmTaskFormDatum(DcmTaskFormDatumBase):
    """
    企业待办表单数据主业务类（完全继承 TD3iDcmTaskFormDatum 字段）。

    ---
    description: 数字化城市管理信息系统企业待办表单数据
    type: object
    properties:
      id:
        description: 主键ID
        type: integer
        example: 1001
        readOnly: true
      rec_id:
        description: 记录ID
        type: integer
        example: 2001
      rec_disp_num:
        description: 显示编号
        type: string
        example: "D20240501001"
        maxLength: 50
      rec_type_id:
        description: 类型ID
        type: integer
        example: 101
      rec_type_name:
        description: 案件类型
        type: string
        example: "市容环境"
        maxLength: 100
      task_num:
        description: 任务号
        type: string
        example: "TASK20240501001"
        maxLength: 50
      other_task_num:
        description: 第三方任务号
        type: string
        example: "THIRD-2024-001"
        maxLength: 100
      act_property_id:
        description: 任务属性ID
        type: integer
        example: 5
      biz_id:
        description: 业务ID
        type: integer
        example: 10
      biz_name:
        description: 业务名称
        type: string
        example: "市容巡查"
        maxLength: 200
      sys_id:
        description: 系统ID
        type: integer
        example: 1
      address:
        description: 地址描述
        type: string
        example: "中山路与解放路交叉口"
        maxLength: 65535
      district_name:
        description: 所属区域
        type: string
        example: "鼓楼区"
        maxLength: 50
      coordinate_x:
        description: 经度
        type: number
        format: decimal
        example: 118.789012
      coordinate_y:
        description: 纬度
        type: number
        format: decimal
        example: 32.045678
      lonlat_x:
        description: 经纬度X
        type: number
        format: decimal
        example: 118.789012
      lonlat_y:
        description: 经纬度Y
        type: number
        format: decimal
        example: 32.045678
      event_type_id:
        description: 问题类型ID
        type: integer
        example: 1001
      event_type_name:
        description: 问题类型
        type: string
        example: "道路破损"
        maxLength: 100
      event_src_id:
        description: 问题来源ID
        type: integer
        example: 101
      event_src_name:
        description: 问题来源
        type: string
        example: "市民举报"
        maxLength: 100
      event_desc:
        description: 问题描述
        type: string
        example: "中山路与解放路交叉口路面大面积破损"
        maxLength: 65535
      max_event_type_id:
        description: 最大事件类型ID
        type: integer
        example: 1002
      max_event_type_name:
        description: 最大事件类型名称
        type: string
        example: "市政设施"
        maxLength: 200
      main_type_id:
        description: 大类ID
        type: integer
        example: 101
      main_type_name:
        description: 大类名称
        type: string
        example: "市容环境"
        maxLength: 100
      sub_type_id:
        description: 小类ID
        type: integer
        example: 10101
      sub_type_name:
        description: 小类名称
        type: string
        example: "道路破损"
        maxLength: 100
      third_type_id:
        description: 第三级类型ID
        type: integer
        example: 1010101
      third_type_name:
        description: 第三级类型名称
        type: string
        example: "人行道破损"
        maxLength: 100
      forth_type_id:
        description: 第四级类型ID
        type: integer
        example: 101010101
      forth_type_name:
        description: 第四级类型名称
        type: string
        example: "沥青路面破损"
        maxLength: 100
      fifth_type_id:
        description: 第五级类型ID
        type: integer
        example: 10101010101
      fifth_type_name:
        description: 第五级类型名称
        type: string
        example: "裂缝"
        maxLength: 100
      sixth_type_id:
        description: 第六级类型ID
        type: integer
        example: 1010101010101
      sixth_type_name:
        description: 第六级类型名称
        type: string
        example: "横向裂缝"
        maxLength: 100
      seventh_type_id:
        description: 第七级类型ID
        type: integer
        example: 101010101010101
      seventh_type_name:
        description: 第七级类型名称
        type: string
        example: "细小横向裂缝"
        maxLength: 100
      create_time:
        description: 创建时间戳
        type: integer
        example: 1714567890000
      update_time:
        description: 更新时间戳
        type: integer
        example: 1714578000000
      deadline_time:
        description: 处理截止时间戳
        type: integer
        example: 1714578000000
      warning_time:
        description: 处理预警时间戳
        type: integer
        example: 1714570000000
      occur_time:
        description: 发生时间戳
        type: integer
        example: 1714567800000
      dispatch_time:
        description: 派遣时间戳
        type: integer
        example: 1714568000000
      archive_time:
        description: 归档时间戳
        type: integer
        example: 1714580000000
      cancel_time:
        description: 取消时间戳
        type: integer
        example: 1714579000000
      refresh_time:
        description: 刷新时间戳
        type: integer
        example: 1714572000000
      refresh_start_time:
        description: 刷新开始时间戳
        type: integer
        example: 1714571000000
      check_send_time:
        description: 核查发送时间戳
        type: integer
        example: 1714570000000
      check_reply_time:
        description: 核查回复时间戳
        type: integer
        example: 1714571000000
      func_deadline:
        description: 职能部门截止时间戳
        type: integer
        example: 1714578000000
      func_deal_time:
        description: 职能部门处理时间戳
        type: integer
        example: 1714576000000
      proc_start_time:
        description: 处理开始时间戳
        type: integer
        example: 1714572000000
      custom_deadline:
        description: 自定义截止时间戳
        type: integer
        example: 1714579000000
      patroltask_deadline_time:
        description: 巡查任务截止时间戳
        type: integer
        example: 1714575000000
      deadline_char:
        description: 时限描述
        type: string
        example: "24小时"
        maxLength: 50
      func_limit_char:
        description: 职能部门时限描述
        type: string
        example: "48小时"
        maxLength: 50
      rec_remain_char:
        description: 记录剩余时间描述
        type: string
        example: "3天"
        maxLength: 50
      rec_used_char:
        description: 记录已用时间描述
        type: string
        example: "1天"
        maxLength: 50
      rec_remain:
        description: 记录剩余时间
        type: number
        format: decimal
        example: 3.5
      rec_used:
        description: 记录已用时间
        type: number
        format: decimal
        example: 1.2
      rec_warning:
        description: 记录预警时间
        type: number
        format: decimal
        example: 0.5
      rec_deadline:
        description: 记录时限
        type: number
        format: decimal
        example: 5.0
      func_part_id:
        description: 职能部门ID
        type: integer
        example: 101
      func_part_name:
        description: 职能部门名称
        type: string
        example: "市政工程处"
        maxLength: 200
      func_part_list_id:
        description: 职能部门列表ID
        type: string
        example: "LIST-001"
        maxLength: 100
      func_part_list_name:
        description: 职能部门列表名称
        type: string
        example: "市政处置组"
        maxLength: 200
      specify_func_id:
        description: 指定职能部门ID
        type: integer
        example: 102
      specify_func_name:
        description: 指定职能部门名称
        type: string
        example: "城市管理局"
        maxLength: 200
      specify_competent_func_id:
        description: 指定主管职能部门ID
        type: integer
        example: 103
      specify_competent_func_name:
        description: 指定主管职能部门名称
        type: string
        example: "市城管委"
        maxLength: 200
      first_depart_name:
        description: 一级专业部门
        type: string
        example: "市政工程处"
        maxLength: 100
      second_depart_name:
        description: 二级专业部门
        type: string
        example: "道路养护科"
        maxLength: 100
      district_id:
        description: 区域ID
        type: integer
        example: 1001
      street_id:
        description: 街道ID
        type: integer
        example: 1002
      street_name:
        description: 街道名称
        type: string
        example: "中山路"
        maxLength: 200
      community_id:
        description: 社区ID
        type: integer
        example: 1003
      community_name:
        description: 社区名称
        type: string
        example: "鼓楼社区"
        maxLength: 200
      duty_grid_id:
        description: 责任网格ID
        type: integer
        example: 1004
      duty_grid_name:
        description: 责任网格名称
        type: string
        example: "鼓楼网格01"
        maxLength: 200
      duty_region_id:
        description: 责任区域ID
        type: integer
        example: 1005
      duty_region_name:
        description: 责任区域名称
        type: string
        example: "鼓楼区"
        maxLength: 200
      duty_district_id:
        description: 责任区域ID
        type: integer
        example: 1005
      duty_district_name:
        description: 责任区域名称
        type: string
        example: "鼓楼区"
        maxLength: 200
      duty_street_id:
        description: 责任街道ID
        type: integer
        example: 1006
      duty_street_name:
        description: 责任街道名称
        type: string
        example: "中山路"
        maxLength: 200
      duty_community_id:
        description: 责任社区ID
        type: integer
        example: 1007
      duty_community_name:
        description: 责任社区名称
        type: string
        example: "鼓楼社区"
        maxLength: 200
      law_duty_grid_id:
        description: 法律责任网格ID
        type: integer
        example: 1008
      law_duty_grid_name:
        description: 法律责任网格名称
        type: string
        example: "执法网格01"
        maxLength: 200
      deal_duty_grid_id:
        description: 处置责任网格ID
        type: integer
        example: 1009
      deal_duty_grid_name:
        description: 处置责任网格名称
        type: string
        example: "处置网格01"
        maxLength: 200
      patrol_id:
        description: 巡查员ID
        type: integer
        example: 2001
      patrol_name:
        description: 巡查员名称
        type: string
        example: "张三"
        maxLength: 200
      accepter_id:
        description: 受理人ID
        type: integer
        example: 2002
      accepter_name:
        description: 受理人姓名
        type: string
        example: "李四"
        maxLength: 100
      human_id:
        description: 操作人ID
        type: integer
        example: 2003
      human_name:
        description: 操作人名称
        type: string
        example: "王五"
        maxLength: 255
      reporter_name:
        description: 举报人姓名
        type: string
        example: "张三"
        maxLength: 100
      reporter_contact:
        description: 举报电话
        type: string
        example: "13800138000"
        maxLength: 50
      tell_num:
        description: 联系电话
        type: string
        example: "13800138000"
        maxLength: 50
      read_flag:
        description: 是否已读（0未读，1已读）
        type: integer
        example: 1
      reply_intime:
        description: 是否两小时回复（0无需回复，1待回复，2已回复，3超时，4无需回复已恢复）
        type: integer
        example: 2
      return_visit_flag:
        description: 回访标识（0无需，1待回访，2已回访）
        type: integer
        example: 1
      urgency_level:
        description: 紧急程度（0正常，1紧急）
        type: integer
        example: 1
      urgent_flag:
        description: 紧急标识
        type: integer
        example: 1
      func_forbid_reporter_info_flag:
        description: 是否禁止举报人信息
        type: integer
        example: 0
      public_flag:
        description: 公开标志
        type: integer
        example: 1
      locked_flag:
        description: 锁定标识
        type: integer
        example: 0
      transited_flag:
        description: 转交标识
        type: integer
        example: 1
      split_rec_flag:
        description: 拆分记录标识
        type: integer
        example: 0
      enable_check_msg:
        description: 启用核查消息
        type: integer
        example: 1
      no_return_visit_flag:
        description: 无需回访标识
        type: integer
        example: 0
      common_rec_type_flag:
        description: 通用记录类型标识
        type: string
        example: "COMMON"
        maxLength: 50
      common_rec_attr_flag:
        description: 通用记录属性标识
        type: string
        example: "AUTO"
        maxLength: 50
      send_pub_check_task_flag:
        description: 发送公共核查任务标识
        type: integer
        example: 1
      reply_flag:
        description: 回复标识
        type: string
        example: "REPLIED"
        maxLength: 50
      whistle_flag:
        description: 吹哨标识
        type: string
        example: "WHISTLE"
        maxLength: 50
      repeat_state:
        description: 重复状态
        type: string
        example: "NOT_REPEAT"
        maxLength: 50
      report_state:
        description: 上报状态
        type: string
        example: "SUBMITTED"
        maxLength: 50
      dispose_state:
        description: 处置状态
        type: integer
        example: 1
      pre_dispose_state:
        description: 预处置状态
        type: string
        example: "PENDING"
        maxLength: 50
      undertake_user_name:
        description: 承办人员
        type: string
        example: "张三"
        maxLength: 50
      undertake_phone:
        description: 联系电话
        type: string
        example: "13800138000"
        maxLength: 50
      deal_person_org:
        description: 承办部门
        type: string
        example: "部门名称"
        maxLength: 50
      media_upload_num:
        description: 媒体上传数量
        type: integer
        example: 3
      media_upload_total_num:
        description: 媒体上传总数
        type: integer
        example: 5
      media_upload_state:
        description: 媒体上传状态
        type: string
        example: "SUCCESS"
        maxLength: 50
      media_check_num:
        description: 媒体核查数量
        type: integer
        example: 2
      media_check_total_num:
        description: 媒体核查总数
        type: integer
        example: 5
      media_verify_num:
        description: 媒体核实数量
        type: integer
        example: 1
      media_verify_total_num:
        description: 媒体核实总数
        type: integer
        example: 5
      media_self_deal_num:
        description: 自行处置媒体数量
        type: integer
        example: 1
      media_self_deal_total_num:
        description: 自行处置媒体总数
        type: integer
        example: 3
      media_review_num:
        description: 复核媒体数量
        type: integer
        example: 1
      media_review_total_num:
        description: 复核媒体总数
        type: integer
        example: 3
      report_pic_num:
        description: 上报图片数量
        type: integer
        example: 2
      report_pic_total_num:
        description: 上报图片总数
        type: integer
        example: 3
      report_video_num:
        description: 上报视频数量
        type: integer
        example: 1
      report_video_total_num:
        description: 上报视频总数
        type: integer
        example: 1
      report_wav_num:
        description: 上报音频数量
        type: integer
        example: 0
      report_wav_total_num:
        description: 上报音频总数
        type: integer
        example: 0
      check_pic_num:
        description: 核查图片数量
        type: integer
        example: 2
      check_pic_total_num:
        description: 核查图片总数
        type: integer
        example: 3
      check_video_num:
        description: 核查视频数量
        type: integer
        example: 1
      check_video_total_num:
        description: 核查视频总数
        type: integer
        example: 1
      check_wav_num:
        description: 核查音频数量
        type: integer
        example: 0
      check_wav_total_num:
        description: 核查音频总数
        type: integer
        example: 0
      verify_pic_num:
        description: 核实图片数量
        type: integer
        example: 1
      verify_pic_total_num:
        description: 核实图片总数
        type: integer
        example: 1
      verify_video_num:
        description: 核实视频数量
        type: integer
        example: 0
      verify_video_total_num:
        description: 核实视频总数
        type: integer
        example: 0
      verify_wav_num:
        description: 核实音频数量
        type: integer
        example: 0
      verify_wav_total_num:
        description: 核实音频总数
        type: integer
        example: 0
      self_deal_pic_num:
        description: 自行处置图片数量
        type: integer
        example: 1
      self_deal_pic_total_num:
        description: 自行处置图片总数
        type: integer
        example: 2
      self_deal_video_num:
        description: 自行处置视频数量
        type: integer
        example: 0
      self_deal_video_total_num:
        description: 自行处置视频总数
        type: integer
        example: 1
      self_deal_wav_num:
        description: 自行处置音频数量
        type: integer
        example: 0
      self_deal_wav_total_num:
        description: 自行处置音频总数
        type: integer
        example: 0
      review_pic_num:
        description: 复核图片数量
        type: integer
        example: 1
      review_pic_total_num:
        description: 复核图片总数
        type: integer
        example: 1
      review_video_num:
        description: 复核视频数量
        type: integer
        example: 0
      review_video_total_num:
        description: 复核视频总数
        type: integer
        example: 0
      review_wav_num:
        description: 复核音频数量
        type: integer
        example: 0
      review_wav_total_num:
        description: 复核音频总数
        type: integer
        example: 0
      media_url:
        description: 内部访问URL
        type: string
        example: "http://internal/media/123.jpg"
        maxLength: 512
      mms_pic_path:
        description: 彩信图片路径
        type: string
        example: "/mms/123.jpg"
        maxLength: 500
      media_path:
        description: 服务器存储路径
        type: string
        example: "/storage/media/123.jpg"
        maxLength: 512
      media_type:
        description: 媒体类型
        type: string
        example: "IMAGE"
        maxLength: 50
      media_usage:
        description: 使用场景
        type: string
        example: "上报"
        maxLength: 100
      media_server_name:
        description: 媒体服务器名称
        type: string
        example: "media-server-01"
        maxLength: 100
      media_property:
        description: 媒体属性
        type: integer
        example: 1
      media_uploaded_name:
        description: 上传时的原始文件名
        type: string
        example: "IMG_20240501.jpg"
        maxLength: 255
      media_shot:
        description: 截图标识或路径
        type: string
        example: "/shots/123.jpg"
        maxLength: 255
      media_label_type_id:
        description: 标签类型ID
        type: integer
        example: 101
      media_default_url:
        description: 外部可访问URL
        type: string
        example: "https://external/media/123.jpg"
        maxLength: 512
      display_order:
        description: 显示顺序
        type: integer
        example: 1
      store_type_id:
        description: 存储类型ID
        type: integer
        example: 1
      special_item_image_type:
        description: 特殊图片类型
        type: string
        example: "SIGNATURE"
        maxLength: 100
      height:
        description: 图片高度
        type: integer
        example: 1080
      width:
        description: 图片宽度
        type: integer
        example: 1920
      send_flag:
        description: 发送标志
        type: integer
        example: 1
      gen_thumb:
        description: 是否生成缩略图
        type: integer
        example: 1
      can_delete:
        description: 是否可删除
        type: integer
        example: 1
      delete_flag:
        description: 删除标记
        type: integer
        example: 0
      delete_reason:
        description: 删除原因
        type: string
        example: "数据重复"
        maxLength: 65535
      pos_type:
        description: 位置类型
        type: string
        example: "GPS"
        maxLength: 50
      view_angle:
        description: 视角
        type: string
        example: "FRONT"
        maxLength: 100
      view_image_name:
        description: 视图图片名称
        type: string
        example: "view_123.jpg"
        maxLength: 200
      view_image_x:
        description: 视图图片X坐标
        type: number
        format: decimal
        example: 0.5
      view_image_y:
        description: 视图图片Y坐标
        type: number
        format: decimal
        example: 0.5
      view_pos_x:
        description: 视图位置X坐标
        type: number
        format: decimal
        example: 0.5
      view_pos_y:
        description: 视图位置Y坐标
        type: number
        format: decimal
        example: 0.5
      attach_rec_flag:
        description: 附件记录标识
        type: string
        example: "ATTACH"
        maxLength: 50
      gather_flag:
        description: 汇总标识
        type: string
        example: "GATHERED"
        maxLength: 50
      link_field_value:
        description: 关联字段值
        type: string
        example: "LINK-123"
        maxLength: 500
      link_field_display_value:
        description: 关联字段显示值
        type: string
        example: "关联值显示"
        maxLength: 500
      unique_id:
        description: 唯一标识
        type: string
        example: "UNIQ-20240501-001"
        maxLength: 100
      third_unique_id:
        description: 第三方唯一标识
        type: string
        example: "THIRD-2024-001"
        maxLength: 100
      equal_group_id:
        description: 等值组ID
        type: integer
        example: 1001
      rec_category_id:
        description: 记录类别ID
        type: integer
        example: 101
      dispatch_opinion:
        description: 派遣意见
        type: string
        example: "请尽快处理"
        maxLength: 500
      revise_opinion:
        description: 修订意见
        type: string
        example: "建议补充图片"
        maxLength: 500
      reply_opinion:
        description: 回复意见
        type: string
        example: "已处理完毕"
        maxLength: 500
      new_inst_advise:
        description: 立案建议
        type: string
        example: "建议立案处理"
        maxLength: 500
      new_inst_cond_id:
        description: 立案条件ID
        type: integer
        example: 101
      new_inst_cond_name:
        description: 立案条件
        type: string
        example: "破损面积大于0.5㎡"
        maxLength: 200
      case_closure_condition:
        description: 结案条件
        type: string
        example: "修复完成并验收"
        maxLength: 200
      event_marks:
        description: 事件标记
        type: string
        example: "HIGH_PRIORITY"
        maxLength: 500
      deduction:
        description: 扣减
        type: string
        example: "扣2分"
        maxLength: 100
      event_property_id:
        description: 事件属性ID
        type: integer
        example: 101
      event_property_name:
        description: 事件属性名称
        type: string
        example: "公共设施"
        maxLength: 200
      city_village_flag:
        description: 城乡标识
        type: string
        example: "CITY"
        maxLength: 50
      force_handle_flag:
        description: 强制处理标识
        type: string
        example: "FORCE"
        maxLength: 50
      auto_check_count:
        description: 自动核查次数
        type: integer
        example: 2
      deal_evaluate_ids:
        description: 处置评价ID列表
        type: string
        example: "101,102,103"
        maxLength: 200
      newinst_no_transit:
        description: 立案不转交
        type: string
        example: "NO_TRANSIT"
        maxLength: 50
      super_rec_id:
        description: 上级记录ID
        type: integer
        example: 2001
      site_num:
        description: 站点编号
        type: string
        example: "SITE-001"
        maxLength: 50
      difficult_type_id:
        description: 困难类型ID
        type: integer
        example: 101
      event_district_grade_id:
        description: 事件区域等级ID
        type: integer
        example: 101
      event_district_grade_name:
        description: 事件区域等级名称
        type: string
        example: "重点区域"
        maxLength: 100
      cus_grid_code:
        description: 自定义网格编码
        type: string
        example: "CUST-GRID-001"
        maxLength: 100
      site_id:
        description: 站点ID
        type: integer
        example: 101
      shop_id:
        description: 商铺ID
        type: integer
        example: 101
      shop_name:
        description: 商铺名称
        type: string
        example: "幸福便利店"
        maxLength: 200
      spec_type_id:
        description: 特殊类型ID
        type: integer
        example: 101
      spec_type_name:
        description: 特殊类型名称
        type: string
        example: "紧急事件"
        maxLength: 100
      proc_account_state_id:
        description: 处理账户状态ID
        type: integer
        example: 1
      check_type_id:
        description: 核查类型ID
        type: integer
        example: 1
      rec_analysis_type_id:
        description: 记录分析类型ID
        type: integer
        example: 1
      proc_time_state_id:
        description: 处理流程状态ID
        type: integer
        example: 1
      proc_ard_state_id:
        description: 处理仲裁状态ID
        type: integer
        example: 1
      proc_enq_state_id:
        description: 处理询问状态ID
        type: integer
        example: 1
      proc_sup_state_id:
        description: 处理监督状态ID
        type: integer
        example: 1
      func_time_state_id:
        description: 职能部门时间状态ID
        type: integer
        example: 1
      check_msg_state_id:
        description: 核查消息状态ID
        type: integer
        example: 1
      verify_msg_state_id:
        description: 核实消息状态ID
        type: integer
        example: 1
      regather_msg_state_id:
        description: 重新采集消息状态ID
        type: integer
        example: 1
      supervision_check_state_id:
        description: 监督核查状态ID
        type: integer
        example: 1
      self_deal_msg_state_id:
        description: 自行处置消息状态ID
        type: integer
        example: 1
      review_msg_state_id:
        description: 复核消息状态ID
        type: integer
        example: 1
      proc_press_state_id:
        description: 处理压力状态ID
        type: integer
        example: 1
      hot_area:
        description: 热点区域
        type: string
        example: "市中心"
        maxLength: 100
      cg_area:
        description: 城管区域
        type: string
        example: "鼓楼区"
        maxLength: 100
      hw_area:
        description: 环卫区域
        type: string
        example: "鼓楼区"
        maxLength: 100
      sz_area:
        description: 市政区域
        type: string
        example: "鼓楼区"
        maxLength: 100
      device_guid:
        description: 设备GUID
        type: string
        example: "A1B2-C3D4-E5F6"
        maxLength: 100
      jx_id:
        description: 警讯ID
        type: integer
        example: 1001
      jx_jxmc:
        description: 警讯名称
        type: string
        example: "道路塌陷警讯"
        maxLength: 200
      jx_design_type:
        description: 警讯设计类型
        type: string
        example: "自动触发"
        maxLength: 100
      report_time_segment_id:
        description: 上报时段ID
        type: integer
        example: 101
      archive_cond_id:
        description: 归档条件ID
        type: integer
        example: 101
      archive_cond:
        description: 归档条件
        type: string
        example: "处理完成"
        maxLength: 100
      archive_type_id:
        description: 归档类型ID
        type: integer
        example: 101
      road_type_id:
        description: 道路类型ID
        type: integer
        example: 101
      road_name:
        description: 道路名称
        type: string
        example: "中山路"
        maxLength: 200
      road_id:
        description: 道路ID
        type: integer
        example: 101
      road_type_name:
        description: 道路类型名称
        type: string
        example: "主干道"
        maxLength: 100
      area_type_id:
        description: 区域类型ID
        type: integer
        example: 101
      duty_grid_type_id:
        description: 责任网格类型ID
        type: integer
        example: 101
      deal_duty_grid_type_id:
        description: 处置责任网格类型ID
        type: integer
        example: 101
      time_area_id:
        description: 时段ID
        type: integer
        example: 101
      time_area_name:
        description: 时段名称
        type: string
        example: "早高峰"
        maxLength: 100
      card_num:
        description: 证件号码
        type: string
        example: "110101199001012345"
        maxLength: 100
      cell_id:
        description: 单元格ID
        type: integer
        example: 101
      cell_name:
        description: 单元格名称
        type: string
        example: "A01单元"
        maxLength: 200
      damage_grade_id:
        description: 损毁等级ID
        type: integer
        example: 101
      damage_grade_name:
        description: 损毁等级名称
        type: string
        example: "严重"
        maxLength: 100
      event_grade_id:
        description: 事件等级ID
        type: integer
        example: 101
      event_grade_name:
        description: 事件等级名称
        type: string
        example: "重大"
        maxLength: 100
      event_level_id:
        description: 事件级别ID
        type: integer
        example: 101
      event_level_name:
        description: 事件级别名称
        type: string
        example: "一级"
        maxLength: 100
      event_district_id:
        description: 事件区域ID
        type: integer
        example: 101
      event_district_name:
        description: 事件区域名称
        type: string
        example: "鼓楼区"
        maxLength: 100
      display_property:
        description: 显示属性
        type: string
        example: "高亮显示"
        maxLength: 200
      display_style_id:
        description: 显示样式ID
        type: integer
        example: 1
      refresh_flag:
        description: 刷新标识
        type: integer
        example: 1
      video_device_id:
        description: 视频设备ID
        type: integer
        example: 101
      video_param:
        description: 视频参数
        type: string
        example: "1080p,30fps"
        maxLength: 500
      patrol_deal_flag:
        description: 巡查处置标识
        type: integer
        example: 1
      send_from_type:
        description: 发送来源类型
        type: string
        example: "APP"
        maxLength: 50
      reply_intime_deadline:
        description: 两小时回复截止时间戳
        type: integer
        example: 1714568000000
      accept_status:
        description: 受理状态
        type: string
        example: "ACCEPTED"
        maxLength: 50
      squadron_id:
        description: 中队ID
        type: integer
        example: 101
      squadron_name:
        description: 中队名称
        type: string
        example: "第一中队"
        maxLength: 200
      property_company_id:
        description: 物业公司ID
        type: integer
        example: 101
      act_record_id:
        description: 操作记录ID
        type: integer
        example: 1001
      main_rec_id:
        description: 主记录ID
        type: integer
        example: 2001
      func_custom_limit:
        description: 职能部门自定义时限
        type: string
        example: "72小时"
        maxLength: 50
      created_at:
        description: 创建时间，ISO格式的日期时间字符串
        type: string
        format: date-time
        example: "2024-01-15 10:30:00"
        readOnly: true
      created_by:
        description: 创建者用户名
        type: string
        example: "admin"
        readOnly: true
      updated_at:
        description: 修改时间，ISO格式的日期时间字符串
        type: string
        format: date-time
        example: "2024-01-16 14:25:00"
        readOnly: true
      updated_by:
        description: 修改者用户名
        type: string
        example: "editor"
        readOnly: true
    """

    @classmethod
    async def create(cls, **kwargs):
        """
        创建新的任务表单数据。

        业务流程：
            1. 使用 HumanTaskFormDatumForm 验证表单数据完整性
            2. 检查任务是否已存在（根据 rec_id）
            3. 创建新任务对象
            4. 设置创建者和更新者为当前用户
            5. 保存到数据库
            6. 返回创建的任务对象

        :param kwargs: 任务参数字典
        :return: 新建任务对象
        :rtype: DcmTaskFormDatum
        :raises AssertionError: 当任务已存在时抛出
        :raises ValidationError: 当表单验证失败时抛出
        """
        # 处理字符串字段去除空格
        for _k, _v in kwargs.items():
            if isinstance(_v, str):
                kwargs[_k] = _v.strip()

        _task_form = DcmTaskFormDatumForm(formdata=kwargs)
        _task_form.validate_form()

        # 检查是否存在同记录ID的任务
        _task: cls = await cls.is_exist(_task_form.rec_id.data)
        assert _task is None, "记录ID已存在，不能重复创建。"

        # 创建任务对象
        _task = cls().copy_from_dict(_task_form.data, skip_none=True).before_save()
        await _task.async_save()
        return _task

    @classmethod
    async def delete(cls, task_id: Union[str, int]):
        """
        删除任务表单数据。

        业务流程：
            1. 根据ID查找任务
            2. 验证任务存在性
            3. 执行删除操作

        :param task_id: 要删除的任务ID
        :return: 删除的任务对象
        :rtype: DcmTaskFormDatum
        :raises AssertionError: 当任务不存在时抛出
        """
        _task: cls = await cls.async_find_by_id(task_id)
        assert _task, f"根据 ID {task_id} 未找到任务。"

        # 执行删除
        _del_query = delete(cls).where(cls.id == _task.id)
        _del_count = (await cls.raw_execute(_del_query)).rowcount
        echo_log(f'已删除任务表单数据（记录ID：{_task.rec_id}，ID：{_task.id}）.')
        return _task

    @classmethod
    async def modify(cls, task_id: Union[str, int], **kwargs):
        """
        修改已有任务表单数据。

        业务流程：
            1. 将 task_id 添加到参数中
            2. 处理字符串字段去除首尾空格
            3. 使用 HumanTaskFormDatumForm 验证表单数据
            4. 检查是否有其他任务使用了相同的 rec_id
            5. 查询原任务对象
            6. 验证任务存在性
            7. 更新字段并设置更新者
            8. 保存到数据库
            9. 返回更新后的任务对象

        :param task_id: 要修改的任务ID
        :param kwargs: 需要更新的字段
        :return: 修改后的任务对象
        :rtype: DcmTaskFormDatum
        :raises AssertionError: 当任务不存在或信息重复时抛出
        :raises ValidationError: 当表单验证失败时抛出
        """
        # 处理字符串字段去除空格
        for _k, _v in kwargs.items():
            if isinstance(_v, str):
                kwargs[_k] = _v.strip()

        # 表单验证
        _task_form = DcmTaskFormDatumForm(formdata=kwargs)
        _task_form.validate_form()

        # 检查是否与其他任务重复（排除自身）
        _other = await cls.exist_other(task_id, _task_form.rec_id.data)
        assert _other is None, "记录ID已存在，不能重复修改。"

        # 查询原任务
        _task: cls = await cls.async_find_by_id(task_id)
        assert _task, f'查无此任务信息。'

        # 更新字段
        _task.copy_from_dict(_task_form.data, skip_none=True).before_save()
        await _task.async_save()
        return _task

    @classmethod
    async def create_batch(cls, data_df: pd.DataFrame):
        """
        批量创建新任务表单数据（传入数据应为全新记录，无需校验是否存在）。

        :param data_df: 包含任务数据的 DataFrame，字段需与模型属性匹配（如 rec_id, task_num 等）
        :return: 成功创建的任务数量
        :rtype: int
        """
        if data_df.empty:
            return 0

        # 一次性转为字典列表（C 层高效）
        records = data_df.to_dict('records')

        # 用列表推导式构造对象
        tasks = [cls().copy_from_dict(record, skip_none=True).before_save() for record in records]

        # 批量插入
        session = cls.get_aio_session()
        try:
            session.add_all(tasks)
            await session.commit()
        except Exception as e:
            await session.rollback()
            raise e
        finally:
            await session.close()
        echo_log(f"批量创建成功：创建 {len(tasks)} 条新任务表单数据。")
        return len(tasks)

    @classmethod
    async def modify_batch(cls, data_df: pd.DataFrame):
        """
        批量修改已有任务表单数据。

        :param data_df: 包含任务数据的 DataFrame
        :return: 成功更新的任务数量
        :rtype: int
        """
        if data_df.empty:
            return 0

        # 必须包含 id 列
        if 'id' not in data_df.columns:
            echo_log(f"错误：modify_batch 要求输入数据必须包含 '{cls.id.key}' 列（主键）")
            return 0

        # 转换为字典列表
        update_data = data_df.to_dict('records')

        # 使用 bulk_update_mappings
        session = cls.get_aio_session()
        try:
            await session.run_sync(
                lambda sync_session: sync_session.bulk_update_mappings(cls, update_data)
            )
            await session.commit()
            updated_count = len(update_data)
        except Exception as e:
            await session.rollback()
            raise e
        finally:
            await session.close()

        echo_log(f"批量修改成功：更新 {updated_count} 条任务表单数据。")
        return updated_count

    @classmethod
    async def save_batch(cls, data_df: pd.DataFrame):
        """
        批量保存数据，自动处理新建和更新。

        :param data_df: 要保存的数据框架
        :return: 新建和更新的数量
        """
        # 筛选数据状态
        _exists_df, _latest_df = await DcmTaskFormDatum.exists_rec_id(data_df)
        # 保存到数据库
        _created_count = await DcmTaskFormDatum.create_batch(_latest_df)
        _updated_count = await DcmTaskFormDatum.modify_batch(_exists_df)
        return _created_count, _updated_count