...
|
...
|
@@ -89,8 +89,8 @@ public class GrassUserVirtualImpl implements IGrassVirtualService{ |
|
|
//没有标记位,直接处理
|
|
|
if(sendTime == null){
|
|
|
platformRedis.setValue(MESSAGE_SENDING_FLAG, DateUtil.getCurrentTimeSeconds(), 600);
|
|
|
List<GrassInBoxAddReq> l = new ArrayList<>();
|
|
|
for (GrassInBoxAddReq message : messageList) {
|
|
|
List<GrassInBoxAddReq> l = new ArrayList<>();
|
|
|
l.add(message);
|
|
|
if (l.size() % 1000 == 0) {
|
|
|
sendMessage(l);
|
...
|
...
|
@@ -101,9 +101,9 @@ public class GrassUserVirtualImpl implements IGrassVirtualService{ |
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
if (CollectionUtils.isNotEmpty(l)) {
|
|
|
sendMessage(l);
|
|
|
}
|
|
|
}
|
|
|
if (CollectionUtils.isNotEmpty(l)) {
|
|
|
sendMessage(l);
|
|
|
}
|
|
|
platformRedis.delete(MESSAGE_SENDING_FLAG);
|
|
|
platformRedis.delete(MESSAGE_KEY);
|
...
|
...
|
|