diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java index 47a47d2..6235cce 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/controller/PatrolResultController.java @@ -1,10 +1,10 @@ package com.inspect.partrolresult.controller; -import com.alibaba.druid.support.json.JSONUtils; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.inspect.analysis.domain.ResultAnalysis; import com.inspect.analysis.domain.resultList; +import com.inspect.analysis.domain.results; import com.inspect.analysis.service.IResultAnalysisService; import com.inspect.base.core.constant.Color; import com.inspect.base.core.constant.RedisConst; @@ -28,12 +28,9 @@ import com.inspect.base.core.web.page.TableDataInfo; import com.inspect.common.log.annotation.Log; import com.inspect.common.log.enums.BizType; import com.inspect.base.redis.service.RedisService; -import com.inspect.img.service.IInspectionReportImgService; import com.inspect.infrared.InfraredImageParser; import com.inspect.infrared.InfraredRequestParam; import com.inspect.infrared.InfraredResponse; -import com.inspect.insreport.service.IInspectionReportService; -import com.inspect.insreportdata.service.IInspectionReportDataService; import com.inspect.base.core.domain.maintain.MaintainRegion; import com.inspect.maintain.domain.MaintainAreaXML; import com.inspect.maintain.domain.PatrolMaintainModuleXml; @@ -61,7 +58,6 @@ import com.inspect.task.domain.PatrolTaskXML; import com.inspect.task.service.IPatrolTaskService; import com.inspect.taskftp.domain.PatrolTaskFtp; import com.inspect.taskftp.service.IPatrolTaskFtpService; -import com.inspect.taskinfo.service.IPatrolTaskInfoService; import com.inspect.taskstatus.domain.PatrolTaskStatus; import com.inspect.taskstatus.service.IPatrolTaskStatusService; @@ -72,6 +68,8 @@ import java.lang.reflect.Field; import java.net.HttpURLConnection; import java.net.URL; import java.text.SimpleDateFormat; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.Arrays; import java.util.Date; @@ -92,7 +90,6 @@ import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.collections4.CollectionUtils; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.format.annotation.DateTimeFormat; import org.springframework.web.bind.annotation.GetMapping; @@ -324,7 +321,7 @@ public class PatrolResultController extends BaseController { PatrolResultAux patrolResultAuxQuery = new PatrolResultAux(); patrolResultAuxQuery.setResultId(brr.getLineId() + ""); resultAuxList = iPatrolResultAuxService.selectPatrolResultAuxList(patrolResultAuxQuery); - if(resultAuxList.isEmpty()) { + if (resultAuxList.isEmpty()) { continue; } @@ -811,7 +808,7 @@ public class PatrolResultController extends BaseController { } algInfoList.removeAll(judgeList); - List meterList = (algInfoList).stream().filter((item) -> { + List meterList = (algInfoList).stream().filter((item) -> { return "meter".equals(item.getAlgSubtypeCode()); }).collect(Collectors.toList()); if (!meterList.isEmpty()) { @@ -1346,7 +1343,7 @@ public class PatrolResultController extends BaseController { i = patrolResultService.updatePatrolResult(patrolResult2); // if (!"2".equals(Jqtype)) { - resultList.add(patrolResult2); + resultList.add(patrolResult2); // } } else { arr.setMainId(mainID + ""); @@ -1394,7 +1391,7 @@ public class PatrolResultController extends BaseController { i = patrolResultService.insertPatrolResult(arr);// resultStatistics.compare(arr); // if (!"2".equals(Jqtype)) { - resultList.add(arr); + resultList.add(arr); // } } } @@ -1913,4 +1910,158 @@ public class PatrolResultController extends BaseController { return dataMsg.getFilePath() + "/" + fileName; } } + + /** + * 获取巡检告警结果列表接⼝ + * + * @param pointDataVo + * @return + */ + @GetMapping({"/pointTrendData"}) + public AjaxResult pointTrendData(PointDataVo pointDataVo) { + // 定义日期时间格式 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + LocalDateTime startDateTime = null; + LocalDateTime endDateTime = null; + if (StringUtils.isNotEmpty(pointDataVo.getStartTime()) && StringUtils.isNotEmpty(pointDataVo.getEndTime())) { + // 补全开始和结束时间 + startDateTime = LocalDateTime.parse(pointDataVo.getStartTime() + " 00:00:00", formatter); + endDateTime = LocalDateTime.parse(pointDataVo.getEndTime() + " 23:59:59", formatter); + } + PatrolResult patrolResult = new PatrolResult(); + patrolResult.setDeviceId(pointDataVo.getDeviceId()); + List list = patrolResultService.selectPatroByAllDev(patrolResult); + List between_list = new ArrayList<>(); + for (PatrolResult result : list) { + LocalDateTime resultDateTime = LocalDateTime.parse(result.getTime(), formatter); + PatrolResultAux pra = new PatrolResultAux(); + pra.setResultId(result.getLineId() + ""); + List pra1 = iPatrolResultAuxService.selectPatrolResultAuxList(pra); + if (!pra1.isEmpty()) { + result.setValue(pra1.get(0).getValue()); + } + + if ("0".equals(result.getValue())) { + result.setValue("正常"); + } + + if ("-1".equals(result.getValue()) || "1".equals(result.getValue())) { + result.setValue("异常"); + } + if (StringUtils.isNotEmpty(pointDataVo.getStartTime()) && StringUtils.isNotEmpty(pointDataVo.getEndTime())) { + // 使用if判断时间范围 + if (!resultDateTime.isBefore(startDateTime) && !resultDateTime.isAfter(endDateTime)) { + PointDataResultVo patrolResultVo = new PointDataResultVo(); + patrolResultVo.setTime(result.getTime()); + patrolResultVo.setValue(result.getValue()); + between_list.add(patrolResultVo); + } else { + + } + } else { + PointDataResultVo patrolResultVo = new PointDataResultVo(); + patrolResultVo.setTime(result.getTime()); + patrolResultVo.setValue(result.getValue()); + between_list.add(patrolResultVo); + } + } + return AjaxResult.success(between_list); + } + + @GetMapping({"/inspectResult"}) + public AjaxResult inspectResult(InspectionPointParam inspectionPointParam) { + inspectionPointParam.setOffset((inspectionPointParam.getPageNum() - 1) * inspectionPointParam.getPageSize()); + List inspectionPointResultVo = patrolResultService.inspectResult(inspectionPointParam); + if (!inspectionPointResultVo.isEmpty()) { + for (InspectionPointResultVo brr : inspectionPointResultVo) { +// String pointId; +// if (StringUtils.isNotEmpty(brr.getComponentId()) && StringUtils.isEmpty(brr.getDeviceName())) { +// pointId = this.recursionGetNameId(brr.getComponentId()); +// if (StringUtils.isNotEmpty(pointId)) { +// String[] ars = pointId.split(StringUtils.COMMA); +// if (StringUtils.isNotEmpty(ars[0])) { +// brr.setDeviceName(ars[0]); +// } +// +// if (ars.length > 1 && StringUtils.isNotEmpty(ars[1])) { +// brr.setMaterialId(ars[1]); +// } +// } +// } + + if (StringUtils.isNotEmpty(brr.getResultType())) { + if (brr.getResultType().equals("0")) { + brr.setAlarmType("1"); + Map stringStringMap = resultAnalysisService.selectPointInfoById(brr.getDeviceId()); + if (stringStringMap != null) { + if (StringUtils.isNotEmpty(stringStringMap.get("point_impt_level"))) { + if (stringStringMap.get("point_impt_level").equals("Ⅰ")) { + brr.setAlarmLevel("EMERGENCY"); + } else if (stringStringMap.get("point_impt_level").equals("Ⅱ")) { + brr.setAlarmLevel("SERIOUS"); + } else { + brr.setAlarmLevel("TEPID"); + } + } else { + brr.setAlarmLevel("TEPID"); + } + } else { + brr.setAlarmLevel("TEPID"); + } + } else { + brr.setAlarmLevel("NORMAL"); + } + } + + if (StringUtils.isNotEmpty(brr.getDeviceId())) { + String pointId = brr.getDeviceId(); + List> pointPrelist = this.patrolTaskService.selectBasePointPre(pointId); + if (pointPrelist != null && !pointPrelist.isEmpty()) { + Map drr = (Map) pointPrelist.get(0); + if (drr != null && drr.get("channel_code") != null) { + String channel_code = (String) drr.get("channel_code"); + brr.setPatroldeviceCode(channel_code); + BasedataEqpBookChannel basedataEqpBookChannel = this.patrolResultService.selectChannelName(channel_code); + if (basedataEqpBookChannel != null) { + brr.setPatroldeviceName(basedataEqpBookChannel.getChannelName()); + } + } + } + } + } + } + List filteredList = new ArrayList<>(); + for (InspectionPointResultVo brr : inspectionPointResultVo) { + boolean flag = true; + if ((inspectionPointParam.getAlarmLevel() != null && !inspectionPointParam.getAlarmLevel().equals(brr.getAlarmLevel()))) { + flag = false; + } + if ((inspectionPointParam.getAlarmType() != null && !inspectionPointParam.getAlarmType().equals(brr.getAlarmType()))) { + flag = false; + } + if ((inspectionPointParam.getPatroldeviceCode() != null && !inspectionPointParam.getPatroldeviceCode().equals(brr.getPatroldeviceCode()))) { + flag = false; + } + if (flag) { + filteredList.add(brr); + } + } + return AjaxResult.success(filteredList); + } + + public String recursionGetNameId(String devId) { + String str = ""; + Map basedataDevice = this.patrolResultService.selectDevInfoById(devId); + if (null != basedataDevice && null != basedataDevice.get("parent_id")) { + if (basedataDevice.get("power_main_equ_flag").equals("Yes")) { + return basedataDevice.get("device_name") + "," + basedataDevice.get("phyasset_id"); + } + + devId = basedataDevice.get("parent_id") + ""; + str = this.recursionGetNameId(devId); + } + + return str; + } + } diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/InspectionPointParam.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/InspectionPointParam.java new file mode 100644 index 0000000..94771ed --- /dev/null +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/InspectionPointParam.java @@ -0,0 +1,28 @@ +package com.inspect.partrolresult.domain; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * 巡检结果请求参数 + */ +@AllArgsConstructor +@NoArgsConstructor +@Data +public class InspectionPointParam { + + String startTime; + String endTime; + String patroldeviceCode; + String deviceId; + String mainDevId; + String componentId; + String taskPatrolledId; + String alarmLevel; + String alarmType; + String resultType; + int pageNum; + int pageSize; + int offset; +} diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/InspectionPointResultVo.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/InspectionPointResultVo.java new file mode 100644 index 0000000..5249e03 --- /dev/null +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/InspectionPointResultVo.java @@ -0,0 +1,39 @@ +package com.inspect.partrolresult.domain; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * \ + * 巡检结果 + */ +@AllArgsConstructor +@NoArgsConstructor +@Data +public class InspectionPointResultVo { + int id; + String patroldeviceCode; + String patroldeviceName; + String taskCode; + String taskName; + String taskPatrolledId; + String deviceId; + String deviceName; + String mainDevId; + String mainDevName; + String componentId; + String componentName; + String value; + String unit; + String recognitionType; + String time; + String fileType; + String filePath; + String baseFilePath; + String rectangle; + String alarmLevel; + String alarmType; + String content; + String resultType; +} diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/PointDataResultVo.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/PointDataResultVo.java new file mode 100644 index 0000000..878cae2 --- /dev/null +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/PointDataResultVo.java @@ -0,0 +1,14 @@ +package com.inspect.partrolresult.domain; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@AllArgsConstructor +@NoArgsConstructor +@Data +public class PointDataResultVo { + + private String time; + private String value; +} diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/PointDataVo.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/PointDataVo.java new file mode 100644 index 0000000..e41d717 --- /dev/null +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/domain/PointDataVo.java @@ -0,0 +1,15 @@ +package com.inspect.partrolresult.domain; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +@AllArgsConstructor +@NoArgsConstructor +@Data +public class PointDataVo { + + private String startTime; + private String endTime; + private String deviceId ; +} diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/mapper/PatrolResultMapper.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/mapper/PatrolResultMapper.java index ab43649..d871f6e 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/mapper/PatrolResultMapper.java +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/mapper/PatrolResultMapper.java @@ -1,12 +1,7 @@ package com.inspect.partrolresult.mapper; import com.inspect.analysis.domain.ResultAnalysis; -import com.inspect.partrolresult.domain.AlgInfo; -import com.inspect.partrolresult.domain.BasePointAreaInfo; -import com.inspect.partrolresult.domain.PatrolPresetPosModule; -import com.inspect.partrolresult.domain.PatrolResult; -import com.inspect.partrolresult.domain.PatrolResultRef; -import com.inspect.partrolresult.domain.ResultValue; +import com.inspect.partrolresult.domain.*; import com.inspect.statistics.domain.TaskStatisticsConfig; import com.inspect.system.base.openDomain.BasedataEqpBookMoMain; @@ -100,4 +95,8 @@ public interface PatrolResultMapper { List selectResultRefByLineId(String lineId); List selectBaseInfoByMainId(String mainId); + + List inspectResult(InspectionPointParam inspectionPointParam); + + BasedataEqpBookChannel selectChannelName(@Param("channelCode") String channelCode); } diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/IPatrolResultService.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/IPatrolResultService.java index b871969..d1b5b5e 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/IPatrolResultService.java +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/IPatrolResultService.java @@ -1,12 +1,7 @@ package com.inspect.partrolresult.service; import com.inspect.analysis.domain.ResultAnalysis; -import com.inspect.partrolresult.domain.AlgInfo; -import com.inspect.partrolresult.domain.BasePointAreaInfo; -import com.inspect.partrolresult.domain.PatrolPresetPosModule; -import com.inspect.partrolresult.domain.PatrolResult; -import com.inspect.partrolresult.domain.PatrolResultRef; -import com.inspect.partrolresult.domain.ResultValue; +import com.inspect.partrolresult.domain.*; import com.inspect.resultmain.domain.PatrolTaskResultMain; import com.inspect.system.base.openDomain.BasedataEqpBookMoMain; import com.inspect.task.domain.PatrolData; @@ -83,4 +78,8 @@ public interface IPatrolResultService { List selectResultRefByLineId(String lineId); List selectBaseInfoByMainId(String mainId); + + List inspectResult(InspectionPointParam inspectionPointParam); + + BasedataEqpBookChannel selectChannelName(String channelCode); } diff --git a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/impl/PatrolResultServiceImpl.java b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/impl/PatrolResultServiceImpl.java index e76808b..d2c7a02 100644 --- a/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/impl/PatrolResultServiceImpl.java +++ b/inspect-main/inspect-main-task/src/main/java/com/inspect/partrolresult/service/impl/PatrolResultServiceImpl.java @@ -14,12 +14,7 @@ import com.inspect.insreport.domain.InspectionReport; import com.inspect.insreport.mapper.InspectionReportMapper; import com.inspect.insreportdata.domain.InspectionReportData; import com.inspect.insreportdata.mapper.InspectionReportDataMapper; -import com.inspect.partrolresult.domain.AlgInfo; -import com.inspect.partrolresult.domain.BasePointAreaInfo; -import com.inspect.partrolresult.domain.PatrolPresetPosModule; -import com.inspect.partrolresult.domain.PatrolResult; -import com.inspect.partrolresult.domain.PatrolResultRef; -import com.inspect.partrolresult.domain.ResultValue; +import com.inspect.partrolresult.domain.*; import com.inspect.partrolresult.mapper.PatrolResultMapper; import com.inspect.partrolresult.service.IPatrolResultService; import com.inspect.partrolresult.util.PrintUtil; @@ -541,6 +536,16 @@ public class PatrolResultServiceImpl implements IPatrolResultService { return this.patrolResultMapper.selectBaseInfoByMainId(mainId); } + @Override + public List inspectResult(InspectionPointParam inspectionPointParam) { + return this.patrolResultMapper.inspectResult(inspectionPointParam); + } + + @Override + public BasedataEqpBookChannel selectChannelName(String channelCode) { + return patrolResultMapper.selectChannelName(channelCode); + } + public static void main(String[] args) { List students = new ArrayList<>(); students.add("s1"); diff --git a/inspect-main/inspect-main-task/src/main/resources/mapper/task/PatrolResultMapper.xml b/inspect-main/inspect-main-task/src/main/resources/mapper/task/PatrolResultMapper.xml index b504a19..2790154 100644 --- a/inspect-main/inspect-main-task/src/main/resources/mapper/task/PatrolResultMapper.xml +++ b/inspect-main/inspect-main-task/src/main/resources/mapper/task/PatrolResultMapper.xml @@ -134,18 +134,18 @@ and main_id = #{mainId} - - - - - - - - - - - - + + + + + + + + + + + + @@ -206,8 +206,8 @@ b.point_status , b.result_type as warn_status, b.description as 'desc', - b.res_img_url as img, - b.image_normal_url_path as img, + b.res_img_url as img, + b.image_normal_url_path as img, a.file_type as img_type, a.data_type, b.filter, @@ -247,27 +247,44 @@ and a.task_patrolled_id=#{taskPatrolId} and b.task_patrol_id=#{taskPatrolId} - and b.objectId=#{objectId} + and b.objectId=#{objectId} and b.result = #{result} - and b.result_type = #{resultType} - and b.result_type = #{resultType} - and b.filter = #{filter} and b.point_status = '0' and b.res_code='2000' - and b.filter = #{filter} and b.res_code!=#{resCode} - and a.device_name like concat('%', #{pointName}, '%') - and d.device_name like concat('%', #{deviceName}, '%') + and b.result_type = + #{resultType} + + and b.result_type = + #{resultType} + + and b.filter = #{filter} and b.point_status + = '0' and b.res_code='2000' + + and b.filter = #{filter} and b.res_code!=#{resCode} + and a.device_name like concat('%', #{pointName}, '%') + and d.device_name like concat('%', #{deviceName}, '%') + - and g.channel_name like concat('%', #{channelName}, '%') - and g.device_source like concat('%', #{deviceSource}, '%') + and g.channel_name like concat('%', + #{channelName}, '%') + + and g.device_source like concat('%', + #{deviceSource}, '%') + - and h.patrol_device_name like concat('%', #{channelName}, '%') - and h.device_source like concat('%', #{deviceSource}, '%') + and h.patrol_device_name like concat('%', + #{channelName}, '%') + + and h.device_source like concat('%', + #{deviceSource}, '%') + + + and b.description like concat('%', #{desc}, '%') + and b.point_status like concat('%', #{pointStatus}, + '%') - and b.description like concat('%', #{desc}, '%') - and b.point_status like concat('%', #{pointStatus}, '%') - ORDER BY d.device_name,a.device_name - ORDER BY b.point_status + ORDER BY d.device_name,a.device_name + ORDER BY b.point_status @@ -387,7 +404,7 @@ and e.device_type_name like concat('%',#{deviceTypeName},'%') - and a.device_id =#{deviceId} + and a.device_id =#{deviceId} and a.main_id =#{mainId} and a.task_name like concat('%',#{taskName},'%') @@ -457,7 +474,8 @@ from basedata_patrolpoint a left join basedata_alg_subtype b on a.alg_subtype_ids = b.alg_subtype_id left join basedata_alg c on b.alg_id = c.alg_id - where CONVERT(a.patrol_point_id, CHAR) = #{lineId} OR a.patrol_point_code LIKE concat('%',#{lineId}) + where CONVERT(a.patrol_point_id, CHAR) = #{lineId} + OR a.patrol_point_code LIKE concat('%', #{lineId}) + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +