Macbook
97 lines
4.3 KiB
Java
97 lines
4.3 KiB
Java
package com.goldenchart.service;
|
|
|
|
import com.goldenchart.dto.LiveStrategySettingsDto;
|
|
import com.goldenchart.dto.LiveSummaryDto;
|
|
import com.goldenchart.dto.PaperSummaryDto;
|
|
import com.goldenchart.dto.TradeSignalDto;
|
|
import com.goldenchart.entity.GcAppSettings;
|
|
import com.goldenchart.repository.GcLiveStrategySettingsRepository;
|
|
import com.goldenchart.repository.GcTradeSignalRepository;
|
|
import com.goldenchart.repository.GcWatchlistRepository;
|
|
import com.goldenchart.trading.pipeline.*;
|
|
import lombok.RequiredArgsConstructor;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
@Service
|
|
@RequiredArgsConstructor
|
|
public class DashboardService {
|
|
|
|
private final AppSettingsService appSettingsService;
|
|
private final PaperTradingService paperTradingService;
|
|
private final LiveTradingService liveTradingService;
|
|
private final LiveStrategySettingsService liveStrategySettingsService;
|
|
private final GcWatchlistRepository watchlistRepo;
|
|
private final GcTradeSignalRepository signalRepo;
|
|
private final GcLiveStrategySettingsRepository liveSettingsRepo;
|
|
private final FcmPushService fcmPushService;
|
|
private final PipelineMonitorService pipelineMonitorService;
|
|
|
|
@Transactional(readOnly = true)
|
|
public Map<String, Object> buildSummary(Long userId, String deviceId) {
|
|
Map<String, Object> out = new HashMap<>();
|
|
GcAppSettings app = appSettingsService.getEntity(userId, deviceId);
|
|
|
|
out.put("app", Map.of(
|
|
"tradingMode", app.getTradingMode() != null ? app.getTradingMode() : "PAPER",
|
|
"liveAutoTradeEnabled", Boolean.TRUE.equals(app.getLiveAutoTradeEnabled()),
|
|
"paperAutoTradeEnabled", Boolean.TRUE.equals(app.getPaperAutoTradeEnabled()),
|
|
"liveStrategyCheck", Boolean.TRUE.equals(app.getLiveStrategyCheck()),
|
|
"chartRealtimeSource", app.getChartRealtimeSource() != null ? app.getChartRealtimeSource() : "BACKEND_STOMP",
|
|
"fcmPushEnabled", Boolean.TRUE.equals(app.getFcmPushEnabled()),
|
|
"hasUpbitKeys", liveTradingService.hasApiKeys(app)
|
|
));
|
|
|
|
int watchlistCount = userId != null
|
|
? watchlistRepo.findByUserIdOrderByDisplayOrderAsc(userId).size()
|
|
: watchlistRepo.findByDeviceIdOrderByDisplayOrderAsc(deviceId).size();
|
|
out.put("watchlistCount", watchlistCount);
|
|
|
|
int liveCheckMarkets = userId != null
|
|
? (int) liveSettingsRepo.findAllByIsLiveCheckTrueAndUserIdIsNotNull().stream()
|
|
.filter(s -> userId.equals(s.getUserId()))
|
|
.count()
|
|
: 0;
|
|
out.put("liveCheckMarkets", liveCheckMarkets);
|
|
|
|
List<LiveStrategySettingsDto> active = liveStrategySettingsService.listActive(userId, deviceId);
|
|
out.put("monitoredMarkets", active.size());
|
|
|
|
if (userId != null) {
|
|
out.put("paper", paperTradingService.getSummary(userId, null));
|
|
out.put("live", liveTradingService.getSummary(userId));
|
|
} else {
|
|
out.put("paper", PaperSummaryDto.builder().build());
|
|
out.put("live", LiveSummaryDto.builder().build());
|
|
}
|
|
|
|
List<TradeSignalDto> recentSignals = (userId != null
|
|
? signalRepo.findByUserIdOrderByCreatedAtDesc(userId)
|
|
: signalRepo.findByDeviceIdOrderByCreatedAtDesc(deviceId != null ? deviceId : ""))
|
|
.stream().limit(8)
|
|
.map(s -> TradeSignalDto.builder()
|
|
.id(s.getId())
|
|
.market(s.getMarket())
|
|
.signalType(s.getSignalType())
|
|
.price(s.getPrice())
|
|
.candleType(s.getCandleType())
|
|
.createdAt(s.getCreatedAt() != null ? s.getCreatedAt().toString() : null)
|
|
.build())
|
|
.toList();
|
|
out.put("recentSignals", recentSignals);
|
|
|
|
out.put("systemMonitor", pipelineMonitorService.buildMonitorSnapshot());
|
|
|
|
out.put("fcm", Map.of(
|
|
"available", fcmPushService.isAvailable(),
|
|
"pushEnabled", Boolean.TRUE.equals(app.getFcmPushEnabled())
|
|
));
|
|
|
|
return out;
|
|
}
|
|
}
|