| | |
| | | |
| | | private void initThread(){ |
| | | List<DeviceConfig> allDevices = new ArrayList<>(); |
| | | List<DeviceConfig> fakeDevices = new ArrayList<>(); |
| | | |
| | | // // 初始化货叉提升机 |
| | | // List<DeviceConfig> forkLiftList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>() |
| | |
| | | // 初始化四向穿梭车 |
| | | List<DeviceConfig> shuttleList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>() |
| | | .eq("device_type", String.valueOf(SlaveType.Shuttle))); |
| | | allDevices.addAll(shuttleList); |
| | | for (DeviceConfig deviceConfig : shuttleList) { |
| | | News.info("初始化四向穿梭车......................................................"); |
| | | ThreadHandler thread = null; |
| | |
| | | |
| | | new Thread(thread).start(); |
| | | SlaveConnection.put(SlaveType.Shuttle, deviceConfig.getDeviceNo(), thread); |
| | | |
| | | if (deviceConfig.getFake() == 1) { |
| | | fakeDevices.add(deviceConfig); |
| | | }else { |
| | | allDevices.add(deviceConfig); |
| | | } |
| | | } |
| | | |
| | | |
| | | //设备初始化完毕 |
| | | deviceMsgUtils.sendDeviceConfig(JSON.toJSONString(allDevices)); |
| | | deviceMsgUtils.sendFakeDeviceConfig(JSON.toJSONString(fakeDevices)); |
| | | } |
| | | |
| | | |