bug修复

Administrator

2023-11-30 6deebc1f495f89cd168021512aaeacb8e93ebae7

bug修复

 third_data/code_plate_key_manager.py

@@ -47,7 +47,7 @@
            blocks.sort(key=lambda x: x[2])
            blocks.reverse()
            for b in blocks:
                if (b[2] > -1 or b[1] in current_limit_up_blocks) and b[1] not in constant.KPL_INVALID_BLOCKS:
                if b[1] not in constant.KPL_INVALID_BLOCKS:
                    final_blocks.append(b)
            if len(final_blocks) < 2:
                final_blocks = blocks

 trade/huaxin/huaxin_trade_server.py

@@ -419,7 +419,8 @@
                logger_debug.exception(e)

            # ----------------------------------板块相关------------------------------
            cls.__KPLCodeJXBlockManager.load_jx_blocks(code, buy_1_price, limit_up_price, kpl_data_manager.KPLLimitUpDataRecordManager.get_current_reasons())
            cls.__KPLCodeJXBlockManager.load_jx_blocks(code, buy_1_price, limit_up_price,
                                                       kpl_data_manager.KPLLimitUpDataRecordManager.get_current_reasons())
            # 更新板块信息
            yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes()
            CodePlateKeyBuyManager.update_can_buy_blocks(code,
@@ -604,7 +605,8 @@
                    msg_list = []
                    try:
                        sell_count = 0
                        sell_orders = huaxin_trade_order_processor.TradeResultProcessor.get_huaxin_sell_order_by_code(code)
                        sell_orders = huaxin_trade_order_processor.TradeResultProcessor.get_huaxin_sell_order_by_code(
                            code)
                        if sell_orders:
                            for sell_order in sell_orders:
                                if huaxin_util.is_can_cancel(sell_order.orderStatus):
@@ -618,7 +620,8 @@
                        msg_list.append(f"无法撤买单")
                    else:
                        msg_list.append(f"已撤买单")
                    self.send_response({"code": 0, "data": {"code": 0,"msg": "；".join(msg_list)}}, client_id, request_id)
                    self.send_response({"code": 0, "data": {"code": 0, "msg": "；".join(msg_list)}}, client_id,
                                       request_id)
        except Exception as e:
            logger_debug.exception(e)
            self.send_response({"code": 1, "msg": str(e)}, client_id, request_id)
@@ -1038,7 +1041,8 @@
                        # 判断是否有名称
                        results = HistoryKDatasUtils.get_gp_codes_names([d["securityID"]])
                        threading.Thread(
                            target=CodesNameManager.add_first_code_name(d["securityID"], results[d["securityID"]])).start()
                            target=CodesNameManager.add_first_code_name(d["securityID"],
                                                                        results[d["securityID"]])).start()
                    if d["prePosition"] <= 0:
                        continue
                    if d["securityID"] != code: