diff --git a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenGridManagerController.java b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenGridManagerController.java index bc65e98..719ad87 100644 --- a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenGridManagerController.java +++ b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenGridManagerController.java @@ -40,7 +40,7 @@ public class ScreenGridManagerController { * @return com.elink.esua.epdc.commons.tools.utils.Result> **/ @PostMapping("gridManagerUploadEvent") - public Result selectGridManagerUploadEvent(@RequestBody ScreenJobFormDTO formDto) { - return screenGridManagerService.selectGridManagerUploadEvent(formDto.getYearMonth()); + public Result selectGridManagerUploadEvent(@RequestBody ScreenJobFormDTO paramDto) { + return screenGridManagerService.selectGridManagerUploadEvent(paramDto); } } diff --git a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenGridManagerDao.java b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenGridManagerDao.java index fdb5ef5..f4e565e 100644 --- a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenGridManagerDao.java +++ b/epdc-cloud-analysis-pc/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.analysis.pc.screen.form.ScreenJobFormDTO; import com.elink.esua.epdc.dto.analysis.pc.screen.result.GridManagerUploadDataResultDTO; import com.elink.esua.epdc.dto.analysis.pc.screen.result.GridManagerUploadEventResultDTO; import com.elink.esua.epdc.dto.analysis.pc.screen.result.ScreenBaseReportResultDTO; @@ -32,7 +33,7 @@ public interface ScreenGridManagerDao extends BaseDao * @Param [customId] * @return java.util.List **/ - List selectGridManagerUploadEvent(@Param("customId")String customId, @Param("yearMonthDay") String yearMonthDay); + List selectGridManagerUploadEvent(ScreenJobFormDTO paramDto); } diff --git a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenGridManagerService.java b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenGridManagerService.java index 97537a4..6945228 100644 --- a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenGridManagerService.java +++ b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenGridManagerService.java @@ -1,6 +1,7 @@ package com.elink.esua.epdc.modules.screen.service; import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.analysis.pc.screen.form.ScreenJobFormDTO; /** * 网格管理 @@ -25,7 +26,7 @@ public interface ScreenGridManagerService { * @Param [customId] * @return java.util.List **/ - Result selectGridManagerUploadEvent(String yearMonthDay); + Result selectGridManagerUploadEvent(ScreenJobFormDTO paramDto); diff --git a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenGridManagerServiceImpl.java b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenGridManagerServiceImpl.java index cf1a021..a3ea494 100644 --- a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenGridManagerServiceImpl.java +++ b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenGridManagerServiceImpl.java @@ -4,6 +4,7 @@ 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.analysis.pc.screen.form.ScreenJobFormDTO; import com.elink.esua.epdc.dto.analysis.pc.screen.result.GridManagerUploadDataResultDTO; import com.elink.esua.epdc.dto.analysis.pc.screen.result.GridManagerUploadEventResultDTO; import com.elink.esua.epdc.dto.analysis.pc.screen.result.ScreenBaseReportResultDTO; @@ -18,6 +19,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; @@ -56,15 +60,71 @@ public class ScreenGridManagerServiceImpl extends BaseServiceImpl gridManagerUploadEventResultDTOS = baseDao.selectGridManagerUploadEvent(customerId, yearMonthDay); - if(gridManagerUploadEventResultDTOS.size()>0){ - String dataJson = ScreenDataUtils.getScreenDateJson(gridManagerUploadEventResultDTOS,true); - // 数据上报 - epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_STATS_USER_GRID_MANAGER_UPLOAD_EVENT, dataJson); + public Result selectGridManagerUploadEvent(ScreenJobFormDTO paramDto) { + paramDto.setCustomId(customerId); + + + if (StringUtils.isBlank(paramDto.getEndTime())) { + + // 如果统计年月日为空,则统计当前天的数据 + String yearMonthDay = paramDto.getYearMonth(); + yearMonthDay = StringUtils.isEmpty(yearMonthDay) ? DateUtils.format(new Date()) : yearMonthDay; + paramDto.setYearMonthDay(yearMonthDay); + List gridManagerUploadEventResultDTOS = baseDao.selectGridManagerUploadEvent(paramDto); + if(gridManagerUploadEventResultDTOS.size()>0){ + String dataJson = ScreenDataUtils.getScreenDateJson(gridManagerUploadEventResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_STATS_USER_GRID_MANAGER_UPLOAD_EVENT, dataJson); + } + + + } 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 = paramDto.getYearMonth(); + yearMonthDay = StringUtils.isEmpty(yearMonthDay) ? DateUtils.format(new Date()) : yearMonthDay; + paramDto.setYearMonthDay(yearMonthDay); + List gridManagerUploadEventResultDTOS = baseDao.selectGridManagerUploadEvent(paramDto); + if(gridManagerUploadEventResultDTOS.size()>0){ + String dataJson = ScreenDataUtils.getScreenDateJson(gridManagerUploadEventResultDTOS,true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_STATS_USER_GRID_MANAGER_UPLOAD_EVENT, dataJson); + } + + } } - return new Result<>(); + return new Result(); + + + + + +// // 如果统计年月日为空,则统计当前天的数据 +// String yearMonthDay = paramDto.getYearMonth(); +// yearMonthDay = StringUtils.isEmpty(yearMonthDay) ? DateUtils.format(new Date()) : yearMonthDay; +// List gridManagerUploadEventResultDTOS = baseDao.selectGridManagerUploadEvent(customerId, yearMonthDay); +// if(gridManagerUploadEventResultDTOS.size()>0){ +// String dataJson = ScreenDataUtils.getScreenDateJson(gridManagerUploadEventResultDTOS,true); +// // 数据上报 +// epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_STATS_USER_GRID_MANAGER_UPLOAD_EVENT, dataJson); +// } +// return new Result<>(); } } diff --git a/epdc-cloud-analysis-pc/src/main/resources/mapper/screen/ScreenGridManagerDao.xml b/epdc-cloud-analysis-pc/src/main/resources/mapper/screen/ScreenGridManagerDao.xml index 30d6601..0e9eb07 100644 --- a/epdc-cloud-analysis-pc/src/main/resources/mapper/screen/ScreenGridManagerDao.xml +++ b/epdc-cloud-analysis-pc/src/main/resources/mapper/screen/ScreenGridManagerDao.xml @@ -160,10 +160,24 @@ -