From 56897a24b0b9b63d62d8df3d11bbae66fe66b1fe Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 20 三月 2025 14:20:13 +0800
Subject: [PATCH] 交易设置及接口

---
 strategy/kpl_api.py |   45 ++++++++++++++++++++++++++-------------------
 1 files changed, 26 insertions(+), 19 deletions(-)

diff --git a/strategy/kpl_api.py b/strategy/kpl_api.py
index e1eef13..08ceb6d 100644
--- a/strategy/kpl_api.py
+++ b/strategy/kpl_api.py
@@ -10,7 +10,8 @@
 import requests
 
 import constant
-from log_module.log import logger_common, logger_kpl_jingxuan_in
+from log_module import async_log_util
+from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_Overall_market_strength_score
 # import requests
 from strategy import data_cache
 from strategy import basic_methods
@@ -230,29 +231,29 @@
                                '澹宠祫婧�', '鑲℃潈杞', '閫佽浆濉潈']) or ('澧為暱' in plate_name):
             # print(f"{i[1]} 寮哄害:{i[2]}")
             # 閫氳繃鏉垮潡ID鑾峰彇鍏朵笅闈㈢殑涓偂寮哄害鍒楄〃
-            its_stock = getCodesByPlate(i[0])
             # print(f"======={i[0]}=======")
-            its_stock = json.loads(its_stock)
+            its_stock = json.loads(getCodesByPlate(i[0]))
 
-            l = its_stock['list'][0]
             # print(f"its_stock['list']  ===  {its_stock['list']}")
             # print(f"its_stock['list'][0]  ===  {its_stock['list'][0]}")
-            # logger.info(f"its_stock['list']  ===  {its_stock['list']}")
-            logger.info(f"its_stock['list'][0]  ===  {its_stock['list'][0]}")
+            logger.info(f"its_stock['list']  ===銆嬨��  {its_stock['list']}")
+            # logger.info(f"its_stock['list'][0]  ===  {its_stock['list'][0]}")
+            its_stock_list_info = its_stock['list'][0]
+
             # 灏嗘澘鍧楀己搴︿笅闈㈠搴旂殑涓偂鍒楄〃鎵撳嵃鍒版棩蹇椾腑
-            # for i in l:
-            #     if l[41] != 1:
+            # for i in its_stock_list_info:
+            #     if i[0] != 1:
             #         logger.info(
