/***********************************************************************
 *            Project: baifenBinfa
 *        ProjectName: 百分兵法管理系统                               
 *                Web: http://chuanyin.com                     
 *             Author:                                        
 *              Email:                               
 *         CreateTime: 202403/02   
 *        Description: 暂无
 ***********************************************************************/

using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Threading.Tasks;
using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.ViewModels.Basics;
using CoreCms.Net.Model.ViewModels.DTO;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Helper;
using SqlSugar;

namespace CoreCms.Net.Repository
{
    /// <summary>
    /// 优惠券码表 接口实现
    /// </summary>
    public class CoreCmsCouponRepository : BaseRepository<CoreCmsCoupon>, ICoreCmsCouponRepository
    {


        public CoreCmsCouponRepository(IUnitOfWork unitOfWork) : base(unitOfWork)
        {
        }

        #region 根据优惠券编码取优惠券的信息,并判断是否可用

        /// <summary>
        /// 根据优惠券编码取优惠券的信息,并判断是否可用
        /// </summary>
        /// <param name="code"></param>
        /// <param name="check"></param>
        public async Task<WebApiCallBack> ToInfo(string[] code, bool check = false)
        {
            var jm = new WebApiCallBack();
            var outData = new List<CoreCmsPromotion>();

            foreach (var codeStr in code)
            {
                var model = await DbClient.Queryable<CoreCmsCoupon, CoreCmsPromotion>((coupon, prommotion) => new object[]
                    {
                        JoinType.Inner, coupon.promotionId == prommotion.id
                    }).Where((coupon, prommotion) => coupon.couponCode == codeStr)
                    .Select((coupon, prommotion) => new
                    {
                        coupon,
                        prommotion
                    }).FirstAsync();
                ;
                if (model != null)
                {
                    if (check)
                    {
                        //判断规则是否开启
                        if (model.prommotion.isEnable == false)
                        {
                            jm.data = 15012;
                            jm.msg = GlobalErrorCodeVars.Code15012;
                            return jm;
                        }
                        //判断优惠券规则是否到达开始时间
                        var dt = DateTime.Now;
                        if (model.coupon.startTime > dt)
                        {
                            jm.data = 15010;
                            jm.msg = GlobalErrorCodeVars.Code15010;
                            return jm;
                        }
                        //判断优惠券规则是否已经到结束时间了，也就是是否过期了
                        if (model.coupon.endTime < dt)
                        {
                            jm.data = 15011;
                            jm.msg = GlobalErrorCodeVars.Code15011;
                            return jm;
                        }
                        //判断是否已经使用过了
                        if (model.coupon.isUsed)
                        {
                            jm.data = 15013;
                            jm.msg = GlobalErrorCodeVars.Code15013;
                            return jm;
                        }
                        //判断此类优惠券是否已经使用过,防止一类优惠券使用多张
                        if (outData.Exists(p => p.id == model.coupon.promotionId))
                        {
                            jm.data = 15015;
                            jm.msg = GlobalErrorCodeVars.Code15015;
                            return jm;
                        }
                    }
                    outData.Add(model.prommotion);
                }
                else
                {
                    jm.data = 15009;
                    jm.msg = GlobalErrorCodeVars.Code15009;
                    return jm;
                }
            }
            jm.status = true;
            jm.data = outData;
            return jm;
        }


        #endregion

