#

luxiaotao1123

2024-12-02 368bc8d1f2b61543ef1b82d53568fbf1beb4dd39

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
package com.zy.acs.manager.core.scheduler;

 

import com.alibaba.fastjson.JSON;

import com.zy.acs.common.utils.Utils;

import com.zy.acs.manager.common.domain.WebsocketDto;

import com.zy.acs.manager.core.service.astart.DynamicNodeType;

import com.zy.acs.manager.core.service.astart.MapDataDispatcher;

import com.zy.acs.manager.core.service.astart.domain.DynamicNode;

import com.zy.acs.manager.manager.entity.Code;

import com.zy.acs.manager.manager.service.CodeService;

import com.zy.acs.manager.manager.websocket.DigitalTwinWebSocket;

import lombok.Data;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

 

import java.util.Comparator;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

 

/**

 * Created by vincent on 4/11/2024

 */

@Component

public class DigitalTwinDataScheduler {

 

    @Autowired

    private CodeService codeService;

    @Autowired

    private MapDataDispatcher mapDataDispatcher;

 

    @Scheduled(cron = "0/1 * * * * ? ")

    public void sync() {

        DynamicNode[][] dynamicMatrix = mapDataDispatcher.getDynamicMatrix(null);

        String[][] codeMatrix = mapDataDispatcher.getCodeMatrix(null);

 

        Map<String, List<CodePos>> dynamicAllot = new HashMap<>();

 

        for (int i = 0; i < dynamicMatrix.length; i++) {

            for (int j = 0; j < dynamicMatrix[i].length; j++) {

                DynamicNode dynamicNode = dynamicMatrix[i][j];

                String vehicle = dynamicNode.getVehicle();

                if (DynamicNodeType.ACCESS.val.equals(vehicle) || DynamicNodeType.BLOCK.val.equals(vehicle)) {

                    continue;

                }

                String codeData = codeMatrix[i][j];

                Code code = codeService.selectByData(codeData);

                if (null == code) {

                    continue;

                }

                if (dynamicAllot.containsKey(vehicle)) {

                    dynamicAllot.get(vehicle).add(new CodePos(codeData, dynamicNode.getSerial()).synPosition(code.getX(), 0, code.getY()));

                } else {

                    dynamicAllot.put(vehicle, Utils.singletonList(new CodePos(codeData, dynamicNode.getSerial()).synPosition(code.getX(), 0, code.getY())));

                }

            }

        }

 

        for (Map.Entry<String, List<CodePos>> entry : dynamicAllot.entrySet()) {

            entry.getValue().sort(Comparator.comparingInt(CodePos::getSerial));

        }

 

        DigitalTwinWebSocket.broadcast(JSON.toJSONString(new WebsocketDto<>("path", "", dynamicAllot.values())));

    }

 

 

    @Data

    public static class CodePos {

 

        private String code;

 

        private int serial;

 

        private Number[] position;

 

        public CodePos synPosition(Number x, Number y, Number z) {

            position = new Number[] {x, y, z};

            return this;

        }

 

        public CodePos(String code, int serial) {

            this.code = code;

            this.serial = serial;

        }

    }

 

}