Merge branch 'dev_export_excel' into dev

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/ExcelUtils.java

@@ -14,11 +14,13 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.ss.usermodel.Sheet;
 import org.apache.poi.ss.usermodel.Workbook;
 import org.springframework.beans.BeanUtils;
+import org.springframework.util.CollectionUtils;
 
 import javax.servlet.ServletOutputStream;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Date;
@@ -80,4 +82,44 @@ public class ExcelUtils {
 
         exportExcel(response, fileName, targetList, targetClass);
     }
+
+    public static void exportExcelToTargetDisposeAll(HttpServletResponse response, String fileName, Collection<?> sourceList,
+                                           Class<?> targetClass) throws Exception {
+        if (!CollectionUtils.isEmpty(sourceList)){
+            List<Object> targetList = new ArrayList<>(sourceList.size());
+            for(Object source : sourceList){
+                Object target = targetClass.newInstance();
+                BeanUtils.copyProperties(source, target);
+                targetList.add(target);
+            }
+            exportExcelDispose(response, fileName, targetList, targetClass);
+        }else {
+            exportExcelDispose(response, fileName, new ArrayList<>(), targetClass);
+        }
+
+
+    }
+
+    public static void exportExcelDispose(HttpServletResponse response, String fileName, Collection<?> list,
+                                   Class<?> pojoClass) throws IOException {
+        if(StringUtils.isBlank(fileName)){
+            //当前日期
+            fileName = DateUtils.format(new Date());
+        }
+        ExportParams params = new ExportParams(fileName,fileName);
+        Workbook workbook = ExcelExportUtil.exportExcel(params, pojoClass, list);
+        Sheet sheet1 = workbook.getSheetAt(0);
+        sheet1.setDefaultColumnWidth(50*256);
+        sheet1.setDefaultRowHeight((short)(2*256));
+        response.setCharacterEncoding("UTF-8");
+        response.setHeader("content-Type", "application/vnd.ms-excel");
+        fileName = fileName + ".xls";
+        response.setHeader("Content-Disposition",
+                "attachment;filename=" +fileName);
+        ServletOutputStream out = response.getOutputStream();
+        workbook.write(out);
+        out.flush();
+        out.close();
+    }
+
 }

epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/datastats/form/CustomerDataManageFormDTO.java

@@ -0,0 +1,67 @@
+package com.epmet.dataaggre.dto.datastats.form;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @Author zxc
+ * @DateTime 2021/9/10 11:04 上午
+ * @DESC
+ */
+@Data
+public class CustomerDataManageFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 6462094914874831738L;
+
+    public interface CustomerDataManageForm{}
+
+    /**
+     * 客户ID
+     */
+    @NotBlank(message = "客户ID不能为空",groups = CustomerDataManageForm.class)
+    private String customerId;
+
+    /**
+     * 组织ID
+     */
+    @NotBlank(message = "组织ID不能为空",groups = CustomerDataManageForm.class)
+    private String agencyId;
+
+    /**
+     * 区间:Interval  截止:end
+     */
+    @NotBlank(message = "type不能为空",groups = CustomerDataManageForm.class)
+    private String type;
+
+    /**
+     * 开始时间【yyyymmdd】
+     */
+    private String startTime;
+
+    /**
+     * 结束时间【yyyymmdd】
+     */
+    @NotBlank(message = "结束时间不能为空",groups = CustomerDataManageForm.class)
+    private String endTime;
+
+    private Integer pageNo = 1;
+
+    private Integer pageSize = 20;
+
+    /**
+     * 是否分页【true分  false不分】
+     */
+    @NotNull(message = "是否分页不能为空",groups = CustomerDataManageForm.class)
+    private Boolean isPage;
+
+    //组织或网格Id集合
+    private List<String> idList;
+    //按起始时间还是结束时间查数据【start end】
+    private String sourceType;
+    //数据类型【组织agency 网格grid】
+    private String dataType;
+}

epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/datastats/result/CustomerDataManageResultDTO.java

@@ -0,0 +1,57 @@
+package com.epmet.dataaggre.dto.datastats.result;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Description 运营情况数据导出-接口返参
+ * @Auth sun
+ */
+@Data
+public class CustomerDataManageResultDTO {
+
+    List<CustomerDataManage> list = new ArrayList<>();
+    private Integer total;
+
+    @Data
+    public static class CustomerDataManage {
+        //组织、网格Id
+        private String orgId;
+        //组织、网格名称
+        private String orgName;
+        //用户数
+        private Integer userCount = 0;
+        //居民数
+        private Integer residentCount = 0;
+        //党员数
+        private Integer partyMemberCount = 0;
+        //小组数
+        private Integer groupCount = 0;
+        //话题数
+        private Integer topicCount = 0;
+        //议题数
+        private Integer issueCount = 0;
+        //项目数
+        private Integer projectCount = 0;
+        //结案项目数
+        private Integer closedProjectCount = 0;
+        //巡查人数
+        private Integer patrolPeopleCount = 0;
+        //巡查次数
+        private Integer patrolCount = 0;
+        //巡查时长
+        private String patrolDuration;
+        //未转换前的巡查时长
+        private Integer patrolDurationInteger = 0;
+        //数据对应dateId
+        @JsonIgnore
+        private String dateId;
+        @JsonIgnore
+        private String staffId;
+    }
+
+
+}

epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/evaluationindex/ScreenAgencyOrGridListDTO.java

@@ -0,0 +1,27 @@
+package com.epmet.dataaggre.dto.evaluationindex;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @author sun
+ * @Description 根据组织Id判断查询直属下级组织/网格列表，组织存在子客户的查询包含子客户组织数据
+ */
+@Data
+public class ScreenAgencyOrGridListDTO implements Serializable {
+    private static final long serialVersionUID = 6328123559936824470L;
+    //组织级别（社区级：community，乡（镇、街道）级:street,区县级: district,市级: city,省级:province）
+    private String level;
+    //直属下级组织或网格集合
+    private List<AgencyGrid> agencyGridList;
+
+    @Data
+    public static class AgencyGrid {
+        //组织id
+        private String orgId;
+        //组织名称
+        private String orgName;
+    }
+}

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/controller/DataStatsController.java

@@ -1,18 +1,21 @@
 package com.epmet.dataaggre.controller;
 
 import com.epmet.commons.tools.exception.RenException;
