From acf384f3d6653f4696446b113177140f491c4e38 Mon Sep 17 00:00:00 2001
From: gongshangguo <gongshangguo@admin.com>
Date: 星期二, 12 四月 2022 09:58:10 +0800
Subject: [PATCH] 更新aiot

---
 aiotProto/aiot/aiot_business.proto |  119 ++++++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 109 insertions(+), 10 deletions(-)

diff --git a/aiotProto/aiot/aiot_business.proto b/aiotProto/aiot/aiot_business.proto
index 94d80be..2b6f0f1 100644
--- a/aiotProto/aiot/aiot_business.proto
+++ b/aiotProto/aiot/aiot_business.proto
@@ -4,30 +4,129 @@
 
 import "aiot_common.proto";
 
+// 璇锋眰绫诲瀷
 enum RequestType{
-    Async = 0;
-    sync = 1;
+    // 鍚屾璇锋眰 榛樿
+    sync = 0;
+    // 寮傛璇锋眰
+    Async = 1;
+}
+
+// 璇锋眰鏂瑰紡
+enum RequestMethod{
+    // 榛樿
+    MethodDefault = 0;
+    // post璇锋眰
+    Post = 1;
+    // get璇锋眰
+    Get = 2;
+    // put璇锋眰
+    Put = 3;
+    // delete璇锋眰
+    Delete = 4;
+}
+
+// 璇锋眰header
+enum RequestContentType{
+    ContentTypeDefault = 0;
+    ApplicationJson = 1;
+    ApplicationXWwwFormUrlencoded = 2;
+    MultipartFormData = 3;
+    ApplicationXml = 4;
 }
 
 // 璇锋眰鐨刡ody浣�
-message BusinessReq {
+message NodeReq {
+    // 璇锋眰鐨則opic url
     string topic = 1;
-    string authorization = 2;
-    string ip = 3;
-    string port = 4;
-    RequestType type = 5;
-    bytes req = 6;
+    // 鑺傜偣ID
+    string nodeId = 2;
+    // token
+    string authorization = 3;
+    // 璇锋眰鎸囧悜鐨刬p
+    string ip = 4;
+    // 璇锋眰鐨勭鍙� 淇濈暀瀛楁
+    string port = 5;
+    // 璇锋眰鐨勫悓姝�/寮傛绫诲瀷
+    RequestType syncType = 6;
+    // method
+    RequestMethod method = 7;
+    // content-type
+    RequestContentType contentType = 8;
+    // 璇锋眰涓氬姟鍙傛暟
+    bytes req = 9;
+}
+
+// 闆嗙兢璇锋眰鍙傛暟
+message ClusterReq{
+    // 璇锋眰鐨則opic url
+    string topic = 1;
+    // 闆嗙兢ID
+    string clusterId = 2;
+    // token
+    string authorization = 3;
+    // 璇锋眰鐨勫悓姝�/寮傛绫诲瀷
+    RequestType syncType = 4;
+    // method
+    RequestMethod method = 5;
+    // content-type
+    RequestContentType contentType = 6;
+    // 璇锋眰涓氬姟鍙傛暟
+    bytes req = 7;
+}
+
+// 璁惧鍒楄〃璇锋眰鍙傛暟
+message NodesReq{
+    // 璇锋眰鐨則opic url
+    string topic = 1;
+    // 璁惧鍒楄〃ID
+    repeated string nodeIds = 2;
+    // token
+    string authorization = 3;
+    // 璇锋眰鐨勫悓姝�/寮傛绫诲瀷
+    RequestType syncType = 4;
+    // method
+    RequestMethod method = 5;
+    // content-type
+    RequestContentType contentType = 6;
+    // 璇锋眰涓氬姟鍙傛暟
+    bytes req = 7;
+}
+
+// 璇锋眰鍒皊aas
+message SaasReq {
+    // 璇锋眰鐨則opic url
+    string rpcAddr = 1;
+    // rpc妯″潡鍚�
+    string rpcNode = 2;
+    // token
+    string authorization = 3;
+    // 璇锋眰鐨勫悓姝�/寮傛绫诲瀷
+    RequestType syncType = 4;
+    // 璇锋眰涓氬姟鍙傛暟
+    bytes req = 5;
 }
 
 // 鍝嶅簲鐨刡ody浣�
 message BusinessReply {
+    // 杩斿洖鐨勯敊璇爜
     int32 code = 1;
+    // 閿欒淇℃伅
     string msg = 2;
+    // 鏄惁success
     bool success = 3;
+    // 杩斿洖缁撴灉
     bytes data = 4;
 }
 
+// 鏈嶅姟
 service AiotService {
-    rpc GetBusiness(BusinessReq) returns (BusinessReply){}
-    rpc SendAiotReq(Protocol) returns (Protocol){}
+    // 鍙戦�佹寚鍚戝崟涓澶囩殑璇锋眰
+    rpc SendToNode(NodeReq) returns (BusinessReply){}
+    // 鐩存帴鍙戦�佸悓姝cp璇锋眰
+    rpc SendAiotSyncReq(Protocol) returns (BusinessReply){}
+    // 鍙戦�佺兢缁勮姹�
+    rpc SendToCluster(ClusterReq) returns (BusinessReply){}
+    // 鍚戝涓澶囧悓鏃跺彂璧风浉鍚屽弬鏁拌姹�
+    rpc SendToNodes(NodesReq) returns (BusinessReply) {}
 }

--
Gitblit v1.8.0