#

Junjie

2025-07-08 e5c1a651ed8057019674c7b4fa68281d5b7ebc8c

 src/main/java/com/zy/core/ServerBootstrap.java

@@ -7,10 +7,10 @@
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.properties.DeviceConfig;
import com.zy.core.thread.fake.FakeNyShuttleThread;
import com.zy.core.thread.impl.LfdZyForkLiftMasterThread;
import com.zy.core.thread.impl.NyShuttleThread;
import com.zy.core.utils.DeviceMsgUtils;
import com.zy.core.utils.FakeDeviceUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
@@ -31,8 +31,6 @@
    private RedisUtil redisUtil;
    @Autowired
    private DeviceMsgUtils deviceMsgUtils;
    @Autowired
    private FakeDeviceUtils fakeDeviceUtils;


    @PostConstruct
@@ -85,17 +83,8 @@
    }

    private void initFakeThread(){
        String fakeDeviceConfig = fakeDeviceUtils.getFakeDeviceConfig();
        if(null != fakeDeviceConfig){
            List<DeviceConfig> deviceConfigs = JSON.parseArray(fakeDeviceConfig, DeviceConfig.class);
            for (DeviceConfig device : deviceConfigs) {
                if (device.getDeviceType().equals(String.valueOf(SlaveType.ForkLift))) {
                    initForkLiftThread(device);
                } else if (device.getDeviceType().equals(String.valueOf(SlaveType.Shuttle))) {
                    initShuttleThread(device);
                }
            }
        }
        ThreadHandler thread = new FakeNyShuttleThread(redisUtil);
        new Thread(thread).start();
    }