+import com.epmet.commons.tools.utils.ExcelUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.validator.ValidatorUtils;
 import com.epmet.dataaggre.dto.datastats.form.*;
 import com.epmet.dataaggre.dto.datastats.result.*;
+import com.epmet.dataaggre.excel.CustomerDataManageExcel;
 import com.epmet.dataaggre.service.datastats.DataStatsService;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletResponse;
+import java.text.ParseException;
+import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @Author sun
@@ -215,4 +218,28 @@ public class DataStatsController {
         return new Result<GovrnRatioResultDTO>().ok(dataStatsService.governRatio(formDTO));
     }
 
+    /**
+     * @Description 客户数据管理导出
+     * @Param formDTO
+     * @Param response
+     * @author zxc
+     * @date 2021/9/10 3:52 下午
+     */
+    @PostMapping("operateexport")
+    public void CustomerDataManage(@RequestBody CustomerDataManageFormDTO formDTO, HttpServletResponse response) throws Exception {
+        ValidatorUtils.validateEntity(formDTO, CustomerDataManageFormDTO.CustomerDataManageForm.class);
+        dataStatsService.CustomerDataManage(formDTO,response);
+    }
+
+    /**
+     * @Param formDTO
+     * @Description 运营情况数据查询
+     * @author sun
+     */
+    @PostMapping("operatedata")
+    public Result<CustomerDataManageResultDTO> operatedata(@RequestBody CustomerDataManageFormDTO formDTO) throws ParseException {
+        ValidatorUtils.validateEntity(formDTO, CustomerDataManageFormDTO.CustomerDataManageForm.class);
+        return new Result<CustomerDataManageResultDTO>().ok(dataStatsService.operateExport(formDTO));
+    }
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/datastats/DataStatsDao.java

@@ -18,6 +18,7 @@
 package com.epmet.dataaggre.dao.datastats;
 
 import com.epmet.dataaggre.dto.datastats.FactGroupActDailyDTO;
+import com.epmet.dataaggre.dto.datastats.form.CustomerDataManageFormDTO;
 import com.epmet.dataaggre.dto.datastats.form.SubAgencyFormDTO;
 import com.epmet.dataaggre.dto.datastats.form.SubGridFormDTO;
 import com.epmet.dataaggre.dto.datastats.result.*;
