查询消息列表即更新未读状态
This commit is contained in:
@@ -1,5 +1,6 @@
|
||||
package com.czg.service.account.service.impl;
|
||||
|
||||
import cn.hutool.core.thread.ThreadUtil;
|
||||
import com.czg.account.dto.AcUserMsgDTO;
|
||||
import com.czg.account.entity.AcUserMsg;
|
||||
import com.czg.account.service.AcUserMsgService;
|
||||
@@ -34,8 +35,19 @@ public class AcUserMsgServiceImpl extends ServiceImpl<AcUserMsgMapper, AcUserMsg
|
||||
|
||||
@Override
|
||||
public Page<AcUserMsgDTO> getUserMsgPage() {
|
||||
long userId = StpKit.USER.getLoginIdAsLong();
|
||||
ThreadUtil.execAsync(() -> {
|
||||
// AcUserMsg msg = new AcUserMsg();
|
||||
// msg.setReadStatus(1);
|
||||
// update(msg, QueryWrapper.create().eq(AcUserMsg::getUserId, userId).eq(AcUserMsg::getReadStatus, 0));
|
||||
//
|
||||
updateChain().set(AcUserMsg::getReadStatus, 1)
|
||||
.eq(AcUserMsg::getUserId, userId)
|
||||
.eq(AcUserMsg::getReadStatus, 0)
|
||||
.update();
|
||||
});
|
||||
return pageAs(PageUtil.buildPage(), QueryWrapper.create().eq(AcUserMsg::getUserId,
|
||||
StpKit.USER.getLoginIdAsLong()).orderBy(AcUserMsg::getCreateTime, false), AcUserMsgDTO.class);
|
||||
userId).orderBy(AcUserMsg::getCreateTime, false), AcUserMsgDTO.class);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user