chore: temporarily disable VehicleSyncTask to suppress MySQL table missing errors

iot-platform/src/main/java/com/iot/platform/task/VehicleSyncTask.java

@@ -1,327 +1,327 @@
-package com.iot.platform.task;
+// // package com.iot.platform.task;
 
-import com.iot.platform.domain.SysCar;
-import com.iot.platform.domain.SysDevice;
-import com.iot.platform.domain.SysDeviceControl;
-import com.iot.platform.config.IotProperties;
-import com.iot.platform.service.*;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.dao.DataAccessException;
-import org.springframework.data.redis.RedisConnectionFailureException;
-import org.springframework.data.redis.core.RedisCallback;
-import org.springframework.data.redis.core.ScanOptions;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-import org.springframework.web.client.RestClientException;
-import org.springframework.web.client.RestTemplate;
+// import com.iot.platform.domain.SysCar;
+// import com.iot.platform.domain.SysDevice;
+// import com.iot.platform.domain.SysDeviceControl;
+// import com.iot.platform.config.IotProperties;
+// import com.iot.platform.service.*;
+// import org.slf4j.Logger;
+// import org.slf4j.LoggerFactory;
+// import org.springframework.dao.DataAccessException;
+// import org.springframework.data.redis.RedisConnectionFailureException;
+// import org.springframework.data.redis.core.RedisCallback;
+// import org.springframework.data.redis.core.ScanOptions;
+// import org.springframework.data.redis.core.StringRedisTemplate;
+// import org.springframework.scheduling.annotation.Scheduled;
+// import org.springframework.stereotype.Component;
+// import org.springframework.web.client.RestClientException;
+// import org.springframework.web.client.RestTemplate;
 
-import java.util.*;
-import java.util.concurrent.TimeUnit;
+// import java.util.*;
+// import java.util.concurrent.TimeUnit;
 
