|
@@ -1,6 +1,7 @@
|
|
|
package com.gyee.wisdom.alarm.sharding.biz;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
@@ -141,9 +142,8 @@ public class InspectOrderBiz {
|
|
|
IPage<InspectOrder> pageResult = inspectOrderService.page(page, wrapper);
|
|
|
|
|
|
|
|
|
-
|
|
|
if (pageResult.getRecords().size() > 0) {
|
|
|
- List<EarlyReportWindturbine> reportWindturbineById = earlyReportWindturbineService.getReportWindturbineById(pageResult.getRecords().stream().map(s -> s.getReportWindturbineId()).collect(Collectors.toList()));
|
|
|
+ List<EarlyReportWindturbine> reportWindturbineById = earlyReportWindturbineService.getReportWindturbineByIds(pageResult.getRecords().stream().map(s -> s.getReportWindturbineId()).collect(Collectors.toList()));
|
|
|
pageResult.getRecords().forEach(s -> {
|
|
|
Optional<EarlyReportWindturbine> first = reportWindturbineById.stream().filter(k -> k.getId().equals(s.getReportWindturbineId())).findFirst();
|
|
|
if (first.isPresent())
|
|
@@ -171,20 +171,26 @@ public class InspectOrderBiz {
|
|
|
ResponseWrapper wrapper = null;
|
|
|
//代表为 报告评审环节,因此需要 向InspectOrder表中新增数据
|
|
|
if (StringUtils.isBlank(dto.getId())) {
|
|
|
-
|
|
|
- InspectOrder order = new InspectOrder();
|
|
|
- order.setId(String.valueOf(SnowflakeGenerator.generateId()))
|
|
|
- .setVerifyTime(new Date())
|
|
|
- .setVerifyUser(user)
|
|
|
- .setVerifyView(dto.getVerifyView())
|
|
|
- .setVerifyResult(dto.isVerifyResult())
|
|
|
- .setClosed(dto.isClosed());
|
|
|
-
|
|
|
- boolean save = inspectOrderService.save(order);
|
|
|
- if (save)
|
|
|
- wrapper = ResponseWrapper.success("评审成功");
|
|
|
- else
|
|
|
- wrapper = ResponseWrapper.error("评审失败");
|
|
|
+ try {
|
|
|
+ InspectOrder order = new InspectOrder();
|
|
|
+ order.setId(String.valueOf(SnowflakeGenerator.generateId()))
|
|
|
+ .setVerifyTime(new Date())
|
|
|
+ .setVerifyUser(user)
|
|
|
+ .setVerifyView(dto.getVerifyView())
|
|
|
+ .setVerifyResult(dto.isVerifyResult())
|
|
|
+ .setWindturbineId(dto.getWindturbineId())
|
|
|
+ .setReportWindturbineId(dto.getReportWindturbineId())
|
|
|
+ .setClosed(dto.isClosed());
|
|
|
+ boolean saveInspectOrder = inspectOrderService.saveInspectOrder(order);
|
|
|
+ if (saveInspectOrder)
|
|
|
+ wrapper = ResponseWrapper.success("评审成功");
|
|
|
+ else
|
|
|
+ wrapper = ResponseWrapper.error("评审失败");
|
|
|
+ } catch (Exception e) {
|
|
|
+ wrapper = ResponseWrapper.error("评审失败,数据异常", JSON.toJSONString(e.getStackTrace()));
|
|
|
+ } finally {
|
|
|
+ return wrapper;
|
|
|
+ }
|
|
|
} else {
|
|
|
InspectOrder order = inspectOrderService.getById(dto.getId());
|
|
|
|
|
@@ -192,21 +198,22 @@ public class InspectOrderBiz {
|
|
|
wrapper = ResponseWrapper.error("找不到对应的巡检单");
|
|
|
} else {
|
|
|
//计划环节
|
|
|
- if (dto.getCreatePlanTime() != null) {
|
|
|
+ if (order.getCreatePlanTime() == null && order.getInspectTime() == null) {
|
|
|
order.setCreatePlanUser(user)
|
|
|
- .setCreatePlanTime(dto.getCreatePlanTime())
|
|
|
+ .setCreatePlanTime(dto.getCreatePlanTime() == null ? new Date() : dto.getCreatePlanTime())
|
|
|
.setPlanStartTime(dto.getPlanStartTime())
|
|
|
.setPlanEndTime(dto.getPlanEndTime());
|
|
|
}
|
|
|
//巡检环节
|
|
|
- if (dto.getInspectTime() != null) {
|
|
|
+ else if (order.getInspectTime() == null && order.getCreatePlanTime() != null) {
|
|
|
order.setInspectUser(user)
|
|
|
- .setInspectTime(dto.getInspectTime())
|
|
|
+ .setInspectTime(dto.getInspectTime() == null ? new Date() : dto.getInspectTime())
|
|
|
.setInspectView(dto.getInspectView())
|
|
|
.setAccordreport(dto.isAccordreport())
|
|
|
.setClosed(dto.isClosed());
|
|
|
+ } else {
|
|
|
+ return ResponseWrapper.error("系统异常,请联系管理员");
|
|
|
}
|
|
|
-
|
|
|
boolean b = inspectOrderService.updateById(order);
|
|
|
if (b)
|
|
|
wrapper = ResponseWrapper.success("更新成功");
|
|
@@ -223,25 +230,67 @@ public class InspectOrderBiz {
|
|
|
Map<String, Integer> inspectOrderCount = getInspectOrderCount(stationId);
|
|
|
Map<String, Integer> noVerifyReport = getNoVerifyReport(stationId);
|
|
|
|
|
|
- String dicString="";
|
|
|
- JSONObject orderObject = new JSONObject();
|
|
|
- JSONObject reportObject = new JSONObject();
|
|
|
- for (Map.Entry<String, Integer> entry :
|
|
|
- inspectOrderCount.entrySet()) {
|
|
|
- orderObject.put(entry.getKey(), entry.getValue());
|
|
|
- }
|
|
|
+
|
|
|
+ JSONArray jsonArray = new JSONArray();
|
|
|
+ int wshCount = 0;
|
|
|
for (Map.Entry<String, Integer> entry :
|
|
|
noVerifyReport.entrySet()) {
|
|
|
- reportObject.put(entry.getKey(), entry.getValue());
|
|
|
+ JSONObject reportObject = new JSONObject();
|
|
|
String partName = DataDictionaryCache.getPartName(entry.getKey());
|
|
|
- dicString=dicString+","+entry.getKey()+"-"+partName;
|
|
|
+ reportObject.put("code", entry.getKey());
|
|
|
+ reportObject.put("name", partName);
|
|
|
+ reportObject.put("count", entry.getValue());
|
|
|
+ wshCount = wshCount + entry.getValue();
|
|
|
+
|
|
|
+ jsonArray.add(reportObject);
|
|
|
+ }
|
|
|
+
|
|
|
+ List<String> collect = noVerifyReport.keySet().stream().collect(Collectors.toList());
|
|
|
+
|
|
|
+ if (collect.size() < 4) {
|
|
|
+
|
|
|
+ if (!collect.contains("CLX")) {
|
|
|
+ JSONObject reportObject = new JSONObject();
|
|
|
+ reportObject.put("code", "CLX");
|
|
|
+ reportObject.put("name", "齿轮箱");
|
|
|
+ reportObject.put("count", 0);
|
|
|
+ jsonArray.add(reportObject);
|
|
|
+ }
|
|
|
+ if (!collect.contains("FDJ")) {
|
|
|
+ JSONObject reportObject = new JSONObject();
|
|
|
+ reportObject.put("code", "FDJ");
|
|
|
+ reportObject.put("name", "发电机");
|
|
|
+ reportObject.put("count", 0);
|
|
|
+ jsonArray.add(reportObject);
|
|
|
+ }
|
|
|
+ if (!collect.contains("BJXT")) {
|
|
|
+ JSONObject reportObject = new JSONObject();
|
|
|
+ reportObject.put("code", "BJXT");
|
|
|
+ reportObject.put("name", "变桨系统");
|
|
|
+ reportObject.put("count", 0);
|
|
|
+ jsonArray.add(reportObject);
|
|
|
+ }
|
|
|
+ if (!collect.contains("CDL")) {
|
|
|
+ JSONObject reportObject = new JSONObject();
|
|
|
+ reportObject.put("code", "CDL");
|
|
|
+ reportObject.put("name", "传动链");
|
|
|
+ reportObject.put("count", 0);
|
|
|
+ jsonArray.add(reportObject);
|
|
|
+ }
|
|
|
}
|
|
|
- dicString=dicString+",YSH-已审核,WJH-未计划,YJH-已计划,DXJ-待巡检,YXJ-已巡检";
|
|
|
|
|
|
+
|
|
|
+ JSONObject orderObject = new JSONObject();
|
|
|
+ for (Map.Entry<String, Integer> entry :
|
|
|
+ inspectOrderCount.entrySet()) {
|
|
|
+ orderObject.put(entry.getKey(), entry.getValue());
|
|
|
+ }
|
|
|
+ orderObject.put("WSH", wshCount);
|
|
|
+ String dicString = "WSH-未审核,YSH-已审核,WJH-未计划,YJH-已计划,DXJ-待巡检,YXJ-已巡检";
|
|
|
JSONObject resultObject = new JSONObject();
|
|
|
- resultObject.put("report", reportObject);
|
|
|
+ resultObject.put("report", jsonArray);
|
|
|
resultObject.put("order", orderObject);
|
|
|
- resultObject.put("dic",dicString);
|
|
|
+ resultObject.put("dic", dicString);
|
|
|
return resultObject;
|
|
|
}
|
|
|
|
|
@@ -305,4 +354,28 @@ public class InspectOrderBiz {
|
|
|
|
|
|
return resultMap;
|
|
|
}
|
|
|
+
|
|
|
+ public List<InspectOrderDto> getOrderDtoList(Date startTime, Date endTime) {
|
|
|
+
|
|
|
+ QueryWrapper<InspectOrder> wrapper = new QueryWrapper<>();
|
|
|
+ if (startTime != null)
|
|
|
+ wrapper.gt("VERIFYTIME", startTime);
|
|
|
+ if (endTime != null)
|
|
|
+ wrapper.lt("VERIFYTIME", endTime);
|
|
|
+ wrapper.eq("VERIFYRESULT", true);
|
|
|
+
|
|
|
+ List<InspectOrder> list = inspectOrderService.list(wrapper);
|
|
|
+ List<InspectOrderDto> orderDtoList = packInspectOrderInspectOrderDto(list);
|
|
|
+ if (orderDtoList.size() > 0) {
|
|
|
+ List<EarlyReportWindturbine> reportWindturbineById = earlyReportWindturbineService.getReportWindturbineByIds(list.stream().map(s -> s.getReportWindturbineId()).collect(Collectors.toList()));
|
|
|
+ orderDtoList.forEach(s -> {
|
|
|
+ Optional<EarlyReportWindturbine> first = reportWindturbineById.stream().filter(k -> k.getId().equals(s.getReportWindturbineId())).findFirst();
|
|
|
+ if (first.isPresent())
|
|
|
+ s.setEarlyReportWindturbine(first.get());
|
|
|
+ });
|
|
|
+ }
|
|
|
+ return orderDtoList;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
}
|