        #region 获取 我的优惠券
        /// <summary>
        /// 获取 我的优惠券
        /// </summary>
        /// <param name="userId">用户序列</param>
        /// <param name="promotionId">促销序列</param>
        /// <param name="display">优惠券状态编码</param>
        /// <param name="page">页码</param>
        /// <param name="limit">数量</param>
        public async Task<WebApiCallBack> GetMyCoupon(int userId, int promotionId = 0, string display = "", int page = 1, int limit = 10)
        {
            var jm = new WebApiCallBack();
            jm.code = 0;

            RefAsync<int> totalCount = 0;
            var dt = DateTime.Now;
            var listData = await DbClient.Queryable<CoreCmsCoupon, CoreCmsPromotion>((coupon, promotion) => new object[]
                 {
                        JoinType.Inner, coupon.promotionId == promotion.id
                 })
                .Where((coupon, promotion) => coupon.userId == userId)
                .Where((coupon, promotion) => promotion.isDel == false)
                .Where((coupon, promotion) => promotion.type == (int)GlobalEnumVars.PromotionType.Coupon)
                .WhereIF(display == GlobalEnumVars.CouponIsUsedStatusText.noUsed.ToString(), (coupon, promotion) => coupon.isUsed == false && coupon.endTime >= dt)
                .WhereIF(display == GlobalEnumVars.CouponIsUsedStatusText.yesUsed.ToString(), (coupon, promotion) => coupon.isUsed == true)
                .WhereIF(display == GlobalEnumVars.CouponIsUsedStatusText.invalid.ToString(), (coupon, promotion) => coupon.endTime < dt && coupon.isUsed == false)
                .WhereIF(promotionId > 0, (coupon, promotion) => coupon.promotionId == promotionId)
                .WhereIF(promotionId == 0, (coupon, promotion) => promotion.isEnable == true)
                .Select((coupon, promotion) => new CoreCmsCoupon
                {
                    couponCode = coupon.couponCode,
                    promotionId = coupon.promotionId,
                    isUsed = coupon.isUsed,
                    userId = coupon.userId,
                    usedId = coupon.usedId,
                    createTime = coupon.createTime,
                    updateTime = coupon.updateTime,
                    couponName = promotion.name,
                    startTime = coupon.startTime,
                    endTime = coupon.endTime,

                })
                .With(SqlWith.Null)
                .MergeTable()
                .Mapper(p => p.conditions, p => p.promotionId)
                .Mapper(p => p.results, p => p.promotionId)
                .OrderBy(p => p.createTime, OrderByType.Desc)

                .ToPageListAsync(page, limit, totalCount);

            var totalPages = totalCount.Value / limit;
            if (totalPages == 0) { totalPages++; }
            if (totalPages % limit > 0)
                totalPages++;

            var resutlList = new List<GetMyCouponResultDto>();
            if (listData != null && listData.Any())
            {
                foreach (var item in listData)
                {
                    //var pcondition = await DbClient.Queryable<CoreCmsPromotionCondition>().Where(p => p.promotionId == item.promotionId).ToListAsync();
                    //var presult = await DbClient.Queryable<CoreCmsPromotionResult>().Where(p => p.promotionId == item.promotionId).ToListAsync();
                    var expression1 = string.Empty;
                    var expression2 = string.Empty;

                    var dto = new GetMyCouponResultDto();

                    foreach (var condition in item.conditions)
                    {
                        var str = PromotionHelper.GetConditionMsg(condition.code, condition.parameters);
                        expression1 += str;
                        dto.conditions.Add(str);
                    }
                    foreach (var result in item.results)
                    {
                        var str = PromotionHelper.GetResultMsg(result.code, result.parameters);
                        expression2 += str;
                        dto.results.Add(str);
                    }

                    dto.couponCode = item.couponCode;
                    dto.promotionId = item.promotionId;
                    dto.isUsed = item.isUsed;
                    dto.userId = item.userId;
                    dto.usedId = item.usedId;
                    dto.createTime = item.createTime;
                    dto.updateTime = item.updateTime;
                    dto.couponName = item.couponName;

                    dto.expression1 = expression1;
                    dto.expression2 = expression2;

                    dto.isExpire = dt > item.endTime;
                    dto.startTime = item.startTime;
                    dto.endTime = item.endTime;
                    dto.stime = item.startTime.ToString("yyyy-MM-dd");
                    dto.etime = item.endTime.ToString("yyyy-MM-dd");

                    resutlList.Add(dto);
                }
            }
            jm.status = true;
            jm.msg = "获取成功";
            jm.data = new
            {
                list = resutlList,
                count = totalCount.Value,
                display,
                page = totalPages
            };
            jm.code = totalCount.Value;

            return jm;
        }
        #endregion

