//package com.billion.main.plc.sub;
|
//
|
//
|
//import cn.hutool.core.collection.CollUtil;
|
//import cn.hutool.core.util.ObjectUtil;
|
//import cn.hutool.http.HttpRequest;
|
//import cn.hutool.http.HttpResponse;
|
//import cn.hutool.json.JSONUtil;
|
//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
//import com.billion.main.api.domain.StationST180;
|
//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 com.alibaba.fastjson.JSONObject;
|
//
|
//import java.text.ParseException;
|
//import java.text.SimpleDateFormat;
|
//import java.util.*;
|
//import java.util.concurrent.CompletableFuture;
|
//import java.util.stream.Collectors;
|
//import java.lang.reflect.Field;
|
//
|
//
|
//@Slf4j
|
//@Component
|
//public class OPCUaSubscription implements SubscriptionCallback {
|
//
|
// public static MiloService miloService;
|
// public static IScCollectionParamConfService collectionParamConfService;
|
// public static IDaParamCollectionService paramCollectionService;
|
// public static IDaStationCollectionService stationCollectionService;
|
//
|
// public OPCUaSubscription(MiloService miloService, IScCollectionParamConfService collectionParamConfService
|
// ,IDaParamCollectionService paramCollectionService,IDaStationCollectionService stationCollectionService) {
|
// OPCUaSubscription.miloService = miloService;
|
// OPCUaSubscription.collectionParamConfService = collectionParamConfService;
|
// OPCUaSubscription.paramCollectionService = paramCollectionService;
|
// OPCUaSubscription.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)){
|
// //如果是2做出站处理
|
// if(valueString.equals(Constants.TWO)){
|
// Integer result = Constants.INTEGER_TWO_ONE;
|
// result = saveParamCollection(device, "snCode", "stationStatus");
|
// miloService.writeToOpcShort(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 Integer saveParamCollection(String device, String snCode, String stationStatus) {
|
// Integer result = Constants.INTEGER_TWO_ONE;
|
// try {
|
// // 查询参数配置表
|
// List<ScCollectionParamConf> list = collectionParamConfService.list(new LambdaQueryWrapper<ScCollectionParamConf>()
|
// .eq(ScCollectionParamConf::getLocationCode, device)
|
// .eq(ScCollectionParamConf::getSubscribe, Constants.ONE)
|
// .orderByDesc(ScCollectionParamConf::getOrderNum)
|
// );
|
//
|
// if (CollUtil.isNotEmpty(list)) {
|
// // 获取参数值
|
// List<String> collect = list.stream()
|
// .map(ScCollectionParamConf::getNode)
|
// .collect(Collectors.toList());
|
// List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(collect);
|
//
|
// // 保存采集数据
|
// saveCollectionData(device, snCode, list, readWriteEntityList);
|
//
|
// // 创建工位对象并赋值
|
// Object stationObject = createStationObject(device, list, readWriteEntityList);
|
// if (stationObject != null) {
|
// System.out.println("工位" + device + "对象创建成功：" + stationObject);
|
// // 这里可以对创建的对象进行进一步处理
|
//
|
// }
|
// }
|
//
|
// } catch (Exception e) {
|
// log.error("保存数据异常", e);
|
// throw new RuntimeException("保存数据发送工厂MES异常");
|
// }
|
// return result;
|
// }
|
//
|
// /**
|
// * 保存采集数据
|
// */
|
// private static void saveCollectionData(String device, String snCode,
|
// List<ScCollectionParamConf> list, List<ReadWriteEntity> readWriteEntityList) {
|
// 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.insertBatch(collectionList);
|
// }
|
//
|
// /**
|
// * 创建工位对象并赋值
|
// */
|
// private static Object createStationObject(String device,
|
// List<ScCollectionParamConf> list, List<ReadWriteEntity> readWriteEntityList) {
|
// try {
|
// // 构建完整的类名
|
// String className = "com.billion.main.api.domain.Station" + device;
|
// Class<?> stationClass = Class.forName(className);
|
// Object stationObject = stationClass.newInstance();
|
//
|
// // 获取所有属性
|
// Field[] fields = stationClass.getDeclaredFields();
|
//
|
// // 创建参数值Map，方便查找
|
// Map<String, String> paramValueMap = new HashMap<>();
|
// for (int i = 0; i < list.size(); i++) {
|
// paramValueMap.put(list.get(i).getParamCode(),
|
// readWriteEntityList.get(i).getValue().toString());
|
// }
|
//
|
// // 按顺序给属性赋值
|
// for (Field field : fields) {
|
// field.setAccessible(true);
|
// String paramCode = field.getName(); // 假设属性名与参数编码一致
|
// String value = paramValueMap.get(paramCode);
|
//
|
// if (value != null) {
|
// // 根据字段类型转换值
|
// Object convertedValue = convertValue(value, field.getType());
|
// field.set(stationObject, convertedValue);
|
// }
|
// }
|
//
|
// return stationObject;
|
// } catch (Exception e) {
|
// log.error("创建工位对象失败：" + device, e);
|
// return null;
|
// }
|
// }
|
//
|
// /**
|
// * 根据字段类型转换值
|
// */
|
// private static Object convertValue(String value, Class<?> type) {
|
// if (type == String.class) {
|
// return value;
|
// } else if (type == Integer.class || type == int.class) {
|
// return Integer.parseInt(value);
|
// } else if (type == Double.class || type == double.class) {
|
// return Double.parseDouble(value);
|
// } else if (type == Float.class || type == float.class) {
|
// return Float.parseFloat(value);
|
// } else if (type == Long.class || type == long.class) {
|
// return Long.parseLong(value);
|
// } else if (type == Boolean.class || type == boolean.class) {
|
// return Boolean.parseBoolean(value);
|
// } else if (type == Date.class) {
|
// try {
|
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
// return sdf.parse(value);
|
// } catch (ParseException e) {
|
// return null;
|
// }
|
// }
|
// return value;
|
// }
|
//
|
//}
|
