#

luxiaotao1123

2024-11-12 0628aaf9aa7c172cd5288f553ef045f8077ea9e4

 zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/MapDataWsScheduler.java

@@ -8,8 +8,10 @@
import com.zy.acs.manager.core.service.astart.MapDataDispatcher;
import com.zy.acs.manager.manager.entity.Agv;
import com.zy.acs.manager.manager.entity.AgvDetail;
import com.zy.acs.manager.manager.entity.AgvModel;
import com.zy.acs.manager.manager.entity.Code;
import com.zy.acs.manager.manager.service.AgvDetailService;
import com.zy.acs.manager.manager.service.AgvModelService;
import com.zy.acs.manager.manager.service.AgvService;
import com.zy.acs.manager.manager.service.CodeService;
import com.zy.acs.manager.manager.websocket.MapWebSocket;
@@ -34,6 +36,8 @@
    @Autowired
    private AgvDetailService agvDetailService;
    @Autowired
    private AgvModelService agvModelService;
    @Autowired
    private CodeService codeService;
    @Autowired
    private MapDataDispatcher mapDataDispatcher;
@@ -42,12 +46,12 @@

    @Scheduled(cron = "0/1 * * * * ? ")
    public void broadcast() {
//        i++;
//        int key;
//        if (i > 10) {
//            i=0;
//        }
//        key = i /2;
        i++;
        int key;
        if (i > 10) {
            i=0;
        }
        key = i /2;
//        MapWebSocket.broadcast(mockData.get(key));


@@ -64,6 +68,7 @@
        );
        for (Agv agv : agvList) {
            AgvDetail agvDetail = agvDetailService.selectByAgvId(agv.getId());
            AgvModel agvModel = agvModelService.getById(agv.getAgvModel());
            if (null == agvDetail) { continue; }
            Long recentCode = agvDetail.getRecentCode();
            if (null == recentCode) { continue; }
@@ -71,6 +76,7 @@
            if (null == code) { continue; }

            MapWsAgvVo vo = new MapWsAgvVo();
            vo.setAgvModel(agvModel.getType());
            vo.setAgvNo(agv.getUuid());
            vo.setCode(code.getData());
            vo.setDirection(agvDetail.getAgvAngle());