Browse Source

项目分类接口提交

feature/syp_points
songyunpeng 5 years ago
parent
commit
dd8a1b6d54
  1. 11
      esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/constant/EpmetConstant.java
  2. 66
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/item/result/CategoryGridDailyResultDTO.java
  3. 71
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/item/result/CategoryOrgDailyResultDTO.java
  4. 31
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/ScreenCategoryDateDTO.java
  5. 33
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/common/dao/EpdcTableNameDao.java
  6. 17
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/common/entity/EpdcTableName.java
  7. 36
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/item/controller/ItemAnalysisController.java
  8. 6
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/item/dao/ItemAnalysisDao.java
  9. 22
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/item/service/ItemAnalysisService.java
  10. 34
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemAnalysisServiceImpl.java
  11. 23
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/utils/ScreenDataUtils.java
  12. 29
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/common/EpdcTableName.xml
  13. 72
      esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/item/ItemAnalysisDao.xml
  14. 23
      esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java
  15. 9
      esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java
  16. 36
      esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/ScreenProjectDataPushDayTaskImpl.java

11
esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/constant/EpmetConstant.java

@ -212,6 +212,17 @@ public interface EpmetConstant {
String EPMET_PROJECT_UPLOAD_PROJECT_PROCESS = "/data/stats/project/uploadprojectprocess";
/**
* 事件/项目分析按类别统计-网格03-22已确定
*/
String EPMET_PROJECT_CATEGORY_GRID_DAILY = "/data/stats/project/category-grid-daily";
/**
* 事件/项目分析按类别统计-组织03-22已确定
*/
String EPMET_PROJECT_CATEGORY_ORG_DAILY = "/data/stats/project/category-org-daily";
/**
* 行政地区编码查询 - 平阴县
*/

66
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/item/result/CategoryGridDailyResultDTO.java

@ -0,0 +1,66 @@
/**
* Copyright 2018 人人开源 https://www.renren.io
* <p>
* 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.
* <p>
* 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.
* <p>
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.elink.esua.epdc.dto.item.result;
import lombok.Data;
import java.io.Serializable;
/**
* 事件/项目分析按类别统计-网格03-22已确定
*
* @author zhy
* @date 2021/3/22 16:55
*/
@Data
public class CategoryGridDailyResultDTO implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 类别编码
*/
private String categoryCode;
/**
* 项目总数
*/
private Integer projectTotal;
/**
* 组织id
*/
private String gridId;
/**
* 组织所属上级id如果属于跟组织下直属网格pid=0
*/
private String pid;
/**
* 组织所有父级ids以英文逗号隔开; pid=0时pids=0
*/
private String pids;
/**
* 分类等级12....
*/
private Integer level;
}

71
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/item/result/CategoryOrgDailyResultDTO.java

@ -0,0 +1,71 @@
/**
* Copyright 2018 人人开源 https://www.renren.io
* <p>
* 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.
* <p>
* 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.
* <p>
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.elink.esua.epdc.dto.item.result;
import lombok.Data;
import java.io.Serializable;
/**
* 事件/项目分析按类别统计-组织03-22已确定
*
* @author zhy
* @date 2021/3/22 16:56
*/
@Data
public class CategoryOrgDailyResultDTO implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 类别编码
*/
private String categoryCode;
/**
* 项目总数
*/
private Integer projectTotal;
/**
* 组织id
*/
private String orgId;
/**
* 组织所属上级id如果属于跟组织下直属网格pid=0
*/
private String pid;
/**
* 组织所有父级ids以英文逗号隔开; pid=0时pids=0
*/
private String pids;
/**
* 社区级community街道:street
*/
private String orgType;
/**
* 分类等级12....
*/
private Integer level;
}

31
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/result/ScreenCategoryDateDTO.java

@ -0,0 +1,31 @@
package com.elink.esua.epdc.dto.screen.result;
import lombok.Data;
import java.io.Serializable;
/**
* 事件/项目分析按类别统计
*
* @author zhy
* @date 2021/3/23 10:37
*/
@Data
public class ScreenCategoryDateDTO implements Serializable {
private static final long serialVersionUID = 8161588041384645877L;
/**
* 当为true时后台将先删除当前维度的数据后新增
*/
private Boolean isFirst;
/**
* 日期Id, 数据更新至yyyyMMdd
*/
private String dateId;
/**
* 上报数据
*/
private Object dataList;
}

33
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/common/dao/EpdcTableNameDao.java

