#

Junjie

3 天以前 ce511a3d55e5f349b1647172e562c1659bbc8172

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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
package com.zy.core;
 
import com.zy.common.exception.CoolException;
import com.zy.common.utils.RedisUtil;
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.properties.DeviceConfig;
import com.zy.core.thread.fake.FakeNyLiftThread;
import com.zy.core.thread.fake.FakeNyShuttleThread;
import com.zy.core.thread.fake.FakeZyForkLiftThread;
import com.zy.core.thread.impl.LfdZyForkLiftMasterThread;
import com.zy.core.thread.impl.NyLiftThread;
import com.zy.core.thread.impl.NyShuttleThread;
import com.zy.core.utils.DeviceMsgUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
 
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import java.util.List;
 
/**
 * Created by vincent on 2020/8/4
 */
@Slf4j
@Component
public class ServerBootstrap {
 
    @Value("${deviceMsgConfig.gatewayPort}")
    private int gatewayPort;
    @Value("${deviceMsgConfig.enableFakeDeviceThread}")
    private boolean enableFakeDeviceThread;
    @Value("${deviceMsgConfig.enableFake}")
    private boolean enableFake;
    @Autowired
    private RedisUtil redisUtil;
    @Autowired
    private DeviceMsgUtils deviceMsgUtils;
 
 
    @PostConstruct
    @Async
    public void init() throws InterruptedException {
        News.info("核心控制层开始初始化...............................................");
        Thread.sleep(2000);
        // 初始化消息队列
        initMq();
        // 初始化虚拟设备线程
        initFakeThread();
        // 初始化下位机线程
        initThread();
        News.info("核心控制层已启动...............................................");
    }
 
    private void initMq(){
        // 初始化设备mq
        List<DeviceConfig> deviceConfigs = deviceMsgUtils.getDeviceConfig();
        for (DeviceConfig device : deviceConfigs) {
            SlaveType type = SlaveType.findInstance(device.getDeviceType());
            if(null == type){
                continue;
            }
            MessageQueue.init(type, device.getDeviceNo());
        }
    }
 
    private void initThread(){
        List<DeviceConfig> deviceConfigs = deviceMsgUtils.getDeviceConfig();
        for (DeviceConfig device : deviceConfigs) {
            if (device.getDeviceType().equals(String.valueOf(SlaveType.ForkLift))) {
                initForkLiftThread(device);
            } else if (device.getDeviceType().equals(String.valueOf(SlaveType.Lift))) {
                initLiftThread(device);
            } else if (device.getDeviceType().equals(String.valueOf(SlaveType.Shuttle))) {
                initShuttleThread(device);
            }
        }
    }
 
    private void initFakeThread(){
        if (enableFake) {
            ThreadHandler thread = new FakeNyShuttleThread(redisUtil, gatewayPort, enableFake, enableFakeDeviceThread);
            new Thread(thread).start();
            SlaveConnection.put(SlaveType.FakeThread, 1, thread);
 
            ThreadHandler thread2 = new FakeZyForkLiftThread(redisUtil);
            new Thread(thread2).start();
            SlaveConnection.put(SlaveType.FakeThread, 2, thread2);
 
            ThreadHandler thread3 = new FakeNyLiftThread(redisUtil);
            new Thread(thread3).start();
            SlaveConnection.put(SlaveType.FakeThread, 3, thread3);
        }
    }
 
 
    @PreDestroy
    public void destroy() {
    }
 
    private void initForkLiftThread(DeviceConfig deviceConfig) {
        ThreadHandler thread = null;
        if (deviceConfig.getThreadImpl().equals("LfdZyForkLiftMasterThread")) {
            thread = new LfdZyForkLiftMasterThread(deviceConfig, redisUtil);
        } else {
            throw new CoolException("未知的线程实现");
        }
 
        new Thread(thread).start();
        SlaveConnection.put(SlaveType.ForkLiftMaster, deviceConfig.getDeviceNo(), thread);
    }
 
    private void initLiftThread(DeviceConfig deviceConfig) {
        ThreadHandler thread = null;
        if (deviceConfig.getThreadImpl().equals("NyLiftThread")) {
            thread = new NyLiftThread(deviceConfig, redisUtil);
        } else {
            throw new CoolException("未知的线程实现");
        }
 
        new Thread(thread).start();
        SlaveConnection.put(SlaveType.Lift, deviceConfig.getDeviceNo(), thread);
    }
 
    private void initShuttleThread(DeviceConfig deviceConfig) {
        ThreadHandler thread = null;
        if (deviceConfig.getThreadImpl().equals("NyShuttleThread")) {
            thread = new NyShuttleThread(deviceConfig, redisUtil);
        } else {
            throw new CoolException("未知的线程实现");
        }
 
        new Thread(thread).start();
        SlaveConnection.put(SlaveType.Shuttle, deviceConfig.getDeviceNo(), thread);
    }
 
 
}