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;
	}
}