派生自 HangZhouMes
hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownLoadCacheGlassTask.java
@@ -3,10 +3,13 @@ import cn.hutool.core.lang.Assert; import cn.smallbun.screw.core.util.CollectionUtils; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.mes.common.S7object; import com.mes.common.config.Const; import com.mes.damage.entity.Damage; import com.mes.damage.service.DamageService; import com.mes.device.PlcParameterObject; import com.mes.downglassinfo.entity.DownGlassInfo; import com.mes.downglassinfo.entity.DownGlassTask; @@ -27,6 +30,7 @@ import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @@ -54,9 +58,8 @@ DownWorkstationService downWorkstationService; @Autowired DownGlassInfoService downGlassInfoService; @Value("${mes.threshold}") private Integer threshold; @Autowired DamageService damageService; @Value("${mes.throughWidth}") private Integer throughWidth; @@ -94,7 +97,6 @@ log.info("1、获取到的请求字为：{}，获取到的扫描ID为：{}，获取到的确认字为：{}，获取到的出片状态分别为：g06:{}、g08:{}、g11:{}、g13:{},当前格子号为：{}", requestWord, glassIdeValue, confirmationWrodValue, out06Glassstate, out08Glassstate, out11Glassstate, out13Glassstate, currentSlot); if ("0".equals(requestWord)) { if ("0".equals(confirmationWrodValue)) { log.info("2、获取到的请求字为0，且确认字为0，不执行任务"); @@ -126,6 +128,87 @@ } } @Scheduled(fixedDelay = 300) public void plcShelfFull() { List<DownWorkstation> list = downGlassInfoService.queryWorkStationIsFull(); S7control s7control = S7object.getinstance().plccontrol; PlcParameterObject plcMesObject = S7object.getinstance().PlcMesObject; if (CollectionUtils.isNotEmpty(list)) { s7control.writeWord(plcMesObject.getPlcParameter("alarm_signal").getAddress(), 1); } else { s7control.writeWord(plcMesObject.getPlcParameter("alarm_signal").getAddress(), 0); } } @Scheduled(fixedDelay = 1000) public void dealDamageTask() { Date startDate = new Date(); log.info("下片破损玻璃清除任务开始执行时间：{}", startDate); List<DownGlassTask> downGlassTaskList = downGlassTaskService.list(new LambdaQueryWrapper<DownGlassTask>() .in(DownGlassTask::getTaskType, Const.GLASS_CACHE_TYPE_OUT_ALL).in(DownGlassTask::getTaskStatus, Const.GLASS_STATE_DAMAGE_TAKE)); if (CollectionUtils.isNotEmpty(downGlassTaskList)) { //获取破损/拿走玻璃id List<String> glassList = downGlassTaskList.stream().map(DownGlassTask::getGlassId).collect(Collectors.toList()); //将任务表中的数据删除 downGlassTaskService.remove(new LambdaQueryWrapper<DownGlassTask>().in(DownGlassTask::getTaskType, Const.GLASS_CACHE_TYPE_OUT_ALL).in(DownGlassTask::getGlassId, glassList)); //清除下片玻璃信息表数据 downGlassInfoService.remove(new LambdaQueryWrapper<DownGlassInfo>().in(DownGlassInfo::getGlassId, glassList)); //下片数量-1 for (DownGlassTask downGlassTask : downGlassTaskList ) { if (Const.GLASS_CACHE_TYPE_OUT_ALL.equals(downGlassTask.getTaskType())) { downWorkstationService.update( new LambdaUpdateWrapper<DownWorkstation>() .setSql("racks_number = racks_number-1") .eq(DownWorkstation::getWorkstationId, downGlassTask.getEndCell()) ); } } List<Damage> damageList = downGlassTaskList.stream().map(e -> { Damage damage = new Damage(); damage.setGlassId(e.getGlassId()); damage.setLine(Const.TEMPERING_OUT_TARGET_POSITION); damage.setWorkingProcedure("下片"); damage.setRemark("下片"); damage.setStatus(0); damage.setType(e.getTaskStatus()); return damage; }).collect(Collectors.toList()); damageService.batchInsertDamage(damageList); } Date endDate = new Date(); log.info("本次任务结束时间：{}，共耗时：{}ms", endDate, endDate.getTime() - startDate.getTime()); } /** * 更新已绑定工位流程卡的破损/拿走的数量信息 */ @Scheduled(fixedDelay = 1000) public void updateWorkStationOtherCount() { Date startDate = new Date(); log.info("下片破更新损玻璃数量任务开始执行时间：{}", startDate); //获取已绑定流程卡的工位信息 List<DownWorkstation> downWorkstationList = downWorkstationService.list(new LambdaQueryWrapper<DownWorkstation>() .isNotNull(DownWorkstation::getFlowCardId) .ne(DownWorkstation::getFlowCardId, "") .orderByDesc(DownWorkstation::getWorkstationId)); for (DownWorkstation downWorkstation : downWorkstationList) { //更新工位其他玻璃信息的数量 QueryWrapper<Damage> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("process_id", downWorkstation.getFlowCardId()); queryWrapper.gt("type", 3); if (downWorkstation.getLayer() != 0) { queryWrapper.eq("technology_number", downWorkstation.getLayer()); } int otherNumber = damageService.count(queryWrapper); downWorkstationService.update(new LambdaUpdateWrapper<DownWorkstation>().set(DownWorkstation::getOtherNumber, otherNumber) .eq(DownWorkstation::getWorkstationId, downWorkstation.getWorkstationId())); } Date endDate = new Date(); log.info("下片破更新损玻璃数量任务结束时间：{}，共耗时：{}ms", endDate, endDate.getTime() - startDate.getTime()); } public void inTo(String glassId, String requestWord, String currentSlot) { log.info("1、按照玻璃id:{}获取玻璃小片信息,当前格子为:{}", glassId, currentSlot); //添加进片任务 查找空格 @@ -147,9 +230,16 @@ } else { log.info("该玻璃尺寸非人工下片"); //获取该玻璃的流程卡是否已绑定架子 DownWorkstation one = downWorkstationService.getOne(new LambdaQueryWrapper<DownWorkstation>() .eq(DownWorkstation::getLayer, glassInfo.getLayer()) .eq(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())); DownWorkstation one; if (glassInfo.getCombine() != 0) { one = downWorkstationService.getOne(new LambdaQueryWrapper<DownWorkstation>() .eq(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())); } else { one = downWorkstationService.getOne(new LambdaQueryWrapper<DownWorkstation>() .eq(DownWorkstation::getLayer, glassInfo.getLayer()) .eq(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())); } //是否已经绑定 true：已绑定 false:未绑定 Boolean isBind = Boolean.FALSE; if (null != one) { @@ -164,13 +254,18 @@ if (CollectionUtils.isNotEmpty(list)) { log.info("有空架子,将流程卡与架子好绑定，执行进片任务 结束"); //绑定流程卡 downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getWorkstationId(), glassInfo.getLayer()); if (glassInfo.getCombine() == 0) { downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getWorkstationId(), glassInfo.getLayer()); } else { downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getWorkstationId(), 0); } // downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getId(), glassInfo.getLayer()); checkFlag = Boolean.TRUE; } } if (!checkFlag) { log.info("无空架子,获取已绑定架子的流程卡信息,查看玻璃信息是否可被对调"); List<DownGlassInfoDTO> downGlassInfoDTOList = downGlassInfoService.queryWorkStationIsIn(Boolean.FALSE); List<DownGlassInfoDTO> downGlassInfoDTOList = downGlassInfoService.queryWorkStationIsIn(Const.WORK_STATION_ALL, Boolean.FALSE); log.info("获取架子上已绑定流程卡落架的数量及未落架的玻璃数据：{}", downGlassInfoDTOList); if (CollectionUtils.isEmpty(downGlassInfoDTOList)) { log.info("已绑定流程卡均无未落架玻璃，请及时处理架子上的玻璃，清除流程卡,执行进片任务"); @@ -213,11 +308,18 @@ //将任务插入理片笼详情表 DownStorageCageDetails downStorageCageDetails = new DownStorageCageDetails(); BeanUtils.copyProperties(glassInfo, downStorageCageDetails); //当需要合并落架时不绑定层号 if (glassInfo.getCombine() != 0) { downStorageCageDetails.setLayer(0); } downStorageCageDetails.setState(Const.GLASS_STATE_IN); downStorageCageDetails.setSlot(nearestEmpty.getSlot()); downStorageCageDetails.setDeviceId(nearestEmpty.getDeviceId()); downStorageCageDetailsService.save(downStorageCageDetails); // 生成进片任务 initDownGlassTask(glassInfo, 0, nearestEmpty.getSlot(), Const.GLASS_CACHE_TYPE_IN); //删除理片笼表拿走/破损数据数据 damageService.deleteByGlassId(glassInfo.getGlassId()); } public Boolean outTo(String glassStatus06, String out08Glassstate, String glassStatus11, String @@ -234,9 +336,14 @@ if (StringUtils.isNotBlank(glassId)) { GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId)); BeanUtils.copyProperties(glassInfo, cageDetails); //当需要合并落架时不绑定层号 if (glassInfo.getCombine() != 0) { cageDetails.setLayer(0); } //获取当前笼子空格信息 DownStorageCage empty = downStorageCageService.selectCacheEmpty(Integer.parseInt(currentSlot), Boolean.TRUE); cageDetails.setSlot(empty.getSlot()); cageDetails.setDeviceId(empty.getDeviceId()); tempList.add(cageDetails); } log.info("出片2：笼内玻璃的数据(包括待进片)有：{}", tempList); @@ -249,6 +356,7 @@ //2、08台空闲，先走扔工下片或2号机械臂，无玻璃出片 在走1号机械臂 //机械臂被禁用的情况下不能继续向禁用的机械臂放玻璃 Boolean flag08 = "1".equals(out08Glassstate) ? Boolean.TRUE : Boolean.FALSE; flag08 = true; if (!flag08) { generateTaskByShelf(glassStatus06, glassStatus11, flag08, glassStatus13, tempList, cageDetails, glassId); } else { @@ -301,14 +409,25 @@ List<Integer> workList = new ArrayList(); if (flag08) { if (!"2".equals(glassStatus11)) { workList.addAll(Const.G11_WORK_STATION); List<Integer> wroklistOne = downWorkstationService.list(new LambdaQueryWrapper<DownWorkstation>() .eq(DownWorkstation::getEnableState, Const.SLOT_ON).in(DownWorkstation::getWorkstationId, Const.G11_WORK_STATION)) .stream() .map(DownWorkstation::getWorkstationId) .collect(Collectors.toList()); workList.addAll(wroklistOne); } } else { if (!"2".equals(glassStatus06)) { workList.addAll(Const.G06_WORK_STATION); List<Integer> wroklistTwo = downWorkstationService.list(new LambdaQueryWrapper<DownWorkstation>() .eq(DownWorkstation::getEnableState, Const.SLOT_ON).in(DownWorkstation::getWorkstationId, Const.G06_WORK_STATION)) .stream() .map(DownWorkstation::getWorkstationId) .collect(Collectors.toList()); workList.addAll(wroklistTwo); } } List<Integer> workStationAll = Arrays.asList(1, 2, 3, 4, 5, 6); //获取非本次落架的架子信息 List<Integer> offWorkStationList = workStationAll.stream().filter(e -> !workList.contains(e)).collect(Collectors.toList()); List<DownStorageCageDetails> list = new ArrayList(); //是否有空架子 true：有 false:无 @@ -338,9 +457,17 @@ Map<String, List<DownWorkstation>> listMap = downWorkstationList.stream() .filter(item -> StringUtils.isNotBlank(item.getFlowCardId())).collect(Collectors.groupingBy(item -> item.getFlowCardId() + ":" + item.getLayer())); //过滤筛选获取架子上对应流程卡+层数的笼子内的玻璃信息 list = tempList.stream().filter(item -> listMap.containsKey(item.getFlowCardId() + ":" + item.getLayer())).collect(Collectors.toList()); if (CollectionUtils.isEmpty(list) && flag08 && !"2".equals(glassStatus13)) { list = tempList.stream().filter(item -> { double firstLength = Math.max(item.getWidth(), item.getHeight()); double secondLength = Math.min(item.getWidth(), item.getHeight()); return firstLength > maxWidth || secondLength > maxHeight; }).collect(Collectors.toList()); } } else { log.info("存在未绑定流程卡架子，直接获取笼内所有玻璃,且未绑定架子的玻璃信息"); log.info("存在未绑定流程卡架子，直接获取笼内所有玻璃,且未绑定架子的玻璃信息（都可以出的玻璃）"); //获取禁用及非本机械臂的架子的流程号及层数对应的玻璃信息 List<DownWorkstation> downWorkstationOffList = downWorkstationService.list(new LambdaQueryWrapper<DownWorkstation>() .and(i -> i.in(DownWorkstation::getWorkstationId, offWorkStationList).or().eq(DownWorkstation::getEnableState, Const.SLOT_OFF))); @@ -370,6 +497,8 @@ log.info("笼内玻璃无法执行出片"); return Boolean.FALSE; } //获取具体出那一片玻璃 //tao:人工--> 所有架子都未绑定时进行绑定 --->有未绑定架子时进行绑定 --->绑定过流程卡的玻璃-->玻璃流程卡多层--->玻璃流程卡单层 String tempGlassId = null; Boolean isNeedBind = Boolean.FALSE; @@ -387,16 +516,17 @@ loop: if (StringUtils.isBlank(tempGlassId)) { //获取正在落架的绑定流程卡的信息(流程卡、层数、落架数量) List<DownGlassInfoDTO> downGlassInfoDTOList = downGlassInfoService.queryWorkStationIsIn(Boolean.TRUE); //落架玻璃数为0，即使绑定了流程卡，也无法找到对应的架子信息，只能重新绑定 List<DownGlassInfoDTO> downGlassInfoDTOList = downGlassInfoService.queryWorkStationFlowCard(workList); List<String> downGlassFlowList = downGlassInfoDTOList.stream().map(item -> item.getFlowCardId() + ":" + item.getLayer()).collect(Collectors.toList()); if (CollectionUtils.isEmpty(downGlassFlowList)) { //架子都未绑定流程卡，出笼内子数量最多尺寸最大的玻璃id,无 则返回扫描扫到的玻璃id进行出片 tempGlassId = downStorageCageDetailsService.getGlassInfoMaxCount(glassId, offWorkStationList); isNeedBind = Boolean.TRUE; break loop; } //将笼子内的玻璃进行过滤，仅获取无法落架的流程卡玻璃 //tao:当有空架时优先对笼内可出片且未绑架子的玻璃进出绑架并出片 List<DownStorageCageDetails> noDownLoadList = list.stream().filter(item -> !downGlassFlowList.contains(item.getFlowCardId() + ":" + item.getLayer())) .collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(noDownLoadList)) { @@ -417,7 +547,7 @@ return Boolean.FALSE; } //将笼内玻璃的流程卡+层号 和落架的流程卡 去重，得出展示无法落架的玻璃，判断玻璃数是否超过阈值 //笼内玻璃是否可落架:笼内是否有需要中空的 //笼内玻璃是否可落架:笼内是否有需要中空 List<DownStorageCageDetails> multiLayerList = list.stream().filter(item -> item.getTotalLayer() >= 2).collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(multiLayerList)) { for (DownStorageCageDetails item : multiLayerList) { @@ -434,7 +564,7 @@ break loop; } Integer sequence = downGlassInfoService.queryMaxSequence(item.getFlowCardId(), item.getLayer()); log.info("获取当前玻璃需要放的次序：笼内同流程 同层数的通达次序+1:{}", sequence); log.info("获取当前玻璃需要放的次序：笼内同流程 同层数的落架次序+1:{}", sequence); DownGlassInfo downGlassInfo = downGlassInfoService.getOne(new LambdaQueryWrapper<DownGlassInfo>() .eq(DownGlassInfo::getFlowCardId, downGlassInfoDTO.getFlowCardId()) .eq(DownGlassInfo::getLayer, downGlassInfoDTO.getLayer()).eq(DownGlassInfo::getSequence, sequence)); @@ -456,6 +586,7 @@ if (CollectionUtils.isNotEmpty(downStorageCageDetails)) { tempGlassId = downStorageCageDetails.get(0).getGlassId(); break; } } } @@ -502,18 +633,30 @@ if (null != emptyDownWorkstation) { log.info("获取到空架子信息，绑定流程卡"); downWorkstationService.updateFlowCardIdAndCount(downStorageCageDetails.getFlowCardId(), emptyDownWorkstation.getWorkstationId(), downStorageCageDetails.getLayer()); // downWorkstationService.updateFlowCardIdAndCount(downStorageCageDetails.getFlowCardId(), emptyDownWorkstation.getId(), downStorageCageDetails.getLayer()); endCell = emptyDownWorkstation.getWorkstationId(); } else { //todo:增加虚拟工位,绑定流程卡 // downWorkstationService.insertDownWorkstation(); // endCell = Const.G13_WORK_STATION; // downWorkstationService.updateFlowCardIdAndCount(downStorageCageDetails.getFlowCardId(), emptyDownWorkstation.getId(), downStorageCageDetails.getLayer()); log.info("没有空架子信息，无法绑定流程卡"); return Boolean.FALSE; } } else { DownWorkstation workstation = downWorkstationService.getOne(new LambdaUpdateWrapper<DownWorkstation>() .eq(DownWorkstation::getFlowCardId, downStorageCageDetails.getFlowCardId()).eq(DownWorkstation::getLayer, downStorageCageDetails.getLayer())); endCell = workstation.getWorkstationId(); double firstLength = Math.max(downStorageCageDetails.getWidth(), downStorageCageDetails.getHeight()); double secondLength = Math.min(downStorageCageDetails.getWidth(), downStorageCageDetails.getHeight()); if (firstLength > maxWidth || secondLength > maxHeight) { endCell = Const.G13_WORK_STATION; } else { DownWorkstation workstation; workstation = downWorkstationService.getOne(new LambdaUpdateWrapper<DownWorkstation>() .eq(DownWorkstation::getFlowCardId, downStorageCageDetails.getFlowCardId()).eq(DownWorkstation::getLayer, downStorageCageDetails.getLayer())); endCell = workstation.getWorkstationId(); } } //更新落架玻璃数量 if (endCell == 7) { if (endCell == Const.G13_WORK_STATION) { downWorkstationService.update(new UpdateWrapper<DownWorkstation>().eq("flow_card_id", downStorageCageDetails.getFlowCardId()) .eq("layer", downStorageCageDetails.getLayer()).setSql("other_number = other_number +1")); } else { @@ -525,11 +668,31 @@ DownGlassInfo downGlassInfo = new DownGlassInfo(); BeanUtils.copyProperties(downStorageCageDetails, downGlassInfo); //落架片序 downGlassInfo.setSequence(downGlassInfoService.queryMaxSequence(downGlassInfo.getFlowCardId(), downGlassInfo.getLayer())); LambdaQueryWrapper<DownGlassInfo> wrapper = new LambdaQueryWrapper<DownGlassInfo>(); wrapper.eq(DownGlassInfo::getFlowCardId, downGlassInfo.getFlowCardId()) .orderByDesc(DownGlassInfo::getSequence) .last("limit 1"); if (downStorageCageDetails.getLayer() != 0) { wrapper.eq(DownGlassInfo::getLayer, downGlassInfo.getLayer()); } // downGlassInfo.setSequence(downGlassInfoService.queryMaxSequence(downGlassInfo.getFlowCardId(), downGlassInfo.getLayer())); int k = 0; DownGlassInfo downGlassInfo1 = downGlassInfoService.getOne(wrapper); if (downGlassInfo1 != null) { k = 1; } else { k = 1; } downGlassInfo.setSequence(k); downGlassInfo.setWorkStationId(endCell); downGlassInfo.setGmtCreate(new Date()); downGlassInfoService.save(downGlassInfo); //生成任务信息 GlassInfo glassInfo = new GlassInfo(); downStorageCageDetails.setLayer(0); BeanUtils.copyProperties(downStorageCageDetails, glassInfo); //删除理片笼表拿走/破损数据数据 damageService.deleteByGlassId(glassInfo.getGlassId()); return initDownGlassTask(glassInfo, downStorageCageDetails.getSlot(), endCell, taskType); } @@ -547,6 +710,14 @@ downGlassTask.setTaskStatus(0); downGlassTask.setCreateTime(new Date()); downGlassTaskService.save(downGlassTask); //添加报工数据 Damage damage = new Damage(); damage.setGlassId(glassInfo.getGlassId()); damage.setWorkingProcedure("钢化"); damage.setLine(4001); damage.setType(1); damage.setRemark("钢化后卧式理片"); damageService.insertDamage(damage); //向plc发送命令 return sendMessageToPlc((int) glassInfo.getWidth(), (int) glassInfo.getHeight(), (int) glassInfo.getThickness(), startCell, endCell, taskType);
