package com.jcdm.main.plcserver.sub; import cn.hutool.core.date.DateUtil; import cn.hutool.json.JSONObject; 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.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("OP300","OP280", "OP320", "OP340", "OP350", "OP360","OP370", "OP390", "OP470", "OP530", "OP540"); //采集模组工位 public List moduleCodeList = Arrays.asList("OP300","OP310", "OP320", "OP340", "OP350", "OP330"); //空的 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) { 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)){ //请求工单 // if(device.equals("OP230")){ // getFactoryOrder("OP230"); // } //自动工位 //plc给我们一个pack码,拿pack码校验出型号 if(moduleCodeList.stream().anyMatch(s -> s.equals(device))){ //读模组码 String moduleCode = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCode").getValue().toString(); String productTye = thoroughfare + "." + device + ".ProductType"; if(null!=moduleCode && moduleCode.length() == 24){ miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(productTye).value(Integer.valueOf(moduleCode.substring(7,8))).build()); //进站保存数据 // inSaveDate(thoroughfare,device) //记录数据完成 String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(11).build()); //请求工单 }else { miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(12).build()); } }else { //手动工位处理逻辑 // if(automaticList.stream().noneMatch(s -> s.equals(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))){ //自动工位 //出站保存数据 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("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), 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{ String workOrderNo = ""; String productCode = ""; //2、保存过站采集数据 // String workOrderNo = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "WorkOrderNumber").getValue().toString(); // String productCode = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "ProductType").getValue().toString(); 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); } 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(sdf.parse(strt));//入站时间 daPassingStationCollection.setOutboundTime(sdf.parse(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); } }