From 6609c02ebffba20780db28846b31bfba03cefa94 Mon Sep 17 00:00:00 2001 From: lihongjie0209 Date: Sat, 21 Dec 2024 16:06:05 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=89=8D=E6=9C=9F=E6=B2=A1=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E5=AF=BC=E8=87=B4=E5=9B=9E=E6=94=B6=E5=9B=BE=E8=A1=A8?= =?UTF-8?q?=E4=B8=BA=E7=A9=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../coal/pdcDeviceData/service/PdcDeviceDataService.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/main/java/cn/lihongjie/coal/pdcDeviceData/service/PdcDeviceDataService.java b/src/main/java/cn/lihongjie/coal/pdcDeviceData/service/PdcDeviceDataService.java index 1f4dfbc9..c2146cb4 100644 --- a/src/main/java/cn/lihongjie/coal/pdcDeviceData/service/PdcDeviceDataService.java +++ b/src/main/java/cn/lihongjie/coal/pdcDeviceData/service/PdcDeviceDataService.java @@ -181,7 +181,13 @@ public class PdcDeviceDataService with tmp as (select d.device_id, time_bucket_gapfill(cast(:bucket as interval), d.time) as tb, - interpolate(max(d.total_data)) as total_data + interpolate(max(d.total_data), (select ('2024-12-18 00:00:00'::timestamp, (select total_data + from t_pdc_device_data x + where x.time >= :startTime + AND x.time <= :endTime + and x.device_id = d.device_id + order by x.time + limit 1)))) as total_data from t_pdc_device_data d left join t_pdc_device pdc on d.device_id = pdc.id