对接牦牛资产档案

baqing-admin/src/main/java/com/ruoyi/web/modules/industryservice/service/IotDataIncrementalSyncService.java

@@ -21,7 +21,7 @@ import com.ruoyi.web.modules.industryservice.support.IotSyncSupport.SyncQuery;
 /**
  * IoT 数据同步编排服务。
  * <p>
- * 每日 11:15 由 {@link com.ruoyi.web.modules.industryservice.task.IotDataIncrementalSyncTask} 触发。
+ * 每日凌晨 1:00 由 {@link com.ruoyi.web.modules.industryservice.task.IotDataIncrementalSyncTask} 触发。
  * </p>
  *
  * <h3>全量 / 增量策略（按表独立判断）</h3>

baqing-admin/src/main/java/com/ruoyi/web/modules/industryservice/task/IotDataIncrementalSyncTask.java

@@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
 /**
  * IoT 数据增量同步定时任务（Quartz 调用：{@code iotDataIncrementalSyncTask.syncIncremental}）。
  * <p>
- * 建议 cron：{@code 0 15 11 * * ?}（每天 11:15）。
+ * 建议 cron：{@code 0 0 1 * * ?}（每天凌晨 1:00）。
  * 同步牛只称重、定位项圈、环境监测三类数据。
  * </p>
  */

baqing-admin/src/main/resources/mapper/industryservice/BizEnvMonitoringRecordMapper.xml

@@ -34,7 +34,7 @@
     </select>
 
     <select id="selectMaxMonitoringTime" resultType="java.util.Date">
-        select max(monitoring_time) from biz_env_monitoring_record where del_flag = '0'
+        select max(monitoring_time) from biz_env_monitoring_record
     </select>
 
     <select id="countRecords" resultType="long">

baqing-admin/src/main/resources/mapper/industryservice/BizYakCollarLocationMapper.xml

@@ -28,7 +28,7 @@
     </select>
 
     <select id="selectMaxReportTime" resultType="java.util.Date">
-        select max(report_time) from biz_yak_collar_location where del_flag = '0'
+        select max(report_time) from biz_yak_collar_location
     </select>
 
     <select id="countRecords" resultType="long">

baqing-admin/src/main/resources/mapper/industryservice/BizYakWeighingRecordMapper.xml

@@ -34,7 +34,7 @@
     </select>
 
     <select id="selectMaxWeighingTime" resultType="java.util.Date">
-        select max(weighing_time) from biz_yak_weighing_record where del_flag = '0'
+        select max(weighing_time) from biz_yak_weighing_record
     </select>
 
     <select id="countRecords" resultType="long">

sql/biz_sys_job_iot_data_incremental_sync.sql

@@ -1,4 +1,4 @@
+-- IoT 数据每日凌晨 1:00 增量同步（需在「系统管理-定时任务」中启用）
 -- 调用目标：iotDataIncrementalSyncTask.syncIncremental
 -- 若 job_id 冲突请调整主键后执行
 
@@ -10,7 +10,7 @@ INSERT INTO sys_job (
     'IoT数据每日增量同步',
     'DEFAULT',
     'iotDataIncrementalSyncTask.syncIncremental',
-    '0 15 11 * * ?',
+    '0 0 1 * * ?',
     '3',
     '1',
     '0',