@@ -308,4 +309,30 @@ public interface DataStatsDao {
      * @author sun
      */
     List<GridMemberPatrolListResultDTO> selectGirdMemberPatrol(GridMemberPatrolListFormDTO formDTO);
+
+    /**
+     * @Description 直属组织或网格下注册用户数据
+     * @author sun
+     */
+    List<CustomerDataManageResultDTO.CustomerDataManage> regUserList(CustomerDataManageFormDTO formDTO);
+    /**
+     * @Description 直属组织或网格下群组数据
+     * @author sun
+     */
+    List<CustomerDataManageResultDTO.CustomerDataManage> groupList(CustomerDataManageFormDTO formDTO);
+    /**
+     * @Description 直属组织或网格下话题数据
+     * @author sun
+     */
+    List<CustomerDataManageResultDTO.CustomerDataManage> topicList(CustomerDataManageFormDTO formDTO);
+    /**
+     * @Description 直属组织或网格下议题数据
+     * @author sun
+     */
+    List<CustomerDataManageResultDTO.CustomerDataManage> issueList(CustomerDataManageFormDTO formDTO);
+    /**
+     * @Description 直属组织或网格下项目数据
+     * @author sun
+     */
+    List<CustomerDataManageResultDTO.CustomerDataManage> projectList(CustomerDataManageFormDTO formDTO);
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/epmetuser/StatsStaffPatrolRecordDailyDao.java

@@ -19,6 +19,8 @@ package com.epmet.dataaggre.dao.epmetuser;
 
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dataaggre.dto.datastats.form.CustomerDataManageFormDTO;
+import com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO;
 import com.epmet.dataaggre.dto.epmetuser.result.PatrolDailySumResult;
 import com.epmet.dataaggre.entity.epmetuser.StatsStaffPatrolRecordDailyEntity;
 import org.apache.ibatis.annotations.Mapper;
@@ -43,4 +45,10 @@ public interface StatsStaffPatrolRecordDailyDao extends BaseDao<StatsStaffPatrol
      * @return
      */
     List<PatrolDailySumResult> getPatrolSumList(@Param("agencyFullIdList") List<String> agencyFullIdList, @Param("startDateId") String startDateId, @Param("endDateId") String endDateId);
+
+    /**
+     * @Description 直属组织或网格下巡查数据
+     * @author sun
+     */
+    List<CustomerDataManageResultDTO.CustomerDataManage> patrolList(CustomerDataManageFormDTO formDTO);
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/evaluationindex/EvaluationIndexDao.java

@@ -95,4 +95,12 @@ public interface EvaluationIndexDao {
      */
     List<ScreenCustomerAgencyDTO> getSubAgencyListByAgency(@Param("agencyId") String agencyId, @Param("areaCode") String areaCode, @Param("list") List<String> list);
 
+    /**
+     * @Description  根据组织ID查询组织名
+     * @Param agencyId
+     * @author zxc
+     * @date 2021/9/10 3:54 下午
+     */
+    String selectAgencyNameByAgencyId(@Param("agencyId")String agencyId);
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/excel/CustomerDataManageExcel.java

@@ -0,0 +1,55 @@
+package com.epmet.dataaggre.excel;
+
+import cn.afterturn.easypoi.excel.annotation.Excel;
+import lombok.Data;
+
+/**
+ * @Author zxc
+ * @DateTime 2021/9/10 10:15 上午
+ * @DESC
+ */
+@Data
+public class CustomerDataManageExcel {
+
+    @Excel(name = "组织")
+    private String orgName;
+
+    @Excel(name = "用户数")
+    private Integer userCount;
+
+    @Excel(name = "居民数")
+    private Integer residentCount;
+
+    @Excel(name = "党员数")
+    private Integer partyMemberCount;
+
+    @Excel(name = "小组数")
+    private Integer groupCount;
+
+    @Excel(name = "话题数")
+    private Integer topicCount;
+
+    @Excel(name = "议题数")
+    private Integer issueCount;
+
+    @Excel(name = "项目数")
+    private Integer projectCount;
+
+    @Excel(name = "结案项目数")
+    private Integer closedProjectCount;
+
+    @Excel(name = "巡查人数")
+    private Integer patrolPeopleCount;
+
+    @Excel(name = "巡查次数")
+    private Integer patrolCount;
+
+    @Excel(name = "巡查时长")
+    private String patrolDuration;
+
+    /**
+     * 未转换前的巡查时长
+     */
+    private Integer patrolDurationInteger;
+
+}

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/datastats/DataStatsService.java

@@ -9,6 +9,8 @@ import com.epmet.dataaggre.dto.govorg.result.GridMemberDataAnalysisResultDTO;
 import com.epmet.dataaggre.dto.resigroup.ActCategoryDictDTO;
 import com.epmet.dataaggre.dto.resigroup.result.GroupActRankDetailDTO;
 
+import javax.servlet.http.HttpServletResponse;
+import java.text.ParseException;
 import java.util.List;
 
 /**
@@ -229,4 +231,20 @@ public interface DataStatsService {
      * @author sun
      */
     List<GridMemberPatrolListResultDTO> getGirdMemberPatrol(GridMemberPatrolListFormDTO formDTO);
+
+    /**
+     * @Description 客户数据管理导出
+     * @Param formDTO
+     * @Param response
+     * @author zxc
+     * @date 2021/9/10 3:52 下午
+     */
+    void CustomerDataManage(CustomerDataManageFormDTO formDTO, HttpServletResponse response) throws Exception;
+
+    /**
+     * @Description 运营情况数据查询
+     * @author sun
+     */
+    CustomerDataManageResultDTO operateExport(CustomerDataManageFormDTO formDTO) throws ParseException;
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/datastats/impl/DataStatsServiceImpl.java

@@ -2,47 +2,53 @@
 
  import com.alibaba.fastjson.JSON;
  import com.epmet.commons.dynamic.datasource.annotation.DataSource;
-import com.epmet.commons.tools.constant.NumConstant;
+ import com.epmet.commons.tools.constant.NumConstant;
  import com.epmet.commons.tools.constant.StrConstant;
  import com.epmet.commons.tools.enums.OrgLevelEnum;
-import com.epmet.commons.tools.utils.DateUtils;
-import com.epmet.dataaggre.constant.DataSourceConstant;
-import com.epmet.dataaggre.constant.OrgConstant;
-import com.epmet.dataaggre.dao.datastats.DataStatsDao;
-import com.epmet.dataaggre.dao.datastats.FactGridMemberStatisticsDailyDao;
-import com.epmet.dataaggre.dto.datastats.FactGroupActDailyDTO;
-import com.epmet.dataaggre.dto.datastats.form.*;
-import com.epmet.dataaggre.dto.datastats.result.*;
+ import com.epmet.commons.tools.exception.RenException;
+ import com.epmet.commons.tools.utils.DateUtils;
+ import com.epmet.commons.tools.utils.ExcelUtils;
+ import com.epmet.dataaggre.constant.DataSourceConstant;
+ import com.epmet.dataaggre.constant.OrgConstant;
+ import com.epmet.dataaggre.dao.datastats.DataStatsDao;
+ import com.epmet.dataaggre.dao.datastats.FactGridMemberStatisticsDailyDao;
+ import com.epmet.dataaggre.dto.datastats.FactGroupActDailyDTO;
+ import com.epmet.dataaggre.dto.datastats.form.*;
+ import com.epmet.dataaggre.dto.datastats.result.*;
  import com.epmet.dataaggre.dto.epmetuser.form.GridMemberPatrolListFormDTO;
  import com.epmet.dataaggre.dto.epmetuser.result.GridMemberPatrolListResultDTO;
  import com.epmet.dataaggre.dto.epmetuser.result.PatrolDailySumResult;
-import com.epmet.dataaggre.dto.evaluationindex.ScreenCustomerAgencyDTO;
-import com.epmet.dataaggre.dto.evaluationindex.ScreenCustomerGridDTO;
-import com.epmet.dataaggre.dto.evaluationindex.ScreenGovernRankDataDailyDTO;
-import com.epmet.dataaggre.dto.govorg.result.GridMemberDataAnalysisResultDTO;
-import com.epmet.dataaggre.dto.resigroup.ActCategoryDictDTO;
-import com.epmet.dataaggre.dto.resigroup.result.GroupActRankDetailDTO;
-import com.epmet.dataaggre.entity.datastats.DimAgencyEntity;
-import com.epmet.dataaggre.entity.datastats.FactAgencyGovernDailyEntity;
-import com.epmet.dataaggre.service.datastats.DataStatsService;
-import com.epmet.dataaggre.service.epmetuser.StatsStaffPatrolRecordDailyService;
-import com.epmet.dataaggre.service.evaluationindex.EvaluationIndexService;
-import com.epmet.dataaggre.service.opercrm.CustomerRelation;
-import com.github.pagehelper.PageHelper;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import java.math.BigDecimal;
-import java.math.RoundingMode;
-import java.text.NumberFormat;
-import java.text.SimpleDateFormat;
-import java.util.*;
-import java.util.concurrent.atomic.AtomicInteger;
-import java.util.concurrent.atomic.AtomicReference;
-import java.util.stream.Collectors;
+ import com.epmet.dataaggre.dto.evaluationindex.ScreenAgencyOrGridListDTO;
+ import com.epmet.dataaggre.dto.evaluationindex.ScreenCustomerAgencyDTO;
+ import com.epmet.dataaggre.dto.evaluationindex.ScreenCustomerGridDTO;
+ import com.epmet.dataaggre.dto.evaluationindex.ScreenGovernRankDataDailyDTO;
+ import com.epmet.dataaggre.dto.govorg.result.GridMemberDataAnalysisResultDTO;
+ import com.epmet.dataaggre.dto.resigroup.ActCategoryDictDTO;
+ import com.epmet.dataaggre.dto.resigroup.result.GroupActRankDetailDTO;
+ import com.epmet.dataaggre.entity.datastats.DimAgencyEntity;
+ import com.epmet.dataaggre.entity.datastats.FactAgencyGovernDailyEntity;
+ import com.epmet.dataaggre.excel.CustomerDataManageExcel;
+ import com.epmet.dataaggre.service.datastats.DataStatsService;
+ import com.epmet.dataaggre.service.epmetuser.StatsStaffPatrolRecordDailyService;
+ import com.epmet.dataaggre.service.evaluationindex.EvaluationIndexService;
+ import com.epmet.dataaggre.service.opercrm.CustomerRelation;
+ import com.github.pagehelper.PageHelper;
+ import lombok.extern.slf4j.Slf4j;
+ import org.apache.commons.collections4.CollectionUtils;
+ import org.apache.commons.lang3.StringUtils;
+ import org.springframework.beans.factory.annotation.Autowired;
+ import org.springframework.stereotype.Service;
+
+ import javax.servlet.http.HttpServletResponse;
+ import java.math.BigDecimal;
+ import java.math.RoundingMode;
+ import java.text.NumberFormat;
+ import java.text.ParseException;
+ import java.text.SimpleDateFormat;
+ import java.util.*;
+ import java.util.concurrent.atomic.AtomicInteger;
+ import java.util.concurrent.atomic.AtomicReference;
+ import java.util.stream.Collectors;
 
 /**
  * @Author sun
@@ -1841,4 +1847,258 @@ public class DataStatsServiceImpl implements DataStatsService {
         return dataStatsDao.selectGirdMemberPatrol(formDTO);
     }
 
+    /**
+     * @Description 客户数据管理导出
+     * @Param formDTO
+     * @Param response
+     * @author zxc
+     * @date 2021/9/10 3:52 下午
+     */
+    @Override
+    public void CustomerDataManage(CustomerDataManageFormDTO formDTO, HttpServletResponse response) throws Exception {
+        List<CustomerDataManageResultDTO.CustomerDataManage> result = operateExport(formDTO).getList();
+        if (!CollectionUtils.isEmpty(result)){
+            CustomerDataManageResultDTO.CustomerDataManage c = new CustomerDataManageResultDTO.CustomerDataManage();
+            c.setOrgName("合计");
+            c.setUserCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getUserCount)));
+            c.setResidentCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getResidentCount)));
+            c.setPartyMemberCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getPartyMemberCount)));
+            c.setGroupCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getGroupCount)));
+            c.setTopicCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getTopicCount)));
+            c.setIssueCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getIssueCount)));
+            c.setProjectCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getProjectCount)));
+            c.setClosedProjectCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getClosedProjectCount)));
+            c.setPatrolPeopleCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getPatrolPeopleCount)));
+            c.setPatrolCount(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getPatrolCount)));
+            c.setPatrolDurationInteger(result.stream().collect(Collectors.summingInt(CustomerDataManageResultDTO.CustomerDataManage::getPatrolDurationInteger)));
+            c.setPatrolDuration(getHm(c.getPatrolDurationInteger()));
+            result.add(c);
+        }
+        String fileName = excelName(formDTO);
+        ExcelUtils.exportExcelToTargetDisposeAll(response,fileName,result, CustomerDataManageExcel.class);
+    }
+
+    /**
+     * @Description  秒转换时分
+     * @Param seconds
+     * @author zxc
+     * @date 2021/9/13 10:03 上午
+     */
+    public String getHm(Integer seconds){
+        String result = "0分钟";
+        if (seconds >= NumConstant.SIXTY) {
+            Integer hours = seconds / 3600;
+            Integer minutes = seconds % 3600 / 60;
+            result = (hours < NumConstant.ONE ? "" : hours + "小时") + (minutes < NumConstant.ONE ? "" : minutes + "分钟");
+        }else if (seconds < NumConstant.SIXTY && seconds > NumConstant.ZERO){
+            result = "1分钟";
+        }
+        return result;
+    }
+
+    /**
+     * @Description  表头获取
+     * @Param formDTO
+     * @author zxc
+     * @date 2021/9/13 10:02 上午
+     */
+    public String excelName(CustomerDataManageFormDTO formDTO){
+        StringBuffer s = new StringBuffer();
+        String agencyName = indexService.selectAgencyNameByAgencyId(formDTO.getAgencyId());
+        s.append(agencyName);
+        if (StringUtils.isNotBlank(formDTO.getStartTime())){
+            String startTime = formDTO.getStartTime();
+            String sYear = startTime.substring(0, 4);
+            String sMonth = startTime.substring(4, 6);
+            String sDay = startTime.substring(6, 8);
+            String endTime = formDTO.getEndTime();
+            String eYear = endTime.substring(0, 4);
+            String eMonth = endTime.substring(4, 6);
+            String eDay = endTime.substring(6, 8);
+            s.append(sYear).append("年").append(sMonth).append("月").append(sDay).append("日-")
+                    .append(eYear).append("年").append(eMonth).append("月").append(eDay).append("日区间新增值");
+        }else {
+            String endTime = formDTO.getEndTime();
+            String eYear = endTime.substring(0, 4);
+            String eMonth = endTime.substring(4, 6);
+            String eDay = endTime.substring(6, 8);
+            s.append(eYear).append("年").append(eMonth).append("月").append(eDay).append("日截止累计值");
+        }
+        return s.toString();
+    }
+
+    /**
+     * @Param formDTO
+     * @Description 运营情况数据查询
+     * @author sun
+     */
+    @Override
+    public CustomerDataManageResultDTO operateExport(CustomerDataManageFormDTO formDTO) throws ParseException {
+        CustomerDataManageResultDTO resultDTO = new CustomerDataManageResultDTO();
+        List<CustomerDataManageResultDTO.CustomerDataManage> dataManageList = new ArrayList<>();
+        //1.必要参数校验及处理
+        if ("Interval".equals(formDTO.getType()) && StringUtils.isEmpty(formDTO.getStartTime())) {
+            throw new RenException("请选择开始时间或查询累计值");
+        }
+        //入参有开始时间的则需要减去一天
+        if (StringUtils.isNotBlank(formDTO.getStartTime())) {
+            SimpleDateFormat format = new SimpleDateFormat(DateUtils.DATE_PATTERN_YYYYMMDD);
+            Date date = format.parse(formDTO.getStartTime());
+            Date yesterday = DateUtils.addDateDays(date, -1);
+            formDTO.setStartTime(format.format(yesterday));
+        }
+
+        //2.查询组织信息，判断查询下级组织还是网格数据
+        ScreenAgencyOrGridListDTO agencyGrid = indexService.getSubAgencyOrGridList(formDTO.getAgencyId());
+        if (null == agencyGrid) {
+            return new CustomerDataManageResultDTO();
+        }
+        //组织或网格Id集合
+        List<String> idList = agencyGrid.getAgencyGridList().stream().map(ScreenAgencyOrGridListDTO.AgencyGrid::getOrgId).collect(Collectors.toList());
+        formDTO.setDataType(!"community".equals(agencyGrid.getLevel()) ? "agency" : "grid");
+        formDTO.setIdList(idList);
+        resultDTO.setTotal(idList.size());
+
+        //3.查询截止日期用户、群组、话题、议题、项目、巡查数据
+        formDTO.setSourceType("end");
+        List<CustomerDataManageResultDTO.CustomerDataManage> userEnd = dataStatsDao.regUserList(formDTO);
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> uEndMap = new HashMap<>();
+        userEnd.stream().forEach(u->uEndMap.put(u.getOrgId(),u));
+        List<CustomerDataManageResultDTO.CustomerDataManage> groupEnd = dataStatsDao.groupList(formDTO);
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> gEndMap = new HashMap<>();
+        groupEnd.stream().forEach(u->gEndMap.put(u.getOrgId(),u));
+        List<CustomerDataManageResultDTO.CustomerDataManage> topicEnd = dataStatsDao.topicList(formDTO);
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> tEndMap = new HashMap<>();
+        topicEnd.stream().forEach(u->tEndMap.put(u.getOrgId(),u));
+        List<CustomerDataManageResultDTO.CustomerDataManage> issueEnd = dataStatsDao.issueList(formDTO);
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> iEndMap = new HashMap<>();
+        issueEnd.stream().forEach(u->iEndMap.put(u.getOrgId(),u));
+        List<CustomerDataManageResultDTO.CustomerDataManage> projectEnd = dataStatsDao.projectList(formDTO);
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> pEndMap = new HashMap<>();
+        projectEnd.stream().forEach(u->pEndMap.put(u.getOrgId(),u));
+        //巡查数据不区分区间差值，只计算累计值，人员做去重处理且是有巡查记录的人员
+        List<CustomerDataManageResultDTO.CustomerDataManage> patrolEnd = statsStaffPatrolRecordDailyService.patrolList(formDTO);
+
+        //4.判断是否需要查询起始日期用户、群组、话题、议题、项目、巡查数据
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> uStartMap = new HashMap<>();
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> gStartMap = new HashMap<>();
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> tStartMap = new HashMap<>();
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> iStartMap = new HashMap<>();
+        HashMap<String, CustomerDataManageResultDTO.CustomerDataManage> pStartMap = new HashMap<>();
+        if ("Interval".equals(formDTO.getType())) {
+            formDTO.setSourceType("start");
+            List<CustomerDataManageResultDTO.CustomerDataManage> userStart = dataStatsDao.regUserList(formDTO);
+            userStart.stream().forEach(u->uStartMap.put(u.getOrgId(),u));
+            List<CustomerDataManageResultDTO.CustomerDataManage> groupStart = dataStatsDao.groupList(formDTO);
+            groupStart.stream().forEach(u->gStartMap.put(u.getOrgId(),u));
+            List<CustomerDataManageResultDTO.CustomerDataManage> topicStart = dataStatsDao.topicList(formDTO);
+            topicStart.stream().forEach(u->tStartMap.put(u.getOrgId(),u));
+            List<CustomerDataManageResultDTO.CustomerDataManage> issueStart = dataStatsDao.issueList(formDTO);
+            issueStart.stream().forEach(u->iStartMap.put(u.getOrgId(),u));
+            List<CustomerDataManageResultDTO.CustomerDataManage> projectStart = dataStatsDao.projectList(formDTO);
+            projectStart.stream().forEach(u->pStartMap.put(u.getOrgId(),u));
+        }
+
+        //5.封装数据
+        agencyGrid.getAgencyGridList().forEach(org -> {
+            CustomerDataManageResultDTO.CustomerDataManage dto = new CustomerDataManageResultDTO.CustomerDataManage();
+            dto.setOrgId(org.getOrgId());
+            dto.setOrgName(org.getOrgName());
+            int user = 0;
+            int resi = 0;
+            int part = 0;
+            if(uEndMap.containsKey(org.getOrgId())){
+                user = uEndMap.get(org.getOrgId()).getUserCount();
+                resi = uEndMap.get(org.getOrgId()).getResidentCount();
+                part = uEndMap.get(org.getOrgId()).getPartyMemberCount();
+                if ("Interval".equals(formDTO.getType())&&uStartMap.containsKey(org.getOrgId())) {
+                    user = user - uStartMap.get(org.getOrgId()).getUserCount();
+                    resi = resi - uStartMap.get(org.getOrgId()).getResidentCount();
+                    part = part - uStartMap.get(org.getOrgId()).getPartyMemberCount();
+                }
+            }
+            int group = 0;
+            if(gEndMap.containsKey(org.getOrgId())){
+                group = gEndMap.get(org.getOrgId()).getGroupCount();
+                if ("Interval".equals(formDTO.getType())&&gStartMap.containsKey(org.getOrgId())) {
+                    group = group - gStartMap.get(org.getOrgId()).getGroupCount();
+                }
+            }
+            int topic = 0;
+            if(tEndMap.containsKey(org.getOrgId())){
+                topic = tEndMap.get(org.getOrgId()).getTopicCount();
+                if ("Interval".equals(formDTO.getType())&&tStartMap.containsKey(org.getOrgId())) {
+                    topic = topic - tStartMap.get(org.getOrgId()).getTopicCount();
+                }
+            }
+            int issue = 0;
+            if(iEndMap.containsKey(org.getOrgId())){
+                issue = iEndMap.get(org.getOrgId()).getIssueCount();
+                if ("Interval".equals(formDTO.getType())&&iStartMap.containsKey(org.getOrgId())) {
+                    issue = issue - iStartMap.get(org.getOrgId()).getIssueCount();
+                }
+            }
+            int project = 0;
+            int closed = 0;
+            if(pEndMap.containsKey(org.getOrgId())){
+                project = pEndMap.get(org.getOrgId()).getProjectCount();
+                closed = pEndMap.get(org.getOrgId()).getClosedProjectCount();
+                if ("Interval".equals(formDTO.getType())&&pStartMap.containsKey(org.getOrgId())) {
+                    project = project - pStartMap.get(org.getOrgId()).getProjectCount();
+                    closed = closed - pStartMap.get(org.getOrgId()).getClosedProjectCount();
+                }
+            }
+            int patro = 0;
+            int patroCount = 0;
+            String patrolDuration = "";
+            int patrolDurationInteger = 0;
+            HashSet set = new HashSet();
+            for (CustomerDataManageResultDTO.CustomerDataManage u : patrolEnd) {
+                if (org.getOrgId().equals(u.getOrgId())) {
+                    patroCount += u.getPatrolCount();
+                    patrolDurationInteger += u.getPatrolDurationInteger();
+                    set.add(u.getStaffId());
+                }
+            }
+            patro = set.size();
+            Integer minutes = patrolDurationInteger / 60;
+            patrolDuration = (minutes / 60 > 0 ? minutes / 60 + "小时" : "") + (minutes % 60 > 0 ? minutes % 60 + "分钟" : "0分钟");
+
+            dto.setUserCount(user);
+            dto.setResidentCount(resi);
+            dto.setPartyMemberCount(part);
+            dto.setGroupCount(group);
+            dto.setTopicCount(topic);
+            dto.setIssueCount(issue);
+            dto.setProjectCount(project);
+            dto.setClosedProjectCount(closed);
+            dto.setPatrolPeopleCount(patro);
+            dto.setPatrolCount(patroCount);
+            dto.setPatrolDuration(patrolDuration);
+            dto.setPatrolDurationInteger(patrolDurationInteger);
+
+            dataManageList.add(dto);
+        });
+
+        //6.默认按用户总数降序
+        Collections.sort(dataManageList, new Comparator<CustomerDataManageResultDTO.CustomerDataManage>() {
+            @Override
+            public int compare(CustomerDataManageResultDTO.CustomerDataManage o1, CustomerDataManageResultDTO.CustomerDataManage o2) {
+                return o2.getUserCount().compareTo(o1.getUserCount());
+            }
+        });
+
+        //7.物理分页并返回
+        if (formDTO.getIsPage()) {
+            int firstIndex = (formDTO.getPageNo() - 1) * formDTO.getPageSize();
+            int lastIndex = formDTO.getPageNo() * formDTO.getPageSize();
+            List<CustomerDataManageResultDTO.CustomerDataManage> list = dataManageList.subList((firstIndex > dataManageList.size() ? dataManageList.size() : firstIndex), (lastIndex > dataManageList.size() ? dataManageList.size() : lastIndex));
+            resultDTO.setList(list);
+            return resultDTO;
+        }
+        resultDTO.setList(dataManageList);
+        return resultDTO;
+    }
+
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/StatsStaffPatrolRecordDailyService.java

