/***********************************************************************
 *            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.Text;
using System.Threading.Tasks;
using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.Entities.Expression;
using CoreCms.Net.Model.ViewModels.Basics;
using CoreCms.Net.Model.ViewModels.DTO;
using CoreCms.Net.Utility.Helper;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using SqlSugar;

namespace CoreCms.Net.Repository
{
    /// <summary>
    /// 订单表 接口实现
    /// </summary>
    public class CoreCmsOrderRepository : BaseRepository<CoreCmsOrder>, ICoreCmsOrderRepository
    {
        public CoreCmsOrderRepository(IUnitOfWork unitOfWork) : base(unitOfWork)
        {

        }


        #region 查询团购秒杀下单数量（获取货品的秒杀团购数据）
        /// <summary>
        /// 查询团购秒杀下单数量（获取货品的秒杀团购数据）
        /// </summary>
        /// <param name="productId"></param>
        /// <param name="userId"></param>
        /// <param name="startTime"></param>
        /// <param name="endTime"></param>
        /// <param name="orderType"></param>
        /// <returns></returns>
        public FindLimitOrderDto FindLimitOrder(int productId, int userId, DateTime? startTime, DateTime? endTime, int orderType = 0)
        {
            var dto = new FindLimitOrderDto();

            var statusArr = new int[] { (int)GlobalEnumVars.OrderStatus.Normal, (int)GlobalEnumVars.OrderStatus.Complete };

            var payStatusArr = new int[] { (int)GlobalEnumVars.OrderPayStatus.No, (int)GlobalEnumVars.OrderPayStatus.Yes, (int)GlobalEnumVars.OrderPayStatus.PartialYes };
            var shipStatusArr = new int[] { (int)GlobalEnumVars.OrderShipStatus.No, (int)GlobalEnumVars.OrderShipStatus.Yes, (int)GlobalEnumVars.OrderShipStatus.PartialYes };


            var queryable = DbClient.Queryable<CoreCmsOrderItem, CoreCmsOrder>((orderItem, orderModel) => new object[]
                {
                    JoinType.Inner, orderItem.orderId == orderModel.orderId
                });

            //计算订单总量
            queryable.WhereIF(productId > 0, (orderItem, orderModel) => orderItem.productId == productId);
            queryable.In((orderItem, orderModel) => orderModel.status, statusArr);
            //在活动时间范围内
            queryable.WhereIF(startTime != null, (orderItem, orderModel) => orderModel.createTime >= startTime);
            queryable.WhereIF(endTime != null, (orderItem, orderModel) => orderModel.createTime < endTime);
            //已退款、已退货、部分退款的、部分退货的排除
            queryable.In((orderItem, orderModel) => orderModel.payStatus, payStatusArr);
            queryable.In((orderItem, orderModel) => orderModel.shipStatus, shipStatusArr);


            //订单类型
            if (orderType > 0)
            {
                queryable.Where((orderItem, orderModel) => orderModel.orderType == orderType);
            }

            dto.TotalOrders = queryable.Clone().Select((orderItem, orderModel) => new { nums = orderItem.nums }).MergeTable().With(SqlWith.Null).Sum(p => p.nums);

            if (userId <= 0) return dto;
            {
                queryable.Where((orderItem, orderModel) => orderModel.userId == userId);
                dto.TotalUserOrders = queryable.Clone().Select((orderItem, orderModel) => new { nums = orderItem.nums }).MergeTable().With(SqlWith.Null).Sum(p => p.nums);
            }
            return dto;
        }

        #endregion


        #region 查询团购秒杀下单数量（获取商品序号的秒杀团购数据）
        /// <summary>
        /// 查询团购秒杀下单数量（获取商品序号的秒杀团购数据）
        /// </summary>
        /// <param name="goodId"></param>
        /// <param name="userId"></param>
        /// <param name="startTime"></param>
        /// <param name="endTime"></param>
        /// <param name="orderType"></param>
        /// <returns></returns>
        public FindLimitOrderDto FindLimitOrderByGoodId(int goodId, int userId, DateTime? startTime, DateTime? endTime, int orderType = 0)
        {
            var dto = new FindLimitOrderDto();

            var statusArr = new int[] { (int)GlobalEnumVars.OrderStatus.Normal, (int)GlobalEnumVars.OrderStatus.Complete };

            var payStatusArr = new int[] { (int)GlobalEnumVars.OrderPayStatus.No, (int)GlobalEnumVars.OrderPayStatus.Yes, (int)GlobalEnumVars.OrderPayStatus.PartialYes };
            var shipStatusArr = new int[] { (int)GlobalEnumVars.OrderShipStatus.No, (int)GlobalEnumVars.OrderShipStatus.Yes, (int)GlobalEnumVars.OrderShipStatus.PartialYes };


            var queryable = DbClient.Queryable<CoreCmsOrderItem, CoreCmsOrder>((orderItem, orderModel) => new object[]
                {
                    JoinType.Inner, orderItem.orderId == orderModel.orderId
                });

            //计算订单总量
            queryable.WhereIF(goodId > 0, (orderItem, orderModel) => orderItem.goodsId == goodId);
            queryable.In((orderItem, orderModel) => orderModel.status, statusArr);
            //在活动时间范围内
            queryable.WhereIF(startTime != null, (orderItem, orderModel) => orderModel.createTime >= startTime);
            queryable.WhereIF(endTime != null, (orderItem, orderModel) => orderModel.createTime < endTime);
            //已退款、已退货、部分退款的、部分退货的排除
            queryable.In((orderItem, orderModel) => orderModel.payStatus, payStatusArr);
            queryable.In((orderItem, orderModel) => orderModel.shipStatus, shipStatusArr);


            //订单类型
            if (orderType > 0)
            {
                queryable.Where((orderItem, orderModel) => orderModel.orderType == orderType);
            }

            dto.TotalOrders = queryable.Clone().Select((orderItem, orderModel) => new { nums = orderItem.nums }).MergeTable().With(SqlWith.Null).Sum(p => p.nums);

            if (userId <= 0) return dto;
            {
                queryable.Where((orderItem, orderModel) => orderModel.userId == userId);
                dto.TotalUserOrders = queryable.Clone().Select((orderItem, orderModel) => new { nums = orderItem.nums }).MergeTable().With(SqlWith.Null).Sum(p => p.nums);
            }
            return dto;
        }

        #endregion

        #region 根据用户id和商品id获取下了多少订单
        /// <summary>
        /// 根据用户id和商品id获取下了多少订单
        /// </summary>
        /// <param name="userId"></param>
        /// <param name="goodId"></param>
        /// <returns></returns>
        public int GetOrderNum(int userId, int goodId)
        {
            var num = DbClient.Queryable<CoreCmsOrder, CoreCmsOrderItem>((op, ot) => new object[]
            {
                JoinType.Inner, op.orderId == ot.orderId
            }).Where((op, ot) => op.userId == userId && ot.goodsId == goodId).Count();
            return num;
        }
        #endregion


        #region 根据用户id和商品id获取下了多少订单

        /// <summary>
        /// 根据用户id和商品id获取下了多少订单
        /// </summary>
        /// <param name="userId"></param>
        /// <param name="goodId"></param>
        /// <param name="orderStatus">状态</param>
        /// <returns></returns>
        public int GetOrderNum(int userId, int goodId,int orderStatus)
        {
            var num = DbClient.Queryable<CoreCmsOrder, CoreCmsOrderItem>((op, ot) => new object[]
            {
                JoinType.Inner, op.orderId == ot.orderId
            }).Where((op, ot) => op.userId == userId && ot.goodsId == goodId && op.status == orderStatus).Count();
            return num;
        }
        #endregion


        #region 重写根据条件列表数据
        /// <summary>
        ///     重写根据条件列表数据
        /// </summary>
        /// <param name="predicate">判断集合</param>
        /// <param name="orderByType">排序方式</param>
        /// <param name="orderByExpression"></param>
        /// <returns></returns>
        public async Task<List<CoreCmsOrder>> QueryListAsync(Expression<Func<CoreCmsOrder, bool>> predicate,
            Expression<Func<CoreCmsOrder, object>> orderByExpression, OrderByType orderByType)
        {
            List<CoreCmsOrder> list = await DbClient.Queryable<CoreCmsOrder, CoreCmsUser>((sOrder, sUser) => new JoinQueryInfos(
                     JoinType.Left, sOrder.userId == sUser.id))
                    .Select((sOrder, sUser) => new CoreCmsOrder
                    {
                        orderId = sOrder.orderId,
                        goodsAmount = sOrder.goodsAmount,
                        payedAmount = sOrder.payedAmount,
                        orderAmount = sOrder.orderAmount,
                        payStatus = sOrder.payStatus,
                        shipStatus = sOrder.shipStatus,
                        status = sOrder.status,
                        orderType = sOrder.orderType,
                        receiptType = sOrder.receiptType,
                        paymentCode = sOrder.paymentCode,
                        paymentTime = sOrder.paymentTime,
                        logisticsId = sOrder.logisticsId,
                        logisticsName = sOrder.logisticsName,
                        costFreight = sOrder.costFreight,
                        userId = sOrder.userId,
                        sellerId = sOrder.sellerId,
                        confirmStatus = sOrder.confirmStatus,
                        confirmTime = sOrder.confirmTime,
                        storeId = sOrder.storeId,
                        shipAreaId = sOrder.shipAreaId,
                        shipAddress = sOrder.shipAddress,
                        shipName = sOrder.shipName,
                        shipMobile = sOrder.shipMobile,
                        weight = sOrder.weight,
                        taxType = sOrder.taxType,
                        taxCode = sOrder.taxCode,
                        taxTitle = sOrder.taxTitle,
                        point = sOrder.point,
                        pointMoney = sOrder.pointMoney,
                        orderDiscountAmount = sOrder.orderDiscountAmount,
                        goodsDiscountAmount = sOrder.goodsDiscountAmount,
                        couponDiscountAmount = sOrder.couponDiscountAmount,
                        coupon = sOrder.coupon,
                        promotionList = sOrder.promotionList,
                        memo = sOrder.memo,
                        ip = sOrder.ip,
                        mark = sOrder.mark,
                        source = sOrder.source,
                        isComment = sOrder.isComment,
                        isdel = sOrder.isdel,
                        createTime = sOrder.createTime,
                        updateTime = sOrder.updateTime,
                        userNickName = sUser.nickName
                    })
                    .With(SqlWith.NoLock)
                    .MergeTable()
                    .Mapper(sOrder => sOrder.aftersalesItem, sOrder => sOrder.aftersalesItem.First().orderId)
                    .Mapper(sOrder => sOrder.items, sOrder => sOrder.items.First().orderId)
                    .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                    .WhereIF(predicate != null, predicate)
                    .ToListAsync();
            return list;
        }

        #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<CoreCmsOrder>> QueryPageAsync(Expression<Func<CoreCmsOrder, bool>> predicate,
            Expression<Func<CoreCmsOrder, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
            int pageSize = 20, bool blUseNoLock = false)
        {
            RefAsync<int> totalCount = 0;
            List<CoreCmsOrder> page = await DbClient.Queryable<CoreCmsOrder, CoreCmsUser>((sOrder, sUser) => new JoinQueryInfos(
                     JoinType.Left, sOrder.userId == sUser.id))
                    .Select((sOrder, sUser) => new CoreCmsOrder
                    {
                        orderId = sOrder.orderId,
                        goodsAmount = sOrder.goodsAmount,
                        payedAmount = sOrder.payedAmount,
                        orderAmount = sOrder.orderAmount,
                        payStatus = sOrder.payStatus,
                        shipStatus = sOrder.shipStatus,
                        status = sOrder.status,
                        orderType = sOrder.orderType,
                        receiptType = sOrder.receiptType,
                        paymentCode = sOrder.paymentCode,
                        paymentTime = sOrder.paymentTime,
                        logisticsId = sOrder.logisticsId,
                        logisticsName = sOrder.logisticsName,
                        costFreight = sOrder.costFreight,
                        userId = sOrder.userId,
                        sellerId = sOrder.sellerId,
                        confirmStatus = sOrder.confirmStatus,
                        confirmTime = sOrder.confirmTime,
                        storeId = sOrder.storeId,
                        shipAreaId = sOrder.shipAreaId,
                        shipAddress = sOrder.shipAddress,
                        shipName = sOrder.shipName,
                        shipMobile = sOrder.shipMobile,
                        weight = sOrder.weight,
                        taxType = sOrder.taxType,
                        taxCode = sOrder.taxCode,
                        taxTitle = sOrder.taxTitle,
                        point = sOrder.point,
                        pointMoney = sOrder.pointMoney,
                        orderDiscountAmount = sOrder.orderDiscountAmount,
                        goodsDiscountAmount = sOrder.goodsDiscountAmount,
                        couponDiscountAmount = sOrder.couponDiscountAmount,
                        coupon = sOrder.coupon,
                        promotionList = sOrder.promotionList,
                        memo = sOrder.memo,
                        ip = sOrder.ip,
                        mark = sOrder.mark,
                        source = sOrder.source,
                        isComment = sOrder.isComment,
                        isdel = sOrder.isdel,
                        createTime = sOrder.createTime,
                        updateTime = sOrder.updateTime,
                        userNickName = sUser.nickName,
                       
                       
                    })
                    .With(SqlWith.NoLock)
                    .MergeTable()
                    .Mapper(sOrder => sOrder.aftersalesItem, sOrder => sOrder.aftersalesItem.First().orderId)
                    .Mapper(sOrder => sOrder.items, sOrder => sOrder.items.First().orderId)                    
                    .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                    .WhereIF(predicate != null, predicate)
                    .ToPageListAsync(pageIndex, pageSize, totalCount);

            var list = new PageList<CoreCmsOrder>(page, pageIndex, pageSize, totalCount);
            return list;
        }

        #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<CoreCmsOrder>> QueryPageNewAsync(Expression<Func<CoreCmsOrder, bool>> predicate,
            Expression<Func<CoreCmsOrder, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
            int pageSize = 20, bool blUseNoLock = false)
        {
            RefAsync<int> totalCount = 0;
            List<CoreCmsOrder> page;
            if (blUseNoLock)
            {
                page = await DbClient.Queryable<CoreCmsOrder>()
                .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                .WhereIF(predicate != null, predicate).Select(p => new CoreCmsOrder
                {
                    orderId = p.orderId,
                    goodsAmount = p.goodsAmount,
                    payedAmount = p.payedAmount,
                    orderAmount = p.orderAmount,
                    payStatus = p.payStatus,
                    shipStatus = p.shipStatus,
                    status = p.status,
                    orderType = p.orderType,
                    receiptType = p.receiptType,
                    paymentCode = p.paymentCode,
                    paymentTime = p.paymentTime,
                    logisticsId = p.logisticsId,
                    logisticsName = p.logisticsName,
                    costFreight = p.costFreight,
                    userId = p.userId,
                    sellerId = p.sellerId,
                    confirmStatus = p.confirmStatus,
                    confirmTime = p.confirmTime,
                    storeId = p.storeId,
                    shipAreaId = p.shipAreaId,
                    shipAddress = p.shipAddress,
                    shipName = p.shipName,
                    shipMobile = p.shipMobile,
                    weight = p.weight,
                    taxType = p.taxType,
                    taxCode = p.taxCode,
                    taxTitle = p.taxTitle,
                    point = p.point,
                    pointMoney = p.pointMoney,
                    orderDiscountAmount = p.orderDiscountAmount,
                    goodsDiscountAmount = p.goodsDiscountAmount,
                    couponDiscountAmount = p.couponDiscountAmount,
                    coupon = p.coupon,
                    promotionList = p.promotionList,
                    memo = p.memo,
                    ip = p.ip,
                    mark = p.mark,
                    source = p.source,
                    isComment = p.isComment,
                    isdel = p.isdel,
                    createTime = p.createTime,
                    updateTime = p.updateTime,

                }).With(SqlWith.NoLock).ToPageListAsync(pageIndex, pageSize, totalCount);
            }
            else
            {
                page = await DbClient.Queryable<CoreCmsOrder>()
                .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                .WhereIF(predicate != null, predicate).Select(p => new CoreCmsOrder
                {
                    orderId = p.orderId,
                    goodsAmount = p.goodsAmount,
                    payedAmount = p.payedAmount,
                    orderAmount = p.orderAmount,
                    payStatus = p.payStatus,
                    shipStatus = p.shipStatus,
                    status = p.status,
                    orderType = p.orderType,
                    receiptType = p.receiptType,
                    paymentCode = p.paymentCode,
                    paymentTime = p.paymentTime,
                    logisticsId = p.logisticsId,
                    logisticsName = p.logisticsName,
                    costFreight = p.costFreight,
                    userId = p.userId,
                    sellerId = p.sellerId,
                    confirmStatus = p.confirmStatus,
                    confirmTime = p.confirmTime,
                    storeId = p.storeId,
                    shipAreaId = p.shipAreaId,
                    shipAddress = p.shipAddress,
                    shipName = p.shipName,
                    shipMobile = p.shipMobile,
                    weight = p.weight,
                    taxType = p.taxType,
                    taxCode = p.taxCode,
                    taxTitle = p.taxTitle,
                    point = p.point,
                    pointMoney = p.pointMoney,
                    orderDiscountAmount = p.orderDiscountAmount,
                    goodsDiscountAmount = p.goodsDiscountAmount,
                    couponDiscountAmount = p.couponDiscountAmount,
                    coupon = p.coupon,
                    promotionList = p.promotionList,
                    memo = p.memo,
                    ip = p.ip,
                    mark = p.mark,
                    source = p.source,
                    isComment = p.isComment,
                    isdel = p.isdel,
                    createTime = p.createTime,
                    updateTime = p.updateTime,

                }).ToPageListAsync(pageIndex, pageSize, totalCount);
            }
            var list = new PageList<CoreCmsOrder>(page, pageIndex, pageSize, totalCount);
            return list;
        }

        #endregion


    }
}