package com.jcdm.main.plcserver.sub; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; 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.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.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.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; @Component public class OPCUaSubscription implements SubscriptionCallback { public SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //新自动工站 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","OP300B","OP320A","OP320B","OP340A","OP340B","OP365", "OP350A", "OP350B", "OP330"); //区分模组型号工位 public List distinguishingModules = Arrays.asList("OP300","OP310", "OP340", "OP350", "OP330"); //区分小车码 public List agvId = Arrays.asList("OP360", "OP390", "OP470","OP280"); //区分pack型号的工位 public List packIdList = Arrays.asList("OP280","OP360","OP390","OP470"); //测试设备手动工位 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; public OPCUaSubscription(MiloService miloService, IDaPassingStationCollectionService daPassingStationCollectionService, IDaCollectionParamConfService collectionParamConfService, IDaParamCollectionService daParamCollectionService, IOmProductionOrdeInfoService omProductionOrdeInfoService) { OPCUaSubscription.miloService = miloService; this.daPassingStationCollectionService = daPassingStationCollectionService; OPCUaSubscription.collectionParamConfService = collectionParamConfService; OPCUaSubscription.daParamCollectionService = daParamCollectionService; OPCUaSubscription.omProductionOrdeInfoService = omProductionOrdeInfoService; } @Override public void onSubscribe(String identifier, Object 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 { //手动工位处理逻辑 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))){ //自动工位 //出站保存数据 recordDataDoneValue = 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()); } } }else { System.out.println("^"); } } //保存拧紧数据 else if (("AngleResult").equals(tab)) { if("1".equals(tabVlaue)||"2".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)); } } } } 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"; if(device.equals("OP365")){ try { saveStationInfo365(thoroughfare,device); }catch (Exception e){ e.printStackTrace(); } } }else { read = read + "PACKCode"; } } snCode = miloService.readFromOpcUa(read).getValue().toString(); if(null == snCode || "".equals(snCode)){ result = "22"; }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、保存参数采集数据 SaveParamData(snCode,thoroughfare,device,workOrderNo,productCode); //如果是末尾工站要报工 if(device.equals("OP500")){ RestfulService.getWorkReportResultFeedback(snCode,device,format.format(new Date())); //1、更新工单信息 updateOrderInfo(snCode); } try{ daParamCollectionService.pushGeelycvMesFeedback(snCode,device); }catch (Exception e){ } 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 { 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); } 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); for (int i = 0; i < readWriteEntityList.size(); i++) { if(readWriteEntityList.get(i).getValue() == null){ readWriteEntityList.get(i).setValue(" "); } } 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); } 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 (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 prefix = thoroughfare+"."+device+"."; List passingStationCollections = new ArrayList<>(); String ModuleCodeA = miloService.readFromOpcUa(prefix + "ModuleCodeA").getValue().toString(); String ModuleCodeB = miloService.readFromOpcUa(prefix + "ModuleCodeB").getValue().toString(); String StationStatusA = miloService.readFromOpcUa(prefix + "StationStatusA").getValue().toString(); String StationStatusB = miloService.readFromOpcUa(prefix + "StationStatusB").getValue().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); String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(21).build()); return; } }