@@ -18,6 +18,8 @@
 package com.epmet.dataaggre.service.epmetuser;
 
 import com.epmet.commons.mybatis.service.BaseService;
+import com.epmet.dataaggre.dto.datastats.form.CustomerDataManageFormDTO;
+import com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO;
 import com.epmet.dataaggre.dto.epmetuser.result.PatrolDailySumResult;
 import com.epmet.dataaggre.entity.epmetuser.StatsStaffPatrolRecordDailyEntity;
 
@@ -40,4 +42,9 @@ public interface StatsStaffPatrolRecordDailyService extends BaseService<StatsSta
      */
 	List<PatrolDailySumResult> getPatrolSumList(List<String> agencyList, String startDateId, String endDateId);
 
+	/**
+	 * @Description 直属组织或网格下巡查数据
+	 * @author sun
+	 */
+	List<CustomerDataManageResultDTO.CustomerDataManage> patrolList(CustomerDataManageFormDTO formDTO);
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/StatsStaffPatrolRecordDailyServiceImpl.java

@@ -4,6 +4,8 @@ import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.dataaggre.constant.DataSourceConstant;
 import com.epmet.dataaggre.dao.epmetuser.StatsStaffPatrolRecordDailyDao;
+import com.epmet.dataaggre.dto.datastats.form.CustomerDataManageFormDTO;
+import com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO;
 import com.epmet.dataaggre.dto.epmetuser.result.PatrolDailySumResult;
 import com.epmet.dataaggre.entity.epmetuser.StatsStaffPatrolRecordDailyEntity;
 import com.epmet.dataaggre.service.epmetuser.StatsStaffPatrolRecordDailyService;