@ -0,0 +1,33 @@
/**
* Copyright 2018 人人开源 https://www.renren.io
* <p>
* 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.
* <p>
* 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.
* <p>
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.elink.esua.epdc.modules.common.dao;
import com.elink.esua.epdc.commons.mybatis.dao.BaseDao;
import com.elink.esua.epdc.modules.common.entity.EpdcTableName;
import org.apache.ibatis.annotations.Mapper;
/**
* 声明表名
*
* @author work@yujt.net.cn
* @date 2020/7/20 16:04
*/
@Mapper
public interface EpdcTableNameDao extends BaseDao<EpdcTableName> {
}

17
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/common/entity/EpdcTableName.java

@ -0,0 +1,17 @@
package com.elink.esua.epdc.modules.common.entity;
import lombok.Data;
import java.io.Serializable;
/**
* 声明表名
*
* @author work@yujt.net.cn
* @date 2020/7/20 16:00
*/
@Data
public class EpdcTableName implements Serializable {
private static final long serialVersionUID = 2548002813384497114L;
}

36
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/item/controller/ItemAnalysisController.java

@ -20,14 +20,12 @@ package com.elink.esua.epdc.modules.item.controller;
import com.elink.esua.epdc.commons.tools.page.PageData;
import com.elink.esua.epdc.commons.tools.utils.Result;
import com.elink.esua.epdc.dto.item.result.*;
import com.elink.esua.epdc.dto.item.form.ItemSurveyFormDTO;
import com.elink.esua.epdc.dto.item.result.DifficultItemResultDTO;
import com.elink.esua.epdc.dto.item.result.ItemResultDTO;
import com.elink.esua.epdc.dto.item.result.ItemSurveyResultDTO;
import com.elink.esua.epdc.dto.item.result.UnsolvedItemResultDTO;
import com.elink.esua.epdc.modules.item.service.ItemAnalysisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.Map;
@ -109,4 +107,30 @@ public class ItemAnalysisController {
PageData<ReportSolvedItemResultDTO> page = itemAnalysisService.listReportSolvedItemResultDTO(params);
return new Result<PageData<ReportSolvedItemResultDTO>>().ok(page);
}
/**
* 事件/项目分析按类别统计-网格03-22已确定
*
* @param
* @return com.elink.esua.epdc.commons.tools.utils.Result<java.util.List < com.elink.esua.epdc.dto.category.CategoryGridResultDailyDTO>>
* @author zhy
* @date 2021/3/22 17:06
*/
@GetMapping("categoryGridDaily")
public Result getCategoryGridDaily(String date) {
return itemAnalysisService.getCategoryGridDaily(date);
}
/**
* 事件/项目分析按类别统计-组织03-22已确定
*
* @param
* @return com.elink.esua.epdc.commons.tools.utils.Result<java.util.List < com.elink.esua.epdc.dto.category.CategoryOrgResultDailyDTO>>
* @author zhy
* @date 2021/3/22 17:06
*/
@GetMapping("categoryOrgDaily")
public Result getCategoryOrgDaily(String date) {
return itemAnalysisService.getCategoryOrgDaily(date);
}
}

6
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/item/dao/ItemAnalysisDao.java

@ -105,4 +105,10 @@ public interface ItemAnalysisDao extends BaseDao<ItemResultDTO> {
* @Date: 2020-02-12
*/
List<HotItemListResultDTO> selectListHotItemList(HotItemListFormDTO formDto);
List<CategoryGridDailyResultDTO> getCategoryGridDaily();
List<CategoryOrgDailyResultDTO> getCategoryCommDaily();
List<CategoryOrgDailyResultDTO> getCategoryStreetDaily();
}

22
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/item/service/ItemAnalysisService.java

@ -1,8 +1,8 @@
package com.elink.esua.epdc.modules.item.service;
import com.elink.esua.epdc.commons.tools.page.PageData;
import com.elink.esua.epdc.commons.tools.utils.Result;
import com.elink.esua.epdc.dto.item.form.HotItemListFormDTO;
import com.elink.esua.epdc.dto.item.result.*;
import com.elink.esua.epdc.dto.item.form.ItemAnalysisFormDTO;
import com.elink.esua.epdc.dto.item.form.ItemSurveyFormDTO;
import com.elink.esua.epdc.dto.item.result.*;
@ -89,4 +89,24 @@ public interface ItemAnalysisService {
* @Date: 2020-02-12
*/
List<HotItemListResultDTO> listHotItemList(HotItemListFormDTO formDto);
/**
* 事件/项目分析按类别统计-网格03-22已确定
*
* @param
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/3/23 9:13
*/
Result getCategoryGridDaily(String date);
/**
* 事件/项目分析按类别统计-组织03-22已确定
*
* @param
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/3/23 9:13
*/
Result getCategoryOrgDaily(String date);
}

