{"text_format":"2","workbook":"xlsx","n_sheets":3,"sheets":["同步数据","删除表涉及问题","Sheet3"],"not_rendered":{"charts":0,"images":0,"macros":0,"external_links":0,"defined_names":1,"comments":0,"pivot_tables":0},"unopened":[],"bounds":{"document_bytes":16777216,"sheet_cells":100000,"run_cost":"one","rows_first":2000,"rows_last":500,"rows_between":2000,"halvings":0,"cell_chars":16384,"cell_head_chars":4096},"cells_cut":0,"cells_raw":0,"read":"whole","date_system":"1900"}

{"sheet":"同步数据","index":0,"n_rows":104,"n_cols":10,"rows_kept":104,"cut":false,"hidden":false,"merged":[[0,0,0,5],[88,7,99,7]]}
["大数据平台同步策略"]
["同步频率","同步名称","同步策略","涉及主表表名","查询语句(若有)","备注(和省标同步修改)"]
["每天凌晨0点执行","视频通道","增量同步","gs_jc_spjk","全表查询","主表id不一致及新增 修改完成"]
["每天凌晨0点执行","视频通道","增量同步","rq_jc_spjk","增量查询","修改完成"]
["每天凌晨0点执行","视频通道","增量同步","dl_jc_spjk","增量查询","修改完成"]
["每天凌晨0点执行","视频通道","增量同步","ps_jc_spjk-->NL_JC_SPJK","增量查询","修改完成"]
["每天凌晨0点执行","视频通道","增量同步","ql_jc_spjk","增量查询","修改完成"]
["每天凌晨0点执行","视频通道","增量同步","sg_jc_spjk","增量查询","修改完成"]
["每天凌晨0点执行","风险","全量同步","rq_jg_fxpg","select bsm,\n        xzqhdm,\n        ssqy,\n        zrdw,\n        pgdy,\n        glgdbh,\n        pgdygdcd,\n        fxms,\n        fxdj,\n        gkzt,        \n        bz,\n        yskzjbz,\n        sjtbzt,\n        tbsj,\n        gxid,\n        fxlx,\n        pgsj,\n        pgdw,\n        dz,\n        pcbh,\n        pgdymc,\n        pgdywz,\n        pgdywybs,\n        knxdj,\n        hgdj,\n        gkcs,\n        kjxx\n        from ztfbk_sjg.rq_jg_fxpg\n        where 1=1 and fxdj is not null and xzqhdm is not null","修改完成"]
["每天凌晨0点执行","风险","全量同步","gs_jg_gwfxhczxx"," select bsm,\n        xzqhdm,\n        fxbh,\n        fxdj,\n        xxdz,\n        pgdw,\n        pgsj,\n        gkzt,\n        gkcs,\n        fxms,\n        bz,\n        qsdw,\n        sjcgpcbh,\n        pgdymc,\n        pgdywybs,\n        glgdbh,\n        pgdywz,\n        pgdygdcd,\n        knxdj,\n        hgdj,\n        kjxx\n        from ztfbk_sjg.gs_jg_gwfxhczxx\n        where 1=1 and fxdj is not null and xzqhdm is not null","修改完成"]
["每天凌晨0点执行","风险","全量同步","ps_jg_ysfxgk"," select bsm,\n        xzqhdm,\n        nf,\n        fxmc,\n        fxdj,\n        fxly,\n        fxnr,\n        wz,\n        mj,\n        gkcs,\n        sfgk,\n        gkzt,\n        yskzjbz,\n        sjtbzt,\n        tbsj,\n        kjxx\n        from ztfbk_sjg.ps_jg_ysfxgk\n        where 1=1 and fxdj is not null and xzqhdm is not null","修改完成"]
["每天凌晨0点执行","风险","全量同步","ps_js_yld-->NL_JG_YLD"," select bsm, xzqhdm, mc, fxdj, dz, dcjyl, dcjylcxsj, dczdnlss, dczdysmj, dcnlcxsj, nlzyyy, dcrq, qyqkms, tbdw,\n        tbrq, bz, yskzjbz, sjtbzt, tbsj, kjxx\n        from ztfbk_sjg.ps_js_yld\n        where 1=1 and fxdj is not null and xzqhdm is not null"," 改成NL_JG_YLD表,修改完成"]
["每天凌晨0点执行","风险","全量同步","dl_jc_dltxfx--> dl_jg_dltxfx","select bsm,\n        xzqhdm,\n        gcmc,\n        jcdw,\n        pgdybh,\n        pgdylc,\n        pgfz,\n        dlmc,\n        dlqd,\n        dlzd,\n        dldj,\n        fxdj,\n        bz,\n        yskzjbz,\n        tbsj,\n        pgsj,\n        fj,\n        kjxx\n        from ztfbk_sjg.dl_jc_dltxfx\n        where  fxdj is not null and xzqhdm is not null","修改完成"]
["每天凌晨0点执行","风险","全量同步","ql_jg_fxpg"," select bsm,\n        xzqhdm,\n        qlmc,\n        qlbh,\n        pgsj,\n        fxmc,\n        fxdj,\n        fxms,\n        gkzt,\n        bz,\n        yskzjbz,\n        tbsj,\n        kjxx\n        from ztfbk_sjg.ql_jg_fxpg\n        where  fxdj is not null and xzqhdm is not null","修改完成"]
["每天凌晨0点执行","突发事件","全量同步","sg_jg_dsfsgphsj-->SG_JG_PHSJ","SELECT sg_jg_phczjg.czfzr,sg_jg_phczjg.czfzrlxdh,sg_jg_phczjg.czjs yhczjs,sg_jg_phczjg.czbg yhczbg,sg_jg_phczjg.czzt yhczzt,sg_jg_phczjg.czwcsj AS czwcsj2,sg_jg_phczjg.xczp yhxczp,sg_jg_phczjg.czdw yhczdw,sg_jg_phsj.*FROM ztfbk_sjg.sg_jg_phsj sg_jg_phsj LEFT JOIN ztfbk_sjg.sg_jg_phczjg sg_jg_phczjg ON sg_jg_phczjg.dsfphsjbsm=sg_jg_phsj.yskzjbz WHERE sg_jg_phsj.xzqhdm IS NOT NULL","修改完成"]
["每天凌晨0点执行","突发事件","全量同步","rq_jg_tfsjqx"," select bsm,\n        '0' as scene,\n        xzqhdm,\n        sjmc,\n        sjsm,\n        dz,\n        gljcss,\n        xyjb,\n        xczp,\n        qxnr,\n        cljg,\n        clrq,\n        clry,\n        cldw,\n        fj,\n        bz,\n        tbsj\n        from ztfbk_sjg.rq_jg_tfsjqx\n        where 1=1 and xyjb is not null and xzqhdm is not null"," "]
["每天凌晨0点执行","突发事件","全量同步","gs_jg_tfsjqx"," select\n        '2' as scene,\n        *\n        from ztfbk_sjg.gs_jg_tfsjqx\n        where 1=1 and xyjb is not null and xzqhdm is not null"," "]
["每天凌晨0点执行","突发事件","全量同步","ps_jg_tfsjqx"," select\n        '1' as scene,\n        *\n        from ztfbk_sjg.ps_jg_tfsjqx\n        where 1=1 and xyjb is not null and xzqhdm is not null"," "]
["每天凌晨0点执行","燃气设施隐患","全量同步","rq_jc_rqssyh-->rq_jg_rqssyh"," SELECT\n        rq_jg_zgjl.zgjg,\n        rq_jg_zgjl.zgrq,\n        rq_jg_rqssyh.bsm,\n        '0' AS scene,\n        rq_jg_rqssyh.xzqhdm,\n        rq_jg_rqssyh.yhms,\n        rq_jg_rqssyh.yhlx,\n        CASE\n        rq_jg_rqssyh.yhdj\n        WHEN 'A' THEN\n        '2'\n        WHEN 'B' THEN\n        '1' ELSE NULL\n        END AS yhdj,\n        rq_jg_rqssyh.yhddz,\n        rq_jg_rqssyh.qsdw ssjg,\n        CASE\n        rq_jg_rqssyh.zgzt\n        WHEN 1 THEN\n        0\n        WHEN 2 THEN\n        1\n        WHEN 3 THEN\n        2 ELSE NULL\n        END AS zgzt,\n        rq_jg_rqssyh.sbry sbr,\n        rq_jg_rqssyh.sbrdw,\n        rq_jg_rqssyh.sbrq sbsj,\n        rq_jg_rqssyh.zgfzr,\n        rq_jg_rqssyh.zgfzrlxdh,\n        rq_jg_rqssyh.bz,\n        rq_jg_rqssyh.yskzjbz,\n        rq_jg_rqssyh.sjtbzt,\n        rq_jg_rqssyh.tbsj,\n        rq_jg_rqssyh.sjly,\n        rq_jg_rqssyh.xjjlbsm,\n        rq_jg_rqssyh.zgjlbsm,\n        rq_jg_rqssyh.yhtp as yhtpStr,\n        rq_jg_rqssyh.kjxx\n        FROM\n        ztfbk_sjg.rq_jg_rqssyh rq_jg_rqssyh\n        LEFT JOIN ztfbk_sjg.rq_jg_zgjl rq_jg_zgjl ON rq_jg_rqssyh.zgjlbsm = rq_jg_zgjl.yskzjbz\n        WHERE\n        1 = 1\n        AND rq_jg_rqssyh.yhdj IS NOT NULL\n        AND rq_jg_rqssyh.xzqhdm IS NOT NULL\n        <if test=\"lastSyncTime != null\">\n            and rq_jg_rqssyh.tbsj &gt; #{lastSyncTime,jdbcType=TIMESTAMP}\n        </if>","表名修改,表字段已修改"]
["每天凌晨0点执行","道路塌陷隐患","全量同步","dl_jc_dltxyh-->dl_jg_dltxyh","select * from  ztfbk_sjg.dl_jg_dltxyh where 1=1 and fxdj is not null and xzqhdm is not null order by tbsj","修改完成"]
["每天凌晨0点执行","燃气场站","全量同步","rq_js_cz-->RQ_CZ","select * from  ztfbk_sjg.rq_cz order by tbsj","多字段删除,涉及后管展示(刘琳琳确认后管不影响),已修改"]
["每天凌晨0点执行","排水排口","全量同步","ps_js_pk-->PS_PK","select * from ztfbk_sjg.ps_pk order by tbsj"," 已修改"]
["每天凌晨0点执行","排水场站","全量同步","ps_js_cz-->PS_CZ","select * from  ztfbk_sjg.ps_cz order by tbsj"," 已修改"]
["每天凌晨0点执行","调蓄设施","全量同步","ps_js_txss","select * from  ztfbk_sjg.ps_js_txss order by tbsj"," 已修改"]
["每天凌晨0点执行","供水厂站","全量同步","gs_js_cz","select * from ztfbk_sjg.gs_js_cz"," 不做同步,数据保留"]
["每天凌晨0点执行","主要河道属性","全量同步","ps_js_zyhd","全表查询"," 已修改"]
["每天凌晨0点执行","行泄通道","全量同步","ps_js_xxtd","全表查询"," 已修改"]
["每天凌晨0点执行","重点排水户","全量同步","ps_js_psh","全表查询"," 已修改"]
["每天凌晨0点执行","老旧管网改造落实情况","全量同步","gs_jg_ljgwgzlsqk","全表查询"," 前置库表结构还没有修改"]
["每天凌晨0点执行","桥梁属性","全量同步","ql_js_ql-->ql_ql","全表查询"," 已修改"]
["每天凌晨0点执行","城市道路属性","全量同步","dl_js_csdl-->DL_CSDL","全表查询"," 已修改"]
["每天凌晨0点执行","第三方施工项目信息","全量同步","sg_jg_dsfsgxmxx-->SG_JG_XMXX","全表查询"," 已修改"]
["---","燃气用户属性\n结构表","不用补","RQ_JS_RQYH--->RQ_JG_RQYH","全表查询","已确认"]
["每天凌晨0点执行","截流设施","全量同步","ps_js_jlss","select * from  ztfbk_sjg.ps_js_jlss order by tbsj"," 已修改"]
["每天凌晨0点执行","监测点","全量同步","gjk_wlw_wlw_rq_jcd","select bsm as id,bsm,xzqhdm  as area,dwmc as name, null as jcwz, case gc when '' then null else gc::decimal end as gc,gcjz as gcjz ,null as \" +\n            \"remark,kjxx as kjxx ,1 as  deleted,'0' as scene,ssmc as ssmc,ssbm as ssbm,\\n\" +\n            \"now() as created_at,null as created_by,now() as updated_at,null as updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_rq_jcd","已确认"]
["每天凌晨0点执行","监测点","全量同步","gjk_wlw_wlw_gs_jcd","select bsm as id,bsm,xzqhdm  as area,dwmc as name, null as jcwz, case gc when '' then null else gc::decimal end as gc,gcjz as gcjz ,null as \" +\n            \"remark,kjxx as kjxx ,1 as  deleted,'2' as scene,ssmc as ssmc,ssbm as ssbm,\\n\" +\n            \"now() as created_at,null as created_by,now() as updated_at,null as updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_gs_jcd"," "]
["每天凌晨0点执行","监测点","全量同步","gjk_wlw_wlw_ps_jcd","select bsm as id,bsm,xzqhdm  as area,dwmc as name, null as jcwz, case gc when '' then null else gc::decimal end as gc,gcjz as gcjz ,null as \" +\n            \"remark,kjxx as kjxx ,1 as  deleted,'1' as scene,ssmc as ssmc,ssbm as ssbm,\\n\" +\n            \"now() as created_at,null as created_by,now()  as updated_at,null as updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_ps_jcd"," "]
["每天凌晨0点执行","监测点","全量同步","gjk_wlw_wlw_sg_jcd","select bsm as id,bsm,xzqhdm  as area,dwmc as name, null as jcwz, case gc when '' then null else gc::decimal end as gc,gcjz as gcjz ,null as \" +\n            \"remark,kjxx as kjxx ,1 as  deleted,'5' as scene,ssmc as ssmc,ssbm as ssbm,\\n\" +\n            \"now() as created_at,null as created_by,now() as updated_at,null as updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_ql_jcd"," "]
["每天凌晨0点执行","监测点","全量同步","gjk_wlw_wlw_sg_jcd","select bsm as id,bsm,xzqhdm  as area,dwmc as name, null as jcwz, case gc when '' then null else gc::decimal end as gc,gcjz as gcjz ,null as \" +\n            \"remark,kjxx as kjxx ,1 as  deleted,'3' as scene,ssmc as ssmc,ssbm as ssbm,\\n\" +\n            \"now() as created_at,null as created_by,now() as updated_at,null as updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_sg_jcd"," "]
["每天凌晨0点执行","监测设备","全量同步","sg_jc_jcsb,sg_js_jcd-->SG_JC_JCD","SELECT A\n .bsm AS ID,\n A.bsm AS alarm_threshold,\n A.bsm,\n A.dwbsm,\n A.sblx AS equipment_type,\n A.sbmc AS equipment_name,\n A.sbxh AS equipment_model,\n A.jczb AS monitoring_index,\n A.cjpl AS collection_frequency,\n A.scpl AS upload_frequency,\n A.sbzt :: TEXT AS equipment_status,\n A.csmc AS manufacturer_name,\n A.xdgd AS relative_altitude,\n A.azrq AS instal_time,\n A.gdfs AS power_supply_mode,\n A.azwhdw AS instal_mainten_unit,\n b.jcwz AS POSITION,\n b.xzqhdm AS area,\n A.bz AS remark,\n NULL AS geom_data,\n NULL AS DEFINED,\n 1 AS deleted,\n now( ) AS created_at,\n NULL AS created_by,\n now( ) AS updated_at,\n NULL AS updated_by \nFROM\n ztfbk_sjg.sg_jc_jcsb\n A LEFT JOIN ztfbk_sjg.sg_jc_jcd b ON A.dwbsm = b.bsm"," 已修改"]
["每天凌晨0点执行","监测设备","全量同步","gjk_wlw_wlw_rq_jcsb,gjk_wlw_wlw_rq_jcd","select a.bsm        as id,\n               a.srcid as alarm_threshold,\n               a.bsm,\n               a.dwbsm,\n               a.sblx       as equipment_type,\n               a.sbmc       as equipment_name,\n               a.sbxh       as equipment_model,\n               a.jczb       as monitoring_index,\n               a.cjpl       as collection_frequency,\n               a.scpl       as upload_frequency,\n               a.sbzt::text as equipment_status,\n               a.csmc       as manufacturer_name,\n               case a.xdgd when '' then null else a.xdgd::decimal end as relative_altitude,\n               null       as instal_time,\n               a.gdfs       as power_supply_mode,\n               a.azwhdw     as instal_mainten_unit,\n               null         as position,\n               b.xzqhdm     as area,\n               a.bz         as remark,\n               null         as geom_data,\n               null         as defined,\n               1            as deleted,\n               now()        as created_at,\n               null         as created_by,\n               now()        as updated_at,\n               null         as updated_by\n        from ${tableName} a\n                 left join ${jcdTableName} b on a.dwbsm = b.bsm"," "]
["每天凌晨0点执行","监测设备","全量同步","gjk_wlw_wlw_gs_jcsb,gjk_wlw_wlw_gs_jcd","select a.bsm        as id,\n               a.srcid as alarm_threshold,\n               a.bsm,\n               a.dwbsm,\n               a.sblx       as equipment_type,\n               a.sbmc       as equipment_name,\n               a.sbxh       as equipment_model,\n               a.jczb       as monitoring_index,\n               a.cjpl       as collection_frequency,\n               a.scpl       as upload_frequency,\n               a.sbzt::text as equipment_status,\n               a.csmc       as manufacturer_name,\n               case a.xdgd when '' then null else a.xdgd::decimal end as relative_altitude,\n               null       as instal_time,\n               a.gdfs       as power_supply_mode,\n               a.azwhdw     as instal_mainten_unit,\n               null         as position,\n               b.xzqhdm     as area,\n               a.bz         as remark,\n               null         as geom_data,\n               null         as defined,\n               1            as deleted,\n               now()        as created_at,\n               null         as created_by,\n               now()        as updated_at,\n               null         as updated_by\n        from ${tableName} a\n                 left join ${jcdTableName} b on a.dwbsm = b.bsm"," "]
["每天凌晨0点执行","监测设备","全量同步","gjk_wlw_wlw_ps_jcsb,gjk_wlw_wlw_ps_jcd","select a.bsm        as id,\n               a.srcid as alarm_threshold,\n               a.bsm,\n               a.dwbsm,\n               a.sblx       as equipment_type,\n               a.sbmc       as equipment_name,\n               a.sbxh       as equipment_model,\n               a.jczb       as monitoring_index,\n               a.cjpl       as collection_frequency,\n               a.scpl       as upload_frequency,\n               a.sbzt::text as equipment_status,\n               a.csmc       as manufacturer_name,\n               case a.xdgd when '' then null else a.xdgd::decimal end as relative_altitude,\n               null       as instal_time,\n               a.gdfs       as power_supply_mode,\n               a.azwhdw     as instal_mainten_unit,\n               null         as position,\n               b.xzqhdm     as area,\n               a.bz         as remark,\n               null         as geom_data,\n               null         as defined,\n               1            as deleted,\n               now()        as created_at,\n               null         as created_by,\n               now()        as updated_at,\n               null         as updated_by\n        from ${tableName} a\n                 left join ${jcdTableName} b on a.dwbsm = b.bsm"," "]
["每天凌晨0点执行","监测设备","全量同步","gjk_wlw_wlw_ql_jcsb,gjk_wlw_wlw_ql_jcd","select a.bsm        as id,\n               a.srcid as alarm_threshold,\n               a.bsm,\n               a.dwbsm,\n               a.sblx       as equipment_type,\n               a.sbmc       as equipment_name,\n               a.sbxh       as equipment_model,\n               a.jczb       as monitoring_index,\n               a.cjpl       as collection_frequency,\n               a.scpl       as upload_frequency,\n               a.sbzt::text as equipment_status,\n               a.csmc       as manufacturer_name,\n               case a.xdgd when '' then null else a.xdgd::decimal end as relative_altitude,\n               null       as instal_time,\n               a.gdfs       as power_supply_mode,\n               a.azwhdw     as instal_mainten_unit,\n               null         as position,\n               b.xzqhdm     as area,\n               a.bz         as remark,\n               null         as geom_data,\n               null         as defined,\n               1            as deleted,\n               now()        as created_at,\n               null         as created_by,\n               now()        as updated_at,\n               null         as updated_by\n        from ${tableName} a\n                 left join ${jcdTableName} b on a.dwbsm = b.bsm"," "]
["每天凌晨0点执行","监测点关系","全量同步","rq_js_cz,gjk_wlw_wlw_rq_jcsb","select a.bsm as id ,b.bsm as point_bsm,1 as rel_type,a.bsm as rel_bsm,\\n\" +\n            \"1 as deleted , now() as create_at,null created_by,now() as update_at,null updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_rq_jcsb  a ,ztfbk_sjg.gjk_wlw_wlw_rq_jcd b\\n\" +\n            \"where a.dwbsm  = b.bsm\\n\" +\n            \"union all \\n\" +\n            \"select a.bsm as id ,b.bsm as point_bsm,0 as rel_type,a.bsm as rel_bsm,\\n\" +\n            \"1 as deleted , now() as create_at,null created_by,now() as update_at,null updated_by\\n\" +\n            \"from ztfbk_sjg.rq_js_cz  a ,ztfbk_sjg.gjk_wlw_wlw_rq_jcd b\\n\" +\n            \"where a.yskzjbz  = b.ssbm"]
["每天凌晨0点执行","监测点关系","全量同步","ps_js_txss,gjk_wlw_wlw_ps_jcsb","SELECT A.bsm AS ID,b.bsm AS point_bsm,1 AS rel_type,A.bsm AS rel_bsm,1 AS deleted,now() AS create_at,NULL created_by,now() AS update_at,NULL updated_by FROM ztfbk_sjg.gjk_wlw_wlw_ps_jcsb A,ztfbk_sjg.gjk_wlw_wlw_ps_jcd b WHERE A.dwbsm=b.bsm UNION ALL SELECT A.bsm AS ID,b.bsm AS point_bsm,0 AS rel_type,A.bsm AS rel_bsm,1 AS deleted,now() AS create_at,NULL created_by,now() AS update_at,NULL updated_by FROM ztfbk_sjg.ps_cz A,ztfbk_sjg.gjk_wlw_wlw_ps_jcd b WHERE A.yskzjbz=b.ssbm UNION ALL SELECT A.bsm AS ID,b.bsm AS point_bsm,0 AS rel_type,A.bsm AS rel_bsm,1 AS deleted,now() AS create_at,NULL created_by,now() AS update_at,NULL updated_by FROM ztfbk_sjg.ps_js_txss A,ztfbk_sjg.gjk_wlw_wlw_ps_jcd b WHERE A.yskzjbz=b.ssbm"," ps_cz,ps_js_txss已经修改"]
["每天凌晨0点执行","监测点关系","全量同步","gjk_wlw_wlw_gs_jcsb,gs_js_cz","select a.bsm as id ,b.bsm as point_bsm,1 as rel_type,a.bsm as rel_bsm,\\n\" +\n            \"1 as deleted , now() as create_at,null created_by,now() as update_at,null updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_gs_jcsb  a ,ztfbk_sjg.gjk_wlw_wlw_gs_jcd b\\n\" +\n            \"where a.dwbsm  = b.bsm\\n\" +\n            \"union all \\n\" +\n            \"select a.bsm as id ,b.bsm as point_bsm,0 as rel_type,a.bsm as rel_bsm,\\n\" +\n            \"1 as deleted , now() as create_at,null created_by,now() as update_at,null updated_by\\n\" +\n            \"from ztfbk_sjg.gs_js_cz  a ,ztfbk_sjg.gjk_wlw_wlw_gs_jcd b\\n\" +\n            \"where a.bsm  = b.ssbm"," "]
["每天凌晨0点执行","监测点关系","全量同步","gjk_wlw_wlw_sg_jcd","select a.bsm as id ,b.bsm as point_bsm,1 as rel_type,a.bsm as rel_bsm,\\n\" +\n            \"1 as deleted , now() as create_at,null created_by,now() as update_at,null updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_sg_jcsb  a ,ztfbk_sjg.gjk_wlw_wlw_sg_jcd b\\n\" +\n            \"where a.dwbsm  = b.bsm"," "]
["每天凌晨0点执行","监测点关系","全量同步","gjk_wlw_wlw_ql_jcsb","select a.bsm as id ,b.bsm as point_bsm,1 as rel_type,a.bsm as rel_bsm,\\n\" +\n            \"1 as deleted , now() as create_at,null created_by,now() as update_at,null updated_by\\n\" +\n            \"from ztfbk_sjg.gjk_wlw_wlw_ql_jcsb  a ,ztfbk_sjg.gjk_wlw_wlw_ql_jcd b\\n\" +\n            \"where a.dwbsm  = b.bsm"," "]
["每天凌晨0点执行","燃气监测项阈值","全量同步","rq_jc_jcxyz","全表查询"," "]
["每天凌晨0点执行","排水监测项阈值","全量同步","ps_jc_jcxyz-->NL_JC_JCXYZ","全表查询","已修改"]
["每天凌晨0点执行","增压站或二供泵房","全量同步","gs_js_gsbz","全表查询"," "]
["每天凌晨0点执行","供水监测项阈值","全量同步","gs_jc_jcxyz","全表查询","已修改"]
["每天凌晨0点执行","施工监测项阈值","全量同步","sg_jc_jcxyz","全表查询","已修改"]
["每天凌晨0点执行","桥梁监测项阈值","全量同步","ql_jc_jcxyz","全表查询","已修改"]
["每天凌晨0点执行","应急预案","增量同步","zy_js_yjya","增量查询"," "]
["每天凌晨0点执行","避难场所","全量同步","zy_js_bncs"," select *\n    from ztfbk_sjg.zy_js_bncs    \n      order by sjtbsj desc","已修改"]
["每天凌晨0点执行","应急仓库","全量同步","zy_js_ck"," select *\n    from ztfbk_sjg.zy_js_ck","已修改"]
["每天凌晨0点执行","救援队伍","全量同步","zy_js_jydw"," select *\n    from ztfbk_sjg.zy_js_jydw","已修改"]
["每天凌晨0点执行","应急物资","全量同步","zy_js_yjwz"," select *\n    from ztfbk_sjg.zy_js_yjwz","已修改"]
["每天凌晨0点执行","应急专家","全量同步","zy_js_yjzj"," select *\n    from ztfbk_sjg.zy_js_yjzj","已修改"]
["每天凌晨0点执行","医疗机构","全量同步","zy_js_ylwsjg","select *\n    from ztfbk_sjg.zy_js_ylwsjg","已修改"]
["每天凌晨0点执行","重大危险源","全量同步","zy_js_zdwxy","select *\n    from ztfbk_sjg.zy_js_zdwxy","已修改"]
["每天凌晨0点执行","事件档案","全量同步","sg_jg_dxdaalk"," select *\n      from ztfbk_sjg.sg_jg_dxdaalk","已修改"]
["每天凌晨0点执行","巡检记录","全量同步","rq_jg_xjjl","select bsm as id,'0' as scene,'' as type,\" +\n            \"case when xjdx = 1 then '管道' when xjdx = 2 then '场站' when xjdx = 3 then '用户' \\n\" +\n            \"when xjdx = 4 then '其它' when xjdx = 5 then '管网' when xjdx = 6 then '泵站' \\n\" +\n            \"when xjdx = 7 then '闸门' when xjdx = 8 then '河道' when xjdx = 9 then '其他附属设施'\\n\" +\n            \"else '' end as object,jcdy as unit,jcxm as project,jcff as function,\\n\" +\n            \"jcnr as content,jcjg as result,czyh as pitfall,jcrq as check_time,jcry as checker,ssqsdw as owner,\\n\" +\n            \"zgdw as manager,fj::text as annex,bz as remark,null as order_num,now() as create_time,null as create_user,\\n\" +\n            \"now() as update_time,null update_user,1 as del_flag,null as plan_id\\n\" +\n            \"from ztfbk_sjg.rq_jg_xjjl","已修改"]
["每天凌晨0点执行","巡检记录","全量同步","gs_jg_xjjl","select id,'2' as scene,'' as type,\" +\n            \"case when jcdx = '1' then '管道' when jcdx = '2' then '场站' when jcdx = '3' then '用户' \\n\" +\n            \"when jcdx = '4' then '其它' when jcdx = '5' then '管网' when jcdx = '6' then '泵站' \\n\" +\n            \"when jcdx = '7' then '闸门' when jcdx = '8' then '河道' when jcdx = '9' then '其他附属设施'\\n\" +\n            \"else '' end as object,jcdy as unit,jcxm as project,jcff as function,\\n\" +\n            \"jcnr as content,jcjg as result,'' as pitfall,jcrq as check_time,jcry as checker,ssqsdw as owner,\\n\" +\n            \"zgdw as manager,fj::text as annex,bz as remark,null as order_num,now() as create_time,null as create_user,\\n\" +\n            \"now() as update_time,null update_user,1 as del_flag,null as plan_id\\n\" +\n            \"from ztfbk_sjg.gs_jg_xjjl"," 不做同步,数据保留"]
["每天凌晨0点执行","巡检记录","全量同步","ps_jg_xjjl-->NL_JG_XJJL","SELECT bsm AS ID,'1' AS scene,'' AS TYPE,CASE WHEN xjdx='5' THEN '雨水管网' WHEN xjdx='6' THEN '雨水泵站' WHEN xjdx='7' THEN '雨水闸门' WHEN xjdx='8' THEN '河道' WHEN xjdx='9' THEN '雨水其他附属设施' WHEN xjdx='10' THEN '污水管网' WHEN xjdx='11' THEN '污水泵站' WHEN xjdx='12' THEN '污水闸门' WHEN xjdx='13' THEN '污水其他附属设施' WHEN xjdx='14' THEN '合流管网' WHEN xjdx='15' THEN '合流泵站' WHEN xjdx='16' THEN '合流其他附属设施' ELSE '' END AS OBJECT,jcdy AS unit,jcxm AS project,jcff AS FUNCTION,jcnr AS CONTENT,jcjg AS RESULT,czyh AS pitfall,jcrq AS check_time,jcry AS checker,ssqsdw AS OWNER,'' AS manager,fj :: TEXT AS annex,bz AS remark,NULL AS order_num,now() AS create_time,NULL AS create_user,now() AS update_time,NULL update_user,1 AS del_flag,NULL AS plan_id FROM ztfbk_sjg.NL_JG_XJJL","已修改"]
["每天凌晨0点执行","巡检记录","全量同步","dl_jg_xjjl","select bsm as id,'6' as scene,'' as type,\" +\n            \"case when xjdx = 1 then '管道' when xjdx = 2 then '场站' when xjdx = 3 then '用户' \\n\" +\n            \"when xjdx = 4 then '其它' when xjdx = 5 then '管网' when xjdx = 6 then '泵站' \\n\" +\n            \"when xjdx = 7 then '闸门' when xjdx = 8 then '河道' when xjdx = 9 then '其他附属设施'\\n\" +\n            \"else '' end as object,jcdy as unit,jcxm as project,jcff as function,\\n\" +\n            \"jcnr as content,jcjg as result,czyh as pitfall,jcrq as check_time,jcry as checker,ssqsdw as owner,\\n\" +\n            \"zgdw as manager,fj::text as annex,bz as remark,null as order_num,now() as create_time,null as create_user,\\n\" +\n            \"now() as update_time,null update_user,1 as del_flag,null as plan_id\\n\" +\n            \"from ztfbk_sjg.dl_jg_xjjl"," "]
["每天凌晨0点执行","巡检记录","全量同步","ql_jg_xjjl","select bsm as id,'5' as scene,'' as type,\" +\n            \"case when xjdx = 1 then '管道' when xjdx = 2 then '场站' when xjdx = 3 then '用户' \\n\" +\n            \"when xjdx = 4 then '其它' when xjdx = 5 then '管网' when xjdx = 6 then '泵站' \\n\" +\n            \"when xjdx = 7 then '闸门' when xjdx = 8 then '河道' when xjdx = 9 then '其他附属设施'\\n\" +\n            \"else '' end as object,jcdy as unit,jcxm as project,jcff as function,\\n\" +\n            \"jcnr as content,jcjg as result,czyh as pitfall,jcrq as check_time,jcry as checker,ssqsdw as owner,\\n\" +\n            \"zgdw as manager,fj::text as annex,bz as remark,null as order_num,now() as create_time,null as create_user,\\n\" +\n            \"now() as update_time,null update_user,1 as del_flag,null as plan_id\\n\" +\n            \"from ztfbk_sjg.ql_jg_xjjl"," "]
["每天凌晨0点执行","养护记录","全量同步","rq_jg_yhjl","全表查询"," "]
["每天凌晨0点执行","养护记录","全量同步","gs_jg_yhjl","全表查询"," "]
["每天凌晨0点执行","养护记录","全量同步","ps_jg_yhjl-->NL_JG_YHJL","全表查询","已修改"]
["每天凌晨0点执行","养护记录","全量同步","ql_jg_yhjl","全表查询"," "]
["每天凌晨0点执行","养护记录","全量同步","dl_jg_yhjl","全表查询"," "]
["每天凌晨0点执行","维修记录","全量同步","rq_jg_rcwhwx","全表查询"," "]
["每天凌晨0点执行","维修记录","全量同步","gs_jg_rcwhwx","全表查询"," "]
["每天凌晨0点执行","维修记录","全量同步","ps_jg_rcwhwx","全表查询"," "]
["每天凌晨0点执行","维修记录","全量同步","dl_jg_rcwhwx","全表查询"," "]
["每天凌晨0点执行","整改记录属性","全量同步","rq_jg_zgjl","全表查询","已修改"]
["每天凌晨0点执行","安全专项检查记录","全量同步","rq_jg_aqzxjcjl","全表查询"," "]
["每天凌晨0点执行","联合检查记录","全量同步","rq_jg_lhjcjl","全表查询"," "]
["每天凌晨0点执行","第三方施工联合惩戒属性","全量同步","sg_jg_dsfsglhcj-->SG_JG_LHCJ","全表查询","已修改"]
["每半点执行","规划建设","全量同步","rq_jg_jhxm"," select *\n    from ztfbk_sjg.rq_jg_jhxm"," "]
["每半点执行","规划建设","全量同步","ql_jg_jhxm"," select *\n      from ztfbk_sjg.ql_jg_jhxm","已修改"]
["每半点执行","规划建设","全量同步","dl_jg_jhxm"," select *\n      from ztfbk_sjg.dl_jg_jhxm"," "]
["每半点执行","规划建设","全量同步","gs_jg_jhxm"," select *\n      from ztfbk_sjg.gs_jg_jhxm"," "]
["每半点执行","规划建设","全量同步","ps_jg_jhxm","  select *\n      from ztfbk_sjg.ps_jg_jhxm"," "]
["每半点执行","规划建设","全量同步","zh_jg_jhxm"," select *\n      from ztfbk_sjg.zh_jg_jhxm"," "]
["每半点执行","监测预警 ","全量同步","rq_jc_jcyj","select bsm,\n        '0' as scene,\n        xzqhdm,\n        yjmc,\n        yjssmc,\n        yjssbh,\n        yjlx,\n        yjdz,\n        case when yjjb is null then 1 else yjjb end as yjjb,\n        yjzt,\n        yjscsj,\n        yjsbsj,\n        yjjs,\n        yjbg,\n        ypfx,\n        fxbg,\n        czzt,\n        czr,\n        czsj,\n        czjy,\n        czbg,\n        bz,\n        tbsj\n        from ztfbk_sjg.rq_jc_jcyj\n        where 1=1 and (xzqhdm is not null)","有数据了6131","rq_jc_jcyj","预警数据抽取","rq_jc_jcyj","xzqhdm is not null"]
["每半点执行","监测预警 ","全量同步","gs_jc_jcyj","select bsm,\n        '2' as scene,\n        xzqhdm,\n        yjmc,\n        yjssmc,\n        yjssbh,\n        yjlx,\n        yjdz,\n        case when yjjb is null then 1 else yjjb end as yjjb,\n        yjzt,\n        yjscsj,\n        yjsbsj,\n        yjjs,\n        yjbg,\n        ypfx,\n        fxbg,\n        czzt,\n        czr,\n        czsj,\n        czjy,\n        czbg,\n        bz,\n        tbsj\n        from ztfbk_sjg.gs_jc_jcyj\n        where 1=1 and (xzqhdm is not null)","无数据","gs_jc_jcyj",null,"gs_jc_jcyj","xzqhdm is not null"]
["每半点执行","监测预警 ","全量同步","ps_jc_jcyj==>NL_JC_JCYJ","select bsm,\n        '1' as scene,\n        xzqhdm,\n        yjmc,\n        yjssmc,\n        yjssbh,\n        yjlx,\n        yjdz,\n        case when yjjb is null then 1 else yjjb end as yjjb,\n        yjzt,\n        yjscsj,\n        yjsbsj,\n        yjjs,\n        yjbg,\n        ypfx,\n        fxbg,\n        czzt,\n        czr,\n        czsj,\n        czjy,\n        czbg,\n        bz,\n        tbsj\n        from ztfbk_sjg.ps_jc_jcyj\n        where 1=1 and (xzqhdm is not null)","无数据","ps_jc_jcyj",null,"ps_jc_jcyj","xzqhdm is not null"]
["每半点执行","监测预警 ","全量同步","ql_jc_jcyj","select bsm,\n        '5' as scene,\n        xzqhdm,\n        yjmc,\n        yjssmc,\n        yjssbh,\n        yjlx,\n        yjdz,\n        case when yjjb is null then 1 else yjjb end as yjjb,\n        yjzt,\n        yjscsj,\n        yjsbsj,\n        yjjs,\n        yjbg,\n        ypfx,\n        fxbg,\n        czzt,\n        czr,\n        czsj,\n        czjy,\n        czbg,\n        bz,\n        tbsj\n        from ztfbk_sjg.ql_jc_jcyj\n        where 1=1 and (xzqhdm is not null)","无数据","ql_jc_jcyj",null,"ql_jc_jcyj","xzqhdm is not null"]
["每半点执行","监测预警 ","全量同步","rq_jc_jcbj","SELECT CASE WHEN rq_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE rq_jc_jcbj.dqbjjb END AS dqbjjb2, rq_jc_bjfx.bsm AS jcBjfxBsm,bjdwwz,xcpcry,xczkms,xcryfxbg,fxnr,xctpspwj,rq_jc_bjcz.czzt,rq_jc_bjcz.czsj,rq_jc_bjcz.cznr,rq_jc_bjcz.czbg,rq_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_rq_jcsb.sbmc,COALESCE (gjk_wlw_wlw_rq_jcd.xzqhdm,rq_jc_bjcz.xzqhdm) xzqhdm,rq_jc_jcbj.*FROM ztfbk_sjg.rq_jc_jcbj rq_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_rq_jcsb gjk_wlw_wlw_rq_jcsb ON gjk_wlw_wlw_rq_jcsb.srcid=rq_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_rq_jcd gjk_wlw_wlw_rq_jcd ON gjk_wlw_wlw_rq_jcd.bsm=gjk_wlw_wlw_rq_jcsb.dwbsm LEFT JOIN ztfbk_sjg.rq_jc_bjcz rq_jc_bjcz ON rq_jc_bjcz.bjbh=rq_jc_jcbj.bjbh LEFT JOIN ztfbk_sjg.rq_jc_bjfx rq_jc_bjfx ON rq_jc_bjfx.bjbh=rq_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_rq_jcd.xzqhdm IS NOT NULL OR rq_jc_bjcz.xzqhdm IS NOT NULL) )","主表(6565条)没有行政区划字段,关联表没有数据","rq_jc_jcbj",null,"rq_jc_jcbj","SELECT CASE WHEN rq_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE rq_jc_jcbj.dqbjjb END AS dqbjjb2,rq_jc_bjfx.bsm AS jcBjfxBsm,bjdwwz,xcpcry,xczkms,xcryfxbg,fxnr,xctpspwj,rq_jc_bjcz.czzt,rq_jc_bjcz.czsj,rq_jc_bjcz.cznr,rq_jc_bjcz.czbg,rq_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_rq_jcsb.sbmc,COALESCE (gjk_wlw_wlw_rq_jcd.xzqhdm,rq_jc_bjcz.xzqhdm) xzqhdm,rq_jc_jcbj.*FROM ztfbk_sjg.rq_jc_jcbj rq_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_rq_jcsb gjk_wlw_wlw_rq_jcsb ON gjk_wlw_wlw_rq_jcsb.bsm=rq_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_rq_jcd gjk_wlw_wlw_rq_jcd ON gjk_wlw_wlw_rq_jcd.bsm=gjk_wlw_wlw_rq_jcsb.dwbsm LEFT JOIN ztfbk_sjg.rq_jc_bjcz rq_jc_bjcz ON rq_jc_bjcz.bjbh=rq_jc_jcbj.bjbh LEFT JOIN ztfbk_sjg.rq_jc_bjfx rq_jc_bjfx ON rq_jc_bjfx.bjbh=rq_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_rq_jcd.xzqhdm IS NOT NULL OR rq_jc_bjcz.xzqhdm IS NOT NULL))"]
["每半点执行","监测预警 ","全量同步","sg_jc_jcbj","SELECT CASE WHEN sg_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE sg_jc_jcbj.dqbjjb END AS dqbjjb2, sg_jc_bjcz.czzt,sg_jc_bjcz.czsj,sg_jc_bjcz.cznr,sg_jc_bjcz.czbg,sg_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_sg_jcsb.sbmc,COALESCE (gjk_wlw_wlw_sg_jcd.xzqhdm,sg_jc_bjcz.xzqhdm) xzqhdm,sg_jc_jcbj.*FROM ztfbk_sjg.sg_jc_jcbj sg_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_sg_jcsb gjk_wlw_wlw_sg_jcsb ON gjk_wlw_wlw_sg_jcsb.srcid=sg_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_sg_jcd gjk_wlw_wlw_sg_jcd ON gjk_wlw_wlw_sg_jcd.bsm=gjk_wlw_wlw_sg_jcsb.dwbsm LEFT JOIN ztfbk_sjg.sg_jc_bjcz sg_jc_bjcz ON sg_jc_bjcz.bjbh=sg_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_sg_jcd.xzqhdm IS NOT NULL OR sg_jc_bjcz.xzqhdm IS NOT NULL))","3条数据","sg_jc_jcbj",null,"sg_jc_jcbj","SELECT CASE WHEN sg_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE sg_jc_jcbj.dqbjjb END AS dqbjjb2, sg_jc_bjcz.czzt,sg_jc_bjcz.czsj,sg_jc_bjcz.cznr,sg_jc_bjcz.czbg,sg_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_sg_jcsb.sbmc,COALESCE (gjk_wlw_wlw_sg_jcd.xzqhdm,sg_jc_bjcz.xzqhdm) xzqhdm,sg_jc_jcbj.*FROM ztfbk_sjg.sg_jc_jcbj sg_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_sg_jcsb gjk_wlw_wlw_sg_jcsb ON gjk_wlw_wlw_sg_jcsb.bsm=sg_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_sg_jcd gjk_wlw_wlw_sg_jcd ON gjk_wlw_wlw_sg_jcd.bsm=gjk_wlw_wlw_sg_jcsb.dwbsm LEFT JOIN ztfbk_sjg.sg_jc_bjcz sg_jc_bjcz ON sg_jc_bjcz.bjbh=sg_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_sg_jcd.xzqhdm IS NOT NULL OR sg_jc_bjcz.xzqhdm IS NOT NULL))"]
["每半点执行","监测预警 ","全量同步","gs_jc_jcbj","SELECT CASE WHEN gs_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE gs_jc_jcbj.dqbjjb END AS dqbjjb2, gs_jc_bjfx.bsm AS jcBjfxBsm,bjdwwz,xcpcry,xczkms,xcryfxbg,fxnr,xctpspwj,gs_jc_bjcz.czzt,gs_jc_bjcz.czsj,gs_jc_bjcz.cznr,gs_jc_bjcz.czbg,gs_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_gs_jcsb.sbmc,COALESCE (gjk_wlw_wlw_gs_jcd.xzqhdm,gs_jc_bjcz.xzqhdm) xzqhdm,gs_jc_jcbj.*FROM ztfbk_sjg.gs_jc_jcbj gs_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_gs_jcsb gjk_wlw_wlw_gs_jcsb ON gjk_wlw_wlw_gs_jcsb.srcid=gs_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_gs_jcd gjk_wlw_wlw_gs_jcd ON gjk_wlw_wlw_gs_jcd.bsm=gjk_wlw_wlw_gs_jcsb.dwbsm LEFT JOIN ztfbk_sjg.gs_jc_bjcz gs_jc_bjcz ON gs_jc_bjcz.bjbh=gs_jc_jcbj.bjbh LEFT JOIN ztfbk_sjg.gs_jc_bjfx gs_jc_bjfx ON gs_jc_bjfx.bjbh=gs_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_gs_jcd.xzqhdm IS NOT NULL OR gs_jc_bjcz.xzqhdm IS NOT NULL) )","无数据","gs_jc_jcbj",null,"gs_jc_jcbj","SELECT CASE WHEN gs_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE gs_jc_jcbj.dqbjjb END AS dqbjjb2, gs_jc_bjfx.bsm AS jcBjfxBsm,bjdwwz,xcpcry,xczkms,xcryfxbg,fxnr,xctpspwj,gs_jc_bjcz.czzt,gs_jc_bjcz.czsj,gs_jc_bjcz.cznr,gs_jc_bjcz.czbg,gs_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_gs_jcsb.sbmc,COALESCE (gjk_wlw_wlw_gs_jcd.xzqhdm,gs_jc_bjcz.xzqhdm) xzqhdm,gs_jc_jcbj.*FROM ztfbk_sjg.gs_jc_jcbj gs_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_gs_jcsb gjk_wlw_wlw_gs_jcsb ON gjk_wlw_wlw_gs_jcsb.bsm=gs_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_gs_jcd gjk_wlw_wlw_gs_jcd ON gjk_wlw_wlw_gs_jcd.bsm=gjk_wlw_wlw_gs_jcsb.dwbsm LEFT JOIN ztfbk_sjg.gs_jc_bjcz gs_jc_bjcz ON gs_jc_bjcz.bjbh=gs_jc_jcbj.bjbh LEFT JOIN ztfbk_sjg.gs_jc_bjfx gs_jc_bjfx ON gs_jc_bjfx.bjbh=gs_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_gs_jcd.xzqhdm IS NOT NULL OR gs_jc_bjcz.xzqhdm IS NOT NULL) )"]
["每半点执行","监测预警 ","全量同步","ps_jc_jcbj==>NL_JC_JCBJ","SELECT CASE WHEN nl_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE nl_jc_jcbj.dqbjjb END AS dqbjjb2,nl_jc_bjfx.bsm AS jcBjfxBsm,bjdwwz,NULL AS xcpcry,xczkms,xcryfxbg,fxnr,NULL AS xctpspwj,nl_jc_bjcz.czzt,nl_jc_bjcz.czsj,nl_jc_bjcz.cznr,nl_jc_bjcz.czbg,nl_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_ps_jcsb.sbmc,COALESCE (gjk_wlw_wlw_ps_jcd.xzqhdm,nl_jc_bjcz.xzqhdm) xzqhdm,nl_jc_jcbj.*FROM ztfbk_sjg.nl_jc_jcbj_view nl_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_ps_jcsb gjk_wlw_wlw_ps_jcsb ON gjk_wlw_wlw_ps_jcsb.bsm=nl_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_ps_jcd gjk_wlw_wlw_ps_jcd ON gjk_wlw_wlw_ps_jcd.bsm=gjk_wlw_wlw_ps_jcsb.dwbsm LEFT JOIN ztfbk_sjg.nl_jc_bjcz_view nl_jc_bjcz ON nl_jc_bjcz.bsm=nl_jc_jcbj.bsm LEFT JOIN ztfbk_sjg.nl_jc_bjfx_view nl_jc_bjfx ON nl_jc_bjfx.bsm=nl_jc_jcbj.bsm WHERE 1=1 AND (gjk_wlw_wlw_ps_jcd.xzqhdm IS NOT NULL OR nl_jc_bjcz.xzqhdm IS NOT NULL)","无数据","ps_jc_jcbj",null,"ps_jc_jcbj","SELECT CASE WHEN ps_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE ps_jc_jcbj.dqbjjb END AS dqbjjb2, ps_jc_bjfx.bsm AS jcBjfxBsm,bjdwwz,xcpcry,xczkms,xcryfxbg,fxnr,xctpspwj,ps_jc_bjcz.czzt,ps_jc_bjcz.czsj,ps_jc_bjcz.cznr,ps_jc_bjcz.czbg,ps_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_ps_jcsb.sbmc,COALESCE (gjk_wlw_wlw_ps_jcd.xzqhdm,ps_jc_bjcz.xzqhdm) xzqhdm,ps_jc_jcbj.*FROM ztfbk_sjg.ps_jc_jcbj ps_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_ps_jcsb gjk_wlw_wlw_ps_jcsb ON gjk_wlw_wlw_ps_jcsb.bsm=ps_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_ps_jcd gjk_wlw_wlw_ps_jcd ON gjk_wlw_wlw_ps_jcd.bsm=gjk_wlw_wlw_ps_jcsb.dwbsm LEFT JOIN ztfbk_sjg.ps_jc_bjcz ps_jc_bjcz ON ps_jc_bjcz.bjbh=ps_jc_jcbj.bjbh LEFT JOIN ztfbk_sjg.ps_jc_bjfx ps_jc_bjfx ON ps_jc_bjfx.bjbh=ps_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_ps_jcd.xzqhdm IS NOT NULL OR ps_jc_bjcz.xzqhdm IS NOT NULL) )"]
["每半点执行","监测预警 ","全量同步","ql_jc_jcbj","SELECT distinct CASE WHEN ql_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE ql_jc_jcbj.dqbjjb END AS dqbjjb2,ql_jc_bjfx.bsm AS jcBjfxBsm,bjdwwz,xcpcry,xczkms,xcryfxbg,fxnr,xctpspwj,ql_jc_bjcz.czzt,ql_jc_bjcz.czsj,ql_jc_bjcz.cznr,ql_jc_bjcz.czbg,ql_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_ql_jcsb.sbmc,COALESCE (gjk_wlw_wlw_ql_jcd.xzqhdm,ql_jc_bjcz.xzqhdm) xzqhdm,ql_jc_jcbj.*FROM ztfbk_sjg.ql_jc_jcbj ql_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_ql_jcsb gjk_wlw_wlw_ql_jcsb ON gjk_wlw_wlw_ql_jcsb.srcid=ql_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_ql_jcd gjk_wlw_wlw_ql_jcd ON gjk_wlw_wlw_ql_jcd.bsm=gjk_wlw_wlw_ql_jcsb.dwbsm LEFT JOIN (\\n\" +\n            \"SELECT*FROM (\\n\" +\n            \"SELECT ROW_NUMBER () OVER (PARTITION BY ztfbk_sjg.ql_jc_bjcz.bjbh ORDER BY ztfbk_sjg.ql_jc_bjcz.czsj DESC) AS rowNum,*FROM ztfbk_sjg.ql_jc_bjcz) d WHERE rowNum=1) AS ql_jc_bjcz ON ql_jc_bjcz.bjbh=ql_jc_jcbj.bjbh LEFT JOIN ztfbk_sjg.ql_jc_bjfx ql_jc_bjfx ON ql_jc_bjfx.bjbh=ql_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_ql_jcd.xzqhdm IS NOT NULL OR ql_jc_bjcz.xzqhdm IS NOT NULL))","33条数据","ql_jc_jcbj",null,"ql_jc_jcbj","SELECT distinct CASE WHEN ql_jc_jcbj.dqbjjb IS NULL THEN '4' ELSE ql_jc_jcbj.dqbjjb END AS dqbjjb2,ql_jc_bjfx.bsm AS jcBjfxBsm,bjdwwz,xcpcry,xczkms,xcryfxbg,fxnr,xctpspwj,ql_jc_bjcz.czzt,ql_jc_bjcz.czsj,ql_jc_bjcz.cznr,ql_jc_bjcz.czbg,ql_jc_bjcz.bz sgJcBjczBz,gjk_wlw_wlw_ql_jcsb.sbmc,COALESCE (gjk_wlw_wlw_ql_jcd.xzqhdm,ql_jc_bjcz.xzqhdm) xzqhdm,ql_jc_jcbj.*FROM ztfbk_sjg.ql_jc_jcbj ql_jc_jcbj LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_ql_jcsb gjk_wlw_wlw_ql_jcsb ON gjk_wlw_wlw_ql_jcsb.srcid=ql_jc_jcbj.sbbsm LEFT JOIN ztfbk_sjg.gjk_wlw_wlw_ql_jcd gjk_wlw_wlw_ql_jcd ON gjk_wlw_wlw_ql_jcd.bsm=gjk_wlw_wlw_ql_jcsb.dwbsm LEFT JOIN (\n            SELECT*FROM (\n            SELECT ROW_NUMBER () OVER (PARTITION BY ztfbk_sjg.ql_jc_bjcz.bjbh ORDER BY ztfbk_sjg.ql_jc_bjcz.czsj DESC) AS rowNum,*FROM ztfbk_sjg.ql_jc_bjcz) d WHERE rowNum=1) AS ql_jc_bjcz ON ql_jc_bjcz.bjbh=ql_jc_jcbj.bjbh LEFT JOIN ztfbk_sjg.ql_jc_bjfx ql_jc_bjfx ON ql_jc_bjfx.bjbh=ql_jc_jcbj.bjbh WHERE 1=1 AND ((gjk_wlw_wlw_ql_jcd.xzqhdm IS NOT NULL OR ql_jc_bjcz.xzqhdm IS NOT NULL))"]
["每半点执行","监测预警 ","全量同步","sg_jc_gxzdcgqsbjcyj","SELECT*FROM ztfbk_sjg.sg_jc_gxzdcgqsbjcyj WHERE SJLX IN (1,2,3) and xzqhdm is not null","262条数据","sg_jc_gxzdcgqsbjcyj",null,"sg_jc_gxzdcgqsbjcyj","SELECT*FROM ztfbk_sjg.sg_jc_gxzdcgqsbjcyj WHERE SJLX IN (1,2,3) and xzqhdm is not null"]
["每半点执行","监测预警 ","全量同步","sg_jc_dwzdsbjcyj","select * from ztfbk_sjg.sg_jc_dwzdsbjcyj","2条数据","sg_jc_dwzdsbjcyj",null,"sg_jc_dwzdsbjcyj","select * from ztfbk_sjg.sg_jc_dwzdsbjcyj"]
["每半点执行","监测预警 ","全量同步","sg_jc_spjcsbjcyj","select * from ztfbk_sjg.sg_jc_spjcsbjcyj","874条数据","sg_jc_spjcsbjcyj",null,"sg_jc_spjcsbjcyj","select * from ztfbk_sjg.sg_jc_spjcsbjcyj"]
["每半点执行","监测预警 ","全量同步","dl_jc_bjcz","SELECT dl_jc_bjcz.xctpspwj,dl_jc_bjcz.czjg,dl_jc_bjcz.wcczsj,dl_jc_bjcz.ksczsj,dl_jc_bjcz.xcpcry,dl_jc_bjcz.czzt,dl_jc_bjcz.czfa,COALESCE (dl_jc_jcd.xzqhdm,dl_jc_bjcz.xzqhdm) xzqhdm,dl_jc_jcd.jcwz,dl_jc_jcsb.sbmc,dl_jc_jcbj.*FROM ztfbk_sjg.dl_jc_jcbj dl_jc_jcbj LEFT JOIN dl_jc_jcsb ON dl_jc_jcsb.bsm=dl_jc_jcbj.sbbsm LEFT JOIN dl_jc_jcd ON dl_jc_jcd.bsm=dl_jc_jcbj.dwbsm LEFT JOIN ztfbk_sjg.dl_jc_bjcz dl_jc_bjcz ON dl_jc_bjcz.bjbh=dl_jc_jcbj.bjbh WHERE 1=1 AND ((dl_jc_jcd.xzqhdm IS NOT NULL OR dl_jc_bjcz.xzqhdm IS NOT NULL))"]
[null,null,"新增","QL_JC_JCYJ_ SD","SELECT\n        bsm,\n        '1' AS scene,\n        xzqhdm,\n        yjmc,\n        yjssmc,\n        yjssbh,\n        yjlx,\n        yjdz,\n        CASE\n        WHEN yjjb IS NULL THEN\n        1 ELSE yjjb\n        END AS yjjb,\n        yjzt,\n        yjscsj AS yjscsj,\n        yjsbsj,\n        yjjs,\n        yjbg,\n        ypfx,\n        fxbg,\n        czzt,\n        czry AS czr,\n        czsj,\n        czjy,\n        czbg,\n        bz,\n        tbsj\n        FROM\n        ztfbk_sjg.QL_JC_JCYJ_SD\n        WHERE\n        1 = 1\n        AND ( xzqhdm IS NOT NULL )"]
[null,null,"新增","DL_JC_JCYJ","SELECT\n            bsm,\n            '1' AS scene,\n            xzqhdm,\n            yjmc,\n            yjssmc,\n            yjssbh,\n            yjlx,\n            yjdz,\n            CASE\n                WHEN yjjb IS NULL THEN\n                    1 ELSE yjjb\n                END AS yjjb,\n            yjzt,\n            yjscsj AS yjscsj,\n            yjsbsj,\n            yjjs,\n            yjbg,\n            ypfx,\n            fxbg,\n            czzt,\n            czry AS czr,\n            czsj,\n            czjy,\n            czbg,\n            bz,\n            tbsj\n        FROM\n            ztfbk_sjg.DL_JC_JCYJ\n        WHERE\n            1 = 1\n          AND ( xzqhdm IS NOT NULL )"]
[null,null,"新增","SG_JC_JCYJ","SELECT\n            bsm,\n            '1' AS scene,\n            xzqhdm,\n            yjmc,\n            yjssmc,\n            yjssbh,\n            yjlx,\n            yjdz,\n            CASE\n                WHEN yjjb IS NULL THEN\n                    1 ELSE yjjb\n                END AS yjjb,\n            yjzt,\n            yjscsj AS yjscsj,\n            yjsbsj,\n            yjjs,\n            yjbg,\n            ypfx,\n            fxbg,\n            czzt,\n            czry AS czr,\n            czsj,\n            czjy,\n            czbg,\n            bz,\n            tbsj\n        FROM\n            ztfbk_sjg.SG_JC_JCYJ\n        WHERE\n            1 = 1\n          AND ( xzqhdm IS NOT NULL )"]

