1

zhang

4 天以前 1930fa774bec2a088cc2cdb83dbf359168c6798f

1

 src/main/java/com/zy/asrs/domain/vo/StationStatus.java

New file
@@ -0,0 +1,13 @@
package com.zy.asrs.domain.vo;

import lombok.Data;

import java.io.Serializable;

@Data
public class StationStatus implements Serializable {

    private String staNo;

    private Boolean conveyable;
}

 src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java

@@ -1,9 +1,11 @@
package com.zy.asrs.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.core.exception.CoolException;
import com.zy.asrs.controller.requestParam.StationRequestParam;
import com.zy.asrs.domain.vo.StationStatus;
import com.zy.common.utils.HttpHandler;
import com.zy.common.utils.News;
import com.zy.core.cache.MessageQueue;
@@ -142,16 +144,18 @@
            return;
        }
        if (staProtocol.getWorkNo() > 0 && staProtocol.isAutoing() && !staProtocol.isEmptyMk() && staProtocol.isPakMk()) {
            Integer workNo = staProtocol.getWorkNo();
            staProtocol.setWorkNo(0);
            staProtocol.setStaNo((short) 0);
            boolean result = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
            log.info("1007站点清空：{},{}", staProtocol.getWorkNo(), 1006);
            StaProtocol staProtocol1006 = devpThread.getStation().get(1006);
            staProtocol1006.setWorkNo(workNo);
            staProtocol1006.setStaNo((short) 1007);
            boolean result2 = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
            log.info("1006站点往前走一格：{},{}", staProtocol.getWorkNo(), 1007);
            if (station(1007)) {
                Integer workNo = staProtocol.getWorkNo();
                staProtocol.setWorkNo(0);
                staProtocol.setStaNo((short) 0);
                boolean result = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
                log.info("1007站点清空：{},{}", staProtocol.getWorkNo(), 1006);
                StaProtocol staProtocol1006 = devpThread.getStation().get(1006);
                staProtocol1006.setWorkNo(workNo);
                staProtocol1006.setStaNo((short) 1007);
                boolean result2 = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
                log.info("1006站点往前走一格：{},{}", staProtocol.getWorkNo(), 1007);
            }
        }
    }

@@ -173,14 +177,26 @@
                    .doPost();
            JSONObject jsonObject = JSON.parseObject(response);
            if (jsonObject.getInteger("code").equals(200)) {
                log.info("下发任务返回数据：{}", response);
                return true;
                log.info("RCS返回数据：{}", response);
                JSONArray data = jsonObject.getJSONArray("data");
                List<StationStatus> stationStatuses = JSONArray.parseArray(data.toString(), StationStatus.class);
                for (StationStatus object : stationStatuses) {
                    if (object.getStaNo().equals(staNo + "")) {
                        if (object.getConveyable()) {
                            return true;
                        } else {
                            log.info("站点：{}状态不对", staNo);
                            return false;
                        }
                    }
                }
                log.info("未返回站点状态：{}", staNo);
            } else {
                //log.error("请求接口失败！！！url：{}；request：{}；response：{}", ctuUrl + sendTask, JSON.toJSONString(openBusSubmitParam), response);
                throw new CoolException("调用下发任务接口报错");
            }
        } catch (Exception e) {
            //log.error("fail", e);
            log.error("fail", e);
        }
        return false;
    }

 src/main/resources/application.yml

@@ -15,8 +15,8 @@


ctu:
  url: 10.10.10.200:8088
  station: /station/convey
  url: 192.168.3.216:8088
  station: /api/open/station/convey
  locSync: /api/open/loc/sync
  sendTask: /api/open/bus/submit
  getLoc: /api/open/loc/one