From 7f70cb15d035f0c233b9e62b9e43aa985317c908 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期一, 04 十一月 2024 10:22:45 +0800 Subject: [PATCH] # --- zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/MapDataWsScheduler.java | 247 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 245 insertions(+), 2 deletions(-) diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/MapDataWsScheduler.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/MapDataWsScheduler.java index 7aadde7..09035a8 100644 --- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/MapDataWsScheduler.java +++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/MapDataWsScheduler.java @@ -1,9 +1,27 @@ package com.zy.acs.manager.core.scheduler; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.zy.acs.common.utils.GsonUtils; +import com.zy.acs.manager.core.domain.BackpackDto; +import com.zy.acs.manager.core.domain.MapWsAgvVo; import com.zy.acs.manager.core.domain.MapWsVo; +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.Code; +import com.zy.acs.manager.manager.service.AgvDetailService; +import com.zy.acs.manager.manager.service.AgvService; +import com.zy.acs.manager.manager.service.CodeService; import com.zy.acs.manager.manager.websocket.MapWebSocket; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; +import java.util.ArrayList; +import java.util.List; +import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; /** * Created by vincent on 10/14/2024 @@ -11,11 +29,236 @@ @Component public class MapDataWsScheduler { + @Autowired + private AgvService agvService; + @Autowired + private AgvDetailService agvDetailService; + @Autowired + private CodeService codeService; + @Autowired + private MapDataDispatcher mapDataDispatcher; + + int i = 0; + @Scheduled(cron = "0/1 * * * * ? ") public void broadcast() { - MapWsVo mapWsVo = new MapWsVo(); + i++; + int key; + if (i > 10) { + i=0; + } + key = i /2; + MapWebSocket.broadcast(mockData.get(key)); - MapWebSocket.broadcast("123"); + + MapWsVo mapWsVo = new MapWsVo(); + mapWsVo.setAgvVos(syncAgv()); +// MapWebSocket.broadcast(GsonUtils.toJson(mapWsVo)); + } + + private List<MapWsAgvVo> syncAgv() { + List<MapWsAgvVo> agvVos = new ArrayList<>(); + + List<Agv> agvList = agvService.list(new LambdaQueryWrapper<Agv>() +// .eq(Agv::getStatus, 1) + ); + for (Agv agv : agvList) { + AgvDetail agvDetail = agvDetailService.selectByAgvId(agv.getId()); + if (null == agvDetail) { continue; } + Long recentCode = agvDetail.getRecentCode(); + if (null == recentCode) { continue; } + Code code = codeService.getById(recentCode); + + MapWsAgvVo vo = new MapWsAgvVo(); + vo.setAgvNo(agv.getUuid()); + vo.setCode(code.getData()); + vo.setDirection(agvDetail.getAgvAngle()); + vo.setBackpack(GsonUtils.fromJsonToList(agvDetail.getBackpack(), BackpackDto.class)); + vo.setBattery(agvDetail.getSoc()); + + vo.setDynamicRoute(mapDataDispatcher.queryCodeListFromDynamicNode(null, agv.getUuid())); + + agvVos.add(vo); + } + + return agvVos; + } + + + + + + + private static final Map<Integer, String> mockData = new ConcurrentHashMap<>(); + + @PostConstruct + public void init() { + mockData.put(1, + "{\n" + + " \"agvVos\": [\n" + + " {\n" + + " \"agvNo\": \"1\",\n" + + " \"code\": \"00000002\",\n" + + " \"direction\": 90,\n" + + " \"dynamicRoute\": [\n" + + " \"00000002\",\n" + + " \"00000003\",\n" + + " \"00000004\"\n" + + " ]\n" + + " },\n" + + " {\n" + + " \"agvNo\": \"2\",\n" + + " \"code\": \"00000063\",\n" + + " \"direction\": 90,\n" + + " \"dynamicRoute\": [\n" + + " \"00000063\",\n" + + " \"00000062\",\n" + + " \"00000061\",\n" + + " \"00000060\",\n" + + " \"00000059\"\n" + + " ]\n" + + " }\n" + + " ]\n" + + "}" + ); + mockData.put(2, +"{\n" + + " \"agvVos\": [\n" + + " {\n" + + " \"agvNo\": \"1\",\n" + + " \"code\": \"00000003\",\n" + + " \"direction\": 90,\n" + + " \"dynamicRoute\": [\n" + + " \"00000003\",\n" + + " \"00000004\"\n" + + " ]\n" + + " },\n" + + " {\n" + + " \"agvNo\": \"2\",\n" + + " \"code\": \"00000062\",\n" + + " \"direction\": 90,\n" + + " \"dynamicRoute\": [\n" + + " \n" + + " \"00000062\",\n" + + " \"00000061\",\n" + + " \"00000060\",\n" + + " \"00000059\"\n" + + " ]\n" + + " }\n" + + " ]\n" + + "}" + + ); + + mockData.put(3, + "{\n" + + " \"agvVos\": [\n" + + " {\n" + + " \"agvNo\": \"1\",\n" + + " \"code\": \"00000004\",\n" + + " \"direction\": 90,\n" + + " \"dynamicRoute\": [\n" + + " \n" + + " \"00000004\"\n" + + " ]\n" + + " },\n" + + " {\n" + + " \"agvNo\": \"2\",\n" + + " \"code\": \"00000061\",\n" + + " \"direction\": 90,\n" + + " \"dynamicRoute\": [\n" + + "\n" + + " \"00000061\",\n" + + " \"00000060\",\n" + + " \"00000059\"\n" + + " ]\n" + + " }\n" + + " ]\n" + + "}" + ); + + mockData.put(4, + "{\n" + + " \"agvVos\": [\n" + + " {\n" + + " \"agvNo\": \"1\",\n" + + " \"code\": \"00000004\",\n" + + " \"direction\": 120,\n" + + " \"dynamicRoute\": [\n" + + " \"00000004\"\n" + + " ]\n" + + " },\n" + + " {\n" + + " \"agvNo\": \"2\",\n" + + " \"code\": \"00000060\",\n" + + " \"direction\": 90,\n" + + " \"dynamicRoute\": [\n" + + "\n" + + " \"00000060\",\n" + + " \"00000059\"\n" + + " ]\n" + + " }\n" + + " ]\n" + + "}" + ); + + mockData.put(5, + "{\n" + + " \"agvVos\": [\n" + + " {\n" + + " \"agvNo\": \"1\",\n" + + " \"code\": \"00000004\",\n" + + " \"direction\": 180,\n" + + " \"dynamicRoute\": [\n" + + " \"00000004\"\n" + + " ]\n" + + " },\n" + + " {\n" + + " \"agvNo\": \"2\",\n" + + " \"code\": \"00000059\",\n" + + " \"direction\": 90,\n" + + " \"dynamicRoute\": [\n" + + "\n" + + " \"00000059\"\n" + + " ]\n" + + " }\n" + + " ]\n" + + "}" + + ); } } + + +/** + + { + "agvVos": [ + { + "agvNo": "1", + "code": "00000002", + "direction": 90, + "dynamicRoute": [ + "00000002", + "00000003", + "00000004" + ] + }, + { + "agvNo": "2", + "code": "00000063", + "direction": 90, + "dynamicRoute": [ + "00000063", + "00000062", + "00000061", + "00000060", + "00000059" + ] + } + ] + } + ] + } + */ \ No newline at end of file -- Gitblit v1.9.1