|
|
@@ -250,19 +250,6 @@ class ArbitrageProcess:
|
|
|
# 处理精度
|
|
|
pseudo_amount_to_sell = pseudo_amount_to_sell.quantize(Decimal('1'), rounding=ROUND_DOWN)
|
|
|
|
|
|
- # # 链上余额判断
|
|
|
- # from_token_balance = web3.get_erc20_balance(self.from_token_addr, self.user_wallet)
|
|
|
-
|
|
|
- # if from_token_balance < self.arbitrage_details["chain_usdt_use"]:
|
|
|
- # msg = f"链上剩余{self.base_coin}: {from_token_balance}, 需要使用:{self.arbitrage_details["chain_usdt_use"]}, 余额不足,不能触发交易。"
|
|
|
- # logging.info(msg)
|
|
|
- # add_state_flow_entry(self.process_item, self.current_state, msg, "fail")
|
|
|
- # self._set_state(self.STATE_FAILED)
|
|
|
- # return
|
|
|
- # msg = f"链上剩余{self.base_coin}: {from_token_balance}, 需要使用:{self.arbitrage_details["chain_usdt_use"]}, 余额充足。"
|
|
|
- # logging.info(msg)
|
|
|
- # add_state_flow_entry(self.process_item, self.current_state, msg, "success")
|
|
|
-
|
|
|
order_params = {
|
|
|
"symbol": self.symbol.replace('_', ''),
|
|
|
"side": "SELL",
|
|
|
@@ -272,7 +259,7 @@ class ArbitrageProcess:
|
|
|
logging.info(order_params)
|
|
|
exchange_sell_order = mexc.trade.post_order(order_params)
|
|
|
if 'orderId' not in exchange_sell_order:
|
|
|
- msg = f"交易所现货卖出下单失败:{exchange_sell_order}"
|
|
|
+ msg = f"交易所现货卖出下单失败:{exchange_sell_order}, {order_params}"
|
|
|
logging.error(msg)
|
|
|
add_state_flow_entry(self.process_item, self.current_state, msg, "fail")
|
|
|
self._set_state(self.STATE_FAILED)
|