ФрилансРазделы

⏱️ Urgent project – looking for an experienced developer to finalize MT4 bot (deadline: Tuesday)

MQL5 Эксперты Forex Отладка робота/индикатора Выгрузка данных на сайт

Техническое задание

"""
Fast Multi-Pair RSI Trading Bot
Supports:
- BTCUSDT
- XAUUSD
- GBPUSD

Opens fast buy or sell trades based on RSI signals
Closes trades after 5, 10, or 15 minutes
"""

import asyncio
import time
from dataclasses import dataclass, field
from typing import Dict, List, Optional
import pandas as pd
import numpy as np

# ===== RSI calculation ===== #
def compute_rsi(close: pd.Series, period: int = 14) -> pd.Series:
    delta = close.diff()
    gain = delta.clip(lower=0)
    loss = -delta.clip(upper=0)
    avg_gain = gain.ewm(alpha=1 / period, adjust=False).mean()
    avg_loss = loss.ewm(alpha=1 / period, adjust=False).mean()
    rs = avg_gain / avg_loss
    return 100 - (100 / (1 + rs))

# ===== Position structure ===== #
@dataclass
class Position:
    id: str
    symbol: str
    side: str
    entry_price: float
    size: float
    opened_at: float
    duration_min: int

# ===== Config ===== #
@dataclass
class BotConfig:
    symbols: List[str] = field(default_factory=lambda: ["BTCUSDT", "XAUUSD", "GBPUSD"])
    rsi_period: int = 14
    rsi_oversold: int = 30
    rsi_overbought: int = 70
    durations_min: List[int] = field(default_factory=lambda: [5, 10, 15])
    account_equity: float = 2000.0
    risk_pct: float = 0.5
    lot_size: Optional[float] = None
    paper: bool = True

# ===== Trading Bot ===== #
class MultiPairRSIBot:
    def __init__(self, cfg: BotConfig):
        self.cfg = cfg
        self.data: Dict[str, pd.DataFrame] = {sym: pd.DataFrame() for sym in cfg.symbols}
        self.positions: Dict[str, Dict[str, Position]] = {sym: {} for sym in cfg.symbols}
        self._id = 0

    # ========== Fake 1-minute feed for PAPER mode ========== #
    def get_fake_ohlcv(self, symbol):
        now = int(time.time()) * 1000
        df = self.data[symbol]

        last_close = df["close"].iloc[-1] if not df.empty else 1000 + np.random.rand() * 10
        change = np.random.normal(0, 0.0008)
        close = last_close * (1 + change)
        high = max(last_close, close)
        low = min(last_close, close)

        return (now, last_close, high, low, close, 0)

    # ========== Append new candle ========== #
    def append_candle(self, symbol, ohlc):
        ts, o, h, l, c, v = ohlc
        row = {"timestamp": pd.to_datetime(ts, unit="ms"),
               "open": o, "high": h, "low": l, "close": c, "volume": v}
        self.data[symbol] = pd.concat([self.data[symbol], pd.DataFrame([row])], ignore_index=True)
        if len(self.data[symbol]) > 2000:
            self.data[symbol] = self.data[symbol].iloc[-2000:]

    # ========== Timeframe aggregation ========== #
    def to_tf(self, symbol, minutes):
        df = self.data[symbol]
        if df.empty:
            return pd.DataFrame()
        df["bucket"] = df["timestamp"].dt.floor(f"{minutes}T")
        out = df.groupby("bucket").agg({
            "open": "first",
            "high": "max",
            "low": "min",
            "close": "last",
            "volume": "sum"
        }).reset_index().rename(columns={"bucket": "timestamp"})
        return out

    # ========== Position sizing ========== #
    def get_size(self, price):
        if self.cfg.lot_size:
            return self.cfg.lot_size
        risk_amount = self.cfg.account_equity * (self.cfg.risk_pct / 100)
        return round(risk_amount / price, 4)

    # ========== Check RSI signals and enter trades ========== #
    async def process_signals(self, symbol):
        for dur in self.cfg.durations_min:
            df = self.to_tf(symbol, dur)
            if len(df) < self.cfg.rsi_period + 2:
                continue

            df["rsi"] = compute_rsi(df["close"], self.cfg.rsi_period)

            prev = df["rsi"].iloc[-2]
            last = df["rsi"].iloc[-1]
            price = df["close"].iloc[-1]

            # BUY: RSI cross up
            if prev <= self.cfg.rsi_oversold and last > prev:
                size = self.get_size(price)
                await self.open_position(symbol, "buy", price, size, dur)

            # SELL: RSI cross down
            if prev >= self.cfg.rsi_overbought and last < prev:
                size = self.get_size(price)
                await self.open_position(symbol, "sell", price, size, dur)

    # ========== Open position ========== #
    async def open_position(self, symbol, side, price, size, duration):
        self._id += 1
        pid = f"{symbol}_{self._id}"
        print(f"[{symbol}] OPEN {side.upper()} @ {price:.2f} | {duration}m | size {size}")

        pos = Position(
            id=pid,
            symbol=symbol,
            side=side,
            entry_price=price,
            size=size,
            opened_at=time.time(),
            duration_min=duration
        )
        self.positions[symbol][pid] = pos

    # ========== Close expired trades ========== #
    async def close_expired(self, symbol):
        now = time.time()
        to_close = []

        for pid, pos in self.positions[symbol].items():
            if (now - pos.opened_at) / 60 >= pos.duration_min:
                to_close.append(pid)

        for pid in to_close:
            await self.close_position(symbol, pid)

    # ========== Close position ========== #
    async def close_position(self, symbol, pid):
        pos = self.positions[symbol][pid]
        last_price = self.data[symbol]["close"].iloc[-1]
        pnl = (last_price - pos.entry_price) * pos.size if pos.side == "buy" else (pos.entry_price - last_price) * pos.size

        print(f"[{symbol}] CLOSE {pos.side.upper()} @ {last_price:.2f} | PnL = {pnl:.3f}")
        self.cfg.account_equity += pnl
        del self.positions[symbol][pid]

    # ========== Main loop ========== #
    async def start(self):
        print("Starting multi-pair RSI bot...")
        print("Symbols:", self.cfg.symbols)

        while True:
            try:
                for symbol in self.cfg.symbols:

                    # new candle
                    ohlcv = self.get_fake_ohlcv(symbol)
                    self.append_candle(symbol, ohlcv)

                    # signal scan
                    await self.process_signals(symbol)

                    # manage trades
                    await self.close_expired(symbol)

            except Exception as e:
                print("Error:", e)

            await asyncio.sleep(1)

