...
|
...
|
@@ -89,11 +89,12 @@ public class GrassUserVirtualImpl implements IGrassVirtualService{ |
|
|
|
|
|
//没有标记位,直接处理
|
|
|
if(sendTime == null){
|
|
|
int batchSize = configReader.getInt("platform.grass.autoPraiseMessage.batchSize" , 500);
|
|
|
platformRedis.setValue(MESSAGE_SENDING_FLAG, DateUtil.getCurrentTimeSeconds(), 600);
|
|
|
List<GrassInBoxAddReq> l = new ArrayList<>();
|
|
|
for (GrassInBoxAddReq message : messageList) {
|
|
|
l.add(message);
|
|
|
if (l.size() % 1000 == 0) {
|
|
|
if (l.size() % batchSize == 0) {
|
|
|
sendMessage(l);
|
|
|
l.clear();
|
|
|
try {
|
...
|
...
|
|