#

Junjie

3 天以前 2f9849905dbb8d65faa28628a40084708a0386ef

 src/main/java/com/zy/core/network/fake/ZyStationFakeConnect.java

@@ -3,7 +3,9 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.core.common.SpringUtils;
import com.zy.asrs.entity.BasStation;
import com.zy.asrs.entity.DeviceConfig;
import com.zy.asrs.service.BasStationService;
import com.zy.common.model.NavigateNode;
import com.zy.common.utils.NavigateUtils;
import com.zy.common.utils.RedisUtil;
@@ -99,6 +101,16 @@
        return new CommandResponse(true, "命令已受理（异步执行）");
    }

    @Override
    public CommandResponse sendOriginCommand(String address, short[] data) {
        return new CommandResponse(true, "原始命令已受理（异步执行）");
    }

    @Override
    public byte[] readOriginCommand(String address, int length) {
        return new byte[0];
    }

    private void handleCommand(Integer deviceNo, StationCommand command) {
        News.info("[WCS Debug] 站点仿真模拟已启动，命令数据={}", JSON.toJSONString(command));
        Integer taskNo = command.getTaskNo();
@@ -191,12 +203,9 @@
        Integer stationId = command.getStationId();
        Integer targetStationId = command.getTargetStaNo();

        String startLev = String.valueOf(stationId).substring(0, 1);

        List<NavigateNode> navigateNodes = null;

        try {
            navigateNodes = navigateUtils.calcByStationId(Integer.parseInt(startLev), stationId, targetStationId);
            navigateNodes = navigateUtils.calcByStationId(stationId, targetStationId);
        } catch (Exception e) {
            e.printStackTrace();
        }
@@ -209,6 +218,10 @@
    }

    private void diffLevCommand(StationCommand command, boolean generateBarcode) {
        BasStationService basStationService = SpringUtils.getBean(BasStationService.class);
        if (basStationService == null) {
            return;
        }
        NavigateUtils navigateUtils = SpringUtils.getBean(NavigateUtils.class);
        if (navigateUtils == null) {
            return;
@@ -218,20 +231,27 @@
        Integer stationId = command.getStationId();
        Integer targetStationId = command.getTargetStaNo();

        String startLev = String.valueOf(stationId).substring(0, 1);
        String endLev = String.valueOf(targetStationId).substring(0, 1);
        
        List<NavigateNode> navigateNodes = null;
        List<NavigateNode> targetNavigateNodes = null;

        try {
            List<NavigateNode> liftStationList = navigateUtils.findLiftStationList(Integer.parseInt(startLev));
            BasStation startStation = basStationService.selectById(stationId);
            if (startStation == null) {
                return;
            }

            BasStation targetStation = basStationService.selectById(targetStationId);
            if (targetStation == null) {
                return;
            }

            List<NavigateNode> liftStationList = navigateUtils.findLiftStationList(startStation.getStationLev());
            if(liftStationList.isEmpty()){
                //未找到提升机节点
                return;
            }

            List<NavigateNode> targetLiftStationList = navigateUtils.findLiftStationList(Integer.parseInt(endLev));
            List<NavigateNode> targetLiftStationList = navigateUtils.findLiftStationList(targetStation.getStationLev());
            if(targetLiftStationList.isEmpty()){
                //未找到提升机节点
                return;
@@ -261,13 +281,13 @@
                    continue;
                }

                navigateNodes = navigateUtils.calcByStationId(Integer.parseInt(startLev), stationId, liftStationId);
                navigateNodes = navigateUtils.calcByStationId(stationId, liftStationId);
                if(navigateNodes == null){
                    continue;
                }

                //计算提升机到目标站的路径
                targetNavigateNodes = navigateUtils.calcByStationId(Integer.parseInt(endLev), targetLiftStationId, targetStationId);
                targetNavigateNodes = navigateUtils.calcByStationId(targetLiftStationId, targetStationId);
                if(targetNavigateNodes == null) {
                    continue;
                }
@@ -306,8 +326,9 @@

            Integer nextStationId = null;
            Integer nextStationDeviceNo = null;
            NavigateNode nextNode = null;
            try {
                NavigateNode nextNode = navigateNodes.get(i + 1);
                nextNode = navigateNodes.get(i + 1);
                JSONObject nextValueObject = JSON.parseObject(nextNode.getNodeValue());
                nextStationId = nextValueObject.getInteger("stationId");
                nextStationDeviceNo = nextValueObject.getInteger("deviceNo");
@@ -352,6 +373,10 @@
                    continue;
                }
                lastStationId = currentStationId;

                if (nextNode.getIsInflectionPoint()) {
                    sleep(4000);
                }
            }

            i++;
@@ -617,7 +642,7 @@
        return executeResult;
    }

    public synchronized boolean lockExecute(Integer taskNo, Supplier<Boolean> function) {
    public boolean lockExecute(Integer taskNo, Supplier<Boolean> function) {
        if (!setLockStation(taskNo)) {
            return false;
        }
@@ -627,7 +652,7 @@
        return result;
    }

    private synchronized boolean checkTaskNoInArea(Integer taskNo) {
    private boolean checkTaskNoInArea(Integer taskNo) {
        Object fakeTaskNoAreaObj = redisUtil.get(RedisKeyType.FAKE_TASK_NO_AREA.key);
        if (fakeTaskNoAreaObj == null) {
            return false;