package org.springblade.modules.messageRecord.service.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springblade.core.tool.utils.DateUtil;
|
import org.springblade.modules.messageRecord.entity.MessageUser;
|
import org.springblade.modules.messageRecord.mapper.MessageUserMapper;
|
import org.springblade.modules.messageRecord.service.IMessageUserService;
|
import org.springblade.modules.messageRecord.vo.MessageUserVO;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
|
@Service
|
public class MessageUserServiceImpl extends ServiceImpl<MessageUserMapper, MessageUser> implements IMessageUserService {
|
@Override
|
public IPage<MessageUserVO> getPage(IPage<MessageUserVO> page, MessageUserVO messageUserVO) {
|
return page.setRecords(baseMapper.getPage(page, messageUserVO));
|
}
|
|
@Override
|
public Boolean updateIsReadStatus(String ids, String isRead) {
|
|
List<MessageUser> messageUserList = baseMapper.selectBatchIds(Arrays.asList(ids));
|
|
messageUserList.forEach(messageUser ->{
|
messageUser.setUpdateTime(DateUtil.now());
|
messageUser.setIsRead(isRead);
|
});
|
|
boolean b = updateBatchById(messageUserList);
|
return b;
|
}
|
|
@Override
|
public IPage<MessageUserVO> getMessagePage(IPage<MessageUserVO> page, MessageUserVO messageUserVO) {
|
List<MessageUserVO> list = new ArrayList<>();
|
|
if (messageUserVO.getMessageType().equals("send")){
|
//我发送的
|
list = baseMapper.getMySendMessage(page,messageUserVO);
|
|
}else if (messageUserVO.getMessageType().equals("receive")){
|
//我收到的
|
list = baseMapper.getMyReceiveMessage(page,messageUserVO);
|
}
|
page.setRecords(list);
|
return page;
|
}
|
}
|
