| | |
| | | param.setIoType(1); |
| | | param.setSourceStaNo(inSta.getStaNo()); |
| | | param.setLocType1(locTypeDto.getLocType1()); |
| | | param.setFull(staProtocol.isFull()); |
| | | String response = new HttpHandler.Builder() |
| | | .setUri(wmsUrl) |
| | | .setPath("/rpc/pakin/loc/v1") |
| | |
| | | * 扫描碟盘机自动入库空托盘 |
| | | */ |
| | | public synchronized void autoEmptyIn() { |
| | | for (CrnSlave crnSlave : slaveProperties.getCrn()) { |
| | | // 遍历空板入库口 |
| | | for (CrnSlave.CrnStn emptyInStn : crnSlave.getEmptyCrnInStn()) { |
| | | for (DevpSlave slave : slaveProperties.getDevp()) { |
| | | for (DevpSlave.Sta sta : slave.getAutoEmptyIn()) { |
| | | // 获取空板入库站信息 |
| | | SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, emptyInStn.getDevpPlcId()); |
| | | StaProtocol staProtocol = devpThread.getStation().get(emptyInStn.getStaNo()); |
| | | SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, slave.getId()); |
| | | StaProtocol staProtocol = devpThread.getStation().get(sta.getStaNo()); |
| | | if (staProtocol == null) { |
| | | continue; |
| | | } else { |
| | |
| | | |
| | | SearchLocParam param = new SearchLocParam(); |
| | | param.setIoType(10); |
| | | param.setSourceStaNo(emptyInStn.getStaNo()); |
| | | param.setSourceStaNo(sta.getStaNo()); |
| | | param.setLocType1(locTypeDto.getLocType1()); |
| | | String response = new HttpHandler.Builder() |
| | | .setUri(wmsUrl) |
| | |
| | | e.printStackTrace(); |
| | | TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | |
| | | * 扫描拆盘机自动出库空托盘 |
| | | */ |
| | | public synchronized void autoEmptyOut() { |
| | | for (CrnSlave crnSlave : slaveProperties.getCrn()) { |
| | | for (CrnSlave.CrnStn emptyOutStn : crnSlave.getEmptyCrnOutStn()) { |
| | | DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, emptyOutStn.getDevpPlcId()); |
| | | StaProtocol staProtocol = devpThread.getStation().get(emptyOutStn.getStaNo()); |
| | | for (DevpSlave slave : slaveProperties.getDevp()) { |
| | | for (DevpSlave.Sta sta : slave.getAutoEmptyOut()) { |
| | | DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, slave.getId()); |
| | | StaProtocol staProtocol = devpThread.getStation().get(sta.getStaNo()); |
| | | if (staProtocol == null) { |
| | | return; |
| | | } else { |
| | |
| | | |
| | | if (staProtocol.isAutoing() //自动 |
| | | && !staProtocol.isLoading() //无物 |
| | | && staProtocol.isOutEnable() //可出信号 |
| | | && staProtocol.isEmptyPalletRequire() //空托盘需求信号 |
| | | && staProtocol.getWorkNo() == 0 |
| | | ) { |
| | | WrkMast pakoutEmpty = wrkMastMapper.selectPakoutEmpty(emptyOutStn.getStaNo()); |
| | | WrkMast pakoutEmpty = wrkMastMapper.selectPakoutEmpty(sta.getStaNo()); |
| | | if (null != pakoutEmpty) { |
| | | return; |
| | | } |
| | | try { |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("crnNo", crnSlave.getId()); |
| | | map.put("staNo", sta.getStaNo());//目标站 |
| | | String response = new HttpHandler.Builder() |
| | | .setUri(wmsUrl) |
| | | .setParams(map) |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | } |