From dbf1793b62b69f824a401242cfd5430dd4992fa8 Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期一, 18 十一月 2024 12:01:14 +0800 Subject: [PATCH] 运行监控导出 --- ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java | 2 ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java | 3 ycl-pojo/src/main/java/com/ycl/platform/domain/excel/TMonitorExp.java | 66 ++++++++++++++++ ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java | 14 ++ ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml | 26 ++++++ ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java | 88 +++++++++++++++++----- 6 files changed, 176 insertions(+), 23 deletions(-) diff --git a/ycl-pojo/src/main/java/com/ycl/platform/domain/excel/TMonitorExp.java b/ycl-pojo/src/main/java/com/ycl/platform/domain/excel/TMonitorExp.java new file mode 100644 index 0000000..a5edb27 --- /dev/null +++ b/ycl-pojo/src/main/java/com/ycl/platform/domain/excel/TMonitorExp.java @@ -0,0 +1,66 @@ +package com.ycl.platform.domain.excel; + +import annotation.Excel; +import com.ycl.platform.domain.vo.DynamicColumnVO; +import lombok.Data; + +import java.util.List; + +@Data +public class TMonitorExp { + /** + * 璁惧缂栫爜 + */ + @Excel(name = "璁惧缂栫爜") + private String serialNumber; + + /** + * 璁惧鍚嶇О + */ + @Excel(name = "璁惧鍚嶇О") + private String name; + + /** + * 鎽勫儚鏈篒PV4鎴朓PV6鍦板潃 + */ + @Excel(name = "IP") + private String ip; + + /** + * 鎽勫儚鏈哄姛鑳界被鍨媅1.瑙嗛鐩戞帶;2.杞﹁締璇嗗埆;3.浜哄憳璇嗗埆;] 鏁版嵁鏍煎紡[濉叆澶氫釜鍊煎苟浠�/闅斿紑銆備緥濡� 1/2] + */ + @Excel(name = "鎽勫儚鏈哄姛鑳界被鍨�") + private String cameraFunType; + + /** + * 璁惧鐘舵�� + */ + @Excel(name = "鐘舵��", readConverterExp = "-1=绂荤嚎,1=鍦ㄧ嚎,0=鏈煡") + private Integer onState; + /** + * 琛屾斂鍖哄煙 + */ + @Excel(name = "琛屾斂鍖哄煙") + private String deptName; + + /** + * 绠$悊鍗曚綅 + */ + @Excel(name = "绠$悊鍗曚綅") + private String managementUnit; + /** + * 鏍囩 + */ + @Excel(name = "鏍囩") + private String tag; + private Boolean provinceTag; + private Boolean deptTag; + private Boolean importantTag; + private Boolean importantCommandImageTag; + + private Integer pointId; + /** + * 鍔ㄦ�佸垪 + */ + private List<DynamicColumnVO> dynamicColumnList; +} diff --git a/ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java b/ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java index 32d1f22..48f4102 100644 --- a/ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java +++ b/ycl-server/src/main/java/com/ycl/platform/controller/TMonitorController.java @@ -83,7 +83,7 @@ /** * 鑾峰彇璁惧璧勪骇璇︾粏淇℃伅 */ - @PreAuthorize("@ss.hasPermi('system:monitor:query')") + @PreAuthorize("@ss.hasPermi('system:monitor:query')") @GetMapping(value = "/{id}") public AjaxResult getInfo(@PathVariable("id") Long id) { @@ -93,7 +93,7 @@ /** * 鏂板璁惧璧勪骇 */ - @PreAuthorize("@ss.hasPermi('system:monitor:add')") + @PreAuthorize("@ss.hasPermi('system:monitor:add')") @Log(title = "璁惧璧勪骇", businessType = BusinessType.INSERT) @PostMapping public AjaxResult add(@RequestBody TMonitor tMonitor) @@ -142,6 +142,14 @@ { return success(tMonitorService.recoveryException(monitor)); } - + /** + * 瀵煎嚭 + */ + @PreAuthorize("@ss.hasPermi('system:monitor:export')") + @Log(title = "瀵煎嚭", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response,TMonitorVO tMonitor) throws IOException, NoSuchFieldException, IllegalAccessException { + tMonitorService.export(response,tMonitor); + } } diff --git a/ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java b/ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java index 893cac3..ecfd274 100644 --- a/ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java +++ b/ycl-server/src/main/java/com/ycl/platform/mapper/TMonitorMapper.java @@ -3,6 +3,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.ycl.platform.domain.entity.TMonitor; +import com.ycl.platform.domain.excel.TMonitorExp; import com.ycl.platform.domain.form.VideoExportForm; import com.ycl.platform.domain.query.DashboardQuery; import com.ycl.platform.domain.query.DataCenterQuery; @@ -180,4 +181,6 @@ void batchUpdateOnline(@Param("ipList")List<String> ipList,@Param("date") Date date,@Param("online")Integer online); List<TMonitor> selectCarOrFace(); + + List<TMonitorExp> exportTMonitorList(TMonitorVO tMonitor); } diff --git a/ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java b/ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java index 7862bc6..3b8a84b 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java +++ b/ycl-server/src/main/java/com/ycl/platform/service/ITMonitorService.java @@ -128,4 +128,6 @@ Map<String, Object> carHome(HomeQuery monitorQuery) throws ParseException, InvocationTargetException, NoSuchMethodException, InstantiationException, IllegalAccessException; Map<String, Object> videoHome(HomeQuery monitorQuery) throws ParseException, InvocationTargetException, NoSuchMethodException, InstantiationException, IllegalAccessException; + + void export(HttpServletResponse response, TMonitorVO tMonitor); } diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java index 32b9f2c..6fc3f24 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java +++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java @@ -7,6 +7,7 @@ import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import com.ycl.platform.domain.entity.TMonitor; +import com.ycl.platform.domain.excel.TMonitorExp; import com.ycl.platform.domain.excel.VideoDailyExp; import com.ycl.platform.domain.excel.VideoTotalExp; import com.ycl.platform.domain.form.VideoExportForm; @@ -40,6 +41,7 @@ import com.ycl.system.service.ISysConfigService; import com.ycl.utils.DateUtils; import com.ycl.utils.StringUtils; +import com.ycl.utils.poi.ExcelUtil; import constant.ApiConstants; import constant.CheckConstants; import enumeration.general.AreaDeptEnum; @@ -134,7 +136,7 @@ for (TMonitorVO monitor : monitors) { if (!CollectionUtils.isEmpty(voList)) { for (WorkOrderVO workOrderVO : voList) { - if (monitor.getWorkOrderNo()!=null && monitor.getWorkOrderNo().equals(workOrderVO.getWorkOrderNo())) { + if (monitor.getWorkOrderNo() != null && monitor.getWorkOrderNo().equals(workOrderVO.getWorkOrderNo())) { monitor.setUnitContact(workOrderVO.getUnitContact()); monitor.setUnitContactPhone(workOrderVO.getUnitContactPhone()); monitor.setYwPeopleName(workOrderVO.getYwPeopleName()); @@ -416,7 +418,7 @@ @Override public void exportVideoTotal(HttpServletResponse response, VideoExportForm exportForm) throws IOException { //榛樿鏌ユ墍鏈夐儴闂� - if(CollectionUtils.isEmpty(exportForm.getDeptIds())){ + if (CollectionUtils.isEmpty(exportForm.getDeptIds())) { List<Integer> deptIds = new ArrayList<>(); for (AreaDeptEnum value : AreaDeptEnum.values()) { deptIds.add(value.getDeptId()); @@ -464,7 +466,7 @@ long count = onlines.stream() .filter(item -> ApiConstants.UY_OnlineSite_Online.equals(item.getOnline())) .count(); - videoExp.setOnline(Integer.valueOf(count+"")); + videoExp.setOnline(Integer.valueOf(count + "")); videoExp.setOffline(videoExp.getTotal() - videoExp.getOnline()); } //璁剧疆瀛樺偍鎯呭喌 @@ -509,7 +511,7 @@ @Override public void exportVideoOnline(HttpServletResponse response, VideoExportForm exportForm) throws IOException, NoSuchFieldException, IllegalAccessException { //榛樿鏌ユ墍鏈夐儴闂� - if(CollectionUtils.isEmpty(exportForm.getDeptIds())){ + if (CollectionUtils.isEmpty(exportForm.getDeptIds())) { List<Integer> deptIds = new ArrayList<>(); for (AreaDeptEnum value : AreaDeptEnum.values()) { deptIds.add(value.getDeptId()); @@ -524,7 +526,7 @@ List<Integer> pointIds = tMonitorResults.stream().map(TMonitorResult::getPointId).collect(Collectors.toList()); List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds); //琛ュ厖鍔ㄦ�佸垪鏁版嵁 - if(!CollectionUtils.isEmpty(dynamics)) { + if (!CollectionUtils.isEmpty(dynamics)) { Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId)); for (TMonitorResult tMonitorResult : tMonitorResults) { Integer pointId = tMonitorResult.getPointId(); @@ -553,7 +555,7 @@ videoDailyExp.setArea(areaDeptEnum == null ? "鏈煡" : areaDeptEnum.getName()); StringBuilder tag = new StringBuilder("" + (result.getProvinceTag() ? "鐪佸巺銆�" : "") + (result.getImportantTag() ? "閲嶇偣鐐逛綅銆�" : "") + (result.getImportantCommandImageTag() ? "閲嶇偣鎸囨尌鍥惧儚銆�" : "") + (result.getDeptTag() ? "閮ㄧ骇銆�" : "")); //鍔ㄦ�佸垪澶勭悊鍔犲湪鏍囩閲� - if(!CollectionUtils.isEmpty(result.getDynamicColumnList())){ + if (!CollectionUtils.isEmpty(result.getDynamicColumnList())) { List<DynamicColumnVO> dynamicColumnList = result.getDynamicColumnList(); for (DynamicColumnVO dynamicColumnVO : dynamicColumnList) { tag.append(dynamicColumnVO.getColumnValue()).append("銆�"); @@ -585,7 +587,7 @@ @Override public void exportVideoRecord(HttpServletResponse response, VideoExportForm exportForm) throws IOException, NoSuchFieldException, IllegalAccessException { //榛樿鏌ユ墍鏈夐儴闂� - if(CollectionUtils.isEmpty(exportForm.getDeptIds())){ + if (CollectionUtils.isEmpty(exportForm.getDeptIds())) { List<Integer> deptIds = new ArrayList<>(); for (AreaDeptEnum value : AreaDeptEnum.values()) { deptIds.add(value.getDeptId()); @@ -600,7 +602,7 @@ List<Integer> pointIds = tMonitorResults.stream().map(TMonitorResult::getPointId).collect(Collectors.toList()); List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds); //琛ュ厖鍔ㄦ�佸垪鏁版嵁 - if(!CollectionUtils.isEmpty(dynamics)) { + if (!CollectionUtils.isEmpty(dynamics)) { Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId)); for (TMonitorResult tMonitorResult : tMonitorResults) { Integer pointId = tMonitorResult.getPointId(); @@ -629,7 +631,7 @@ videoDailyExp.setArea(areaDeptEnum == null ? "鏈煡" : areaDeptEnum.getName()); StringBuilder tag = new StringBuilder("" + (result.getProvinceTag() ? "鐪佸巺銆�" : "") + (result.getImportantTag() ? "閲嶇偣鐐逛綅銆�" : "") + (result.getImportantCommandImageTag() ? "閲嶇偣鎸囨尌鍥惧儚銆�" : "") + (result.getDeptTag() ? "閮ㄧ骇銆�" : "")); //鍔ㄦ�佸垪澶勭悊鍔犲湪鏍囩閲� - if(!CollectionUtils.isEmpty(result.getDynamicColumnList())){ + if (!CollectionUtils.isEmpty(result.getDynamicColumnList())) { List<DynamicColumnVO> dynamicColumnList = result.getDynamicColumnList(); for (DynamicColumnVO dynamicColumnVO : dynamicColumnList) { tag.append(dynamicColumnVO.getColumnValue()).append("銆�"); @@ -661,7 +663,7 @@ @Override public void exportVideoLoseTime(HttpServletResponse response, VideoExportForm exportForm) throws NoSuchFieldException, IllegalAccessException, IOException { //榛樿鏌ユ墍鏈夐儴闂� - if(CollectionUtils.isEmpty(exportForm.getDeptIds())){ + if (CollectionUtils.isEmpty(exportForm.getDeptIds())) { List<Integer> deptIds = new ArrayList<>(); for (AreaDeptEnum value : AreaDeptEnum.values()) { deptIds.add(value.getDeptId()); @@ -676,7 +678,7 @@ List<Integer> pointIds = tMonitorResults.stream().map(TMonitorResult::getPointId).collect(Collectors.toList()); List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds); //琛ュ厖鍔ㄦ�佸垪鏁版嵁 - if(!CollectionUtils.isEmpty(dynamics)) { + if (!CollectionUtils.isEmpty(dynamics)) { Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId)); for (TMonitorResult tMonitorResult : tMonitorResults) { Integer pointId = tMonitorResult.getPointId(); @@ -705,7 +707,7 @@ videoDailyExp.setArea(areaDeptEnum == null ? "鏈煡" : areaDeptEnum.getName()); StringBuilder tag = new StringBuilder("" + (result.getProvinceTag() ? "鐪佸巺銆�" : "") + (result.getImportantTag() ? "閲嶇偣鐐逛綅銆�" : "") + (result.getImportantCommandImageTag() ? "閲嶇偣鎸囨尌鍥惧儚銆�" : "") + (result.getDeptTag() ? "閮ㄧ骇銆�" : "")); //鍔ㄦ�佸垪澶勭悊鍔犲湪鏍囩閲� - if(!CollectionUtils.isEmpty(result.getDynamicColumnList())){ + if (!CollectionUtils.isEmpty(result.getDynamicColumnList())) { List<DynamicColumnVO> dynamicColumnList = result.getDynamicColumnList(); for (DynamicColumnVO dynamicColumnVO : dynamicColumnList) { tag.append(dynamicColumnVO.getColumnValue()).append("銆�"); @@ -815,7 +817,7 @@ new Document("$group", new Document("_id", "$mongoCreateTime") .append("onlineCount", new Document("$sum", new Document("$cond", Arrays.asList( - new Document("$eq", Arrays.asList("$online",ApiConstants.UY_OnlineSite_Online)), + new Document("$eq", Arrays.asList("$online", ApiConstants.UY_OnlineSite_Online)), 1, 0 )) @@ -847,6 +849,52 @@ resultMap.put("baseLine", Integer.valueOf(sysDictData.getDictValue())); } return resultMap; + } + + /** + * 鍒楄〃瀵煎嚭 + * + * @param response + * @param tMonitor + */ + @Override + public void export(HttpServletResponse response, TMonitorVO tMonitor) { + List<TMonitorExp> monitors = tMonitorMapper.exportTMonitorList(tMonitor); + //鑾峰彇鍔ㄦ�佸垪鏁版嵁 + List<Integer> pointIds = monitors.stream().map(TMonitorExp::getPointId).collect(Collectors.toList()); + List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds); + //琛ュ厖鍔ㄦ�佸垪鏁版嵁 + if (!CollectionUtils.isEmpty(dynamics)) { + Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId)); + for (TMonitorExp tMonitorResult : monitors) { + Integer pointId = tMonitorResult.getPointId(); + tMonitorResult.setDynamicColumnList(map.get(pointId)); + } + } + monitors.forEach(monitor -> { + String cameraFunType = monitor.getCameraFunType(); + if (!StringUtils.isEmpty(cameraFunType)) { + String video = cameraFunType.replaceAll("1", "瑙嗛"); + String car = video.replaceAll("2", "杞﹁締"); + String type = car.replaceAll("3", "浜鸿劯"); + monitor.setCameraFunType(type); + } + StringBuilder tag = new StringBuilder("" + (monitor.getProvinceTag() ? "鐪佸巺銆�" : "") + (monitor.getImportantTag() ? "閲嶇偣鐐逛綅銆�" : "") + (monitor.getImportantCommandImageTag() ? "閲嶇偣鎸囨尌鍥惧儚銆�" : "") + (monitor.getDeptTag() ? "閮ㄧ骇銆�" : "")); + //鍔ㄦ�佸垪澶勭悊鍔犲湪鏍囩閲� + if (!CollectionUtils.isEmpty(monitor.getDynamicColumnList())) { + List<DynamicColumnVO> dynamicColumnList = monitor.getDynamicColumnList(); + for (DynamicColumnVO dynamicColumnVO : dynamicColumnList) { + tag.append(dynamicColumnVO.getColumnValue()).append("銆�"); + } + } + // 鍒犻櫎瀛楃涓叉湯灏剧殑鈥溿�佲�� + if (tag.toString().endsWith("銆�")) { + tag = new StringBuilder(tag.substring(0, tag.length() - 1)); + } + monitor.setTag(tag.toString()); + }); + ExcelUtil<TMonitorExp> util = new ExcelUtil<>(TMonitorExp.class); + util.exportExcel(response, monitors, "2".equals(tMonitor.getCameraFunType()) ? "杞﹁締" : "浜鸿劯"); } @@ -917,7 +965,7 @@ new Document("$group", new Document("_id", "$mongoCreateTime") .append("onlineCount", new Document("$sum", new Document("$cond", Arrays.asList( - new Document("$eq", Arrays.asList("$online",ApiConstants.UY_OnlineSite_Online)), + new Document("$eq", Arrays.asList("$online", ApiConstants.UY_OnlineSite_Online)), 1, 0 )) @@ -1105,12 +1153,12 @@ for (TMonitorResult monitorResult : onlineResult) { int dayOfMonth = monitorResult.getMongoCreateTime().getDayOfMonth(); String online = ""; - if(ApiConstants.UY_OnlineSite_Online.equals(monitorResult.getOnline())){ - online +="鍦ㄧ嚎"; - }else if(ApiConstants.UY_OnlineSite_Offline.equals(monitorResult.getOnline())){ - online +="绂荤嚎"; - }else { - online +="鏈煡"; + if (ApiConstants.UY_OnlineSite_Online.equals(monitorResult.getOnline())) { + online += "鍦ㄧ嚎"; + } else if (ApiConstants.UY_OnlineSite_Offline.equals(monitorResult.getOnline())) { + online += "绂荤嚎"; + } else { + online += "鏈煡"; } //鍙嶅皠璧嬪�硷紝瀛楁缁熶竴瀹氫箟涓篸ay+1锛�2锛�3... Field field = videoDailyExp.getClass().getDeclaredField("day" + dayOfMonth); diff --git a/ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml b/ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml index 4d17f84..475d5b3 100644 --- a/ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml +++ b/ycl-server/src/main/resources/mapper/zgyw/TMonitorMapper.xml @@ -181,6 +181,32 @@ </where> </select> + <select id="exportTMonitorList" resultType="com.ycl.platform.domain.excel.TMonitorExp"> + select m.id, m.serial_number, name, ip, camera_fun_type,p.online as onState, + d.dept_name, p.id as pointId,p.province_tag,p.dept_tag,p.important_tag,p.important_command_image_tag,u.unit_name as managementUnit + from t_monitor m + left join t_yw_point p on m.serial_number = p.serial_number and p.deleted = 0 + left join sys_dept d on p.dept_id = d.dept_id and d.del_flag = 0 + left join t_yw_unit u on p.unit_id = u.id and u.deleted = 0 + <where> + p.examine_status = 1 + <if test="serialNumber != null and serialNumber != ''">and m.serial_number = #{serialNumber}</if> + <if test="name != null and name != ''"> + and (name like concat('%', #{name}, '%') + or m.ip like concat('%', #{name}, '%') + or m.serial_number like concat('%', #{name}, '%') + or u.unit_name like concat('%', #{name}, '%')) + </if> + <if test="provinceTag != null ">and p.province_tag = #{provinceTag}</if> + <if test="deptTag != null ">and p.dept_tag = #{deptTag}</if> + <if test="cameraFunType != null and cameraFunType != ''">and camera_fun_type like concat('%', + #{cameraFunType}, '%') + </if> + <if test="onState != null ">and p.online = #{onState}</if> + <if test="civilCode != null and civilCode != ''">and civil_code = #{civilCode}</if> + </where> + </select> + <select id="selectMonitorVOList" resultType="com.ycl.platform.domain.vo.TMonitorVO"> select m.id, m.serial_number, name, site_type, mac_addr, ip, camera_fun_type, longitude, latitude, camera_capture_area, on_state, civil_code, integrated_device, camera_brand, address, net_working, -- Gitblit v1.8.0