package com.jcdm.main.plcserver.sub; import cn.hutool.core.date.DateUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.jcdm.framework.websocket.WebSocketUsers; 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 javax.websocket.Session; import java.util.*; import java.util.stream.Collectors; @Component public class OPCUaSubscription implements SubscriptionCallback { //自动工位 public List automaticList = Arrays.asList("OP300","OP280", "OP320", "OP340", "OP350", "OP360","OP370", "OP390", "OP470", "OP530", "OP540"); public List moduleCodeList = Arrays.asList("OP300","OP310", "OP320", "OP340", "OP350", "OP33"); public List nullList = Arrays.asList("OP250","OP260"); public static MiloService miloService; Map map = WebSocketUsers.getUsers(); public IDaPassingStationCollectionService daPassingStationCollectionService; public static IDaCollectionParamConfService collectionParamConfService; public static IDaParamCollectionService daParamCollectionService; public OPCUaSubscription(MiloService miloService, IDaPassingStationCollectionService daPassingStationCollectionService, IDaCollectionParamConfService collectionParamConfService, IDaParamCollectionService daParamCollectionService) { OPCUaSubscription.miloService = miloService; this.daPassingStationCollectionService = daPassingStationCollectionService; OPCUaSubscription.collectionParamConfService = collectionParamConfService; OPCUaSubscription.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(11).build()); if(automaticList.stream().noneMatch(s -> s.equals(device))){ //给前端发工件到位信号 WebSocketUsers.sendMessageToUserByText(map.get(device), "IN"); } //请求工单 }else if("2".equals(tabVlaue)){ if(automaticList.stream().anyMatch(s -> s.equals(device))){ //自动工位 //出站保存数据 recordDataDoneValue = outSaveDate(thoroughfare,device); //记录数据完成 String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf(RecordDataDoneAddress)).build()); }else { //手动工位 WebSocketUsers.sendMessageToUserByText(map.get(device), "END"); } }else { System.out.println("^"); } } //保存拧紧数据 else if (("AngleResult").equals(tab)) { if("OK".equals(tabVlaue)||"NG".equals(tabVlaue)){ List list = new ArrayList<>(); String[] suffixes = {"Torque", "Angle", "TorqueResult", "AngleResult"}; for (String suffix : suffixes) { String string = thoroughfare + "." + device + "." + suffix; list.add(string); } List list1 = miloService.readFromOpcUa(list); List collect = list1.stream().map(ReadWriteEntity::getValue).collect(Collectors.toList()); String joinedString = String.join(",", collect.toString()); WebSocketUsers.sendMessageToUserByText(map.get(device), joinedString); } } } } catch (Exception e) { } } /** * 获取SNCode */ public String getSNCode(){ String SNCode = ""; return SNCode; } /** * 出站保存数据 */ public String outSaveDate(String thoroughfare,String device) { String snCode = ""; String result = ""; String read = thoroughfare + "." + device + "."; try { if(nullList.stream().noneMatch(s -> s.equals(device))){ if(moduleCodeList.stream().anyMatch(s -> s.equals(device))){ read = read + "ModuleCode"; }else { read = read + "PACKCode"; } } snCode = miloService.readFromOpcUa(read).getValue().toString(); if(null == snCode || "".equals(snCode)){ result = "22"; }else{ //1、更新工单信息 //updateOrderInfo(); //2、保存过站采集数据 String workOrderNo = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "WorkOrderNumber").getValue().toString(); String productCode = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "ProductType").getValue().toString(); saveStationInfo(snCode,thoroughfare,device,workOrderNo,productCode); //3、保存参数采集数据 SaveParamData(snCode,thoroughfare,device,workOrderNo,productCode); result = "21"; } }catch (Exception e) { System.out.println(e.getMessage()); } return result; } // /** // * 出站保存数据 // */ // public String outSaveDate(String thoroughfare,String device) { // String result = ""; // try { // //读取SNCode // String PACKCode = thoroughfare + "." + device + ".PACKCode"; // Object PACKCodeObject = miloService.readFromOpcUa(PACKCode).getValue(); // if(null == PACKCodeObject || "".equals(PACKCodeObject)){ // result = "22"; // }else{ // String PACKCodeParam = PACKCodeObject.toString(); // //1、更新工单信息 // //updateOrderInfo(); // //2、保存过站采集数据 // saveStationInfo(PACKCodeParam,thoroughfare,device); // //3、保存参数采集数据 // SaveParamData(PACKCodeParam,thoroughfare,device,"",""); // // result = "21"; // // } // // }catch (Exception e) { // // } // return result; // } /** * 保存过站采集 */ public void saveStationInfo(String packCode,String thoroughfare,String device,String workOrderNo,String productCode) throws Exception { String prefix = thoroughfare+"."+device+"."; String startTime = miloService.readFromOpcUa(prefix + "StartTime").getValue().toString(); String stopTime = miloService.readFromOpcUa(prefix + "StopTime").getValue().toString(); String stationStatus = miloService.readFromOpcUa(prefix + "StationStatus").getValue().toString(); DaPassingStationCollection daPassingStationCollection = new DaPassingStationCollection(); daPassingStationCollection.setSfcCode(packCode); daPassingStationCollection.setWorkOrderNo(workOrderNo); daPassingStationCollection.setProductCode(productCode); daPassingStationCollection.setLocationCode(device); // daPassingStationCollection.setInboundTime(startTime);//入站时间 // daPassingStationCollection.setOutboundTime(stopTime);//出站时间 daPassingStationCollection.setOutRsSign(stationStatus);//出站是否合格 daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection); } public static void SaveParamData(String packCode,String thoroughfare,String device,String workOrderNo,String productType) 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 map = new HashMap<>(); map.put("GC", "南浔工厂"); map.put("CXBH", "Pack线"); map.put("SBBH", "设备001"); map.put("YGBH", "员工001"); List confList = new ArrayList<>(); map.forEach((key, value) -> { List daCollectionParamConfs = collectionParamConfService.list(new LambdaQueryWrapper() .eq(DaCollectionParamConf::getProcessesCode,locationCode) .like(DaCollectionParamConf::getCollectParameterId,key)); DaParamCollection saveData = new DaParamCollection(); saveData.setWorkOrderNo(workOrderNo); saveData.setProductCode(productCode); saveData.setLocationCode(locationCode); saveData.setSfcCode(packCode); saveData.setParamCode(daCollectionParamConfs.get(0).getCollectParameterId()); saveData.setParamName(daCollectionParamConfs.get(0).getCollectParameterName()); saveData.setCollectionTime(new Date()); saveData.setParamValue(value); confList.add(saveData); }); daParamCollectionService.insertBatch(confList); } }