administrator/ai-trading-sys
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

update

Browse source
This commit is contained in:
kienvt 2025-07-17 17:38:51 +07:00
parent 3d0079dd06
commit 66d33e7cb3
2 changed files with 38 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/dao/position.ts
View file

@ -4,6 +4,7 @@ export interface Position {
entry: number; entry: number;
leverage: number; leverage: number;
volume: number; volume: number;
profit: number; sl: number;
profitPercentage: number; tp: number;
} status: string;
}

51
src/schedule/index.ts
View file

@ -16,8 +16,6 @@ const bybitService = new BybitService(
false false
); );
export const eventHandlerFuture: EventHandler = { export const eventHandlerFuture: EventHandler = {
onBuy: (order: Order, reason: string) => { onBuy: (order: Order, reason: string) => {
sendMessage(`Future Buy ${order.symbol} ${order.interval}M sendMessage(`Future Buy ${order.symbol} ${order.interval}M
@ -35,9 +33,10 @@ export const eventHandlerFuture: EventHandler = {
side: "Buy", side: "Buy",
orderType: "Limit", orderType: "Limit",
price: Number(order.entry).toFixed(2), price: Number(order.entry).toFixed(2),
qty: '1', stopLoss: Number(order.stopLoss).toFixed(2),
qty: "1",
}); });
console.log( console.log(
`Buy ${order.symbol} ${order.interval}M ${reason} ${order.entry}` `Buy ${order.symbol} ${order.interval}M ${reason} ${order.entry}`
); );
@ -57,13 +56,17 @@ export const eventHandlerFuture: EventHandler = {
side: "Sell", side: "Sell",
orderType: "Limit", orderType: "Limit",
price: Number(order.entry).toFixed(2), price: Number(order.entry).toFixed(2),
qty: '1', stopLoss: Number(order.stopLoss).toFixed(2),
qty: "1",
}); });
console.log( console.log(
`Sell ${order.symbol} ${order.interval}M ${reason} ${order.entry}` `Sell ${order.symbol} ${order.interval}M ${reason} ${order.entry}`
); );
}, },
onEvent: async (eventType: EventType, {candle, analysis}: {candle: Candle, analysis: Analysis}) => { onEvent: async (
eventType: EventType,
{ candle, analysis }: { candle: Candle; analysis: Analysis }
) => {
if (eventType === "HighVolatility") { if (eventType === "HighVolatility") {
const positions = await bybitService.listPositions({ const positions = await bybitService.listPositions({
category: "linear", category: "linear",
@ -78,10 +81,15 @@ export const eventHandlerFuture: EventHandler = {
symbol: analysis.symbol, symbol: analysis.symbol,
side: "Sell", side: "Sell",
orderType: "Limit", orderType: "Limit",
price: candle.close > analysis.currentBB.upper ? Number(candle.close).toFixed(2) : Number(analysis.currentBB.upper).toFixed(2), price:
candle.close > analysis.currentBB.upper
? Number(candle.close).toFixed(2)
: Number(analysis.currentBB.upper).toFixed(2),
qty: halfSize, qty: halfSize,
}); });
sendMessage(`Future Căt nửa ${analysis.symbol} ${analysis.interval}M ${analysis.currentBB.upper} ${halfSize}`); sendMessage(
`Future Căt nửa ${analysis.symbol} ${analysis.interval}M ${analysis.currentBB.upper} ${halfSize}`
);
} }
if (position.side === "Sell" && analysis.isUnderBbLower) { if (position.side === "Sell" && analysis.isUnderBbLower) {
const halfSize = (Number(position.size) / 2).toFixed(2); const halfSize = (Number(position.size) / 2).toFixed(2);
@ -90,10 +98,15 @@ export const eventHandlerFuture: EventHandler = {
symbol: analysis.symbol, symbol: analysis.symbol,
side: "Buy", side: "Buy",
orderType: "Limit", orderType: "Limit",
price: candle.close < analysis.currentBB.lower ? Number(candle.close).toFixed(2) : Number(analysis.currentBB.lower).toFixed(2), price:
candle.close < analysis.currentBB.lower
? Number(candle.close).toFixed(2)
: Number(analysis.currentBB.lower).toFixed(2),
qty: halfSize, qty: halfSize,
}); });
sendMessage(`Future Căt nửa ${analysis.symbol} ${analysis.interval}M ${analysis.currentBB.lower} ${halfSize}`); sendMessage(
`Future Căt nửa ${analysis.symbol} ${analysis.interval}M ${analysis.currentBB.lower} ${halfSize}`
);
} }
} }
} }
@ -117,9 +130,9 @@ const eventHandlerSpot: EventHandler = {
side: "Buy", side: "Buy",
orderType: "Limit", orderType: "Limit",
price: Number(order.entry).toFixed(2), price: Number(order.entry).toFixed(2),
qty: '1', qty: "1",
}); });
console.log( console.log(
`Buy ${order.symbol} ${order.interval}M ${reason} ${order.entry}` `Buy ${order.symbol} ${order.interval}M ${reason} ${order.entry}`
); );
@ -134,8 +147,10 @@ const eventHandlerSpot: EventHandler = {
reason: ${reason} reason: ${reason}
`); `);
}, },
onEvent: async (eventType: EventType, {candle, analysis}: {candle: Candle, analysis: Analysis}) => { onEvent: async (
}, eventType: EventType,
{ candle, analysis }: { candle: Candle; analysis: Analysis }
) => {},
}; };
const eventHandlerNotification: EventHandler = { const eventHandlerNotification: EventHandler = {
@ -148,7 +163,7 @@ const eventHandlerNotification: EventHandler = {
volume: ${order.volume} volume: ${order.volume}
reason: ${reason} reason: ${reason}
`); `);
console.log( console.log(
`Buy ${order.symbol} ${order.interval}M ${reason} ${order.entry}` `Buy ${order.symbol} ${order.interval}M ${reason} ${order.entry}`
); );
@ -163,8 +178,10 @@ const eventHandlerNotification: EventHandler = {
reason: ${reason} reason: ${reason}
`); `);
}, },
onEvent: async (eventType: EventType, {candle, analysis}: {candle: Candle, analysis: Analysis}) => { onEvent: async (
}, eventType: EventType,
{ candle, analysis }: { candle: Candle; analysis: Analysis }
) => {},
}; };
createCandleAnalysisSchedule("ETHUSDT", "15", eventHandlerFuture); createCandleAnalysisSchedule("ETHUSDT", "15", eventHandlerFuture);