diff --git a/scripts/mofin_collect.py b/scripts/mofin_collect.py index efcdfddb..904cd69e 100644 --- a/scripts/mofin_collect.py +++ b/scripts/mofin_collect.py @@ -74,6 +74,21 @@ try: ) if result and result.get("action"): print(f" 🔄 FORCE_REASSESS {code} {name}: {hours_stale:.0f}h过期→已立即重评→{result['action'][:60]}", flush=True) + # 写strategy_evaluations表(产生即落盘,不断链) + try: + cur.execute(""" + INSERT INTO strategy_evaluations + (code, eval_type, status, new_stop_loss, new_tp, reason, created_at) + VALUES (?, 'reassess', 'completed', ?, ?, ?, ?) + """, ( + code, + result.get("stop_loss"), + result.get("take_profit"), + f"{result.get('action','')} RR={result.get('rr_ratio','?')} 信号={result.get('timing_signal','')}", + now.isoformat() + )) + except Exception as eval_err: + print(f" ⚠️ 写evaluation表失败: {eval_err}", flush=True) else: print(f" ⚠️ FORCE_REASSESS {code} {name}: 重评返回空结果", flush=True) except Exception as e: @@ -105,6 +120,20 @@ try: ) if result and result.get("action"): print(f" 🔄 CREATE_STRATEGY {code} {name}: 无策略→已创建→{result['action'][:60]}", flush=True) + try: + cur.execute(""" + INSERT INTO strategy_evaluations + (code, eval_type, status, new_stop_loss, new_tp, reason, created_at) + VALUES (?, 'reassess', 'completed', ?, ?, ?, ?) + """, ( + code, + result.get("stop_loss"), + result.get("take_profit"), + f"{result.get('action','')} RR={result.get('rr_ratio','?')} 信号={result.get('timing_signal','')}", + now.isoformat() + )) + except Exception as eval_err: + print(f" ⚠️ 写evaluation表失败: {eval_err}", flush=True) else: print(f" ⚠️ CREATE_STRATEGY {code} {name}: 重评返回空", flush=True) except Exception as e: @@ -130,6 +159,20 @@ try: if result and result.get("action"): wl_stale += 1 print(f" 📋 WATCHLIST_REASSESS {code} {name}: →{result['action'][:60]}", flush=True) + try: + cur.execute(""" + INSERT INTO strategy_evaluations + (code, eval_type, status, new_stop_loss, new_tp, reason, created_at) + VALUES (?, 'reassess', 'completed', ?, ?, ?, ?) + """, ( + code, + result.get("stop_loss"), + result.get("take_profit"), + f"自选:{result.get('action','')} RR={result.get('rr_ratio','?')} 信号={result.get('timing_signal','')}", + now.isoformat() + )) + except Exception as eval_err: + print(f" ⚠️ 写evaluation表失败: {eval_err}", flush=True) else: wl_fresh += 1 except Exception as e: