From c3f1cfdea0c16916c941f3279658090da2aadf0d Mon Sep 17 00:00:00 2001 From: linyimin <18316471919@139.com> Date: Wed, 16 Sep 2026 09:30:26 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20TCP=E5=8D=8F=E8=AE=AE=E6=94=AF=E6=8C=81?= =?UTF-8?q?protobuf=E5=BA=8F=E5=88=97=E5=8C=96=EF=BC=8C=E4=BF=9D=E7=95=99J?= =?UTF-8?q?SON=E5=85=BC=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 新增 tcp_messages_pb2.py protobuf Python绑定 - msg_handler.cpp: 新增 make_packet_pb/raw bytes打包, parse_packet_raw/raw解析 - archery_netcore.cpp: 注册 make_packet_pb/parse_packet_raw - network.py: 新增 _use_proto 标志，_make_send_packet/_parse_recv 自动选择proto/JSON - 登录version加+proto后缀标识proto模式 - protobuf序列化/反序列化失败时自动回退JSON --- cpp_ext/archery_netcore.cpp | 9 +- cpp_ext/msg_handler.cpp | 59 ++++++++ cpp_ext/msg_handler.hpp | 11 +- network.py | 121 ++++++++++++++- tcp_messages_pb2.py | 295 ++++++++++++++++++++++++++++++++++++ 5 files changed, 485 insertions(+), 10 deletions(-) create mode 100644 tcp_messages_pb2.py diff --git a/cpp_ext/archery_netcore.cpp b/cpp_ext/archery_netcore.cpp index 06162a6..8d468d3 100644 --- a/cpp_ext/archery_netcore.cpp +++ b/cpp_ext/archery_netcore.cpp @@ -56,10 +56,17 @@ PYBIND11_MODULE(archery_netcore, m) { m.def("make_packet", &netcore::make_packet, "Pack TCP packet: header (len+type+checksum) + JSON body", py::arg("msg_type"), py::arg("body_dict")); - + + m.def("make_packet_pb", &netcore::make_packet_pb, + "Pack TCP packet: header (len+type+checksum) + raw bytes body (for protobuf)", + py::arg("msg_type"), py::arg("body_bytes")); + m.def("parse_packet", &netcore::parse_packet, "Parse TCP packet, return (msg_type, body_dict)"); + m.def("parse_packet_raw", &netcore::parse_packet_raw, + "Parse TCP packet, return (msg_type, body_bytes) without JSON parsing"); + m.def("get_config", &get_config, "Get system configuration"); m.def( diff --git a/cpp_ext/msg_handler.cpp b/cpp_ext/msg_handler.cpp index d06d900..94b3dfb 100644 --- a/cpp_ext/msg_handler.cpp +++ b/cpp_ext/msg_handler.cpp @@ -51,6 +51,43 @@ namespace netcore { return py::bytes(reinterpret_cast(packet.data()), packet.size()); } + // 打包 TCP 数据包 (raw bytes body, 用于 protobuf) + py::bytes make_packet_pb(int msg_type, py::bytes body_bytes) { + netcore::log_debug(std::string("make_packet_pb msg_type=") + std::to_string(msg_type)); + + py::buffer_info buf = py::buffer(body_bytes).request(); + uint32_t body_len = buf.size; + uint32_t checksum = body_len + msg_type; + + std::vector packet; + packet.reserve(12 + body_len); + + // body_len (big-endian, 4 bytes) + packet.push_back((body_len >> 24) & 0xFF); + packet.push_back((body_len >> 16) & 0xFF); + packet.push_back((body_len >> 8) & 0xFF); + packet.push_back(body_len & 0xFF); + + // msg_type (big-endian, 4 bytes) + packet.push_back((msg_type >> 24) & 0xFF); + packet.push_back((msg_type >> 16) & 0xFF); + packet.push_back((msg_type >> 8) & 0xFF); + packet.push_back(msg_type & 0xFF); + + // checksum (big-endian, 4 bytes) + packet.push_back((checksum >> 24) & 0xFF); + packet.push_back((checksum >> 16) & 0xFF); + packet.push_back((checksum >> 8) & 0xFF); + packet.push_back(checksum & 0xFF); + + // 追加 body bytes + const uint8_t* body_ptr = static_cast(buf.ptr); + packet.insert(packet.end(), body_ptr, body_ptr + body_len); + + netcore::log_debug(std::string("make_packet_pb done bytes=") + std::to_string(packet.size())); + return py::bytes(reinterpret_cast(packet.data()), packet.size()); + } + // 解析 TCP 数据包 py::tuple parse_packet(py::bytes data) { // 1) 转换为 bytes view @@ -110,4 +147,26 @@ namespace netcore { return py::make_tuple(py::int_(msg_type), raw_dict); } } + + // 解析 TCP 数据包 -> (msg_type, body_bytes) 不做 JSON 解析 + py::tuple parse_packet_raw(py::bytes data) { + py::buffer_info buf = py::buffer(data).request(); + if (buf.size < 12) { + return py::make_tuple(py::none(), py::none()); + } + + const uint8_t* ptr = static_cast(buf.ptr); + + uint32_t body_len = (ptr[0] << 24) | (ptr[1] << 16) | (ptr[2] << 8) | ptr[3]; + uint32_t msg_type = (ptr[4] << 24) | (ptr[5] << 16) | (ptr[6] << 8) | ptr[7]; + + uint32_t expected_len = 12 + body_len; + if (buf.size < expected_len) { + return py::make_tuple(py::none(), py::none()); + } + + // 返回原始 body bytes（不做 JSON 解析） + py::bytes body_bytes(reinterpret_cast(ptr + 12), body_len); + return py::make_tuple(py::int_(msg_type), body_bytes); + } } \ No newline at end of file diff --git a/cpp_ext/msg_handler.hpp b/cpp_ext/msg_handler.hpp index fcee18f..b65beb9 100644 --- a/cpp_ext/msg_handler.hpp +++ b/cpp_ext/msg_handler.hpp @@ -7,8 +7,15 @@ namespace py = pybind11; namespace netcore { - // 打包 TCP 数据包 + // 打包 TCP 数据包 (JSON body) py::bytes make_packet(int msg_type, py::dict body_dict); - // 解包 TCP 数据包 + + // 打包 TCP 数据包 (raw bytes body, 用于 protobuf) + py::bytes make_packet_pb(int msg_type, py::bytes body_bytes); + + // 解包 TCP 数据包 -> (msg_type, body_dict) py::tuple parse_packet(py::bytes data); + + // 解包 TCP 数据包 -> (msg_type, body_bytes) 不做 JSON 解析 + py::tuple parse_packet_raw(py::bytes data); } \ No newline at end of file diff --git a/network.py b/network.py index e8d7d16..66b77df 100644 --- a/network.py +++ b/network.py @@ -23,6 +23,14 @@ from logger_manager import logger_manager from wifi import wifi_manager import subprocess +# protobuf 支持 +try: + import tcp_messages_pb2 as pb + _HAS_PROTO = True +except ImportError: + _HAS_PROTO = False + print("[NET] tcp_messages_pb2 not found, protobuf disabled") + def _wifi_tls_would_block(exc): """ @@ -72,6 +80,9 @@ class NetworkManager: self._raw_line_data = [] self._manual_trigger_flag = False + # protobuf 协议支持 + self._use_proto = _HAS_PROTO # 默认启用 proto（如果可用） + # 限制并发命令线程数 self._cmd_thread_lock = threading.Lock() self._cmd_thread_count = 0 @@ -711,6 +722,103 @@ class NetworkManager: """线程安全地将消息加入队列（公共方法）""" self._enqueue((msg_type, data_dict), high) + def _make_send_packet(self, msg_type, data_dict): + """根据协议模式构造发送数据包""" + if self._use_proto and _HAS_PROTO: + return self._make_proto_packet(msg_type, data_dict) + return self._netcore.make_packet(msg_type, data_dict) + + def _make_proto_packet(self, msg_type, data_dict): + """使用 protobuf 序列化构造数据包""" + try: + if msg_type == 1: + # 登录消息 + msg = pb.LoginRequest( + device_id=data_dict.get("deviceId", ""), + password=data_dict.get("password", ""), + if_admin=data_dict.get("ifAdmin", False), + version=data_dict.get("version", ""), + vol=data_dict.get("vol", 0), + vol_per=data_dict.get("vol_per", 0), + iccid=data_dict.get("iccid", ""), + ) + elif msg_type == 4: + # 心跳消息 + msg = pb.Heartbeat( + t=data_dict.get("t", 0), + vol=data_dict.get("vol", 0), + vol_per=data_dict.get("vol_per", 0), + ) + elif msg_type == 2: + # 业务逻辑消息 + cmd = data_dict.get("cmd", 0) + inner_data = {k: v for k, v in data_dict.items() if k != "cmd"} + data_bytes = json.dumps(inner_data).encode("utf-8") if inner_data else b"" + msg = pb.LogicBody(cmd=cmd, data=data_bytes) + else: + # 其他消息类型，回退到 JSON + return self._netcore.make_packet(msg_type, data_dict) + + body_bytes = msg.SerializeToString() + return self._netcore.make_packet_pb(msg_type, body_bytes) + except Exception as e: + self.logger.error(f"[NET] protobuf 序列化失败，回退到 JSON: {e}") + return self._netcore.make_packet(msg_type, data_dict) + + def _parse_recv(self, payload): + """解析接收的数据包，返回 (msg_type, body_dict)""" + if self._use_proto and _HAS_PROTO: + msg_type, body_bytes = self._netcore.parse_packet_raw(payload) + if msg_type is None: + return None, None + try: + body_dict = self._parse_proto_body(msg_type, body_bytes) + return msg_type, body_dict + except Exception as e: + self.logger.error(f"[NET] protobuf 反序列化失败: {e}") + # 回退到 JSON 解析 + return self._netcore.parse_packet(payload) + else: + return self._netcore.parse_packet(payload) + + def _parse_proto_body(self, msg_type, body_bytes): + """将 protobuf body bytes 反序列化为 dict""" + if msg_type == 1: + msg = pb.LoginResponse() + msg.ParseFromString(body_bytes) + return {"cmd": msg.cmd, "data": msg.data} + elif msg_type == 4: + # 心跳 ACK 通常无 body + return {} + elif msg_type == 2: + msg = pb.LogicBody() + msg.ParseFromString(body_bytes) + result = {"cmd": msg.cmd} + if msg.data: + try: + result["data"] = json.loads(msg.data.decode("utf-8")) + except: + result["data"] = {"raw": msg.data.hex()} + return result + elif msg_type == 40: + msg = pb.OtaFragment() + msg.ParseFromString(body_bytes) + return {"l": msg.l, "d": msg.d, "t": msg.t, "v": msg.v} + elif msg_type == 100: + msg = pb.ImageUploadCommand() + msg.ParseFromString(body_bytes) + return {"uploadUrl": msg.upload_url, "token": msg.token, "shootId": msg.shoot_id, "outlink": msg.outlink} + elif msg_type == 101: + msg = pb.LogUploadCommand() + msg.ParseFromString(body_bytes) + return {"uploadUrl": msg.upload_url, "token": msg.token, "key": msg.key, "outlink": msg.outlink, "archive": msg.archive} + else: + # 未知类型，尝试 JSON 解析 + try: + return json.loads(body_bytes.decode("utf-8")) + except: + return {"raw": body_bytes.hex()} + def connect_server(self): """ 连接到服务器（自动选择WiFi或4G） @@ -1842,14 +1950,13 @@ class NetworkManager: login_data = { "deviceId": self.device_id, "password": self.password, - "version": config.APP_VERSION, + "version": config.APP_VERSION + ("+proto" if self._use_proto else ""), "vol": vol_val, "vol_per": voltage_to_percent(vol_val) } iccid_pending_marker = self._maybe_add_iccid_to_login(login_data) print(f"login_data: {login_data}") - # if not self.tcp_send_raw(self.make_packet(1, login_data)): - if not self.tcp_send_raw(self._netcore.make_packet(1, login_data)): + if not self.tcp_send_raw(self._make_send_packet(1, login_data)): self._tcp_connected = False try: self.disconnect_server() @@ -1926,7 +2033,7 @@ class NetworkManager: pass # msg_type, body = self.parse_packet(payload) - msg_type, body = self._netcore.parse_packet(payload) + msg_type, body = self._parse_recv(payload) # 处理登录响应 if not logged_in and msg_type == 1: @@ -2310,7 +2417,7 @@ class NetworkManager: if item: msg_type, data_dict = item - pkt = self._netcore.make_packet(msg_type, data_dict) + pkt = self._make_send_packet(msg_type, data_dict) if not self.tcp_send_raw(pkt): # 发送失败：将消息放回队首（队列满则丢弃） with self.get_queue_lock(): @@ -2339,8 +2446,8 @@ class NetworkManager: current_time = time.ticks_ms() if logged_in and current_time - last_heartbeat_send_time > config.HEARTBEAT_INTERVAL * 1000: vol_val = get_bus_voltage() - if not self.tcp_send_raw( - self._netcore.make_packet(4, {"vol": vol_val, "vol_per": voltage_to_percent(vol_val)})): + heartbeat_pkt = self._make_send_packet(4, {"vol": vol_val, "vol_per": voltage_to_percent(vol_val)}) + if not self.tcp_send_raw(heartbeat_pkt): # if not self.tcp_send_raw(self.make_packet(4, {"vol": vol_val, "vol_per": voltage_to_percent(vol_val)})): send_hartbeat_fail_count += 1 # 短暂波动可能导致一次发送失败：连续失败达到阈值才重连，避免重连风暴 diff --git a/tcp_messages_pb2.py b/tcp_messages_pb2.py new file mode 100644 index 0000000..7ffd3ce --- /dev/null +++ b/tcp_messages_pb2.py @@ -0,0 +1,295 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# source: tcp_messages.proto +"""Generated protocol buffer code.""" +from google.protobuf import descriptor as _descriptor +from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection +from google.protobuf import symbol_database as _symbol_database +# @@protoc_insertion_point(imports) + +_sym_db = _symbol_database.Default() + + + + +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x12tcp_messages.proto\x12\x03tcp\"\x83\x01\n\x0cLoginRequest\x12\x11\n\tdevice_id\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\x12\x10\n\x08if_admin\x18\x03 \x01(\x08\x12\x0f\n\x07version\x18\x04 \x01(\t\x12\x0b\n\x03vol\x18\x05 \x01(\x01\x12\x0f\n\x07vol_per\x18\x06 \x01(\x01\x12\r\n\x05iccid\x18\x07 \x01(\t\"*\n\rLoginResponse\x12\x0b\n\x03\x63md\x18\x01 \x01(\r\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\t\"4\n\tHeartbeat\x12\t\n\x01t\x18\x01 \x01(\x03\x12\x0b\n\x03vol\x18\x02 \x01(\x01\x12\x0f\n\x07vol_per\x18\x03 \x01(\x01\"&\n\tLogicBody\x12\x0b\n\x03\x63md\x18\x01 \x01(\r\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\")\n\x0cResponseBody\x12\x0b\n\x03\x63md\x18\x01 \x01(\r\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\"@\n\x0bMonitorBody\x12\x11\n\tdevice_id\x18\x01 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\x12\x10\n\x08msg_type\x18\x03 \x01(\r\",\n\x16MonitorDevicesResponse\x12\x12\n\ndevice_ids\x18\x01 \x03(\t\"9\n\x0bOtaFragment\x12\t\n\x01l\x18\x01 \x01(\x05\x12\t\n\x01\x64\x18\x02 \x01(\t\x12\t\n\x01t\x18\x03 \x01(\x05\x12\t\n\x01v\x18\x04 \x01(\t\"\xab\x02\n\tShootData\x12\x0f\n\x07shot_id\x18\x01 \x01(\t\x12\t\n\x01x\x18\x02 \x01(\x01\x12\t\n\x01y\x18\x03 \x01(\x01\x12\t\n\x01r\x18\x04 \x01(\x01\x12\t\n\x01\x64\x18\x05 \x01(\x01\x12\x0b\n\x03\x61\x64\x63\x18\x06 \x01(\x01\x12\x14\n\x0ctarget_class\x18\x07 \x01(\t\x12\x1f\n\x17target_class_confidence\x18\x08 \x01(\x01\x12\x0f\n\x07\x64_laser\x18\t \x01(\x01\x12\x17\n\x0f\x64_laser_quality\x18\n \x01(\x01\x12\t\n\x01m\x18\x0b \x01(\t\x12\x14\n\x0claser_method\x18\x0c \x01(\t\x12\x10\n\x08target_x\x18\r \x01(\x01\x12\x10\n\x08target_y\x18\x0e \x01(\x01\x12\x15\n\roffset_method\x18\x0f \x01(\t\x12\x17\n\x0f\x64istance_method\x18\x10 \x01(\t\"!\n\nShootEvent\x12\x13\n\x0bshoot_event\x18\x01 \x01(\t\"C\n\rBatteryReport\x12\x0f\n\x07\x62\x61ttery\x18\x01 \x01(\x01\x12\x0f\n\x07voltage\x18\x02 \x01(\x01\x12\x10\n\x08net_type\x18\x03 \x01(\t\"9\n\x11\x43\x65nterPointResult\x12\x0e\n\x06result\x18\x01 \x01(\t\x12\t\n\x01x\x18\x02 \x01(\x01\x12\t\n\x01y\x18\x03 \x01(\x01\"3\n\x0e\x43\x65nterPointSet\x12\x0b\n\x03\x63md\x18\x01 \x01(\r\x12\t\n\x01x\x18\x02 \x01(\x01\x12\t\n\x01y\x18\x03 \x01(\x01\"(\n\tOtaResult\x12\x0e\n\x06result\x18\x01 \x01(\t\x12\x0b\n\x03url\x18\x02 \x01(\t\"\x1f\n\rGenericResult\x12\x0e\n\x06result\x18\x01 \x01(\t\"&\n\x08IpReport\x12\x0e\n\x06result\x18\x01 \x01(\t\x12\n\n\x02ip\x18\x02 \x01(\t\"Z\n\x12ImageUploadCommand\x12\x12\n\nupload_url\x18\x01 \x01(\t\x12\r\n\x05token\x18\x02 \x01(\t\x12\x10\n\x08shoot_id\x18\x03 \x01(\t\x12\x0f\n\x07outlink\x18\x04 \x01(\t\"d\n\x10LogUploadCommand\x12\x12\n\nupload_url\x18\x01 \x01(\t\x12\r\n\x05token\x18\x02 \x01(\t\x12\x0b\n\x03key\x18\x03 \x01(\t\x12\x0f\n\x07outlink\x18\x04 \x01(\t\x12\x0f\n\x07\x61rchive\x18\x05 \x01(\t\"K\n\x0eOtaRequestData\x12\x0c\n\x04ssid\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\x12\x0b\n\x03url\x18\x03 \x01(\t\x12\x0c\n\x04mode\x18\x04 \x01(\t\"1\n\x0fWifiConnectData\x12\x0c\n\x04ssid\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\"_\n\x11ImageUploadResult\x12\x0e\n\x06result\x18\x01 \x01(\t\x12\x10\n\x08shoot_id\x18\x02 \x01(\t\x12\x0b\n\x03key\x18\x03 \x01(\t\x12\x0e\n\x06reason\x18\x04 \x01(\t\x12\x0b\n\x03via\x18\x05 \x01(\t\"v\n\x0fLogUploadResult\x12\x0e\n\x06result\x18\x01 \x01(\t\x12\x0e\n\x06reason\x18\x02 \x01(\t\x12\x10\n\x08\x66ilename\x18\x03 \x01(\t\x12\x13\n\x0bstatus_code\x18\x04 \x01(\x05\x12\x0c\n\x04ssid\x18\x05 \x01(\t\x12\x0e\n\x06\x64\x65tail\x18\x06 \x01(\t\"J\n\x14\x42\x61tteryQueryResponse\x12\x0f\n\x07\x62\x61ttery\x18\x01 \x01(\x01\x12\x0f\n\x07voltage\x18\x02 \x01(\x01\x12\x10\n\x08net_type\x18\x03 \x01(\t\"\'\n\x0fOta4gSubCodeReq\x12\t\n\x01l\x18\x01 \x01(\x05\x12\t\n\x01v\x18\x02 \x01(\t\"5\n\x10Ota4gSubCodeResp\x12\x0b\n\x03\x63md\x18\x01 \x01(\r\x12\t\n\x01l\x18\x02 \x01(\x05\x12\t\n\x01v\x18\x03 \x01(\t\"\x1e\n\x0fShutdownCommand\x12\x0b\n\x03\x63md\x18\x01 \x01(\r\" \n\x0c\x41utoShutdown\x12\x10\n\x08poweroff\x18\x01 \x01(\tBB\n\rcom.shoot.tcpZ1git.shelingxingqiu.com/shoot-tcp-server/proto;tcpb\x06proto3') + + + +_LOGINREQUEST = DESCRIPTOR.message_types_by_name['LoginRequest'] +_LOGINRESPONSE = DESCRIPTOR.message_types_by_name['LoginResponse'] +_HEARTBEAT = DESCRIPTOR.message_types_by_name['Heartbeat'] +_LOGICBODY = DESCRIPTOR.message_types_by_name['LogicBody'] +_RESPONSEBODY = DESCRIPTOR.message_types_by_name['ResponseBody'] +_MONITORBODY = DESCRIPTOR.message_types_by_name['MonitorBody'] +_MONITORDEVICESRESPONSE = DESCRIPTOR.message_types_by_name['MonitorDevicesResponse'] +_OTAFRAGMENT = DESCRIPTOR.message_types_by_name['OtaFragment'] +_SHOOTDATA = DESCRIPTOR.message_types_by_name['ShootData'] +_SHOOTEVENT = DESCRIPTOR.message_types_by_name['ShootEvent'] +_BATTERYREPORT = DESCRIPTOR.message_types_by_name['BatteryReport'] +_CENTERPOINTRESULT = DESCRIPTOR.message_types_by_name['CenterPointResult'] +_CENTERPOINTSET = DESCRIPTOR.message_types_by_name['CenterPointSet'] +_OTARESULT = DESCRIPTOR.message_types_by_name['OtaResult'] +_GENERICRESULT = DESCRIPTOR.message_types_by_name['GenericResult'] +_IPREPORT = DESCRIPTOR.message_types_by_name['IpReport'] +_IMAGEUPLOADCOMMAND = DESCRIPTOR.message_types_by_name['ImageUploadCommand'] +_LOGUPLOADCOMMAND = DESCRIPTOR.message_types_by_name['LogUploadCommand'] +_OTAREQUESTDATA = DESCRIPTOR.message_types_by_name['OtaRequestData'] +_WIFICONNECTDATA = DESCRIPTOR.message_types_by_name['WifiConnectData'] +_IMAGEUPLOADRESULT = DESCRIPTOR.message_types_by_name['ImageUploadResult'] +_LOGUPLOADRESULT = DESCRIPTOR.message_types_by_name['LogUploadResult'] +_BATTERYQUERYRESPONSE = DESCRIPTOR.message_types_by_name['BatteryQueryResponse'] +_OTA4GSUBCODEREQ = DESCRIPTOR.message_types_by_name['Ota4gSubCodeReq'] +_OTA4GSUBCODERESP = DESCRIPTOR.message_types_by_name['Ota4gSubCodeResp'] +_SHUTDOWNCOMMAND = DESCRIPTOR.message_types_by_name['ShutdownCommand'] +_AUTOSHUTDOWN = DESCRIPTOR.message_types_by_name['AutoShutdown'] +LoginRequest = _reflection.GeneratedProtocolMessageType('LoginRequest', (_message.Message,), { + 'DESCRIPTOR' : _LOGINREQUEST, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.LoginRequest) + }) +_sym_db.RegisterMessage(LoginRequest) + +LoginResponse = _reflection.GeneratedProtocolMessageType('LoginResponse', (_message.Message,), { + 'DESCRIPTOR' : _LOGINRESPONSE, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.LoginResponse) + }) +_sym_db.RegisterMessage(LoginResponse) + +Heartbeat = _reflection.GeneratedProtocolMessageType('Heartbeat', (_message.Message,), { + 'DESCRIPTOR' : _HEARTBEAT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.Heartbeat) + }) +_sym_db.RegisterMessage(Heartbeat) + +LogicBody = _reflection.GeneratedProtocolMessageType('LogicBody', (_message.Message,), { + 'DESCRIPTOR' : _LOGICBODY, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.LogicBody) + }) +_sym_db.RegisterMessage(LogicBody) + +ResponseBody = _reflection.GeneratedProtocolMessageType('ResponseBody', (_message.Message,), { + 'DESCRIPTOR' : _RESPONSEBODY, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.ResponseBody) + }) +_sym_db.RegisterMessage(ResponseBody) + +MonitorBody = _reflection.GeneratedProtocolMessageType('MonitorBody', (_message.Message,), { + 'DESCRIPTOR' : _MONITORBODY, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.MonitorBody) + }) +_sym_db.RegisterMessage(MonitorBody) + +MonitorDevicesResponse = _reflection.GeneratedProtocolMessageType('MonitorDevicesResponse', (_message.Message,), { + 'DESCRIPTOR' : _MONITORDEVICESRESPONSE, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.MonitorDevicesResponse) + }) +_sym_db.RegisterMessage(MonitorDevicesResponse) + +OtaFragment = _reflection.GeneratedProtocolMessageType('OtaFragment', (_message.Message,), { + 'DESCRIPTOR' : _OTAFRAGMENT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.OtaFragment) + }) +_sym_db.RegisterMessage(OtaFragment) + +ShootData = _reflection.GeneratedProtocolMessageType('ShootData', (_message.Message,), { + 'DESCRIPTOR' : _SHOOTDATA, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.ShootData) + }) +_sym_db.RegisterMessage(ShootData) + +ShootEvent = _reflection.GeneratedProtocolMessageType('ShootEvent', (_message.Message,), { + 'DESCRIPTOR' : _SHOOTEVENT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.ShootEvent) + }) +_sym_db.RegisterMessage(ShootEvent) + +BatteryReport = _reflection.GeneratedProtocolMessageType('BatteryReport', (_message.Message,), { + 'DESCRIPTOR' : _BATTERYREPORT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.BatteryReport) + }) +_sym_db.RegisterMessage(BatteryReport) + +CenterPointResult = _reflection.GeneratedProtocolMessageType('CenterPointResult', (_message.Message,), { + 'DESCRIPTOR' : _CENTERPOINTRESULT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.CenterPointResult) + }) +_sym_db.RegisterMessage(CenterPointResult) + +CenterPointSet = _reflection.GeneratedProtocolMessageType('CenterPointSet', (_message.Message,), { + 'DESCRIPTOR' : _CENTERPOINTSET, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.CenterPointSet) + }) +_sym_db.RegisterMessage(CenterPointSet) + +OtaResult = _reflection.GeneratedProtocolMessageType('OtaResult', (_message.Message,), { + 'DESCRIPTOR' : _OTARESULT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.OtaResult) + }) +_sym_db.RegisterMessage(OtaResult) + +GenericResult = _reflection.GeneratedProtocolMessageType('GenericResult', (_message.Message,), { + 'DESCRIPTOR' : _GENERICRESULT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.GenericResult) + }) +_sym_db.RegisterMessage(GenericResult) + +IpReport = _reflection.GeneratedProtocolMessageType('IpReport', (_message.Message,), { + 'DESCRIPTOR' : _IPREPORT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.IpReport) + }) +_sym_db.RegisterMessage(IpReport) + +ImageUploadCommand = _reflection.GeneratedProtocolMessageType('ImageUploadCommand', (_message.Message,), { + 'DESCRIPTOR' : _IMAGEUPLOADCOMMAND, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.ImageUploadCommand) + }) +_sym_db.RegisterMessage(ImageUploadCommand) + +LogUploadCommand = _reflection.GeneratedProtocolMessageType('LogUploadCommand', (_message.Message,), { + 'DESCRIPTOR' : _LOGUPLOADCOMMAND, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.LogUploadCommand) + }) +_sym_db.RegisterMessage(LogUploadCommand) + +OtaRequestData = _reflection.GeneratedProtocolMessageType('OtaRequestData', (_message.Message,), { + 'DESCRIPTOR' : _OTAREQUESTDATA, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.OtaRequestData) + }) +_sym_db.RegisterMessage(OtaRequestData) + +WifiConnectData = _reflection.GeneratedProtocolMessageType('WifiConnectData', (_message.Message,), { + 'DESCRIPTOR' : _WIFICONNECTDATA, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.WifiConnectData) + }) +_sym_db.RegisterMessage(WifiConnectData) + +ImageUploadResult = _reflection.GeneratedProtocolMessageType('ImageUploadResult', (_message.Message,), { + 'DESCRIPTOR' : _IMAGEUPLOADRESULT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.ImageUploadResult) + }) +_sym_db.RegisterMessage(ImageUploadResult) + +LogUploadResult = _reflection.GeneratedProtocolMessageType('LogUploadResult', (_message.Message,), { + 'DESCRIPTOR' : _LOGUPLOADRESULT, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.LogUploadResult) + }) +_sym_db.RegisterMessage(LogUploadResult) + +BatteryQueryResponse = _reflection.GeneratedProtocolMessageType('BatteryQueryResponse', (_message.Message,), { + 'DESCRIPTOR' : _BATTERYQUERYRESPONSE, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.BatteryQueryResponse) + }) +_sym_db.RegisterMessage(BatteryQueryResponse) + +Ota4gSubCodeReq = _reflection.GeneratedProtocolMessageType('Ota4gSubCodeReq', (_message.Message,), { + 'DESCRIPTOR' : _OTA4GSUBCODEREQ, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.Ota4gSubCodeReq) + }) +_sym_db.RegisterMessage(Ota4gSubCodeReq) + +Ota4gSubCodeResp = _reflection.GeneratedProtocolMessageType('Ota4gSubCodeResp', (_message.Message,), { + 'DESCRIPTOR' : _OTA4GSUBCODERESP, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.Ota4gSubCodeResp) + }) +_sym_db.RegisterMessage(Ota4gSubCodeResp) + +ShutdownCommand = _reflection.GeneratedProtocolMessageType('ShutdownCommand', (_message.Message,), { + 'DESCRIPTOR' : _SHUTDOWNCOMMAND, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.ShutdownCommand) + }) +_sym_db.RegisterMessage(ShutdownCommand) + +AutoShutdown = _reflection.GeneratedProtocolMessageType('AutoShutdown', (_message.Message,), { + 'DESCRIPTOR' : _AUTOSHUTDOWN, + '__module__' : 'tcp_messages_pb2' + # @@protoc_insertion_point(class_scope:tcp.AutoShutdown) + }) +_sym_db.RegisterMessage(AutoShutdown) + +if _descriptor._USE_C_DESCRIPTORS == False: + + DESCRIPTOR._options = None + DESCRIPTOR._serialized_options = b'\n\rcom.shoot.tcpZ1git.shelingxingqiu.com/shoot-tcp-server/proto;tcp' + _LOGINREQUEST._serialized_start=28 + _LOGINREQUEST._serialized_end=159 + _LOGINRESPONSE._serialized_start=161 + _LOGINRESPONSE._serialized_end=203 + _HEARTBEAT._serialized_start=205 + _HEARTBEAT._serialized_end=257 + _LOGICBODY._serialized_start=259 + _LOGICBODY._serialized_end=297 + _RESPONSEBODY._serialized_start=299 + _RESPONSEBODY._serialized_end=340 + _MONITORBODY._serialized_start=342 + _MONITORBODY._serialized_end=406 + _MONITORDEVICESRESPONSE._serialized_start=408 + _MONITORDEVICESRESPONSE._serialized_end=452 + _OTAFRAGMENT._serialized_start=454 + _OTAFRAGMENT._serialized_end=511 + _SHOOTDATA._serialized_start=514 + _SHOOTDATA._serialized_end=813 + _SHOOTEVENT._serialized_start=815 + _SHOOTEVENT._serialized_end=848 + _BATTERYREPORT._serialized_start=850 + _BATTERYREPORT._serialized_end=917 + _CENTERPOINTRESULT._serialized_start=919 + _CENTERPOINTRESULT._serialized_end=976 + _CENTERPOINTSET._serialized_start=978 + _CENTERPOINTSET._serialized_end=1029 + _OTARESULT._serialized_start=1031 + _OTARESULT._serialized_end=1071 + _GENERICRESULT._serialized_start=1073 + _GENERICRESULT._serialized_end=1104 + _IPREPORT._serialized_start=1106 + _IPREPORT._serialized_end=1144 + _IMAGEUPLOADCOMMAND._serialized_start=1146 + _IMAGEUPLOADCOMMAND._serialized_end=1236 + _LOGUPLOADCOMMAND._serialized_start=1238 + _LOGUPLOADCOMMAND._serialized_end=1338 + _OTAREQUESTDATA._serialized_start=1340 + _OTAREQUESTDATA._serialized_end=1415 + _WIFICONNECTDATA._serialized_start=1417 + _WIFICONNECTDATA._serialized_end=1466 + _IMAGEUPLOADRESULT._serialized_start=1468 + _IMAGEUPLOADRESULT._serialized_end=1563 + _LOGUPLOADRESULT._serialized_start=1565 + _LOGUPLOADRESULT._serialized_end=1683 + _BATTERYQUERYRESPONSE._serialized_start=1685 + _BATTERYQUERYRESPONSE._serialized_end=1759 + _OTA4GSUBCODEREQ._serialized_start=1761 + _OTA4GSUBCODEREQ._serialized_end=1800 + _OTA4GSUBCODERESP._serialized_start=1802 + _OTA4GSUBCODERESP._serialized_end=1855 + _SHUTDOWNCOMMAND._serialized_start=1857 + _SHUTDOWNCOMMAND._serialized_end=1887 + _AUTOSHUTDOWN._serialized_start=1889 + _AUTOSHUTDOWN._serialized_end=1921 +# @@protoc_insertion_point(module_scope)