|
|
@@ -524,7 +524,10 @@ class ArbitrageProcess:
|
|
|
|
|
|
# 如果300秒都沒確認成功,該交易大概率沒有上鏈
|
|
|
if waiting_times <= 0:
|
|
|
- msg = f"链上交易确认失败:{chain_tx_hash}"
|
|
|
+ with self.pending_lock:
|
|
|
+ tx_details = copy.deepcopy(self.pending_data[chain_tx_hash]['tx_details'])
|
|
|
+
|
|
|
+ msg = f"链上交易确认失败:{chain_tx_hash}, {tx_details}"
|
|
|
logging.error(msg)
|
|
|
add_state_flow_entry(self.process_item, self.current_state, msg, "fail")
|
|
|
self._set_state(self.STATE_WAITING_EXCHANGE_ROLLBACK)
|
|
|
@@ -763,7 +766,7 @@ class ArbitrageProcess:
|
|
|
msg = f"交易所提现已发送, 提现ID: {self.exchange_withdrawal_id}"
|
|
|
logging.info(msg)
|
|
|
add_state_flow_entry(self.process_item, self.current_state, msg, "success")
|
|
|
-
|
|
|
+
|
|
|
self._set_state(self.STATE_WAITING_WITHDRAWAL_CONFIRM)
|
|
|
except Exception as e:
|
|
|
msg = f"转账回链上失败: {e}"
|