package com.jcdm.main.plcserver.sub; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.jcdm.common.utils.StringUtils; import com.jcdm.framework.websocket.WebSocketUsers; import com.jcdm.main.constant.Constants; 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.da.testDeviceInterface.domain.DaTestDeviceInterface; import com.jcdm.main.da.testDeviceInterface.service.IDaTestDeviceInterfaceService; import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo; import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService; import com.jcdm.main.plcserver.conf.OPCElement; import com.jcdm.main.plcserver.util.TimeUtil; import com.jcdm.main.restful.factoryMes.service.RestfulService; import com.jcdm.main.restful.qingYan.doman.ChildVO; import com.jcdm.main.restful.qingYan.doman.ParentVO; import com.kangaroohy.milo.model.ReadWriteEntity; import com.kangaroohy.milo.runner.subscription.SubscriptionCallback; import com.kangaroohy.milo.service.MiloService; import lombok.extern.slf4j.Slf4j; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import javax.websocket.Session; import java.text.SimpleDateFormat; import java.time.Instant; import java.util.*; import java.util.stream.Collectors; @Slf4j @Component public class OPCUaSubscription implements SubscriptionCallback { private static final Logger logger = LoggerFactory.getLogger("sys-user"); public SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //新自动工站 public List automaticList = Arrays.asList("POP270","POP282", "POP281", "POP283", "POP285", "POP286", "POP290","OP365","POP300", "POP320", "POP400"); //采集模组工位 ModuleCode public List moduleCodeList = Arrays.asList("POP281","POP282","POP283","POP285","OP365", "POP286", "POP284"); //区分小车码 public List agvId = Arrays.asList("POP290", "POP320", "POP400","POP270"); //测试设备手动工位 public List testList = Arrays.asList("POP360-1","POP360-2","POP360-3","POP360-4","POP410-1","POP410-2","POP410-3","POP370","POP420-1","POP420-2","POP420-3"); //空的 public List nullList = Arrays.asList("OP250","OP260"); // //新自动工站 // public List automaticList = Arrays.asList("OP280","OP310A","OP310B", "OP300A","OP300B", "OP320A","OP320B", "OP340A","OP340B", "OP350A","OP350B", "OP360","OP365","OP370", "OP390", "OP470"); // // //采集模组工位 ModuleCode // public List moduleCodeList = Arrays.asList("OP300A","OP310A","OP310B","OP300B","OP320A","OP320B","OP340A","OP340B","OP365", "OP350A", "OP350B", "OP330"); // // //区分小车码 // public List agvId = Arrays.asList("OP360", "OP390", "OP470","OP280"); // // //测试设备手动工位 // public List testList = Arrays.asList("OP430-1","OP430-2","OP430-3","OP430-4","OP480-1","OP480-2","OP480-3","OP440"); // // // //空的 // 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 static IOmProductionOrdeInfoService omProductionOrdeInfoService; private static IDaTestDeviceInterfaceService daTestDeviceInterfaceService; public OPCUaSubscription(MiloService miloService, IDaPassingStationCollectionService daPassingStationCollectionService, IDaCollectionParamConfService collectionParamConfService, IDaParamCollectionService daParamCollectionService, IOmProductionOrdeInfoService omProductionOrdeInfoService, IDaTestDeviceInterfaceService daTestDeviceInterfaceService) { OPCUaSubscription.miloService = miloService; this.daPassingStationCollectionService = daPassingStationCollectionService; OPCUaSubscription.collectionParamConfService = collectionParamConfService; OPCUaSubscription.daParamCollectionService = daParamCollectionService; OPCUaSubscription.omProductionOrdeInfoService = omProductionOrdeInfoService; OPCUaSubscription.daTestDeviceInterfaceService = daTestDeviceInterfaceService; } @Override public void onSubscribe(String identifier, Object value) { logger.info("地址:"+identifier+"值:"+value); try { if(null != value && Integer.valueOf(value.toString())!= 0) { String[] nodes = identifier.split("[.]"); String thoroughfare = nodes[0];//通道 String device = nodes[1];//设备 String tab = nodes[2];//标记 String tabVlaue = value.toString();//地址值 if (("RecordData").equals(tab)) { String recordDataDoneValue = ""; if("1".equals(tabVlaue)){ //请求工单 // if(device.equals("OP230")){ // getFactoryOrder("OP230"); // } //自动工位 if(automaticList.stream().anyMatch(s -> s.equals(device))){ //plc给我们一个模组码,拿模组码校验出型号 if(moduleCodeList.stream().anyMatch(s -> s.equals(device))) { String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; //读模组码 Object moduleCode = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCode").getValue(); if(device.equals("OP365")){ Object moduleCodeA = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCodeA").getValue(); Object moduleCodeB = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCodeB").getValue(); if(moduleCodeA!=null && moduleCodeB!=null){ miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(11).build()); }else { miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(12).build()); } return; } if(moduleCode!=null){ miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(11).build()); }else { miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(12).build()); } }else { if(agvId.stream().anyMatch(s -> s.equals(device))){ Object agvIdObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".AGVID").getValue(); //agvId 小车码是否为空 if(agvIdObject!=null){ String PACKCode = thoroughfare + "." + device + ".MPACKCode"; OmProductionOrdeInfo one = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper().eq(OmProductionOrdeInfo::getTrolleyYard, agvIdObject.toString())); //小车码查找工单是否为空 if(one!=null){ String packId = one.getProductNum(); miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(PACKCode).value(packId).build()); miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(11).build()); }else { miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(12).build()); } }else { miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(12).build()); } }else { String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; Object packCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".PACKCode").getValue(); if(packCodeObject!=null){ //pack 如果区分型号的话就要处理 //记录数据完成 miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(11).build()); }else { miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(12).build()); } } } }else { //手动工位处理逻辑 // if (map.containsKey(device)){ WebSocketUsers.sendMessageToUserByText(map.get(device), "IN"); String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(11).build()); // } } }else if("2".equals(tabVlaue)){ if(automaticList.stream().anyMatch(s -> s.equals(device))){ //自动工位 //出站保存数据 outSaveDate(thoroughfare,device); //记录数据完成 /*String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf(recordDataDoneValue)).build());*/ }else { //手动工位 // if(device.contains("OP330")){ // String str = device.substring(0,5); // WebSocketUsers.sendMessageToUserByText(map.get(str), "END"); // }else { WebSocketUsers.sendMessageToUserByText(map.get(device), "END"); // } if(testList.stream().anyMatch(s -> s.equals(device))){ String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(21).build()); // Object packCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCode").getValue(); // DaTestDeviceInterface deviceInterfaceOne = null; // // if (ObjectUtil.isNotNull(packCodeObject)) { // String modelCode = packCodeObject.toString(); // deviceInterfaceOne = daTestDeviceInterfaceService.getOne(new LambdaQueryWrapper() // .eq(DaTestDeviceInterface::getProductNum, modelCode) // .eq(DaTestDeviceInterface::getStationCode, device)); // } // // if (deviceInterfaceOne != null && "1".equals(deviceInterfaceOne.getTotalResult())) { // writeToOpcShort(RecordDataDoneAddress, (short) 21); // } else { // writeToOpc(RecordDataDoneAddress, (short) 22); // } // writeToOpc(RecordDataDoneAddress, (short) 21); } } }else { System.out.println("^"); } } //保存拧紧数据 else if (("TighteningFrequency").equals(tab)) { if(!"0".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), TightenTheConversionOkNg(joinedString)); logger.info("读取到工位{}的Scaner数据:{}",device,TightenTheConversionOkNg(joinedString)); } } } } catch (Exception e) { logger.info("订阅方法报错:{}"+e.getMessage()); logger.error("订阅方法报错",e); } } /** * 获取SNCode */ public String getSNCode(){ String SNCode = ""; return SNCode; } /** * 出站保存数据 */ public void 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"; } } if(device.equals("OP365")){ try { saveStationInfo365(thoroughfare,device); }catch (Exception e){ e.printStackTrace(); } }else { snCode = miloService.readFromOpcUa(read).getValue().toString(); if(null == snCode || "".equals(snCode)){ String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf("22")).build()); }else{ String workOrderNo = ""; String productCode = ""; //2、保存过站采集数据 Object orderNumberObject = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "WorkOrderNumber").getValue(); if(orderNumberObject!=null){ workOrderNo = orderNumberObject.toString(); } Object productCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "ProductType").getValue(); if(productCodeObject!=null){ productCode = productCodeObject.toString(); } saveStationInfo(snCode,thoroughfare,device,workOrderNo,productCode); //3、保存参数采集数据 List daParamCollectionList = SaveParamData(snCode,thoroughfare,device,workOrderNo,productCode); //如果是末尾工站要报工 if(device.equals("POP430")){ RestfulService.getWorkReportResultFeedback(snCode,device,format.format(new Date())); //1、更新工单信息 updateOrderInfo(snCode); } try{ daParamCollectionService.automaticWorkstationPushGeelycvMesFeedback(snCode,device,daParamCollectionList); }catch (Exception e){ } } } }catch (Exception e) { logger.error("出站保存数据异常:"+e); } } // /** // * 出站保存数据 // */ // 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 { logger.info("进入工位{}-方法saveStationInfo",device); SimpleDateFormat sdf = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy", Locale.US); sdf.setTimeZone(TimeZone.getTimeZone("GMT+8")); // CST通常表示中国标准时间,即东八区 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); String strt = TimeUtil.stringProcessing(startTime); String end = TimeUtil.stringProcessing(stopTime); daPassingStationCollection.setInboundTime(format.parse(TimeUtil.test(strt)));//入站时间 daPassingStationCollection.setOutboundTime(format.parse(TimeUtil.test(end)));//出站时间 daPassingStationCollection.setOutRsSign(stationStatus);//出站是否合格 daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection); logger.info("结束工位{}-方法saveStationInfo",device); } public static List SaveParamData(String packCode,String thoroughfare,String device,String workOrderNo,String productType) throws Exception { logger.info("进入工位{}-方法SaveParamData",device); List list; DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf(); daCollectionParamConf.setGatherAddress(thoroughfare+ "." + device); list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf); List daParamCollectionlist = new ArrayList<>(); List nodeIdList = list.stream().map(info -> { String nodeid = info.getGatherAddress(); return nodeid; }).collect(Collectors.toList()); if(!nodeIdList.isEmpty()){ List readWriteEntityList = miloService.readFromOpcUa(nodeIdList); for(int i=0;i baseDataList = addBaseData(workOrderNo,productType,device,packCode); for (int i = 0; i < baseDataList.size(); i++){ daParamCollectionlist.add(baseDataList.get(i)); } logger.info("结束工位{}-方法SaveParamData",device); return daParamCollectionlist; } public static List addBaseData(String workOrderNo,String productCode,String locationCode,String packCode){ Map 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); return confList; } public static void getFactoryOrder(String locationCode){ String productionWorkOrder = RestfulService.getProductionWorkOrderRequest("", locationCode); JSONObject jsonObject = new JSONObject(productionWorkOrder); JSONObject dataObject = jsonObject.getJSONObject("data"); String productNum = dataObject.getStr("productNum"); String stationCode = dataObject.getStr("stationCode"); String materialCode = dataObject.getStr("materialCode"); String productionOrderNum = dataObject.getStr("productionOrderNum"); OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo(); omProductionOrdeInfo.setProductNum(productNum); omProductionOrdeInfo.setWorkOrderNo(productionOrderNum); omProductionOrdeInfo.setStationCode(stationCode); omProductionOrdeInfo.setProductCode(materialCode); omProductionOrdeInfoService.save(omProductionOrdeInfo); } public static void updateOrderInfo(String packCode){ OmProductionOrdeInfo one = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper().eq(OmProductionOrdeInfo::getProductNum, packCode)); one.setOrderStatus("5"); omProductionOrdeInfoService.saveOrUpdate(one); } public static void avgFunction(){ } public static String TightenTheConversionOkNg(String param){ // 去除首尾的方括号,然后按照逗号分割字符串 String[] parts = param.substring(1, param.length() - 1).split(","); // 创建一个新的StringBuilder来构建替换后的字符串 StringBuilder sb = new StringBuilder(); sb.append('['); // 添加左方括号 for (int i = 0; i < parts.length; i++) { String part = parts[i].trim(); // 去除可能的空格 float value; try { value = Float.parseFloat(part); // 尝试将字符串转换为浮点数 String replacement; if(i<2){ replacement = part; }else{ if (value == 1f) { replacement = "OK"; } else{ replacement = "NG"; } } /* if (value == 1f) { replacement = "OK"; } else if (value == 2f) { replacement = "NG"; } else { replacement = part; // 如果不是1或2,则保持不变 }*/ sb.append(replacement); if (i < parts.length - 1) { sb.append(','); // 添加逗号(除了最后一个元素) } } catch (NumberFormatException e) { // 如果转换失败,则保持原样(或进行其他错误处理) sb.append(part); if (i < parts.length - 1) { sb.append(','); } } } sb.append(']'); // 添加右方括号 return sb.toString(); } /** * 校验是否存在NG * @param packCode sfcCode * @return boolean */ public boolean checkIsNG(String packCode,String modelCode){ List list = daPassingStationCollectionService.list(new LambdaQueryWrapper() .eq(StrUtil.isNotBlank(packCode),DaPassingStationCollection::getSfcCode, packCode) .eq(DaPassingStationCollection::getOutRsSign, Constants.UN_PASS)); return CollUtil.isEmpty(list); } /** * 保存过站采集 */ public void saveStationInfo365(String thoroughfare,String device) throws Exception { String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; String prefix = thoroughfare+"."+device+"."; List passingStationCollections = new ArrayList<>(); String ModuleCodeA = ""; String ModuleCodeB = ""; String StationStatusA = ""; String StationStatusB = ""; Object objectModuleCodeA = miloService.readFromOpcUa(prefix + "ModuleCodeA").getValue(); Object objectModuleCodeB = miloService.readFromOpcUa(prefix + "ModuleCodeB").getValue(); Object objectStationStatusA = miloService.readFromOpcUa(prefix + "StationStatusA").getValue(); Object objectStationStatusB = miloService.readFromOpcUa(prefix + "StationStatusB").getValue(); if(ObjectUtil.isNotNull(objectModuleCodeA) && ObjectUtil.isNotNull(objectStationStatusA) && ObjectUtil.isNotNull(objectModuleCodeB) && ObjectUtil.isNotNull(objectStationStatusB)){ ModuleCodeA = objectModuleCodeA.toString(); ModuleCodeB = objectModuleCodeB.toString(); StationStatusA = objectStationStatusA.toString(); StationStatusB = objectStationStatusB.toString(); String[] modeles = {ModuleCodeA,ModuleCodeB}; String[] StationStatus = {StationStatusA,StationStatusB}; String startTime = miloService.readFromOpcUa(prefix + "StartTime").getValue().toString(); String stopTime = miloService.readFromOpcUa(prefix + "StopTime").getValue().toString(); for (int i = 0; i < 2; i++) { DaPassingStationCollection daPassingStationCollection = new DaPassingStationCollection(); String strt = TimeUtil.stringProcessing(startTime); String end = TimeUtil.stringProcessing(stopTime); daPassingStationCollection.setInboundTime(format.parse(TimeUtil.test(strt)));//入站时间 daPassingStationCollection.setOutboundTime(format.parse(TimeUtil.test(end)));//出站时间 daPassingStationCollection.setSfcCode(modeles[i]); daPassingStationCollection.setLocationCode(device); daPassingStationCollection.setOutRsSign(StationStatus[i]);//出站是否合格 passingStationCollections.add(daPassingStationCollection); } daPassingStationCollectionService.saveBeachDaPassingStationCollection(passingStationCollections); miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(21).build()); logger.info("工位{}回复21",device); }else { miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(22).build()); } } private static void writeToOpcShort(String identifier, short value) { try { miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(identifier).value(value).build()); } catch (Exception e) { throw new RuntimeException(e); } } }