| | |
| | | Map<String, Object> logicParams, |
| | | Map<String, Object> params) { |
| | | |
| | | String deviceId = deviceConfig.getDeviceId(); |
| | | String deviceId = String.valueOf(deviceConfig.getId()); |
| | | PlcClient plcClient = getPlcClient(deviceConfig); |
| | | if (plcClient == null) { |
| | | return buildResult(deviceConfig, "checkAndProcess", false, |
| | |
| | | WorkstationLogicConfig config, |
| | | Map<String, Object> logicParams) { |
| | | |
| | | String deviceId = deviceConfig.getDeviceId(); |
| | | String deviceId = String.valueOf(deviceConfig.getId()); |
| | | |
| | | // 停止旧的监控任务 |
| | | handleStopMonitor(deviceConfig); |
| | |
| | | * 停止监控任务 |
| | | */ |
| | | private DevicePlcVO.OperationResult handleStopMonitor(DeviceConfig deviceConfig) { |
| | | String deviceId = deviceConfig.getDeviceId(); |
| | | String deviceId = String.valueOf(deviceConfig.getId()); |
| | | ScheduledFuture<?> future = monitorTasks.remove(deviceId); |
| | | if (future != null && !future.isCancelled()) { |
| | | future.cancel(false); |
| | |
| | | * 清空缓冲队列 |
| | | */ |
| | | private DevicePlcVO.OperationResult handleClearBuffer(DeviceConfig deviceConfig) { |
| | | String deviceId = deviceConfig.getDeviceId(); |
| | | String deviceId = String.valueOf(deviceConfig.getId()); |
| | | glassBuffer.remove(deviceId); |
| | | lastScanTime.remove(deviceId); |
| | | log.info("已清空缓冲队列: deviceId={}", deviceId); |