|
|
@ -1,10 +1,10 @@ |
|
|
package com.inspect.partrolresult.controller; |
|
|
package com.inspect.partrolresult.controller; |
|
|
|
|
|
|
|
|
import com.alibaba.druid.support.json.JSONUtils; |
|
|
|
|
|
import com.alibaba.fastjson.JSONArray; |
|
|
import com.alibaba.fastjson.JSONArray; |
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
import com.inspect.analysis.domain.ResultAnalysis; |
|
|
import com.inspect.analysis.domain.ResultAnalysis; |
|
|
import com.inspect.analysis.domain.resultList; |
|
|
import com.inspect.analysis.domain.resultList; |
|
|
|
|
|
import com.inspect.analysis.domain.results; |
|
|
import com.inspect.analysis.service.IResultAnalysisService; |
|
|
import com.inspect.analysis.service.IResultAnalysisService; |
|
|
import com.inspect.base.core.constant.Color; |
|
|
import com.inspect.base.core.constant.Color; |
|
|
import com.inspect.base.core.constant.RedisConst; |
|
|
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.annotation.Log; |
|
|
import com.inspect.common.log.enums.BizType; |
|
|
import com.inspect.common.log.enums.BizType; |
|
|
import com.inspect.base.redis.service.RedisService; |
|
|
import com.inspect.base.redis.service.RedisService; |
|
|
import com.inspect.img.service.IInspectionReportImgService; |
|
|
|
|
|
import com.inspect.infrared.InfraredImageParser; |
|
|
import com.inspect.infrared.InfraredImageParser; |
|
|
import com.inspect.infrared.InfraredRequestParam; |
|
|
import com.inspect.infrared.InfraredRequestParam; |
|
|
import com.inspect.infrared.InfraredResponse; |
|
|
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.base.core.domain.maintain.MaintainRegion; |
|
|
import com.inspect.maintain.domain.MaintainAreaXML; |
|
|
import com.inspect.maintain.domain.MaintainAreaXML; |
|
|
import com.inspect.maintain.domain.PatrolMaintainModuleXml; |
|
|
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.task.service.IPatrolTaskService; |
|
|
import com.inspect.taskftp.domain.PatrolTaskFtp; |
|
|
import com.inspect.taskftp.domain.PatrolTaskFtp; |
|
|
import com.inspect.taskftp.service.IPatrolTaskFtpService; |
|
|
import com.inspect.taskftp.service.IPatrolTaskFtpService; |
|
|
import com.inspect.taskinfo.service.IPatrolTaskInfoService; |
|
|
|
|
|
import com.inspect.taskstatus.domain.PatrolTaskStatus; |
|
|
import com.inspect.taskstatus.domain.PatrolTaskStatus; |
|
|
import com.inspect.taskstatus.service.IPatrolTaskStatusService; |
|
|
import com.inspect.taskstatus.service.IPatrolTaskStatusService; |
|
|
|
|
|
|
|
|
@ -72,6 +68,8 @@ import java.lang.reflect.Field; |
|
|
import java.net.HttpURLConnection; |
|
|
import java.net.HttpURLConnection; |
|
|
import java.net.URL; |
|
|
import java.net.URL; |
|
|
import java.text.SimpleDateFormat; |
|
|
import java.text.SimpleDateFormat; |
|
|
|
|
|
import java.time.LocalDateTime; |
|
|
|
|
|
import java.time.format.DateTimeFormatter; |
|
|
import java.util.ArrayList; |
|
|
import java.util.ArrayList; |
|
|
import java.util.Arrays; |
|
|
import java.util.Arrays; |
|
|
import java.util.Date; |
|
|
import java.util.Date; |
|
|
@ -92,7 +90,6 @@ import javax.servlet.http.HttpServletRequest; |
|
|
import javax.servlet.http.HttpServletResponse; |
|
|
import javax.servlet.http.HttpServletResponse; |
|
|
|
|
|
|
|
|
import org.apache.commons.collections4.CollectionUtils; |
|
|
import org.apache.commons.collections4.CollectionUtils; |
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
|
|
import org.springframework.beans.factory.annotation.Value; |
|
|
import org.springframework.beans.factory.annotation.Value; |
|
|
import org.springframework.format.annotation.DateTimeFormat; |
|
|
import org.springframework.format.annotation.DateTimeFormat; |
|
|
import org.springframework.web.bind.annotation.GetMapping; |
|
|
import org.springframework.web.bind.annotation.GetMapping; |
|
|
@ -324,7 +321,7 @@ public class PatrolResultController extends BaseController { |
|
|
PatrolResultAux patrolResultAuxQuery = new PatrolResultAux(); |
|
|
PatrolResultAux patrolResultAuxQuery = new PatrolResultAux(); |
|
|
patrolResultAuxQuery.setResultId(brr.getLineId() + ""); |
|
|
patrolResultAuxQuery.setResultId(brr.getLineId() + ""); |
|
|
resultAuxList = iPatrolResultAuxService.selectPatrolResultAuxList(patrolResultAuxQuery); |
|
|
resultAuxList = iPatrolResultAuxService.selectPatrolResultAuxList(patrolResultAuxQuery); |
|
|
if(resultAuxList.isEmpty()) { |
|
|
|
|
|
|
|
|
if (resultAuxList.isEmpty()) { |
|
|
continue; |
|
|
continue; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@ -811,7 +808,7 @@ public class PatrolResultController extends BaseController { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
algInfoList.removeAll(judgeList); |
|
|
algInfoList.removeAll(judgeList); |
|
|
List<AlgInfo> meterList = (algInfoList).stream().filter((item) -> { |
|
|
|
|
|
|
|
|
List<AlgInfo> meterList = (algInfoList).stream().filter((item) -> { |
|
|
return "meter".equals(item.getAlgSubtypeCode()); |
|
|
return "meter".equals(item.getAlgSubtypeCode()); |
|
|
}).collect(Collectors.toList()); |
|
|
}).collect(Collectors.toList()); |
|
|
if (!meterList.isEmpty()) { |
|
|
if (!meterList.isEmpty()) { |
|
|
@ -1346,7 +1343,7 @@ public class PatrolResultController extends BaseController { |
|
|
|
|
|
|
|
|
i = patrolResultService.updatePatrolResult(patrolResult2); |
|
|
i = patrolResultService.updatePatrolResult(patrolResult2); |
|
|
// if (!"2".equals(Jqtype)) { |
|
|
// if (!"2".equals(Jqtype)) { |
|
|
resultList.add(patrolResult2); |
|
|
|
|
|
|
|
|
resultList.add(patrolResult2); |
|
|
// } |
|
|
// } |
|
|
} else { |
|
|
} else { |
|
|
arr.setMainId(mainID + ""); |
|
|
arr.setMainId(mainID + ""); |
|
|
@ -1394,7 +1391,7 @@ public class PatrolResultController extends BaseController { |
|
|
i = patrolResultService.insertPatrolResult(arr);// |
|
|
i = patrolResultService.insertPatrolResult(arr);// |
|
|
resultStatistics.compare(arr); |
|
|
resultStatistics.compare(arr); |
|
|
// if (!"2".equals(Jqtype)) { |
|
|
// if (!"2".equals(Jqtype)) { |
|
|
resultList.add(arr); |
|
|
|
|
|
|
|
|
resultList.add(arr); |
|
|
// } |
|
|
// } |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
@ -1913,4 +1910,158 @@ public class PatrolResultController extends BaseController { |
|
|
return dataMsg.getFilePath() + "/" + fileName; |
|
|
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<PatrolResult> list = patrolResultService.selectPatroByAllDev(patrolResult); |
|
|
|
|
|
List<PointDataResultVo> between_list = new ArrayList<>(); |
|
|
|
|
|
for (PatrolResult result : list) { |
|
|
|
|
|
LocalDateTime resultDateTime = LocalDateTime.parse(result.getTime(), formatter); |
|
|
|
|
|
PatrolResultAux pra = new PatrolResultAux(); |
|
|
|
|
|
pra.setResultId(result.getLineId() + ""); |
|
|
|
|
|
List<PatrolResultAux> 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> 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<String, String> 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<Map<String, Object>> pointPrelist = this.patrolTaskService.selectBasePointPre(pointId); |
|
|
|
|
|
if (pointPrelist != null && !pointPrelist.isEmpty()) { |
|
|
|
|
|
Map<String, Object> 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<InspectionPointResultVo> 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<String, Object> 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; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
} |
|
|
} |