@@ -36,4 +38,13 @@ public class StatsStaffPatrolRecordDailyServiceImpl extends BaseServiceImpl<Stat
         return baseDao.getPatrolSumList(agencyFullIdList,startDateId,endDateId);
     }
 
+    /**
+     * @Description 直属组织或网格下巡查数据
+     * @author sun
+     */
+    @Override
+    public List<CustomerDataManageResultDTO.CustomerDataManage> patrolList(CustomerDataManageFormDTO formDTO) {
+        return baseDao.patrolList(formDTO);
+    }
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/evaluationindex/EvaluationIndexService.java

@@ -2,6 +2,7 @@ package com.epmet.dataaggre.service.evaluationindex;
 
 import com.epmet.dataaggre.dto.datastats.form.GovrnRatioFormDTO;
 import com.epmet.dataaggre.dto.datastats.result.GovrnRatioResultDTO;
+import com.epmet.dataaggre.dto.evaluationindex.ScreenAgencyOrGridListDTO;
 import com.epmet.dataaggre.dto.evaluationindex.ScreenCustomerAgencyDTO;
 import com.epmet.dataaggre.dto.evaluationindex.ScreenCustomerGridDTO;
 import com.epmet.dataaggre.dto.evaluationindex.ScreenGovernRankDataDailyDTO;
@@ -71,4 +72,18 @@ public interface EvaluationIndexService {
      */
     List<ScreenCustomerAgencyDTO> getSubAgencyListByAgency(String agencyId);
 
+    /**
+     * @Description  根据组织ID查询组织名
+     * @Param agencyId
+     * @author zxc
+     * @date 2021/9/10 3:54 下午
+     */
+    String selectAgencyNameByAgencyId(String agencyId);
+
+    /**
+     * @Description 根据组织Id判断查询直属下级组织/网格列表，组织存在子客户的查询包含子客户组织数据
+     * @author sun
+     */
+    ScreenAgencyOrGridListDTO getSubAgencyOrGridList(String agencyId);
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/evaluationindex/impl/EvaluationIndexServiceImpl.java

@@ -2,10 +2,12 @@ package com.epmet.dataaggre.service.evaluationindex.impl;
 
 import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.tools.exception.RenException;
+import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.dataaggre.constant.DataSourceConstant;
 import com.epmet.dataaggre.dao.evaluationindex.EvaluationIndexDao;
 import com.epmet.dataaggre.dto.datastats.form.GovrnRatioFormDTO;
 import com.epmet.dataaggre.dto.datastats.result.GovrnRatioResultDTO;
+import com.epmet.dataaggre.dto.evaluationindex.ScreenAgencyOrGridListDTO;
 import com.epmet.dataaggre.dto.evaluationindex.ScreenCustomerAgencyDTO;
 import com.epmet.dataaggre.dto.evaluationindex.ScreenCustomerGridDTO;
 import com.epmet.dataaggre.dto.evaluationindex.ScreenGovernRankDataDailyDTO;
@@ -143,4 +145,65 @@ public class EvaluationIndexServiceImpl implements EvaluationIndexService {
         }
     }
 
