| | |
|---|
| | | |
|---|
| | | private void clearStartupRuntimeLocks() { |
|---|
| | | redisUtil.del(RedisKeyType.STATION_EXECUTE_COMMAND_LOCK.key); |
|---|
| | | java.util.Set<String> stationSendLockKeys = redisUtil.scanKeys(RedisKeyType.STATION_EXECUTE_COMMAND_LOCK.key + ":", 2048); |
|---|
| | | if (stationSendLockKeys != null && !stationSendLockKeys.isEmpty()) { |
|---|
| | | redisUtil.del(stationSendLockKeys.toArray(new String[0])); |
|---|
| | | } |
|---|
| | | // News.info("系统启动时已清理输送站命令执行锁，key={}", RedisKeyType.STATION_EXECUTE_COMMAND_LOCK.key); |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | thread = new ZyStationThread(deviceConfig, redisUtil); |
|---|
| | | } else if (deviceConfig.getThreadImpl().equals("ZyStationV3Thread")) { |
|---|
| | | thread = new ZyStationV3Thread(deviceConfig, redisUtil); |
|---|
| | | } else if (deviceConfig.getThreadImpl().equals("ZyStationV4Thread")) { |
|---|
| | | thread = new ZyStationV4Thread(deviceConfig, redisUtil); |
|---|
| | | } else if (deviceConfig.getThreadImpl().equals("ZyStationV5Thread")) { |
|---|
| | | thread = new ZyStationV5Thread(deviceConfig, redisUtil); |
|---|
| | | } else { |
|---|
