diff --git a/src/main/java/com/upchina/group/service/common/GroupCacheService.java b/src/main/java/com/upchina/group/service/common/GroupCacheService.java
index 0af43d7..f7cf1b5 100644
--- a/src/main/java/com/upchina/group/service/common/GroupCacheService.java
+++ b/src/main/java/com/upchina/group/service/common/GroupCacheService.java
@@ -76,7 +76,7 @@ public class GroupCacheService {
         Integer isRecommend = message.getIsRecommend();
         if (GroupInteractiveType.GROUP.value.equals(interactiveType)) {
             removeMessage(groupId, null, QueryGroupMessageType.ALL, messageId);
-            if (GroupMessageUserType.ADVISOR.value.equals(userType)) {
+            if (GroupMessageUserType.ADVISOR.value.equals(userType) || GroupMessageUserType.ASSISTANT.value.equals(userType)) {
                 removeMessage(groupId, null, QueryGroupMessageType.ADVISOR, messageId);
             } else if (GroupMessageUserType.CUSTOMER.value.equals(userType)) {
                 removeMessage(groupId, null, QueryGroupMessageType.CUSTOMER, messageId);
@@ -105,7 +105,7 @@ public class GroupCacheService {
         Integer isRecommend = message.getIsRecommend();
         if (GroupInteractiveType.GROUP.value.equals(interactiveType)) {
             addMessage(groupId, null, QueryGroupMessageType.ALL, messageId);
-            if (GroupMessageUserType.ADVISOR.value.equals(userType)) {
+            if (GroupMessageUserType.ADVISOR.value.equals(userType) || GroupMessageUserType.ASSISTANT.value.equals(userType)) {
                 addMessage(groupId, null, QueryGroupMessageType.ADVISOR, messageId);
             } else if (GroupMessageUserType.CUSTOMER.value.equals(userType)) {
                 addMessage(groupId, null, QueryGroupMessageType.CUSTOMER, messageId);