-@Component
-public class VehicleSyncTask {
+// @Component
+// public class VehicleSyncTask {
 
-    private static final Logger log = LoggerFactory.getLogger(VehicleSyncTask.class);
+//     private static final Logger log = LoggerFactory.getLogger(VehicleSyncTask.class);
 
-    private final SysCarService sysCarService;
-    private final SysDeviceService sysDeviceService;
-    private final StringRedisTemplate stringRedisTemplate;
-    private final SysrealtimeService sysrealtimeService;
-    private final SysDeviceVoService sysDeviceVoService;
-    private final SysDeviceControlService sysDeviceControlService;
-    private final RestTemplate restTemplate;
-    private final IotProperties iotProperties;
+//     private final SysCarService sysCarService;
+//     private final SysDeviceService sysDeviceService;
+//     private final StringRedisTemplate stringRedisTemplate;
+//     private final SysrealtimeService sysrealtimeService;
+//     private final SysDeviceVoService sysDeviceVoService;
+//     private final SysDeviceControlService sysDeviceControlService;
+//     private final RestTemplate restTemplate;
+//     private final IotProperties iotProperties;
 
-    public VehicleSyncTask(SysCarService sysCarService,
-                           SysDeviceService sysDeviceService,
-                           StringRedisTemplate stringRedisTemplate,
-                           SysrealtimeService sysrealtimeService,
-                           SysDeviceVoService sysDeviceVoService,
-                           SysDeviceControlService sysDeviceControlService,
-                           RestTemplate restTemplate,
-                           IotProperties iotProperties) {
-        this.sysCarService = sysCarService;
-        this.sysDeviceService = sysDeviceService;
-        this.stringRedisTemplate = stringRedisTemplate;
-        this.sysrealtimeService = sysrealtimeService;
-        this.sysDeviceVoService = sysDeviceVoService;
-        this.sysDeviceControlService = sysDeviceControlService;
-        this.restTemplate = restTemplate;
-        this.iotProperties = iotProperties;
-    }
+//     public VehicleSyncTask(SysCarService sysCarService,
+//                            SysDeviceService sysDeviceService,
+//                            StringRedisTemplate stringRedisTemplate,
+//                            SysrealtimeService sysrealtimeService,
+//                            SysDeviceVoService sysDeviceVoService,
+//                            SysDeviceControlService sysDeviceControlService,
+//                            RestTemplate restTemplate,
+//                            IotProperties iotProperties) {
+//         this.sysCarService = sysCarService;
+//         this.sysDeviceService = sysDeviceService;
+//         this.stringRedisTemplate = stringRedisTemplate;
+//         this.sysrealtimeService = sysrealtimeService;
+//         this.sysDeviceVoService = sysDeviceVoService;
+//         this.sysDeviceControlService = sysDeviceControlService;
+//         this.restTemplate = restTemplate;
+//         this.iotProperties = iotProperties;
+//     }
 
-    private boolean tryLock(String lockKey, long expireSeconds) {
-        Boolean acquired = stringRedisTemplate.opsForValue().setIfAbsent(lockKey, "1", expireSeconds, TimeUnit.SECONDS);
-        return Boolean.TRUE.equals(acquired);
-    }
+//     private boolean tryLock(String lockKey, long expireSeconds) {
+//         Boolean acquired = stringRedisTemplate.opsForValue().setIfAbsent(lockKey, "1", expireSeconds, TimeUnit.SECONDS);
+//         return Boolean.TRUE.equals(acquired);
+//     }
 
-    private void unlock(String lockKey) {
-        Boolean deleted = stringRedisTemplate.delete(lockKey);
-        if (!Boolean.TRUE.equals(deleted)) {
-            log.warn("分布式锁释放失败: {}", lockKey);
-        }
-    }
+//     private void unlock(String lockKey) {
+//         Boolean deleted = stringRedisTemplate.delete(lockKey);
+//         if (!Boolean.TRUE.equals(deleted)) {
+//             log.warn("分布式锁释放失败: {}", lockKey);
+//         }
+//     }
 
-    /**
-     * 更新车辆的控制器信息
-     * 30秒更新一次
-     */
-    @Scheduled(fixedDelay = 30000)
-    public void updateSysCar() {
-        String lockKey = "lock:vehicle-sync:updateSysCar";
-        if (!tryLock(lockKey, 60)) {
-            log.debug("获取锁失败，跳过本次执行: {}", lockKey);
-            return;
-        }
-        try {
-            doUpdateSysCar();
-        } finally {
-            unlock(lockKey);
-        }
-    }
+//     /**
+//      * 更新车辆的控制器信息
+//      * 30秒更新一次
+//      */
+//     @Scheduled(fixedDelay = 30000)
+//     public void updateSysCar() {
+//         String lockKey = "lock:vehicle-sync:updateSysCar";
+//         if (!tryLock(lockKey, 60)) {
+//             log.debug("获取锁失败，跳过本次执行: {}", lockKey);
+//             return;
+//         }
+//         try {
+//             doUpdateSysCar();
+//         } finally {
+//             unlock(lockKey);
+//         }
+//     }
 
-    private void doUpdateSysCar() {
-        List<SysCar> sysCarList = sysCarService.selectcontrollerId();
-        for (SysCar sysCar : sysCarList) {
-            try {
-                if (sysCar.getControllerId() == null || sysCar.getControllerId().isEmpty()) {
-                    continue;
-                }
-                SysDevice latitude = sysDeviceService.selectsysdevice(sysCar.getControllerId(), "纬度");
-                SysDevice longitude = sysDeviceService.selectsysdevice(sysCar.getControllerId(), "经度");
+//     private void doUpdateSysCar() {
+//         List<SysCar> sysCarList = sysCarService.selectcontrollerId();
+//         for (SysCar sysCar : sysCarList) {
+//             try {
+//                 if (sysCar.getControllerId() == null || sysCar.getControllerId().isEmpty()) {
+//                     continue;
+//                 }
+//                 SysDevice latitude = sysDeviceService.selectsysdevice(sysCar.getControllerId(), "纬度");
+//                 SysDevice longitude = sysDeviceService.selectsysdevice(sysCar.getControllerId(), "经度");
 
-                String redisKeyPattern = "workorder:coordinate:" + sysCar.getControllerId() + ":*";
-                Set<String> keys = scanKeys(redisKeyPattern);
+//                 String redisKeyPattern = "workorder:coordinate:" + sysCar.getControllerId() + ":*";
+//                 Set<String> keys = scanKeys(redisKeyPattern);
 
-                if (keys == null || keys.isEmpty()) {
-                    updateCarPosition(sysCar, latitude, longitude);
-                } else {
-                    for (String key : keys) {
-                        Map<Object, Object> coordinateMap = stringRedisTemplate.opsForHash().entries(key);
-                        Object cachedLat = coordinateMap.get("latitude");
-                        Object cachedLon = coordinateMap.get("longitude");
-                        if (cachedLat != null && cachedLat.equals(latitude.getV()) && cachedLon != null && cachedLon.equals(longitude.getV())) {
-                            continue;
-                        }
-                        updateCarPosition(sysCar, latitude, longitude);
-                    }
-                }
-            } catch (DataAccessException e) {
-                log.error("更新车辆位置失败 carId={}: {}", sysCar.getCarId(), e.getMessage(), e);
-            } catch (Exception e) {
-                log.error("更新车辆位置异常 carId={}: {}", sysCar.getCarId(), e.getMessage(), e);
-            }
-        }
-    }
+//                 if (keys == null || keys.isEmpty()) {
+//                     updateCarPosition(sysCar, latitude, longitude);
+//                 } else {
+//                     for (String key : keys) {
+//                         Map<Object, Object> coordinateMap = stringRedisTemplate.opsForHash().entries(key);
+//                         Object cachedLat = coordinateMap.get("latitude");
+//                         Object cachedLon = coordinateMap.get("longitude");
+//                         if (cachedLat != null && cachedLat.equals(latitude.getV()) && cachedLon != null && cachedLon.equals(longitude.getV())) {
+//                             continue;
+//                         }
+//                         updateCarPosition(sysCar, latitude, longitude);
+//                     }
+//                 }
+//             } catch (DataAccessException e) {
+//                 log.error("更新车辆位置失败 carId={}: {}", sysCar.getCarId(), e.getMessage(), e);
+//             } catch (Exception e) {
+//                 log.error("更新车辆位置异常 carId={}: {}", sysCar.getCarId(), e.getMessage(), e);
+//             }
+//         }
+//     }
 
-    private void updateCarPosition(SysCar sysCar, SysDevice latitude, SysDevice longitude) {
-        String redisKey = "workorder:coordinate:" + sysCar.getControllerId();
-        stringRedisTemplate.opsForHash().put(redisKey, "latitude", latitude.getV());
-        stringRedisTemplate.opsForHash().put(redisKey, "longitude", longitude.getV());
-        stringRedisTemplate.persist(redisKey);
+//     private void updateCarPosition(SysCar sysCar, SysDevice latitude, SysDevice longitude) {
+//         String redisKey = "workorder:coordinate:" + sysCar.getControllerId();
+//         stringRedisTemplate.opsForHash().put(redisKey, "latitude", latitude.getV());
+//         stringRedisTemplate.opsForHash().put(redisKey, "longitude", longitude.getV());
+//         stringRedisTemplate.persist(redisKey);
 
-        String position = latitude.getV() + "," + longitude.getV();
-        sysCarService.updatecarposition(position, sysCar.getCarId());
-        String url = iotProperties.getMqtt().getVehicleTriggerUrl() + "?carId=" + sysCar.getCarId();
-        try {
-            restTemplate.postForObject(url, null, String.class);
-        } catch (RestClientException e) {
-            log.warn("触发webhook失败 carId={}: {}", sysCar.getCarId(), e.getMessage());
-        }
-    }
+//         String position = latitude.getV() + "," + longitude.getV();
+//         sysCarService.updatecarposition(position, sysCar.getCarId());
+//         String url = iotProperties.getMqtt().getVehicleTriggerUrl() + "?carId=" + sysCar.getCarId();
+//         try {
+//             restTemplate.postForObject(url, null, String.class);
+//         } catch (RestClientException e) {
+//             log.warn("触发webhook失败 carId={}: {}", sysCar.getCarId(), e.getMessage());
+//         }
+//     }
 
-    private Set<String> scanKeys(String pattern) {
-        Set<String> keys = new HashSet<>();
-        ScanOptions options = ScanOptions.scanOptions().match(pattern).count(100).build();
-        try {
-            stringRedisTemplate.execute((RedisCallback<Void>) connection -> {
-                org.springframework.data.redis.core.Cursor<byte[]> cursor = connection.scan(options);
-                while (cursor.hasNext()) {
-                    keys.add(new String(cursor.next()));
-                }
-                cursor.close();
-                return null;
-            });
-        } catch (RedisConnectionFailureException e) {
-            log.warn("Redis SCAN 连接失败 pattern={}: {}", pattern, e.getMessage());
-        } catch (Exception e) {
-            log.error("Redis SCAN 失败 pattern={}: {}", pattern, e.getMessage(), e);
-        }
-        return keys;
-    }
+//     private Set<String> scanKeys(String pattern) {
+//         Set<String> keys = new HashSet<>();
+//         ScanOptions options = ScanOptions.scanOptions().match(pattern).count(100).build();
+//         try {
+//             stringRedisTemplate.execute((RedisCallback<Void>) connection -> {
+//                 org.springframework.data.redis.core.Cursor<byte[]> cursor = connection.scan(options);
+//                 while (cursor.hasNext()) {
+//                     keys.add(new String(cursor.next()));
+//                 }
+//                 cursor.close();
+//                 return null;
+//             });
+//         } catch (RedisConnectionFailureException e) {
+//             log.warn("Redis SCAN 连接失败 pattern={}: {}", pattern, e.getMessage());
+//         } catch (Exception e) {
+//             log.error("Redis SCAN 失败 pattern={}: {}", pattern, e.getMessage(), e);
+//         }
+//         return keys;
+//     }
 
-    @Scheduled(fixedDelay = 30000)
-    public void insertDevice() {
-        String lockKey = "lock:vehicle-sync:insertDevice";
-        if (!tryLock(lockKey, 60)) {
-            log.debug("获取锁失败，跳过本次执行: {}", lockKey);
-            return;
-        }
-        try {
-            doInsertDevice();
-        } finally {
-            unlock(lockKey);
-        }
-    }
+//     @Scheduled(fixedDelay = 30000)
+//     public void insertDevice() {
+//         String lockKey = "lock:vehicle-sync:insertDevice";
+//         if (!tryLock(lockKey, 60)) {
+//             log.debug("获取锁失败，跳过本次执行: {}", lockKey);
+//             return;
+//         }
+//         try {
+//             doInsertDevice();
+//         } finally {
+//             unlock(lockKey);
+//         }
+//     }
 
-    private void doInsertDevice() {
-        Set<String> activeKeys;
-        try {
-            activeKeys = stringRedisTemplate.opsForSet().members("DSB:active:devices");
-        } catch (Exception e) {
-            log.warn("redis中无数据");
-            return;
-        }
-        try {
-            if (activeKeys == null || activeKeys.isEmpty()) {
-                log.info("redis中无数据");
-                return;
-            }
-            List<SysDeviceControl> sysDeviceControlList = sysDeviceControlService.selectdevice("device");
-            for (String redisKey : activeKeys) {
-                Map<Object, Object> dataMap = stringRedisTemplate.opsForHash().entries(redisKey);
-                if (dataMap == null || dataMap.isEmpty()) {
-                    stringRedisTemplate.opsForSet().remove("DSB:active:devices", redisKey);
-                    continue;
-                }
-                String[] parts = redisKey.split(":", 3);
-                if (parts.length != 3 || !"DSB".equals(parts[0])) {
-                    log.warn("跳过非法 key: {}", redisKey);
-                    continue;
-                }
-                String controllerId = parts[1];
-                Integer count = sysDeviceVoService.selectcount(controllerId);
-                if (count != null && count > 0) {
-                    StringBuilder keyvalue = new StringBuilder();
-                    for (int i = 0; i < sysDeviceControlList.size(); i++) {
-                        for (Map.Entry<Object, Object> entry : dataMap.entrySet()) {
-                            String fieldKey = entry.getKey().toString();
-                            String fieldvalue = entry.getValue().toString();
-                            if (sysDeviceControlList.get(i).getControllerName().equals(fieldKey)) {
-                                keyvalue.append(fieldKey).append("=/'").append(fieldvalue).append("/'");
-                                if (i < sysDeviceControlList.size() - 1) {
-                                    keyvalue.append(",");
-                                }
-                            }
-                        }
-                    }
-                    boolean updated = sysDeviceVoService.updatesysdevice(keyvalue.toString(), controllerId);
-                    if (!updated) {
-                        log.warn("更新设备配置失败: controllerId={}", controllerId);
-                    }
-                } else {
-                    StringBuilder key = new StringBuilder();
-                    StringBuilder value = new StringBuilder();
-                    for (int i = 0; i < sysDeviceControlList.size(); i++) {
-                        for (Map.Entry<Object, Object> entry : dataMap.entrySet()) {
-                            String fieldKey = entry.getKey().toString();
-                            String fieldvalue = entry.getValue().toString();
-                            if (sysDeviceControlList.get(i).getControllerName().equals(fieldKey)) {
-                                key.append(fieldKey);
-                                value.append(fieldvalue);
-                                if (i < sysDeviceControlList.size() - 1) {
-                                    key.append(",");
-                                    value.append(",");
-                                }
-                            }
-                        }
-                    }
-                    boolean inserted = sysDeviceVoService.insertdevice(key.toString(), value.toString());
-                    if (!inserted) {
-                        log.warn("插入设备配置失败: controllerId={}", controllerId);
-                    }
-                }
-            }
-        } catch (RedisConnectionFailureException e) {
-            log.warn("Redis 连接失败，跳过本次同步: {}", e.getMessage());
-        } catch (DataAccessException e) {
-            log.error("数据库操作失败: {}", e.getMessage(), e);
-        } catch (Exception e) {
-            log.error("同步设备配置失败: {}", e.getMessage(), e);
-        }
-    }
+//     private void doInsertDevice() {
+//         Set<String> activeKeys;
+//         try {
+//             activeKeys = stringRedisTemplate.opsForSet().members("DSB:active:devices");
+//         } catch (Exception e) {
+//             log.warn("redis中无数据");
+//             return;
+//         }
+//         try {
+//             if (activeKeys == null || activeKeys.isEmpty()) {
+//                 log.info("redis中无数据");
+//                 return;
+//             }
+//             List<SysDeviceControl> sysDeviceControlList = sysDeviceControlService.selectdevice("device");
+//             for (String redisKey : activeKeys) {
+//                 Map<Object, Object> dataMap = stringRedisTemplate.opsForHash().entries(redisKey);
+//                 if (dataMap == null || dataMap.isEmpty()) {
+//                     stringRedisTemplate.opsForSet().remove("DSB:active:devices", redisKey);
+//                     continue;
+//                 }
+//                 String[] parts = redisKey.split(":", 3);
+//                 if (parts.length != 3 || !"DSB".equals(parts[0])) {
+//                     log.warn("跳过非法 key: {}", redisKey);
+//                     continue;
+//                 }
+//                 String controllerId = parts[1];
+//                 Integer count = sysDeviceVoService.selectcount(controllerId);
+//                 if (count != null && count > 0) {
+//                     StringBuilder keyvalue = new StringBuilder();
+//                     for (int i = 0; i < sysDeviceControlList.size(); i++) {
+//                         for (Map.Entry<Object, Object> entry : dataMap.entrySet()) {
+//                             String fieldKey = entry.getKey().toString();
+//                             String fieldvalue = entry.getValue().toString();
+//                             if (sysDeviceControlList.get(i).getControllerName().equals(fieldKey)) {
+//                                 keyvalue.append(fieldKey).append("=/'").append(fieldvalue).append("/'");
+//                                 if (i < sysDeviceControlList.size() - 1) {
+//                                     keyvalue.append(",");
+//                                 }
+//                             }
+//                         }
+//                     }
+//                     boolean updated = sysDeviceVoService.updatesysdevice(keyvalue.toString(), controllerId);
+//                     if (!updated) {
+//                         log.warn("更新设备配置失败: controllerId={}", controllerId);
+//                     }
+//                 } else {
+//                     StringBuilder key = new StringBuilder();
+//                     StringBuilder value = new StringBuilder();
+//                     for (int i = 0; i < sysDeviceControlList.size(); i++) {
+//                         for (Map.Entry<Object, Object> entry : dataMap.entrySet()) {
+//                             String fieldKey = entry.getKey().toString();
+//                             String fieldvalue = entry.getValue().toString();
+//                             if (sysDeviceControlList.get(i).getControllerName().equals(fieldKey)) {
+//                                 key.append(fieldKey);
+//                                 value.append(fieldvalue);
+//                                 if (i < sysDeviceControlList.size() - 1) {
+//                                     key.append(",");
+//                                     value.append(",");
+//                                 }
+//                             }
+//                         }
+//                     }
+//                     boolean inserted = sysDeviceVoService.insertdevice(key.toString(), value.toString());
+//                     if (!inserted) {
+//                         log.warn("插入设备配置失败: controllerId={}", controllerId);
+//                     }
+//                 }
+//             }
+//         } catch (RedisConnectionFailureException e) {
+//             log.warn("Redis 连接失败，跳过本次同步: {}", e.getMessage());
+//         } catch (DataAccessException e) {
+//             log.error("数据库操作失败: {}", e.getMessage(), e);
+//         } catch (Exception e) {
+//             log.error("同步设备配置失败: {}", e.getMessage(), e);
+//         }
+//     }
 
-    /**
-     * 更新数据库实时数据
-     */
-    @Scheduled(fixedDelay = 30000)
-    public void syncRedisToMySQL() {
-        String lockKey = "lock:vehicle-sync:syncRedisToMySQL";
-        if (!tryLock(lockKey, 60)) {
-            log.debug("获取锁失败，跳过本次执行: {}", lockKey);
-            return;
-        }
-        try {
-            doSyncRedisToMySQL();
-        } finally {
-            unlock(lockKey);
-        }
-    }
+//     /**
+//      * 更新数据库实时数据
+//      */
+//     @Scheduled(fixedDelay = 30000)
+//     public void syncRedisToMySQL() {
+//         String lockKey = "lock:vehicle-sync:syncRedisToMySQL";
+//         if (!tryLock(lockKey, 60)) {
+//             log.debug("获取锁失败，跳过本次执行: {}", lockKey);
+//             return;
+//         }
+//         try {
+//             doSyncRedisToMySQL();
+//         } finally {
+//             unlock(lockKey);
+//         }
+//     }
 
-    private void doSyncRedisToMySQL() {
-        Set<String> activeKeys = stringRedisTemplate.opsForSet().members("DSB:active:devices");
-        if (activeKeys == null || activeKeys.isEmpty()) return;
+//     private void doSyncRedisToMySQL() {
+//         Set<String> activeKeys = stringRedisTemplate.opsForSet().members("DSB:active:devices");
+//         if (activeKeys == null || activeKeys.isEmpty()) return;
 
-        for (String redisKey : activeKeys) {
-            try {
-                Map<Object, Object> dataMap = stringRedisTemplate.opsForHash().entries(redisKey);
-                if (dataMap == null || dataMap.isEmpty()) {
-                    stringRedisTemplate.opsForSet().remove("DSB:active:devices", redisKey);
-                    continue;
-                }
+//         for (String redisKey : activeKeys) {
+//             try {
+//                 Map<Object, Object> dataMap = stringRedisTemplate.opsForHash().entries(redisKey);
+//                 if (dataMap == null || dataMap.isEmpty()) {
+//                     stringRedisTemplate.opsForSet().remove("DSB:active:devices", redisKey);
+//                     continue;
+//                 }
 
-                String[] parts = redisKey.split(":", 3);
-                if (parts.length != 3 || !"DSB".equals(parts[0])) {
-                    log.warn("跳过非法 key: {}", redisKey);
-                    continue;
-                }
-                String controllerId = parts[1];
+//                 String[] parts = redisKey.split(":", 3);
+//                 if (parts.length != 3 || !"DSB".equals(parts[0])) {
+//                     log.warn("跳过非法 key: {}", redisKey);
+//                     continue;
+//                 }
+//                 String controllerId = parts[1];
 
-                try {
-                    sysrealtimeService.createrealtime(controllerId);
-                } catch (Exception e) {
-                    log.error("创建表失败: {} | {}", controllerId, e.getMessage(), e);
-                    continue;
-                }
+//                 try {
+//                     sysrealtimeService.createrealtime(controllerId);
+//                 } catch (Exception e) {
+//                     log.error("创建表失败: {} | {}", controllerId, e.getMessage(), e);
+//                     continue;
+//                 }
 
-                String createTime = getStringValue(dataMap, "createTime");
-                String timestamp = getStringValue(dataMap, "timestamp");
-                String deviceId = getStringValue(dataMap, "device_id");
-                if (createTime == null || timestamp == null || deviceId == null) {
-                    continue;
-                }
+//                 String createTime = getStringValue(dataMap, "createTime");
+//                 String timestamp = getStringValue(dataMap, "timestamp");
+//                 String deviceId = getStringValue(dataMap, "device_id");
+//                 if (createTime == null || timestamp == null || deviceId == null) {
+//                     continue;
+//                 }
 
-                List<String> existingKeys = sysrealtimeService.selectAllKeys(controllerId);
-                Set<String> existingKeySet = existingKeys != null ? new HashSet<>(existingKeys) : Collections.emptySet();
+//                 List<String> existingKeys = sysrealtimeService.selectAllKeys(controllerId);
+//                 Set<String> existingKeySet = existingKeys != null ? new HashSet<>(existingKeys) : Collections.emptySet();
 
-                for (Map.Entry<Object, Object> entry : dataMap.entrySet()) {
-                    String fieldKey = entry.getKey().toString();
-                    if ("createTime".equals(fieldKey) || "timestamp".equals(fieldKey) || "device_id".equals(fieldKey)) {
-                        continue;
-                    }
-                    String fieldValue = getStringValue(dataMap, fieldKey);
-                    if (fieldValue == null) continue;
+//                 for (Map.Entry<Object, Object> entry : dataMap.entrySet()) {
+//                     String fieldKey = entry.getKey().toString();
+//                     if ("createTime".equals(fieldKey) || "timestamp".equals(fieldKey) || "device_id".equals(fieldKey)) {
+//                         continue;
+//                     }
+//                     String fieldValue = getStringValue(dataMap, fieldKey);
+//                     if (fieldValue == null) continue;
 
-                    if (existingKeySet.contains(fieldKey)) {
-                        sysrealtimeService.updatetables(controllerId, createTime, fieldValue, timestamp, fieldKey, deviceId);
-                    } else {
-                        sysrealtimeService.inserttables(controllerId, createTime, deviceId, timestamp, fieldKey, fieldValue);
-                    }
-                }
-            } catch (RedisConnectionFailureException e) {
-                log.error("Redis 连接失败: {} | {}", redisKey, e.getMessage());
-            } catch (DataAccessException e) {
-                log.error("数据库操作失败: {} | {}", redisKey, e.getMessage(), e);
-            } catch (Exception e) {
-                log.error("同步设备失败: {} | {}", redisKey, e.getMessage(), e);
-            }
-        }
-    }
+//                     if (existingKeySet.contains(fieldKey)) {
+//                         sysrealtimeService.updatetables(controllerId, createTime, fieldValue, timestamp, fieldKey, deviceId);
+//                     } else {
+//                         sysrealtimeService.inserttables(controllerId, createTime, deviceId, timestamp, fieldKey, fieldValue);
+//                     }
+//                 }
+//             } catch (RedisConnectionFailureException e) {
+//                 log.error("Redis 连接失败: {} | {}", redisKey, e.getMessage());
+//             } catch (DataAccessException e) {
+//                 log.error("数据库操作失败: {} | {}", redisKey, e.getMessage(), e);
+//             } catch (Exception e) {
+//                 log.error("同步设备失败: {} | {}", redisKey, e.getMessage(), e);
+//             }
+//         }
+//     }
 
-    private String getStringValue(Map<Object, Object> map, String key) {
-        Object val = map.get(key);
-        return val == null ? null : val.toString().trim();
-    }
-}
+//     private String getStringValue(Map<Object, Object> map, String key) {
+//         Object val = map.get(key);
+//         return val == null ? null : val.toString().trim();
+//     }
+// }