From a2dc7b4f0ff68f8ea87b1d5c32539dbe0961a4b4 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 17 七月 2025 14:23:07 +0800
Subject: [PATCH] bug修复

---
 api/outside_api_command_callback.py |  130 +++++++++++++++++++++++++++++++++++++++---
 1 files changed, 119 insertions(+), 11 deletions(-)

diff --git a/api/outside_api_command_callback.py b/api/outside_api_command_callback.py
index 27088d6..897abee 100644
--- a/api/outside_api_command_callback.py
+++ b/api/outside_api_command_callback.py
@@ -14,7 +14,8 @@
 import constant
 import inited_data
 import outside_api_command_manager
-from cancel_strategy.s_l_h_cancel_strategy import SCancelBigNumComputer, LCancelRateManager
+from cancel_strategy.s_l_h_cancel_strategy import SCancelBigNumComputer, LCancelRateManager, \
+    CancelRateHumanSettingManager, LCancelBigNumComputer, LDownCancelWatchIndexStatisticManager
 from code_attribute import gpcode_manager, code_volumn_manager, zyltgb_util, code_nature_analyse
 from code_attribute.code_data_util import ZYLTGBUtil
 from code_attribute.code_l1_data_manager import L1DataManager
@@ -54,11 +55,12 @@
 from trade.huaxin import huaxin_trade_api, huaxin_trade_data_update, \
     huaxin_trade_record_manager, huaxin_trade_order_processor, huaxin_sell_util
 from trade.huaxin.huaxin_trade_record_manager import PositionManager, DealRecordManager, DelegateRecordManager
-from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, BeforeSubDealBigOrderManager
+from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, BeforeSubDealBigOrderManager, \
+    TotalDealBigOrderThresholdMoneyManager
 from trade.sell import sell_manager
 from trade.sell.sell_rule_manager import TradeRuleManager, SellRule
 from trade.trade_data_manager import RadicalBuyDealCodesManager
-from trade.trade_manager import TradeTargetCodeModeManager, AutoCancelSellModeManager
+from trade.trade_manager import TradeTargetCodeModeManager, AutoCancelSellModeManager, CodesContinueBuyMoneyManager
 from settings.trade_setting import MarketSituationManager, TradeBlockBuyModeManager
 from utils import socket_util, data_export_util, tool, huaxin_util, output_util, global_util, init_data_util
 from servers import server_util
@@ -398,7 +400,13 @@
             elif code_list_type == outside_api_command_manager.CODE_LIST_GREEN:
                 if operate == outside_api_command_manager.OPERRATE_SET:
                     gpcode_manager.GreenListCodeManager().add_code(code)
+                    trade_record_log_util.add_green(code, "浜轰负鍔犵豢")
+
                     gpcode_manager.WantBuyCodesManager().add_code(code)
+                    # 鍔犵櫧
+                    gpcode_manager.WhiteListCodeManager().add_code(code, is_human=True)
+                    trade_record_log_util.add_white_buy(code, "鍔犵豢鍔犵櫧")
+
                     name = gpcode_manager.get_code_name(code)
                     if not name:
                         results = HistoryKDatasUtils.get_gp_codes_names([code])
@@ -406,7 +414,7 @@
                             gpcode_manager.CodesNameManager.add_first_code_name(code, results[code])
                 elif operate == outside_api_command_manager.OPERRATE_DELETE:
                     gpcode_manager.GreenListCodeManager().remove_code(code)
-                    gpcode_manager.WantBuyCodesManager().remove_code(code)
+                    gpcode_manager.WhiteListCodeManager().remove_code(code)
                 elif operate == outside_api_command_manager.OPERRATE_GET:
                     codes = gpcode_manager.GreenListCodeManager().list_codes_cache()
                     datas = []
@@ -878,12 +886,16 @@
                     [huaxin_util.TORA_TSTP_OST_Accepted, huaxin_util.TORA_TSTP_OST_PartTraded])
                 fdatas = []
                 if current_delegates:
+                    codes_set = set()
                     for c in current_delegates:
                         try:
                             if int(c["direction"]) != huaxin_util.TORA_TSTP_D_Buy:
                                 continue
                             code = c["securityID"]
