From ed9e2367eea9baa6c8bea82e0f81c209ffb2a56f Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 02 一月 2023 17:55:50 +0800
Subject: [PATCH] 撤单策略再次修改
---
l2_code_operate.py | 49 ++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 38 insertions(+), 11 deletions(-)
diff --git a/l2_code_operate.py b/l2_code_operate.py
index a514496..60254ab 100644
--- a/l2_code_operate.py
+++ b/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锛歝lientid-{} 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)
--
Gitblit v1.8.0