package cn.iocoder.yudao.module.bpm.dal.mysql.oa;

import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.bpm.dal.dataobject.oa.OaNoticeReadDO;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

@Mapper
public interface OaNoticeReadMapper extends BaseMapperX<OaNoticeReadDO> {

    default OaNoticeReadDO selectByNoticeIdAndUserId(Long noticeId, Long userId) {
        return selectOne(new LambdaQueryWrapperX<OaNoticeReadDO>()
                .eq(OaNoticeReadDO::getNoticeId, noticeId)
                .eq(OaNoticeReadDO::getUserId, userId));
    }

    default List<OaNoticeReadDO> selectListByNoticeId(Long noticeId) {
        return selectList(new LambdaQueryWrapperX<OaNoticeReadDO>()
                .eq(OaNoticeReadDO::getNoticeId, noticeId));
    }

    default Long selectCountByNoticeId(Long noticeId) {
        return selectCount(new LambdaQueryWrapperX<OaNoticeReadDO>()
                .eq(OaNoticeReadDO::getNoticeId, noticeId));
    }

    default Long selectUnreadCountByUserId(Long userId, List<Long> noticeIds) {
        if (noticeIds == null || noticeIds.isEmpty()) {
            return 0L;
        }
        // 总公告数 - 已读数 = 未读数
        return (long) noticeIds.size() - selectCount(new LambdaQueryWrapperX<OaNoticeReadDO>()
                .in(OaNoticeReadDO::getNoticeId, noticeIds)
                .eq(OaNoticeReadDO::getUserId, userId));
    }

}