+                            if code in codes_set:
+                                continue
                             orderSysID = c.get("orderSysID")
+                            codes_set.add(code)
                             code_name = gpcode_manager.get_code_name(code)
                             # 鑾峰彇涓嬪崟浣嶇疆淇℃伅
                             order_begin_pos = TradePointManager().get_buy_compute_start_data_cache(code)
@@ -1066,21 +1078,21 @@
                             except:
                                 pass
                             # L鎾ゆ瘮渚�
-                            l_down_cancel_rate, must_buy = LCancelRateManager.get_cancel_rate(code,
-                                                                                              buy_mode=OrderBeginPosInfo.MODE_RADICAL)
+                            l_down_cancel_rate, must_buy, cancel_rate_info = LCancelRateManager.get_cancel_rate(code,
+                                                                                                                buy_mode=OrderBeginPosInfo.MODE_RADICAL)
 
                             # 鍦ㄦ寕鐨勮窛绂绘垚浜よ繘搴︿綅閲戦/锛堣繙杩戞湡鍙傝�冮噺-鍗曞綋鏃ュ疄鏃舵垚浜ら噺锛�*100%
                             expire_rate = "鏈煡"
                             try:
                                 referer_volume = code_volumn_manager.CodeVolumeManager().get_radical_buy_refer_volume(
-                                    code, limit_up_price)
+                                    code, float(limit_up_price))
                                 today_volumn = code_volumn_manager.CodeVolumeManager().get_today_volumn_cache(code)
                                 if referer_volume == today_volumn:
                                     expire_rate = "100%"
                                 else:
                                     expire_rate = f"{100 - round(100 * total_left_num * 100 / (referer_volume - today_volumn), 2)}%"
-                            except:
-                                pass
+                            except Exception as e:
+                                logger_debug.exception(e)
 
                             fdata = {"id": orderSysID, "code_info": (code, code_name), "total_num": total_nums,
                                      "finish_num": deal_or_cancel_num,
@@ -1106,6 +1118,7 @@
                                      "block": '',
                                      "trade_queue": [],
                                      "l_down_cancel_rate": l_down_cancel_rate,
+                                     "l_down_cancel_rate_info": cancel_rate_info,
                                      "expire_rate": expire_rate
                                      }
                             limit_up_data = kpl_data_manager.KPLLimitUpDataRecordManager.record_code_dict.get(code)
@@ -1151,7 +1164,17 @@
                                     fdata['mode'] = -1
                             except:
                                 pass
-
+                            # L鍚庡泭鎷揩鐓�
+                            try:
+                                current_info = LCancelBigNumComputer().statistic_l_down_watch_indexes_info(code)
+                                last_info = LDownCancelWatchIndexStatisticManager().get_statistic_info(code)
+                                fdata['l_down_watch_indexes_info'] = {}
+                                if current_info:
+                                    fdata['l_down_watch_indexes_info']['current'] = current_info
+                                if last_info:
+                                    fdata['l_down_watch_indexes_info']['last'] = last_info
+                            except:
+                                pass
                             fdatas.append(fdata)
                         except Exception as e:
                             logger_debug.exception(e)
@@ -1319,7 +1342,9 @@
                     if volumes_data:
                         is_new_top = code_nature_analyse.is_new_top(code,
                                                                     gpcode_manager.get_limit_up_price_by_preprice(code,
-                                                                                                                  volumes_data[0]["close"]),
+                                                                                                                  volumes_data[
+                                                                                                                      0][
+                                                                                                                      "close"]),
                                                                     volumes_data)
 
                 data = {
@@ -1476,7 +1501,90 @@
                                    client_id,
                                    request_id)
 
+            elif ctype == "test_cancel_order":
+                # 鑾峰彇鐩稿悓鏉垮潡鐨勬定鍋滀唬鐮佹暟閲�
+                code = data.get("code")
+                trade_manager.start_cancel_buy(code, force=True)
+                self.send_response({"code": 0, "data": {}},
+                                   client_id,
+                                   request_id)
 
