From a4362dfe3e0e9c6fad426685da0065455799d018 Mon Sep 17 00:00:00 2001 From: hdy <1105738590@qq.com> Date: 星期三, 10 七月 2024 20:06:15 +0800 Subject: [PATCH] cvt交互逻辑更新 --- jcdm-main/src/main/java/com/jcdm/main/plcserver/callback/InitCallback.java | 111 ++++++++++++++++++++++++++++++++----------------------- 1 files changed, 64 insertions(+), 47 deletions(-) diff --git a/jcdm-main/src/main/java/com/jcdm/main/plcserver/callback/InitCallback.java b/jcdm-main/src/main/java/com/jcdm/main/plcserver/callback/InitCallback.java index d7a6c53..94af5de 100644 --- a/jcdm-main/src/main/java/com/jcdm/main/plcserver/callback/InitCallback.java +++ b/jcdm-main/src/main/java/com/jcdm/main/plcserver/callback/InitCallback.java @@ -54,53 +54,31 @@ String ecpStr = "";//寮傚父璁板綍鏍囪 try { if (null != value) { - //BCOP40杩涚珯鏍¢獙 - if (identifier.equals("CFL4CVT.BCOP040.RecordData") && null != value && "1".equals(value.toString())) { - //寰呮坊鍔犱粠杩囩珯閲囬泦琛ㄥ彇sfc_code鍐欏叆plc鐨剆ncode鏂规硶 - ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BCOP040.MesRecordDataDone", 11); - miloService.writeToOpcByte(entity); + //BCOP010鍑虹珯鏍¢獙 + if (identifier.equals("CFL4CVT.BCOP010.RecordData") && null != value && "2".equals(value.toString())) { + ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BCOP010.MesRecordDataDone", 21); + miloService.writeToOpcShort(entity); } //BCOP40鍑虹珯鏍¢獙 else if (identifier.equals("CFL4CVT.BCOP040.RecordData") && null != value && "2".equals(value.toString())) { - SaveData("CFL4CVT.BCOP40.RecordData"); - ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BCOP040.MesRecordDataDone", 21); - miloService.writeToOpcByte(entity); - } - //BCOP60杩涚珯鏍¢獙 - else if (identifier.equals("CFL4CVT.BCOP060.RecordData") && null != value && "1".equals(value.toString())) { - //寰呮坊鍔犱粠杩囩珯閲囬泦琛ㄥ彇sfc_code鍐欏叆plc鐨剆ncode鏂规硶 - ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BCOP060.MesRecordDataDone", 11); - miloService.writeToOpcByte(entity); + SaveData("CFL4CVT.BCOP040.RecordData"); } //BCOP60鍑虹珯鏍¢獙 else if (identifier.equals("CFL4CVT.BCOP060.RecordData") && null != value && "2".equals(value.toString())) { SaveData("CFL4CVT.BCOP060.RecordData"); - ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BCOP060.MesRecordDataDone", 21); - miloService.writeToOpcByte(entity); - } - //BCOP100杩涚珯鏍¢獙 - else if (identifier.equals("CFL4CVT.BCOP100.RecordData") && null != value && "1".equals(value.toString())) { - //寰呮坊鍔犱粠杩囩珯閲囬泦琛ㄥ彇sfc_code鍐欏叆plc鐨剆ncode鏂规硶 - ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BCOP100.MesRecordDataDone", 11); - miloService.writeToOpcByte(entity); } //BCOP100鍑虹珯鏍¢獙 else if (identifier.equals("CFL4CVT.BCOP100.RecordData") && null != value && "2".equals(value.toString())) { SaveData("CFL4CVT.BCOP100.RecordData"); - ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BCOP100.MesRecordDataDone", 21); - miloService.writeToOpcByte(entity); - }//BP020杩涚珯鏍¢獙 - else if (identifier.equals("CFL4CVT.BP020.RecordData") && null != value && "1".equals(value.toString())) { - //寰呮坊鍔犱粠杩囩珯閲囬泦琛ㄥ彇sfc_code鍐欏叆plc鐨剆ncode鏂规硶 - ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BP020.MesRecordDataDone", 11); - miloService.writeToOpcByte(entity); + } //BP020鍑虹珯鏍¢獙 else if (identifier.equals("CFL4CVT.BP020.RecordData") && null != value && "2".equals(value.toString())) { SaveData("CFL4CVT.BP020.RecordData"); - ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BP020.MesRecordDataDone", 21); - miloService.writeToOpcByte(entity); - + } + else if(identifier.equals("CFL4CVT.OP220.RecordData") && null != value && "2".equals(value.toString())) { + ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.OP220.MesRecordDataDone", 21); + miloService.writeToOpcShort(entity); } } @@ -114,11 +92,56 @@ } } +// public void SaveData(String Node) throws Exception { +// String[] parts = Node.split("[.]"); +// Object SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Code1").getValue(); +// +// if (null != SNCodeObject) { +// String SNCode = SNCodeObject.toString(); +// List<DaCollectionParamConf> list; +// DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf(); +// daCollectionParamConf.setGatherAddress(parts[0] + "." + parts[1]); +// list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf); +// +// List<String> nodeIdList = list.stream().map(info -> { +// String nodeid = info.getGatherAddress(); +// return nodeid; +// }).collect(Collectors.toList()); +// +// if (!nodeIdList.isEmpty()) { +// List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(nodeIdList); +// List<DaParamCollection> daParamCollectionlist = new ArrayList<>(); +// for (int i = 0; i < nodeIdList.size(); i++) { +// DaParamCollection ParamCollection = new DaParamCollection(); +// if (!readWriteEntityList.get(i).getValue().toString().equals("0.0")) { +// ParamCollection.setParamCode(readWriteEntityList.get(i).getIdentifier().toString().split("[.]")[2]); +// ParamCollection.setLocationCode(parts[1]); +// Object value = readWriteEntityList.get(i).getValue(); +// if (ObjectUtils.isNotEmpty(value)) { +// String string = value.toString(); +// ParamCollection.setParamValue(string); +// } +// ParamCollection.setSfcCode(SNCode); +// ParamCollection.setParamName(list.get(i).getCollectParameterName()); +// ParamCollection.setParamUpper(list.get(i).getParamUpper()); +// ParamCollection.setParamLower(list.get(i).getParamLower()); +// ParamCollection.setUnit(list.get(i).getCollectParameterUnit()); +// ParamCollection.setState("鍚堟牸"); +// ParamCollection.setType(list.get(i).getCollectParameterType()); +// ParamCollection.setCollectionTime(new Date()); +// daParamCollectionlist.add(ParamCollection); +// } +// } +// daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist); +// } +// } +// } + public void SaveData(String Node) throws Exception { String[] parts = Node.split("[.]"); - Object SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Code1").getValue(); - - if (null != SNCodeObject) { + Object SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".RecordData").getValue(); + if(null != SNCodeObject) + { String SNCode = SNCodeObject.toString(); List<DaCollectionParamConf> list; DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf(); @@ -130,19 +153,15 @@ return nodeid; }).collect(Collectors.toList()); - if (!nodeIdList.isEmpty()) { + if(!nodeIdList.isEmpty()){ List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(nodeIdList); List<DaParamCollection> daParamCollectionlist = new ArrayList<>(); - for (int i = 0; i < nodeIdList.size(); i++) { + for(int i=0;i<nodeIdList.size();i++){ DaParamCollection ParamCollection = new DaParamCollection(); - if (!readWriteEntityList.get(i).getValue().toString().equals("0.0")) { + if(!readWriteEntityList.get(i).getValue().toString().equals("0.0")){ ParamCollection.setParamCode(readWriteEntityList.get(i).getIdentifier().toString().split("[.]")[2]); ParamCollection.setLocationCode(parts[1]); - Object value = readWriteEntityList.get(i).getValue(); - if (ObjectUtils.isNotEmpty(value)) { - String string = value.toString(); - ParamCollection.setParamValue(string); - } + ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString()); ParamCollection.setSfcCode(SNCode); ParamCollection.setParamName(list.get(i).getCollectParameterName()); ParamCollection.setParamUpper(list.get(i).getParamUpper()); @@ -155,13 +174,11 @@ } } daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist); + ReadWriteEntity entity = new ReadWriteEntity(parts[0] + "." + parts[1] +".MesRecordDataDone", 21); + miloService.writeToOpcShort(entity); } } } - public void WriteSNCode(String Node) throws Exception { - - - } } \ No newline at end of file -- Gitblit v1.9.3