        #region 根据条件查询分页数据及导航数据

        /// <summary>
        ///     根据条件查询分页数据及导航数据
        /// </summary>
        /// <param name="predicate">判断集合</param>
        /// <param name="orderByType">排序方式</param>
        /// <param name="isToPage">是否分页</param>
        /// <param name="pageIndex">当前页面索引</param>
        /// <param name="pageSize">分布大小</param>
        /// <param name="orderByExpression"></param>
        /// <returns></returns>
        public async Task<IPageList<CoreCmsCoupon>> QueryPageMapperAsync(Expression<Func<CoreCmsCoupon, bool>> predicate,
            Expression<Func<CoreCmsCoupon, object>> orderByExpression, OrderByType orderByType, bool isToPage = false, int pageIndex = 1,
            int pageSize = 20)
        {
            RefAsync<int> totalCount = 0;
            List<CoreCmsCoupon> page;
            if (isToPage)
            {
                page = await DbClient.Queryable<CoreCmsCoupon>()
                    .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                    .WhereIF(predicate != null, predicate).Select(p => new CoreCmsCoupon
                    {
                        id = p.id,
                        couponCode = p.couponCode,
                        promotionId = p.promotionId,
                        isUsed = p.isUsed,
                        userId = p.userId,
                        usedId = p.usedId,
                        createTime = p.createTime,
                        updateTime = p.updateTime,
                        startTime = p.startTime,
                        endTime = p.endTime,
                    })
                    .Mapper(p => p.promotion, p => p.promotionId)
                    .Mapper(p => p.conditions, p => p.conditions.First().promotionId)
                    .Mapper(p => p.results, p => p.results.First().promotionId)
                    .ToPageListAsync(pageIndex, pageSize, totalCount);
            }
            else
            {
                page = await DbClient.Queryable<CoreCmsCoupon>()
                    .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                    .WhereIF(predicate != null, predicate)
                    .Take(pageSize)
                    .Select(p => new CoreCmsCoupon
                    {
                        id = p.id,
                        couponCode = p.couponCode,
                        promotionId = p.promotionId,
                        isUsed = p.isUsed,
                        userId = p.userId,
                        usedId = p.usedId,
                        createTime = p.createTime,
                        updateTime = p.updateTime,
                        startTime = p.startTime,
                        endTime = p.endTime,
                    })
                    .Mapper(p => p.promotion, p => p.promotionId)
                    .Mapper(p => p.conditions, p => p.conditions.First().promotionId)
                    .Mapper(p => p.results, p => p.results.First().promotionId)
                    .ToListAsync();
            }
            var list = new PageList<CoreCmsCoupon>(page, pageIndex, pageSize, totalCount);
            return list;
        }

        #endregion

        #region 重写数据并获取相关
        /// <summary>
        ///     重写数据并获取相关
        /// </summary>
        /// <param name="predicate">判断集合</param>
        /// <returns></returns>
        public async Task<List<CoreCmsCoupon>> QueryWithAboutAsync(Expression<Func<CoreCmsCoupon, bool>> predicate)
        {
            var page = await DbClient.Queryable<CoreCmsCoupon, CoreCmsUser, CoreCmsPromotion>((p, sUser, sPromotion) => new JoinQueryInfos(
                    JoinType.Left, p.userId == sUser.id,
                    JoinType.Left, p.promotionId == sPromotion.id))
                .Select((p, sUser, sPromotion) => new CoreCmsCoupon
                {
                    id = p.id,
                    couponCode = p.couponCode,
                    promotionId = p.promotionId,
                    isUsed = p.isUsed,
                    userId = p.userId,
                    usedId = p.usedId,
                    createTime = p.createTime,
                    updateTime = p.updateTime,
                    userNickName = sUser.nickName,
                    couponName = sPromotion.name,
                    startTime = p.startTime,
                    endTime = p.endTime,
                })
                .MergeTable()
                .WhereIF(predicate != null, predicate)
                .ToListAsync();
            return page;
        }

