package com.jcdm.main.plcserver.sub; import com.jcdm.main.da.collectionParamConf.domain.DaCollectionParamConf; import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService; import com.jcdm.main.da.paramCollection.domain.DaParamCollection; import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService; import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection; import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService; import com.jcdm.main.plcserver.conf.OPCElement; import com.kangaroohy.milo.model.ReadWriteEntity; import com.kangaroohy.milo.runner.subscription.SubscriptionCallback; import com.kangaroohy.milo.service.MiloService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.stream.Collectors; @Component public class OPCUaSubscription implements SubscriptionCallback { public static MiloService miloService; public IDaPassingStationCollectionService daPassingStationCollectionService; public IDaCollectionParamConfService collectionParamConfService; public IDaParamCollectionService daParamCollectionService; public OPCUaSubscription(MiloService miloService, IDaPassingStationCollectionService daPassingStationCollectionService, IDaCollectionParamConfService collectionParamConfService, IDaParamCollectionService daParamCollectionService) { OPCUaSubscription.miloService = miloService; this.daPassingStationCollectionService = daPassingStationCollectionService; this.collectionParamConfService = collectionParamConfService; this.daParamCollectionService = daParamCollectionService; } @Override public void onSubscribe(String identifier, Object value) { try { if(null != value) { String[] nodes = identifier.split("[.]"); String thoroughfare = nodes[0];//通道 String device = nodes[1];//设备 String tab = nodes[2];//标记 String tabVlaue = value.toString();//地址值 //请求下发SN号 if (("RecordSN").equals(tab) && "1".equals(tabVlaue)) { //获取SN号方法 String SNCode = getSNCode(); //下发SN String SNCodeAddress = thoroughfare + "." + device + ".SNCode"; miloService.writeToOpcChar(ReadWriteEntity.builder().identifier(SNCodeAddress).value(SNCode).build()); //下发SN完成 String recordSNDoneAddress = thoroughfare + "." + device + ".RecordSNDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(recordSNDoneAddress).value(1).build()); } //请求记录数据 else if (("RecordData").equals(tab)) { String recordDataDoneValue = ""; if("1".equals(tabVlaue)){ recordDataDoneValue = "11"; //进站保存数据 // inSaveDate(thoroughfare,device) //记录数据完成 String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(recordDataDoneValue).build()); //给前端发工件到位信号 //请求工单 }else if("2".equals(tabVlaue)){ //出站保存数据 recordDataDoneValue = outSaveDate(thoroughfare,device); //记录数据完成 String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(recordDataDoneValue).build()); }else{ System.out.println("^"); } } } } catch (Exception e) { } } /** * 获取SNCode */ public String getSNCode(){ String SNCode = ""; return SNCode; } /** * 出站保存数据 */ public String outSaveDate(String thoroughfare,String device) { String result = ""; try { //读取SNCode String SNCodeAddress = thoroughfare + "." + device + ".SNCode"; Object SNCodeObject = miloService.readFromOpcUa(SNCodeAddress).getValue(); if(null == SNCodeObject || "".equals(SNCodeObject)){ result = "22"; }else{ String SNCode = SNCodeObject.toString(); //1、更新工单信息 //updateOrderInfo(); //2、保存过站采集数据 saveStationInfo(SNCode,thoroughfare,device); //3、保存参数采集数据 SaveParamData(SNCode,thoroughfare,device); result = "21"; } }catch (Exception e) { } return result; } /** * 保存过站采集 */ public void saveStationInfo(String SNCode,String thoroughfare,String device){ DaPassingStationCollection daPassingStationCollection = new DaPassingStationCollection(); daPassingStationCollection.setSfcCode(SNCode); //daPassingStationCollection.setInboundTime();//入站时间 daPassingStationCollection.setOutboundTime(new Date());//出站时间 //daPassingStationCollection.setOutRsSign();//出站是否合格 daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection); } public void SaveParamData(String SNCode,String thoroughfare,String device) throws Exception { List list; DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf(); daCollectionParamConf.setGatherAddress(thoroughfare+ "." + device); list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf); List nodeIdList = list.stream().map(info -> { String nodeid = info.getGatherAddress(); return nodeid; }).collect(Collectors.toList()); if(!nodeIdList.isEmpty()){ List readWriteEntityList = miloService.readFromOpcUa(nodeIdList); List daParamCollectionlist = new ArrayList<>(); for(int i=0;i