Yuebon.Messages/Yuebon.Messages.Core/Repositories/MemberMessageBoxRepository.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using Yuebon.Commons.Core.UnitOfWork;
using Yuebon.Commons.Repositories;
using Yuebon.Messages.IRepositories;
using Yuebon.Messages.Models;

namespace Yuebon.Messages.Repositories
{
    /// <summary>
    /// 仓储接口的实现
    /// </summary>
    public class MemberMessageBoxRepository : BaseRepository<MemberMessageBox>, IMemberMessageBoxRepository
    {

        public MemberMessageBoxRepository(IUnitOfWork unitOfWork) : base(unitOfWork)
        {
            this.tableName = "Sys_MemberMessageBox";
            this.primaryKey = "Id";
        }

        /// <summary>
        /// 更新已读状态
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public bool UpdateIsReadStatus(string id, int isread, string userid)
        {
            string strwhere = " Accepter='" + userid + "' ";
            if (!string.IsNullOrEmpty(id))
            {
                strwhere += " and Id='" + id + "' ";
            }

            string sql = @"update Sys_MemberMessageBox set IsRead=" + isread +
                ", ReadDate='" + DateTime.Now.ToShortDateString() + "' ";
            if (strwhere != "")
            {
                sql += sql + " where " + strwhere;
            }

            return Db.Ado.ExecuteCommand(sql) > 0 ? true : false;

        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="isread">2:全部，0：未读，1：已读</param>
        /// <param name="userid"></param>
        /// <returns></returns>
        public int GetTotalCounts(int isread, string userid)
        {
            string strwhere = " Accepter='" + userid + "' ";
            if (isread != 2)
            {
                strwhere += " and IsRead=" + isread;
            }

            string sql = @"select * from Sys_MemberMessageBox ";