sqlite根据access数据库定时更新数据

cmc-temperature-back/cmc-monitoring/src/main/java/com/ruoyi/monitoring/controller/CmcTemperatureController.java

@@ -14,6 +14,7 @@ import com.ruoyi.monitoring.service.ICmcTemperatureService;
 import com.ruoyi.common.web.controller.BaseController;
 import org.noear.solon.annotation.*;
 
+import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -41,68 +42,6 @@ public class CmcTemperatureController extends BaseController {
         return cmcTemperatureService.list(qw);
     }
 
-    /**
-     * 根据点位查询水温监测列表
-     */
-    @Get
-    @Mapping("listByInfo")
-    public PageData<CmcTemperature> listByInfo(Page<CmcTemperature> page, CmcTemperature cmcTemperature, CmcChannel cmcChannel) {
-        int channelSize = cmcChannelService.listChannel(cmcChannel).size();
-        page.setPageSize(page.getPageSize() * channelSize);
-        QueryWrapper qw = getQW(cmcTemperature, cmcChannel);
-        List<CmcTemperature> records = cmcTemperatureService.list(qw);
-        List<CmcTemperature> temperatureList = new ArrayList<>();
-        int total = 0;
-        if (records.size() > 0) {
-            long diffInMillis;
-            // 第30条与第31条数据时间差 毫秒
-            if (channelSize > 30) {
-                diffInMillis = records.get(30).getDatetime().getTime() - records.get(29).getDatetime().getTime();
-                // 时间差超过15分钟，删最后10条数据
-                if (diffInMillis / 1000 / 60 > 15)
-                    records.subList(records.size() - channelSize + 30, records.size()).clear();
-            }
-            // 第1条数据与0时时间差 毫秒
-            diffInMillis = records.get(0).getDatetime().getTime() - cmcTemperature.getStartTime().getTime();
-            if (diffInMillis / 1000 / 60 > 15)
-                records.subList(records.size() - channelSize, records.size()).clear();
-            CmcTemperature temperature = new CmcTemperature();
-            long fifteenMinutesAgoMillis = cmcTemperature.getStartTime().getTime() - (15 * 60 * 1000);
-            Date fifteenMinutesAgo = new Date(fifteenMinutesAgoMillis);
-            temperature.setStartTime(fifteenMinutesAgo);
-            temperature.setEndTime(cmcTemperature.getStartTime());
-            QueryWrapper qw1 = getQW(temperature, cmcChannel);
-            temperatureList = cmcTemperatureService.list(qw1);
-            temperatureList.addAll(records);
-            if (channelSize > 30) {
-                for (int i = 0; i < temperatureList.size() - channelSize + 1; i = i + channelSize) {
-                    Date minTime = temperatureList.get(i).getDatetime();
-                    if (temperatureList.get(i + 10).getDatetime().getTime() > minTime.getTime()) {
-                        for (int j = i + 10; j < i + channelSize; j++) {
-                            temperatureList.get(j).setDatetime(minTime);
-                        }
-                    } else {
-                        if (temperatureList.get(i + 30).getDatetime().getTime() > minTime.getTime()) {
-                            for (int j = i + 30; j < i + channelSize; j++) {
-                                temperatureList.get(j).setDatetime(minTime);
-                            }
-                        }
-                    }
-                }
-            }
-            total = temperatureList.size() / channelSize;
-            if (temperatureList.size() >= page.getPageSize()) {
-                if (page.getPageNumber() > 1) {
-                    temperatureList.subList((int) (page.getPageSize() * (page.getPageNumber())), temperatureList.size()).clear();
-                    temperatureList.subList(0, (int) (page.getPageSize() * (page.getPageNumber() - 1))).clear();
-                }
-                else
-                    temperatureList.subList((int) page.getPageSize(), temperatureList.size()).clear();
-            }
-        }
-        return getPageData(temperatureList).total(total);
-    }
-
     /**
      * 根据点位查询水温监测列表（不分页）
      */
