| | |
| | | continue; |
| | | } |
| | | |
| | | List<Integer> liftAllStaNo = ForkLiftUtils.getLiftAllStaNo(liftNo); |
| | | if (liftAllStaNo.isEmpty()) { |
| | | continue; |
| | | } |
| | | |
| | | //获取入库任务 |
| | | List<WrkMast> inWrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>() |
| | | .eq("lift_no", liftNo) |
| | | .in("sta_no", liftAllStaNo) |
| | | .in("wrk_sts" |
| | | , WrkStsType.NEW_INBOUND.sts |
| | | , WrkStsType.INBOUND_DEVICE_RUN.sts |
| | |
| | | |
| | | //获取出库任务 |
| | | List<WrkMast> outWrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>() |
| | | .eq("lift_no", liftNo) |
| | | .in("source_sta_no", liftAllStaNo) |
| | | .in("wrk_sts" |
| | | , WrkStsType.NEW_OUTBOUND.sts |
| | | , WrkStsType.OUTBOUND_SHUTTLE_RUN.sts |
| | |
| | | */ |
| | | public class ForkLiftUtils { |
| | | |
| | | //获取提升机所有站点 |
| | | public static List<Integer> getLiftAllStaNo(Integer liftNo) { |
| | | List<Integer> list = new ArrayList<>(); |
| | | ForkLiftThread forkLiftThread = (ForkLiftThread) SlaveConnection.get(SlaveType.ForkLift, liftNo); |
| | | if (forkLiftThread == null) { |
| | | return list; |
| | | } |
| | | |
| | | for (ForkLiftStaProtocol forkLiftStaProtocol : forkLiftThread.getForkLiftStaProtocols()) { |
| | | list.add(forkLiftStaProtocol.getStaNo()); |
| | | } |
| | | |
| | | return list; |
| | | } |
| | | |
| | | //获取提升机站点 |
| | | public static ForkLiftStaProtocol getLiftStaByStaNo(Integer staNo) { |
| | | SlaveProperties slaveProperties = SpringUtils.getBean(SlaveProperties.class); |