#

vincentlu

6 天以前 b033217d3193b2f5ebabb43cce4c7cb2776df6ee

 zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java

@@ -23,6 +23,7 @@
import com.zy.acs.manager.core.domain.AgvBackpackDto;
import com.zy.acs.manager.core.domain.Lane;
import com.zy.acs.manager.core.domain.TaskPosDto;
import com.zy.acs.manager.core.integrate.conveyor.ConveyorStationService;
import com.zy.acs.manager.core.service.astart.MapDataDispatcher;
import com.zy.acs.manager.manager.controller.param.OpenBusSubmitParam;
import com.zy.acs.manager.manager.entity.*;
@@ -93,7 +94,7 @@
    @Autowired
    private AgvModelService agvModelService;
    @Autowired
    private LaneService laneService;
    private LaneBuilder laneBuilder;
    @Autowired
    private ActionSorter actionSorter;
    @Autowired
@@ -447,7 +448,7 @@
                                throw new BusinessException("seqNum: " + task.getSeqNum() + " failed to update");
                            }
                            // update reserve
                            staReserveService.allocateCallBack(sta, task, agvId);
                            staReserveService.allocateCallBack(task, agvId);
                        }
                        // normal
                        , (task, agvNo, sta) -> {
@@ -461,7 +462,7 @@
                                throw new BusinessException("seqNum: " + task.getSeqNum() + " failed to update");
                            }
                            // update reserve
                            staReserveService.allocateCallBack(sta, task, agvId);
                            staReserveService.allocateCallBack(task, agvId);
                        });
//                if (Cools.isEmpty(agvNo)) {
////                    log.warn("Task[{}] has an issue， because it failed to check out agv which is idle...", task.getSeqNum());
@@ -669,6 +670,7 @@


            // generate travel
            travelService.finishAll(agvId);
            Travel travel = new Travel();
            travel.setUuid(String.valueOf(snowflakeIdWorker.nextId()).substring(3));
            travel.setTravelId(String.valueOf(snowflakeIdWorker.nextId()).substring(3));
@@ -790,7 +792,7 @@
            task.setOriCode(agvDetail.getCode());
            task.setDestCode(endCode.getId());
            // lane
            Lane destLane = laneService.search(endCode.getData());
            Lane destLane = laneBuilder.search(endCode.getData());
            if (null != destLane) {
                task.setDestLaneHash(destLane.getHashCode());
            }
@@ -804,6 +806,7 @@
            }

            // generate travel
            travelService.finishAll(agvId);
            Travel travel = new Travel();
            travel.setUuid(String.valueOf(snowflakeIdWorker.nextId()).substring(3));
            travel.setTravelId(String.valueOf(snowflakeIdWorker.nextId()).substring(3));