异常保护

Administrator

4 天以前 48fb7a00951f91bdc707e5dd2d196e5bccb752c3

 servers/server.py

@@ -22,7 +22,7 @@
    current_price_process_manager, trade_juejin, trade_constant
import l2.transaction_progress

from log_module.log import  logger_trade_delegate, logger_buy_1_volumn_record, \
from log_module.log import logger_trade_delegate, logger_buy_1_volumn_record, \
    logger_l2_trade_queue, logger_l2_trade_buy_queue, logger_debug
from trade.huaxin import huaxin_trade_record_manager
from trade.trade_manager import TradeTargetCodeModeManager
@@ -258,7 +258,8 @@
                        limit_up_price = gpcode_manager.get_limit_up_price(code)

                        if limit_up_price is not None:
                            code_price_manager.Buy1PriceManager().process(code, buy_one_price, buy_one_volumn, buy_time, limit_up_price,
                            code_price_manager.Buy1PriceManager().process(code, buy_one_price, buy_one_volumn, buy_time,
                                                                          limit_up_price,
                                                                          sell_one_price, sell_one_volumn)
                            _start_time = time.time()
                            msg += "买1价格处理：" + f"{_start_time - __start_time} "
@@ -276,14 +277,16 @@
                                    buy_one_price_ = decimal.Decimal(round(float(buy_one_price), 2)).quantize(
                                        decimal.Decimal("0.00"))
                                    # 获取执行位时间
                                    order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code)
                                    order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(
                                        code)
                                    if True:
                                        # 只有下单过后才获取交易进度
                                        exec_time = None
                                        try:
                                            if order_begin_pos.buy_exec_index and order_begin_pos.buy_exec_index > -1:
                                                exec_time = \
                                                    l2.l2_data_util.local_today_datas.get(code)[order_begin_pos.buy_exec_index]["val"]["time"]
                                                    l2.l2_data_util.local_today_datas.get(code)[
                                                        order_begin_pos.buy_exec_index]["val"]["time"]
                                        except:
                                            pass
                                        buy_progress_index = self.tradeBuyQueue.compute_traded_index(code,
@@ -291,7 +294,9 @@
                                                                                                     buy_queue_result_list,
                                                                                                     exec_time)
                                        if buy_progress_index is not None:
                                            LCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index, buy_progress_index,
                                            LCancelBigNumComputer().set_trade_progress(code,
                                                                                       order_begin_pos.buy_single_index,
                                                                                       buy_progress_index,
                                                                                       l2.l2_data_util.local_today_datas.get(
                                                                                           code))

@@ -421,7 +426,8 @@
                        state = trade_manager.CodesTradeStateManager().get_trade_state(code)
                        if state == trade_constant.TRADE_STATE_BUY_PLACE_ORDER or state == trade_constant.TRADE_STATE_BUY_DELEGATED or state == trade_constant.TRADE_STATE_BUY_CANCEL_ING:
                            try:
                                l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "手动撤销", cancel_type=trade_constant.CANCEL_TYPE_HUMAN)
                                l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "手动撤销",
                                                                                    cancel_type=trade_constant.CANCEL_TYPE_HUMAN)
                                return_str = json.dumps({"code": 0})
                            except Exception as e:
                                return_str = json.dumps({"code": 2, "msg": str(e)})
@@ -444,7 +450,7 @@
                    data = json.loads(_str)
                    codes = data["data"]["codes"]
                    for code in codes:
                        l2_trade_util.forbidden_trade(code, msg="手动加入")
                        l2_trade_util.forbidden_trade(code, msg="手动加入", force=True)
                        name = gpcode_manager.get_code_name(code)
                        if not name:
                            results = HistoryKDatasUtils.get_gp_codes_names([code])
@@ -688,4 +694,4 @@
                trade_manager.save_trade_success_data(fdatas)
        except:
            pass
        time.sleep(1.5)
        time.sleep(1.5)