diff --git a/src/Services/Masa.Mc.Service/Application/ChannelStatistics/ChannelStatisticsQueryHandler.cs b/src/Services/Masa.Mc.Service/Application/ChannelStatistics/ChannelStatisticsQueryHandler.cs
index 54d8f427..f66af931 100644
--- a/src/Services/Masa.Mc.Service/Application/ChannelStatistics/ChannelStatisticsQueryHandler.cs
+++ b/src/Services/Masa.Mc.Service/Application/ChannelStatistics/ChannelStatisticsQueryHandler.cs
@@ -33,8 +33,8 @@ public async Task GetAppVendorSendStatisticsAsync(GetAppVendorSendStatisticsQuer
 
         var grouped = await (from record in records
                              join receiver in receiverUsers
-                                 on new { record.MessageTaskHistoryId, record.ChannelUserIdentity }
-                                 equals new { receiver.MessageTaskHistoryId, receiver.ChannelUserIdentity } into receiverGroup
+                                 on new { record.MessageTaskHistoryId, record.ChannelUserIdentity, record.UserId }
+                                 equals new { receiver.MessageTaskHistoryId, receiver.ChannelUserIdentity, receiver.UserId } into receiverGroup
                              from receiver in receiverGroup.DefaultIfEmpty()
                              select new
                              {
@@ -250,8 +250,8 @@ private IQueryable<MessageRecordQueryModel> ApplyVendorFilter(IQueryable<Message
 
         return from record in records
                join receiver in receiverUsers
-                   on new { record.MessageTaskHistoryId, record.ChannelUserIdentity }
-                   equals new { receiver.MessageTaskHistoryId, receiver.ChannelUserIdentity }
+                   on new { record.MessageTaskHistoryId, record.ChannelUserIdentity, record.UserId }
+                   equals new { receiver.MessageTaskHistoryId, receiver.ChannelUserIdentity, receiver.UserId }
                select record;
     }