diff --git a/service/friend.go b/service/friend.go
index 948cbbb..0a40f95 100644
--- a/service/friend.go
+++ b/service/friend.go
@@ -82,7 +82,7 @@ func GetAllEnableNews() (records []entity.Friend, err error) {
 // @return records
 // @return err
 func GetAllEnableClearGroup() (records []entity.Friend, err error) {
-	err = client.MySQL.Where("clear_members != 0").Where("is_ok IS TRUE").Find(&records).Error
+	err = client.MySQL.Where("clear_member > 0").Where("is_ok IS TRUE").Find(&records).Error
 	return
 }
 
diff --git a/tasks/cleargroupuser/cleargroupuser.go b/tasks/cleargroupuser/cleargroupuser.go
index c236b4c..0d92de8 100644
--- a/tasks/cleargroupuser/cleargroupuser.go
+++ b/tasks/cleargroupuser/cleargroupuser.go
@@ -13,7 +13,7 @@ import (
 // ClearGroupUser
 // @description: 清理群成员
 func ClearGroupUser() {
-	groups, err := service.GetAllEnableNews()
+	groups, err := service.GetAllEnableClearGroup()
 	if err != nil {
 		log.Printf("获取启用了聊天排行榜的群组失败, 错误信息: %v", err)
 		return
@@ -42,9 +42,9 @@ func ClearGroupUser() {
 		// 发送通知到群里
 		ms := make([]string, 0)
 		for k, v := range memberMap {
-			ms = append(ms, fmt.Sprintf("%s: %s", k, v))
+			ms = append(ms, fmt.Sprintf("昵称：%s\n最后活跃时间：%s", k, v))
 		}
-		msg := fmt.Sprintf("#清理群成员#\n\n很遗憾地通知各位，就在刚刚，有%d名群友引活跃度不够暂时离开了我们，希望还健在的群友引以为戒、保持活跃！\n\n活跃信息: \n%s",
+		msg := fmt.Sprintf("#清理群成员\n\n很遗憾地通知各位，就在刚刚，有%d名群友引活跃度不够暂时离开了我们，希望还健在的群友引以为戒、保持活跃！\n\n活跃信息: \n%s",
 			memberCount, strings.Join(ms, "\n"))
 		utils.SendMessage(group.Wxid, "", msg, 0)
 	}