REQ-3345: 同步消息
This commit is contained in:
parent
5d52e9639d
commit
d4920cb062
@ -42,7 +42,9 @@ class GroupMessageSyncer implements Runnable {
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
Long beginMs = service.getMaxSendTime(group.getTid()).orElse(oneAgo()).getTime();
|
||||
Long beginMs = service.getMaxSendTime(group.getTid())
|
||||
.orElse(oneAndHalfDayAgo())
|
||||
.getTime();
|
||||
Long endMs = System.currentTimeMillis();
|
||||
Timeline timeline = new Timeline(beginMs, endMs);
|
||||
// don't change
|
||||
@ -121,7 +123,7 @@ class GroupMessageSyncer implements Runnable {
|
||||
}
|
||||
}
|
||||
|
||||
private Date oneAgo() {
|
||||
return DateTime.now().minusDays(1).toDate();
|
||||
private Date oneAndHalfDayAgo() {
|
||||
return DateTime.now().minusDays(1).minusHours(12).toDate();
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user