-            #             f"l === 涓偂浠g爜锛歿l[0]}锛屽叕鍙稿悕绉帮細{l[1]}锛屼富鍔涜祫閲戞帹娴嬶細{l[2]}锛屾湭鐭�0鍊硷細{l[3]}锛屾蹇碉細{l[4]}锛屾渶鏂颁环锛歿l[5]}锛屽綋鏃ュ綋鏃舵定骞咃細{l[6]}%锛�"
-            #             f"鎴愪氦棰濓細{round(l[7] / 100000000, 2)} 浜匡紝瀹為檯鎹㈡墜鐜囷細{l[8]}%锛屾湭鐭�0鍊硷細{l[9]}锛屽疄闄呮祦閫氾細{round(l[10] / 100000000, 2)}浜匡紝"
-            #             f"涓诲姏涔帮細{round(l[11] / 100000000, 2)}浜匡紝"
-            #             f"涓诲姏鍗栵細{round(l[12] / 100000000, 2)}浜匡紝"
-            #             f"涓诲姏鍑�棰濓細{round(l[13] / 10000, 2)}涓囷紝涔版垚鍗犳瘮锛歿l[14]}%锛屽崠鎴愬崰姣旓細{l[15]}%锛屽噣鎴愬崰姣旓細{l[16]}%锛屼拱娴佸崰姣旓細{l[17]}%锛屽崠娴佸崰姣旓細{l[18]}%锛屽噣娴佸崰姣旓細{l[19]}%锛�"
-            #             f"鍖洪棿娑ㄥ箙锛歿l[20]}%锛岄噺姣旓細{l[21]}锛屾湭鐭�0锛歿l[22]}锛屼笂鏉挎儏鍐碉細{l[23]}锛屼笂鏉挎帓鍚嶏細{l[24]}锛屾崲鎵嬬巼锛歿l[25]}%锛�"
-            #             f"鏈煡绌哄�硷細{l[26]}锛屾湭鐭ラ浂鍊硷細{l[27]}锛屾敹鐩樺皝鍗曪細{l[28]}锛屾渶澶у皝鍗曪細{l[29]}锛屾湭鐭ョ┖鍊硷紵锛歿l[30]}锛�"
-            #             f"锛燂細{l[30]}%锛岋紵锛歿l[31]}锛岋紵锛燂細{l[32]}锛屾尟骞咃細{l[33]}%锛屾湭鐭�0锛燂紵锛燂紵锛歿l[34]}锛屾湭鐭�0锛燂紵锛燂紵锛燂細{l[35]}锛�"
-            #             f"锛�=锛歿l[36]}锛岋紵鎬诲競鍊硷細{l[37]}锛岋紵娴侀�氬競鍊硷細{l[38]}锛屾渶缁堝綊灞炴蹇碉紙鏀剁洏鍚庡嚭鏁版嵁锛燂級锛歿l[39]}锛岄娑ㄦ鏁帮細{l[40]}锛�"
-            #             f"41鏈煡1鍊硷細{l[41]}锛岀涓夊搴︽満鏋勬寔浠撱�恠tr鏁版嵁鍕跨敤杩愮畻绗︺�戯細{l[42]}涓囷紝锛熷勾棰勬祴鍑�鍒╂鼎锛歿l[43]}锛屼笂骞撮娴嬪噣鍒╂鼎锛歿l[44]}锛屽勾鍐呴娴嬪噣鍒╂鼎锛歿l[45]}"
+            #             f"l === 涓偂浠g爜锛歿i[0]}锛屽叕鍙稿悕绉帮細{i[1]}锛屼富鍔涜祫閲戞帹娴嬶細{i[2]}锛屾湭鐭�0鍊硷細{i[3]}锛屾蹇碉細{i[4]}锛屾渶鏂颁环锛歿i[5]}锛屽綋鏃ュ綋鏃舵定骞咃細{i[6]}%锛�"
+            #             f"鎴愪氦棰濓細{round(i[7] / 100000000, 2)} 浜匡紝瀹為檯鎹㈡墜鐜囷細{i[8]}%锛屾湭鐭�0鍊硷細{i[9]}锛屽疄闄呮祦閫氾細{round(i[10] / 100000000, 2)}浜匡紝"
+            #             f"涓诲姏涔帮細{round(i[11] / 100000000, 2)}浜匡紝"
+            #             f"涓诲姏鍗栵細{round(i[12] / 100000000, 2)}浜匡紝"
+            #             f"涓诲姏鍑�棰濓細{round(i[13] / 10000, 2)}涓囷紝涔版垚鍗犳瘮锛歿i[14]}%锛屽崠鎴愬崰姣旓細{i[15]}%锛屽噣鎴愬崰姣旓細{i[16]}%锛屼拱娴佸崰姣旓細{i[17]}%锛屽崠娴佸崰姣旓細{i[18]}%锛屽噣娴佸崰姣旓細{i[19]}%锛�"
+            #             f"鍖洪棿娑ㄥ箙锛歿i[20]}%锛岄噺姣旓細{i[21]}锛屾湭鐭�0锛歿i[22]}锛屼笂鏉挎儏鍐碉細{i[23]}锛屼笂鏉挎帓鍚嶏細{i[24]}锛屾崲鎵嬬巼锛歿i[25]}%锛�"
+            #             f"鏈煡绌哄�硷細{i[26]}锛屾湭鐭ラ浂鍊硷細{i[27]}锛屾敹鐩樺皝鍗曪細{i[28]}锛屾渶澶у皝鍗曪細{i[29]}锛屾湭鐭ョ┖鍊硷紵锛歿i[30]}锛�"
+            #             f"锛燂細{i[30]}%锛岋紵锛歿i[31]}锛岋紵锛燂細{i[32]}锛屾尟骞咃細{i[33]}%锛屾湭鐭�0锛燂紵锛燂紵锛歿i[34]}锛屾湭鐭�0锛燂紵锛燂紵锛燂細{i[35]}锛�"
+            #             f"锛�=锛歿i[36]}锛岋紵鎬诲競鍊硷細{i[37]}锛岋紵娴侀�氬競鍊硷細{i[38]}锛屾渶缁堝綊灞炴蹇碉紙鏀剁洏鍚庡嚭鏁版嵁锛燂級锛歿i[39]}锛岄娑ㄦ鏁帮細{i[40]}锛�"
+            #             f"41鏈煡1鍊硷細{i[41]}锛岀涓夊搴︽満鏋勬寔浠撱�恠tr鏁版嵁鍕跨敤杩愮畻绗︺�戯細{i[42]}涓囷紝锛熷勾棰勬祴鍑�鍒╂鼎锛歿i[43]}锛屼笂骞撮娴嬪噣鍒╂鼎锛歿i[44]}锛屽勾鍐呴娴嬪噣鍒╂鼎锛歿i[45]}"
             #         )
 
             # 鑾峰彇璇ユ蹇垫澘鍧楃殑鐨勫瓙鐗堝潡
@@ -744,11 +745,17 @@
                     data_cache.real_time_market_strong = get_market_strong()
                     # data_cache.time_sharing_market_strong_dirt = time_sharing_market_strong_dirt.update({now: data_cache.real_time_market_strong})
                     logger.info(f"澶х洏琛屾儏鎯呯华缁煎悎寮哄害 [鍒嗘暟]==={data_cache.real_time_market_strong}鍒�")
+                    # 澶х洏缁煎悎寮哄害鍒嗘暟 鐨� 寮傛鏃ュ織
+                    logger_Overall_market_strength_score.info(data_cache.real_time_market_strong)
+                    async_log_util.info(logger_Overall_market_strength_score, f"澶х洏琛屾儏鎯呯华缁煎悎寮哄害 [鍒嗘暟]==={data_cache.real_time_market_strong}鍒�")
+
                     usefulMoney = data_cache.account_finance_dict[0].get('usefulMoney', 0)
                     logger.info(f"璐︽埛鍙敤璧勯噾==={usefulMoney}鍏�")
                     # 浣庤糠鎯呯华姣斾緥
                     low_emotion_mood_ratio = 1
-                    if data_cache.real_time_market_strong <= 33:
+                    # 33鍒嗘槸涓袱绾у垎鍖栭樁姊笉濂斤紝鐩墠涓嶅ソ鎷挎崗锛屾殏鏃朵笉鐢�
+                    # if data_cache.real_time_market_strong <= 33:
+                    if data_cache.real_time_market_strong <= 20:
                         low_emotion_mood_ratio = 0.1
                         if data_cache.real_time_market_strong <= 10:
                             low_emotion_mood_ratio = 0

--
Gitblit v1.8.0