更新aiot

gongshangguo

2022-04-12 acf384f3d6653f4696446b113177140f491c4e38

 aiotProto/aiot/aiot_business.proto

@@ -12,44 +12,99 @@
    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;
}

// 请求的body体
message NodeReq {
    // 请求的topic url
    string topic = 1;
    // 节点ID
    string nodeId = 2;
    // token
    string authorization = 2;
    string authorization = 3;
    // 请求指向的ip
    string ip = 3;
    string ip = 4;
    // 请求的端口 保留字段
    string port = 4;
    string port = 5;
    // 请求的同步/异步类型
    RequestType syncType = 5;
    RequestType syncType = 6;
    // method
    RequestMethod method = 7;
    // content-type
    RequestContentType contentType = 8;
    // 请求业务参数
    bytes req = 6;
    bytes req = 9;
}

// 集群请求参数
message ClusterReq{
    // 请求的topic url
    string topic = 1;
    // 集群ID
    string ClusterId = 1;
    string clusterId = 2;
    // token
    string authorization = 2;
    string authorization = 3;
    // 请求的同步/异步类型
    RequestType syncType = 3;
    RequestType syncType = 4;
    // method
    RequestMethod method = 5;
    // content-type
    RequestContentType contentType = 6;
    // 请求业务参数
    bytes req = 4;
    bytes req = 7;
}

// 设备列表请求参数
message NodesReq{
    // 请求的topic url
    string topic = 1;
    // 设备列表ID
    repeated string NodeIds = 1;
    repeated string nodeIds = 2;
    // token
    string authorization = 2;
    string authorization = 3;
    // 请求的同步/异步类型
    RequestType syncType = 3;
    RequestType syncType = 4;
    // method
    RequestMethod method = 5;
    // content-type
    RequestContentType contentType = 6;
    // 请求业务参数
    bytes req = 4;
    bytes req = 7;
}

// 请求到saas
message SaasReq {
    // 请求的topic url
    string rpcAddr = 1;
    // rpc模块名
    string rpcNode = 2;
    // token
    string authorization = 3;
    // 请求的同步/异步类型
    RequestType syncType = 4;
    // 请求业务参数
    bytes req = 5;
}

// 响应的body体
@@ -68,8 +123,8 @@
service AiotService {
    // 发送指向单个设备的请求
    rpc SendToNode(NodeReq) returns (BusinessReply){}
    // 直接发送tcp请求
    rpc SendAiotReq(Protocol) returns (Protocol){}
    // 直接发送同步tcp请求
    rpc SendAiotSyncReq(Protocol) returns (BusinessReply){}
    // 发送群组请求
    rpc SendToCluster(ClusterReq) returns (BusinessReply){}
    // 向多个设备同时发起相同参数请求