IA.Service/MessagePushService.cs

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

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

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Transactions;
using IA.Core.Context;
using IA.Core.Domain;
using IA.Interface;
using IA.Models;
using IA.Models.Common;

namespace IA.Service
{
    /// <summary>
    /// 消息推送审批服务实现
    /// </summary>
    public class MessagePushService : IMessagePushService
    {
        private readonly IDbContext _dbContext;
        private readonly IRepository<MessagePushApprovalTask> _messagePATRepository;
        private readonly IRepository<MessagePushApprovalinfo> _meaagePARepository;
        private readonly IRepository<MessagePush> _messagePushRepository;

        public MessagePushService(
            IDbContext dbContext,
            IRepository<MessagePushApprovalTask> messagePatRepository,
            IRepository<MessagePushApprovalinfo> meaagePaRepository, IRepository<MessagePush> messagePushRepository)
        {
            _dbContext = dbContext;
            _messagePATRepository = messagePatRepository;
            _meaagePARepository = meaagePaRepository;
            _messagePushRepository = messagePushRepository;
        }

        /// <summary>
        /// 获取消息推送审批列表
        /// </summary>
        /// <param name="messageName"></param>
        /// <param name="enumSendTaskArray"></param>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <returns></returns>
        public IPagedList<MessagePushApprovalTaskAllModel> GetPushApprovalList(
            string messageName,
            EnumSendTask[] enumSendTaskArray,
            int pageIndex = 0,
            int pageSize = Int32.MaxValue)
        {
            string sqlText = @"SELECT a.*, 
                                    b.actionname, 
                                    c.username 
                             FROM   messagepushapprovaltask a 
                                    LEFT JOIN formaction AS b 
                                           ON a.auditstate = b.id 
                                    LEFT JOIN userinfo AS c 
                                           ON a.createid = c.userid 
                             WHERE  1 = 1 {0}
                             ORDER  BY a.createtime DESC ";