+    /**
+     * @Description  根据组织ID查询组织名
+     * @Param agencyId
+     * @author zxc
+     * @date 2021/9/10 3:54 下午
+     */
+    @Override
+    public String selectAgencyNameByAgencyId(String agencyId) {
+        return evaluationIndexDao.selectAgencyNameByAgencyId(agencyId);
+    }
+
+    /**
+     * @Description 根据组织Id判断查询直属下级组织/网格列表，组织存在子客户的查询包含子客户组织数据
+     * @author sun
+     */
+    @Override
+    public ScreenAgencyOrGridListDTO getSubAgencyOrGridList(String agencyId) {
+        ScreenAgencyOrGridListDTO resultDTO = new ScreenAgencyOrGridListDTO();
+        List<ScreenAgencyOrGridListDTO.AgencyGrid> agencyGridList = new ArrayList<>();
+        //1.查询组织信息
+        ScreenCustomerAgencyDTO dto = evaluationIndexDao.getByAgencyId(agencyId);
+        if (dto == null) {
+            log.error(String.format("组织信息不存在,组织Id->%s"), agencyId);
+            return new ScreenAgencyOrGridListDTO();
+        }
+        //2.根据组织级别判断查询直属组织或网格列表
+        List<ScreenCustomerAgencyDTO> agencyList = new ArrayList<>();
+        List<ScreenCustomerGridDTO> gridList = new ArrayList<>();
+        List<ScreenAgencyOrGridListDTO.AgencyGrid> finalAgencyGridList = agencyGridList;
+        if (!"community".equals(dto.getLevel())) {
+            //2-1.直属下级组织列表
+            //2.判断客户是否存在子客户
+            List<String> list = customerRelation.haveSubCustomer(dto.getCustomerId());
+            if (!CollectionUtils.isNotEmpty(list)) {
+                agencyList = evaluationIndexDao.getSubAgencyListByAgency(agencyId, null, null);
+            } else {
+                list.add(dto.getCustomerId());
+                agencyList = evaluationIndexDao.getSubAgencyListByAgency(null, dto.getAreaCode(), list);
+            }
+            agencyList.forEach(gr->{
+                ScreenAgencyOrGridListDTO.AgencyGrid org = new ScreenAgencyOrGridListDTO.AgencyGrid();
+                org.setOrgId(gr.getAgencyId());
+                org.setOrgName(gr.getAgencyName());
+                finalAgencyGridList.add(org);
+            });
+        } else {
+            //2-2.直属下级网格列表
+            gridList = evaluationIndexDao.getSubGridList(agencyId);
+            gridList.forEach(gr->{
+                ScreenAgencyOrGridListDTO.AgencyGrid org = new ScreenAgencyOrGridListDTO.AgencyGrid();
+                org.setOrgId(gr.getGridId());
+                org.setOrgName(gr.getGridName());
+                finalAgencyGridList.add(org);
+            });
+        }
+
+        resultDTO.setLevel(dto.getLevel());
+        resultDTO.setAgencyGridList(agencyGridList);
+        return resultDTO;
+    }
+
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/datastats/DatsStatsDao.xml

@@ -797,4 +797,205 @@
         GROUP BY staff_id
     </select>
 
