diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/form/GmUploaddataParamDTO.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/form/GmUploaddataParamDTO.java new file mode 100644 index 00000000..4fb55d31 --- /dev/null +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-client/src/main/java/com/elink/esua/epdc/dto/screen/form/GmUploaddataParamDTO.java @@ -0,0 +1,38 @@ +package com.elink.esua.epdc.dto.screen.form; + +import lombok.Data; + +import java.io.Serializable; + + +/** + * @author: qushutong + * @Date: 2022/2/23 16:58 + * @Description: 项目总数数据推送 + */ +@Data +public class GmUploaddataParamDTO implements Serializable { + private static final long serialVersionUID = 1132628937660635407L; + + /** + * 截止时间 + */ + private String endTime; + + /** + * 客户id + */ + private String customId; + + /** + * 开始时间 + */ + private String startTime; + + /** + * 年月日 + */ + private String yearMonthDay; + + +} diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenGridManagerController.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenGridManagerController.java index 3d955e94..57571008 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenGridManagerController.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenGridManagerController.java @@ -1,6 +1,7 @@ package com.elink.esua.epdc.modules.screen.controller; import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.screen.form.GmUploaddataParamDTO; import com.elink.esua.epdc.dto.screen.form.ScreenJobFormDTO; import com.elink.esua.epdc.modules.screen.service.ScreenGridManagerService; import org.springframework.beans.factory.annotation.Autowired; @@ -29,8 +30,8 @@ public class ScreenGridManagerController { * @return com.elink.esua.epdc.commons.tools.utils.Result> **/ @PostMapping("gridManagerUploadData") - public Result selectGridManagerUploadData() { - return screenGridManagerService.selectGridManagerUploadData(); + public Result selectGridManagerUploadData(@RequestBody GmUploaddataParamDTO paramDto) { + return screenGridManagerService.selectGridManagerUploadData(paramDto); } /** * @Description 网格员事件分析上报 diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenGridManagerDao.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenGridManagerDao.java index 6c087774..106ba441 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenGridManagerDao.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenGridManagerDao.java @@ -1,6 +1,7 @@ package com.elink.esua.epdc.modules.screen.dao; import com.elink.esua.epdc.commons.mybatis.dao.BaseDao; +import com.elink.esua.epdc.dto.screen.form.GmUploaddataParamDTO; import com.elink.esua.epdc.dto.screen.form.ScreenBaseReportDataFormDTO; import com.elink.esua.epdc.dto.screen.result.*; import org.apache.ibatis.annotations.Mapper; @@ -23,7 +24,7 @@ public interface ScreenGridManagerDao extends BaseDao **/ - List selectGridManagerUploadData(@Param("customId")String customId,@Param("yearMonthDay") String yearMonthDay); + List selectGridManagerUploadData(GmUploaddataParamDTO paramDto); /** * @Description 网格员事件总数上报 * @Author songyunpeng diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenGridManagerService.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenGridManagerService.java index 97537a41..d61e67b0 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenGridManagerService.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenGridManagerService.java @@ -1,6 +1,8 @@ package com.elink.esua.epdc.modules.screen.service; import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.screen.form.GmUploaddataParamDTO; +import com.elink.esua.epdc.dto.screen.form.ItemCountParamDTO; /** * 网格管理 @@ -17,7 +19,7 @@ public interface ScreenGridManagerService { * @Param [customId] * @return java.util.List **/ - Result selectGridManagerUploadData(); + Result selectGridManagerUploadData(GmUploaddataParamDTO paramDto); /** * @Description 网格员事件总数上报 * @Author songyunpeng diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenGridManagerServiceImpl.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenGridManagerServiceImpl.java index a3ed5ff7..39d07fc5 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenGridManagerServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenGridManagerServiceImpl.java @@ -4,7 +4,10 @@ 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.utils.DateUtils; import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.screen.form.GmUploaddataParamDTO; +import com.elink.esua.epdc.dto.screen.form.ItemCountParamDTO; import com.elink.esua.epdc.dto.screen.form.ScreenBaseReportDataFormDTO; +import com.elink.esua.epdc.dto.screen.result.CommunityProjectResultDTO; import com.elink.esua.epdc.dto.screen.result.GridManagerUploadDataResultDTO; import com.elink.esua.epdc.dto.screen.result.GridManagerUploadEventResultDTO; import com.elink.esua.epdc.modules.screen.dao.ScreenGridManagerDao; @@ -17,6 +20,9 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.Calendar; import java.util.Date; import java.util.List; @@ -34,18 +40,72 @@ public class ScreenGridManagerServiceImpl extends BaseServiceImpl gridManagerUploadDataResultDTOS = baseDao.selectGridManagerUploadData(customerId, yearMonthDay); - if(gridManagerUploadDataResultDTOS.size()!=0){ - String dataJson = ScreenDataUtils.getScreenDateJson(gridManagerUploadDataResultDTOS,true); - // 数据上报 - String body = epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_STATS_USER_GRID_MANAGER_UPLOAD_DATA, dataJson); - log.info(body); + public Result selectGridManagerUploadData(GmUploaddataParamDTO paramDto) { + paramDto.setCustomId(customerId); + + if (StringUtils.isBlank(paramDto.getEndTime())) { + // 统计截止到昨天的数据 + String yearMonthDay = DateUtils.format(DateUtils.addDateDays(new Date(), -1)); + paramDto.setYearMonthDay(yearMonthDay); + List gridManagerUploadDataResultDTOS = baseDao.selectGridManagerUploadData(paramDto); + if(gridManagerUploadDataResultDTOS.size()!=0){ + String dataJson = ScreenDataUtils.getScreenDateJson(gridManagerUploadDataResultDTOS,true); + // 数据上报 + String body = epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_STATS_USER_GRID_MANAGER_UPLOAD_DATA, dataJson); + log.info(body); + } + + + } else { + // 推送所有日期 + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + Calendar ca = Calendar.getInstance(); + Date curDate = null; + Date endDate = null; + try { + curDate = sdf.parse(paramDto.getStartTime()); + endDate = sdf.parse(paramDto.getEndTime()); + } catch (ParseException e) { + e.printStackTrace(); + } + int i =curDate.compareTo(endDate); + while (curDate.compareTo(endDate) <= 0) { + ca.setTime(curDate); + paramDto.setEndTime(sdf.format(curDate)); + ca.add(Calendar.DAY_OF_MONTH, 1); + curDate = ca.getTime(); + + // 统计截止到昨天的数据 + String yearMonthDay = DateUtils.format(DateUtils.addDateDays(new Date(), -1)); + paramDto.setYearMonthDay(yearMonthDay); + List gridManagerUploadDataResultDTOS = baseDao.selectGridManagerUploadData(paramDto); + if(gridManagerUploadDataResultDTOS.size()!=0){ + String dataJson = ScreenDataUtils.getScreenDateJson(gridManagerUploadDataResultDTOS,true); + // 数据上报 + String body = epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_STATS_USER_GRID_MANAGER_UPLOAD_DATA, dataJson); + log.info(body); + } + + } } + return new Result(); - return new Result<>(); + + + + + +// // 统计截止到昨天的数据 +// String yearMonthDay = DateUtils.format(DateUtils.addDateDays(new Date(), -1)); +// List gridManagerUploadDataResultDTOS = baseDao.selectGridManagerUploadData(customerId, yearMonthDay); +// if(gridManagerUploadDataResultDTOS.size()!=0){ +// String dataJson = ScreenDataUtils.getScreenDateJson(gridManagerUploadDataResultDTOS,true); +// // 数据上报 +// String body = epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_STATS_USER_GRID_MANAGER_UPLOAD_DATA, dataJson); +// log.info(body); +// } +// +// return new Result<>(); } @Override diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenGridManagerDao.xml b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenGridManagerDao.xml index e1f70de1..0901fa61 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenGridManagerDao.xml +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/resources/mapper/screen/ScreenGridManagerDao.xml @@ -3,154 +3,201 @@ -