#

luxiaotao1123

2024-04-03 b67f13b04339ac0cd1a10b07d58e9c30c53b97a2

#

 zy-asrs-flow/src/pages/map/utils.js

@@ -585,5 +585,9 @@
}

export const updateMapStatusInRealTime = (data) => {
    console.log('map: ' + data);
    const mapVo = JSON.parse(data);
    // shuttle
    for (const shuttleVo of mapVo.shuttleVos) {
        console.log(shuttleVo);
    }
}

 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/entity/MapWsShuttleVo.java

New file
@@ -0,0 +1,15 @@
package com.zy.asrs.wcs.core.map.entity;

import lombok.Data;

/**
 * Created by vincent on 4/3/2024
 */
@Data
public class MapWsShuttleVo {

    private String shuttleNo;

    private String curLocNo;

}

 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/entity/MapWsVo.java

New file
@@ -0,0 +1,16 @@
package com.zy.asrs.wcs.core.map.entity;

import lombok.Data;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by vincent on 4/3/2024
 */
@Data
public class MapWsVo {

    private List<MapWsShuttleVo> shuttleVos = new ArrayList<>();

}

 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/map/websocket/MockScheduler.java

@@ -1,5 +1,8 @@
package com.zy.asrs.wcs.core.map.websocket;

import com.alibaba.fastjson.JSON;
import com.zy.asrs.wcs.core.map.entity.MapWsShuttleVo;
import com.zy.asrs.wcs.core.map.entity.MapWsVo;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@@ -11,7 +14,15 @@

    @Scheduled(cron = "0/1 * * * * ? ")
    public void mock() {
        MapWebSocket.broadcast("test data");
        MapWsVo wsVo = new MapWsVo();

        // shuttle
        MapWsShuttleVo shuttleVo = new MapWsShuttleVo();
        shuttleVo.setShuttleNo("1");
        shuttleVo.setCurLocNo("1-1-1");
        wsVo.getShuttleVos().add(shuttleVo);

        MapWebSocket.broadcast(JSON.toJSONString(wsVo));
    }

}