        #endregion

        #region 重写根据条件查询分页数据
        /// <summary>
        ///     重写根据条件查询分页数据
        /// </summary>
        /// <param name="predicate">判断集合</param>
        /// <param name="orderByType">排序方式</param>
        /// <param name="pageIndex">当前页面索引</param>
        /// <param name="pageSize">分布大小</param>
        /// <param name="orderByExpression"></param>
        /// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
        /// <returns></returns>
        public async Task<IPageList<CoreCmsCoupon>> QueryPageAsync(Expression<Func<CoreCmsCoupon, bool>> predicate,
            Expression<Func<CoreCmsCoupon, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
            int pageSize = 20, bool blUseNoLock = false)
        {
            RefAsync<int> totalCount = 0;
            var page = blUseNoLock
                ? await DbClient.Queryable<CoreCmsCoupon, CoreCmsUser, CoreCmsPromotion>((p, sUser, sPromotion) => new JoinQueryInfos(
                         JoinType.Left, p.userId == sUser.id,
                         JoinType.Left, p.promotionId == sPromotion.id))
                .Select((p, sUser, sPromotion) => new CoreCmsCoupon
                {
                    id = p.id,
                    couponCode = p.couponCode,
                    promotionId = p.promotionId,
                    isUsed = p.isUsed,
                    userId = p.userId,
                    usedId = p.usedId,
                    createTime = p.createTime,
                    updateTime = p.updateTime,
                    userNickName = sUser.nickName,
                    couponName = sPromotion.name,
                    startTime = p.startTime,
                    endTime = p.endTime,
                })
                .With(SqlWith.NoLock)
                .MergeTable()
                .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                .WhereIF(predicate != null, predicate)
                .ToPageListAsync(pageIndex, pageSize, totalCount)
                :
                await DbClient.Queryable<CoreCmsCoupon, CoreCmsUser, CoreCmsPromotion>((p, sUser, sPromotion) => new JoinQueryInfos(
                        JoinType.Left, p.userId == sUser.id,
                        JoinType.Left, p.promotionId == sPromotion.id))
                    .Select((p, sUser, sPromotion) => new CoreCmsCoupon
                    {
                        id = p.id,
                        couponCode = p.couponCode,
                        promotionId = p.promotionId,
                        isUsed = p.isUsed,
                        userId = p.userId,
                        usedId = p.usedId,
                        createTime = p.createTime,
                        updateTime = p.updateTime,
                        userNickName = sUser.nickName,
                        couponName = sPromotion.name,
                        startTime = p.startTime,
                        endTime = p.endTime,
                    })
                .MergeTable()
                .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                .WhereIF(predicate != null, predicate)
                .ToPageListAsync(pageIndex, pageSize, totalCount);
            var list = new PageList<CoreCmsCoupon>(page, pageIndex, pageSize, totalCount);
            return list;
        }

        #endregion

        #region 获取 我的优惠券可用数量
        /// <summary>
        /// 获取 我的优惠券可用数量
        /// </summary>
        /// <param name="userId">用户序列</param>
        public async Task<int> GetMyCouponCount(int userId)
        {
            var jm = new WebApiCallBack();
            jm.code = 0;

            var dt = DateTime.Now;
            var count = await DbClient.Queryable<CoreCmsCoupon, CoreCmsPromotion>((coupon, promotion) => new object[]
                 {
                        JoinType.Inner, coupon.promotionId == promotion.id
                 })
                .Where((coupon, promotion) => coupon.userId == userId)
                .Where((coupon, promotion) => promotion.isDel == false)
                .Where((coupon, promotion) => coupon.isUsed == false)
                .Where((coupon, promotion) => promotion.type == (int)GlobalEnumVars.PromotionType.Coupon)
                .Where((coupon, promotion) => coupon.endTime > dt)
                .CountAsync();
            return count;
        }
        #endregion

    }
}