| | |
|---|
| | | |
|---|
| | | // } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public synchronized void inOutSwap() { |
|---|
| | | SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1); |
|---|
| | | StaProtocol staProtocol = devpThread.getStation().get(305); |
|---|
| | | if (staProtocol == null) { |
|---|
| | | return; |
|---|
| | | } else { |
|---|
| | | staProtocol = staProtocol.clone(); |
|---|
| | | } |
|---|
| | | if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.getWorkNo() > 6000 && staProtocol.getWorkNo() <= 9000) { |
|---|
| | | |
|---|
| | | List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("wrk_sts", 1L).eq("io_type", 1) |
|---|
| | | .eq("source_sta_no", 305).orderBy("appe_time", true)); |
|---|
| | | for (WrkMast wrkMast : wrkMasts) { |
|---|
| | | wrkMast.setWhsType(3); |
|---|
| | | wrkMastService.updateById(wrkMast); |
|---|
| | | |
|---|
| | | staProtocol.setWorkNo(wrkMast.getWrkNo()); |
|---|
| | | staProtocol.setStaNo((short) 0); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); |
|---|
| | | |
|---|
| | | log.info("出库任务完成转入库,任务号：{}，目标站：{}-----", wrkMast.getWrkNo(), wrkMast.getStaNo()); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
