From 8884d2ca43d30a1a6d5e211cc57182a490957e96 Mon Sep 17 00:00:00 2001 From: fanxb Date: Sun, 17 May 2020 15:59:34 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8Dredis=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E6=B6=88=E8=B4=B9=E9=94=99=E8=AF=AFbug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../business/bookmark/consumer/PinyinUpdateConsumer.java | 4 ++-- .../business/bookmark/service/impl/PinYinServiceImpl.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/consumer/PinyinUpdateConsumer.java b/bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/consumer/PinyinUpdateConsumer.java index a42f22a..442709a 100644 --- a/bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/consumer/PinyinUpdateConsumer.java +++ b/bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/consumer/PinyinUpdateConsumer.java @@ -39,7 +39,7 @@ public class PinyinUpdateConsumer implements RedisConsumer { for (int i = 0, size = bookmarks.size(); i < size; i++) { bookmarkDao.updateSearchKey(bookmarks.get(i).getBookmarkId(), resList.get(i)); } - //更新本用户书签更新时间 - RedisUtil.addToMq(RedisConstant.BOOKMARK_UPDATE_VERSION, new UserBookmarkUpdate(bookmarks.get(0).getUserId())); + //更新本用户书签更新版本 + RedisUtil.addToMq(RedisConstant.BOOKMARK_UPDATE_VERSION, bookmarks.get(0).getUserId()); } } diff --git a/bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/service/impl/PinYinServiceImpl.java b/bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/service/impl/PinYinServiceImpl.java index 6e461f0..959141c 100644 --- a/bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/service/impl/PinYinServiceImpl.java +++ b/bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/service/impl/PinYinServiceImpl.java @@ -61,7 +61,7 @@ public class PinYinServiceImpl implements PinYinService { i = bookmarks.get(SIZE - 1).getBookmarkId(); } //更新所有用户的上次刷新时间 - RedisUtil.addToMq(RedisConstant.BOOKMARK_UPDATE_VERSION, new UserBookmarkUpdate(-1, System.currentTimeMillis())); + RedisUtil.addToMq(RedisConstant.BOOKMARK_UPDATE_VERSION, -1); } @Override