Jcdm042-Mes.git

懒羊羊

2024-03-15 49c784e6ac7d71c5eaf7352e0a215842b4ca5456

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