实现发送消息到媒介

pkg/rpc/protos/models/message_receiver.proto

@@ -0,0 +1,18 @@
+syntax = "proto3";
+option go_package = "./pb";
+
+package pb;
+
+import "models/message_recipient.proto";
+import "models/message_recipient_group.proto";
+
+message MessageReceiver {
+	int64 id = 1;
+	int64 clusterId = 2;
+	int64 nodeId = 3;
+	int64 serverId = 4;
+	string type = 5;
+	bytes paramsJSON = 6;
+	MessageRecipient messageRecipient = 7;
+	MessageRecipientGroup messageRecipientGroup = 8;
+}

pkg/rpc/protos/service_message_receiver.proto

@@ -0,0 +1,53 @@
+syntax = "proto3";
+option go_package = "./pb";
+
+package pb;
+
+import "models/message_receiver.proto";
+import "models/rpc_messages.proto";
+
+// 消息对象接收者设置
+service MessageReceiverService {
+	// 修改接收者
+	rpc updateMessageReceivers (UpdateMessageReceiversRequest) returns (RPCSuccess);
+
+	// 查找接收者
+	rpc findAllMessageReceivers (FindAllMessageReceiversRequest) returns (FindAllMessageReceiversResponse);
+
+	// 删除接收者
+	rpc deleteMessageReceiver (DeleteMessageReceiverRequest) returns (RPCSuccess);
+}
+
+// 修改接收者
+message UpdateMessageReceiversRequest {
+	int64 nodeClusterId = 1;
+	int64 nodeId = 2;
+	int64 serverId = 3;
+	bytes paramsJSON = 5;
+	map<string, RecipientOptions> recipientOptions = 6; // type => options
+
+	message RecipientOption {
+		int64 messageRecipientId = 1;
+		int64 messageRecipientGroupId = 2;
+	}
+
+	message RecipientOptions {
+		repeated RecipientOption recipientOptions = 1;
+	}
+}
+
+// 查找接收者
+message FindAllMessageReceiversRequest {
+	int64 nodeClusterId = 1;
+	int64 nodeId = 2;
+	int64 serverId = 3;
+}
+
+message FindAllMessageReceiversResponse {
+	repeated MessageReceiver messageReceivers = 1;
+}
+
+// 删除接收者
+message DeleteMessageReceiverRequest {
+	int64 messageReceiverId = 1;
+}

pkg/rpc/protos/service_message_recipient.proto

@@ -30,8 +30,8 @@ service MessageRecipientService {
 // 创建接收人
 message CreateMessageRecipientRequest {
 	int64 adminId = 1;
-	int64 instanceId = 2;
-	repeated int64 groupIds = 3;
+	int64 messageMediaInstanceId = 2;
+	repeated int64 messageRecipientGroupIds = 3;
 	string description = 4;
 	string user = 5;
 }
@@ -44,8 +44,8 @@ message CreateMessageRecipientResponse {
 message UpdateMessageRecipientRequest {
 	int64 messageRecipientId = 1;
 	int64 adminId = 2;
-	int64 instanceId = 3;
-	repeated int64 groupIds = 4;
+	int64 messageMediaInstanceId = 3;
+	repeated int64 messageRecipientGroupIds = 4;
 	string description = 5;
 	bool isOn = 6;
 	string user = 7;
@@ -60,7 +60,7 @@ message DeleteMessageRecipientRequest {
 message CountAllEnabledMessageRecipientsRequest {
 	int64 adminId = 1;
 	string mediaType = 2;
-	int64 groupId = 3;
+	int64 messageRecipientGroupId = 3;
 	string keyword = 4;
 }
 
@@ -68,7 +68,7 @@ message CountAllEnabledMessageRecipientsRequest {
 message ListEnabledMessageRecipientsRequest {
 	int64 adminId = 1;
 	string mediaType = 2;
-	int64 groupId = 3;
+	int64 messageRecipientGroupId = 3;
 	string keyword = 4;
 	int64 offset = 5;
 	int64 size = 6;