34
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemAnalysisServiceImpl.java

@ -2,23 +2,31 @@ package com.elink.esua.epdc.modules.item.service.impl;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl;
import com.elink.esua.epdc.commons.tools.constant.EpmetConstant;
import com.elink.esua.epdc.commons.tools.constant.NumConstant;
import com.elink.esua.epdc.commons.tools.page.PageData;
import com.elink.esua.epdc.commons.tools.security.user.SecurityUser;
import com.elink.esua.epdc.commons.tools.security.user.UserDetail;
import com.elink.esua.epdc.commons.tools.utils.DateUtils;
import com.elink.esua.epdc.commons.tools.utils.Result;
import com.elink.esua.epdc.datasources.DataSourceNames;
import com.elink.esua.epdc.datasources.annotation.DataSource;
import com.elink.esua.epdc.dto.item.form.HotItemListFormDTO;
import com.elink.esua.epdc.dto.item.result.*;
import com.elink.esua.epdc.dto.item.form.ItemAnalysisFormDTO;
import com.elink.esua.epdc.dto.item.form.ItemSurveyFormDTO;
import com.elink.esua.epdc.dto.item.result.*;
import com.elink.esua.epdc.modules.item.dao.ItemAnalysisDao;
import com.elink.esua.epdc.modules.item.service.ItemAnalysisService;
import com.elink.esua.epdc.utils.EpmetUtils;
import com.elink.esua.epdc.utils.ScreenDataUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
@ -31,6 +39,8 @@ import java.util.Map;
public class ItemAnalysisServiceImpl extends BaseServiceImpl<ItemAnalysisDao, ItemResultDTO> implements ItemAnalysisService {
private Logger logger = LoggerFactory.getLogger(getClass());
@Autowired
private EpmetUtils epmetUtils;
/**
* @param params
* @return com.elink.esua.epdc.dto.item.result.ItemResultDTO
@ -149,4 +159,26 @@ public class ItemAnalysisServiceImpl extends BaseServiceImpl<ItemAnalysisDao, It
formDto.setPageIndex(pageIndex);
return baseDao.selectListHotItemList(formDto);
}
@Override
public Result getCategoryGridDaily(String date) {
date = StringUtils.isEmpty(date) ? DateUtils.format(DateUtils.addDateDays(new Date(),-1)) : date;
List<CategoryGridDailyResultDTO> gridDataList = baseDao.getCategoryGridDaily();
String dataJson = ScreenDataUtils.getScreenCategoryDataJson(gridDataList, date, true);
epmetUtils.httpPost(EpmetConstant.EPMET_PROJECT_CATEGORY_GRID_DAILY, dataJson);
return new Result();
}
@Override
public Result getCategoryOrgDaily(String date) {
date = StringUtils.isEmpty(date) ? DateUtils.format(DateUtils.addDateDays(new Date(),-1)) : date;
List<CategoryOrgDailyResultDTO> commDataList = baseDao.getCategoryCommDaily();
List<CategoryOrgDailyResultDTO> streetDataList = baseDao.getCategoryStreetDaily();
List<CategoryOrgDailyResultDTO> orgDataList = new ArrayList<>();
orgDataList.addAll(streetDataList);
orgDataList.addAll(commDataList);
String dataJson = ScreenDataUtils.getScreenCategoryDataJson(orgDataList, date, true);
epmetUtils.httpPost(EpmetConstant.EPMET_PROJECT_CATEGORY_ORG_DAILY, dataJson);
return new Result();
}
}

23
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/utils/ScreenDataUtils.java

@ -2,6 +2,7 @@ package com.elink.esua.epdc.utils;
import com.alibaba.fastjson.JSONObject;
import com.elink.esua.epdc.commons.tools.utils.DateUtils;
import com.elink.esua.epdc.dto.screen.result.ScreenCategoryDateDTO;
import com.elink.esua.epdc.dto.screen.result.ScreenDataDTO;
import com.elink.esua.epdc.dto.screen.result.ScreenDataDateDTO;
import com.elink.esua.epdc.dto.screen.result.ScreenDataMonthDTO;
@ -142,6 +143,28 @@ public class ScreenDataUtils {
dateDto.setMonthId(dateId.replace("-", ""));
dateDto.setDataList(data);
return JSONObject.toJSONString(dateDto);
}
/**
* 数据更新至事件为年月日类型
*
* @param data 数据
* @param dateId 日期字符串
* @param isFirst 是否首次
* @return java.lang.String
* @author zhy
* @date 2021/3/23 9:52
*/
public static String getScreenCategoryDataJson(Object data, String dateId, Boolean isFirst) {
if (StringUtils.isEmpty(dateId)) {
// 获取当前时间 yyyy-MM
dateId = DateUtils.formatYearMonth(new Date());
}
ScreenCategoryDateDTO dateDto = new ScreenCategoryDateDTO();
dateDto.setIsFirst(isFirst);
dateDto.setDateId(dateId.replace("-", ""));
dateDto.setDataList(data);
return JSONObject.toJSONString(dateDto);
}
}

