添加下单锁

Administrator

2024-04-28 cecea3031cbd616476d8e1432be2b729f7c6b786

添加下单锁

 constant.py

@@ -99,7 +99,7 @@

# 开盘啦
KPL_INVALID_BLOCKS = {"一季报增长", "二季报增长", "三季报增长", "四季报增长", "业绩增长", "中报增长", "年报增长", "年报预增", "无", "次新股", "ST摘帽", "超跌",
                      "股权转让", "并购重组", "再融资", "年报预增", " 专精特新", "壳资源", "行业龙头", "参股金融", "科创板", "实控人变更"}
                      "股权转让", "并购重组", "再融资", "年报预增", " 专精特新", "壳资源", "行业龙头", "科创板", "实控人变更"}
# 是否开启API交易
API_TRADE_ENABLE = True
# 每只票买的金额

 third_data/code_plate_key_manager.py

@@ -443,6 +443,11 @@

    # 返回key集合(排除无效板块),今日涨停原因,今日历史涨停原因,历史涨停原因,二级,精选板块
    def get_plate_keys(self, code):
        """
        获取代码的板块
        @param code:
        @return: （板块关键词集合,今日涨停原因+涨停推荐原因,今日历史涨停原因,历史涨停原因,精选板块）
        """
        keys = set()
        k1 = set()


 third_data/kpl_api.py

@@ -261,4 +261,4 @@


if __name__ == "__main__":
    print(getLimitUpInfoNew())
    print(set(__getConceptJXBK("002670")) - constant.KPL_INVALID_BLOCKS)

 trade/huaxin/huaxin_trade_api.py

@@ -166,14 +166,19 @@
    #         logging.exception(e)


# 下单ZMQ通信锁
__order_zmq_lock = threading.Lock()


def __order_by_zmq(data_json):
    """
    通过zmq发送下单信息
    @param data_json:
    @return:
    """
    order_socket.send_json(data_json)
    response = order_socket.recv_string()
    with __order_zmq_lock:
        order_socket.send_json(data_json)
        response = order_socket.recv_string()


def __cancel_order_by_zmq(data_json):
@@ -512,7 +517,8 @@

def cancel_order(direction, code, orderSysID, orderRef=None, blocking=False, sinfo=None, request_id=None,
                 recancel=False):
    if tool.trade_time_sub(tool.get_now_time_str(), "14:57:00") >= 0 and tool.trade_time_sub(tool.get_now_time_str(), "15:00:01") <= 0 :
    if tool.trade_time_sub(tool.get_now_time_str(), "14:57:00") >= 0 and tool.trade_time_sub(tool.get_now_time_str(),
                                                                                             "15:00:01") <= 0:
        # 集合竞价不撤单
        return