| | |
| | | String paramProductNum = ""; |
| | | try { |
| | | // 查询最新的工单信息 |
| | | List<OmProductionOrdeInfo> list = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().orderByAsc(OmProductionOrdeInfo::getCreateTime)); |
| | | if(list.size() > 0){ |
| | | paramProductNum = list.get(list.size()-1).getProductNum(); |
| | | } |
| | | String orderJsonString = RestfulService.getProductionWorkOrderRequest(paramProductNum, "OP230"); |
| | | OmProductionOrdeInfo lastOrder = omProductionOrdeInfoService.getLastOrder(); |
| | | String orderJsonString = RestfulService.getProductionWorkOrderRequest(lastOrder.getProductNum(), "OP230"); |
| | | JSONObject jsonObject = new JSONObject(orderJsonString); |
| | | // 从JSONObject中获取data对象 |
| | | JSONObject dataObject = jsonObject.getJSONObject("data"); |
| | |
| | | for (ReadWriteEntity readWriteEntity : readWriteEntityList) { |
| | | if (ObjectUtil.isNotNull(readWriteEntity.getValue()) && !"".equals(readWriteEntity.getValue().toString().trim())){ |
| | | cellCodeList.add(readWriteEntity.getValue().toString());//封装电芯码 |
| | | }else{ |
| | | }/*else{ |
| | | cellCodeList.add("");//封装电芯码 |
| | | } |
| | | }*/ |
| | | } |
| | | |
| | | } catch (Exception e) { |
| | |
| | | .eq(DaTestDeviceInterfaceTemp::getStationCode, device) |
| | | .eq(DaTestDeviceInterfaceTemp::getProductNum,cellCode)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(0); |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(list.size()-1); |
| | | if (Constants.ONE.equals(daTestDeviceInterfaceTemp.getTotalResult())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_1").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_1").value(2).build()); |
| | | } |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempById(daTestDeviceInterfaceTemp.getId()); |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempByProductNum(cellCode); |
| | | |
| | | } |
| | | return flag; |
| | | } |
| | |
| | | .eq(DaTestDeviceInterfaceTemp::getStationCode, device) |
| | | .eq(DaTestDeviceInterfaceTemp::getProductNum,cellCode)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(0); |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(list.size()-1); |
| | | if (Constants.ONE.equals(daTestDeviceInterfaceTemp.getTotalResult())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_1").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_1").value(2).build()); |
| | | } |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempById(daTestDeviceInterfaceTemp.getId()); |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempByProductNum(cellCode); |
| | | } |
| | | } |
| | | Object value2 = miloService.readFromOpcUa(thoroughfare + "." + device + ".CellCode_2").getValue(); |
| | |
| | | .eq(DaTestDeviceInterfaceTemp::getStationCode, device) |
| | | .eq(DaTestDeviceInterfaceTemp::getProductNum,cellCode)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(0); |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(list.size()-1); |
| | | if (Constants.ONE.equals(daTestDeviceInterfaceTemp.getTotalResult())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_2").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_2").value(2).build()); |
| | | } |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempById(daTestDeviceInterfaceTemp.getId()); |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempByProductNum(cellCode); |
| | | } |
| | | } |
| | | |
| | |
| | | .eq(DaTestDeviceInterfaceTemp::getStationCode, device) |
| | | .eq(DaTestDeviceInterfaceTemp::getProductNum,cellCode)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(0); |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(list.size()-1); |
| | | if (Constants.ONE.equals(daTestDeviceInterfaceTemp.getTotalResult())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_3").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_3").value(2).build()); |
| | | } |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempById(daTestDeviceInterfaceTemp.getId()); |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempByProductNum(cellCode); |
| | | } |
| | | } |
| | | |
| | |
| | | .eq(DaTestDeviceInterfaceTemp::getStationCode, device) |
| | | .eq(DaTestDeviceInterfaceTemp::getProductNum,cellCode)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(0); |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(list.size()-1); |
| | | if (Constants.ONE.equals(daTestDeviceInterfaceTemp.getTotalResult())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_4").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_4").value(2).build()); |
| | | } |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempById(daTestDeviceInterfaceTemp.getId()); |
| | | daTestDeviceInterfaceTempService.deleteDaTestDeviceInterfaceTempByProductNum(cellCode); |
| | | } |
| | | } |
| | | |