@@ -138,32 +77,31 @@ public class CmcTemperatureController extends BaseController {
     }
 
     private static List<Map<String, Object>> prepareData(List<CmcChannel> channelList, List<CmcTemperature> temperatureList) {
-        Map<String, Map<Long, Float>> timeDataMap = new LinkedHashMap<>();
-        List<Long> sensors = new ArrayList<>();
+        Map<String, Map<Integer, String>> timeDataMap = new LinkedHashMap<>();
+        List<Integer> sensors = new ArrayList<>();
         channelList.forEach(channel ->  {
             sensors.add(channel.getSensorNo());
         });
         for (CmcTemperature cmcTemperature : temperatureList) {
-            Date datetime = cmcTemperature.getDatetime();
-            Long sensorNo = cmcTemperature.getSensorNo();
+            String datetime = cmcTemperature.getDatetime();
+            Integer sensorNo = cmcTemperature.getSensorNo();
 
-            String dateTme = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(datetime);
-            if (!timeDataMap.containsKey(dateTme)) {
-                timeDataMap.put(dateTme, new HashMap<>());
+            if (!timeDataMap.containsKey(datetime)) {
+                timeDataMap.put(datetime, new HashMap<>());
             }
 
-            timeDataMap.get(dateTme).put(sensorNo, cmcTemperature.getData());
+            timeDataMap.get(datetime).put(sensorNo, cmcTemperature.getData());
         }
 
         // 转换为导出格式
         List<Map<String, Object>> exportData = new ArrayList<>();
 
-        for (Map.Entry<String, Map<Long, Float>> entry : timeDataMap.entrySet()) {
+        for (Map.Entry<String, Map<Integer, String>> entry : timeDataMap.entrySet()) {
             Map<String, Object> rowData = new HashMap<>();
             rowData.put("Datetime", entry.getKey());
 
-            Map<Long, Float> locationData = entry.getValue();
-            for (Long sensor : sensors) {
+            Map<Integer, String> locationData = entry.getValue();
+            for (Integer sensor : sensors) {
                 rowData.put(String.valueOf(sensor), locationData.get(sensor));
             }
 

cmc-temperature-back/cmc-monitoring/src/main/java/com/ruoyi/monitoring/domain/CmcChannel.java

@@ -16,12 +16,12 @@ public class CmcChannel {
     /** 序号 */
     @Excel(name = "序号")
     @Id
-    private Long Id;
+    private Integer Id;
 
     /** 传感器编号 */
     @Excel(name = "传感器编号")
     @NotNull(message = "传感器编号不能为空")
-    private Long SensorNo;
+    private Integer SensorNo;
 
     /** 传感器位置 */
     @Excel(name = "传感器位置")
@@ -49,6 +49,6 @@ public class CmcChannel {
 
     /** 单位 */
     @Excel(name = "单位")
-    private Date LastDT;
+    private String LastDT;
 
 }

cmc-temperature-back/cmc-monitoring/src/main/java/com/ruoyi/monitoring/domain/CmcTemperature.java

@@ -17,7 +17,7 @@ public class CmcTemperature {
     /** 序号 */
     @Excel(name = "序号")
     @Id
-    private Long Id;
+    private Integer Id;
 
     /** 监测组编号 */
     @Excel(name = "监测组编号")
@@ -25,31 +25,31 @@ public class CmcTemperature {
 
     /** 传感器编号 */
     @Excel(name = "传感器编号")
-    private Long SensorNo;
+    private Integer SensorNo;
 
     @RelationOneToOne(selfField = "Sensor_No", targetField = "Sensor_No", targetTable = "Channel")
     private CmcChannel channel;
 
     /** 监测时间 */
     @Excel(name = "监测时间")
-    private Date Datetime;
+    private String Datetime;
 
     /** 水温数值 */
     @Excel(name = "水温数值")
-    private Float Data;
+    private String Data;
 
     /** Volt */
     @Excel(name = "Volt")
-    private Float Volt;
+    private String Volt;
 
     /** CSQ */
     @Excel(name = "CSQ")
     private Integer CSQ;
 
     @Column(ignore = true)
-    private Date startTime;
+    private String startTime;
 
     @Column(ignore = true)
-    private Date endTime;
+    private String endTime;
 
 }

cmc-temperature-back/cmc-monitoring/src/main/java/com/ruoyi/monitoring/mapper/CmcChannelMapper.java

@@ -3,6 +3,7 @@ package com.ruoyi.monitoring.mapper;
 import com.ruoyi.monitoring.domain.CmcChannel;
 import com.mybatisflex.annotation.UseDataSource;
 import com.mybatisflex.core.BaseMapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -19,4 +20,8 @@ public interface CmcChannelMapper extends BaseMapper<CmcChannel> {
      */
     List<CmcChannel> listChannel(CmcChannel cmcChannel);
 
+    Long selectMaxId();
+
+    int batchInsert(@Param("list") List<CmcChannel> list);
+
 }

cmc-temperature-back/cmc-monitoring/src/main/java/com/ruoyi/monitoring/mapper/CmcTemperatureMapper.java

@@ -25,4 +25,8 @@ public interface CmcTemperatureMapper extends BaseMapper<CmcTemperature> {
                                          @Param("startTime") String startTime,
                                          @Param("endTime") String endTime);
 
+    Long selectMaxId();
+
+    int batchInsert(@Param("list") List<CmcTemperature> list);
+
 }

cmc-temperature-back/cmc-monitoring/src/main/java/com/ruoyi/monitoring/mapper/access/AccessChannelMapper.java

@@ -0,0 +1,18 @@
+package com.ruoyi.monitoring.mapper.access;
+
+import com.mybatisflex.annotation.UseDataSource;
+import com.mybatisflex.core.BaseMapper;
+import com.ruoyi.monitoring.domain.CmcChannel;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@UseDataSource("access")
+public interface AccessChannelMapper extends BaseMapper<CmcChannel> {
+
+    List<CmcChannel> listAll();
+
+    List<CmcChannel> listByIdRange(@Param("minIdExclusive") Long minIdExclusive);
+}
+
+

cmc-temperature-back/cmc-monitoring/src/main/java/com/ruoyi/monitoring/mapper/access/AccessDataMapper.java

@@ -0,0 +1,16 @@
+package com.ruoyi.monitoring.mapper.access;
+
+import com.mybatisflex.annotation.UseDataSource;
+import com.mybatisflex.core.BaseMapper;
+import com.ruoyi.monitoring.domain.CmcTemperature;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@UseDataSource("access")
+public interface AccessDataMapper extends BaseMapper<CmcTemperature> {
+
+    List<CmcTemperature> listByIdRange(@Param("minIdExclusive") Long minIdExclusive);
+}
+
+

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

@@ -0,0 +1,8 @@
+package com.ruoyi.monitoring.service;
+
+public interface IAccessSyncService {
+
+    void syncAccessToSqlite();
+}
+
+

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

@@ -0,0 +1,119 @@
+package com.ruoyi.monitoring.service.impl;
+
+import com.ruoyi.monitoring.domain.CmcChannel;
+import com.ruoyi.monitoring.domain.CmcTemperature;
+import com.ruoyi.monitoring.mapper.CmcChannelMapper;
+import com.ruoyi.monitoring.mapper.CmcTemperatureMapper;
+import com.ruoyi.monitoring.mapper.access.AccessChannelMapper;
+import com.ruoyi.monitoring.mapper.access.AccessDataMapper;
+import com.ruoyi.monitoring.service.IAccessSyncService;
+import org.noear.solon.annotation.Component;
+import org.noear.solon.annotation.Inject;
+
+import java.util.List;
+
+@Component
+public class AccessSyncServiceImpl implements IAccessSyncService {
+
+    // 每批插入的记录数
+    private static final int BATCH_SIZE = 5000;
+
+    @Inject
+    AccessChannelMapper accessChannelMapper;
+
+    @Inject
+    AccessDataMapper accessDataMapper;
+
+    @Inject
+    CmcChannelMapper sqliteChannelMapper;
+
+    @Inject
+    CmcTemperatureMapper sqliteDataMapper;
+
+    @Override
+    public void syncAccessToSqlite() {
+        System.out.println("开始同步Access数据到SQLite...");
+        
+        try {
+            // 同步 Channel：增量，按ID递增同步
+            System.out.println("开始同步Channel表...");
+            Long channelMaxId = sqliteChannelMapper.selectMaxId();
+            if (channelMaxId == null) {
+                channelMaxId = 0L;
+            }
+            System.out.println("SQLite Channel表当前最大ID: " + channelMaxId);
+            List<CmcChannel> newChannels = accessChannelMapper.listByIdRange(channelMaxId);
+            if (newChannels != null && !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：增量，按ID递增同步
+            System.out.println("开始同步Data表...");
+            Long dataMaxId = sqliteDataMapper.selectMaxId();
+            if (dataMaxId == null) {
+                dataMaxId = 0L;
+            }
+            System.out.println("SQLite Data表当前最大ID: " + dataMaxId);
+            List<CmcTemperature> newData = accessDataMapper.listByIdRange(dataMaxId);
+            for (CmcTemperature cmcTemperature : newData) {
+                cmcTemperature.setDatetime(cmcTemperature.getDatetime().replace(".000000", ""));
+                cmcTemperature.setData(cmcTemperature.getData().replace("00000", ""));
+            }
+            if (newData != null && !newData.isEmpty()) {
+                System.out.println("从Access读取到" + newData.size() + "条新Data记录（ID > " + dataMaxId + "）");
+                // 分批插入
+                batchInsertData(newData);
+                System.out.println("Data表同步完成，共同步" + newData.size() + "条新记录");
+            } else {
+                System.out.println("没有新的Data记录需要同步（ID > " + dataMaxId + "）");
+            }
+            
+            System.out.println("Access数据同步到SQLite完成");
+        } catch (Exception e) {
+            System.out.println("同步Access数据到SQLite失败: " + e.getMessage());
+            e.printStackTrace();
+            throw e;
+        }
+    }
+
+    /**
+     * 分批插入Channel记录
+     */
+    private void batchInsertChannels(List<CmcChannel> channels) {
+        int total = channels.size();
+        int batchCount = (total + BATCH_SIZE - 1) / BATCH_SIZE;
+        
+        for (int i = 0; i < batchCount; i++) {
+            int fromIndex = i * BATCH_SIZE;
+            int toIndex = Math.min((i + 1) * BATCH_SIZE, total);
+            List<CmcChannel> batch = channels.subList(fromIndex, toIndex);
+            
+            sqliteChannelMapper.batchInsert(batch);
+            System.out.println("Channel表已插入第 " + (i + 1) + "/" + batchCount + " 批，共 " + batch.size() + " 条记录");
+        }
+    }
+
+    /**
+     * 分批插入Data记录
+     */
+    private void batchInsertData(List<CmcTemperature> dataList) {
+        int total = dataList.size();
+        int batchCount = (total + BATCH_SIZE - 1) / BATCH_SIZE;
+        
+        for (int i = 0; i < batchCount; i++) {
+            int fromIndex = i * BATCH_SIZE;
+            int toIndex = Math.min((i + 1) * BATCH_SIZE, total);
+            List<CmcTemperature> batch = dataList.subList(fromIndex, toIndex);
+            
+            sqliteDataMapper.batchInsert(batch);
+            System.out.println("Data表已插入第 " + (i + 1) + "/" + batchCount + " 批，共 " + batch.size() + " 条记录");
+        }
+    }
+}
+
+

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

@@ -6,11 +6,11 @@ import com.ruoyi.monitoring.domain.CmcChannel;
 import com.ruoyi.monitoring.domain.CmcTemperature;
 import com.ruoyi.monitoring.mapper.CmcChannelMapper;
 import com.ruoyi.monitoring.mapper.CmcTemperatureMapper;
-import com.ruoyi.monitoring.service.ICmcChannelService;
 import com.ruoyi.monitoring.service.ICmcTemperatureService;
 import org.noear.solon.annotation.Component;
 import org.noear.solon.annotation.Inject;
 
+import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
@@ -42,9 +42,7 @@ public class CmcTemperatureServiceImpl extends ServiceImpl<CmcTemperatureMapper,
 //        QueryWrapper qw = getQW(cmcTemperature, cmcChannel);
 //        List<CmcTemperature> records = cmcTemperatureMapper.selectListByQuery(qw);
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        String startStr = cmcTemperature.getStartTime() == null ? null : sdf.format(cmcTemperature.getStartTime());
-        String endStr = cmcTemperature.getEndTime() == null ? null : sdf.format(cmcTemperature.getEndTime());
-        List<CmcTemperature> records = cmcTemperatureMapper.listTemperature(cmcTemperature, cmcChannel, startStr, endStr);
+        List<CmcTemperature> records = cmcTemperatureMapper.listTemperature(cmcTemperature, cmcChannel, cmcTemperature.getStartTime(), cmcTemperature.getEndTime());
         if (records == null || records.isEmpty()) {
             return new ArrayList<>();
         }
@@ -56,7 +54,7 @@ public class CmcTemperatureServiceImpl extends ServiceImpl<CmcTemperatureMapper,
             long diffInMillis;
             // 第30条与第31条数据时间差 毫秒
             if (channelSize > 30 && records.size() > 30) {
-                diffInMillis = records.get(30).getDatetime().getTime() - records.get(29).getDatetime().getTime();
+                diffInMillis = parseStringToDate(records.get(30).getDatetime()).getTime() - parseStringToDate(records.get(29).getDatetime()).getTime();
                 // 时间差超过15分钟，删最后10条数据
                 if (diffInMillis / 1000 / 60 > 15) {
                     // 使用更安全的方式删除数据，避免内存泄漏
@@ -67,7 +65,7 @@ public class CmcTemperatureServiceImpl extends ServiceImpl<CmcTemperatureMapper,
 
             // 第1条数据与0时时间差 毫秒
             if (!records.isEmpty() && cmcTemperature.getStartTime() != null) {
-                diffInMillis = records.get(0).getDatetime().getTime() - cmcTemperature.getStartTime().getTime();
+                diffInMillis = parseStringToDate(records.get(0).getDatetime()).getTime() - parseStringToDate(cmcTemperature.getStartTime()).getTime();
                 if (diffInMillis / 1000 / 60 > 15) {
                     int removeStart = Math.max(0, records.size() - channelSize);
                     records = new ArrayList<>(records.subList(0, removeStart));
@@ -76,15 +74,14 @@ public class CmcTemperatureServiceImpl extends ServiceImpl<CmcTemperatureMapper,
 
             // 查询15分钟前的数据
             CmcTemperature temperature = new CmcTemperature();
-            long fifteenMinutesAgoMillis = cmcTemperature.getStartTime().getTime() - (15 * 60 * 1000);
+            long fifteenMinutesAgoMillis = parseStringToDate(cmcTemperature.getStartTime()).getTime() - (15 * 60 * 1000);
             Date fifteenMinutesAgo = new Date(fifteenMinutesAgoMillis);
-            temperature.setStartTime(fifteenMinutesAgo);
+            String fifteenMinutesAgoString = sdf.format(fifteenMinutesAgo);
+            temperature.setStartTime(fifteenMinutesAgoString);
             temperature.setEndTime(cmcTemperature.getStartTime());
 //            QueryWrapper qw1 = getQW(temperature, cmcChannel);
 //            List<CmcTemperature> previousData = cmcTemperatureMapper.selectListByQuery(qw1);
-            String prevStart = temperature.getStartTime() == null ? null : sdf.format(temperature.getStartTime());
-            String prevEnd = temperature.getEndTime() == null ? null : sdf.format(temperature.getEndTime());
-            List<CmcTemperature> previousData = cmcTemperatureMapper.listTemperature(temperature, cmcChannel, prevStart, prevEnd);
+            List<CmcTemperature> previousData = cmcTemperatureMapper.listTemperature(temperature, cmcChannel,  temperature.getStartTime(), temperature.getEndTime());
 
             if (previousData != null && !previousData.isEmpty()) {
                 // 合并数据，避免重复创建列表
@@ -107,27 +104,27 @@ public class CmcTemperatureServiceImpl extends ServiceImpl<CmcTemperatureMapper,
      * @param temperatureList 温度数据列表
      * @param channelSize 通道数量
      */
-    private void processTemperatureData(List<CmcTemperature> temperatureList, int channelSize) {
+    private void processTemperatureData(List<CmcTemperature> temperatureList, int channelSize){
         // 使用迭代器模式，避免频繁的索引访问
         for (int i = 0; i < temperatureList.size() - channelSize + 1; i += channelSize) {
             if (i + channelSize > temperatureList.size()) {
                 break;
             }
 
-            Date minTime = temperatureList.get(i).getDatetime();
+            String minTime = temperatureList.get(i).getDatetime();
 
             // 优化时间比较逻辑
             if (i + 10 < temperatureList.size() &&
-                    temperatureList.get(i + 10).getDatetime().getTime() > minTime.getTime()) {
+                    parseStringToDate(temperatureList.get(i + 10).getDatetime()).getTime() > parseStringToDate(minTime).getTime()) {
                 // 更新第10-30条数据的时间
                 for (int j = i + 10; j < Math.min(i + channelSize, temperatureList.size()); j++) {
-                    temperatureList.get(j).setDatetime(new Date(minTime.getTime()));
+                    temperatureList.get(j).setDatetime(minTime);
                 }
             } else if (i + 30 < temperatureList.size() &&
-                    temperatureList.get(i + 30).getDatetime().getTime() > minTime.getTime()) {
+                    parseStringToDate(temperatureList.get(i + 30).getDatetime()).getTime() > parseStringToDate(minTime).getTime()) {
                 // 更新第30条之后数据的时间
                 for (int j = i + 30; j < Math.min(i + channelSize, temperatureList.size()); j++) {
-                    temperatureList.get(j).setDatetime(new Date(minTime.getTime()));
+                    temperatureList.get(j).setDatetime(minTime);
                 }
             }
         }
@@ -156,4 +153,13 @@ public class CmcTemperatureServiceImpl extends ServiceImpl<CmcTemperatureMapper,
         return qw;
     }
 
+    private Date parseStringToDate(String dateTimeStr) {
+        try {
+            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            return format.parse(dateTimeStr);
+        } catch (ParseException e) {
+            // 处理解析异常，或者返回默认值
+            return new Date();
+        }
+    }
 }

cmc-temperature-back/cmc-monitoring/src/main/resources/mapper/access/AccessChannelMapper.xml

@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.ruoyi.monitoring.mapper.access.AccessChannelMapper">
+
+    <resultMap type="com.ruoyi.monitoring.domain.CmcChannel" id="CmcChannelResult">
+        <id     property="Id"      column="ID"      />
+        <result property="SensorNo"     column="Sensor_No"     />
+        <result property="Info"   column="Info"   />
+        <result property="Ver"    column="Ver"    />
+        <result property="Sn"      column="Sn"      />
+        <result property="Ca"    column="Ca"    />
+        <result property="Cb"    column="Cb"    />
+        <result property="Units"    column="Units"    />
+        <result property="LastDT"    column="LastDT"    />
+    </resultMap>
+
+    <select id="listAll" resultMap="CmcChannelResult">
+        SELECT c.ID, c.Sensor_No, c.Info, c.Ver, c.Sn, c.Ca, c.Cb, c.Units, c.LastDT
+        FROM Channel c
+    </select>
+
+    <select id="listByIdRange" resultMap="CmcChannelResult">
+        SELECT c.ID, c.Sensor_No, c.Info, c.Ver, c.Sn, c.Ca, c.Cb, c.Units, c.LastDT
+        FROM Channel c
+        WHERE c.ID > #{minIdExclusive}
+        ORDER BY c.ID ASC
+    </select>
+
+</mapper>
+

cmc-temperature-back/cmc-monitoring/src/main/resources/mapper/access/AccessDataMapper.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.ruoyi.monitoring.mapper.access.AccessDataMapper">
+
+    <resultMap type="com.ruoyi.monitoring.domain.CmcTemperature" id="CmcTemperatureResult">
+        <id     property="Id"      column="ID"      />
+        <result property="GroupNo"    column="Group_No"    />
+        <result property="SensorNo"     column="Sensor_No"     />
+        <result property="Datetime"   column="DateTime"   />
+        <result property="Data"    column="Data"    />
+        <result property="Volt"      column="Volt"      />
+        <result property="CSQ"    column="CSQ"    />
+    </resultMap>
+
+    <select id="listByIdRange" resultMap="CmcTemperatureResult">
+        SELECT d.ID, d.Group_No, d.Sensor_No, d.DateTime, d.Data, d.Volt, d.CSQ
+        FROM Data d
+        WHERE d.ID &gt; #{minIdExclusive}
+        ORDER BY d.ID ASC
+    </select>
+
+</mapper>
+

cmc-temperature-back/cmc-monitoring/src/main/resources/mapper/temperature/CmcChannelMapper.xml

@@ -35,4 +35,16 @@
         </where>
     </select>
 
+    <select id="selectMaxId" resultType="long">
+        SELECT IFNULL(MAX(ID), 0) FROM Channel
+    </select>
+
+    <insert id="batchInsert">
+        INSERT INTO Channel (ID, Sensor_No, Info, Ver, Sn, Ca, Cb, Units, LastDT)
+        VALUES
+        <foreach collection="list" item="item" separator=",">
+            (#{item.Id}, #{item.SensorNo}, #{item.Info}, #{item.Ver}, #{item.Sn}, #{item.Ca}, #{item.Cb}, #{item.Units}, #{item.LastDT})
+        </foreach>
+    </insert>
+
 </mapper>

cmc-temperature-back/cmc-monitoring/src/main/resources/mapper/temperature/CmcTemperatureMapper.xml

@@ -25,17 +25,29 @@
     <select id="listTemperature" resultMap="CmcTemperatureResult">
         <include refid="selectTemperatureVo"/>
         <where>
-            <if test="CmcTemperature != null and CmcTemperature.Id != null">d.ID = #{CmcTemperature.Id}</if>
-            <if test="CmcTemperature != null and CmcTemperature.GroupNo != null">AND d.Group_No = #{CmcTemperature.GroupNo}</if>
-            <if test="CmcTemperature != null and CmcTemperature.SensorNo != null">AND d.Sensor_No = #{CmcTemperature.SensorNo}</if>
-            <if test="CmcTemperature != null and CmcTemperature.Data != null">AND d.Data = #{CmcTemperature.Data}</if>
-            <if test="CmcTemperature != null and CmcTemperature.Volt != null">AND d.Volt = #{CmcTemperature.Volt}</if>
-            <if test="CmcTemperature != null and CmcTemperature.CSQ != null">AND d.CSQ = #{CmcTemperature.CSQ}</if>
+            <if test="cmcTemperature != null and cmcTemperature.Id != null">d.ID = #{cmcTemperature.Id}</if>
+            <if test="cmcTemperature != null and cmcTemperature.GroupNo != null">AND d.Group_No = #{cmcTemperature.GroupNo}</if>
+            <if test="cmcTemperature != null and cmcTemperature.SensorNo != null">AND d.Sensor_No = #{cmcTemperature.SensorNo}</if>
+            <if test="cmcTemperature != null and cmcTemperature.Data != null">AND d.Data = #{cmcTemperature.Data}</if>
+            <if test="cmcTemperature != null and cmcTemperature.Volt != null">AND d.Volt = #{cmcTemperature.Volt}</if>
+            <if test="cmcTemperature != null and cmcTemperature.CSQ != null">AND d.CSQ = #{cmcTemperature.CSQ}</if>
             <if test="startTime != null and startTime != ''">AND d.DateTime &gt;= #{startTime}</if>
             <if test="endTime != null and endTime != ''">AND d.DateTime &lt;= #{endTime}</if>
-            <if test="CmcChannel != null and CmcChannel.Info != null and CmcChannel.Info != ''">AND c.Info LIKE '%' || #{CmcChannel.Info} || '%'</if>
+            <if test="cmcChannel != null and cmcChannel.Info != null and cmcChannel.Info != ''">AND c.Info LIKE '%' || #{cmcChannel.Info} || '%'</if>
         </where>
         ORDER BY d.DateTime ASC, d.Sensor_No ASC
     </select>
 
+    <select id="selectMaxId" resultType="long">
+        SELECT IFNULL(MAX(ID), 0) FROM Data
+    </select>
+
+    <insert id="batchInsert">
+        INSERT INTO Data (ID, Group_No, Sensor_No, DateTime, Data, Volt, CSQ)
+        VALUES
+        <foreach collection="list" item="item" separator=",">
+            (#{item.Id}, #{item.GroupNo}, #{item.SensorNo}, #{item.Datetime}, #{item.Data}, #{item.Volt}, #{item.CSQ})
+        </foreach>
+    </insert>
+
 </mapper>

cmc-temperature-back/ruoyi-admin/src/main/resources/quartz.properties

@@ -1,27 +1,22 @@
-# 指定持久化方案
-org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
-org.quartz.jobStore.acquireTriggersWithinLock=true
+# 指定持久化方案 - 使用内存模式（避免SQLite BLOB问题）
+org.quartz.jobStore.class=org.quartz.simpl.RAMJobStore
 org.quartz.jobStore.misfireThreshold=5000
 
-# 指定表前缀
-org.quartz.jobStore.tablePrefix=QRTZ_
-
-# 指定数据源
-org.quartz.jobStore.dataSource=ryDS
-
-org.quartz.dataSource.ryDS.provider=hikaricp
-org.quartz.dataSource.ryDS.driver=org.sqlite.JDBC
-org.quartz.dataSource.ryDS.URL=jdbc:sqlite::resource:static/cmc-temperature.db?date_string_format=yyyy-MM-dd HH:mm:ss
-org.quartz.dataSource.ryDS.user=
-org.quartz.dataSource.ryDS.password=
+# 如果需要使用数据库持久化，请取消下面的注释并注释掉上面的RAMJobStore配置
+# 注意：SQLite不支持BLOB操作，建议使用MySQL
+#org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
+#org.quartz.jobStore.acquireTriggersWithinLock=true
+#org.quartz.jobStore.misfireThreshold=5000
+#org.quartz.jobStore.tablePrefix=QRTZ_
+#org.quartz.jobStore.dataSource=ryDS
 #org.quartz.dataSource.ryDS.provider=hikaricp
 #org.quartz.dataSource.ryDS.driver=com.mysql.cj.jdbc.Driver
 #org.quartz.dataSource.ryDS.URL=jdbc:mysql://127.0.0.1:3306/ry-vue?useUnicode=true&zeroDateTimeBehavior=convertToNull&autoReconnect=true
 #org.quartz.dataSource.ryDS.user=root
 #org.quartz.dataSource.ryDS.password=
-org.quartz.dataSource.ryDS.maxConnections=10
-org.quartz.datasource.ryDS.validateOnCheckout=true
-org.quartz.datasource.ryDS.validationQuery=select 1
+#org.quartz.dataSource.ryDS.maxConnections=10
+#org.quartz.datasource.ryDS.validateOnCheckout=true
+#org.quartz.datasource.ryDS.validationQuery=select 1
 
 # 指定线程池
 org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool

cmc-temperature-back/ruoyi-schedule/pom.xml

@@ -32,6 +32,10 @@
             <groupId>com.ruoyi</groupId>
             <artifactId>ruoyi-system</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.ruoyi</groupId>
+            <artifactId>cmc-monitoring</artifactId>
+        </dependency>
     </dependencies>
     
 </project>

cmc-temperature-back/ruoyi-schedule/src/main/java/com/ruoyi/schedule/mapper/SysJobLogMapper.java

@@ -1,5 +1,6 @@
 package com.ruoyi.schedule.mapper;
 
+import com.mybatisflex.annotation.UseDataSource;
 import com.mybatisflex.core.BaseMapper;
 import com.ruoyi.schedule.domain.SysJobLog;
 
@@ -7,6 +8,7 @@ import com.ruoyi.schedule.domain.SysJobLog;
  * 定时任务调度日志 数据层
  * @author ruoyi
  */
+@UseDataSource("sqlite")
 public interface SysJobLogMapper extends BaseMapper<SysJobLog> {
 
     /**

cmc-temperature-ui/src/views/temperature/temMonitor.vue

@@ -78,7 +78,7 @@
                       :label="sensor.sensorName" width="120" align="center" show-overflow-tooltip>
                       <template #default="scope">
                         <span>
-                          {{ scope.row[sensor.sensorName] ? scope.row[sensor.sensorName].toFixed(2) : '-' }}
+                          {{ scope.row[sensor.sensorName] ? Number(scope.row[sensor.sensorName]).toFixed(2) : '-' }}
                         </span>
                       </template>
                     </el-table-column>