29
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/common/EpdcTableName.xml

@ -0,0 +1,29 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao">
<!--测试库名-->
<sql id="tb_admin">js_esua_epdc_admin</sql>
<sql id="tb_analysis">js_esua_epdc_analysis</sql>
<sql id="tb_api">js_esua_epdc_api</sql>
<sql id="tb_custom">js_esua_epdc_custom</sql>
<sql id="tb_events">js_esua_epdc_events</sql>
<sql id="tb_group">js_esua_epdc_group</sql>
<sql id="tb_mutuality">js_esua_epdc_mutuality</sql>
<sql id="tb_news">js_esua_epdc_news</sql>
<sql id="tb_user">js_esua_epdc_user</sql>
<!--生产库名-->
<!--<sql id="tb_admin">esua_epdc_admin</sql>
<sql id="tb_analysis">esua_epdc_analysis</sql>
<sql id="tb_api">esua_epdc_api</sql>
<sql id="tb_custom">esua_epdc_custom</sql>
<sql id="tb_events">esua_epdc_events</sql>
<sql id="tb_group">esua_epdc_group</sql>
<sql id="tb_mutuality">esua_epdc_mutuality</sql>
<sql id="tb_news">esua_epdc_news</sql>
<sql id="tb_user">esua_epdc_user</sql>-->
</mapper>

72
esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/item/ItemAnalysisDao.xml

@ -479,4 +479,76 @@
statementNum DESC
LIMIT #{pageIndex}, #{pageSize};
</select>
<select id="getCategoryGridDaily" resultType="com.elink.esua.epdc.dto.item.result.CategoryGridDailyResultDTO">
SELECT
ei.category_code AS categoryCode,
count(0) AS projectTotal,
ei.GRID_ID AS gridId,
REVERSE(
LEFT (
REVERSE(ei.PARENT_DEPT_IDS),
LOCATE(
',',
REVERSE(ei.PARENT_DEPT_IDS)
) - 1
)
) AS pid,
ei.PARENT_DEPT_IDS AS pids,
ec.category_type AS LEVEL
FROM
<include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_events"/>.epdc_item ei
LEFT JOIN <include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_events"/>.epdc_category ec ON ei.CATEGORY_CODE = ec.category_code
WHERE
ei.DEL_FLAG = '0'
AND ec.DEL_FLAG = '0'
GROUP BY
ei.CATEGORY_CODE,
ei.GRID_ID
</select>
<select id="getCategoryCommDaily" resultType="com.elink.esua.epdc.dto.item.result.CategoryOrgDailyResultDTO">
SELECT
ei.category_code AS categoryCode,
count(0) AS projectTotal,
comm.id AS orgId,
comm.pid AS pid,
comm.pids AS pids,
'community' AS orgType,
ec.category_type AS LEVEL
FROM
<include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_events"/>.epdc_item ei
LEFT JOIN <include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_events"/>.epdc_category ec ON ei.CATEGORY_CODE = ec.category_code
LEFT JOIN <include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_admin"/>.sys_dept sd ON ei.GRID_ID = sd.id
LEFT JOIN <include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_admin"/>.sys_dept comm ON sd.pid = comm.id
WHERE
ei.DEL_FLAG = '0'
AND ec.DEL_FLAG = '0'
GROUP BY
ei.CATEGORY_CODE,
comm.id
</select>
<select id="getCategoryStreetDaily" resultType="com.elink.esua.epdc.dto.item.result.CategoryOrgDailyResultDTO">
SELECT
ei.category_code AS categoryCode,
count(0) AS projectTotal,
street.id AS orgId,
'0' AS pid,
'0' AS pids,
'street' AS orgType,
ec.category_type AS LEVEL
FROM
<include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_events"/>.epdc_item ei
LEFT JOIN <include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_events"/>.epdc_category ec ON ei.CATEGORY_CODE = ec.category_code
LEFT JOIN <include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_admin"/>.sys_dept sd ON ei.GRID_ID = sd.id
LEFT JOIN <include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_admin"/>.sys_dept comm ON sd.pid = comm.id
LEFT JOIN <include refid="com.elink.esua.epdc.modules.common.dao.EpdcTableNameDao.tb_admin"/>.sys_dept street ON comm.pid = street.id
WHERE
ei.DEL_FLAG = '0'
AND ec.DEL_FLAG = '0'
GROUP BY
ei.CATEGORY_CODE,
street.id
</select>
</mapper>

