#

luxiaotao1123

2024-11-26 c7ac2c8bb899b0785daaa9f72a69581bdb93fef1

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

@@ -9,6 +9,7 @@
import com.zy.acs.manager.common.utils.MapDataUtils;
import com.zy.acs.manager.core.domain.BlockVehicleDto;
import com.zy.acs.manager.core.domain.TaskPosDto;
import com.zy.acs.manager.core.domain.type.BlockSeverityType;
import com.zy.acs.manager.core.service.astart.MapDataDispatcher;
import com.zy.acs.manager.core.service.astart.RetreatNavigateNode;
import com.zy.acs.manager.core.service.astart.WaveNodeType;
@@ -199,17 +200,18 @@
        String agvNo = agv.getUuid();
        Date now = new Date();
        Jam jam = jamService.getJam(agv.getId(), startCode.getId(), segment.getId());
        BlockSeverityType blockSeverity = BlockSeverityType.query(null == jam ? null : jam.getDuration());
        // judge avoid of jam
        List<Jam> unfinishedOriginJamByCurrAgv = jamService.hasUnfinishedOriginJamByAvo(agv.getId(), startCode.getId(), segment.getId());
        List<Jam> unfinishedOriginJamByCurrAgv = jamService.getUnfinishedOriginJamByAvo(agv.getId(), startCode.getId(), segment.getId());
        List<String> blackPath = this.getBlackPathList(unfinishedOriginJamByCurrAgv);

        // 结果集
        List<String> pathList = new ArrayList<>();

        // 无障碍解
        List<String> unlockPathList = mapService.checkoutPath(agvNo, startCode, endCode, false);
        List<String> unlockPathList = mapService.checkoutPath(agvNo, startCode, endCode, false, blackPath, segment);
        // 避让解
        List<String> lockPathList = mapService.checkoutPath(agvNo, startCode, endCode, true);
        List<String> lockPathList = mapService.checkoutPath(agvNo, startCode, endCode, true, blackPath, segment);

        if (!Cools.isEmpty(lockPathList) && // 存在避让解
            Math.abs(lockPathList.size() - unlockPathList.size()) <= Arrays.stream(mapDataDispatcher.getCodeMatrix(lev)).mapToInt(row -> row.length).sum() / 10
@@ -218,8 +220,18 @@
            pathList = lockPathList;
        } else {

            // preview path
            List<String> draftPath = new ArrayList<>(unlockPathList);
            if (blockSeverity.equals(BlockSeverityType.SEVERE)) {
                unlockPathList.remove(endCode.getData());
                blackPath.addAll(unlockPathList);
                List<String> newUnlockPathList = mapService.checkoutPath(agvNo, startCode, endCode, false, blackPath, segment);
                if (!Cools.isEmpty(newUnlockPathList)) {
                    draftPath = newUnlockPathList;
                }
            }
            // 可走行路径集合计算
            List<BlockVehicleDto> blockVehicleList = this.slicePathAndReturnBlockVehicleList(lev, unlockPathList, agvNo, pathList);    // jamAgvNo may was wave
            List<BlockVehicleDto> blockVehicleList = this.slicePathAndReturnBlockVehicleList(lev, draftPath, agvNo, pathList);    // jamAgvNo may was wave

            if (!Cools.isEmpty(pathList)) {

@@ -252,8 +264,7 @@
                    Integer maxJamTimeoutFactor = null;

                    // persist jam data
                    ArrayList<String> jamPath = new ArrayList<>(unlockPathList);
                    jam = this.createOrUpdateJam(agv, startCode, segment, jam, jamPath);
                    jam = this.createOrUpdateJam(agv, startCode, segment, jam, draftPath);

                    // ? has unAvoidable block vehicles
                    if (blockVehicleList.stream().anyMatch(blockVehicleDto -> !blockVehicleDto.isAvoidable())) {
@@ -271,47 +282,54 @@
                        } else {

                            // select optimal block vehicle
                            String blockAgvNo = blockVehicleList.stream()
                                    .filter(BlockVehicleDto::isAvoidable)
                                    .map(BlockVehicleDto::getVehicle)
                                    .findFirst().orElse(null);
                            String blockAgvNo = this.checkoutBestSolutionOfBlocks(blockVehicleList);
                            if (Cools.isEmpty(blockAgvNo)) {

                            // block vehicle info
                            Agv blockAgv = agvService.selectByUuid(blockAgvNo);
                            String blockAgvCode = codeService.getById(agvDetailService.selectByAgvId(blockAgv.getId()).getRecentCode()).getData();
                                maxJamTimeoutFactor = 2;

                            do {
                            } else {

                                // 阻塞车辆正在原地作业，等待 ===>> 超过等待时间，绕路
                                List<Segment> runningSegList = segmentService.getByAgvAndState(blockAgv.getId(), SegmentStateType.RUNNING.toString());
                                if (!Cools.isEmpty(runningSegList)) {
                                    maxJamTimeoutFactor = 1;
                                    break;
                                }
                                // block vehicle info
                                Agv blockAgv = agvService.selectByUuid(blockAgvNo);
                                String blockAgvCode = codeService.getById(agvDetailService.selectByAgvId(blockAgv.getId()).getRecentCode()).getData();

                                // 判断下个任务是否为原地任务，如果是则等待 ===>> 超过等待时间，绕路；如果不是，让阻塞车辆避让
                                Segment waitingSeg = segmentService.getJustWaitingSeg(blockAgv.getId());
                                if (null != waitingSeg && waitingSeg.getEndNode().equals(codeService.selectByData(blockAgvCode).getId())) {
                                    maxJamTimeoutFactor = 1;
                                    break;
                                }
                                do {

                                // notify block vehicle to avoid
                                if (this.notifyVehicleAvoid(blockAgvNo, blockAgvCode, jamPath, agvNo, jam)) {
                                    if (jam.getCycleAvo() == 1) {
                                        jam.setCycleCode(endCode.getId());
                                    // 阻塞车辆正在原地作业，等待 ===>> 超过等待时间，绕路
                                    List<Segment> runningSegList = segmentService.getByAgvAndState(blockAgv.getId(), SegmentStateType.RUNNING.toString());
                                    if (!Cools.isEmpty(runningSegList)) {
                                        maxJamTimeoutFactor = 1;
                                        break;
                                    }
                                    jam.setAvoAgv(blockAgv.getId());
                                    jam.setNotifyTime(new Date());
                                    if (!jamService.updateById(jam)) {
                                        throw new CoolException(jam.getUuid() + "-jam failed to update！！！");

                                    // 判断下个任务是否为原地任务，如果是则等待 ===>> 超过等待时间，绕路；如果不是，让阻塞车辆避让
                                    List<Segment> waitingSegList = segmentService.getJustWaitingSeg(blockAgv.getId());
                                    if (null != waitingSegList
                                            && waitingSegList.stream().anyMatch(
                                            waitingSeg -> waitingSeg.getEndNode().equals(codeService.selectByData(blockAgvCode).getId())
                                    )) {
                                        maxJamTimeoutFactor = 1;
                                        break;
                                    }
                                } else {

                                    maxJamTimeoutFactor = 1;
                                }
                                    // notify block vehicle to avoid
                                    if (this.notifyVehicleAvoid(blockAgvNo, blockAgvCode, draftPath, agvNo, jam)) {
                                        if (jam.getCycleAvo() == 1) {
                                            jam.setCycleCode(endCode.getId());
                                        }
                                        jam.setAvoAgv(blockAgv.getId());
                                        jam.setNotifyTime(new Date());
                                        if (!jamService.updateById(jam)) {
                                            throw new CoolException(jam.getUuid() + "-jam failed to update！！！");
                                        }
                                    } else {

                            } while (false);
                                        maxJamTimeoutFactor = 1;
                                    }

                                } while (false);
                            }

                        }

                    }
@@ -437,6 +455,10 @@
        List<Segment> waitingSegList = segmentService.getByAgvAndState(agv.getId(), SegmentStateType.WAITING.toString());
        if (!Cools.isEmpty(waitingSegList)) {

            if (waitingSegList.size() > 1) {
                log.error("避让通知失败，{}号车辆存在多个等待中的Segment！！！", agvNo);
                return false;
            }
            // revert
            Date now = new Date();
            for (Segment seg : waitingSegList) {
@@ -500,7 +522,21 @@
        if (!Cools.isEmpty(unfinishedOriginJamByCurrAgv)) {
            for (Jam jam : unfinishedOriginJamByCurrAgv) {
                if (!Cools.isEmpty(jam.getJamPath())) {

                    List<String> list = GsonUtils.fromJsonToList(jam.getJamPath(), String.class);

                    Agv jamAgv = agvService.getById(jam.getJamAgv());
                    List<String> jamDynamicNodes = mapDataDispatcher.queryCodeListFromDynamicNode(null, jamAgv.getUuid());
                    // jamDynamicNodes has sorted
                    String firstCodeNode = jamDynamicNodes.stream().findFirst().orElse(null);

                    if (!Cools.isEmpty(firstCodeNode)) {
                        int idx = list.indexOf(firstCodeNode);
                        if (idx != -1) {
                            list = new ArrayList<>(list.subList(idx, list.size()));
                        }
                    }

                    blackPathList.addAll(list);
                }
            }
@@ -508,4 +544,18 @@
        return blackPathList.stream().distinct().collect(Collectors.toList());
    }

    private String checkoutBestSolutionOfBlocks(List<BlockVehicleDto> blockVehicleList) {
        assert !Cools.isEmpty(blockVehicleList);
        for (BlockVehicleDto blockVehicleDto : blockVehicleList) {
            if (!blockVehicleDto.isAvoidable()) {
                continue;
            }
            // 没有避让中的任务
            if (Cools.isEmpty(jamService.getUnfinishedAvoSegByAvo(blockVehicleDto.getVehicle(), null))) {
                return blockVehicleDto.getVehicle();
            }
        }
        return null;
    }

}