# ========== Launch Example ========== #
async def main():
    cfg = BotConfig(
        symbols=["BTCUSDT", "XAUUSD", "GBPUSD"],
        account_equity=3000.0,
        paper=True,
        lot_size=None
    )
    bot = MultiPairRSIBot(cfg)

    task = asyncio.create_task(bot.start())
    await asyncio.sleep(60 * 5) # run 5 minutes demo
    task.cancel()

if __name__ == "__main__":
    asyncio.run(main())

Откликнулись

1
Разработчик 1
Оценка
(633)
Проекты
1001
47%
Арбитраж
33
36% / 36%
Просрочено
98
10%
Работает
Опубликовал: 6 примеров
2
Разработчик 2
Оценка
(19)
Проекты
24
8%
Арбитраж
9
33% / 33%
Просрочено
1
4%
Загружен
3
Разработчик 3
Оценка
(48)
Проекты
56
34%
Арбитраж
15
27% / 60%
Просрочено
1
2%
Работает
4
Разработчик 4
Оценка
(6)
Проекты
5
0%
Арбитраж
4
25% / 75%
Просрочено
2
40%
Свободен
5
Разработчик 5
Оценка
(8)
Проекты
11
0%
Арбитраж
8
25% / 63%
Просрочено
2
18%
Работает
6
Разработчик 6
Оценка
(16)
Проекты
35
23%
Арбитраж
4
0% / 50%
Просрочено
2
6%
Работает
7
Разработчик 7
Оценка
(1)
Проекты
2
0%
Арбитраж
2
0% / 50%
Просрочено
0
Свободен
8
Разработчик 8
Оценка
(2)
Проекты
2
0%
Арбитраж
0
Просрочено
0
Свободен
9
Разработчик 9
Оценка
(17)
Проекты
21
14%
Арбитраж
8
38% / 38%
Просрочено
3
14%
Загружен
10
Разработчик 10
Оценка
(593)
Проекты
684
32%
Арбитраж
42
45% / 45%
Просрочено
12
2%
Занят
11
Разработчик 11
Оценка
(19)
Проекты
26
27%
Арбитраж
4
50% / 25%
Просрочено
4
15%
Загружен
12
Разработчик 12
Оценка
(4)
Проекты
3
33%
Арбитраж
2
0% / 100%
Просрочено
0
Свободен
13
Разработчик 13
Оценка
(2668)
Проекты
3400
68%
Арбитраж
77
48% / 14%
Просрочено
342
10%
Работает
Опубликовал: 1 пример
14
Разработчик 14
Оценка
(2)
Проекты
3
0%
Арбитраж
0
Просрочено
0
Свободен
15
Разработчик 15
Оценка
(1)
Проекты
0
0%
Арбитраж
1
0% / 100%
Просрочено
0
Свободен
16
Разработчик 16
Оценка
(1)
Проекты
1
100%
Арбитраж
0
Просрочено
0
Свободен
17
Разработчик 17
Оценка
(258)
Проекты
265
29%
Арбитраж
0
Просрочено
3
1%
Свободен
Опубликовал: 2 примера
18
Разработчик 18
Оценка
(28)
Проекты
32
25%
Арбитраж
20
10% / 50%
Просрочено
10
31%
Работает
19
Разработчик 19
Оценка
(10)
Проекты
12
0%
Арбитраж
3
33% / 33%
Просрочено
1
8%
Свободен
20
Разработчик 20
Оценка
(298)
Проекты
477
40%
Арбитраж
105
40% / 24%
Просрочено
81
17%
Загружен
Опубликовал: 2 примера
21
Разработчик 21
Оценка
Проекты
0
0%
Арбитраж
0
Просрочено
0
Свободен
22
Разработчик 22
Оценка
Проекты
0
0%
Арбитраж
0
Просрочено
0
Свободен
23
Разработчик 23
Оценка
Проекты
0
0%
Арбитраж
0
Просрочено
0
Свободен
Похожие заказы
Need Custom MT4 Indicator through cracking file (Non-Repaint, Same Signal Logic as Existing Tool, Legit PC ID system ) 150 - 350 USD
I am looking for an experienced MQL4/MQL5 developer to build a custom MT4 indicator from scratch or cracking my ex4 file that i provide to you. I already have an existing indicator (EX4) which produces highly accurate buy/sell signals. I want a similar indicator developed based on its observable behavior and signal structure. my existing indicator is pc id protected so you have to do PC ID security bypass and source

Информация о проекте

Бюджет
50+ USD