Authored by liangyi.chen@yoho.cn

Fix

@@ -871,6 +871,7 @@ public class GrassArticleServiceImpl implements IGrassArticleService { @@ -871,6 +871,7 @@ public class GrassArticleServiceImpl implements IGrassArticleService {
871 List<Integer> limitSendUids = uidList.stream().filter(uid -> !specAtUids.contains(uid)).collect(Collectors.toList()); 871 List<Integer> limitSendUids = uidList.stream().filter(uid -> !specAtUids.contains(uid)).collect(Collectors.toList());
872 List<Integer> needSendList = new ArrayList<>(); 872 List<Integer> needSendList = new ArrayList<>();
873 if(CollectionUtils.isNotEmpty(limitSendUids)){ 873 if(CollectionUtils.isNotEmpty(limitSendUids)){
  874 + uidList.removeAll(limitSendUids);
874 //@用户次数限制 875 //@用户次数限制
875 int atThreshold = configReader.getInt("platform.grass.atUser.threshold", 0); 876 int atThreshold = configReader.getInt("platform.grass.atUser.threshold", 0);
876 877
@@ -908,8 +909,9 @@ public class GrassArticleServiceImpl implements IGrassArticleService { @@ -908,8 +909,9 @@ public class GrassArticleServiceImpl implements IGrassArticleService {
908 redis.longExpire(atInboxIntelTimesCacheKey, 24, TimeUnit.HOURS); 909 redis.longExpire(atInboxIntelTimesCacheKey, 24, TimeUnit.HOURS);
909 logger.info("The specUser {} has send Inbox times is {}" , specUid , inboxIntelTimes); 910 logger.info("The specUser {} has send Inbox times is {}" , specUid , inboxIntelTimes);
910 }); 911 });
911 - uidList.removeAll(needSendList);  
912 - sendBatchInbox(addReqList); 912 + if(addReqList.size() > 0){
  913 + sendBatchInbox(addReqList);
  914 + }
913 915
914 } 916 }
915 } 917 }