diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.4__create_wgh_table.sql b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.4__create_wgh_table.sql
new file mode 100644
index 0000000000..d63a579232
--- /dev/null
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/resources/db/migration/V0.0.4__create_wgh_table.sql
@@ -0,0 +1,324 @@
+CREATE TABLE `ca_bm_grid` (
+  `grid_id` bigint(20) NOT NULL COMMENT '网格ID',
+  `grid_code` varchar(50) COLLATE utf8_bin NOT NULL COMMENT '网格编码。人工填写，编码规则业务规定，不允许重复。',
+  `grid_name` varchar(200) COLLATE utf8_bin NOT NULL COMMENT '网格名称',
+  `gb_code` varchar(50) COLLATE utf8_bin DEFAULT NULL COMMENT '行政区划的国标编码',
+  `parent_id` bigint(20) DEFAULT NULL COMMENT '上级网格ID',
+  `parent_code` varchar(50) COLLATE utf8_bin DEFAULT NULL COMMENT '上级网格编码',
+  `grid_classification` varchar(10) COLLATE utf8_bin NOT NULL COMMENT '网格分类。1基础网格 2环保网格 3防火网格 4城管网格 5执法网格 6安监网格等',
+  `grid_level` varchar(10) COLLATE utf8_bin NOT NULL COMMENT '网格层级。网格层级表的层级\n根据【网格层级表】的层级关系动态展示。\n查询【网格层级表】层级 条件：上层级=网格树返回的网格层级',
+  `grid_property` varchar(10) COLLATE utf8_bin DEFAULT NULL COMMENT '网格属性。01村庄、02小区、03企业、04学校（幼儿园）、05医院、06驻镇（街）单位、07其他',
+  `is_end` char(1) COLLATE utf8_bin NOT NULL COMMENT '是否最后一级:0否 1是',
+  `grid_address` varchar(200) COLLATE utf8_bin DEFAULT NULL COMMENT '网格地址',
+  `grid_introduce` varchar(1024) COLLATE utf8_bin DEFAULT NULL COMMENT '网格介绍',
+  `grid_picture` varchar(240) COLLATE utf8_bin DEFAULT NULL COMMENT '宣传图片',
+  `regin_scope_desc` varchar(1024) COLLATE utf8_bin DEFAULT NULL COMMENT '地图区域范围',
+  `grid_sort` int(10) DEFAULT NULL COMMENT '展示顺序',
+  `point_status` varchar(10) COLLATE utf8_bin NOT NULL COMMENT '标绘状态',
+  `grid_em_center` bigint(10) DEFAULT NULL COMMENT '事件上报中心',
+  `grid_begin_time` datetime DEFAULT NULL COMMENT '初始日期',
+  `grid_end_time` datetime DEFAULT NULL COMMENT '终止日期',
+  `grid_area` varchar(240) COLLATE utf8_bin DEFAULT NULL COMMENT '面积',
+  `is_valid` varchar(10) COLLATE utf8_bin DEFAULT '1' COMMENT '是否有效',
+  `create_by` bigint(20) NOT NULL COMMENT '创建人',
+  `create_date` datetime NOT NULL COMMENT '创建时间',
+  `update_by` bigint(20) NOT NULL,
+  `update_date` datetime NOT NULL,
+  `delete_flag` varchar(10) COLLATE utf8_bin NOT NULL DEFAULT 'normal' COMMENT '删除状态: 字典值：normal正常，删除deleted',
+  `versions` int(10) DEFAULT '1' COMMENT '乐观锁',
+  `attribute1` varchar(240) COLLATE utf8_bin DEFAULT NULL COMMENT '网格内人口规模',
+  `attribute2` varchar(240) COLLATE utf8_bin DEFAULT NULL COMMENT '是否成立网格党支部或网格党小组',
+  `attribute3` varchar(240) COLLATE utf8_bin DEFAULT NULL COMMENT '网格党组织类型',
+  `attribute4` varchar(240) COLLATE utf8_bin DEFAULT NULL COMMENT '党组织编码',
+  `attribute5` varchar(240) COLLATE utf8_bin DEFAULT NULL COMMENT '扩展字段',
+  `attribute6` bigint(20) DEFAULT NULL COMMENT '扩展字段',
+  `attribute7` bigint(20) DEFAULT NULL COMMENT '扩展字段',
+  `attribute8` bigint(20) DEFAULT NULL COMMENT '扩展字段',
+  `attribute9` datetime DEFAULT NULL COMMENT '扩展字段',
+  `attribute10` datetime DEFAULT NULL COMMENT '扩展字段',
+  PRIMARY KEY (`grid_id`) USING BTREE,
+  KEY `SELECT_PARENT` (`parent_id`) USING BTREE,
+  KEY `idx_grid_grid_id` (`grid_id`) USING BTREE,
+  KEY `idx_grid_grid_sort` (`grid_sort`) USING BTREE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
+
+CREATE TABLE `wgh_base_grid` (
+  `coordinate_info` text,
+  `grid_name` varchar(100) DEFAULT NULL,
+  `sub_district_office` varchar(100) DEFAULT NULL,
+  `community` varchar(100) DEFAULT NULL,
+  `street_code` varchar(100) DEFAULT NULL,
+  `grid_code` varchar(100) DEFAULT NULL,
+  `community_code` varchar(100) DEFAULT NULL,
+  `longitude` varchar(100) DEFAULT NULL,
+  `latitude` varchar(100) DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
+
+CREATE TABLE `wgh_community` (
+  `coordinate_info` text,
+  `street_name` varchar(100) DEFAULT NULL,
+  `street_code` varchar(100) DEFAULT NULL,
+  `community_name` varchar(100) DEFAULT NULL,
+  `community_code` varchar(100) DEFAULT NULL,
+  `longitude` varchar(100) DEFAULT NULL,
+  `latitude` varchar(100) DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
+
+CREATE TABLE `wgh_dywg` (
+  `OBJECTID` int(11) NOT NULL,
+  `BGNAME` varchar(200) DEFAULT NULL COMMENT '网格名称',
+  `STREET` varchar(20) DEFAULT NULL COMMENT '所属街镇',
+  `COMMUNITY` varchar(50) DEFAULT NULL COMMENT '所属社区',
+  `BGSQUA` double DEFAULT NULL COMMENT '网格面积',
+  `ORDATE` datetime DEFAULT NULL COMMENT '初始时间',
+  `CHDATE` datetime DEFAULT NULL COMMENT '变更时间',
+  `NOTE` varchar(500) DEFAULT NULL COMMENT '备注',
+  `CONTACTS` varchar(50) DEFAULT NULL,
+  `TELPHONE` varchar(100) DEFAULT NULL COMMENT '联系电话',
+  `insert_time` datetime DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='单元网格';
+
+CREATE TABLE `wgh_jdb` (
+  `OBJECTID_1` varchar(50) DEFAULT NULL,
+  `OBJECTID` varchar(50) DEFAULT NULL,
+  `MC` varchar(60) DEFAULT NULL COMMENT '街道名称',
+  `person_in_charge` varchar(20) DEFAULT NULL COMMENT '责任人',
+  `phone` varchar(50) DEFAULT NULL COMMENT '联系电话',
+  `SHAPE_LENG` double DEFAULT NULL,
+  `insert_time` datetime DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='街道办';
+
+CREATE TABLE `wgh_jqz` (
+  `OBJECTID` int(11) DEFAULT NULL,
+  `XH` varchar(500) DEFAULT NULL COMMENT '序号',
+  `NAME` varchar(500) DEFAULT NULL COMMENT '单位名称',
+  `AREA` double DEFAULT NULL,
+  `SPACE` varchar(500) DEFAULT NULL COMMENT '周边安全间距',
+  `PROBLEM` varchar(500) DEFAULT NULL COMMENT '存在问题',
+  `TYPE` varchar(500) DEFAULT NULL COMMENT '危险源类型',
+  `LOCATION` varchar(500) DEFAULT NULL COMMENT '经营地址',
+  `PRINCIPAL` varchar(500) DEFAULT NULL COMMENT '负责人',
+  `PHONE` varchar(500) DEFAULT NULL COMMENT '联系电话',
+  `QTYPE` varchar(500) DEFAULT NULL COMMENT '企业类型',
+  `WTYPE` varchar(500) DEFAULT NULL COMMENT '危化品种类',
+  `level` varchar(500) DEFAULT NULL COMMENT '等级',
+  `nature` varchar(500) DEFAULT NULL COMMENT '性质',
+  `remarks` varchar(500) DEFAULT NULL COMMENT '备注',
+  `DWMCJC` varchar(50) DEFAULT NULL,
+  `LAYER` varchar(50) DEFAULT NULL,
+  `SSJDB` varchar(50) DEFAULT NULL,
+  `AMOUNT` varchar(50) DEFAULT NULL COMMENT '数量',
+  `YJCS` varchar(100) DEFAULT NULL COMMENT '应急措施',
+  `insert_time` datetime DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='加气站信息';
+
+CREATE TABLE `wgh_jxcs` (
+  `OBJECTID` varchar(255) DEFAULT NULL,
+  `JSON_INFO` varchar(255) DEFAULT NULL,
+  `CREAT_TIME` varchar(255) DEFAULT NULL,
+  `SSJD` varchar(255) DEFAULT NULL COMMENT '所属街道',
+  `SSSQ` varchar(255) DEFAULT NULL COMMENT '所属社区',
+  `DLM` varchar(255) DEFAULT NULL COMMENT '道路名',
+  `MPH` varchar(255) DEFAULT NULL COMMENT '门牌号',
+  `NAME` varchar(255) DEFAULT NULL COMMENT '名称',
+  `ZTLX` varchar(255) DEFAULT NULL,
+  `TYPE` varchar(255) DEFAULT NULL COMMENT '子类型',
+  `XYDM` varchar(255) DEFAULT NULL COMMENT '统一社会信用代码',
+  `LXR` varchar(255) DEFAULT NULL COMMENT '联系人',
+  `LXDH` varchar(255) DEFAULT NULL COMMENT '联系电话',
+  `USER_NAME` varchar(255) DEFAULT NULL,
+  `BZ` varchar(255) DEFAULT NULL COMMENT '备注',
+  `AVAILABLE` varchar(255) DEFAULT NULL,
+  `ID` varchar(255) DEFAULT NULL,
+  `USER_ID` varchar(255) DEFAULT NULL COMMENT '编辑人ID',
+  `UPDATE_TIM` varchar(255) DEFAULT NULL COMMENT '编辑人姓名',
+  `INSERT_TIME` varchar(255) DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='九小场所信息';
+
+CREATE TABLE `wgh_jyz` (
+  `OBJECTID` int(11) DEFAULT NULL,
+  `XH` varchar(500) DEFAULT NULL COMMENT '序号',
+  `NAME` varchar(500) DEFAULT NULL COMMENT '单位名称',
+  `AREA` double DEFAULT NULL,
+  `SPACE` varchar(500) DEFAULT NULL COMMENT '周边安全间距',
+  `PROBLEM` varchar(500) DEFAULT NULL COMMENT '存在问题',
+  `TYPE` varchar(500) DEFAULT NULL COMMENT '危险源类型',
+  `LOCATION` varchar(500) DEFAULT NULL COMMENT '经营地址',
+  `PRINCIPAL` varchar(500) DEFAULT NULL COMMENT '负责人',
+  `PHONE` varchar(500) DEFAULT NULL COMMENT '联系电话',
+  `QTYPE` varchar(500) DEFAULT NULL COMMENT '企业类型',
+  `WTYPE` varchar(500) DEFAULT NULL COMMENT '危化品种类',
+  `level` varchar(500) DEFAULT NULL COMMENT '等级',
+  `nature` varchar(500) DEFAULT NULL COMMENT '性质',
+  `remarks` varchar(500) DEFAULT NULL COMMENT '备注',
+  `DWMCJC` varchar(50) DEFAULT NULL,
+  `LAYER` varchar(50) DEFAULT NULL,
+  `SSJDB` varchar(50) DEFAULT NULL,
+  `AMOUNT` varchar(300) DEFAULT NULL COMMENT '数量',
+  `YJCS` varchar(260) DEFAULT NULL COMMENT '应急措施',
+  `insert_time` datetime DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='加油站';
+
+CREATE TABLE `wgh_sjxxb` (
+  `OBJECTID_1` int(11) DEFAULT NULL,
+  `OBJECTID` double DEFAULT NULL,
+  `INFOSOURCENAME` varchar(700) DEFAULT NULL COMMENT '事件来源',
+  `INFOTYPENAME` varchar(700) DEFAULT NULL COMMENT '事件类别',
+  `COMMUNITYNAME` varchar(700) DEFAULT NULL COMMENT '社区名称',
+  `DESCRIPTION` varchar(700) DEFAULT NULL COMMENT '事件描述',
+  `TASKID` varchar(500) DEFAULT NULL,
+  `CASESN` varchar(500) DEFAULT NULL,
+  `ADDRESS` varchar(700) DEFAULT NULL COMMENT '事件地址',
+  `STATUSNAME` varchar(700) DEFAULT NULL COMMENT '事件状态',
+  `INFOBCNAME` varchar(700) DEFAULT NULL,
+  `INFOSCNAME` varchar(700) DEFAULT NULL,
+  `STREETNAME` varchar(700) DEFAULT NULL COMMENT '街道名称',
+  `DISCOVERTIME` datetime DEFAULT NULL,
+  `insert_time` datetime DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='事件信息';
+
+CREATE TABLE `wgh_sqxx` (
+  `OBJECTID` int(11) DEFAULT NULL,
+  `COMMUAREA` double DEFAULT NULL,
+  `BELONGTO` varchar(100) DEFAULT NULL,
+  `CONTACTS` varchar(100) DEFAULT NULL,
+  `TELPHONE` varchar(100) DEFAULT NULL,
+  `number_of_grid` double DEFAULT NULL,
+  `street_code` varchar(100) DEFAULT NULL,
+  `community_code` varchar(100) DEFAULT NULL,
+  `COMMNAME` varchar(200) DEFAULT NULL,
+  `JDCJGB` varchar(200) DEFAULT NULL,
+  `WGZ` varchar(100) DEFAULT NULL,
+  `police_name` varchar(500) DEFAULT NULL,
+  `traffic_police_phone` double DEFAULT NULL,
+  `traffic_police_company` varchar(500) DEFAULT NULL,
+  `peo_police_name` varchar(500) DEFAULT NULL,
+  `peo_police_phone` varchar(500) DEFAULT NULL,
+  `police_station` varchar(500) DEFAULT NULL,
+  `WGY` varchar(200) DEFAULT NULL,
+  `JDLXKS` varchar(200) DEFAULT NULL,
+  `DDY` varchar(200) DEFAULT NULL,
+  `ZHZFXM` varchar(100) DEFAULT NULL,
+  `ZHZFDH` varchar(100) DEFAULT NULL,
+  `ZHZFBM` varchar(100) DEFAULT NULL,
+  `insert_time` datetime DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
+
+CREATE TABLE `wgh_subdistrict_office` (
+  `coordinate_info` text,
+  `street_name` varchar(100) DEFAULT NULL,
+  `street_code` varchar(100) DEFAULT NULL,
+  `longitude` varchar(100) DEFAULT NULL,
+  `latitude` varchar(100) DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
+
+CREATE TABLE `wgh_szcgwgh` (
+  `OBJECTID` int(11) DEFAULT NULL,
+  `NOTE` varchar(200) DEFAULT NULL COMMENT '备注',
+  `SSSQ` varchar(200) DEFAULT NULL,
+  `SSJD` varchar(200) DEFAULT NULL,
+  `ID` varchar(200) DEFAULT NULL,
+  `insert_time` datetime DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='数字城管网格化信息';
+
+CREATE TABLE `wgh_szzrwg` (
+  `OBJECTID` int(11) DEFAULT NULL,
+  `NOTE` varchar(100) DEFAULT NULL COMMENT '备注',
+  `NAME` varchar(100) DEFAULT NULL COMMENT '责任单位',
+  `PRINCIPAL` varchar(100) DEFAULT NULL COMMENT '监管人',
+  `PHONE` varchar(100) DEFAULT NULL COMMENT '联系方式',
+  `insert_time` datetime DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='市政责任网格信息';
+
+CREATE TABLE `wgh_whpdw` (
+  `OBJECTID` int(11) DEFAULT NULL,
+  `XH` varchar(500) DEFAULT NULL COMMENT '序号',
+  `NAME` varchar(500) DEFAULT NULL COMMENT '单位名称',
+  `AREA` double DEFAULT NULL,
+  `SPACE` varchar(500) DEFAULT NULL COMMENT '周边安全间距',
+  `PROBLEM` varchar(500) DEFAULT NULL COMMENT '存在问题',
+  `TYPE` varchar(500) DEFAULT NULL COMMENT '危险源类型',
+  `LOCATION` varchar(500) DEFAULT NULL COMMENT '经营地址',
+  `PERSON` varchar(500) DEFAULT NULL COMMENT '安全负责人',
+  `PHONE` varchar(500) DEFAULT NULL COMMENT '联系电话',
+  `QTYPE` varchar(500) DEFAULT NULL COMMENT '企业类型',
+  `WTYPE` varchar(500) DEFAULT NULL COMMENT '危化品种类',
+  `AMOUNT` varchar(500) DEFAULT NULL COMMENT '数量',
+  `GRADE` varchar(500) DEFAULT NULL COMMENT '等级',
+  `NATRUE` varchar(500) DEFAULT NULL COMMENT '性质',
+  `YJCS` varchar(500) DEFAULT NULL COMMENT '应急措施',
+  `NOTE` varchar(500) DEFAULT NULL COMMENT '备注',
+  `DWMCJC` varchar(100) DEFAULT NULL,
+  `PRINCIPAL` varchar(500) DEFAULT NULL COMMENT '主要负责人',
+  `USER` varchar(500) DEFAULT NULL COMMENT '用途',
+  `LAYER` varchar(100) DEFAULT NULL,
+  `SSJDB` varchar(100) DEFAULT NULL,
+  `insert_time` timestamp NULL DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='危化品单位信息';
+
+CREATE TABLE `wgh_yjbmcs` (
+  `OBJECTID` int(11) DEFAULT NULL,
+  `GRADE` varchar(500) DEFAULT NULL,
+  `ADRESS` varchar(500) DEFAULT NULL COMMENT '地址',
+  `AREA` varchar(500) DEFAULT NULL COMMENT '面积(㎡)',
+  `RNNS` varchar(500) DEFAULT NULL COMMENT '容纳人数',
+  `SFBSP` varchar(500) DEFAULT NULL,
+  `ZYSBCS` varchar(500) DEFAULT NULL,
+  `FZR` varchar(500) DEFAULT NULL,
+  `ZGDW` varchar(500) DEFAULT NULL,
+  `NAME` varchar(500) DEFAULT NULL,
+  `FZRTEL` varchar(100) DEFAULT NULL,
+  `SSJD` varchar(100) DEFAULT NULL,
+  `INSERT_TIME` timestamp NULL DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='应急避难场所信息';
+
+CREATE TABLE `wgh_yqhjz` (
+  `OBJECTID` int(11) DEFAULT NULL,
+  `XH` varchar(1000) DEFAULT NULL COMMENT '序号',
+  `NAME` varchar(1000) DEFAULT NULL COMMENT '单位名称',
+  `AREA` double DEFAULT NULL,
+  `SPACE` varchar(1000) DEFAULT NULL COMMENT '周边安全间距',
+  `TYPE` varchar(1000) DEFAULT NULL COMMENT '危险源类型',
+  `LOCATION` varchar(1000) DEFAULT NULL COMMENT '经营地址',
+  `PRINCIPAL` varchar(1000) DEFAULT NULL COMMENT '负责人',
+  `PHONE` varchar(1000) DEFAULT NULL COMMENT '联系电话',
+  `QTYPE` varchar(1000) DEFAULT NULL COMMENT '企业类型',
+  `WTYPE` varchar(1000) DEFAULT NULL COMMENT '危化品种类',
+  `AMOUNT` varchar(1000) DEFAULT NULL COMMENT '数量',
+  `GRADE` varchar(1000) DEFAULT NULL COMMENT '等级',
+  `NATRUE` varchar(1000) DEFAULT NULL COMMENT '性质',
+  `YJCS` varchar(1000) DEFAULT NULL COMMENT '应急措施',
+  `NOTE` varchar(1000) DEFAULT NULL COMMENT '备注',
+  `DWMCJC` varchar(100) DEFAULT NULL COMMENT '简称',
+  `LAYER` varchar(100) DEFAULT NULL COMMENT '所在图层',
+  `SSJDB` varchar(100) DEFAULT NULL COMMENT '所属街道办',
+  `PROBLEM` varchar(100) DEFAULT NULL COMMENT '存在问题',
+  `insert_time` timestamp NULL DEFAULT NULL COMMENT '插入日期'
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='油气合建站信息';
+
+CREATE ALGORITHM = UNDEFINED DEFINER = `root` @`%` SQL SECURITY DEFINER VIEW `view_grid_comm_street` AS SELECT
+`g4`.`grid_id` AS `grid_id`,
+`g4`.`grid_name` AS `grid_name`,
+`g3`.`grid_id` AS `community_id`,
+`g3`.`grid_name` AS `community_name`,
+`g2`.`grid_id` AS `street_id`,
+`g2`.`grid_name` AS `street_name`,
+concat( `g2`.`grid_id`, ':', `g3`.`grid_id`, ':', `g4`.`grid_id` ) AS `grid_id_path`
+FROM
+	((
+			`ca_bm_grid` `g4`
+			JOIN `ca_bm_grid` `g3` ON (((
+						`g3`.`grid_id` = `g4`.`parent_id`
+						)
+					AND ( `g3`.`grid_level` = 'level3' )
+				AND ( `g3`.`delete_flag` = 'normal' ))))
+		JOIN `ca_bm_grid` `g2` ON (((
+					`g2`.`grid_id` = `g3`.`parent_id`
+					)
+				AND ( `g2`.`grid_level` = 'level2' )
+			AND ( `g2`.`delete_flag` = 'normal' ))))
+WHERE
+	((
+			`g4`.`grid_level` = 'level4'
+		)
+	AND ( `g4`.`delete_flag` = 'normal' ))