| | |
|---|
| | | , (task, agvNo, sta) -> { |
|---|
| | | Long agvId = agvService.getAgvId(agvNo); |
|---|
| | | |
|---|
| | | // List<Travel> travelList = travelService.list(new LambdaQueryWrapper<Travel>() |
|---|
| | | // .eq(Travel::getAgvId, agvId) |
|---|
| | | // .eq(Travel::getState, TravelStateType.RUNNING.toString()) |
|---|
| | | // .orderByDesc(Travel::getCreateTime)); |
|---|
| | | // if (Cools.isEmpty(travelList)) { |
|---|
| | | // throw new BusinessException("[Agv: " + agvNo + "]allocate inbound failed to find travel"); |
|---|
| | | // } |
|---|
| | | // Travel travel = travelList.get(0); |
|---|
| | | // |
|---|
| | | // List<Segment> currSegments = segmentService.list(new LambdaQueryWrapper<Segment>() |
|---|
| | | // .eq(Segment::getAgvId, agvId) |
|---|
| | | // .eq(Segment::getTravelId, travel.getId()) |
|---|
| | | // ); |
|---|
| | | // load segment |
|---|
| | | Segment currSeg = segmentService.getRollerWaiting(agvId, sta.getCode(), TaskPosDto.PosType.ORI_STA); |
|---|
| | | Travel travel = travelService.findRunningTravel(agvId); |
|---|
| | | if (null == travel) { |
|---|
| | | throw new CoolException("[Agv:" + agvNo + "] allocate inbound failed: no roller waiting travel"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // curr segment |
|---|
| | | Segment currSeg = segmentService.getCurrWaitingSeg(travel.getId(), agvId); |
|---|
| | | if (null == currSeg) { |
|---|
| | | throw new BusinessException("[Agv:" + agvNo + "] allocate inbound failed: no roller waiting segment"); |
|---|
| | | throw new CoolException("[Agv:" + agvNo + "] allocate inbound failed: no waiting segment"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // get backpack lev |
|---|
