#

tqs

2022-12-06 32503cc754caa4984f408f7c2a6d10701a72522e

#

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

@@ -188,7 +188,13 @@

                            barcodeThread.setBarcode("");
                            staProtocol.setWorkNo(dto.getWorkNo().shortValue());

                            if(Cools.isEmpty(dto.getRgvNo()) || dto.getRgvNo() <= 0) {
                            staProtocol.setStaNo(dto.getStaNo().shortValue());
                            } else {//如果存在RGV编号，说明需要RGV接驳，先下发任务到RGV源站
                                staProtocol.setStaNo(dto.getRgvSstaNo().shortValue());
                            }

                            devpThread.setPakMk(staProtocol.getSiteId(), false);
                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                            if (!result) {

 src/main/java/com/zy/common/model/StartupDto.java

@@ -8,14 +8,43 @@
@Data
public class StartupDto {

    /**
     * 源站
     */
    private Integer sourceStaNo;

    /**
     * 目标站
     */
    private Integer staNo;

    /**
     * 堆垛机号
     */
    private Integer crnNo;

    /**
     * 库位号
     */
    private String locNo;

    /**
     * 工作号
     */
    private Integer workNo;

    /**
     * RGV编号
     */
    private Integer rgvNo;

    /**
     * RGV源站
     */
    private Integer rgvSstaNo;

    /**
     * RGV目标站
     */
    private Integer rgvDstaNo;
}

 src/main/java/com/zy/core/thread/LedThread.java

@@ -63,7 +63,7 @@
    @Override
    @SuppressWarnings({"InfiniteLoopStatement", "unchecked"})
    public void run() {
        connect();
//        connect();
        close();
        while (true) {
            try {