From b169b0c298fb294adbc5bd332982908afca4e819 Mon Sep 17 00:00:00 2001 From: admin <15939171744@163.com> Date: 星期二, 16 四月 2024 10:09:56 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 50 insertions(+), 2 deletions(-) diff --git a/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java b/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java index 3ab7f5a..c4d4395 100644 --- a/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java +++ b/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java @@ -1,10 +1,15 @@ package com.jcdm.main.da.paramCollection.service.impl; import cn.hutool.core.date.DateUtil; +import cn.hutool.db.Db; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.jcdm.common.utils.DateUtils; +import com.jcdm.main.bs.formula.service.IBsFormulaInfoService; +import com.jcdm.main.bs.formula.service.impl.BsFormulaInfoServiceImpl; import com.jcdm.main.bs.formulaChild.domain.BsFormulaChildInfo; import com.jcdm.main.bs.formulaChild.mapper.BsFormulaChildInfoMapper; +import com.jcdm.main.bs.formulaChild.service.IBsFormulaChildInfoService; import com.jcdm.main.da.collectionParamConf.domain.DaCollectionParamConf; import com.jcdm.main.da.collectionParamConf.mapper.DaCollectionParamConfMapper; import com.jcdm.main.da.paramCollection.domain.DaParamCollection; @@ -44,6 +49,9 @@ private BsFormulaChildInfoMapper bsFormulaChildInfoMapper; @Autowired + private IBsFormulaChildInfoService bsFormulaChildInfoService; + + @Autowired private MiloService miloService; @Autowired @@ -51,6 +59,9 @@ @Resource private SqlSessionFactory sqlSessionFactory; + + @Autowired + private IDaParamCollectionService daParamCollectionService; /** * 鏌ヨ璁惧浜у搧杩囩▼鍙傛暟閲囬泦 @@ -195,6 +206,18 @@ @Override public void saveCampaignTimeParameters(DaParamCollection daParamCollection) { + List<BsFormulaChildInfo> list = bsFormulaChildInfoService.list(new LambdaQueryWrapper<BsFormulaChildInfo>() + .eq(BsFormulaChildInfo::getProcessesCode, daParamCollection.getLocationCode()) + .eq(BsFormulaChildInfo::getSpareField4, "1") + ); + if(!list.get(0).getResults().equals("OK")){ + try { + miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+daParamCollection.getLocationCode()+".RecordDataDone").value(22).build()); + } catch (Exception e) { + throw new RuntimeException(e); + } + return; + } BsFormulaChildInfo bsFormulaChildInfo = new BsFormulaChildInfo(); bsFormulaChildInfo.setProcessesCode(daParamCollection.getLocationCode()); bsFormulaChildInfo.setProductCode(daParamCollection.getProductCode()); @@ -227,13 +250,38 @@ daPassingStationCollections.get(0).setOutboundTime(new Date()); int i = daPassingStationCollectionMapper.updateDaPassingStationCollection(daPassingStationCollections.get(0)); - OPCUaSubscription.SaveParamData(daParamCollection.getProductBarcode(),"OP",daParamCollection.getLocationCode(),daParamCollection.getWorkOrderNo(),daParamCollection.getProductCode()); +// OPCUaSubscription.SaveParamData(daParamCollection.getProductBarcode(),"OP",daParamCollection.getLocationCode(),daParamCollection.getWorkOrderNo(),daParamCollection.getProductCode()); //缁檕pc鍙�21 - miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("OP."+daParamCollection.getLocationCode()+".RecordDataDone").value(21).build()); + miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+daParamCollection.getLocationCode()+".RecordDataDone").value(21).build()); } catch (Exception e) { throw new RuntimeException(e); } } } + + @Override + public void insertBatch(List<DaParamCollection> confList){ + try{ + this.saveBatch(confList); + }catch (Exception e){ + return; + } + + } + + @Override + public void replaceAssemblyCode(DaParamCollection daParamCollection) { + List<DaParamCollection> list = daParamCollectionService.list(new LambdaQueryWrapper<DaParamCollection>() + .eq(DaParamCollection::getSfcCode, daParamCollection.getSfcCode()) + .eq(DaParamCollection::getLocationCode, daParamCollection.getLocationCode()) + ); + if(list.size() > 0){ + for (DaParamCollection paramCollection : list) { + paramCollection.setSfcCode(daParamCollection.getYzSfcCode()); + daParamCollectionService.saveOrUpdate(paramCollection); + } + } + + } } -- Gitblit v1.9.3