| | |
|---|
| | | import com.zy.entity.*; |
|---|
| | | import com.zy.mapper.*; |
|---|
| | | import com.zy.service.*; |
|---|
| | | import com.zy.system.entity.Config; |
|---|
| | | import com.zy.system.service.ConfigService; |
|---|
| | | import com.zy.utils.*; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | |
|---|
| | | && staProtocol.isPakMk() && staProtocol.getWorkNo() >= 9993 && staProtocol.getWorkNo() <= 9995) { // 9990-9992空托，9993-9995 满托，9999回退 |
|---|
| | | if(Cools.isEmpty(barcode) || "NG".endsWith(barcode) || "NoRead".equals(barcode) || "00000000".equals(barcode)) { |
|---|
| | | News.info("{}条码扫描错误：{}",barcodeThread.getSlave().getId(),barcode); |
|---|
| | | continue; |
|---|
| | | staProtocol.setWorkNo(wrkNo); |
|---|
| | | staProtocol.setStaNo(inSta.getBackSta().shortValue()); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(3, "条码扫描错误")); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // 判断重复工作档 |
|---|
| | | WrkMast wrkMast = wrkMastMapper.selectPakInStep1(inSta.getStaNo(), barcode); |
|---|
| | |
|---|
| | | staProtocol = staProtocol.clone(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isPakMk() && staProtocol.getWorkNo() == 9999) { |
|---|
| | | if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isPakMk() |
|---|
| | | && staProtocol.getWorkNo() >= 9993 && staProtocol.getWorkNo() <= 9995) { |
|---|
| | | News.warnNoLog(""+mark+" - 0"+" - 开始执行"); |
|---|
| | | WrkMast wrkMast = wrkMastMapper.selectPickStep(barcode); |
|---|
| | | if (wrkMast == null) { |
|---|
| | |
|---|
| | | // 获取目标站 |
|---|
| | | Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>() |
|---|
| | | .eq("type_no", wrkMast.getIoType() - 50) |
|---|
| | | .eq("stn_no", pickSta.getStaNo()) // 作业站点 = 拣料出库的目标站 |
|---|
| | | .eq("stn_no", wrkMast.getSourceStaNo()) // 作业站点 = 拣料出库的目标站 |
|---|
| | | .eq("crn_no", wrkMast.getCrnNo()); // 堆垛机号 |
|---|
| | | StaDesc staDesc = staDescService.selectOne(wrapper); |
|---|
| | | if (Cools.isEmpty(staDesc)) { |
|---|
| | | News.error(""+mark+" - 2"+" - 入库路径不存在！type_no={},stn_no={},crn_no={}", wrkMast.getIoType(), pickSta.getStaNo(), wrkMast.getCrnNo()); |
|---|
| | | staProtocol.setWorkNo(wrkNo); |
|---|
| | | staProtocol.setStaNo((short) (pickSta.getStaNo().shortValue()-(short)1)); |
|---|
| | | staProtocol.setStaNo(pickSta.getBackSta().shortValue()); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | log.error("输送线下发4："+wrkNo+","+(pickSta.getStaNo().shortValue()-(short)1)); |
|---|
| | | log.error("输送线下发4："+wrkNo+","+pickSta.getBackSta()); |
|---|
| | | //LED |
|---|
| | | LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, pickSta.getLed()); |
|---|
| | | // led 异常显示 |
|---|
| | |
|---|
| | | wrkMast.setIoTime(now); |
|---|
| | | wrkMast.setIoType(wrkMast.getIoType() - 50); // 入出库类型: 103->53,104->54,107->57 |
|---|
| | | wrkMast.setWrkSts(2L); // 工作状态: 2.设备上走 |
|---|
| | | wrkMast.setSourceStaNo(wrkMast.getStaNo()); // 源站 |
|---|
| | | wrkMast.setSourceStaNo(staProtocol.getSiteId()); // 源站 |
|---|
| | | wrkMast.setStaNo(staNo); // 目标站 |
|---|
| | | wrkMast.setLocNo(wrkMast.getSourceLocNo()); // 目标库位 = 出库时的源库位 |
|---|
| | | wrkMast.setSourceLocNo(""); // 源库位清空 |
|---|
| | |
|---|
| | | News.infoNoLog(""+mark+" - 1"+" - 0"+" - 堆垛机入出库作业下发 ： 入库执行完毕"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private ConfigService configService; |
|---|
| | | /** |
|---|
| | | * 出库 ===>> 库位到堆垛机站 |
|---|
| | | * 2022-06-09 TQS修改，查询工作档LIST，遍历下发，防止第一个任务堵塞出库 |
|---|
| | | */ |
|---|
| | | public synchronized void locToCrnStn(CrnSlave slave, CrnProtocol crnProtocol,Integer mark) { |
|---|
| | | News.warnNoLog(""+mark+" - 2"+" - 0"+" - 堆垛机入出库作业下发：执行出库"); |
|---|
| | | |
|---|
| | | // 控制是否允许连续出库，不判断出库站点状态(根据状态启用) |
|---|
| | | boolean crnAvailableOut = false; |
|---|
| | | Config config = configService.selectOne(new EntityWrapper<Config>().eq("code","removeCrnAvailableOut")); |
|---|
| | | if (config != null && config.getStatus() == 1) { |
|---|
| | | crnAvailableOut = true; |
|---|
| | | } |
|---|
| | | for (CrnSlave.CrnStn crnStn : slave.getCrnOutStn()) { |
|---|
| | | // 获取工作状态为11（生成出库ID）的出库工作档 |
|---|
| | | List<WrkMast> wrkMasts = wrkMastMapper.selectPakOutStep11(slave.getId(), crnStn.getStaNo()); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 判断堆垛机出库站状态 |
|---|
| | | if (staProtocol.isAutoing() && !staProtocol.isLoading() && staDetl.getCanouting() != null && staDetl.getCanouting().equals("Y") |
|---|
| | | && staProtocol.getWorkNo() == 0 && staProtocol.isOutEnable()) { |
|---|
| | | if (staProtocol.isAutoing() && staDetl.getCanouting() != null && staDetl.getCanouting().equals("Y") |
|---|
| | | && (crnAvailableOut || !staProtocol.isLoading() && staProtocol.getWorkNo() == 0 && staProtocol.isOutEnable())) { |
|---|
| | | // 堆垛机控制过滤 |
|---|
| | | if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) { |
|---|
| | | // continue; |
|---|
| | |
|---|
| | | wrkMast.setCrnNo(crn.getId()); |
|---|
| | | wrkMast.setSourceLocNo(shallowLoc.getLocNo()); // 源库位 |
|---|
| | | wrkMast.setLocNo(loc.getLocNo()); // 目标库位 |
|---|
| | | wrkMast.setFullPlt(shallowLoc.getFullPlt()); // 满板 |
|---|
| | | wrkMast.setFullPlt(shallowLoc.getLocSts().equals("F") ? "Y" : "N"); // 满板 |
|---|
| | | wrkMast.setPicking("N"); // 拣料 |
|---|
| | | wrkMast.setExitMk("N"); // 退出 |
|---|
| | | wrkMast.setEmptyMk(shallowLoc.getLocSts().equals("D") ? "Y" : "N"); // 空板 |
|---|
