Jcdm042-Mes.git

2024-03-07 a5b351156c343e707cf977b9e76ac2cfc9e64259

提交 \| 用户 \| 时间
a5b351	1	package com.jcdm.main.plcserver.sub;
C	2
	3
	4	import com.jcdm.main.da.collectionParamConf.domain.DaCollectionParamConf;
	5	import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService;
	6	import com.jcdm.main.da.paramCollection.domain.DaParamCollection;
	7	import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService;
	8	import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection;
	9	import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService;
	10	import com.jcdm.main.plcserver.conf.OPCElement;
	11	import com.kangaroohy.milo.model.ReadWriteEntity;
	12	import com.kangaroohy.milo.runner.subscription.SubscriptionCallback;
	13	import com.kangaroohy.milo.service.MiloService;
	14	import org.springframework.beans.factory.annotation.Autowired;
	15	import org.springframework.stereotype.Component;
	16
	17	import java.util.ArrayList;
	18	import java.util.Date;
	19	import java.util.List;
	20	import java.util.stream.Collectors;
	21
	22
	23	@Component
	24	public class OPCUaSubscription implements SubscriptionCallback {
	25
	26	public static MiloService miloService;
	27
	28	public IDaPassingStationCollectionService daPassingStationCollectionService;
	29
	30	public IDaCollectionParamConfService collectionParamConfService;
	31
	32	public IDaParamCollectionService daParamCollectionService;
	33
	34	public OPCUaSubscription(MiloService miloService,
	35	IDaPassingStationCollectionService daPassingStationCollectionService,
	36	IDaCollectionParamConfService collectionParamConfService,
	37	IDaParamCollectionService daParamCollectionService) {
	38	OPCUaSubscription.miloService = miloService;
	39	this.daPassingStationCollectionService = daPassingStationCollectionService;
	40	this.collectionParamConfService = collectionParamConfService;
	41	this.daParamCollectionService = daParamCollectionService;
	42
	43	}
	44
	45
	46	@Override
	47	public void onSubscribe(String identifier, Object value) {
	48
	49	try {
	50	if(null != value) {
	51	String[] nodes = identifier.split("[.]");
	52	String thoroughfare = nodes[0];//通道
	53	String device = nodes[1];//设备
	54	String tab = nodes[2];//标记
	55	String tabVlaue = value.toString();//地址值
	56
	57	//请求下发SN号
	58	if (("RecordSN").equals(tab) && "1".equals(tabVlaue)) {
	59	//获取SN号方法
	60	String SNCode = getSNCode();
	61
	62	//下发SN
	63	String SNCodeAddress = thoroughfare + "." + device + ".SNCode";
	64	miloService.writeToOpcChar(ReadWriteEntity.builder().identifier(SNCodeAddress).value(SNCode).build());
	65	//下发SN完成
	66	String recordSNDoneAddress = thoroughfare + "." + device + ".RecordSNDone";
	67	miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(recordSNDoneAddress).value(1).build());
	68	}
	69	//请求记录数据
	70	else if (("RecordData").equals(tab)) {
	71	String recordDataDoneValue = "";
	72
	73	if("1".equals(tabVlaue)){
	74	recordDataDoneValue = "11";
	75
	76	//进站保存数据
	77	//inSaveDate(thoroughfare,device)
	78	//记录数据完成
	79	String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone";
	80	miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(recordDataDoneValue).build());
	81	}else if("2".equals(tabVlaue)){
	82
	83	//出站保存数据
	84	recordDataDoneValue = outSaveDate(thoroughfare,device);
	85	//记录数据完成
	86	String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone";
	87	miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(recordDataDoneValue).build());
	88	}else{
	89	System.out.println("^");
	90	}
	91
	92
	93
	94
	95	}
	96	}
	97	} catch (Exception e) {
	98
	99	}
	100	}
	101
	102
	103
	104	/**
	105	* 获取SNCode
	106	*/
	107	public String getSNCode(){
	108	String SNCode = "";
	109	return SNCode;
	110	}
	111
	112
	113	/**
	114	* 出站保存数据
	115	*/
	116	public String outSaveDate(String thoroughfare,String device) {
	117	String result = "";
	118	try {
	119	//读取SNCode
	120	String SNCodeAddress = thoroughfare + "." + device + ".SNCode";
	121	Object SNCodeObject = miloService.readFromOpcUa(SNCodeAddress).getValue();
	122	if(null == SNCodeObject \|\| "".equals(SNCodeObject)){
	123	result = "22";
	124	}else{
	125	String SNCode = SNCodeObject.toString();
	126	//1、更新工单信息
	127	//updateOrderInfo();
	128	//2、保存过站采集数据
	129	saveStationInfo(SNCode,thoroughfare,device);
	130	//3、保存参数采集数据
	131	SaveParamData(SNCode,thoroughfare,device);
	132
	133	result = "21";
	134
	135	}
	136
	137	}catch (Exception e) {
	138
	139	}
	140	return result;
	141	}
	142
	143	/**
	144	* 保存过站采集
	145	*/
	146	public void saveStationInfo(String SNCode,String thoroughfare,String device){
	147	DaPassingStationCollection daPassingStationCollection = new DaPassingStationCollection();
	148	daPassingStationCollection.setSfcCode(SNCode);
	149	//daPassingStationCollection.setInboundTime();//入站时间
	150	daPassingStationCollection.setOutboundTime(new Date());//出站时间
	151	//daPassingStationCollection.setOutRsSign();//出站是否合格
	152	daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection);
	153	}
	154
	155	public void SaveParamData(String SNCode,String thoroughfare,String device) throws Exception {
	156	List<DaCollectionParamConf> list;
	157	DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf();
	158	daCollectionParamConf.setGatherAddress(thoroughfare+ "." + device);
	159	list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf);
	160
	161	List<String> nodeIdList = list.stream().map(info -> {
	162	String nodeid = info.getGatherAddress();
	163	return nodeid;
	164	}).collect(Collectors.toList());
	165
	166	if(!nodeIdList.isEmpty()){
	167	List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(nodeIdList);
	168	List<DaParamCollection> daParamCollectionlist = new ArrayList<>();
	169	for(int i=0;i<nodeIdList.size();i++){
	170	DaParamCollection ParamCollection = new DaParamCollection();
	171	if(!readWriteEntityList.get(i).getValue().toString().equals("0.0")){
	172	ParamCollection.setParamCode(readWriteEntityList.get(i).getIdentifier().toString().split("[.]")[2]);
	173	ParamCollection.setLocationCode(device);
	174	ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
	175	ParamCollection.setSfcCode(SNCode);
	176	ParamCollection.setParamName(list.get(i).getCollectParameterName());
	177	ParamCollection.setParamUpper(list.get(i).getParamUpper());
	178	ParamCollection.setParamLower(list.get(i).getParamLower());
	179	ParamCollection.setUnit(list.get(i).getCollectParameterUnit());
	180	//ParamCollection.setState("合格");
	181	ParamCollection.setType(list.get(i).getCollectParameterType());
	182	ParamCollection.setCollectionTime(new Date());
	183	daParamCollectionlist.add(ParamCollection);
	184	}
	185	}
	186	//daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist);
	187	}
	188
	189	}
	190	}