| | |
| | | |
| | | |
| | | import cn.hutool.core.collection.CollUtil; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import cn.hutool.core.util.ObjectUtil; |
| | | import cn.hutool.core.util.StrUtil; |
| | | import cn.hutool.json.JSONObject; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.jcdm.common.utils.StringUtils; |
| | | import com.jcdm.framework.websocket.WebSocketUsers; |
| | | import com.jcdm.main.constant.Constants; |
| | | import com.jcdm.main.da.collectionParamConf.domain.DaCollectionParamConf; |
| | |
| | | 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.query.ProductOrderChild; |
| | | import com.jcdm.main.da.passingStationCollection.query.ProductOrderQuery; |
| | | import com.jcdm.main.da.passingStationCollection.query.ProductOrderVO; |
| | | import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService; |
| | | import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo; |
| | | import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService; |
| | | import com.jcdm.main.plcserver.conf.OPCElement; |
| | | import com.jcdm.main.plcserver.util.TimeUtil; |
| | | import com.jcdm.main.restful.factoryMes.service.RestfulService; |
| | | import com.jcdm.main.work.domain.KeyCodeRelation; |
| | | import com.jcdm.main.work.domain.WorkOrder; |
| | | import com.jcdm.main.work.service.KeyCodeCheckService; |
| | | import com.jcdm.main.work.service.KeyCodeRelationService; |
| | | import com.jcdm.main.work.service.WorkOrderService; |
| | | import com.kangaroohy.milo.model.ReadWriteEntity; |
| | | import com.kangaroohy.milo.runner.subscription.SubscriptionCallback; |
| | | import com.kangaroohy.milo.service.MiloService; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.websocket.Session; |
| | |
| | | import java.util.stream.Collectors; |
| | | |
| | | |
| | | @Slf4j |
| | | @Component |
| | | public class OPCUaSubscription implements SubscriptionCallback { |
| | | |
| | |
| | | public static IDaParamCollectionService daParamCollectionService; |
| | | |
| | | public static IOmProductionOrdeInfoService omProductionOrdeInfoService; |
| | | public static WorkOrderService workOrderService; |
| | | public static KeyCodeCheckService keyCodeCheckService; |
| | | public static KeyCodeRelationService keyCodeRelationService; |
| | | |
| | | public OPCUaSubscription(MiloService miloService, |
| | | IDaPassingStationCollectionService daPassingStationCollectionService, |
| | | IDaCollectionParamConfService collectionParamConfService, |
| | | IDaParamCollectionService daParamCollectionService, |
| | | IOmProductionOrdeInfoService omProductionOrdeInfoService) { |
| | | IOmProductionOrdeInfoService omProductionOrdeInfoService, |
| | | WorkOrderService workOrderService, |
| | | KeyCodeCheckService keyCodeCheckService, |
| | | KeyCodeRelationService keyCodeRelationService) { |
| | | OPCUaSubscription.miloService = miloService; |
| | | this.daPassingStationCollectionService = daPassingStationCollectionService; |
| | | OPCUaSubscription.collectionParamConfService = collectionParamConfService; |
| | | OPCUaSubscription.daParamCollectionService = daParamCollectionService; |
| | | OPCUaSubscription.omProductionOrdeInfoService = omProductionOrdeInfoService; |
| | | OPCUaSubscription.workOrderService = workOrderService; |
| | | OPCUaSubscription.keyCodeCheckService = keyCodeCheckService; |
| | | OPCUaSubscription.keyCodeRelationService = keyCodeRelationService; |
| | | |
| | | } |
| | | |
| | | |
| | |
| | | public void onSubscribe(String identifier, Object value) { |
| | | |
| | | try { |
| | | if(null != value && Integer.valueOf(value.toString())!= 0) { |
| | | 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 tabVlaue = value.toString();//地址值 |
| | | |
| | | if (("RecordData").equals(tab)) { |
| | | String recordDataDoneValue = ""; |
| | | |
| | | if("1".equals(tabVlaue)){ |
| | | |
| | | //请求工单 |
| | | // if(device.equals("OP230")){ |
| | | // getFactoryOrder("OP230"); |
| | | // } |
| | | |
| | | //自动工位 |
| | | if(automaticList.stream().anyMatch(s -> s.equals(device))){ |
| | | //plc给我们一个模组码,拿模组码校验出型号 |
| | | if(moduleCodeList.stream().anyMatch(s -> s.equals(device))) { |
| | | String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; |
| | | //读模组码 |
| | | Object moduleCode = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCode").getValue(); |
| | | |
| | | if(moduleCode!=null){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(11).build()); |
| | | }else { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(12).build()); |
| | | } |
| | | }else { |
| | | if(agvId.stream().anyMatch(s -> s.equals(device))){ |
| | | Object agvIdObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".AGVID").getValue(); |
| | | //agvId 小车码是否为空 |
| | | if(agvIdObject!=null){ |
| | | String PACKCode = thoroughfare + "." + device + ".MPACKCode"; |
| | | OmProductionOrdeInfo one = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getTrolleyYard, agvIdObject.toString())); |
| | | //小车码查找工单是否为空 |
| | | if(one!=null){ |
| | | String packId = one.getProductNum(); |
| | | miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(PACKCode).value(packId).build()); |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(11).build()); |
| | | }else { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(12).build()); |
| | | } |
| | | }else { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(12).build()); |
| | | } |
| | | |
| | | }else { |
| | | String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; |
| | | Object packCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".PACKCode").getValue(); |
| | | if(packCodeObject!=null){ |
| | | //pack 如果区分型号的话就要处理 |
| | | //记录数据完成 |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(11).build()); |
| | | }else { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(12).build()); |
| | | } |
| | | |
| | | } |
| | | } |
| | | }else { |
| | | //手动工位处理逻辑 |
| | | WebSocketUsers.sendMessageToUserByText(map.get(device), "IN"); |
| | | String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; |
| | | |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(11).build()); |
| | | } |
| | | |
| | | |
| | | }else if("2".equals(tabVlaue)){ |
| | | if(automaticList.stream().anyMatch(s -> s.equals(device))){ |
| | | //自动工位 |
| | | //出站保存数据 |
| | | recordDataDoneValue = outSaveDate(thoroughfare,device); |
| | | //记录数据完成 |
| | | String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf(recordDataDoneValue)).build()); |
| | | }else { |
| | | //手动工位 |
| | | if(device.contains("OP330")){ |
| | | String str = device.substring(0,5); |
| | | WebSocketUsers.sendMessageToUserByText(map.get(str), "END"); |
| | | }else { |
| | | WebSocketUsers.sendMessageToUserByText(map.get(device), "END"); |
| | | } |
| | | if(testList.stream().anyMatch(s -> s.equals(device))){ |
| | | String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(21).build()); |
| | | String valueString = value.toString();//地址值 |
| | | if (Constants.RECORD_CHECK_CODE.equals(tab)){ |
| | | if (Constants.ONE.equals(valueString)){ |
| | | Integer scanResult = 11; |
| | | if (Constants.OP010.equals(device) || Constants.OP030.equals(device)){ |
| | | //OP010工位电芯条码校验||OP030工位电芯条码校验 |
| | | Object value1 = miloService.readFromOpcUa(thoroughfare + "." + device + ".Scaner").getValue(); |
| | | if (ObjectUtil.isNotNull(value1)){ |
| | | String keyCode = value1.toString(); |
| | | log.info("读取到工位{}的Scaner数据:{}",device,keyCode); |
| | | //仅校验长度是否合格 |
| | | // List<KeyCodeCheck> collect = keyCodeCheckService.list().stream().filter(x -> x.getKeyCode().contains(keyCode)).collect(Collectors.toList()); |
| | | // if (CollUtil.isNotEmpty(collect)){ |
| | | // scanResult = 11; |
| | | // } |
| | | } |
| | | } |
| | | }else { |
| | | System.out.println("^"); |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ScanerResult1").value(scanResult).build()); |
| | | log.info("写入到工位{}的ScanerResult1数据:{}",device,scanResult); |
| | | } |
| | | } |
| | | //保存拧紧数据 |
| | | else if (("AngleResult").equals(tab)) { |
| | | if("1".equals(tabVlaue)||"2".equals(tabVlaue)){ |
| | | List<String> list = new ArrayList<>(); |
| | | String[] suffixes = {"Torque", "Angle", "TorqueResult", "AngleResult"}; |
| | | |
| | | for (String suffix : suffixes) { |
| | | String string = thoroughfare + "." + device + "." + suffix; |
| | | list.add(string); |
| | | }else if (Constants.RECORD_DATA.equals(tab)){ |
| | | if (Constants.ONE.equals(valueString)){ |
| | | //1:告知MES托盘已到站,请求下发进站状态 |
| | | if (Constants.OP030.equals(device)){ |
| | | //反馈电芯ocv检测结果 |
| | | boolean b = OCVResultFeedBack(thoroughfare, device); |
| | | if (b){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(11).build()); |
| | | log.info("写入到工位{}的RecordDataDone数据:{}",device,11); |
| | | }else { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(12).build()); |
| | | log.info("写入到工位{}的RecordDataDone数据:{}",device,12); |
| | | } |
| | | } else { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(11).build()); |
| | | log.info("写入到工位{}的RecordDataDone数据:{}",device,11); |
| | | } |
| | | List<ReadWriteEntity> list1 = miloService.readFromOpcUa(list); |
| | | List<Object> collect = list1.stream().map(ReadWriteEntity::getValue).collect(Collectors.toList()); |
| | | String joinedString = String.join(",", collect.toString()); |
| | | WebSocketUsers.sendMessageToUserByText(map.get(device), TightenTheConversionOkNg(joinedString)); |
| | | }else if (Constants.TWO.equals(valueString)){ |
| | | //分段010-065段 |
| | | List<String> PART1 = new ArrayList<>(); |
| | | PART1.add(Constants.OP020); |
| | | PART1.add(Constants.OP030); |
| | | PART1.add(Constants.OP040); |
| | | PART1.add(Constants.OP050); |
| | | PART1.add(Constants.OP060); |
| | | PART1.add(Constants.OP065); |
| | | if (Constants.OP010.equals(device)){ |
| | | //010工位无过站记录,只给放行信号 |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(21).build()); |
| | | log.info("写入到工位{}的RecordDataDone数据:{}",device,21); |
| | | }else if (PART1.contains(device)){ |
| | | //020工位保存过站记录+参数数据 |
| | | List<DaPassingStationCollection> passingList = getDaPassingStationCollections(thoroughfare, device); |
| | | if (CollUtil.isNotEmpty(passingList)){ |
| | | daPassingStationCollectionService.insertBatch(passingList); |
| | | } |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(21).build()); |
| | | log.info("写入到工位{}的RecordDataDone数据:{}",device,21); |
| | | } else if (Constants.OP100_1.equals(device) || Constants.OP100_2.equals(device)){ |
| | | //下发刻码信息-为模组码 |
| | | ProductOrderQuery query = new ProductOrderQuery(); |
| | | query.setSiteCode("3983"); |
| | | query.setStationCode(device); |
| | | List<WorkOrder> collect = workOrderService.list().stream() |
| | | .sorted(Comparator.comparing(WorkOrder::getCreateTime).reversed()) |
| | | .collect(Collectors.toList()); |
| | | if (CollUtil.isNotEmpty(collect)){ |
| | | query.setProductNum(collect.get(0).getProductNum()); |
| | | } |
| | | ProductOrderVO vo = daPassingStationCollectionService.queryMessFromLine(query); |
| | | if (Constants.SUCCESS.equals(vo.getCode())){ |
| | | WorkOrder workOrder = new WorkOrder(); |
| | | ProductOrderChild data = vo.getData(); |
| | | workOrder.setProductNum(data.getProductNum()); |
| | | workOrder.setProductionOrderNum(data.getProductionOrderNum()); |
| | | workOrder.setStationCode(data.getStationCode()); |
| | | workOrder.setMaterialCode(data.getMaterialCode()); |
| | | workOrder.setModel(data.getModel()); |
| | | workOrderService.save(workOrder); |
| | | //写入模组码、工单号、产品型号到plc |
| | | log.info("写入模组码、工单号、产品型号到plc"); |
| | | miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ModuleCode").value(data.getModel()).build()); |
| | | miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".WorkOrderNumber").value(data.getProductionOrderNum()).build()); |
| | | //这里plc录入的产品型号类型是int类型,工厂mes返回数据不是int类型,可能会出现问题 |
| | | miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ProductType").value(data.getProductNum()).build()); |
| | | //绑定模组码和电芯码数据 |
| | | List<DaCollectionParamConf> list = collectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>() |
| | | .eq(DaCollectionParamConf::getProcessesCode, device) |
| | | .eq(DaCollectionParamConf::getRemarks,Constants.ONE)); |
| | | List<String> collect3 = list.stream().filter(x -> Constants.INT_ZERO.equals(x.getKeyNum())).map(DaCollectionParamConf::getGatherAddress).collect(Collectors.toList()); |
| | | List<String> collect1 = list.stream().filter(x -> Constants.INT_ONE.equals(x.getKeyNum())|| Constants.INT_TWO.equals(x.getKeyNum())) |
| | | .map(DaCollectionParamConf::getGatherAddress).collect(Collectors.toList()); |
| | | // List<String> collect2 = list.stream().filter(x -> Constants.INT_TWO.equals(x.getKeyNum())) |
| | | // .map(DaCollectionParamConf::getGatherAddress).collect(Collectors.toList()); |
| | | List<ReadWriteEntity> paramCollectionList1 = miloService.readFromOpcUa(collect1); |
| | | List<ReadWriteEntity> paramCollectionList3 = miloService.readFromOpcUa(collect3); |
| | | if (CollUtil.isNotEmpty(paramCollectionList1)){ |
| | | List<KeyCodeRelation> relationList = new ArrayList<>(); |
| | | for (ReadWriteEntity readWriteEntity : paramCollectionList1) { |
| | | if (ObjectUtil.isNotNull(readWriteEntity.getValue())){ |
| | | KeyCodeRelation keyCodeRelation = new KeyCodeRelation(); |
| | | keyCodeRelation.setModuleCode(data.getModel()); |
| | | keyCodeRelation.setKeyCode(readWriteEntity.getValue().toString()); |
| | | keyCodeRelation.setProductionOrderNum(data.getProductionOrderNum()); |
| | | keyCodeRelation.setProductNum(data.getProductNum()); |
| | | keyCodeRelation.setCreateTime(new Date()); |
| | | relationList.add(keyCodeRelation); |
| | | } |
| | | } |
| | | if (CollUtil.isNotEmpty(relationList)){ |
| | | keyCodeRelationService.insertBatch(relationList); |
| | | } |
| | | } |
| | | if (CollUtil.isNotEmpty(paramCollectionList3)){ |
| | | QueryPLCData(device,thoroughfare,collect3); |
| | | } |
| | | //保存过站记录 |
| | | DaPassingStationCollection passingStationCollection = new DaPassingStationCollection(); |
| | | passingStationCollection.setModuleCode(data.getModel()); |
| | | |
| | | passingStationCollection.setLocationCode(device); |
| | | passingStationCollection.setInboundTime(new Date()); |
| | | String stationStatus = Constants.PASS; |
| | | ReadWriteEntity stationStatusRead = miloService.readFromOpcUa(thoroughfare + "." + device + ".StationStatus"); |
| | | if (ObjectUtil.isNotNull(stationStatusRead.getValue())){ |
| | | String string = stationStatusRead.getValue().toString(); |
| | | log.info("读取工位{}StationStatus:{}",device,string); |
| | | if (Constants.TWO.equals(string)){ |
| | | stationStatus = Constants.UN_PASS; |
| | | } |
| | | } |
| | | passingStationCollection.setOutRsSign(stationStatus); |
| | | passingStationCollection.setCreateTime(new Date()); |
| | | daPassingStationCollectionService.save(passingStationCollection); |
| | | } |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(21).build()); |
| | | log.info("写入到工位{}的RecordDataDone数据:{}",device,21); |
| | | } else { |
| | | //2:告知MES工位工作完成,请求记录工位数据 |
| | | //保存参数采集记录 |
| | | saveParamPassingData(device,thoroughfare); |
| | | //保存过站记录 |
| | | DaPassingStationCollection passingStationCollection = new DaPassingStationCollection(); |
| | | Object value1 = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCode").getValue(); |
| | | String moduleCode = null; |
| | | if (ObjectUtil.isNotNull(value1)){ |
| | | moduleCode = value1.toString(); |
| | | log.info("读取工位{}的ModuleCode数据:{}",device,moduleCode); |
| | | } |
| | | passingStationCollection.setModuleCode(moduleCode); |
| | | passingStationCollection.setLocationCode(device); |
| | | passingStationCollection.setInboundTime(new Date()); |
| | | String stationStatus = Constants.PASS; |
| | | ReadWriteEntity stationStatusRead = miloService.readFromOpcUa(thoroughfare + "." + device + ".StationStatus"); |
| | | if (ObjectUtil.isNotNull(stationStatusRead.getValue())){ |
| | | String string = stationStatusRead.getValue().toString(); |
| | | if (Constants.TWO.equals(string)){ |
| | | stationStatus = Constants.UN_PASS; |
| | | } |
| | | } |
| | | passingStationCollection.setOutRsSign(stationStatus); |
| | | passingStationCollection.setCreateTime(new Date()); |
| | | daPassingStationCollectionService.save(passingStationCollection); |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(21).build()); |
| | | log.info("写入到工位{}的RecordDataDone数据:{}",device,21); |
| | | } |
| | | } |
| | | } else if (Constants.RECORD_SN.equals(tab)){ |
| | | if (Constants.ONE.equals(valueString)){ |
| | | if (Constants.OP070.equals(device)){ |
| | | //OP070下发产品模组码 |
| | | String string = UUID.randomUUID().toString(); |
| | | miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ModuleCode").value(string).build()); |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordSNDone").value(1).build()); |
| | | } |
| | | } |
| | | } else if (Constants.RECORD_CHECK_CODE_1.equals(tab)) { |
| | | if (Constants.OP100_1.equals(device)){ |
| | | //钢带条码校验--发送给工厂mes |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ScanerResult11").value(11).build()); |
| | | } else if (Constants.OP100_2.equals(device)) { |
| | | //PET带条码校验--发送给工厂mes |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".ScanerResult12").value(11).build()); |
| | | } |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 获取SNCode |
| | | */ |
| | | public String getSNCode(){ |
| | | String SNCode = ""; |
| | | return SNCode; |
| | | } |
| | | |
| | | /** |
| | | * 出站保存数据 |
| | | */ |
| | | public String outSaveDate(String thoroughfare,String device) { |
| | | String snCode = ""; |
| | | String result = ""; |
| | | String read = thoroughfare + "." + device + "."; |
| | | |
| | | try { |
| | | if(nullList.stream().noneMatch(s -> s.equals(device))){ |
| | | if(moduleCodeList.stream().anyMatch(s -> s.equals(device))){ |
| | | read = read + "ModuleCode"; |
| | | }else { |
| | | read = read + "PACKCode"; |
| | | } |
| | | } |
| | | snCode = miloService.readFromOpcUa(read).getValue().toString(); |
| | | |
| | | if(null == snCode || "".equals(snCode)){ |
| | | result = "22"; |
| | | }else{ |
| | | |
| | | String workOrderNo = ""; |
| | | String productCode = ""; |
| | | //2、保存过站采集数据 |
| | | Object orderNumberObject = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "WorkOrderNumber").getValue(); |
| | | if(orderNumberObject!=null){ |
| | | workOrderNo = orderNumberObject.toString(); |
| | | } |
| | | |
| | | Object productCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + "." + "ProductType").getValue(); |
| | | if(productCodeObject!=null){ |
| | | productCode = productCodeObject.toString(); |
| | | } |
| | | |
| | | saveStationInfo(snCode,thoroughfare,device,workOrderNo,productCode); |
| | | //3、保存参数采集数据 |
| | | SaveParamData(snCode,thoroughfare,device,workOrderNo,productCode); |
| | | |
| | | //如果是末尾工站要报工 |
| | | if(device.equals("OP500")){ |
| | | RestfulService.getWorkReportResultFeedback(snCode,device,format.format(new Date())); |
| | | //1、更新工单信息 |
| | | updateOrderInfo(snCode); |
| | | } |
| | | |
| | | result = "21"; |
| | | |
| | | } |
| | | |
| | | }catch (Exception e) { |
| | | System.out.println(e.getMessage()); |
| | | log.info(e.getMessage()); |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | |
| | | // /** |
| | | // * 出站保存数据 |
| | | // */ |
| | | // public String outSaveDate(String thoroughfare,String device) { |
| | | // String result = ""; |
| | | // try { |
| | | // //读取SNCode |
| | | // String PACKCode = thoroughfare + "." + device + ".PACKCode"; |
| | | // Object PACKCodeObject = miloService.readFromOpcUa(PACKCode).getValue(); |
| | | // if(null == PACKCodeObject || "".equals(PACKCodeObject)){ |
| | | // result = "22"; |
| | | // }else{ |
| | | // String PACKCodeParam = PACKCodeObject.toString(); |
| | | // //1、更新工单信息 |
| | | // //updateOrderInfo(); |
| | | // //2、保存过站采集数据 |
| | | // saveStationInfo(PACKCodeParam,thoroughfare,device); |
| | | // //3、保存参数采集数据 |
| | | // SaveParamData(PACKCodeParam,thoroughfare,device,"",""); |
| | | // |
| | | // result = "21"; |
| | | // |
| | | // } |
| | | // |
| | | // }catch (Exception e) { |
| | | // |
| | | // } |
| | | // return result; |
| | | // } |
| | | |
| | | /** |
| | | * 保存过站采集 |
| | | * 保存电芯过站记录 |
| | | * @param thoroughfare 通道 |
| | | * @param device 工位 |
| | | * @return list |
| | | * @throws Exception e |
| | | */ |
| | | public void saveStationInfo(String packCode,String thoroughfare,String device,String workOrderNo,String productCode) throws Exception { |
| | | SimpleDateFormat sdf = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy", Locale.US); |
| | | sdf.setTimeZone(TimeZone.getTimeZone("GMT+8")); // CST通常表示中国标准时间,即东八区 |
| | | String prefix = thoroughfare+"."+device+"."; |
| | | String startTime = miloService.readFromOpcUa(prefix + "StartTime").getValue().toString(); |
| | | String stopTime = miloService.readFromOpcUa(prefix + "StopTime").getValue().toString(); |
| | | String stationStatus = miloService.readFromOpcUa(prefix + "StationStatus").getValue().toString(); |
| | | |
| | | DaPassingStationCollection daPassingStationCollection = new DaPassingStationCollection(); |
| | | daPassingStationCollection.setSfcCode(packCode); |
| | | daPassingStationCollection.setWorkOrderNo(workOrderNo); |
| | | daPassingStationCollection.setProductCode(productCode); |
| | | daPassingStationCollection.setLocationCode(device); |
| | | String strt = TimeUtil.stringProcessing(startTime); |
| | | String end = TimeUtil.stringProcessing(stopTime); |
| | | daPassingStationCollection.setInboundTime(sdf.parse(strt));//入站时间 |
| | | daPassingStationCollection.setOutboundTime(sdf.parse(end));//出站时间 |
| | | daPassingStationCollection.setOutRsSign(stationStatus);//出站是否合格 |
| | | daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection); |
| | | } |
| | | |
| | | public static void SaveParamData(String packCode,String thoroughfare,String device,String workOrderNo,String productType) throws Exception { |
| | | List<DaCollectionParamConf> list; |
| | | DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf(); |
| | | daCollectionParamConf.setGatherAddress(thoroughfare+ "." + device); |
| | | list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf); |
| | | |
| | | List<String> nodeIdList = list.stream().map(info -> { |
| | | String nodeid = info.getGatherAddress(); |
| | | return nodeid; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | if(!nodeIdList.isEmpty()){ |
| | | List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(nodeIdList); |
| | | for (int i = 0; i < readWriteEntityList.size(); i++) { |
| | | if(readWriteEntityList.get(i).getValue() == null){ |
| | | readWriteEntityList.get(i).setValue(" "); |
| | | private static List<DaPassingStationCollection> getDaPassingStationCollections(String thoroughfare, String device) throws Exception { |
| | | List<String> readList = new ArrayList<>(); |
| | | readList.add(thoroughfare + "." + device +".CellCode_1"); |
| | | readList.add(thoroughfare + "." + device +".CellCode_2"); |
| | | readList.add(thoroughfare + "." + device +".CellCode_3"); |
| | | readList.add(thoroughfare + "." + device +".CellCode_4"); |
| | | List<String> keyCodeList = new ArrayList<>(); |
| | | List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(readList); |
| | | List<DaPassingStationCollection> passingList = new ArrayList<>(); |
| | | for (ReadWriteEntity readWriteEntity : readWriteEntityList) { |
| | | DaPassingStationCollection passingStationCollection = new DaPassingStationCollection(); |
| | | passingStationCollection.setLocationCode(device); |
| | | passingStationCollection.setInboundTime(new Date()); |
| | | if (ObjectUtil.isNotNull(readWriteEntity.getValue())){ |
| | | passingStationCollection.setKeyCode(readWriteEntity.getValue().toString()); |
| | | keyCodeList.add(readWriteEntity.getValue().toString()); |
| | | } |
| | | String stationStatus = Constants.PASS; |
| | | ReadWriteEntity stationStatusRead = miloService.readFromOpcUa(thoroughfare + "." + device + ".StationStatus"); |
| | | if (ObjectUtil.isNotNull(stationStatusRead.getValue())){ |
| | | String string = stationStatusRead.getValue().toString(); |
| | | if (Constants.TWO.equals(string)){ |
| | | stationStatus = Constants.UN_PASS; |
| | | } |
| | | } |
| | | List<DaParamCollection> daParamCollectionlist = new ArrayList<>(); |
| | | for(int i=0;i<nodeIdList.size();i++){ |
| | | if(!readWriteEntityList.get(i).getValue().toString().equals("0.0")){ |
| | | String tt = readWriteEntityList.get(i).getValue().toString(); |
| | | DaParamCollection ParamCollection = new DaParamCollection(); |
| | | ParamCollection.setParamCode(list.get(i).getCollectParameterId()); |
| | | ParamCollection.setLocationCode(device); |
| | | if(tt.contains("Time")){ |
| | | // String str = TimeUtil.getTimestamp(TimeUtil.stringProcessing(tt)); |
| | | // ParamCollection.setParamValue(str); |
| | | ParamCollection.setParamValue(TimeUtil.getYyyyDdMm(TimeUtil.stringProcessing(tt))); |
| | | }else { |
| | | ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString()); |
| | | passingStationCollection.setOutRsSign(stationStatus); |
| | | passingStationCollection.setCreateTime(new Date()); |
| | | passingList.add(passingStationCollection); |
| | | } |
| | | //参数采集 |
| | | //保存参数采集数据 |
| | | List<DaCollectionParamConf> list = collectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>() |
| | | .eq(DaCollectionParamConf::getProcessesCode, device) |
| | | .eq(DaCollectionParamConf::getRemarks, Constants.ONE)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | List<DaParamCollection> saveParamList = new ArrayList<>(); |
| | | List<String> collect1 = list.stream().filter(x -> Constants.INT_ONE.equals(x.getKeyNum())) |
| | | .map(DaCollectionParamConf::getGatherAddress).collect(Collectors.toList()); |
| | | List<ReadWriteEntity> paramCollectionList1 = miloService.readFromOpcUa(collect1); |
| | | List<String> collect2 = list.stream().filter(x -> Constants.INT_TWO.equals(x.getKeyNum())) |
| | | .map(DaCollectionParamConf::getGatherAddress).collect(Collectors.toList()); |
| | | List<ReadWriteEntity> paramCollectionList2 = miloService.readFromOpcUa(collect2); |
| | | List<String> collect3 = list.stream().filter(x -> Constants.INT_THREE.equals(x.getKeyNum())) |
| | | .map(DaCollectionParamConf::getGatherAddress).collect(Collectors.toList()); |
| | | List<ReadWriteEntity> paramCollectionList3 = miloService.readFromOpcUa(collect3); |
| | | List<String> collect4 = list.stream().filter(x -> Constants.INT_FOUR.equals(x.getKeyNum())) |
| | | .map(DaCollectionParamConf::getGatherAddress).collect(Collectors.toList()); |
| | | List<ReadWriteEntity> paramCollectionList4 = miloService.readFromOpcUa(collect4); |
| | | List<String> collect0 = list.stream().filter(x -> Constants.INT_ZERO.equals(x.getKeyNum())) |
| | | .map(DaCollectionParamConf::getGatherAddress).collect(Collectors.toList()); |
| | | List<ReadWriteEntity> paramCollectionList0 = miloService.readFromOpcUa(collect0); |
| | | if (CollUtil.isNotEmpty(paramCollectionList1)){ |
| | | for (int i = 0; i < paramCollectionList1.size(); i++) { |
| | | DaParamCollection daParamCollection = new DaParamCollection(); |
| | | if (CollUtil.isNotEmpty(keyCodeList) && keyCodeList.size() == 4){ |
| | | daParamCollection.setKeyCode(keyCodeList.get(0)); |
| | | } |
| | | ParamCollection.setSfcCode(packCode); |
| | | if(device.contains("OP360")){ |
| | | String node = nodeIdList.get(i); |
| | | Object value = miloService.readFromOpcUa("PACK.OP360.ModuleSNCode"+node.charAt(node.length()-1)).getValue(); |
| | | if(value!=null){ |
| | | ParamCollection.setModuleCode(value.toString()); |
| | | |
| | | daParamCollection.setParamCode(paramCollectionList1.get(i).getIdentifier()); |
| | | String paramValue = ""; |
| | | if (ObjectUtil.isNotNull(paramCollectionList1.get(i).getValue())){ |
| | | paramValue = paramCollectionList1.get(i).getValue().toString(); |
| | | } |
| | | daParamCollection.setParamValue(paramValue); |
| | | daParamCollection.setLocationCode(device); |
| | | daParamCollection.setCollectionTime(new Date()); |
| | | saveParamList.add(daParamCollection); |
| | | } |
| | | } |
| | | if (CollUtil.isNotEmpty(paramCollectionList2)){ |
| | | for (int i = 0; i < paramCollectionList2.size(); i++) { |
| | | DaParamCollection daParamCollection = new DaParamCollection(); |
| | | if (CollUtil.isNotEmpty(keyCodeList) && keyCodeList.size() == 4){ |
| | | daParamCollection.setKeyCode(keyCodeList.get(1)); |
| | | } |
| | | |
| | | daParamCollection.setParamCode(paramCollectionList2.get(i).getIdentifier()); |
| | | String paramValue = ""; |
| | | if (ObjectUtil.isNotNull(paramCollectionList2.get(i).getValue())){ |
| | | paramValue = paramCollectionList2.get(i).getValue().toString(); |
| | | } |
| | | daParamCollection.setParamValue(paramValue); |
| | | daParamCollection.setLocationCode(device); |
| | | daParamCollection.setCollectionTime(new Date()); |
| | | saveParamList.add(daParamCollection); |
| | | } |
| | | } |
| | | if (CollUtil.isNotEmpty(paramCollectionList3)){ |
| | | for (int i = 0; i < paramCollectionList3.size(); i++) { |
| | | DaParamCollection daParamCollection = new DaParamCollection(); |
| | | if (CollUtil.isNotEmpty(keyCodeList) && keyCodeList.size() == 4){ |
| | | daParamCollection.setKeyCode(keyCodeList.get(2)); |
| | | } |
| | | |
| | | daParamCollection.setParamCode(paramCollectionList3.get(i).getIdentifier()); |
| | | String paramValue = ""; |
| | | if (ObjectUtil.isNotNull(paramCollectionList3.get(i).getValue())){ |
| | | paramValue = paramCollectionList3.get(i).getValue().toString(); |
| | | } |
| | | daParamCollection.setParamValue(paramValue); |
| | | daParamCollection.setLocationCode(device); |
| | | daParamCollection.setCollectionTime(new Date()); |
| | | saveParamList.add(daParamCollection); |
| | | } |
| | | } |
| | | if (CollUtil.isNotEmpty(paramCollectionList4)){ |
| | | for (int i = 0; i < paramCollectionList4.size(); i++) { |
| | | DaParamCollection daParamCollection = new DaParamCollection(); |
| | | if (CollUtil.isNotEmpty(keyCodeList) && keyCodeList.size() == 4){ |
| | | daParamCollection.setKeyCode(keyCodeList.get(3)); |
| | | } |
| | | |
| | | daParamCollection.setParamCode(paramCollectionList4.get(i).getIdentifier()); |
| | | String paramValue = ""; |
| | | if (ObjectUtil.isNotNull(paramCollectionList4.get(i).getValue())){ |
| | | paramValue = paramCollectionList4.get(i).getValue().toString(); |
| | | } |
| | | daParamCollection.setParamValue(paramValue); |
| | | daParamCollection.setLocationCode(device); |
| | | daParamCollection.setCollectionTime(new Date()); |
| | | saveParamList.add(daParamCollection); |
| | | } |
| | | } |
| | | if (CollUtil.isNotEmpty(paramCollectionList0)){ |
| | | for (int i = 0; i < paramCollectionList0.size(); i++) { |
| | | if (CollUtil.isNotEmpty(keyCodeList) && keyCodeList.size() == 4){ |
| | | for (String s : keyCodeList) { |
| | | DaParamCollection daParamCollection = new DaParamCollection(); |
| | | daParamCollection.setKeyCode(s); |
| | | daParamCollection.setParamCode(paramCollectionList0.get(i).getIdentifier()); |
| | | String paramValue = ""; |
| | | if (ObjectUtil.isNotNull(paramCollectionList0.get(i).getValue())){ |
| | | paramValue = paramCollectionList0.get(i).getValue().toString(); |
| | | } |
| | | daParamCollection.setParamValue(paramValue); |
| | | daParamCollection.setLocationCode(device); |
| | | daParamCollection.setCollectionTime(new Date()); |
| | | saveParamList.add(daParamCollection); |
| | | } |
| | | } |
| | | 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()); |
| | | ParamCollection.setWorkOrderNo(workOrderNo); |
| | | ParamCollection.setProductCode(productType); |
| | | daParamCollectionlist.add(ParamCollection); |
| | | // daParamCollectionService.insertDaParamCollection(ParamCollection); |
| | | } |
| | | } |
| | | daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist); |
| | | } |
| | | addBaseData(workOrderNo,productType,device,packCode); |
| | | |
| | | } |
| | | |
| | | public static void addBaseData(String workOrderNo,String productCode,String locationCode,String packCode){ |
| | | Map<String, String> map = new HashMap<>(); |
| | | map.put("GC", "南浔工厂"); |
| | | map.put("CXBH", "Pack线"); |
| | | map.put("SBBH", "设备001"); |
| | | map.put("YGBH", "员工001"); |
| | | List<DaParamCollection> confList = new ArrayList<>(); |
| | | map.forEach((key, value) -> { |
| | | List<DaCollectionParamConf> daCollectionParamConfs = collectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>() |
| | | .eq(DaCollectionParamConf::getProcessesCode,locationCode) |
| | | .like(DaCollectionParamConf::getCollectParameterId,key)); |
| | | DaParamCollection saveData = new DaParamCollection(); |
| | | saveData.setWorkOrderNo(workOrderNo); |
| | | saveData.setProductCode(productCode); |
| | | saveData.setLocationCode(locationCode); |
| | | saveData.setSfcCode(packCode); |
| | | saveData.setParamCode(daCollectionParamConfs.get(0).getCollectParameterId()); |
| | | saveData.setParamName(daCollectionParamConfs.get(0).getCollectParameterName()); |
| | | saveData.setCollectionTime(new Date()); |
| | | saveData.setParamValue(value); |
| | | confList.add(saveData); |
| | | }); |
| | | daParamCollectionService.insertBatch(confList); |
| | | } |
| | | |
| | | public static void getFactoryOrder(String locationCode){ |
| | | String productionWorkOrder = RestfulService.getProductionWorkOrderRequest("", locationCode); |
| | | JSONObject jsonObject = new JSONObject(productionWorkOrder); |
| | | JSONObject dataObject = jsonObject.getJSONObject("data"); |
| | | |
| | | String productNum = dataObject.getStr("productNum"); |
| | | String stationCode = dataObject.getStr("stationCode"); |
| | | String materialCode = dataObject.getStr("materialCode"); |
| | | String productionOrderNum = dataObject.getStr("productionOrderNum"); |
| | | |
| | | OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo(); |
| | | omProductionOrdeInfo.setProductNum(productNum); |
| | | omProductionOrdeInfo.setWorkOrderNo(productionOrderNum); |
| | | omProductionOrdeInfo.setStationCode(stationCode); |
| | | omProductionOrdeInfo.setProductCode(materialCode); |
| | | omProductionOrdeInfoService.save(omProductionOrdeInfo); |
| | | } |
| | | |
| | | public static void updateOrderInfo(String packCode){ |
| | | OmProductionOrdeInfo one = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, packCode)); |
| | | one.setOrderStatus("5"); |
| | | omProductionOrdeInfoService.saveOrUpdate(one); |
| | | } |
| | | |
| | | public static void avgFunction(){ |
| | | |
| | | } |
| | | |
| | | public static String TightenTheConversionOkNg(String param){ |
| | | // 去除首尾的方括号,然后按照逗号分割字符串 |
| | | String[] parts = param.substring(1, param.length() - 1).split(","); |
| | | |
| | | // 创建一个新的StringBuilder来构建替换后的字符串 |
| | | StringBuilder sb = new StringBuilder(); |
| | | sb.append('['); // 添加左方括号 |
| | | |
| | | for (int i = 0; i < parts.length; i++) { |
| | | String part = parts[i].trim(); // 去除可能的空格 |
| | | float value; |
| | | try { |
| | | value = Float.parseFloat(part); // 尝试将字符串转换为浮点数 |
| | | String replacement; |
| | | if (value == 1f) { |
| | | replacement = "OK"; |
| | | } else if (value == 2f) { |
| | | replacement = "NG"; |
| | | } else { |
| | | replacement = part; // 如果不是1或2,则保持不变 |
| | | } |
| | | sb.append(replacement); |
| | | if (i < parts.length - 1) { |
| | | sb.append(','); // 添加逗号(除了最后一个元素) |
| | | } |
| | | } catch (NumberFormatException e) { |
| | | // 如果转换失败,则保持原样(或进行其他错误处理) |
| | | sb.append(part); |
| | | if (i < parts.length - 1) { |
| | | sb.append(','); |
| | | } |
| | | daParamCollectionService.insertBatch(saveParamList); |
| | | } |
| | | } |
| | | sb.append(']'); // 添加右方括号 |
| | | return sb.toString(); |
| | | return passingList; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 校验是否存在NG |
| | | * @param packCode sfcCode |
| | | * @return boolean |
| | | * 030工位返回ocv测试结果 |
| | | * @param thoroughfare |
| | | * @param device |
| | | * @throws Exception |
| | | */ |
| | | public boolean checkIsNG(String packCode,String modelCode){ |
| | | List<DaPassingStationCollection> list = daPassingStationCollectionService.list(new LambdaQueryWrapper<DaPassingStationCollection>() |
| | | .eq(StrUtil.isNotBlank(packCode),DaPassingStationCollection::getSfcCode, packCode) |
| | | .eq(DaPassingStationCollection::getOutRsSign, Constants.UN_PASS)); |
| | | return CollUtil.isEmpty(list); |
| | | private boolean OCVResultFeedBack(String thoroughfare, String device) throws Exception { |
| | | boolean flag = true; |
| | | Object value1 = miloService.readFromOpcUa(thoroughfare + "." + device + ".CellCode_1").getValue(); |
| | | if (ObjectUtil.isNotNull(value1)){ |
| | | String string = value1.toString(); |
| | | List<DaParamCollection> list = daParamCollectionService.list(new LambdaQueryWrapper<DaParamCollection>() |
| | | .eq(DaParamCollection::getKeyCode, string)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaParamCollection daParamCollection = list.get(0); |
| | | if (Constants.ONE.equals(daParamCollection.getState())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_1").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_1").value(2).build()); |
| | | } |
| | | } |
| | | } |
| | | Object value2 = miloService.readFromOpcUa(thoroughfare + "." + device + ".CellCode_2").getValue(); |
| | | if (ObjectUtil.isNotNull(value2)){ |
| | | String string = value2.toString(); |
| | | List<DaParamCollection> list = daParamCollectionService.list(new LambdaQueryWrapper<DaParamCollection>() |
| | | .eq(DaParamCollection::getKeyCode, string)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaParamCollection paramCollection = list.get(0); |
| | | if (Constants.ONE.equals(paramCollection.getState())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_2").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_2").value(2).build()); |
| | | } |
| | | } |
| | | } |
| | | Object value3 = miloService.readFromOpcUa(thoroughfare + "." + device + ".CellCode_3").getValue(); |
| | | if (ObjectUtil.isNotNull(value3)){ |
| | | String string = value3.toString(); |
| | | List<DaParamCollection> list = daParamCollectionService.list(new LambdaQueryWrapper<DaParamCollection>() |
| | | .eq(DaParamCollection::getKeyCode, string)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaParamCollection paramCollection = list.get(0); |
| | | if (Constants.ONE.equals(paramCollection.getState())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_3").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_3").value(2).build()); |
| | | } |
| | | } |
| | | } |
| | | Object value4 = miloService.readFromOpcUa(thoroughfare + "." + device + ".CellCode_4").getValue(); |
| | | if (ObjectUtil.isNotNull(value4)){ |
| | | String string = value4.toString(); |
| | | List<DaParamCollection> list = daParamCollectionService.list(new LambdaQueryWrapper<DaParamCollection>() |
| | | .eq(DaParamCollection::getKeyCode, string)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaParamCollection paramCollection = list.get(0); |
| | | if (Constants.ONE.equals(paramCollection.getState())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_4").value(1).build()); |
| | | }else { |
| | | flag = false; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_4").value(2).build()); |
| | | } |
| | | } |
| | | } |
| | | return flag; |
| | | } |
| | | |
| | | /** |
| | | * 保存过站数据和参数保存数据 |
| | | * @param device 工位号 |
| | | * @throws Exception |
| | | */ |
| | | private void saveParamPassingData(String device,String thoroughfare) throws Exception { |
| | | |
| | | //保存参数采集数据 |
| | | List<DaCollectionParamConf> list = collectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>() |
| | | .eq(DaCollectionParamConf::getProcessesCode, device) |
| | | .eq(DaCollectionParamConf::getRemarks, Constants.ONE)); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | List<String> collect = list.stream().map(DaCollectionParamConf::getGatherAddress) |
| | | .filter(Objects::nonNull).distinct() |
| | | .collect(Collectors.toList()); |
| | | QueryPLCData(device,thoroughfare,collect); |
| | | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 批量查询plc站点数据 |
| | | * @param device 站点 |
| | | * @param collect 点位 |
| | | * @throws Exception |
| | | */ |
| | | private static void QueryPLCData(String device,String thoroughfare,List<String> collect) throws Exception { |
| | | List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(collect); |
| | | |
| | | if (CollUtil.isNotEmpty(readWriteEntityList)){ |
| | | List<DaParamCollection> collectionList = new ArrayList<>(); |
| | | Object value1 = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCode").getValue(); |
| | | String moduleCode = null; |
| | | if (ObjectUtil.isNotNull(value1)){ |
| | | moduleCode = value1.toString(); |
| | | } |
| | | for (int i = 0; i < readWriteEntityList.size(); i++) { |
| | | DaParamCollection daParamCollection = new DaParamCollection(); |
| | | if (StrUtil.isNotBlank(moduleCode)){ |
| | | daParamCollection.setModuleCode(moduleCode); |
| | | } |
| | | daParamCollection.setParamCode(collect.get(i)); |
| | | String paramValue = ""; |
| | | if (ObjectUtil.isNotNull(readWriteEntityList.get(i).getValue())){ |
| | | paramValue = readWriteEntityList.get(i).getValue().toString(); |
| | | } |
| | | daParamCollection.setParamValue(paramValue); |
| | | daParamCollection.setLocationCode(device); |
| | | daParamCollection.setCollectionTime(new Date()); |
| | | collectionList.add(daParamCollection); |
| | | } |
| | | daParamCollectionService.insertBatch(collectionList); |
| | | } |
| | | } |
| | | } |