+    <select id="regUserList" resultType="com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO$CustomerDataManage">
+        SELECT
+            t.orgId, t.dateId, t.userCount, t.partyMemberCount,t.residentCount
+        FROM
+        (
+            SELECT DISTINCT
+                date_id dateId, reg_total userCount, partymember_total partyMemberCount, (reg_total - partymember_total) residentCount
+            <choose>
+                <when test='dataType == "agency"'>
+                    , agency_id orgId
+                    FROM fact_reg_user_agency_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND agency_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </when>
+                <otherwise>
+                    , grid_id orgId
+                    FROM fact_reg_user_grid_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND grid_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </otherwise>
+            </choose>
+            <if test='sourceType != "" and sourceType == "start" and startTime != "" and startTime != null '>
+                AND date_id <![CDATA[>=]]> #{startTime}
+                ORDER BY date_id ASC
+            </if>
+            <if test='sourceType != "" and sourceType == "end" and endTime != "" and endTime != null '>
+                AND date_id <![CDATA[<=]]> #{endTime}
+                ORDER BY date_id DESC
+            </if>
+            <choose>
+                <when test='dataType == "agency"'>, agency_id ASC</when>
+                <otherwise>, grid_id ASC</otherwise>
+            </choose>
+        ) t
+        GROUP BY t.orgId
+    </select>
+    <select id="groupList" resultType="com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO$CustomerDataManage">
+        SELECT
+            t.orgId, t.dateId, t.groupCount
+        FROM
+        (
+            SELECT DISTINCT
+                date_id dateId, group_total groupCount
+            <choose>
+                <when test='dataType == "agency"'>
+                    , agency_id orgId
+                    FROM fact_group_total_agency_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND agency_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </when>
+                <otherwise>
+                    , grid_id orgId
+                    FROM fact_group_total_grid_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND grid_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </otherwise>
+            </choose>
+            <if test='sourceType != "" and sourceType == "start" and startTime != "" and startTime != null '>
+                AND date_id <![CDATA[>=]]> #{startTime}
+                ORDER BY date_id ASC
+            </if>
+            <if test='sourceType != "" and sourceType == "end" and endTime != "" and endTime != null '>
+                AND date_id <![CDATA[<=]]> #{endTime}
+                ORDER BY date_id DESC
+            </if>
+            <choose>
+                <when test='dataType == "agency"'>, agency_id ASC</when>
+                <otherwise>, grid_id ASC</otherwise>
+            </choose>
+        ) t
+        GROUP BY t.orgId
+    </select>
+    <select id="topicList" resultType="com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO$CustomerDataManage">
+        SELECT
+            t.orgId, t.dateId, t.topicCount
+        FROM
+        (
+            SELECT DISTINCT
+                date_id dateId, topic_total topicCount
+            <choose>
+                <when test='dataType == "agency"'>
+                    , agency_id orgId
+                    FROM fact_topic_total_agency_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND agency_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </when>
+                <otherwise>
+                    , grid_id orgId
+                    FROM fact_topic_total_grid_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND grid_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </otherwise>
+            </choose>
+            <if test='sourceType != "" and sourceType == "start" and startTime != "" and startTime != null '>
+                AND date_id <![CDATA[>=]]> #{startTime}
+                ORDER BY date_id ASC
+            </if>
+            <if test='sourceType != "" and sourceType == "end" and endTime != "" and endTime != null '>
+                AND date_id <![CDATA[<=]]> #{endTime}
+                ORDER BY date_id DESC
+            </if>
+            <choose>
+                <when test='dataType == "agency"'>, agency_id ASC</when>
+                <otherwise>, grid_id ASC</otherwise>
+            </choose>
+        ) t
+        GROUP BY t.orgId
+    </select>
+    <select id="issueList" resultType="com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO$CustomerDataManage">
+        SELECT
+            t.orgId, t.dateId, t.issueCount
+        FROM
+        (
+            SELECT DISTINCT
+                date_id dateId, issue_total issueCount
+            <choose>
+                <when test='dataType == "agency"'>
+                    , agency_id orgId
+                    FROM fact_issue_agency_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND agency_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </when>
+                <otherwise>
+                    , grid_id orgId
+                    FROM fact_issue_grid_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND grid_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </otherwise>
+            </choose>
+            <if test='sourceType != "" and sourceType == "start" and startTime != "" and startTime != null '>
+                AND date_id <![CDATA[>=]]> #{startTime}
+                ORDER BY date_id ASC
+            </if>
+            <if test='sourceType != "" and sourceType == "end" and endTime != "" and endTime != null '>
+                AND date_id <![CDATA[<=]]> #{endTime}
+                ORDER BY date_id DESC
+            </if>
+            <choose>
+                <when test='dataType == "agency"'>, agency_id ASC</when>
+                <otherwise>, grid_id ASC</otherwise>
+            </choose>
+        ) t
+        GROUP BY t.orgId
+    </select>
+    <select id="projectList" resultType="com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO$CustomerDataManage">
+        SELECT
+            t.orgId, t.dateId, t.projectCount, t.closedProjectCount
+        FROM
+        (
+            SELECT DISTINCT
+                date_id dateId, project_total projectCount, closed_total closedProjectCount
+            <choose>
+                <when test='dataType == "agency"'>
+                    , agency_id orgId
+                    FROM fact_agency_project_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND agency_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </when>
+                <otherwise>
+                    , grid_id orgId
+                    FROM fact_grid_project_daily
+                    WHERE del_flag = '0'
+                    <foreach collection="idList" item="id" open="AND grid_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </otherwise>
+            </choose>
+            <if test='sourceType != "" and sourceType == "start" and startTime != "" and startTime != null '>
+                AND date_id <![CDATA[>=]]> #{startTime}
+                ORDER BY date_id ASC
+            </if>
+            <if test='sourceType != "" and sourceType == "end" and endTime != "" and endTime != null '>
+                AND date_id <![CDATA[<=]]> #{endTime}
+                ORDER BY date_id DESC
+            </if>
+            <choose>
+                <when test='dataType == "agency"'>, agency_id ASC</when>
+                <otherwise>, grid_id ASC</otherwise>
+            </choose>
+        ) t
+        GROUP BY t.orgId
+    </select>
+
 </mapper>

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetuser/StatsStaffPatrolRecordDailyDao.xml

@@ -15,4 +15,45 @@
     </foreach>
 
     </select>
+
+    <select id="patrolList" resultType="com.epmet.dataaggre.dto.datastats.result.CustomerDataManageResultDTO$CustomerDataManage">
+        SELECT
+            t.dateId, t.orgId, t.staffId, sum(t.patrol_total) patrolCount, SUM(t.total_time) patrolDurationInteger
+        FROM (
+            SELECT
+                date_id dateId, grid_id, staff_id staffId, patrol_total , total_time
+                <choose>
+                    <when test='dataType == "agency"'>
+                        , agency_id orgId
+                    </when>
+                    <otherwise>
+                        , grid_id orgId
+                    </otherwise>
+                </choose>
+            FROM
+            stats_staff_patrol_record_daily
+            WHERE del_flag = '0'
+            AND patrol_total > 0
+            <choose>
+                <when test='dataType == "agency"'>
+                    <foreach collection="idList" item="id" open="AND agency_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </when>
+                <otherwise>
+                    <foreach collection="idList" item="id" open="AND grid_id IN (" separator="," close=")">
+                        #{id}
+                    </foreach>
+                </otherwise>
+            </choose>
+            <if test='type != "" and type == "Interval" and startTime != "" and startTime != null '>
+                AND date_id <![CDATA[>=]]> #{startTime}
+            </if>
+            <if test='endTime != "" and endTime != null '>
+                AND date_id <![CDATA[<=]]> #{endTime}
+            </if>
+        ) t
+        GROUP BY t.grid_id, t.staffId
+    </select>
+
 </mapper>

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/evaluationindex/EvaluationIndexDao.xml

@@ -175,4 +175,11 @@
         </if>
     </select>
 
+    <!-- 根据组织ID查询组织名 -->
+    <select id="selectAgencyNameByAgencyId" resultType="java.lang.String">
+        SELECT AGENCY_NAME FROM screen_customer_agency
+        WHERE AGENCY_ID = #{agencyId}
+          AND DEL_FLAG = 0
+    </select>
+
 </mapper>