| | |
| | | import java.util.Map; |
| | | import java.util.stream.Collectors; |
| | | |
| | | import cn.hutool.core.util.StrUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | |
| | | import com.jcdm.framework.websocket.WebSocketUsers; |
| | | import com.jcdm.main.da.paramCollection.domain.DaParamCollection; |
| | | import com.jcdm.main.da.paramCollection.mapper.DaParamCollectionMapper; |
| | | import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService; |
| | | import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection; |
| | | import com.jcdm.main.da.passingStationCollection.mapper.DaPassingStationCollectionMapper; |
| | | import com.jcdm.main.da.testDeviceInterface.service.IDaTestDeviceInterfaceService; |
| | | import com.kangaroohy.milo.model.ReadWriteEntity; |
| | | import com.kangaroohy.milo.service.MiloService; |
| | | import org.aspectj.weaver.loadtime.Aj; |
| | |
| | | |
| | | @Autowired |
| | | private DaPassingStationCollectionMapper daPassingStationCollectionMapper; |
| | | |
| | | @Autowired |
| | | private IDaTestDeviceInterfaceService daTestDeviceInterfaceService; |
| | | |
| | | @Autowired |
| | | private IDaParamCollectionService daParamCollectionService; |
| | | |
| | | Map<String, Session> map = WebSocketUsers.getUsers(); |
| | | |
| | |
| | | bsFormulaChildInfos.get(0).setResults("OK"); |
| | | bsFormulaChildInfos.get(0).setCollectData(bsFormulaChildInfo.getTightenTheArray()); |
| | | bsFormulaChildInfoMapper.updateBsFormulaChildInfo(bsFormulaChildInfos.get(0)); |
| | | |
| | | Integer stepNumber = Integer.valueOf(bsFormulaChildInfos.get(0).getStepSort()); |
| | | try { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+bsFormulaChildInfo.getLocationCode()+".MStepNumber").value(stepNumber+1).build()); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | |
| | | String spareField4 = bsFormulaChildInfos.get(0).getSpareField4(); |
| | | if (spareField4 != null && !spareField4.isEmpty()) { |
| | | // 执行操作 |
| | |
| | | } |
| | | } |
| | | |
| | | } |
| | | return AjaxResult.success(result); |
| | | } |
| | | |
| | | @Override |
| | | public AjaxResult jrmUpdateResults(BsFormulaChildInfo bsFormulaChildInfo) { |
| | | String result = ""; |
| | | List<BsFormulaChildInfo> bsFormulaChildInfos = new ArrayList<>(); |
| | | List<BsFormulaChildInfo> infos = bsFormulaChildInfoService.list(new LambdaQueryWrapper<BsFormulaChildInfo>() |
| | | .eq(BsFormulaChildInfo::getProcessesCode, bsFormulaChildInfo.getLocationCode()) |
| | | .eq(BsFormulaChildInfo::getProductCode, bsFormulaChildInfo.getProductCode()) |
| | | .eq(BsFormulaChildInfo::getOperationType, "2") |
| | | ).stream().filter(x -> StrUtil.isBlank(x.getCollectData())).collect(Collectors.toList()); |
| | | |
| | | |
| | | for (BsFormulaChildInfo formulaChildInfo : infos) { |
| | | if(bsFormulaChildInfo.getScanBarcode().contains(formulaChildInfo.getMaterialCode())){ |
| | | bsFormulaChildInfos.add(formulaChildInfo); |
| | | break; |
| | | } |
| | | } |
| | | if(bsFormulaChildInfos.size()>0){ |
| | | String spareField4 = bsFormulaChildInfos.get(0).getSpareField4(); |
| | | bsFormulaChildInfos.get(0).setCollectData(bsFormulaChildInfo.getScanBarcode()); |
| | | bsFormulaChildInfos.get(0).setResults("OK"); |
| | | bsFormulaChildInfoMapper.updateBsFormulaChildInfo(bsFormulaChildInfos.get(0)); |
| | | bsFormulaChildInfo.setParamValue(bsFormulaChildInfo.getScanBarcode()); |
| | | bsFormulaChildInfo.setParamCode(bsFormulaChildInfos.get(0).getParamCode()); |
| | | bsFormulaChildInfo.setSfcBarcode(bsFormulaChildInfo.getSfcBarcode()); |
| | | jrmAddParameterCollection(bsFormulaChildInfo); |
| | | |
| | | if (spareField4 != null && !spareField4.isEmpty()) { |
| | | // 执行操作 |
| | | if(bsFormulaChildInfos.get(0).getSpareField4().equals("1")){ |
| | | try { |
| | | result = "3"; |
| | | // String strA = bsFormulaChildInfo.getLocationCode() + "A"; |
| | | // String strB = bsFormulaChildInfo.getLocationCode() + "B"; |
| | | // miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+strA+".RecordDataDone").value(21).build()); |
| | | // miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+strB+".RecordDataDone").value(21).build()); |
| | | String locationCode = bsFormulaChildInfo.getLocationCode(); |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+locationCode+".RecordDataDone").value(21).build()); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | } |
| | | }else { |
| | | result = "1"; |
| | | } |
| | | return AjaxResult.success(result); |
| | | } |
| | |
| | | bsFormulaChildInfo.setParamCode(bsFormulaChildInfos.get(0).getParamCode()); |
| | | bsFormulaChildInfo.setSfcBarcode(bsFormulaChildInfo.getSfcBarcode()); |
| | | addParameterCollection(bsFormulaChildInfo); |
| | | |
| | | // Integer stepNumber = Integer.valueOf(bsFormulaChildInfos.get(0).getStepSort()); |
| | | // try { |
| | | // miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+bsFormulaChildInfo.getLocationCode()+".StepNumber").value(stepNumber).build()); |
| | | // } catch (Exception e) { |
| | | // throw new RuntimeException(e); |
| | | // } |
| | | |
| | | if (spareField4 != null && !spareField4.isEmpty()) { |
| | | // 执行操作 |
| | | if(bsFormulaChildInfos.get(0).getSpareField4().equals("1")){ |
| | |
| | | daParamCollectionMapper.insertDaParamCollection(daParamCollection); |
| | | } |
| | | |
| | | public void jrmAddParameterCollection(BsFormulaChildInfo bsFormulaChildInfo){ |
| | | String scanBarCode = bsFormulaChildInfo.getSfcBarcode(); |
| | | String[] modeleSplit = scanBarCode.split(","); |
| | | // for (String modele : modeleSplit) { |
| | | DaParamCollection daParamCollection = new DaParamCollection(); |
| | | daParamCollection.setParamCode(bsFormulaChildInfo.getParamCode()); |
| | | daParamCollection.setWorkOrderNo(bsFormulaChildInfo.getWorkOrderNo()); |
| | | daParamCollection.setLocationCode(bsFormulaChildInfo.getLocationCode()); |
| | | daParamCollection.setParamValue(bsFormulaChildInfo.getParamValue()); |
| | | daParamCollection.setProductCode(bsFormulaChildInfo.getProductCode()); |
| | | daParamCollection.setCollectionTime(new Date()); |
| | | if(bsFormulaChildInfo.getParamCode().contains("B")){ |
| | | daParamCollection.setSfcCode(modeleSplit[1]); |
| | | }else { |
| | | daParamCollection.setSfcCode(modeleSplit[0]); |
| | | } |
| | | // daParamCollection.setSfcCode(modele); |
| | | daParamCollectionMapper.insertDaParamCollection(daParamCollection); |
| | | // } |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public AjaxResult workpieceRelease(BsFormulaChildInfo bsFormulaChildInfo) { |
| | | daParamCollectionService.pushGeelycvMesFeedback(bsFormulaChildInfo.getProductBarcode(), bsFormulaChildInfo.getLocationCode()); |
| | | List<BsFormulaChildInfo> list = bsFormulaChildInfoService.list(new LambdaQueryWrapper<BsFormulaChildInfo>() |
| | | .eq(BsFormulaChildInfo::getProcessesCode, bsFormulaChildInfo.getLocationCode()) |
| | | .eq(BsFormulaChildInfo::getProductCode, bsFormulaChildInfo.getProductCode())); |
| | |
| | | bsFormulaChildInfos.get(0).setResults("OK"); |
| | | bsFormulaChildInfos.get(0).setCollectData(bsFormulaChildInfo.getTightenTheArray()); |
| | | bsFormulaChildInfoMapper.updateBsFormulaChildInfo(bsFormulaChildInfos.get(0)); |
| | | |
| | | Integer stepNumber = Integer.valueOf(bsFormulaChildInfos.get(0).getStepSort()); |
| | | try { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+bsFormulaChildInfo.getLocationCode()+".MStepNumber").value(stepNumber+1).build()); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | |
| | | String spareField4 = bsFormulaChildInfos.get(0).getSpareField4(); |
| | | if (spareField4 != null && !spareField4.isEmpty()) { |
| | | // 执行操作 |