| | |
|---|
| | | LocTypeDto locTypeDto = new LocTypeDto(staProtocol); |
|---|
| | | |
|---|
| | | SearchLocParam param = new SearchLocParam(); |
|---|
| | | param.setIoType(10); |
|---|
| | | if (emptyInSta.getStaNo().equals(214)){ |
|---|
| | | //拆盘机处空板扫码，驱动托盘向码垛位，不入库 |
|---|
| | | param.setIoType(201); |
|---|
| | | }else { |
|---|
| | | param.setIoType(10); |
|---|
| | | } |
|---|
| | | param.setSourceStaNo(emptyInSta.getStaNo()); |
|---|
| | | param.setLocType1(locTypeDto.getLocType1()); |
|---|
| | | String response = new HttpHandler.Builder() |
|---|
| | |
|---|
| | | e.printStackTrace(); |
|---|
| | | TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | // // 检索库位 |
|---|
| | | // LocTypeDto locTypeDto = new LocTypeDto(staProtocol); |
|---|
| | | // StartupDto startupDto = commonService.getLocNo(1, 10, emptyInSta.getStaNo(), null, locTypeDto, 0); |
|---|
| | | // // 工作号 |
|---|
| | | // int workNo = startupDto.getWorkNo(); |
|---|
| | | // |
|---|
| | | // try { |
|---|
| | | // // 插入工作主档 |
|---|
| | | // WrkMast wrkMast = new WrkMast(); |
|---|
| | | // wrkMast.setWrkNo(workNo); |
|---|
| | | // wrkMast.setIoTime(new Date()); |
|---|
| | | // wrkMast.setWrkSts(2L); // 工作状态：2.设备上走 |
|---|
| | | // wrkMast.setIoType(10); // 入出库状态：10.空板入库 |
|---|
| | | // wrkMast.setIoPri(10D); // 优先级：10 |
|---|
| | | // wrkMast.setCrnNo(startupDto.getCrnNo()); |
|---|
| | | // wrkMast.setSourceStaNo(startupDto.getSourceStaNo()); |
|---|
| | | // wrkMast.setStaNo(startupDto.getStaNo()); |
|---|
| | | // wrkMast.setLocNo(startupDto.getLocNo()); |
|---|
| | | // wrkMast.setFullPlt("N"); // 满板 |
|---|
| | | // wrkMast.setPicking("N"); // 拣料 |
|---|
| | | // wrkMast.setExitMk("N"); // 退出 |
|---|
| | | // wrkMast.setEmptyMk("Y"); // 空板 |
|---|
| | | // wrkMast.setLinkMis("N"); |
|---|
| | | //// wrkMast.setCtnType(sourceStaNo.getCtnType()); // 容器类型 |
|---|
| | | // // 操作人员数据 |
|---|
| | | // wrkMast.setAppeTime(new Date()); |
|---|
| | | // wrkMast.setModiTime(new Date()); |
|---|
| | | // Integer insert = wrkMastMapper.insert(wrkMast); |
|---|
| | | // if (insert == 0) { |
|---|
| | | // throw new CoolException("保存工作档失败"); |
|---|
| | | // } |
|---|
| | | // // 更新目标库位状态 |
|---|
| | | // LocMast locMast = locMastService.selectById(startupDto.getLocNo()); |
|---|
| | | // locMast.setLocSts("S"); // S.入库预约 |
|---|
| | | // locMast.setModiTime(new Date()); |
|---|
| | | // if (!locMastService.updateById(locMast)){ |
|---|
| | | // throw new CoolException("改变库位状态失败"); |
|---|
| | | // } |
|---|
| | | // // 命令下发区 -------------------------------------------------------------------------- |
|---|
| | | // |
|---|
| | | // // 更新站点信息 且 下发plc命令 |
|---|
| | | // staProtocol.setWorkNo((short) workNo); |
|---|
| | | // staProtocol.setStaNo(startupDto.getStaNo().shortValue()); |
|---|
| | | // devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | // boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | // if (!result) { |
|---|
| | | // throw new CoolException("更新plc站点信息失败"); |
|---|
| | | // } |
|---|
| | | // } catch (Exception e) { |
|---|
| | | // e.printStackTrace(); |
|---|
| | | // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); |
|---|
| | | // } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | StaProtocol staProtocol214 = devpThread.getStation().get(214); |
|---|
| | | // 判断是否满足入库条件 |
|---|
| | | if (staProtocol.isAutoing() && staProtocol.getWorkNo() == 0 && staProtocol.isPakMk()) { |
|---|
| | | if (staProtocol.isAutoing() && staProtocol.getWorkNo() == 0 && staProtocol.isPakMk() && staProtocol214.getWorkNo()==0) { |
|---|
| | | staProtocol.setWorkNo((short)9999); |
|---|
| | | staProtocol.setStaNo((short)214); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | |
|---|
| | | */ |
|---|
| | | public synchronized void stackingCompletionDriveTray() { |
|---|
| | | try { |
|---|
| | | List<WrkMast> wrkMasts = wrkMastMapper.selectStackingCompletionDriveTray(); |
|---|
| | | if (Cools.isEmpty(wrkMasts) || wrkMasts.size()==0){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | for (WrkMast wrkMast : wrkMasts){ |
|---|
| | | wrkMast.setWrkSts(44L); |
|---|
| | | // 获取入库站信息 |
|---|
| | | SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1); |
|---|
| | | StaProtocol staProtocol = devpThread.getStation().get(wrkMast.getStaNo()); |
|---|
| | | if (staProtocol == null) { |
|---|
| | | log.error("码垛位自动补充空板：驱动拆盘机输出托盘，任务下发失败，站点查询失败"); |
|---|
| | | return; |
|---|
| | | } else { |
|---|
| | | staProtocol = staProtocol.clone(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (!staProtocol.isLoading()){ |
|---|
| | | log.info("码垛位自动补充空板：驱动拆盘机输出托盘，任务下发失败，站点无物，正在自动调出空板！"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // 判断是否满足入库条件 |
|---|
| | | if (staProtocol.isAutoing() && staProtocol.getWorkNo().equals(wrkMast.getWrkNo().shortValue()) && staProtocol.isPakMk()) { |
|---|
| | | staProtocol.setWorkNo((short)9999); |
|---|
| | | int staNo = wrkMast.getStaNo() + 1; |
|---|
| | | staProtocol.setStaNo((short)staNo); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | boolean result = MessageQueue.offer(SlaveType.Devp, devpThread.getSlave().getId(), new Task(2, staProtocol)); |
|---|
| | | if (!result) { |
|---|
| | | throw new CoolException("更新plc站点信息失败==>码垛位自动补充空板：驱动拆盘机输出托盘！"); |
|---|
| | | } |
|---|
| | | log.info("码垛位自动补充空板：驱动拆盘机输出托盘，任务下发成功：工作号9999、目标站214！"); |
|---|
| | | wrkMastMapper.updateStackingCompletionDriveTray(wrkMast.getWrkNo()); |
|---|
| | | }else { |
|---|
| | | log.error("码垛位自动补充空板：驱动拆盘机输出托盘，任务下发失败，站点状态不符合！"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | e.printStackTrace(); |
|---|
| | | TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); |
|---|
