diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/utils/poi/ExcelUtil.java b/ruoyi-common/src/main/java/com/ruoyi/common/utils/poi/ExcelUtil.java index c6642e7e..acad1e1e 100644 --- a/ruoyi-common/src/main/java/com/ruoyi/common/utils/poi/ExcelUtil.java +++ b/ruoyi-common/src/main/java/com/ruoyi/common/utils/poi/ExcelUtil.java @@ -30,26 +30,7 @@ import org.apache.poi.hssf.usermodel.HSSFShape; import org.apache.poi.hssf.usermodel.HSSFSheet; import org.apache.poi.hssf.usermodel.HSSFWorkbook; import org.apache.poi.ooxml.POIXMLDocumentPart; -import org.apache.poi.ss.usermodel.BorderStyle; -import org.apache.poi.ss.usermodel.Cell; -import org.apache.poi.ss.usermodel.CellStyle; -import org.apache.poi.ss.usermodel.CellType; -import org.apache.poi.ss.usermodel.ClientAnchor; -import org.apache.poi.ss.usermodel.DataValidation; -import org.apache.poi.ss.usermodel.DataValidationConstraint; -import org.apache.poi.ss.usermodel.DataValidationHelper; -import org.apache.poi.ss.usermodel.DateUtil; -import org.apache.poi.ss.usermodel.Drawing; -import org.apache.poi.ss.usermodel.FillPatternType; -import org.apache.poi.ss.usermodel.Font; -import org.apache.poi.ss.usermodel.HorizontalAlignment; -import org.apache.poi.ss.usermodel.IndexedColors; -import org.apache.poi.ss.usermodel.PictureData; -import org.apache.poi.ss.usermodel.Row; -import org.apache.poi.ss.usermodel.Sheet; -import org.apache.poi.ss.usermodel.VerticalAlignment; -import org.apache.poi.ss.usermodel.Workbook; -import org.apache.poi.ss.usermodel.WorkbookFactory; +import org.apache.poi.ss.usermodel.*; import org.apache.poi.ss.util.CellRangeAddress; import org.apache.poi.ss.util.CellRangeAddressList; import org.apache.poi.util.IOUtils; @@ -441,6 +422,9 @@ public class ExcelUtil { exportExcel(response, list, sheetName, StringUtils.EMPTY); } + public void exportImgExcel(HttpServletResponse response, List list, String sheetName,byte[] imageBytes,int width,int height) throws IOException { + exportImgExcel(response, list, sheetName, imageBytes,width,height,StringUtils.EMPTY); + } /** * 对list数据源将其里面的数据导入到excel表单 @@ -458,6 +442,12 @@ public class ExcelUtil this.init(list, sheetName, title, Type.EXPORT); exportExcel(response); } + public void exportImgExcel(HttpServletResponse response, List list, String sheetName,byte[] imageBytes, int width, int height, String title) throws IOException { + response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"); + response.setCharacterEncoding("utf-8"); + this.init(list, sheetName, title, Type.EXPORT); + exportImgExcel(response,imageBytes,width,height); + } /** * 对list数据源将其里面的数据导入到excel表单 @@ -530,6 +520,23 @@ public class ExcelUtil IOUtils.closeQuietly(wb); } } + public void exportImgExcel(HttpServletResponse response,byte[] imageBytes,int width,int height) + { + try + { + writeSheet(); + insertImage(imageBytes,width,height); + wb.write(response.getOutputStream()); + } + catch (Exception e) + { + log.error("导出Excel异常{}", e.getMessage()); + } + finally + { + IOUtils.closeQuietly(wb); + } + } /** * 对list数据源将其里面的数据导入到excel表单 @@ -1429,4 +1436,26 @@ public class ExcelUtil } return str; } + + /** + * 将图片插入到Excel工作表中 + * @param imageBytes 图片的字节数组 + * @param width 图片宽度（以列宽为单位） + * @param height 图片高度（以行高为单位） + */ + public void insertImage(byte[] imageBytes, int width, int height) throws IOException { + // 添加图片到工作簿并获取图片索引 + int pictureIdx = this.wb.addPicture(imageBytes, Workbook.PICTURE_TYPE_JPEG); + + // 创建绘图对象 + Drawing drawing = this.sheet.createDrawingPatriarch(); + + // 设置图片位置 + ClientAnchor anchor = drawing.createAnchor(0, 0, 0, 0, 0, this.list.size()+2, width, this.list.size() + 2 + height); +// ClientAnchor anchor = drawing.createAnchor(0, 0, 0, 0, 0, 5, 4, 3); + Picture pict = drawing.createPicture(anchor, pictureIdx); + + // 调整图片大小 +// pict.resize(); // 默认是100%原始大小 + } } diff --git a/zc-business/src/main/java/com/zc/business/controller/DCPerceivedEventsWarningController.java b/zc-business/src/main/java/com/zc/business/controller/DCPerceivedEventsWarningController.java index 29facecd..b847405b 100644 --- a/zc-business/src/main/java/com/zc/business/controller/DCPerceivedEventsWarningController.java +++ b/zc-business/src/main/java/com/zc/business/controller/DCPerceivedEventsWarningController.java @@ -14,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletResponse; +import java.io.IOException; import java.util.*; import java.util.stream.Collectors; @@ -364,8 +365,8 @@ public class DCPerceivedEventsWarningController extends BaseController { * @return com.ruoyi.common.core.domain.AjaxResult */ @ApiOperation(value = "导出感知事件多发时段",tags = {"ECharts导出"}) - @GetMapping("/exportManyTimesInterval") - public void exportManyTimesInterval(HttpServletResponse response,DcWarning dcWarning){ + @PostMapping("/exportManyTimesInterval") + public void exportManyTimesInterval(HttpServletResponse response,@RequestBody DcWarning dcWarning) throws IOException { if (dcWarning==null||StringUtils.isBlank(dcWarning.getType())||dcWarning.getCurrently()==null||dcWarning.getLastYear()==null ||StringUtils.isBlank(dcWarning.getStartStakeMark())||StringUtils.isBlank(dcWarning.getEndStakeMark()) ||StringUtils.isBlank(dcWarning.getDirection())){ @@ -385,7 +386,15 @@ public class DCPerceivedEventsWarningController extends BaseController { } } ExcelUtil util = new ExcelUtil<>(ManyTimesInterval.class); - util.exportExcel(response, list, UniversalEnum.PERCEIVED_EVENT_OCCURRENCE_PERIOD.getValue()); + + int commaIndex = dcWarning.getFileUrl().indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = dcWarning.getFileUrl().substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + + util.exportImgExcel(response, list, UniversalEnum.PERCEIVED_EVENT_OCCURRENCE_PERIOD.getValue(),imageBytes,6,12); } @@ -400,8 +409,8 @@ public class DCPerceivedEventsWarningController extends BaseController { return AjaxResult.success(perceivedEventsWarningService.newSelectWarningType(dcWarning)); } @ApiOperation(value = "导出感知事件类型分析",tags = {"ECharts导出"}) - @GetMapping("/exportSelectWarningType") - public void exportSelectWarningType(HttpServletResponse response,DcWarning dcWarning){ + @PostMapping("/exportSelectWarningType") + public void exportSelectWarningType(HttpServletResponse response,@RequestBody DcWarning dcWarning) throws IOException { if (dcWarning==null||StringUtils.isBlank(dcWarning.getType())||dcWarning.getCurrently()==null||dcWarning.getLastYear()==null ||StringUtils.isBlank(dcWarning.getStartStakeMark())||StringUtils.isBlank(dcWarning.getEndStakeMark()) ||StringUtils.isBlank(dcWarning.getDirection())){ @@ -425,7 +434,14 @@ public class DCPerceivedEventsWarningController extends BaseController { } } ExcelUtil util = new ExcelUtil<>(SelectWarningType.class); - util.exportExcel(response, list, UniversalEnum.PERCEPTUAL_EVENT_TYPE_ANALYSIS.getValue()); + + int commaIndex = dcWarning.getFileUrl().indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = dcWarning.getFileUrl().substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, UniversalEnum.PERCEPTUAL_EVENT_TYPE_ANALYSIS.getValue(),imageBytes,3,15); } //新-感知事件桩号范围内事件分析 @@ -440,8 +456,8 @@ public class DCPerceivedEventsWarningController extends BaseController { } @ApiOperation(value = "导出桩号范围内事件分析",tags = {"ECharts导出"}) - @GetMapping("/exportSelectSection") - public void exportSelectSection(HttpServletResponse response,DcWarning dcWarning){ + @PostMapping("/exportSelectSection") + public void exportSelectSection(HttpServletResponse response,@RequestBody DcWarning dcWarning) throws IOException { if (dcWarning==null||StringUtils.isBlank(dcWarning.getType())||dcWarning.getCurrently()==null||dcWarning.getLastYear()==null ||StringUtils.isBlank(dcWarning.getStartStakeMark())||StringUtils.isBlank(dcWarning.getEndStakeMark()) ||StringUtils.isBlank(dcWarning.getDirection())){ @@ -475,7 +491,15 @@ public class DCPerceivedEventsWarningController extends BaseController { } ExcelUtil util = new ExcelUtil<>(SelectSection.class); - util.exportExcel(response, list, UniversalEnum.EVENT_ANALYSIS_WITHIN_THE_RANGE_OF_STAKE_NUMBER.getValue()); + + int commaIndex = dcWarning.getFileUrl().indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = dcWarning.getFileUrl().substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + + util.exportImgExcel(response, list, UniversalEnum.EVENT_ANALYSIS_WITHIN_THE_RANGE_OF_STAKE_NUMBER.getValue(),imageBytes,6,12); } //新-感知事件路段处置类型分析 @@ -487,8 +511,8 @@ public class DCPerceivedEventsWarningController extends BaseController { return AjaxResult.success(perceivedEventsWarningService.newSelectStateType(dcWarning)); } @ApiOperation(value = "导出感知事件路段分析",tags = {"ECharts导出"}) - @GetMapping("/exportSelectStateType") - public void exportSelectStateType(HttpServletResponse response, DcWarning dcWarning){ + @PostMapping("/exportSelectStateType") + public void exportSelectStateType(HttpServletResponse response,@RequestBody DcWarning dcWarning) throws IOException { if (dcWarning==null||dcWarning.getCurrently()==null||dcWarning.getLastYear()==null){ return; } @@ -543,8 +567,15 @@ public class DCPerceivedEventsWarningController extends BaseController { list.add(selectStateType); } + int commaIndex = dcWarning.getFileUrl().indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = dcWarning.getFileUrl().substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + ExcelUtil util = new ExcelUtil<>(SelectStateType.class); - util.exportExcel(response, list, UniversalEnum.PERCEPTUAL_EVENT_SECTION_ANALYSIS.getValue()); + util.exportImgExcel(response, list, UniversalEnum.PERCEPTUAL_EVENT_SECTION_ANALYSIS.getValue(),imageBytes,7,14); } //查询感知数量按照路段数量进行排名 @@ -554,8 +585,8 @@ public class DCPerceivedEventsWarningController extends BaseController { } @ApiOperation(value = "导出感知事件路段排名",tags = {"ECharts导出"}) - @GetMapping("/exportSectionPerceivedList") - public void exportSectionPerceivedList(HttpServletResponse response){ + @PostMapping("/exportSectionPerceivedList") + public void exportSectionPerceivedList(HttpServletResponse response,@RequestBody Map params) throws IOException { List> dataList = perceivedEventsWarningService.selectSectionPerceivedEventsList(); List list = new ArrayList<>(); if (dataList != null && dataList.size() > UniversalEnum.ZERO.getNumber()){ @@ -568,6 +599,14 @@ public class DCPerceivedEventsWarningController extends BaseController { } } ExcelUtil util = new ExcelUtil<>(SectionPerceivedList.class); - util.exportExcel(response, list, UniversalEnum.PERCEIVED_EVENT_ROAD_RANK.getValue()); + + String fileUrl = params.get("fileUrl"); + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, UniversalEnum.PERCEIVED_EVENT_ROAD_RANK.getValue(),imageBytes,3,22); } } diff --git a/zc-business/src/main/java/com/zc/business/controller/DcPublishManageController.java b/zc-business/src/main/java/com/zc/business/controller/DcPublishManageController.java index 7642c1d2..05164ce7 100644 --- a/zc-business/src/main/java/com/zc/business/controller/DcPublishManageController.java +++ b/zc-business/src/main/java/com/zc/business/controller/DcPublishManageController.java @@ -21,6 +21,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletResponse; +import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; @@ -185,9 +186,9 @@ public class DcPublishManageController extends BaseController } @ApiOperation(value = "导出今日发布趋势分析",tags = {"ECharts导出"}) - @GetMapping("/exportTrendsPublishManage") - public void exportTrendsPublishManage(HttpServletResponse response){ - + @PostMapping("/exportTrendsPublishManage") + public void exportTrendsPublishManage(HttpServletResponse response,@RequestBody Map params) throws IOException { + String fileUrl = params.get("fileUrl"); List> data = dcPublishManageService.releaseTrendsPublishManage(); List list = new ArrayList<>(); if (data != null && data.size() > 0) { @@ -216,7 +217,15 @@ public class DcPublishManageController extends BaseController } ExcelUtil util = new ExcelUtil<>(TrendsPublishManage.class); - util.exportExcel(response, list, "今日发布趋势分析"); + + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + + util.exportImgExcel(response, list, "今日发布趋势分析",imageBytes,7,12); } //统计服务,月发布渠道趋势分析(只统计成功的) @@ -230,8 +239,8 @@ public class DcPublishManageController extends BaseController } @ApiOperation(value = "导出月发布渠道趋势分析",tags = {"ECharts导出"}) - @GetMapping("/exportMonthTrendsPublishManage") - public void exportMonthTrendsPublishManage(HttpServletResponse response,DcPublishManage dcPublishManage){ + @PostMapping("/exportMonthTrendsPublishManage") + public void exportMonthTrendsPublishManage(HttpServletResponse response,@RequestBody DcPublishManage dcPublishManage) throws IOException { List dates = new ArrayList<>(); LocalDate currentDate = LocalDate.now(); @@ -277,7 +286,13 @@ public class DcPublishManageController extends BaseController } ExcelUtil util = new ExcelUtil<>(TrendsPublishManage.class); - util.exportExcel(response, list, "月发布渠道趋势分析"); + int commaIndex = dcPublishManage.getFileUrl().indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = dcPublishManage.getFileUrl().substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, "月发布渠道趋势分析",imageBytes,7,12); } //统计服务,事件类型对应的发布渠道发布的数量(只统计成功的) @@ -296,8 +311,8 @@ public class DcPublishManageController extends BaseController return AjaxResult.success(dcPublishManageService.eventTypePublishManageMonth(dcPublishManage)); } @ApiOperation(value = "导出各事件发布渠道分析",tags = {"ECharts导出"}) - @GetMapping("/exportEventTypePublishManageMonth") - public void exportEventTypePublishManageMonth(HttpServletResponse response,DcPublishManage dcPublishManage){ + @PostMapping("/exportEventTypePublishManageMonth") + public void exportEventTypePublishManageMonth(HttpServletResponse response,@RequestBody DcPublishManage dcPublishManage) throws IOException { List> data = dcPublishManageService.eventTypePublishManageMonth(dcPublishManage); List list = new ArrayList<>(); @@ -324,7 +339,13 @@ public class DcPublishManageController extends BaseController } ExcelUtil util = new ExcelUtil<>(EventTypePublishManageMonth.class); - util.exportExcel(response, list, "各事件发布渠道分析"); + int commaIndex = dcPublishManage.getFileUrl().indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = dcPublishManage.getFileUrl().substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, "各事件发布渠道分析",imageBytes,7,12); } /** diff --git a/zc-business/src/main/java/com/zc/business/controller/DcTrafficIncidentsController.java b/zc-business/src/main/java/com/zc/business/controller/DcTrafficIncidentsController.java index c8609e4e..78d953b8 100644 --- a/zc-business/src/main/java/com/zc/business/controller/DcTrafficIncidentsController.java +++ b/zc-business/src/main/java/com/zc/business/controller/DcTrafficIncidentsController.java @@ -1,6 +1,7 @@ package com.zc.business.controller; import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.utils.StakeMarkUtils; import com.ruoyi.common.utils.poi.ExcelUtil; import com.zc.business.domain.DcEvent; import com.zc.business.domain.DcEventListQuery; @@ -24,11 +25,7 @@ import javax.servlet.ServletOutputStream; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.text.SimpleDateFormat; -import java.util.ArrayList; -import java.util.Date; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.stream.Collectors; /** @@ -183,8 +180,9 @@ public class DcTrafficIncidentsController { } @ApiOperation(value="导出今日事件趋势",tags = {"ECharts导出"}) - @GetMapping("/exportGetEventTrend") - public void exportGetEventTrend(HttpServletResponse response){ + @PostMapping("/exportGetEventTrend") + public void exportGetEventTrend(HttpServletResponse response,@RequestBody Map params) throws IOException { + String fileUrl = params.get("fileUrl"); AjaxResult ajaxResult = trafficIncidentsService.getEventTrend(); List list = new ArrayList<>(); if (ajaxResult.get("code").equals(UniversalEnum.TWO_HUNDRED.getNumber())) { @@ -201,7 +199,13 @@ public class DcTrafficIncidentsController { } ExcelUtil util = new ExcelUtil<>(EventTrend.class); - util.exportExcel(response, list, "今日事件趋势"); + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, "今日事件趋势",imageBytes,7,14); } /** * @Description 路网管控-事件管控分析-事故车型分析 @@ -609,11 +613,12 @@ public class DcTrafficIncidentsController { } @ApiOperation(value="导出事故多发路段分析",tags = {"ECharts导出"}) - @GetMapping("/exportSelectRoadSectionAnalysis") - public void exportSelectRoadSectionAnalysis(HttpServletResponse response, - @ApiParam(value="方向", name="direction", required=true) @RequestParam ("direction") String direction, - @ApiParam(value="类型(1:日, 2:月, 3:季度, 4-年)", name="type", required=true) @RequestParam ("type") String type, - @ApiParam(value="时间", name="startTime", required=true) @RequestParam ("startTime") String startTime){ + @PostMapping("/exportSelectRoadSectionAnalysis") + public void exportSelectRoadSectionAnalysis(HttpServletResponse response, @RequestBody Map params) throws IOException { + String direction = params.get("direction"); + String type = params.get("type"); + String startTime = params.get("startTime"); + String fileUrl = params.get("fileUrl"); AjaxResult ajaxResult = trafficIncidentsService.selectRoadSectionAnalysis(direction,type,startTime); List list = new ArrayList<>(); if (ajaxResult.get("code").equals(UniversalEnum.TWO_HUNDRED.getNumber())) { @@ -630,7 +635,13 @@ public class DcTrafficIncidentsController { } ExcelUtil util = new ExcelUtil<>(RoadSectionAnalysis.class); - util.exportExcel(response, list, "事故多发路段分析"); + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, "事故多发路段分析",imageBytes,8,12); } /** @@ -652,11 +663,12 @@ public class DcTrafficIncidentsController { } @ApiOperation(value="导出事故类型分析",tags = {"ECharts导出"}) - @GetMapping("/exportSelectEventTypeAnalysis") - public void exportSelectEventTypeAnalysis(HttpServletResponse response, - @ApiParam(value="方向", name="direction", required=true) @RequestParam ("direction") String direction, - @ApiParam(value="类型(1:日, 2:月, 3:季度, 4-年)", name="type", required=true) @RequestParam ("type") String type, - @ApiParam(value="时间", name="startTime", required=true) @RequestParam ("startTime") String startTime){ + @PostMapping("/exportSelectEventTypeAnalysis") + public void exportSelectEventTypeAnalysis(HttpServletResponse response,@RequestBody Map params) throws IOException { + String direction = params.get("direction"); + String type = params.get("type"); + String startTime = params.get("startTime"); + String fileUrl = params.get("fileUrl"); AjaxResult ajaxResult = trafficIncidentsService.selectEventTypeAnalysis(direction,type,startTime); List list = new ArrayList<>(); if (ajaxResult.get("code").equals(UniversalEnum.TWO_HUNDRED.getNumber())) { @@ -673,7 +685,13 @@ public class DcTrafficIncidentsController { } ExcelUtil util = new ExcelUtil<>(EventTypeAnalysis.class); - util.exportExcel(response, list, "事故类型分析"); + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, "事故类型分析",imageBytes,8,12); } //事件时间数量占比 @@ -697,4 +715,124 @@ public class DcTrafficIncidentsController { hashMap.put("lastYearMap",lastYearMap); return AjaxResult.success(hashMap); } + + //事件时间数量占比 + @PostMapping("/exportSelectEventTimeProportion") + public void exportSelectEventTimeProportion(HttpServletResponse response,@RequestBody DcWarning dcWarning) throws IOException { + if (dcWarning==null|| StringUtils.isBlank(dcWarning.getDirection())||StringUtils.isBlank(dcWarning.getType())|| + dcWarning.getCurrently()==null||dcWarning.getLastYear()==null){ + return ; + } + Date currently = dcWarning.getCurrently(); + Date lastYear = dcWarning.getLastYear(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + String formattedDate = sdf.format(currently); + String format = sdf.format(lastYear); + List> currentlyMap = trafficIncidentsService.selectEventTimeProportion(dcWarning.getDirection(), + dcWarning.getType(), formattedDate); + List> lastYearMap = trafficIncidentsService.selectEventTimeProportion(dcWarning.getDirection(), + dcWarning.getType(), format); + HashMap hashMap = new HashMap<>(); + hashMap.put("currentlyMap",currentlyMap); + hashMap.put("lastYearMap",lastYearMap); + + Set dateKey = new HashSet<>(); + String type = dcWarning.getType(); + + List list = new ArrayList<>(); + if ("1".equals(type)){ + currentlyMap.forEach(item ->{ + dateKey.add(item.get("time").toString()); + }); + lastYearMap.forEach(item ->{ + dateKey.add(item.get("time").toString()); + }); + //排序 + Set sortedDateKey = dateKey.stream() + .sorted(Comparator.comparingInt(Integer::parseInt)) + .collect(Collectors.toCollection(LinkedHashSet::new)); + for (String date : sortedDateKey) { + EventTimeProportion eventTimeProportion = new EventTimeProportion(); + eventTimeProportion.setTime(date); + for (HashMap map : currentlyMap) { + if (date.equals(map.get("time").toString())){ + eventTimeProportion.setCurrentData(map.get("number").toString()); + break; + } + } + for (HashMap map : lastYearMap) { + if (date.equals(map.get("time").toString())){ + eventTimeProportion.setContemporaneousData(map.get("number").toString()); + break; + } + } + list.add(eventTimeProportion); + } + } else if ("2".equals(type)){ + currentlyMap.forEach(item ->{ + dateKey.add(item.get("day").toString()); + }); + lastYearMap.forEach(item ->{ + dateKey.add(item.get("day").toString()); + }); + //排序 + Set sortedDateKey = dateKey.stream() + .sorted().collect(Collectors.toCollection(LinkedHashSet::new)); + for (String date : sortedDateKey) { + EventTimeProportion eventTimeProportion = new EventTimeProportion(); + eventTimeProportion.setTime(date); + for (HashMap map : currentlyMap) { + if (date.equals(map.get("day").toString())){ + eventTimeProportion.setCurrentData(map.get("num").toString()); + break; + } + } + for (HashMap map : lastYearMap) { + if (date.equals(map.get("day").toString())){ + eventTimeProportion.setContemporaneousData(map.get("num").toString()); + break; + } + } + list.add(eventTimeProportion); + } + } else if ("3".equals(type) || "4".equals(type)){ + currentlyMap.forEach(item ->{ + dateKey.add(item.get("month").toString()); + }); + lastYearMap.forEach(item ->{ + dateKey.add(item.get("month").toString()); + }); + //排序 + Set sortedDateKey = dateKey.stream() + .sorted(Comparator.comparingInt(Integer::parseInt)) + .collect(Collectors.toCollection(LinkedHashSet::new)); + for (String date : sortedDateKey) { + EventTimeProportion eventTimeProportion = new EventTimeProportion(); + eventTimeProportion.setTime(date); + for (HashMap map : currentlyMap) { + if (date.equals(map.get("month").toString())){ + eventTimeProportion.setCurrentData(map.get("number").toString()); + break; + } + } + for (HashMap map : lastYearMap) { + if (date.equals(map.get("month").toString())){ + eventTimeProportion.setContemporaneousData(map.get("number").toString()); + break; + } + } + list.add(eventTimeProportion); + } + } + + ExcelUtil util = new ExcelUtil<>(EventTimeProportion.class); + int commaIndex = dcWarning.getFileUrl().indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = dcWarning.getFileUrl().substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, "事故时间分布",imageBytes,8,12); + + } } diff --git a/zc-business/src/main/java/com/zc/business/controller/DcTrafficStatisticsController.java b/zc-business/src/main/java/com/zc/business/controller/DcTrafficStatisticsController.java index 907a5618..36772366 100644 --- a/zc-business/src/main/java/com/zc/business/controller/DcTrafficStatisticsController.java +++ b/zc-business/src/main/java/com/zc/business/controller/DcTrafficStatisticsController.java @@ -289,8 +289,12 @@ public class DcTrafficStatisticsController extends BaseController { * @param periodType 时间粒子 */ @ApiOperation(value = "导出全路段车流量状况分析", tags = {"ECharts导出"}) - @GetMapping("/history/exportRealTimeTrafficFlow") - public void exportRealTimeTrafficFlow(HttpServletResponse response, String startDate, String direction, String periodType) { + @PostMapping("/history/exportRealTimeTrafficFlow") + public void exportRealTimeTrafficFlow(HttpServletResponse response,@RequestBody Map params) throws IOException { + String startDate = params.get("startDate"); + String direction = params.get("direction"); + String periodType = params.get("periodType"); + String fileUrl = params.get("fileUrl"); if (StringUtils.isEmpty(startDate) || StringUtils.isEmpty(direction) || StringUtils.isEmpty(periodType)) { return; } @@ -346,7 +350,14 @@ public class DcTrafficStatisticsController extends BaseController { } ExcelUtil util = new ExcelUtil<>(RealTimeTrafficFlow.class); - util.exportExcel(response, list, UniversalEnum.THE_WHOLE_SECTION_TWO_WAY_REAL_TIME_TRAFFIC_FLOW.getValue()); + + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, UniversalEnum.THE_WHOLE_SECTION_TWO_WAY_REAL_TIME_TRAFFIC_FLOW.getValue(),imageBytes,5,12); // 将查询结果封装为成功响应并返回 } @@ -397,8 +408,12 @@ public class DcTrafficStatisticsController extends BaseController { * @param periodType 时间粒子 */ @ApiOperation(value = "导出车流量时段分析", tags = {"ECharts导出"}) - @GetMapping("/history/exportTrafficPeriodAnalysis") - public void exportTrafficPeriodAnalysis(HttpServletResponse response, String startDate, String direction, String periodType) { + @PostMapping("/history/exportTrafficPeriodAnalysis") + public void exportTrafficPeriodAnalysis(HttpServletResponse response,@RequestBody Map params) throws IOException { + String startDate = params.get("startDate"); + String direction = params.get("direction"); + String periodType = params.get("periodType"); + String fileUrl = params.get("fileUrl"); if (StringUtils.isEmpty(startDate) || StringUtils.isEmpty(direction) || StringUtils.isEmpty(periodType)) { return; } @@ -454,7 +469,14 @@ public class DcTrafficStatisticsController extends BaseController { } ExcelUtil util = new ExcelUtil<>(TrafficPeriodAnalysis.class); - util.exportExcel(response, list, UniversalEnum.TRAFFIC_PERIOD_ANALYSIS.getValue()); + + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, UniversalEnum.TRAFFIC_PERIOD_ANALYSIS.getValue(),imageBytes,5,12); } @ApiOperation("断面车流量排名") @@ -474,8 +496,12 @@ public class DcTrafficStatisticsController extends BaseController { * @param periodType 时间粒子 */ @ApiOperation(value = "导出断面车流量排名", tags = {"ECharts导出"}) - @GetMapping("/history/exportSectionTrafficRanking") - public void exportSectionTrafficRanking(HttpServletResponse response, String startDate, String direction, String periodType) { + @PostMapping("/history/exportSectionTrafficRanking") + public void exportSectionTrafficRanking(HttpServletResponse response,@RequestBody Map params) throws IOException { + String startDate = params.get("startDate"); + String direction = params.get("direction"); + String periodType = params.get("periodType"); + String fileUrl = params.get("fileUrl"); List list = new ArrayList<>(); List> dcStatisticsData = dcGantryStatisticsDataService.sectionTrafficRanking(startDate, direction, periodType); for (int i = UniversalEnum.ZERO.getNumber(); i < dcStatisticsData.size(); i++) { @@ -487,7 +513,15 @@ public class DcTrafficStatisticsController extends BaseController { } ExcelUtil util = new ExcelUtil<>(SectionTrafficRanking.class); - util.exportExcel(response, list, UniversalEnum.SECTION_TRAFFIC_RANKING.getValue()); + + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + + util.exportImgExcel(response, list, UniversalEnum.SECTION_TRAFFIC_RANKING.getValue(),imageBytes,3,28); } @@ -508,8 +542,17 @@ public class DcTrafficStatisticsController extends BaseController { } @ApiOperation(value = "导出路段交通指标分析", tags = {"ECharts导出"}) - @GetMapping("/history/exportSectionTrafficIndexAnalysis") - public void exportSectionTrafficIndexAnalysis(HttpServletResponse response, String startDate, String direction, String periodType, Long ranking) { + @PostMapping("/history/exportSectionTrafficIndexAnalysis") + public void exportSectionTrafficIndexAnalysis(HttpServletResponse response,@RequestBody Map params) throws IOException { + String startDate = params.get("startDate").toString(); + String direction = params.get("direction").toString(); + String periodType = params.get("periodType").toString(); + Long ranking = null; + if (params.containsKey("ranking")){ + ranking = Long.valueOf(params.get("ranking").toString()); + } + String fileUrl = params.get("fileUrl").toString(); + List list = new ArrayList<>(); String endDate = UniversalEnum.EMPTY_STRING.getValue(); @@ -571,7 +614,13 @@ public class DcTrafficStatisticsController extends BaseController { } ExcelUtil util = new ExcelUtil<>(SectionTrafficIndexAnalysis.class); - util.exportExcel(response, list, UniversalEnum.SECTION_TRAFFIC_INDEX_ANALYSIS.getValue()); + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, UniversalEnum.SECTION_TRAFFIC_INDEX_ANALYSIS.getValue(),imageBytes,7,14); // 将查询结果封装为成功响应并返回 } @@ -584,8 +633,13 @@ public class DcTrafficStatisticsController extends BaseController { } @ApiOperation(value = "导出交通指标时间分布", tags = {"ECharts导出"}) - @GetMapping("/history/exportPassIndicatorTimeDistribution") - public void exportPassIndicatorTimeDistribution(HttpServletResponse response, String startDate, String direction, String periodType) { + @PostMapping("/history/exportPassIndicatorTimeDistribution") + public void exportPassIndicatorTimeDistribution(HttpServletResponse response, @RequestBody Map params) throws IOException { + String startDate = params.get("startDate"); + String direction = params.get("direction"); + String periodType = params.get("periodType"); + String fileUrl = params.get("fileUrl"); + List list = new ArrayList<>(); String endDate = UniversalEnum.EMPTY_STRING.getValue(); @@ -686,7 +740,14 @@ public class DcTrafficStatisticsController extends BaseController { } ExcelUtil util = new ExcelUtil<>(PassIndicatorTimeDistribution.class); - util.exportExcel(response, list, "交通指标时间分布"); + + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + util.exportImgExcel(response, list, "交通指标时间分布",imageBytes,7,14); // 将查询结果封装为成功响应并返回 } @@ -922,8 +983,8 @@ public class DcTrafficStatisticsController extends BaseController { * 导出收费站出入口实时车流量 */ @ApiOperation(value = "导出收费站出入口实时车流量", tags = {"ECharts导出"}) - @GetMapping("/history/exportTrafficFlowAtTollStationEntranceHour") - public void exportTrafficFlowAtTollStationEntranceHour(HttpServletResponse response) throws IOException, HttpException { + @PostMapping("/history/exportTrafficFlowAtTollStationEntranceHour") + public void exportTrafficFlowAtTollStationEntranceHour(HttpServletResponse response,@RequestBody Map params) throws IOException, HttpException { response.setContentType(UniversalEnum.DERIVE_THE_TWO_WAY_REAL_TIME_TRAFFIC_FLOW_OF_THE_WHOLE_SECTION.getValue()); response.setCharacterEncoding(UniversalEnum.LOWERCASE_UTF_8.getValue()); @@ -1104,6 +1165,21 @@ public class DcTrafficStatisticsController extends BaseController { // 写入文件 try (ServletOutputStream outputStream = response.getOutputStream()) { + String fileUrl = params.get("fileUrl"); + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + // 添加图片到工作簿并获取图片索引 + int pictureIdx = workbook.addPicture(imageBytes, Workbook.PICTURE_TYPE_JPEG); + // 创建绘图对象 + Drawing drawing = sheet.createDrawingPatriarch(); + // 设置图片位置 + ClientAnchor anchor = drawing.createAnchor(0, 0, 0, 0, 0, LocationEnum.values().length+3, 12, LocationEnum.values().length + 3 + 12); + Picture pict = drawing.createPicture(anchor, pictureIdx); + workbook.write(outputStream); } finally { workbook.close(); @@ -1171,8 +1247,8 @@ public class DcTrafficStatisticsController extends BaseController { * 导出全路段双向实时车流量 */ @ApiOperation(value = "导出全路段双向实时车流量", tags = {"ECharts导出"}) - @GetMapping("/history/exportRealTimeTrafficFlowHour") - public void exportRealTimeTrafficFlowHour(HttpServletResponse response) throws IOException, HttpException { + @PostMapping("/history/exportRealTimeTrafficFlowHour") + public void exportRealTimeTrafficFlowHour(HttpServletResponse response,@RequestBody Map params) throws IOException, HttpException { response.setContentType(UniversalEnum.DERIVE_THE_TWO_WAY_REAL_TIME_TRAFFIC_FLOW_OF_THE_WHOLE_SECTION.getValue()); response.setCharacterEncoding(UniversalEnum.LOWERCASE_UTF_8.getValue()); @@ -1289,6 +1365,21 @@ public class DcTrafficStatisticsController extends BaseController { // 写入文件 try (ServletOutputStream outputStream = response.getOutputStream()) { + String fileUrl = params.get("fileUrl"); + int commaIndex = fileUrl.indexOf(','); + if (commaIndex == -1) { + throw new IllegalArgumentException("Invalid Data URL, no comma found to separate base64 data"); + } + String base64Data = fileUrl.substring(commaIndex + 1); + byte[] imageBytes = Base64.getDecoder().decode(base64Data); + // 添加图片到工作簿并获取图片索引 + int pictureIdx = workbook.addPicture(imageBytes, Workbook.PICTURE_TYPE_JPEG); + // 创建绘图对象 + Drawing drawing = sheet.createDrawingPatriarch(); + // 设置图片位置 + ClientAnchor anchor = drawing.createAnchor(0, 0, 0, 0, 0, thisYearHZ.size()+3, 12, thisYearHZ.size() + 3 + 12); + Picture pict = drawing.createPicture(anchor, pictureIdx); + workbook.write(outputStream); } finally { workbook.close(); diff --git a/zc-business/src/main/java/com/zc/business/domain/DcPublishManage.java b/zc-business/src/main/java/com/zc/business/domain/DcPublishManage.java index 48b0b379..c7b82781 100644 --- a/zc-business/src/main/java/com/zc/business/domain/DcPublishManage.java +++ b/zc-business/src/main/java/com/zc/business/domain/DcPublishManage.java @@ -173,4 +173,5 @@ public class DcPublishManage extends BaseEntity { private Long logId; @TableField(exist = false) private String ip; + private String fileUrl; } \ No newline at end of file diff --git a/zc-business/src/main/java/com/zc/business/domain/DcWarning.java b/zc-business/src/main/java/com/zc/business/domain/DcWarning.java index aab5e4d4..1d951f43 100644 --- a/zc-business/src/main/java/com/zc/business/domain/DcWarning.java +++ b/zc-business/src/main/java/com/zc/business/domain/DcWarning.java @@ -163,6 +163,15 @@ public class DcWarning extends BaseEntity private Date currently; private Long facilityId; + private String fileUrl; + + public String getFileUrl() { + return fileUrl; + } + + public void setFileUrl(String fileUrl) { + this.fileUrl = fileUrl; + } public Long getFacilityId() { return facilityId; diff --git a/zc-business/src/main/java/com/zc/business/domain/export/EventTimeProportion.java b/zc-business/src/main/java/com/zc/business/domain/export/EventTimeProportion.java new file mode 100644 index 00000000..8de65056 --- /dev/null +++ b/zc-business/src/main/java/com/zc/business/domain/export/EventTimeProportion.java @@ -0,0 +1,62 @@ +package com.zc.business.domain.export; + +import com.ruoyi.common.annotation.Excel; +import com.ruoyi.common.core.domain.BaseEntity; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; + +/** + * 导出事故时间分析对象 + * + * @author ruoyi + * @date 2024-01-13 + */ +public class EventTimeProportion extends BaseEntity +{ + private static final long serialVersionUID = 1L; + + + /** 时间 */ + @Excel(name = "时间") + private String time; + + /** 事件数量 */ + @Excel(name = "事件数量(起)") + private String currentData; + /** 去年同期 */ + @Excel(name = "去年同期(起)") + private String contemporaneousData; + + public String getTime() { + return time; + } + + public void setTime(String time) { + this.time = time; + } + + public String getCurrentData() { + return currentData; + } + + public void setCurrentData(String currentData) { + this.currentData = currentData; + } + + public String getContemporaneousData() { + return contemporaneousData; + } + + public void setContemporaneousData(String contemporaneousData) { + this.contemporaneousData = contemporaneousData; + } + + @Override + public String toString() { + return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) + .append("time", getTime()) + .append("currentData", getCurrentData()) + .append("contemporaneousData", getContemporaneousData()) + .toString(); + } +}