using Infrastructure.Attribute;
using Microsoft.AspNetCore.Http;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using ARW.Model;
using ARW.Repository;
using ARW.Repository.Business.SubscribeTasks;
using ARW.Service.Business.IBusinessService.SubscribeTasks;
using ARW.Model.Dto.Business.SubscribeTasks;
using ARW.Model.Models.Business.SubscribeTasks;
using ARW.Model.Vo.Business.SubscribeTasks;
using ARW.Model.Models.Business.Custom.Customers;

namespace ARW.Service.Business.BusinessService.SubscribeTasks
{
    /// <summary>
    /// 订阅推送任务接口实现类
    /// </summary>
    [AppService(ServiceType = typeof(ISubscribeTaskService), ServiceLifetime = LifeTime.Transient)]
    public class SubscribeTaskServiceImpl : BaseService<SubscribeTask>, ISubscribeTaskService
    {
        private readonly SubscribeTaskRepository _SubscribeTaskRepository;

        public SubscribeTaskServiceImpl(SubscribeTaskRepository SubscribeTaskRepository)
        {
            this._SubscribeTaskRepository = SubscribeTaskRepository;
        }

        #region 业务逻辑代码

        /// <summary>
        /// 查询订阅推送任务列表
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        public List<SubscribeTaskVo> GetSubscribeTaskList()
        {
            //开始拼装查询条件d
            var predicate = Expressionable.Create<SubscribeTask>();

            var query = _SubscribeTaskRepository
                .Queryable()
                .Where(predicate.ToExpression())
                .Where(s => s.SubscribeTaskStatus == 0)
                .LeftJoin<Customer>((s,f) => s.CustomerGuid == f.CustomerGuid)
                .OrderBy(s => s.Create_time, OrderByType.Desc)
                .Select((s,f) => new SubscribeTaskVo
                {
                    SubscribeTaskId = s.SubscribeTaskId,
                    SubscribeTaskGuid = s.SubscribeTaskGuid,
                    OpenId = f.CustomerXcxOpenid,
                    SubscribeTaskType = s.SubscribeTaskType,
                    TemplateId = s.TemplateId,
                    SubscribeTaskStatus = s.SubscribeTaskStatus,
                    SubscribeTaskErrorMsg = s.SubscribeTaskErrorMsg,
                });

            return query.ToList();
        }

        #endregion

    }
}