+            elif ctype == "set_total_deal_big_order_threshold_money":
+                code = data.get("code")
+                money = data.get("money")
+                if not code or not money:
+                    self.send_response({"code": 1, "data": {}, "msg": "code/money涓虹┖"},
+                                       client_id,
+                                       request_id)
+                    return
+                TotalDealBigOrderThresholdMoneyManager().set_money(code, int(money),
+                                                                   trade_manager.CodesTradeStateManager().get_trade_state_cache(
+                                                                       code))
+
+                # 濡傛灉鏄姞绾㈢姸鎬侊紝涓斿ぇ鍗曚笉澶熷氨闇�瑕佺Щ绾�
+                if gpcode_manager.MustBuyCodesManager().is_in_cache(code):
+                    deal_big_order_info = radical_buy_data_manager.get_total_deal_big_order_info(code,
+                                                                                                 gpcode_manager.get_limit_up_price_as_num(
+                                                                                                     code))
+                    if deal_big_order_info[0] > 0:
+                        gpcode_manager.MustBuyCodesManager().remove_code(code)
+                        trade_record_log_util.add_common_msg(code, "绉荤孩", f"澶у崟闃堝�间慨鏀癸紙{money}锛�")
+                self.send_response({"code": 0, "data": {}},
+                                   client_id,
+                                   request_id)
+            elif ctype == "set_l_down_rate":
+                # 璁剧疆L鍚庢挙鍗曟瘮渚�
+                code = data.get("code")
+                rate = data.get("rate")
+                if rate < 0 or rate > 2:
+                    self.send_response({"code": 1, "msg": "姣斾緥鑼冨洿涓嶅湪0-1涔嬮棿"},
+                                       client_id,
+                                       request_id)
+                    return
+                rate = round(rate, 2)
+                old_rate = LCancelRateManager().get_cancel_rate(0)[0]
+                # L鍚庢暟鎹揩鐓�
+                last_info = LCancelBigNumComputer().statistic_l_down_watch_indexes_info(code)
+                LDownCancelWatchIndexStatisticManager().set_statistic_info(code, last_info)
+                CancelRateHumanSettingManager().set_l_down(code, rate)
+                # L鍚庨噸鏂板泭鎷�
+                if rate < old_rate:
+                    # 鏀瑰皬鎵嶈兘閲嶆柊鍥婃嫭
+                    LCancelBigNumComputer().re_compute_l_down_watch_indexes(code)
+                self.send_response({"code": 0, "data": {}},
+                                   client_id,
+                                   request_id)
+
+            elif ctype == "get_continue_buy_info":
+                # 璁剧疆L鍚庢挙鍗曟瘮渚�
+                code = data.get("code")
+                money = CodesContinueBuyMoneyManager().get_continue_buy_money(code)
+                if money is None:
+                    money = 0
+                self.send_response({"code": 0, "data": {"money": money, "money_list": constant.AVAILABLE_BUY_MONEYS}},
+                                   client_id,
+                                   request_id)
+            elif ctype == "set_continue_buy_money":
+                # 璁剧疆L鍚庢挙鍗曟瘮渚�
+                code = data.get("code")
+                money = data.get("money")
+                if money <= 0:
+                    # 琛ㄧず绉婚櫎缁拱閲戦
+                    CodesContinueBuyMoneyManager().remove_continue_buy_money(code)
+                    self.send_response({"code": 0, "data": {}},
+                                       client_id,
+                                       request_id)
+                    return
+                if money not in constant.AVAILABLE_BUY_MONEYS:
+                    self.send_response({"code": 1, "msg": f"閲戦锛坽money}锛夋病鍦▄constant.AVAILABLE_BUY_MONEYS}涓�"},
+                                       client_id,
+                                       request_id)
+                    return
+                CodesContinueBuyMoneyManager().set_continue_buy_money(code, money)
+                l2_trade_util.remove_from_forbidden_trade_codes(code)
+                self.send_response({"code": 0, "data": {}},
+                                   client_id,
+                                   request_id)
 
         except Exception as e:
             logging.exception(e)

--
Gitblit v1.8.0