dekun/crypto_monitor
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改企业微信

Browse Source
This commit is contained in:
dekun
2026-05-19 20:48:57 +08:00
parent 90cb9abf31
commit ee38eb1c45
3 changed files with 105 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crypto_monitor_binance/app.py
+35 -14
View File
@@ -272,6 +272,22 @@ def send_wechat_msg(content):
pass pass
_BREAKEVEN_EXCHANGE_WARNED_IDS = set()
def _send_breakeven_exchange_warn_once(order_id, message):
"""移动保本同步交易所失败：同一笔监控单只推送一次，避免轮询刷屏。"""
oid = int(order_id)
if oid in _BREAKEVEN_EXCHANGE_WARNED_IDS:
return
_BREAKEVEN_EXCHANGE_WARNED_IDS.add(oid)
send_wechat_msg(message)
def _clear_breakeven_exchange_warn(order_id):
_BREAKEVEN_EXCHANGE_WARNED_IDS.discard(int(order_id))
def _wechat_account_label(): def _wechat_account_label():
return (os.getenv("BINANCE_ACCOUNT_LABEL") or "binance实盘账户").strip() return (os.getenv("BINANCE_ACCOUNT_LABEL") or "binance实盘账户").strip()
@@ -4958,6 +4974,7 @@ def check_order_monitors():
direction == "long" and new_sl > float(stop_loss) direction == "long" and new_sl > float(stop_loss)
) )
if should_move: if should_move:
was_armed = breakeven_armed
ex_sym = resolve_monitor_exchange_symbol(r) ex_sym = resolve_monitor_exchange_symbol(r)
new_sl = round_price_to_exchange(ex_sym, new_sl) new_sl = round_price_to_exchange(ex_sym, new_sl)
tp_ex = float(take_profit or 0) tp_ex = float(take_profit or 0)
@@ -4967,13 +4984,15 @@ def check_order_monitors():
try: try:
replace_active_monitor_tpsl_on_exchange(r, new_sl, tp_ex) replace_active_monitor_tpsl_on_exchange(r, new_sl, tp_ex)
synced_ex = True synced_ex = True
_clear_breakeven_exchange_warn(pid)
except Exception as e: except Exception as e:
print( print(
f"[breakeven] exchange tpsl replace failed order={pid} {sym}: {e}", f"[breakeven] exchange tpsl replace failed order={pid} {sym}: {e}",
flush=True, flush=True,
) )
send_wechat_msg( _send_breakeven_exchange_warn_once(
f"⚠️ {sym} 移动保本止损未同步交易所：{friendly_exchange_error(e)}" pid,
f"⚠️ {sym} 移动保本止损未同步交易所：{friendly_exchange_error(e)}",
) )
elif ok_live: elif ok_live:
print( print(
@@ -4986,18 +5005,20 @@ def check_order_monitors():
(new_sl, new_sl, pid), (new_sl, new_sl, pid),
) )
stop_loss = new_sl stop_loss = new_sl
arm_txt = "保本止盈" if not breakeven_armed else "移动止盈" breakeven_armed = 1
be_msg = build_wechat_breakeven_message( if not was_armed:
sym, arm_txt = "保本止盈"
direction, be_msg = build_wechat_breakeven_message(
arm_txt, sym,
now_rr, direction,
locked_r, arm_txt,
new_sl, now_rr,
) locked_r,
if ok_live: new_sl,
be_msg += "\n- 交易所：已先撤后挂止盈止损" )
send_wechat_msg(be_msg) if ok_live:
be_msg += "\n- 交易所：已先撤后挂止盈止损"
send_wechat_msg(be_msg)
res = None res = None
# 做多 # 做多
crypto_monitor_gate/app.py
+35 -14
View File
@@ -266,6 +266,22 @@ def send_wechat_msg(content):
pass pass
_BREAKEVEN_EXCHANGE_WARNED_IDS = set()
def _send_breakeven_exchange_warn_once(order_id, message):
"""移动保本同步交易所失败：同一笔监控单只推送一次，避免轮询刷屏。"""
oid = int(order_id)
if oid in _BREAKEVEN_EXCHANGE_WARNED_IDS:
return
_BREAKEVEN_EXCHANGE_WARNED_IDS.add(oid)
send_wechat_msg(message)
def _clear_breakeven_exchange_warn(order_id):
_BREAKEVEN_EXCHANGE_WARNED_IDS.discard(int(order_id))
def _wechat_account_label(): def _wechat_account_label():
return (os.getenv("GATE_ACCOUNT_LABEL") or "gate实盘账户").strip() return (os.getenv("GATE_ACCOUNT_LABEL") or "gate实盘账户").strip()
@@ -4817,6 +4833,7 @@ def check_order_monitors():
direction == "long" and new_sl > float(stop_loss) direction == "long" and new_sl > float(stop_loss)
) )
if should_move: if should_move:
was_armed = breakeven_armed
ex_sym = resolve_monitor_exchange_symbol(r) ex_sym = resolve_monitor_exchange_symbol(r)
new_sl = round_price_to_exchange(ex_sym, new_sl) new_sl = round_price_to_exchange(ex_sym, new_sl)
tp_ex = float(take_profit or 0) tp_ex = float(take_profit or 0)
@@ -4826,13 +4843,15 @@ def check_order_monitors():
try: try:
replace_active_monitor_tpsl_on_exchange(r, new_sl, tp_ex) replace_active_monitor_tpsl_on_exchange(r, new_sl, tp_ex)
synced_ex = True synced_ex = True
_clear_breakeven_exchange_warn(pid)
except Exception as e: except Exception as e:
print( print(
f"[breakeven] exchange tpsl replace failed order={pid} {sym}: {e}", f"[breakeven] exchange tpsl replace failed order={pid} {sym}: {e}",
flush=True, flush=True,
) )
send_wechat_msg( _send_breakeven_exchange_warn_once(
f"⚠️ {sym} 移动保本止损未同步交易所：{friendly_exchange_error(e)}" pid,
f"⚠️ {sym} 移动保本止损未同步交易所：{friendly_exchange_error(e)}",
) )
elif ok_live: elif ok_live:
print( print(
@@ -4845,18 +4864,20 @@ def check_order_monitors():
(new_sl, new_sl, pid), (new_sl, new_sl, pid),
) )
stop_loss = new_sl stop_loss = new_sl
arm_txt = "保本止盈" if not breakeven_armed else "移动止盈" breakeven_armed = 1
be_msg = build_wechat_breakeven_message( if not was_armed:
sym, arm_txt = "保本止盈"
direction, be_msg = build_wechat_breakeven_message(
arm_txt, sym,
now_rr, direction,
locked_r, arm_txt,
new_sl, now_rr,
) locked_r,
if ok_live: new_sl,
be_msg += "\n- 交易所：已先撤后挂止盈止损" )
send_wechat_msg(be_msg) if ok_live:
be_msg += "\n- 交易所：已先撤后挂止盈止损"
send_wechat_msg(be_msg)
res = None res = None
# 做多 # 做多
crypto_monitor_gate_bot/app.py
+35 -14
View File
@@ -263,6 +263,22 @@ def send_wechat_msg(content):
pass pass
_BREAKEVEN_EXCHANGE_WARNED_IDS = set()
def _send_breakeven_exchange_warn_once(order_id, message):
"""移动保本同步交易所失败：同一笔监控单只推送一次，避免轮询刷屏。"""
oid = int(order_id)
if oid in _BREAKEVEN_EXCHANGE_WARNED_IDS:
return
_BREAKEVEN_EXCHANGE_WARNED_IDS.add(oid)
send_wechat_msg(message)
def _clear_breakeven_exchange_warn(order_id):
_BREAKEVEN_EXCHANGE_WARNED_IDS.discard(int(order_id))
def _wechat_account_label(): def _wechat_account_label():
return (os.getenv("GATE_ACCOUNT_LABEL") or "gate实盘账户").strip() return (os.getenv("GATE_ACCOUNT_LABEL") or "gate实盘账户").strip()
@@ -4644,6 +4660,7 @@ def check_order_monitors():
direction == "long" and new_sl > float(stop_loss) direction == "long" and new_sl > float(stop_loss)
) )
if should_move: if should_move:
was_armed = breakeven_armed
ex_sym = resolve_monitor_exchange_symbol(r) ex_sym = resolve_monitor_exchange_symbol(r)
new_sl = round_price_to_exchange(ex_sym, new_sl) new_sl = round_price_to_exchange(ex_sym, new_sl)
tp_ex = float(take_profit or 0) tp_ex = float(take_profit or 0)
@@ -4653,13 +4670,15 @@ def check_order_monitors():
try: try:
replace_active_monitor_tpsl_on_exchange(r, new_sl, tp_ex) replace_active_monitor_tpsl_on_exchange(r, new_sl, tp_ex)
synced_ex = True synced_ex = True
_clear_breakeven_exchange_warn(pid)
except Exception as e: except Exception as e:
print( print(
f"[breakeven] exchange tpsl replace failed order={pid} {sym}: {e}", f"[breakeven] exchange tpsl replace failed order={pid} {sym}: {e}",
flush=True, flush=True,
) )
send_wechat_msg( _send_breakeven_exchange_warn_once(
f"⚠️ {sym} 移动保本止损未同步交易所：{friendly_exchange_error(e)}" pid,
f"⚠️ {sym} 移动保本止损未同步交易所：{friendly_exchange_error(e)}",
) )
elif ok_live: elif ok_live:
print( print(
@@ -4672,18 +4691,20 @@ def check_order_monitors():
(new_sl, new_sl, pid), (new_sl, new_sl, pid),
) )
stop_loss = new_sl stop_loss = new_sl
arm_txt = "保本止盈" if not breakeven_armed else "移动止盈" breakeven_armed = 1
be_msg = build_wechat_breakeven_message( if not was_armed:
sym, arm_txt = "保本止盈"
direction, be_msg = build_wechat_breakeven_message(
arm_txt, sym,
now_rr, direction,
locked_r, arm_txt,
new_sl, now_rr,
) locked_r,
if ok_live: new_sl,
be_msg += "\n- 交易所：已先撤后挂止盈止损" )
send_wechat_msg(be_msg) if ok_live:
be_msg += "\n- 交易所：已先撤后挂止盈止损"
send_wechat_msg(be_msg)
res = None res = None
# 做多 # 做多