| | |
|---|
| | | if data is not None: |
|---|
| | | data = json.loads(data) |
|---|
| | | # logger_code_operate.info("读取操作队列：{}", data) |
|---|
| | | type, code = data["type"], data["code"] |
|---|
| | | type, code = data["type"], data.get("code") |
|---|
| | | create_time = data.get("create_time") |
|---|
| | | if create_time is not None: |
|---|
| | | # 设置10s超时时间 |
|---|
| | |
|---|
| | | client_id, pos = gpcode_manager.get_can_listen_pos() |
|---|
| | | if pos is not None and client_id is not None: |
|---|
| | | L2CodeOperate.setGPCode(client_id, pos, code) |
|---|
| | | elif type == 10: |
|---|
| | | # 批量设置代码，通常在9:25-9:27期间设置 |
|---|
| | | client_id = data.get("client_id") |
|---|
| | | codes = data[codes] |
|---|
| | | # TODO 需要完善分配 |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 强制设置 |
|---|
| | | elif type == 2: |
|---|
| | | client_id = data["client"] |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | correct_client_codes() |
|---|
| | | 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) |
|---|
