//package com.billion.main.plc.sub;
|
//
|
//
|
//import cn.hutool.core.collection.CollUtil;
|
//import cn.hutool.core.util.ObjectUtil;
|
//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
//import com.billion.main.da.domain.DaParamCollection;
|
//import com.billion.main.da.service.IDaParamCollectionService;
|
//import com.billion.main.da.service.IDaStationCollectionService;
|
//import com.billion.main.plc.constant.Constants;
|
//import com.billion.main.sc.domain.ScCollectionParamConf;
|
//import com.billion.main.sc.service.IScCollectionParamConfService;
|
//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.springframework.stereotype.Component;
|
//
|
//import java.util.ArrayList;
|
//import java.util.Date;
|
//import java.util.List;
|
//import java.util.concurrent.CompletableFuture;
|
//import java.util.stream.Collectors;
|
//
|
//
|
//@Slf4j
|
//public class OPCUaSubscriptionTemp implements SubscriptionCallback {
|
//
|
// public static MiloService miloService;
|
// public static IScCollectionParamConfService collectionParamConfService;
|
// public static IDaParamCollectionService paramCollectionService;
|
// public static IDaStationCollectionService stationCollectionService;
|
//
|
// public OPCUaSubscriptionTemp(MiloService miloService, IScCollectionParamConfService collectionParamConfService
|
// , IDaParamCollectionService paramCollectionService, IDaStationCollectionService stationCollectionService) {
|
// OPCUaSubscriptionTemp.miloService = miloService;
|
// OPCUaSubscriptionTemp.collectionParamConfService = collectionParamConfService;
|
// OPCUaSubscriptionTemp.paramCollectionService = paramCollectionService;
|
// OPCUaSubscriptionTemp.stationCollectionService = stationCollectionService;
|
// }
|
//
|
// @Override
|
// public void onSubscribe(String identifier, Object value) {
|
// log.info("地址："+identifier+"值："+value);
|
// try {
|
// if(null != value && !Constants.ZERO.equals(value.toString())) {
|
// String[] nodes = identifier.split("[.]");
|
// String thoroughfare = nodes[0];//通道
|
// String device = nodes[1];//设备
|
// String tab = nodes[2];//标记
|
// String valueString = value.toString();//地址值
|
//
|
// CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> {
|
// subHandle(thoroughfare,device,tab,valueString);
|
// });
|
//
|
// }
|
// } catch (Exception e) {
|
// log.error(e.getMessage());
|
// }
|
// }
|
//
|
// public void subHandle(String thoroughfare,String device,String tab,String valueString){
|
// try{
|
// //监听recordData
|
// if(tab.equals(Constants.RECORD_DATA)){
|
// //如果是1做进站处理
|
// if(valueString.equals(Constants.ONE)){
|
// Object sfcCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".sfcCode").getValue();
|
// if(ObjectUtil.isNotNull(sfcCodeObject)){
|
// miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(Constants.STRING_ONE_ONE).build());
|
// }else {
|
// miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(Constants.STRING_ONE_TWO).build());
|
// }
|
// //如果是2做出站处理处理
|
// }else if(valueString.equals(Constants.TWO)){
|
// String result = Constants.STRING_TWO_ONE;
|
// //读变速箱总成码
|
// Object sfcCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".sfcCode").getValue();
|
// //为空时，返回5
|
// if (ObjectUtil.isNull(sfcCodeObject)){
|
// miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(Constants.STRING_TWO_FIVE).build());
|
// }else {
|
// String snCode = sfcCodeObject.toString().trim();//产品SN
|
// Object stationStatusObjcet = miloService.readFromOpcUa(thoroughfare + "." + device + ".StationStatus").getValue();//站状态地址
|
// String stationStatus = stationStatusObjcet.toString();
|
// if (ObjectUtil.isNotNull(stationStatusObjcet)) {
|
// //保存参数，发送工厂MES
|
// result = saveParamCollection(device, snCode, stationStatus);
|
// //保存过站记录
|
// savePassingStation(device,snCode,stationStatus);
|
// }else {
|
// result = Constants.STRING_TWO_THREE;
|
// log.info("读取到工位{}StationStatus数据：{},返回RecordDataDone的值为{}", device, "IS NULL！", result);
|
// }
|
// }
|
// miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(result).build());
|
// }
|
// }
|
// }catch (Exception e) {
|
// log.error(e.getMessage());
|
// }
|
// }
|
//
|
// /**
|
// * 保存过站数据
|
// *
|
// * @param device 工位
|
// * @param snCode 产品序列号
|
// * @return Integer
|
// * @throws Exception e
|
// */
|
// private static Integer savePassingStation(String device, String snCode,String stationStatus){
|
// Integer result = 21;
|
// try {
|
//
|
//
|
// } catch (Exception e) {
|
// throw new RuntimeException(e);
|
// }
|
//
|
// return result;
|
// }
|
//
|
// /**
|
// * 保存参数数据和发送工厂MES
|
// * @param device 工位
|
// * @param snCode 产品SN
|
// * @param stationStatus 站状态
|
// * @return result
|
// * @throws Exception e
|
// */
|
// private static String saveParamCollection(String device,String snCode,String stationStatus){
|
// String result = Constants.STRING_TWO_ONE;//返回结果
|
// try {
|
// //查询参数配置表
|
// List<ScCollectionParamConf> list = collectionParamConfService.list(new LambdaQueryWrapper<ScCollectionParamConf>()
|
// .eq(ScCollectionParamConf::getLocationCode, device)//工位
|
// .eq(ScCollectionParamConf::getSubscribe, Constants.ONE)//是否采集
|
// );
|
// if (CollUtil.isNotEmpty(list)){
|
// List<String> collect = list.stream()
|
// .map(ScCollectionParamConf::getNode).collect(Collectors.toList());
|
// List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(collect);
|
// ArrayList<DaParamCollection> collectionList = new ArrayList<>();
|
// for (int i = 0; i < readWriteEntityList.size(); i++) {
|
// DaParamCollection daParamCollection = new DaParamCollection();
|
// daParamCollection.setSfcCode(snCode);
|
// daParamCollection.setLocationCode(device);
|
// daParamCollection.setParamCode(list.get(i).getParamCode());//参数编码
|
// daParamCollection.setParamName(list.get(i).getParamName());//参数名称
|
// daParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
|
// daParamCollection.setCollectTime(new Date());
|
// collectionList.add(daParamCollection);
|
// }
|
// paramCollectionService.saveBatch(collectionList);
|
// }
|
//
|
// }catch (Exception e) {
|
// throw new RuntimeException("保存数据发送工厂MES异常");
|
// }
|
// return result;
|
// }
|
//
|
//
|
//}
|
