docs: unify roadmap structure and sync all stages
This commit is contained in:
@@ -3,11 +3,11 @@
|
||||
from __future__ import annotations
|
||||
|
||||
import asyncio
|
||||
import random
|
||||
from datetime import datetime
|
||||
|
||||
from src.core.config import load_settings
|
||||
from src.trading.auto.state import AutoTradeState
|
||||
from src.trading.strategies.base import HoldStrategy, StrategyContext
|
||||
|
||||
|
||||
class AutoTradeService:
|
||||
@@ -115,6 +115,20 @@ class AutoTradeService:
|
||||
state.risk_percent = risk_percent
|
||||
return state
|
||||
|
||||
# собрать контекст для стратегии
|
||||
def _build_strategy_context(self) -> StrategyContext:
|
||||
state = self.get_state()
|
||||
|
||||
return StrategyContext(
|
||||
symbol=state.symbol,
|
||||
status=state.status,
|
||||
risk_percent=state.risk_percent,
|
||||
)
|
||||
|
||||
# получить стратегию для текущего цикла
|
||||
def _get_strategy(self) -> HoldStrategy:
|
||||
return HoldStrategy()
|
||||
|
||||
# выполнить один цикл анализа рынка
|
||||
def run_cycle(self) -> AutoTradeState:
|
||||
state = self.get_state()
|
||||
@@ -122,7 +136,11 @@ class AutoTradeService:
|
||||
if state.status == "OFF":
|
||||
return state
|
||||
|
||||
strategy = self._get_strategy()
|
||||
context = self._build_strategy_context()
|
||||
result = strategy.analyze(context)
|
||||
|
||||
state.last_check_at = datetime.now().strftime("%H:%M:%S")
|
||||
state.last_signal = random.choice(["BUY", "SELL", "HOLD"])
|
||||
state.last_signal = result.signal.value
|
||||
|
||||
return state
|
||||
45
app/src/trading/strategies/base.py
Normal file
45
app/src/trading/strategies/base.py
Normal file
@@ -0,0 +1,45 @@
|
||||
# app/src/trading/strategies/base.py
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from dataclasses import dataclass
|
||||
from typing import Protocol
|
||||
|
||||
from src.trading.strategies.signals import SignalResult, SignalType
|
||||
|
||||
|
||||
@dataclass(slots=True)
|
||||
class StrategyContext:
|
||||
# выбранный торговый инструмент
|
||||
symbol: str
|
||||
|
||||
# текущий режим автоторговли: OBSERVING / RUNNING
|
||||
status: str
|
||||
|
||||
# риск на сделку в процентах
|
||||
risk_percent: float | None = None
|
||||
|
||||
|
||||
class BaseStrategy(Protocol):
|
||||
# техническое имя стратегии
|
||||
name: str
|
||||
|
||||
# выполнить анализ и вернуть торговый сигнал
|
||||
def analyze(self, context: StrategyContext) -> SignalResult:
|
||||
...
|
||||
|
||||
|
||||
class HoldStrategy:
|
||||
name = "HOLD"
|
||||
|
||||
# безопасная стратегия по умолчанию: ничего не делает
|
||||
def analyze(self, context: StrategyContext) -> SignalResult:
|
||||
return SignalResult(
|
||||
signal=SignalType.HOLD,
|
||||
reason="Стратегия не выбрана. Используется безопасный HOLD.",
|
||||
confidence=0.0,
|
||||
payload={
|
||||
"symbol": context.symbol,
|
||||
"status": context.status,
|
||||
},
|
||||
)
|
||||
32
app/src/trading/strategies/signals.py
Normal file
32
app/src/trading/strategies/signals.py
Normal file
@@ -0,0 +1,32 @@
|
||||
# app/src/trading/strategies/signals.py
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from dataclasses import dataclass
|
||||
from enum import StrEnum
|
||||
|
||||
|
||||
class SignalType(StrEnum):
|
||||
# купить
|
||||
BUY = "BUY"
|
||||
|
||||
# продать
|
||||
SELL = "SELL"
|
||||
|
||||
# ничего не делать
|
||||
HOLD = "HOLD"
|
||||
|
||||
|
||||
@dataclass(slots=True)
|
||||
class SignalResult:
|
||||
# итоговый сигнал стратегии
|
||||
signal: SignalType
|
||||
|
||||
# человекочитаемая причина сигнала
|
||||
reason: str
|
||||
|
||||
# уверенность стратегии от 0.0 до 1.0
|
||||
confidence: float = 0.0
|
||||
|
||||
# дополнительные данные стратегии для логов / отладки
|
||||
payload: dict | None = None
|
||||
Reference in New Issue
Block a user