From 8ddc7f5ecc67c0bb424954a86b75ec7444080ba2 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 29 三月 2023 18:02:50 +0800
Subject: [PATCH] 首板买入策略分值优化

---
 server.py |   26 ++++++++++++++++----------
 1 files changed, 16 insertions(+), 10 deletions(-)

diff --git a/server.py b/server.py
index b187ce8..4740661 100644
--- a/server.py
+++ b/server.py
@@ -728,7 +728,7 @@
                 # 鑾峰彇鏈�杩�2涓氦鏄撴棩娑ㄥ仠浠g爜
                 elif type == 72:
                     day = tool.get_now_date_str()
-                    data_dict={}
+                    data_dict = {}
                     for i in range(0, 2):
                         day = juejin.JueJinManager.get_previous_trading_date(day)
                         data_list = list(hot_block_data_process.XGBHotBlockDataManager.list_all(day))
@@ -818,6 +818,14 @@
                         name = gpcode_manager.get_code_name(code)
                         datas.append(f"{name}:{code}")
                     return_str = json.dumps({"code": 0, "data": datas})
+                elif type == 501:
+                    data = json.loads(_str)
+                    is_open = data["data"]["open"]
+                    if is_open:
+                        trade_manager.TradeStateManager.open_buy()
+                    else:
+                        trade_manager.TradeStateManager.close_buy()
+                    return_str = json.dumps({"code": 0, "msg": ("寮�鍚垚鍔�" if is_open else "鍏抽棴鎴愬姛")})
 
                 sk.send(return_str.encode())
 
@@ -908,24 +916,22 @@
     print(cid, pid)
 
 if __name__ == "__main__":
-    codes = ["603655"]
+    codes = ["000719"]
     for code in codes:
         try:
             global_data_loader.load_zyltgb()
-            limit_up_price = float(gpcode_manager.get_limit_up_price(code))
+            limit_up_price = float("11.13")  # float(gpcode_manager.get_limit_up_price(code))
             volumes_data = juejin.get_volumns_by_code(code, 150)
+            volumes_data = volumes_data[1:]
             volumes = juejin.parse_max_volume(volumes_data[:60],
-                                              code_nature_analyse.is_new_top(gpcode_manager.get_limit_up_price(code),
+                                              code_nature_analyse.is_new_top(limit_up_price,
                                                                              volumes_data[:60]))
             logger_first_code_record.info("{} 鑾峰彇鍒伴鏉�60澶╂渶澶ч噺锛歿}", code, volumes)
             code_volumn_manager.set_histry_volumn(code, volumes[0], volumes[1], volumes[2])
             # 鍒ゆ柇K绾垮舰鎬�
-            is_has_k_format, msg = code_nature_analyse.is_has_k_format(
-                gpcode_manager.get_limit_up_price(code), volumes_data)
-            if not is_has_k_format:
-                logger_first_code_record.info("{}棣栨澘K绾垮舰鎬佷笉濂�,{}", code, msg)
-                # 鍔犲叆绂佹浜ゆ槗浠g爜
-                l2_trade_util.forbidden_trade(code)
+            k_format = code_nature_analyse.get_k_format(
+                limit_up_price, volumes_data)
+            print(k_format)
 
             code_nature_analyse.set_record_datas(code,
                                                  gpcode_manager.get_limit_up_price(code),

--
Gitblit v1.8.0