From 7676a9f1aceea1ca864c1035ebc9965deacd73eb Mon Sep 17 00:00:00 2001
From: cryptooda <crypto.oda@gmail.com>
Date: Tue, 28 Oct 2025 18:27:56 +0700
Subject: [PATCH] Fix influxdb candle fetch

---
 .../InfluxDb/AgentBalanceRepository.cs                          | 1 +
 .../InfluxDb/CandleRepository.cs                                | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs b/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs
index ae74ca2f..e329ae8d 100644
--- a/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs
+++ b/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs
@@ -88,6 +88,7 @@ public class AgentBalanceRepository : IAgentBalanceRepository
                        $") " +
                        $"|> filter(fn: (r) => r[\"user_id\"] == \"{userId}\") " +
                        $"|> aggregateWindow(every: {samplingInterval}, fn: last, createEmpty: false) " +
+                       $"|> drop(columns: [\"_start\", \"_stop\"])" +
                        $"|> pivot(rowKey: [\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")";
 
             var result = await query.QueryAsync<AgentBalanceDto>(flux, _influxDbRepository.Organization);
diff --git a/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs b/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs
index 4baea514..ed95ec12 100644
--- a/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs
+++ b/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs
@@ -37,6 +37,7 @@ public class CandleRepository : ICandleRepository
                        $"|> filter(fn: (r) => r[\"exchange\"] == \"{exchange}\")" +
                        $"|> filter(fn: (r) => r[\"ticker\"] == \"{ticker}\")" +
                        $"|> filter(fn: (r) => r[\"timeframe\"] == \"{timeframe}\")" +
+                       $"|> drop(columns: [\"_start\", \"_stop\"])" +
                        $"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")";
             if (limit != null)
             {
@@ -65,6 +66,7 @@ public class CandleRepository : ICandleRepository
                        $"|> filter(fn: (r) => r[\"exchange\"] == \"{exchange}\")" +
                        $"|> filter(fn: (r) => r[\"ticker\"] == \"{ticker}\")" +
                        $"|> filter(fn: (r) => r[\"timeframe\"] == \"{timeframe}\")" +
+                       $"|> drop(columns: [\"_start\", \"_stop\"])" +
                        $"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")";
             if (limit != null)
             {