撤单策略再次修改

Administrator

2023-01-02 ed9e2367eea9baa6c8bea82e0f81c209ffb2a56f

 l2_code_operate.py

@@ -58,6 +58,35 @@
        finally:
            gpcode_manager.rm_operate(gpcode)

    @staticmethod
    def betchSetGPCode(client_id, codes_info):
        # codes_info 格式[(0,"000333")]
        datas = []
        for info in codes_info:
            datas.append({"index": info[0], "code": info[1]})

        data = {"action": "betchSetGPCodes", "data": datas, "force": True}
        logger_code_operate.info("betchSetGPCodes：clientid-{}  info-{}".format(client_id, codes_info))
        codes = []
        for item in codes_info:
            codes.append(item[1])
        gpcode_manager.set_operates(codes)
        try:
            result = server.send_msg(client_id, data)
            logger_code_operate.info(
                "betchSetGPCodes结束（{}）：clientid-{}  info-{}".format(result, client_id, codes_info))
            jsonData = json.loads(result)
            if jsonData["code"] == 0:
                for item in codes_info:
                    gpcode_manager.set_listen_code_by_pos(client_id, item[0], item[1])
                    L2CodeOperate.set_operate_code_state(client_id, item[0], 1)

        except Exception as e:
            logging.exception(e)
            logger_code_operate.error("setGPCode出错：{}", str(e))
        finally:
            gpcode_manager.rm_operates(codes)

    @classmethod
    def run(cls):
        cls.__lock.acquire()
@@ -269,15 +298,13 @@
            logger_code_operate.error("client:{} msg:{}".format(client_id, str(e)))


# 批量设置代码
def betch_set_client_codes(client_id,codes_info):
    # 获取涨幅前16位代码
    L2CodeOperate.betchSetGPCode(client_id, codes_info)


if __name__ == "__main__":
    codes = [(0, "002210"), (1, "600056"), (2, "002591"), (3, "002193"), (4, "603186"), (5, "600833"), (6, "000736"),
             (7, "603000")]
    datas = []
    for item in codes:
        datas.append({"index": item[0], "code": item[1]})
    data = {"action": "betchSetGPCodes", "data": datas}
    try:
        result = server.send_msg(3, data)
        print("设置结果：", result)
    except Exception as e:
        logging.exception(e)
    codes = [(0, "000615"), (1, "002264"), (2, "600225"), (3, "002495"), (4, "600572"), (5, "002279"), (6, "002591"),
             (7, "002880")]
    L2CodeOperate.betchSetGPCode(3, codes)