不同步 Channel 表

cmc-temperature-back/cmc-monitoring/src/main/java/com/ruoyi/monitoring/service/impl/AccessSyncServiceImpl.java

@@ -32,45 +32,45 @@ public class AccessSyncServiceImpl implements IAccessSyncService {
 
         try (Connection conn = DriverManager.getConnection(
                 Solon.cfg().getProperty("mybatis-flex.datasource.access.jdbcUrl"), "", "")) {
-
-            // 直接同步 Channel 表
-            System.out.println("开始同步Channel表...");
-            Integer channelMaxId = sqliteChannelMapper.selectMaxId();
-            System.out.println("SQLite Channel表当前最大ID: " + channelMaxId);
-
-            List<CmcChannel> newChannels = new ArrayList<>();
-
-            String channelQuery = "SELECT ID, Sensor_No, Info, Ver, Sn, Ca, Cb, Units, LastDT " +
-                    "FROM Channel " +
-                    "WHERE ID > ? " +
-                    "ORDER BY ID ASC";
-
-            try (PreparedStatement pstmt = conn.prepareStatement(channelQuery)) {
-                pstmt.setInt(1, channelMaxId);
-                try (ResultSet rs = pstmt.executeQuery()) {
-                    while (rs.next()) {
-                        CmcChannel channel = new CmcChannel();
-                        channel.setId(rs.getInt("ID"));
-                        channel.setSensorNo(rs.getInt("Sensor_No"));
-                        channel.setInfo(rs.getString("Info"));
-                        channel.setVer(rs.getInt("Ver"));
-                        channel.setSn(rs.getString("Sn"));
-                        channel.setCa(rs.getInt("Ca"));
-                        channel.setCb(rs.getInt("Cb"));
-                        channel.setUnits(rs.getString("Units"));
-                        channel.setLastDT(rs.getString("LastDT"));
-                        newChannels.add(channel);
-                    }
-                }
-            }
-
-            if (!newChannels.isEmpty()) {
-                System.out.println("从Access读取到" + newChannels.size() + "条新Channel记录（ID > " + channelMaxId + "）");
-                batchInsertChannels(newChannels);
-                System.out.println("Channel表同步完成，共同步" + newChannels.size() + "条记录");
-            } else {
-                System.out.println("没有新的Channel记录需要同步（ID > " + channelMaxId + "）");
-            }
+//
+//            // 直接同步 Channel 表
+//            System.out.println("开始同步Channel表...");
+//            Integer channelMaxId = sqliteChannelMapper.selectMaxId();
+//            System.out.println("SQLite Channel表当前最大ID: " + channelMaxId);
+//
+//            List<CmcChannel> newChannels = new ArrayList<>();
+//
+//            String channelQuery = "SELECT ID, Sensor_No, Info, Ver, Sn, Ca, Cb, Units, LastDT " +
+//                    "FROM Channel " +
+//                    "WHERE ID > ? " +
+//                    "ORDER BY ID ASC";
+//
+//            try (PreparedStatement pstmt = conn.prepareStatement(channelQuery)) {
+//                pstmt.setInt(1, channelMaxId);
+//                try (ResultSet rs = pstmt.executeQuery()) {
+//                    while (rs.next()) {
+//                        CmcChannel channel = new CmcChannel();
+//                        channel.setId(rs.getInt("ID"));
+//                        channel.setSensorNo(rs.getInt("Sensor_No"));
+//                        channel.setInfo(rs.getString("Info"));
+//                        channel.setVer(rs.getInt("Ver"));
+//                        channel.setSn(rs.getString("Sn"));
+//                        channel.setCa(rs.getInt("Ca"));
+//                        channel.setCb(rs.getInt("Cb"));
+//                        channel.setUnits(rs.getString("Units"));
+//                        channel.setLastDT(rs.getString("LastDT"));
+//                        newChannels.add(channel);
+//                    }
+//                }
+//            }
+//
+//            if (!newChannels.isEmpty()) {
+//                System.out.println("从Access读取到" + newChannels.size() + "条新Channel记录（ID > " + channelMaxId + "）");
+//                batchInsertChannels(newChannels);
+//                System.out.println("Channel表同步完成，共同步" + newChannels.size() + "条记录");
+//            } else {
+//                System.out.println("没有新的Channel记录需要同步（ID > " + channelMaxId + "）");
+//            }
 
             // 同步 Data 表
             System.out.println("开始同步Data表...");

cmc-temperature-back/ruoyi-schedule/src/main/java/com/ruoyi/schedule/task/AccessSyncTask.java

@@ -14,7 +14,7 @@ public class AccessSyncTask {
     IAccessSyncService accessSyncService;
 
     // 每小时执行一次（cron格式：秒 分 时 日 月 周 年）
-    @Scheduled(cron = "0 20 0/1 * * ? *", zone = "Asia/Shanghai")
+    @Scheduled(cron = "0 0 0/1 * * ? *", zone = "Asia/Shanghai")
     public void sync() throws Exception {
         System.out.println("========== Access数据同步任务开始执行，当前时间: " + new Date() + "==========");
         try {