{
+}
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/resipartymember/ResiPartymemberDao.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/resipartymember/ResiPartymemberDao.java
new file mode 100644
index 0000000000..06429e42db
--- /dev/null
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/resipartymember/ResiPartymemberDao.java
@@ -0,0 +1,31 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dataaggre.dao.resipartymember;
+
+import com.epmet.dataaggre.dto.datastats.form.NowStatsDataFormDTO;
+import com.epmet.dataaggre.dto.datastats.result.NowStatsDataResultDTO;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+@Mapper
+public interface ResiPartymemberDao {
+
+ List getNowPart(NowStatsDataFormDTO formDTO);
+
+}
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/epmetuser/IcResiUserEntity.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/epmetuser/IcResiUserEntity.java
index 657b37bb14..517b65938a 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/epmetuser/IcResiUserEntity.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/epmetuser/IcResiUserEntity.java
@@ -215,6 +215,21 @@ public class IcResiUserEntity extends BaseEpmetEntity {
*/
private String isSpecial;
+ /**
+ * 是否租户【是:1 否:0】
+ */
+ private String isTenant;
+
+ /**
+ * 是否流动人口【是:1 否:0】
+ */
+ private String isFloating;
+
+ /**
+ * 是否新阶层人士【是:1 否:0】
+ */
+ private String isXjc;
+
/**
* 文化程度【字典表】
*/
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/epmetuser/RegisterRelationEntity.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/epmetuser/RegisterRelationEntity.java
index 4c21db9b8d..60ee1dc873 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/epmetuser/RegisterRelationEntity.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/epmetuser/RegisterRelationEntity.java
@@ -40,6 +40,16 @@ public class RegisterRelationEntity extends BaseEpmetEntity {
*/
private String customerId;
+ /**
+ * 所属组织机构Id
+ */
+ private String agencyId;
+
+ /**
+ * agencyId的所有上级,包含自己
+ */
+ private String agencyIdPath;
+
/**
* 网格Id (customer_grid.id)
*/
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcCityManagementEntity.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcCityManagementEntity.java
index a1baff300a..fff25b16f4 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcCityManagementEntity.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcCityManagementEntity.java
@@ -73,4 +73,14 @@ public class IcCityManagementEntity extends BaseEpmetEntity {
*/
private String latitude;
+ /**
+ * 联系人
+ */
+ private String principal;
+
+ /**
+ * 联系电话
+ */
+ private String mobile;
+
}
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcCoverageCategoryDictEntity.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcCoverageCategoryDictEntity.java
index cdaca78b91..bc0ae5c9e2 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcCoverageCategoryDictEntity.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcCoverageCategoryDictEntity.java
@@ -43,11 +43,23 @@ public class IcCoverageCategoryDictEntity extends BaseEpmetEntity {
*/
private String placeType;
+ /**
+ * 在可视化系统中所属的plact_type,跟COVERAGE_TYPE可能不同,COVERAGE_TYPE是给管理平台用的
+ */
+ private String placeTypeInAnalysis;
+
+ /**
+ * 要跟菜单绑定(客户配置了这个菜单,这里才显示)
+ */
+ private String menuUrl;
+
/**
* 所属五大图层:zhzl:综合治理图层;yjcl:应急处置图层;aqsc:安全生产图层;csgl:城市管理图层;ggfw:公共服务图层
*/
private String coverageType;
+ private String dataType;
+
/**
* 排序
*/
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcPublicServiceEntity.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcPublicServiceEntity.java
index 6a454c446b..1422ac76ad 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcPublicServiceEntity.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/govorg/IcPublicServiceEntity.java
@@ -73,4 +73,14 @@ public class IcPublicServiceEntity extends BaseEpmetEntity {
*/
private String latitude;
+ /**
+ * 联系人
+ */
+ private String principal;
+
+ /**
+ * 联系电话
+ */
+ private String mobile;
+
}
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/opercustomize/IcResiCategoryWarnConfigEntity.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/opercustomize/IcResiCategoryWarnConfigEntity.java
new file mode 100644
index 0000000000..0738f7e37a
--- /dev/null
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/entity/opercustomize/IcResiCategoryWarnConfigEntity.java
@@ -0,0 +1,86 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dataaggre.entity.opercustomize;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.epmet.commons.mybatis.entity.BaseEpmetEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 居民类别预警配置表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2021-11-04
+ */
+@Data
+@EqualsAndHashCode(callSuper=false)
+@TableName("ic_resi_category_warn_config")
+public class IcResiCategoryWarnConfigEntity extends BaseEpmetEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 客户id
+ */
+ private String customerId;
+
+ /**
+ * 项标签
+ */
+ private String label;
+
+ /**
+ * 表名
+ */
+ private String tableName;
+
+ /**
+ * 列名
+ */
+ private String columnName;
+ /**
+ * 是否预警 1 是 0 否
+ */
+ private String warn;
+
+ /**
+ * 排序
+ */
+ private Integer sort;
+
+ /**
+ * 等级1阈值
+ */
+ @TableField(value = "LEVEL_1")
+ private Integer level1;
+
+ /**
+ * 等级2阈值
+ */
+ @TableField(value = "LEVEL_2")
+ private Integer level2;
+
+ /**
+ * 等级3阈值
+ */
+ @TableField(value = "LEVEL_3")
+ private Integer level3;
+
+}
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/excel/NowStatsDataExcel.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/excel/NowStatsDataExcel.java
new file mode 100644
index 0000000000..0df02e5ab5
--- /dev/null
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/excel/NowStatsDataExcel.java
@@ -0,0 +1,68 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+
+package com.epmet.dataaggre.excel;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.alibaba.excel.annotation.write.style.ColumnWidth;
+import lombok.Data;
+
+@Data
+public class NowStatsDataExcel {
+
+ //组织、网格名称
+ @ExcelProperty(value = "组织名称")
+ @ColumnWidth(25)
+ private String orgName;
+ //注册居民数
+ @ExcelProperty(value = "注册居民数")
+ @ColumnWidth(20)
+ private Integer resiUserCount;
+ //注册党员数
+ @ExcelProperty(value = "注册党员数")
+ @ColumnWidth(20)
+ private Integer partyMemberCount;
+ //事件总数
+ @ExcelProperty(value = "事件总数")
+ @ColumnWidth(20)
+ private Integer icEventCount;
+ //居民上报事件数【小程序端随手拍随时讲】
+ @ExcelProperty(value = "居民上报事件数")
+ @ColumnWidth(20)
+ private Integer resiEventCount;
+ //平台录入事件数【数字平台录入的事件数】
+ @ExcelProperty(value = "平台录入事件数")
+ @ColumnWidth(20)
+ private Integer pcEventCount;
+ //项目总数
+ @ExcelProperty(value = "项目总数")
+ @ColumnWidth(20)
+ private Integer projectCount;
+ //议题转项目数
+ @ExcelProperty(value = "议题转项目数")
+ @ColumnWidth(20)
+ private Integer issueProjectCount;
+ //事件立项数
+ @ExcelProperty(value = "事件立项数")
+ @ColumnWidth(20)
+ private Integer icEventProjectCount;
+ //直接立项项目数
+ @ExcelProperty(value = "立项数")
+ @ColumnWidth(20)
+ private Integer agencyProjectCount;
+
+}
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/redis/GovCustomerMenuRedis.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/redis/GovCustomerMenuRedis.java
new file mode 100644
index 0000000000..5038e14a7c
--- /dev/null
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/redis/GovCustomerMenuRedis.java
@@ -0,0 +1,109 @@
+package com.epmet.dataaggre.redis;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.alibaba.fastjson.JSON;
+import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.exception.EpmetException;
+import com.epmet.commons.tools.redis.RedisKeys;
+import com.epmet.commons.tools.redis.RedisUtils;
+import com.epmet.commons.tools.utils.ConvertUtils;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.GovMenuDTO;
+import com.epmet.dto.form.GetCustomerMenuListFormDTO;
+import com.epmet.feign.GovAccessFeignClient;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 客户菜单配置表
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2021-03-16
+ */
+@Slf4j
+@Component
+public class GovCustomerMenuRedis {
+ @Autowired
+ private RedisUtils redisUtils;
+
+ @Autowired
+ private GovAccessFeignClient govAccessFeignClient;
+
+ /**
+ * Desc: 保存客户菜单缓存
+ * @param customerId
+ * @param type
+ * @param govMenuDTOS
+ * @author zxc
+ * @date 2022/7/27 13:45
+ */
+ public void setCustomerMenuList(String customerId, Integer type, List govMenuDTOS) {
+ if (checkParam(customerId, type) && !CollectionUtils.isEmpty(govMenuDTOS) && StringUtils.isNotBlank(govMenuDTOS.get(NumConstant.ZERO).getName())) {
+ String key = RedisKeys.getCustomerMenuListFiveCoverage().concat(customerId);
+ govMenuDTOS.forEach(g -> {
+ Map map = BeanUtil.beanToMap(g, false, true);
+ redisUtils.listAdd(key,map);
+ });
+ }
+ }
+
+ /**
+ * Desc: 获取客户菜单缓存
+ * @param customerId
+ * @param type
+ * @param tableName
+ * @author zxc
+ * @date 2022/7/27 13:45
+ */
+ public List getCustomerMenuList(String customerId, Integer type, String tableName) {
+ if (checkParam(customerId, type)) {
+ String key = RedisKeys.getCustomerMenuListFiveCoverage().concat(customerId);
+ List result = new ArrayList<>();
+ List