diff --git a/src/main/java/com/xujie/sys/modules/pms/controller/QcController.java b/src/main/java/com/xujie/sys/modules/pms/controller/QcController.java index 1c44baa6..fee051ec 100644 --- a/src/main/java/com/xujie/sys/modules/pms/controller/QcController.java +++ b/src/main/java/com/xujie/sys/modules/pms/controller/QcController.java @@ -2271,10 +2271,11 @@ public class QcController { @PostMapping("/getCollectorDataByItem") public R getCollectorDataByItem(@RequestBody QcFAIRecordData data)throws Exception{ ArrayList rows = qcService.getCollectorDataByItem(data); - if ("Y".equalsIgnoreCase(data.getSpecialTaskFlag()) && (rows == null || rows.isEmpty())) { - return R.error("没有异常数据"); + boolean abnormal = false; + if (!"000#1".equals(data.getOrderNo())) { + abnormal = qcService.checkCollectorAbnormalSignal(data); } - return R.ok().put("rows", rows); + return R.ok().put("rows", rows).put("abnormal",abnormal); } @PostMapping("/checkCollectorAbnormalSignal") diff --git a/src/main/java/com/xujie/sys/modules/pms/service/Impl/DmServiceImpl.java b/src/main/java/com/xujie/sys/modules/pms/service/Impl/DmServiceImpl.java index a183ac32..11f5d22c 100644 --- a/src/main/java/com/xujie/sys/modules/pms/service/Impl/DmServiceImpl.java +++ b/src/main/java/com/xujie/sys/modules/pms/service/Impl/DmServiceImpl.java @@ -69,7 +69,7 @@ public class DmServiceImpl implements DmService { data.setQcType(data.getInspectionTypeNo()); } - String prefix = getDmMethodPrefix(data.getInspectionTypeNo()); + String prefix = "ME"; String methodNo = generateDmMethodNo(data.getSite(), prefix); List checkMethod = dmMapper.checkDmMethodOnlyOne(data); diff --git a/src/main/java/com/xujie/sys/modules/pms/service/Impl/QcServiceImpl.java b/src/main/java/com/xujie/sys/modules/pms/service/Impl/QcServiceImpl.java index 90ac835a..fe805ab8 100644 --- a/src/main/java/com/xujie/sys/modules/pms/service/Impl/QcServiceImpl.java +++ b/src/main/java/com/xujie/sys/modules/pms/service/Impl/QcServiceImpl.java @@ -4821,9 +4821,12 @@ public class QcServiceImpl implements QcService { String ip = location.getIp(); int unitId = location.getRegisterAddress(); Integer isexceptionAdress = location.getRegisterNumInspection(); + final int baseAddr = Integer.parseInt(location.getCuttingSymbol()); + final int groups = location.getRegisterNum(); // 无工单检验:先看302异常信号,1则读取异常数据并复位,0则直接返回空数据 - /*if ("Y".equalsIgnoreCase(data.getSpecialTaskFlag())) { + logger.info("orderNo:{}",data.getOrderNo()); + if ("000#1".equals(data.getOrderNo())) { Integer abnormalSignal = ModbusUtils.readSingleRegister(ip, port, unitId, isexceptionAdress); if (abnormalSignal == null || abnormalSignal == 0) { return new ArrayList<>(); @@ -4831,14 +4834,24 @@ public class QcServiceImpl implements QcService { ArrayList abnormalRows = getAbnormalCollectorData(ip, port, unitId, data); resetCollectorAbnormalRegisters(ip, port, unitId); return abnormalRows; - }*/ + }else{ + logger.info(port+","+ip+","+unitId+","+baseAddr+","+groups+","); + ArrayList collectorDataByModbus = getCollectorDataByModbus(port, ip, unitId, baseAddr, groups, data); + return collectorDataByModbus; + } + /*Integer abnormalSignal = ModbusUtils.readSingleRegister(ip, port, unitId, isexceptionAdress); + if (abnormalSignal == null || abnormalSignal == 0) { + return new ArrayList<>(); + } + ArrayList abnormalRows = getAbnormalCollectorData(ip, port, unitId, data); + resetCollectorAbnormalRegisters(ip, port, unitId); + return abnormalRows;*/ // 10 组数据起始地址和平均值地址 - final int baseAddr = Integer.parseInt(location.getCuttingSymbol()); - final int groups = location.getRegisterNum(); - logger.info(port+","+ip+","+unitId+","+baseAddr+","+groups+","); + + /*logger.info(port+","+ip+","+unitId+","+baseAddr+","+groups+","); ArrayList collectorDataByModbus = getCollectorDataByModbus(port, ip, unitId, baseAddr, groups, data); - return collectorDataByModbus; + return collectorDataByModbus;*/ } @@ -4917,6 +4930,7 @@ public class QcServiceImpl implements QcService { )); subDetailValues.add(detailValues); } + logger.info("解析后获取到的数据:{}",subDetailValues.toString()); return subDetailValues; } @@ -4934,7 +4948,9 @@ public class QcServiceImpl implements QcService { 566, 568, 570, 572, 574, 586, 588, 590, 592, 594 )); + logger.info("开始复位"); ModbusUtils.resetRegisters(ip, port, unitId, resetAddrs); + logger.info("复位结束"); } public ArrayList getCollectorDataByModbus(int port,String ip,int unitId,int baseAddr,int groups,QcFAIRecordData data) throws Exception {