Small fixes
This commit is contained in:
@ -11,7 +11,7 @@ def setStartTime():
|
|||||||
startTime = time.time()
|
startTime = time.time()
|
||||||
|
|
||||||
def getPnL(pair):
|
def getPnL(pair):
|
||||||
with open("tradingLog.log", "r") as f:
|
with open("./data/tradingLog.log", "r") as f:
|
||||||
lines = f.readlines()
|
lines = f.readlines()
|
||||||
|
|
||||||
logEntries = []
|
logEntries = []
|
||||||
|
|||||||
@ -59,7 +59,7 @@ class tradingData:
|
|||||||
self.orderSize = orderSize
|
self.orderSize = orderSize
|
||||||
self.priceDecimals, self.qtyDecimals, self.minimumQty = self.getFilters(pair)
|
self.priceDecimals, self.qtyDecimals, self.minimumQty = self.getFilters(pair)
|
||||||
self.previousPrice = -1
|
self.previousPrice = -1
|
||||||
self.counter = 0
|
self.orderCounter = 0
|
||||||
|
|
||||||
|
|
||||||
def getBalance(self, pair):
|
def getBalance(self, pair):
|
||||||
@ -147,6 +147,7 @@ class tradingData:
|
|||||||
stopLoss = str(sl),
|
stopLoss = str(sl),
|
||||||
tpslMode = "Full"
|
tpslMode = "Full"
|
||||||
)
|
)
|
||||||
|
self.orderCounter += 1
|
||||||
orderID = response.get('result').get('orderId')
|
orderID = response.get('result').get('orderId')
|
||||||
|
|
||||||
generalLogger.info(f"Placed oder on {self.pair} with TP {tp}; SL {sl}")
|
generalLogger.info(f"Placed oder on {self.pair} with TP {tp}; SL {sl}")
|
||||||
@ -209,10 +210,12 @@ class tradingData:
|
|||||||
j['long'] = False
|
j['long'] = False
|
||||||
j['longIDs'] = ['-1', '-1', '-1']
|
j['longIDs'] = ['-1', '-1', '-1']
|
||||||
generalLogger.info(f"Long order on {self.pair} level {j['price']} triggered TP/SL")
|
generalLogger.info(f"Long order on {self.pair} level {j['price']} triggered TP/SL")
|
||||||
|
self.orderCounter -= 1
|
||||||
if orderID in shortIDs:
|
if orderID in shortIDs:
|
||||||
j['short'] = False
|
j['short'] = False
|
||||||
j['shortIDs'] = ['-1', '-1', '-1']
|
j['shortIDs'] = ['-1', '-1', '-1']
|
||||||
generalLogger.info(f"Short order on {self.pair} level {j['price']} triggered TP/SL")
|
generalLogger.info(f"Short order on {self.pair} level {j['price']} triggered TP/SL")
|
||||||
|
self.orderCounter -= 1
|
||||||
if orderStatus == 'Filled':
|
if orderStatus == 'Filled':
|
||||||
for j in self.levels:
|
for j in self.levels:
|
||||||
longIDs = j['longIDs']
|
longIDs = j['longIDs']
|
||||||
|
|||||||
@ -32,6 +32,9 @@ async def parseParams(params):
|
|||||||
# Returnes dictionary of string params as paramsLines in options
|
# Returnes dictionary of string params as paramsLines in options
|
||||||
paramsList = params.split()
|
paramsList = params.split()
|
||||||
paramsDict = {}
|
paramsDict = {}
|
||||||
|
if len(paramsList) != len(options.paramsLines):
|
||||||
|
return -1
|
||||||
|
|
||||||
for i in range(len(options.paramsLines)):
|
for i in range(len(options.paramsLines)):
|
||||||
paramsDict[options.paramsLines[i]] = paramsList[i]
|
paramsDict[options.paramsLines[i]] = paramsList[i]
|
||||||
return paramsDict
|
return paramsDict
|
||||||
|
|||||||
@ -30,7 +30,8 @@ import options
|
|||||||
async def set_commands():
|
async def set_commands():
|
||||||
commands = [BotCommand(command='start', description='Старт'),
|
commands = [BotCommand(command='start', description='Старт'),
|
||||||
BotCommand(command='help', description='Инструкция'),
|
BotCommand(command='help', description='Инструкция'),
|
||||||
BotCommand(command='info', description='Статус'),
|
BotCommand(command='info', description='Информация о стратегиях'),
|
||||||
|
BotCommand(command='status', description='Статус'),
|
||||||
BotCommand(command='strategy', description='Запустить стратегию'),
|
BotCommand(command='strategy', description='Запустить стратегию'),
|
||||||
BotCommand(command='stop', description='Остановить стратегию')
|
BotCommand(command='stop', description='Остановить стратегию')
|
||||||
]
|
]
|
||||||
@ -115,8 +116,8 @@ async def capture_params(message: Message, state: FSMContext):
|
|||||||
|
|
||||||
data = await state.get_data()
|
data = await state.get_data()
|
||||||
t = await jsonProcessing.savePairParams(pair=data.get("pair"), params=data.get("params"))
|
t = await jsonProcessing.savePairParams(pair=data.get("pair"), params=data.get("params"))
|
||||||
params = await jsonProcessing.parseParams(params=data.get("params"))
|
|
||||||
if t == 0:
|
if t == 0:
|
||||||
|
params = await jsonProcessing.parseParams(params=data.get("params"))
|
||||||
client = await bybit.getClient(
|
client = await bybit.getClient(
|
||||||
credentials.api_key,
|
credentials.api_key,
|
||||||
credentials.api_secret,
|
credentials.api_secret,
|
||||||
|
|||||||
Reference in New Issue
Block a user