| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | public synchronized void invokingBase() { |
|---|
| | | WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_sts", 1L).eq("io_type", 1) |
|---|
| | | .eq("source_sta_no", 305)); |
|---|
| | | if (wrkMast != null) { |
|---|
| | | int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("wrk_sts", 2L).eq("io_type", 1) |
|---|
| | | .eq("source_sta_no", 305)); |
|---|
| | | if (count != 0) { |
|---|
| | | log.warn("存在305入库任务，状态为设备上走"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1); |
|---|
| | | StaProtocol staProtocol= devpThread.getStation().get(wrkMast.getStaNo()); |
|---|
| | | if (staProtocol == null) { |
|---|
| | | return; |
|---|
| | | } else { |
|---|
| | | staProtocol = staProtocol.clone(); |
|---|
| | | } |
|---|
| | | if(staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.getWorkNo() == 0) { |
|---|
| | | staProtocol.setWorkNo(wrkMast.getWrkNo()); |
|---|
| | | staProtocol.setStaNo(wrkMast.getSourceStaNo().shortValue()); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | boolean result = MessageQueue.offer(SlaveType.Devp,1, new Task(2, staProtocol)); |
|---|
| | | log.info("入库请求底座------"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_sts", 1L).eq("io_type", 1) |
|---|
| | | // .eq("source_sta_no", 305)); |
|---|
| | | // if (wrkMast != null) { |
|---|
| | | // int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("wrk_sts", 2L).eq("io_type", 1) |
|---|
| | | // .eq("source_sta_no", 305)); |
|---|
| | | // if (count != 0) { |
|---|
| | | // log.warn("存在305入库任务，状态为设备上走"); |
|---|
| | | // return; |
|---|
| | | // } |
|---|
| | | List<WrkMast> wrkMastList = 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 : wrkMastList) { |
|---|
| | | SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1); |
|---|
| | | StaProtocol staProtocol= devpThread.getStation().get(wrkMast.getStaNo()); |
|---|
| | | if (staProtocol == null) { |
|---|
| | | return; |
|---|
| | | } else { |
|---|
| | | staProtocol = staProtocol.clone(); |
|---|
| | | } |
|---|
| | | if(staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.getWorkNo() == 0) { |
|---|
| | | staProtocol.setWorkNo(wrkMast.getWrkNo()); |
|---|
| | | staProtocol.setStaNo(wrkMast.getSourceStaNo().shortValue()); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | MessageQueue.offer(SlaveType.Devp,1, new Task(2, staProtocol)); |
|---|
| | | log.info("入库请求底座-,任务号：{}，目标站：{}-----", wrkMast.getWrkNo(), wrkMast.getStaNo()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // } |
|---|
| | | } |
|---|
| | | } |
|---|
