| | |
| | | # print("- " * 30) |
| | | sk: socket.socket = self.request |
| | | while True: |
| | | data = sk.recv(102400) |
| | | data = sk.recv(1024000) |
| | | if len(data) == 0: |
| | | # print("客户端断开连接") |
| | | break |
| | |
| | | # 保存涨停时间 |
| | | gp_list = gpcode_manager.get_gp_list() |
| | | gp_code_set = set(gp_list) |
| | | now_str = datetime.datetime.now().strftime("%H:%M:%S") |
| | | now_str = tool.get_now_time_str() |
| | | for d in dataList: |
| | | if d["time"] == "00:00:00" or tool.get_time_as_second(now_str) < tool.get_time_as_second( |
| | | d["time"]): |
| | |
| | | data = data_process.parse(_str)["data"] |
| | | client_id = data["client"] |
| | | print("L2自启动成功", client_id) |
| | | now_str = datetime.datetime.now().strftime("%H:%M:%S") |
| | | now_str = tool.get_now_time_str() |
| | | ts = tool.get_time_as_second(now_str) |
| | | # 9点25到9点28之间的自启动就需要批量设置代码 |
| | | if tool.get_time_as_second("09:24:50") <= ts <= tool.get_time_as_second("09:28:00"): |
| | |
| | | return_str = json.dumps(return_json) |
| | | |
| | | # print("心跳:", client_id) |
| | | elif type == 100: |
| | | # 图像识别 |
| | | return_str = data_process.toJson({"code": 0, "data": {"datas": []}}) |
| | | pass |
| | | sk.send(return_str.encode()) |
| | | |
| | | # print("----------handler end ----------") |