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

using System;
using System.Linq;
using System.Threading.Tasks;
using CoreCms.Net.Auth.HttpContextUser;
using CoreCms.Net.Caching.AutoMate.RedisCache;
using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.FromBody;
using CoreCms.Net.Model.ViewModels.UI;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;

namespace CoreCms.Net.Web.WebApi.Controllers
{
    /// <summary>
    /// 优惠券接口
    /// </summary>
    [Route("api/[controller]/[action]")]
    [ApiController]
    public class CouponController : ControllerBase
    {

        private readonly IHttpContextUser _user;
        private readonly ICoreCmsCouponServices _couponServices;
        private readonly ICoreCmsPromotionServices _promotionServices;
        private readonly IRedisOperationRepository _redisOperationRepository;
        private readonly IUnitOfWork _unionOfWork;

        /// <summary>
        /// 构造函数
        /// </summary>
        public CouponController(IHttpContextUser user
            , ICoreCmsCouponServices couponServices, ICoreCmsPromotionServices promotionServices, IRedisOperationRepository redisOperationRepository, IUnitOfWork unionOfWork)
        {
            _user = user;
            _couponServices = couponServices;
            _promotionServices = promotionServices;
            _redisOperationRepository = redisOperationRepository;
            _unionOfWork = unionOfWork;
        }

        //公共接口====================================================================================================

        #region 获取 可领取的优惠券==================================================
        /// <summary>
        /// 获取 可领取的优惠券
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        //[Authorize]
        public async Task<WebApiCallBack> CouponList([FromBody] FMCouponForUserCouponPost entity)
        {
            var jm = new WebApiCallBack() { msg = "获取失败" };

            var list = await _promotionServices.GetReceiveCouponList(entity.page, entity.limit);
            jm.status = true;
            jm.data = list;
            jm.msg = "获取成功";
            jm.otherData = new
            {
                totalCount = 0,
                totalPages = 0,
            };
            if (list != null && list.Any())
            {
                jm.data = list;
                jm.otherData = new
                {
                    list.TotalCount,
                    list.TotalPages
                };
            }
            return jm;
        }
        #endregion

        //验证接口====================================================================================================

        #region 获取优惠券 详情==================================================
        /// <summary>
        /// 获取优惠券 详情
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [Authorize]
        public async Task<WebApiCallBack> CouponDetail([FromBody] FMIntId entity)
        {
            var jm = new WebApiCallBack() { msg = "获取失败" };

            if (entity.id == 0)
            {
                jm.status = false;
                jm.msg = GlobalErrorCodeVars.Code15006;
                return jm;
            }

            var promotionModel = await _promotionServices.QueryByClauseAsync(p => p.id == entity.id);
            if (promotionModel != null)
            {
                jm.status = true;
                jm.data = promotionModel;
                jm.msg = "获取成功";
            }
            return jm;

        }
        #endregion

        #region 获取用户已领取的优惠券==================================================
        /// <summary>
        /// 获取用户已领取的优惠券
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [Authorize]
        public async Task<WebApiCallBack> UserCoupon([FromBody] FMCouponForUserCouponPost entity)
        {
            var jm = await _couponServices.GetMyCoupon(_user.ID, 0, entity.display, entity.page, entity.limit);
            return jm;
        }
        #endregion

        #region 用户领取优惠券==================================================
        /// <summary>
        /// 用户领取优惠券
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [Authorize]
        public async Task<WebApiCallBack> GetCoupon([FromBody] FMIntId entity)
        {
            var jm = new WebApiCallBack();

            var lockKey = "LOCK_GetCoupon:user_" + entity.id;
            var lockHolder = Guid.NewGuid().ToString("N"); //锁持有者
            var redisUserLock = await _redisOperationRepository.LockTakeAsync(lockKey, lockHolder, TimeSpan.FromSeconds(5));
            if (redisUserLock)
            {
                try
                {
                    if (entity.id == 0)
                    {
                        jm.msg = GlobalErrorCodeVars.Code15006;
                        return jm;
                    }
                    //判断优惠券是否可以领取?
                    var promotionModel = await _promotionServices.ReceiveCoupon(entity.id);
                    if (promotionModel.status == false)
                    {
                        return promotionModel;
                    }

                    var promotion = (CoreCmsPromotion)promotionModel.data;
                    if (promotion == null)
                    {
                        jm.msg = GlobalErrorCodeVars.Code15019;
                        return jm;
                    }

                    if (promotion.maxNums > 0)
                    {
                        //判断用户是否已领取?领取次数
                        var couponResult = await _couponServices.GetMyCoupon(_user.ID, entity.id, "all", 1, 9999);
                        if (couponResult.status && couponResult.code >= promotion.maxNums)
                        {
                            jm.msg = GlobalErrorCodeVars.Code15018;
                            return jm;
                        }
                    }
                    jm = await _couponServices.AddData(_user.ID, entity.id, promotion);
                    jm.otherData = promotionModel;
                    return jm;


                }
                catch (Exception e)
                {
                    jm.msg = "数据处理异常";
                    jm.otherData = e;
                }
                finally
                {
                    await _redisOperationRepository.LockReleaseAsync(lockKey, lockHolder);
                }
            }
            else
            {
                jm.msg = "当前请求太频繁_请稍后再试";
            }
            return jm;
        }
        #endregion

        #region 用户输入code领取优惠券==================================================
        /// <summary>
        /// 用户输入code领取优惠券
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [Authorize]
        public async Task<WebApiCallBack> GetCouponKey([FromBody] FMCouponForGetCouponKeyPost entity)
        {
            var jm = new WebApiCallBack();

            if (string.IsNullOrEmpty(entity.key))
            {
                jm.msg = GlobalErrorCodeVars.Code15006;
                return jm;
            }

            var coupon = await _couponServices.QueryByClauseAsync(p => p.couponCode == entity.key);
            if (coupon == null || coupon.promotionId <= 0)
            {
                jm.msg = GlobalErrorCodeVars.Code15009;
                return jm;
            }

            try
            {
                _unionOfWork.BeginTran();

                //判断优惠券是否可以领取?
                var promotionModel = await _promotionServices.ReceiveCoupon(coupon.promotionId);
                if (promotionModel.status == false)
                {
                    _unionOfWork.RollbackTran();
                    return promotionModel;
                }

                var promotion = (CoreCmsPromotion)promotionModel.data;
                if (promotion == null)
                {
                    _unionOfWork.RollbackTran();
                    jm.msg = GlobalErrorCodeVars.Code15019;
                    return jm;
                }

                if (promotion.maxNums > 0)
                {
                    //判断用户是否已领取?领取次数
                    var couponResult = await _couponServices.GetMyCoupon(_user.ID, coupon.promotionId, "all", 1, 9999);
                    if (couponResult.status && couponResult.code >= promotion.maxNums)
                    {
                        _unionOfWork.RollbackTran();
                        jm.msg = GlobalErrorCodeVars.Code15018;
                        return jm;
                    }
                }
                jm = await _couponServices.ReceiveCoupon(_user.ID, entity.key);

                _unionOfWork.CommitTran();

                jm.otherData = promotionModel;

            }
            catch (Exception e)
            {
                _unionOfWork.RollbackTran();
                jm.msg = GlobalErrorCodeVars.Code10000;
                jm.data = e;
            }

            return jm;
        }
        #endregion

    }
}