/***********************************************************************
 *            Project: baifenBinfa
 *        ProjectName: 百分兵法管理系统                               
 *                Web: http://chuanyin.com                     
 *             Author:                                        
 *              Email:                               
 *         CreateTime: 2022/3/8 23:33:07
 *        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.IServices;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.ViewModels.Basics;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Extensions;
using CoreCms.Net.Utility.Helper;
using SqlSugar;


namespace CoreCms.Net.Services
{
    /// <summary>
    /// 用户签到明细表 接口实现
    /// </summary>
    public class CoreCmsUserCheckInDetailsServices : BaseServices<CoreCmsUserCheckInDetails>, ICoreCmsUserCheckInDetailsServices
    {
        private readonly ICoreCmsUserCheckInDetailsRepository _dal;
        private readonly IUnitOfWork _unitOfWork;

        private readonly ICoreCmsSettingServices _settingServices;
        private readonly ICoreCmsUserPointLogServices _userPointLogServices;
        private readonly ICoreCmsUserBalanceServices _userBalanceServices;
        private readonly ICoreCmsCumulativeCheckInRulesServices _cumulativeCheckInRulesServices;
        private readonly ICoreCmsContinuousCheckInRulesServices _continuousCheckInRulesServices;
        private readonly ICoreCmsUserServices _userServices;
        private readonly ICoreCmsUserCheckInServices _userCheckInServices;


        public CoreCmsUserCheckInDetailsServices(IUnitOfWork unitOfWork, ICoreCmsUserCheckInDetailsRepository dal, ICoreCmsSettingServices settingServices, ICoreCmsUserPointLogServices userPointLogServices, ICoreCmsUserBalanceServices userBalanceServices, ICoreCmsCumulativeCheckInRulesServices cumulativeCheckInRulesServices, ICoreCmsContinuousCheckInRulesServices continuousCheckInRulesServices, ICoreCmsUserServices userServices, ICoreCmsUserCheckInServices userCheckInServices)
        {
            this._dal = dal;
            _settingServices = settingServices;
            _userPointLogServices = userPointLogServices;
            _userBalanceServices = userBalanceServices;
            _cumulativeCheckInRulesServices = cumulativeCheckInRulesServices;
            _continuousCheckInRulesServices = continuousCheckInRulesServices;
            _userServices = userServices;
            _userCheckInServices = userCheckInServices;
            base.BaseDal = dal;
            _unitOfWork = unitOfWork;
        }


        /// <summary>
        /// 获取缓存的所有数据
        /// </summary>
        /// <returns></returns>
        public async Task<AdminUiCallBack> DoCheckIn(CoreCmsUserCheckInDetails entity)
        {
            var jm = new AdminUiCallBack();
            try
            {
                var dt = DateTime.Now;
                var dtStr = dt.ToString("yyyy-MM-dd");
                var checkDataStr = entity.checkInData.ToString("yyyy-MM-dd");
                if (dtStr != checkDataStr)
                {
                    jm.msg = "签到日期不符,签到提交日期非今日";
                    return jm;
                }

                var id = await _dal.InsertAsync(entity);

                var userCheckIn = await _userCheckInServices.QueryByClauseAsync(p => p.userId == entity.userId);
                if (userCheckIn != null)
                {
                    //累计签到
                    userCheckIn.cumulativeCheckInCount += 1;

                    //判断是否是连续签到
                    //判断是否是连续签到逻辑是：获取用户最后一次的签到记录，检查查询到的签到记录的checkInData是不是昨天的checkInData，是的话就是连续签到，continuousCheckInCount++,不是的话就是断签了，continuousCheckInCount设置成1重新开始就行了。
                    var lastCheck = await _dal.QueryByClauseAsync(p => p.id < id, true);
                    if (lastCheck == null)
                    {
                        userCheckIn.continuousCheckInCount = 1;
                    }
                    else
                    {
                        var yesterdayDataStr = dt.AddDays(-1).ToString("yyyy-MM-dd");
                        var lastCheckDataStr = lastCheck.checkInData.ToString("yyyy-MM-dd");
                        if (yesterdayDataStr == lastCheckDataStr)
                        {
                            //累加
                            userCheckIn.continuousCheckInCount += 1;
                        }
                        else
                        {
                            //重置
                            userCheckIn.continuousCheckInCount = 1;
                        }
                    }
                    await _userCheckInServices.UpdateAsync(userCheckIn);
                }
                else
                {
                    userCheckIn = new CoreCmsUserCheckIn();
                    userCheckIn.userId = entity.userId;
                    userCheckIn.continuousCheckInCount = 1;
                    userCheckIn.cumulativeCheckInCount = 1;
                    await _userCheckInServices.InsertAsync(userCheckIn);
                }

                //初始化获得的积分
                var point = 0;
                //初始化获得的余额
                var money = 0;


                var allConfigs = await _settingServices.GetConfigDictionaries();
                var showStoresSwitch = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.CheckInIsOpen).ObjectToInt(2);   //是否开启签到
                if (showStoresSwitch == 1)
                {

                    //普通签到赠送处理
                    //签到赠送的数量
                    var checkInCommonNum = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.CheckInCommonNum).ObjectToInt(0);
                    if (checkInCommonNum > 0)
                    {
                        //签到赠送的类别
                        var checkInCommonType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.CheckInCommonType).ObjectToInt(0);
                        switch (checkInCommonType)
                        {
                            case (int)GlobalEnumVars.CheckInCommonType.积分:
                                point += checkInCommonNum;
                                //储值积分
                                await _userPointLogServices.SetPoint(entity.userId, checkInCommonNum, (int)GlobalEnumVars.UserPointSourceTypes.PointTypeSign, "日历签到，获得" + checkInCommonNum + "积分");
                                break;
                            case (int)GlobalEnumVars.CheckInCommonType.余额:
                                money += checkInCommonNum;
                                //储值余额
                                await _userBalanceServices.Change(entity.userId, (int)GlobalEnumVars.UserBalanceSourceTypes.CheckIn, checkInCommonNum, id.ToString());
                                break;
                        }
                    }

                    //判断累计签到次数是否满足
                    var cumulativeCheckInRules = await _cumulativeCheckInRulesServices.QueryAsync(true, true);
                    //获取用户总签到次数（使用userCheckIn的签到次数统计也可以，但是查询实时数据最可靠。根据个人来）
                    //var cumulativeCheckInCount = await _dal.GetCountAsync(p => p.userId == entity.userId);
                    var cumulativeCheckInCount = userCheckIn.cumulativeCheckInCount;
                    //遍历规则
                    async void Action(CoreCmsCumulativeCheckInRules p)
                    {
                        if (cumulativeCheckInCount == p.days)
                        {
                            switch (p.type)
                            {
                                case (int)GlobalEnumVars.CheckInCommonType.积分:
                                    point += p.num;
                                    //储值积分
                                    await _userPointLogServices.SetPoint(entity.userId, p.num, (int)GlobalEnumVars.UserPointSourceTypes.PointTypeSign, "日历签到，获得" + p.num + "积分");
                                    break;
                                case (int)GlobalEnumVars.CheckInCommonType.余额:
                                    money += p.num;
                                    //储值余额
                                    await _userBalanceServices.Change(entity.userId, (int)GlobalEnumVars.UserBalanceSourceTypes.CheckIn, p.num, id.ToString());
                                    break;
                            }
                        }
                        //原则上应该还要加个日志。确定是否这个时间已经领取过了。
                    }
                    cumulativeCheckInRules.ForEach(Action);


                    //判断连续签到次数是否满足
                    var continuousCheckInRules = await _continuousCheckInRulesServices.GetDataWidthChild();
                    //获取用户数据
                    var user = await _userServices.QueryByIdAsync(entity.userId);
                    //获取用户当前已经连续签到的次数
                    var userContinuousCheckInNum = userCheckIn.continuousCheckInCount;

                    //遍历处理结果
                    foreach (var rule in from p in continuousCheckInRules where p.days == userContinuousCheckInNum select p.details.Find(o => o.userGradeId == user.grade) into rule where rule != null select rule)
                    {
                        switch (rule.type)
                        {
                            case (int)GlobalEnumVars.CheckInCommonType.积分:
                                point += rule.num;
                                //储值积分
                                await _userPointLogServices.SetPoint(entity.userId, rule.num, (int)GlobalEnumVars.UserPointSourceTypes.PointTypeSign, "日历签到，获得" + rule.num + "积分");
                                break;
                            case (int)GlobalEnumVars.CheckInCommonType.余额:
                                money += rule.num;
                                //储值余额
                                await _userBalanceServices.Change(entity.userId, (int)GlobalEnumVars.UserBalanceSourceTypes.CheckIn, rule.num, id.ToString());
                                break;
                        }
                    }

                    jm.code = 0;
                    jm.msg = "签到成功共获得" + point + "积分" + money + "余额";
                    jm.data = userCheckIn;
                    jm.otherData = cumulativeCheckInRules;
                }
                else
                {
                    jm.code = 1;
                    jm.msg = "日历签到暂未开启";
                }
            }
            catch (Exception e)
            {
                jm.code = 1;
                jm.msg = "更新失败";
                jm.data = e;
            }
            return jm;
        }

    }
}