23
esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java

@ -6,6 +6,7 @@ import com.elink.esua.epdc.dto.screen.form.ScreenJobFormDTO;
import com.elink.esua.epdc.dto.screen.form.ScreenProjectFormDTO;
import com.elink.esua.epdc.feign.fallback.AnalysisFeignClientFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@ -296,6 +297,28 @@ public interface AnalysisFeignClient {
@PostMapping("analysis/data/stats/project/uploadprojectprocess")
Result uploadProjectProcess(@RequestBody ScreenProjectFormDTO screenProjectFormDTO);
/**
* 事件/项目分析按类别统计-网格03-22已确定
*
* @param
* @return com.elink.esua.epdc.commons.tools.utils.Result<java.util.List < com.elink.esua.epdc.dto.category.CategoryGridResultDailyDTO>>
* @author zhy
* @date 2021/3/22 17:06
*/
@GetMapping("analysis/item/categoryGridDaily")
Result getCategoryGridDaily(String date);
/**
* 事件/项目分析按类别统计-组织03-22已确定
*
* @param
* @return com.elink.esua.epdc.commons.tools.utils.Result<java.util.List < com.elink.esua.epdc.dto.category.CategoryOrgResultDailyDTO>>
* @author zhy
* @date 2021/3/22 17:06
*/
@GetMapping("analysis/item/categoryOrgDaily")
Result getCategoryOrgDaily(String date);
/**
* @Description 分类编码上报
* @Author songyunpeng

9
esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java

@ -159,4 +159,13 @@ public class AnalysisFeignClientFallback implements AnalysisFeignClient {
public Result uploadCategoryCode() {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "uploadCategoryCode");
}
@Override
public Result getCategoryGridDaily(String date) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "getCategoryGridDaily",date);
}
@Override
public Result getCategoryOrgDaily(String date) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER,"getCategoryOrgDaily", date);
}
}

36
esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/ScreenProjectDataPushDayTaskImpl.java

@ -41,7 +41,7 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
@Override
public void run(String param) {
for (int i = 0; i < 12; i++) {
for (int i = 0; i < 14; i++) {
createThread(i);
}
}
@ -83,6 +83,12 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
}else if (methodIndex == 11) {
// 011、项目分类字典上报
uploadcategorydict();
}else if (methodIndex == 12) {
// 012、【事件/项目分析】按类别统计-网格
categoryGridDaily();
}else if (methodIndex == 13) {
// 013、【事件/项目分析】按类别统计-组织
categoryOrgDaily();
}
return 0;
}
@ -318,5 +324,33 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
analysisFeignClient.uploadCategoryCode();
logger.info("<" + methodName + "|项目分类字典上报>定时任务执行结束");
}
/**
* 项目分类字典上报
*
* @return void
* @author WK
* @since 2020/9/17 14:01
*/
private void categoryGridDaily() {
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|【事件/项目分析】按类别统计-网格>定时任务开始执行");
analysisFeignClient.getCategoryGridDaily("");
logger.info("<" + methodName + "|【事件/项目分析】按类别统计-网格>定时任务执行结束");
}
/**
* 项目分类字典上报
*
* @return void
* @author WK
* @since 2020/9/17 14:01
*/
private void categoryOrgDaily() {
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|【事件/项目分析】按类别统计-组织>定时任务开始执行");
analysisFeignClient.getCategoryOrgDaily("");
logger.info("<" + methodName + "|【事件/项目分析】按类别统计-组织>定时任务执行结束");
}
}
Loading…
Cancel
Save