添加持仓代码获取接口

Administrator

2023-12-05 a9f0b07fc74bb2b6f810100f97798bf277008ddb

添加持仓代码获取接口

 trade/huaxin/huaxin_trade_record_manager.py

@@ -116,7 +116,6 @@
    __redisManager = redis_manager.RedisManager(2)
    latest_positions=[]


    @classmethod
    def __get_redis(cls):
        return cls.__redisManager.getRedis()
@@ -243,6 +242,17 @@
        mysqldb = mysql_data.Mysqldb()
        mysqldb.select_one(f"select currentPosition from hx_trade_position where securityID='{code}'")

    # 获取持仓代码
    @classmethod
    def get_position_codes(cls):
        codes = []
        if cls.latest_positions:
            for d in cls.latest_positions:
                if d["prePosition"] <= 0:
                    continue
                codes.append(d["securityID"])
        return codes


# 成交记录
class DealRecordManager:

 trade/huaxin/huaxin_trade_server.py

@@ -1091,6 +1091,13 @@
                                  "data": {"orderStatus": order_entity.orderStatus, "code": order_entity.code,
                                           "msg": f"【{order_entity.code}({code_name})】已挂单"}}
                self.send_response(result, client_id, request_id)
            elif ctype == "get_position_codes":
                # 获取今日可卖的持仓代码
                codes = PositionManager.get_position_codes()
                result = {"code": 0,
                          "data": codes}
                self.send_response(result, client_id, request_id)

        except Exception as e:
            logging.exception(e)
            self.send_response({"code": 1, "msg": f"数据处理出错：{e}"}, client_id, request_id)