package com.yeshi.fanli.service.impl.msg;

import java.util.Date;
import java.util.List;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;

import com.yeshi.fanli.dao.mybatis.msg.MsgAccountDetailMapper;
import com.yeshi.fanli.entity.bus.msg.MsgAccountDetail;
import com.yeshi.fanli.exception.msg.MsgAccountDetailException;
import com.yeshi.fanli.service.inter.msg.MsgAccountDetailService;
import com.yeshi.fanli.service.inter.msg.UserMsgReadStateService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;

@Service
public class MsgAccountDetailServiceImpl implements MsgAccountDetailService {

	@Resource
	private MsgAccountDetailMapper msgAccountDetailMapper;

	@Resource
	private UserMsgReadStateService userMsgReadStateService;

	@Override
	public void addMsgAccountDetail(MsgAccountDetail detail) throws MsgAccountDetailException {
		if (detail == null)
			throw new MsgAccountDetailException(1, "消息为空");
		if (StringUtil.isNullOrEmpty(detail.getTitle()) || StringUtil.isNullOrEmpty(detail.getContent())
				|| detail.getType() == null || detail.getUser() == null)
			throw new MsgAccountDetailException(2, "消息内容不完整");
		// 持久化到数据库
		detail.setCreateTime(new Date());
		detail.setUpdateTime(new Date());
		detail.setRead(false);
		msgAccountDetailMapper.insertSelective(detail);
		userMsgReadStateService.addAccountMsgUnReadCount(detail.getUser().getId(), 1);
	}

	@Override
	public List<MsgAccountDetail> listMsgAccountDetail(Long uid, int page) {
		return msgAccountDetailMapper.listByUid(uid, (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE);
	}

	@Override
	public long countMsgAccountDetail(Long uid) {
		return msgAccountDetailMapper.countByUid(uid);
	}

	@Override
	public void readMsgByUid(Long uid) {
		msgAccountDetailMapper.setMsgReadByUid(uid);
	}

}