| | |
|---|
| | | package com.ruoyi.config; |
|---|
| | | |
|---|
| | | import org.springframework.scheduling.annotation.Scheduled; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import com.ruoyi.system.service.ITestBackfillService; |
|---|
| | | |
|---|
| | | /** 以较低优先级执行历史补采；实时设备观测由既有调度器优先完成。 */ |
|---|
| | | @Component |
|---|
| | | public class TestBackfillScheduler |
|---|
| | | { |
|---|
| | | private final ITestBackfillService backfill; |
|---|
| | | |
|---|
| | | public TestBackfillScheduler(ITestBackfillService backfill) |
|---|
| | | { |
|---|
| | | this.backfill = backfill; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Scheduled(fixedDelay = 3000) |
|---|
| | | public void reconcileAndBackfill() |
|---|
| | | { |
|---|
| | | backfill.reconcileNaturalEnd(); |
|---|
| | | backfill.resumePendingBackfill(); |
|---|
| | | } |
|---|
| | | /** Ticket28 移除历史补采调度，保留空组件避免旧配置加载失败。 */ |
|---|
| | | public void reconcileAndBackfill() { } |
|---|
| | | } |
|---|
