交易优化，看盘接口完善

Administrator

2023-06-06 751183dcd74207a50834cacc575f0dfccb41658c

 trade/current_price_process_manager.py

@@ -20,14 +20,17 @@
    # 获取首板代码
    first_codes = gpcode_manager.get_first_gp_codes()

    print("价格代码数量：", len(prices))
    print("总价格代码数量：", len(prices))

    __actualPriceProcessor.save_current_price_codes_count(len(prices))
    # 采集的代码数量不对
    if len(gpcode_manager.get_gp_list()) - len(prices) > 10:
        print("采集到的代码数量不正确：", len(prices))
        return
    now_str = tool.get_now_time_str()
    now_strs = now_str.split(":")
    # 获取想买单
    want_codes = gpcode_manager.WantBuyCodesManager.list_code()
    if True:
        _code_list = []
        _delete_list = []
@@ -42,10 +45,10 @@
                    rate = rate / 2
                if rate >= 0 and not trade_manager.ForbiddenBuyCodeByScoreManager.is_in(code):
                    # 暂存涨幅为正的代码
                    _code_list.append((rate, code))
                    _code_list.append((rate, code, 1 if code in want_codes else 0))
                else:
                    # 暂存涨幅为负的代码
                    _delete_list.append((rate, code))
                    _delete_list.append((rate, code, 0))
                try:
                    __actualPriceProcessor.process_rate(code, rate, now_str)
                except Exception as e:
@@ -61,7 +64,7 @@

        # -------------------------------处理交易位置分配---------------------------------
        # 排序
        new_code_list = sorted(_code_list, key=lambda e: (e.__getitem__(0), e.__getitem__(1)), reverse=True)
        new_code_list = sorted(_code_list, key=lambda e: (e.__getitem__(2), e.__getitem__(0)), reverse=True)
        # 预填充下单代码
        _buy_win_codes = []
        for d in new_code_list:
@@ -69,7 +72,8 @@
        for d in _delete_list:
            _buy_win_codes.append(d[1])
        try:
            trade_gui.THSBuyWinManagerNew.fill_codes(_buy_win_codes)
            if not constant.JUEJIN_TRADE_ENABLE:
                trade_gui.THSBuyWinManagerNew.fill_codes(_buy_win_codes)
        except Exception as e:
            logging.exception(e)
            pass