{"sheet":"删除表涉及问题","index":1,"n_rows":11,"n_cols":8,"rows_kept":11,"cut":false,"hidden":false,"merged":[]}
[null,null,null,"前置库","正式库"]
[null,null,"表名备注","表名","表名备注","表名","过滤条件"]
["删除表","供水行业","厂站属性结构表","GS_JS_CZ","供水厂站","jcss_gscz","全表","后管供水场站管理和数据统计"]
[null,null,null,"处理结果:停止同步数据保留","基础设施表","zhjg_analysis_facility","facility_type=3(供水厂站)","用于后管展示和前端基础设施统计展示"]
[{"$nulls":4},"综合统计分析-监测点-关系表","zhjg_analysis_point_rel","id=GS_JS_CZ.bms","用于后管展示"]
[null,"供水行业","巡检记录属性结构表","GS_JG_XJJL","行业监督管理-巡查养护-巡查养护记录","industry_supervision_patrol","scene=2","用于后管展示和数据统计"]
[null,null,null,"处理结果:停止同步数据保留"]
[]
[null,null,"表名备注","原表名","表名修改","问题点"]
["表名修改问题","燃气行\n业","监测点属性结\n构表","RQ_JS_JCD","RQ_JC_JCD","目前同步用表gjk_wlw_wlw_rq_jcd,是否需要重新修改"]
[null,null,null,"还是用物联网数据"]

