package com.jcdm.main.plcserver.sub;
|
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.jcdm.main.bs.domain.BsTechnologyRouteChildInfo;
|
import com.jcdm.main.bs.orderScheduling.domain.BsOrderScheduling;
|
import com.jcdm.main.bs.orderScheduling.service.IBsOrderSchedulingService;
|
import com.jcdm.main.bs.technologyRouteChild.service.IBsTechnologyRouteChildInfoService;
|
import com.jcdm.main.da.collectionParamConf.domain.DaCollectionParamConf;
|
import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService;
|
import com.jcdm.main.da.opcuaconfig.domain.DaOpcuaConfig;
|
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.impl.DaPassingStationCollectionServiceImpl;
|
import com.jcdm.main.plcserver.conf.OPCElement;
|
import com.jcdm.main.rm.repairRecord.domain.RmRepairRecord;
|
import com.jcdm.main.rm.repairRecord.service.IRmRepairRecordService;
|
import com.kangaroohy.milo.model.ReadWriteEntity;
|
import com.kangaroohy.milo.runner.subscription.SubscriptionCallback;
|
import com.kangaroohy.milo.service.MiloService;
|
import javafx.animation.Timeline;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import java.math.BigDecimal;
|
import java.sql.Time;
|
import java.time.LocalDateTime;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
|
@Slf4j
|
@Component
|
public class OPCUaSubscription implements SubscriptionCallback {
|
|
public static MiloService miloService;
|
|
public IDaCollectionParamConfService collectionParamConfService;
|
|
public IDaParamCollectionService daParamCollectionService;
|
|
public DaPassingStationCollectionServiceImpl passingStationCollectionServiceImpl;
|
|
public List<DaOpcuaConfig> lists;
|
|
public static final HashMap<String,Integer> map = new HashMap<>();
|
|
public IBsOrderSchedulingService bsOrderSchedulingService;
|
|
public IRmRepairRecordService rmRepairRecordService;
|
|
public IBsTechnologyRouteChildInfoService bsTechnologyRouteChildInfoService;
|
|
public HashMap<String,List<DaCollectionParamConf>> allCollectParamList = new HashMap<>();
|
|
public OPCUaSubscription(MiloService miloService,
|
IDaCollectionParamConfService collectionParamConfService,
|
IDaParamCollectionService daParamCollectionService,
|
DaPassingStationCollectionServiceImpl passingStationCollectionServiceImpl,
|
IBsOrderSchedulingService bsOrderSchedulingService,
|
List<DaOpcuaConfig> lists,
|
IRmRepairRecordService rmRepairRecordService,
|
IBsTechnologyRouteChildInfoService bsTechnologyRouteChildInfoService) {
|
OPCUaSubscription.miloService = miloService;
|
this.collectionParamConfService = collectionParamConfService;
|
this.daParamCollectionService = daParamCollectionService;
|
this.passingStationCollectionServiceImpl = passingStationCollectionServiceImpl;
|
this.bsOrderSchedulingService = bsOrderSchedulingService;
|
this.lists = lists;
|
this.rmRepairRecordService = rmRepairRecordService;
|
this.bsTechnologyRouteChildInfoService = bsTechnologyRouteChildInfoService;
|
|
|
}
|
@Override
|
public void onSubscribe(String identifier, Object value) {
|
String ecpStr = "";//异常记录标记
|
try {
|
if(null != value && "1".equals(value.toString())) {
|
// if (OPCElement.OP121_ZZ_CODE_CHECK.equals(identifier)){
|
// rework("2V91Y RD25D080",identifier);
|
// }
|
//1、检索SN号
|
//2、过站参数采集
|
//3、扫码枪数据回传
|
List<String> collect1 = lists.stream().filter(x -> OPCElement.SN_CHECK.equals(x.getrFunction()))
|
.map(DaOpcuaConfig::getNode).collect(Collectors.toList());
|
List<String> collect2 = lists.stream().filter(x -> OPCElement.SAVE_DATA.equals(x.getrFunction()))
|
.map(DaOpcuaConfig::getNode).collect(Collectors.toList());
|
if (collect1.contains(identifier)){
|
log.info("-------监听到,{}的CODE_CHECK的信号",identifier);
|
log.info("-------time--------------,{}",LocalDateTime.now());
|
//sn
|
this.SNRetrieval(identifier,value.toString());
|
if (identifier.equals(OPCElement.OP120_ZZ_CODE_CHECK) && "1".equals(value.toString())){
|
//总装上线扫码传输数据
|
log.info("-------监听到,{}的扫码枪扫码的CODE_CHECK的信号",identifier);
|
scannerGunMessage();
|
}
|
}
|
if (collect2.contains(identifier)){
|
if ("1".equals(value.toString())){
|
log.info("-------监听到,{}的SAVE_REQUEST_LAST的信号",identifier);
|
log.info("-------time--------------,{}",LocalDateTime.now());
|
//save
|
this.SaveData(identifier);
|
|
}
|
}
|
|
}
|
} catch (Exception e) {
|
System.out.println(e.getMessage());
|
} finally {
|
if (!"".equals(ecpStr)) {
|
System.out.println(ecpStr + "\r\n");
|
}
|
}
|
}
|
|
private void scannerGunMessage() throws Exception {
|
String[] parts = OPCElement.OP120_ZZ_CODE_CHECK.split("[.]");
|
Object SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Code1").getValue();
|
if (null == SNCodeObject){
|
SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Code").getValue();
|
}
|
if (null != SNCodeObject){
|
String SNCode = SNCodeObject.toString();
|
passingStationCollectionServiceImpl.sendMessage(SNCode);
|
}
|
}
|
|
public void SNRetrieval(String Node, String value) throws Exception {
|
String[] parts = Node.split("[.]");
|
if(value.equals("1")) {
|
//SN号检索
|
Object SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Code").getValue();
|
if(null != SNCodeObject) {
|
String SNCode=SNCodeObject.toString();
|
String a=passingStationCollectionServiceImpl.SelectSN(SNCode,parts[1]);
|
log.info("-----返回codeCheckFeed-----,{}",a);
|
// String a="1";
|
// 1:OK可生产 2:NG不可生产 3:NG可返工 4:PC检索失败（无记录）5:PC检索失败（软件）
|
if (StrUtil.isNotBlank(a)){
|
int input = Integer.parseInt(a);
|
ReadWriteEntity entity = new ReadWriteEntity(parts[0]+"."+parts[1]+".CodeCheckFeed", input);
|
log.info("-------监听到,{}的CodeCheck的信号",Node);
|
//首站传输订单号
|
if (OPCElement.OP050_HX_CODE_CHECK.equals(Node)){
|
//查询订单号
|
BsOrderScheduling bsOrderScheduling = new BsOrderScheduling();
|
bsOrderScheduling.setEngineNo(SNCode);
|
List<BsOrderScheduling> tempList = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling);
|
String orderNum = "";
|
if (CollUtil.isNotEmpty(tempList)){
|
BsOrderScheduling bsOrderScheduling1 = tempList.get(0);
|
orderNum = bsOrderScheduling1.getOrderNo();
|
}
|
|
ReadWriteEntity entity2 = new ReadWriteEntity(parts[0]+"."+parts[1]+".OrderNumber", orderNum);
|
miloService.writeToOpcUa(entity2);
|
}
|
//如果是返修工位需要传输返修工位号
|
if (OPCElement.OP465_ZZ_CODE_CHECK.equals(Node) || OPCElement.OP355_ZZ_CODE_CHECK.equals(Node)
|
|| OPCElement.OP695_ZZ_CODE_CHECK.equals(Node) || OPCElement.OP755_ZZ_CODE_CHECK.equals(Node)){
|
rework(SNCode,Node);
|
}
|
System.out.println(entity);
|
miloService.writeToOpcByte(entity);
|
}
|
|
}
|
}
|
}
|
|
private void rework(String SNCode,String Node) throws Exception{
|
BsOrderScheduling bsOrderScheduling = new BsOrderScheduling();
|
bsOrderScheduling.setEngineNo(SNCode);
|
List<String> allProcessCoed = new ArrayList<>();
|
List<String> collect = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling).stream().map(BsOrderScheduling::getModel).collect(Collectors.toList());
|
if (CollUtil.isNotEmpty(collect)){
|
String s = collect.get(0);
|
//查找次机型的完整工序
|
List<BsTechnologyRouteChildInfo> bsTechnologyRouteChildInfos = bsTechnologyRouteChildInfoService.selectAllTechnologyRouteByProductCode(s);
|
if (CollUtil.isNotEmpty(bsTechnologyRouteChildInfos)){
|
allProcessCoed = bsTechnologyRouteChildInfos.stream().map(BsTechnologyRouteChildInfo::getProcessesCode).collect(Collectors.toList());
|
}
|
}
|
RmRepairRecord rmRepairRecord = new RmRepairRecord();
|
rmRepairRecord.setBoxCode(SNCode);
|
List<ReadWriteEntity> writeList = new ArrayList<>();
|
List<RmRepairRecord> rmRepairRecords = rmRepairRecordService.selectRmRepairRecordList(rmRepairRecord);
|
//过站记录
|
DaPassingStationCollection PassingStationCollection=new DaPassingStationCollection();
|
PassingStationCollection.setSfcCode(SNCode);
|
//过站记录
|
List<DaPassingStationCollection> daPassingStationCollections = passingStationCollectionServiceImpl.selectDaPassingStationCollectionList(PassingStationCollection);
|
|
//所有反工工位
|
List<String> collect1 = rmRepairRecords.stream().map(RmRepairRecord::getProcessesCode).collect(Collectors.toList());
|
//查询出所有需要返修工位的最小op块
|
Integer minOP = 0;
|
if (CollUtil.isNotEmpty(collect1)){
|
|
List<Integer> sortList = new ArrayList<>();
|
collect1.stream().forEach(x ->{
|
String op = x.replace("OP", "");
|
if (StrUtil.isNotBlank(op)){
|
int i = Integer.parseInt(op);
|
sortList.add(i);
|
}
|
});
|
if (CollUtil.isNotEmpty(sortList)){
|
List<Integer> collect2 = sortList.stream().sorted().collect(Collectors.toList());
|
minOP = collect2.get(0);
|
}
|
}
|
|
//所有放行工位
|
//过站记录除去返修记录就是传2，返修数据及后面占位数据传1
|
List<String> collect3 = daPassingStationCollections.stream().map(DaPassingStationCollection::getLocationCode).collect(Collectors.toList());
|
if (CollUtil.isNotEmpty(collect1)){
|
collect3 = collect3.stream().filter(x -> !collect1.contains(x)).collect(Collectors.toList());
|
}
|
if (CollUtil.isNotEmpty(collect3)){
|
collect3.forEach(x -> {
|
ReadWriteEntity readWriteEntity = new ReadWriteEntity();
|
readWriteEntity.setIdentifier(x);
|
readWriteEntity.setValue(2);
|
writeList.add(readWriteEntity);
|
});
|
}
|
//需生产工位
|
List<String> collect4 = allProcessCoed;
|
if (CollUtil.isNotEmpty(collect3)){
|
List<String> finalCollect = collect3;
|
collect4 = allProcessCoed.stream().filter(x -> !finalCollect.contains(x)).collect(Collectors.toList());
|
}
|
if (CollUtil.isNotEmpty(collect4)){
|
//数据库查询出的工位
|
collect4.forEach(x -> {
|
ReadWriteEntity readWriteEntity = new ReadWriteEntity();
|
readWriteEntity.setIdentifier(x);
|
readWriteEntity.setValue(1);
|
writeList.add(readWriteEntity);
|
});
|
}
|
// List<String> collect2 = allProcessCoed;
|
// if (CollUtil.isNotEmpty(rmRepairRecords)){
|
// //数据库查询出的工位
|
// rmRepairRecords.forEach(x -> {
|
// ReadWriteEntity readWriteEntity = new ReadWriteEntity();
|
// readWriteEntity.setIdentifier(x.getProcessesCode());
|
// readWriteEntity.setValue(1);
|
// writeList.add(readWriteEntity);
|
// });
|
// collect2 = allProcessCoed.stream().filter(x -> !collect1.contains(x)).collect(Collectors.toList());
|
// }
|
// if (CollUtil.isNotEmpty(collect2)){
|
// collect2.forEach(x -> {
|
// ReadWriteEntity readWriteEntity = new ReadWriteEntity();
|
// readWriteEntity.setIdentifier(x);
|
// readWriteEntity.setValue(2);
|
// writeList.add(readWriteEntity);
|
// });
|
// }
|
String[] parts = Node.split("[.]");
|
String a=passingStationCollectionServiceImpl.SelectSN(SNCode,parts[1]);
|
if (StrUtil.isNotBlank(a)){
|
int input = Integer.parseInt(a);
|
ReadWriteEntity entity = new ReadWriteEntity(parts[0]+"."+parts[1]+".CodeCheckFeed", input);
|
writeList.add(entity);
|
}
|
ReadWriteEntity readWriteEntity = new ReadWriteEntity();
|
readWriteEntity.setIdentifier("Repair_sign");
|
readWriteEntity.setValue(minOP);
|
writeList.add(readWriteEntity);
|
if (CollUtil.isNotEmpty(writeList)){
|
List<ReadWriteEntity> tempList = new ArrayList<>();
|
for (int i = 0; i < writeList.size(); i++) {
|
tempList.add(writeList.get(i));
|
if (tempList.size()>10){
|
miloService.writeToOpcByte(tempList);
|
log.info("写入返修：,{}",tempList);
|
tempList = new ArrayList<>();
|
}
|
}
|
if (CollUtil.isNotEmpty(tempList)){
|
miloService.writeToOpcByte(tempList);
|
log.info("写入返修：,{}",tempList);
|
}
|
|
|
}
|
miloService.writeToOpcByte(writeList);
|
}
|
|
|
public void SaveData(String Node) throws Exception {
|
|
String[] parts = Node.split("[.]");
|
Object SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Code1").getValue();
|
if (null == SNCodeObject){
|
SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Code").getValue();
|
}
|
if(null != SNCodeObject)
|
{
|
String SNCode = SNCodeObject.toString();
|
Object object = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Runtime").getValue();
|
String gatherAddress = parts[0] + "." + parts[1];
|
List<DaCollectionParamConf> list = new ArrayList<>();
|
if (allCollectParamList.containsKey(gatherAddress)){
|
list = allCollectParamList.get(gatherAddress);
|
}else {
|
DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf();
|
daCollectionParamConf.setGatherAddress(gatherAddress);
|
daCollectionParamConf.setRemarks("1");
|
list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf);
|
if (CollUtil.isNotEmpty(list)){
|
//加入hashmap
|
allCollectParamList.put(gatherAddress,list);
|
}
|
}
|
|
List<String> nodeIdList = list.stream().map(info -> {
|
String nodeid = info.getGatherAddress();
|
return nodeid;
|
}).collect(Collectors.toList());
|
|
List<ReadWriteEntity> readWriteEntityList = new ArrayList<>();
|
if(CollUtil.isNotEmpty(nodeIdList)){
|
long time1 = new Date().getTime();
|
readWriteEntityList = miloService.readFromOpcUa(nodeIdList);
|
long time2 = new Date().getTime();
|
log.info("读取点位花费时间：{},",time2-time1);
|
}
|
//返回plc保存成功
|
if (parts.length==3){
|
if ("SaveRequest".equals(parts[2])){
|
ReadWriteEntity entity = new ReadWriteEntity(parts[0] + "." + parts[1] + ".SaveFeed", 1);
|
miloService.writeToOpcByte(entity);
|
}else if ("SaveRequestLast".equals(parts[2])){
|
ReadWriteEntity entity = new ReadWriteEntity(parts[0] + "." + parts[1] + ".SaveFeedLast", 1);
|
miloService.writeToOpcByte(entity);
|
}
|
log.info("-------请求返回,{}的SaveFeedLast的信号",Node);
|
log.info("-------请求返回-----,{}",LocalDateTime.now());
|
}
|
List<DaParamCollection> daParamCollectionlist = new ArrayList<>();
|
if (CollUtil.isNotEmpty(nodeIdList)){
|
for(int i=0;i<nodeIdList.size();i++){
|
if(!readWriteEntityList.get(i).getValue().toString().equals("0.0")){
|
DaParamCollection ParamCollection = new DaParamCollection();
|
ParamCollection.setParamCode(readWriteEntityList.get(i).getIdentifier().toString().split("[.]")[2]);
|
ParamCollection.setLocationCode(parts[1]);
|
if (readWriteEntityList.get(i) == null){
|
ParamCollection.setParamValue("0");
|
}else {
|
ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
|
}
|
ParamCollection.setSfcCode(SNCode);
|
ParamCollection.setParamName(list.get(i).getCollectParameterName());
|
ParamCollection.setParamUpper(list.get(i).getParamUpper());
|
ParamCollection.setParamLower(list.get(i).getParamLower());
|
ParamCollection.setUnit(list.get(i).getCollectParameterUnit());
|
ParamCollection.setState("合格");
|
ParamCollection.setType(list.get(i).getCollectParameterType());
|
ParamCollection.setCollectionTime(new Date());
|
daParamCollectionlist.add(ParamCollection);
|
}
|
}
|
daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist);
|
log.info("-------保存数据完成---------");
|
}
|
|
|
|
|
Long beatTime = 0L;
|
if (ObjectUtil.isNotEmpty(object)){
|
String str = object.toString();
|
beatTime = Float.valueOf(str).longValue();
|
}
|
DaPassingStationCollection PassingStationCollection=new DaPassingStationCollection();
|
PassingStationCollection.setSfcCode(SNCode);
|
PassingStationCollection.setLocationCode(parts[1]);
|
PassingStationCollection.setOutboundTime(new Date());
|
PassingStationCollection.setInboundTime(new Date(new Date().getTime()-beatTime*1000));
|
PassingStationCollection.setCollectionTime(new Date());
|
PassingStationCollection.setCreateTime(new Date());
|
PassingStationCollection.setBeatTime(beatTime.toString());
|
PassingStationCollection.setOutRsSign("合格");
|
passingStationCollectionServiceImpl.insertDaPassingStationCollection(PassingStationCollection);
|
log.info("-------保存过站记录数据完成---------");
|
|
}
|
}
|
}
|
