diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/rest/FaultDeviceController.java b/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/rest/FaultDeviceController.java index bcb7af5e1..11344afe0 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/rest/FaultDeviceController.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/rest/FaultDeviceController.java @@ -73,4 +73,13 @@ public class FaultDeviceController { faultDeviceService.syncInfo(); return new ResponseEntity<>(HttpStatus.OK); } + + @GetMapping("/getAllerrorDevice") + @Log("查询所有设备故障") + + public ResponseEntity getAllerrorDevice(@RequestParam Map whereJson, Pageable page) { + return new ResponseEntity<>(faultDeviceService.getAllerrorDevice(whereJson, page), HttpStatus.OK); + } + + } diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/service/FaultDeviceService.java b/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/service/FaultDeviceService.java index 8d79ac70a..70ac7ff75 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/service/FaultDeviceService.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/service/FaultDeviceService.java @@ -82,4 +82,13 @@ public interface FaultDeviceService { * 同步信息 */ void syncInfo(); + + /** + * 查询数据分页 + * + * @param whereJson 条件 + * @param page 分页参数 + * @return Map + */ + Map getAllerrorDevice(Map whereJson, Pageable page); } diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/service/impl/FaultDeviceServiceImpl.java b/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/service/impl/FaultDeviceServiceImpl.java index 24551819a..86fae4aba 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/service/impl/FaultDeviceServiceImpl.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/basedata/master/service/impl/FaultDeviceServiceImpl.java @@ -326,29 +326,72 @@ public class FaultDeviceServiceImpl implements FaultDeviceService { } public Map getAllerrorDevice(Map whereJson, Pageable page) { - String device_code = MapUtil.getStr(whereJson, "device_code"); String region_code = MapUtil.getStr(whereJson, "region_code"); UserDeviceService userDeviceService = SpringContextHolder.getBean(UserDeviceService.class); String inArea = userDeviceService.getInArea(); - //查询当前人员对应的设备是多少 - JSONArray device_rows = WQLObject.getWQLObject("em_bi_monitordevice").query("region_code in " + inArea + "").getResultJSONArray(0); - List deviceList = new ArrayList<>(); - for (int i = 0; i < device_rows.size(); i++) { - JSONObject row = device_rows.getJSONObject(i); - deviceList.add(row.getString("device_code")); + String query_sql = "region_code in " + inArea + ""; + if (StrUtil.isNotEmpty(region_code)) { + query_sql += " and region_code='" + region_code + "'"; } - // 调用acs接口获取设备 - JSONObject result = SpringContextHolder.getBean(WmsToAcsServiceImpl.class).getDeviceErrorInfo(deviceList); - JSONArray data = result.getJSONArray("data"); + WmsToAcsServiceImpl bean = SpringContextHolder.getBean(WmsToAcsServiceImpl.class); + + //查询当前人员对应的设备是多少 + JSONArray b1_rows = WQLObject.getWQLObject("em_bi_monitordevice").query(query_sql + "AND product_area = 'B1'").getResultJSONArray(0); + List b1List = new ArrayList<>(); + for (int i = 0; i < b1_rows.size(); i++) { + JSONObject row = b1_rows.getJSONObject(i); + b1List.add(row.getString("device_code")); + } + + JSONObject result = bean.getDeviceErrorInfo(b1List,"B1"); + // 调用acs接口获取设备 + JSONArray b1_data = result.getJSONArray("data"); + + JSONArray blk_rows = WQLObject.getWQLObject("em_bi_monitordevice").query(query_sql + "AND product_area = 'BLK'").getResultJSONArray(0); + List blkList = new ArrayList<>(); + for (int i = 0; i < blk_rows.size(); i++) { + JSONObject row = blk_rows.getJSONObject(i); + blkList.add(row.getString("device_code")); + } + + JSONObject result2 = bean.getDeviceErrorInfo(blkList,"BLK"); + // 调用acs接口获取设备 + JSONArray blk_data = result2.getJSONArray("data"); + + JSONArray data = new JSONArray(); + if (ObjectUtil.isNotEmpty(b1_data)) { + for (int i = 0; i < b1_rows.size(); i++) { + JSONObject row = b1_rows.getJSONObject(i); + for (int j = 0; j < b1_data.size(); j++) { + JSONObject b1 = b1_data.getJSONObject(j); + if (b1.getString("device_code").equals(row.getString("device_code"))) { + b1.put("region_code", row.getString("region_code")); + } + data.add(b1); + } + } + } + if (ObjectUtil.isNotEmpty(blk_data)) { + for (int i = 0; i < blk_rows.size(); i++) { + JSONObject row = blk_rows.getJSONObject(i); + for (int j = 0; j < blk_data.size(); j++) { + JSONObject blk = blk_data.getJSONObject(j); + if (blk.getString("device_code").equals(row.getString("device_code"))) { + blk.put("region_code", row.getString("region_code")); + } + data.add(blk); + } + } + } //查询内包间套轴对接位的异常 if (inArea.contains("NBJ")) { - IBstIvtCutpointivtService bean = SpringContextHolder.getBean(IBstIvtCutpointivtService.class); - List list = bean.list(new LambdaQueryWrapper() + IBstIvtCutpointivtService bean2 = SpringContextHolder.getBean(IBstIvtCutpointivtService.class); + List list = bean2.list(new LambdaQueryWrapper() .eq(BstIvtCutpointivt::getPoint_type, "1") .eq(BstIvtCutpointivt::getIs_used, "1") .ne(BstIvtCutpointivt::getRemark, "") @@ -358,6 +401,7 @@ public class FaultDeviceServiceImpl implements FaultDeviceService { JSONObject row = new JSONObject(); row.put("device_code", a.getPoint_code()); row.put("device_name", a.getPoint_code()); + row.put("region_code", "NBJ"); row.put("error_code", ""); row.put("error_message", a.getRemark()); data.add(row); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java b/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java index 6dedd2a04..716b5dc4a 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java @@ -155,5 +155,5 @@ public interface WmsToAcsService { */ JSONObject queryBoxWeigh(JSONObject jo); - JSONObject getDeviceErrorInfo(List list); + JSONObject getDeviceErrorInfo(List list,String product_area); } diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java b/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java index 6b5341c6f..67aa35bac 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java @@ -3,6 +3,7 @@ package org.nl.wms.ext.acs.service.impl; import cn.hutool.core.util.NumberUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.http.HttpRequest; +import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import lombok.RequiredArgsConstructor; @@ -520,7 +521,7 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { } @Override - public JSONObject getDeviceErrorInfo(List list) { + public JSONObject getDeviceErrorInfo(List list,String product_area) { String api = "api/wms/getDeviceErrorInfo"; //判断是否连接ACS系统 String isConnect = SpringContextHolder.getBean(SysParamServiceImpl.class).findByCode("is_connect_acs").getValue(); @@ -532,8 +533,6 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { return result; } - String product_area = "LK"; - String acs_url = URLEnum.find(product_area); if (StrUtil.isEmpty(acs_url)) { log.info(product_area); @@ -543,7 +542,7 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { String url = acs_url + api; try { String resultMsg = HttpRequest.post(url) - .body(String.valueOf(list)) + .body(JSON.toJSONString(list)) .execute().body(); result = JSONObject.parseObject(resultMsg); diff --git a/lms/nladmin-ui/src/views/wms/agvrush/deviceerror/index.vue b/lms/nladmin-ui/src/views/wms/agvrush/deviceerror/index.vue new file mode 100644 index 000000000..35cc67f56 --- /dev/null +++ b/lms/nladmin-ui/src/views/wms/agvrush/deviceerror/index.vue @@ -0,0 +1,113 @@ + + + + +