{"sheet":"Sheet3","index":2,"n_rows":43,"n_cols":9,"rows_kept":43,"cut":false,"hidden":false,"merged":[]}
{"$rows_empty":11}
[null,null,"DlCsdl","dl_js_csdl"]
[null,null,"bsm","bsm",null,null,null,"bsm","bsm"]
[null,null,"xzqhdm","xzqhdm",null,null,null,"xzqhdm","xzqhdm"]
[null,null,"dlmc","dlmc",null,null,null,"dlmc","dlmc"]
[null,null,"dlqd","dlqd",null,null,null,"dlqd","dlqd"]
[null,null,"dlzd","dlzd",null,null,null,"dlzd","dlzd"]
[null,null,"dlzx","dlzx",null,null,null,"dldj","dldj"]
[null,null,"dldj","dldj",null,null,null,"fxdj","fxdj"]
[null,null,"glfl","glfl",null,null,null,"bz","bz"]
[null,null,"yhdj","yhdj",null,null,null,"tbsj","tbsj"]
[null,null,"dlcd","dlcd",null,null,null,"del_flag","del_flag"]
[null,null,"dlkd","dlkd",null,null,null,"gcmc","mc"]
[null,null,"dlmj","dlmj",null,null,null,"jcdw","jcdw"]
[null,null,"jsdw","jsdw",null,null,null,"pgdybh","pgdybh"]
[null,null,"sjdw","sjdw",null,null,null,"pgdylc","pgdycd"]
[null,null,"sgdw","sgdw",null,null,null,"pgfz","pgfz"]
[null,null,"jldw","jldw",null,null,null,"kjxx","kjxx"]
[null,null,"gldw","gldw",null,null,null,"yskzjbz","yskzjbz"]
[null,null,"yhdw","yhdw",null,null,null,"pgsj","pgsj"]
[null,null,"jgrq","jgny",null,null,null,"fj","fj"]
[null,null,"bz","bz",{"$nulls":4},"fxms"]
[null,null,"tbsj","tbsj",{"$nulls":4},"gkcs"]
[null,null,"del_flag","del_flag",{"$nulls":4},"gkzt"]
[null,null,"kjxx","kjxx",{"$nulls":4},"sjtbzt"]
[null,null,"yskzjbz","yskzjbz"]
[null,null,"dlmcbz"]
[null,null,"flbm"]
[null,null,"rxdsl"]
[null,null,"rxdlc"]
[null,null,"zxcdsl"]
[null,null,"zxcdlc"]
[null,null,"sjtbzt"]