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

using System;
using System.Threading.Tasks;
using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.ViewModels.UI;
using Microsoft.Extensions.DependencyInjection;


namespace CoreCms.Net.Services
{
    /// <summary>
    /// 用户订阅提醒状态 接口实现
    /// </summary>
    public class CoreCmsUserWeChatMsgSubscriptionSwitchServices : BaseServices<CoreCmsUserWeChatMsgSubscriptionSwitch>, ICoreCmsUserWeChatMsgSubscriptionSwitchServices
    {
        private readonly ICoreCmsUserWeChatMsgSubscriptionSwitchRepository _dal;
        private readonly IServiceProvider _serviceProvider;

        private readonly IUnitOfWork _unitOfWork;
        public CoreCmsUserWeChatMsgSubscriptionSwitchServices(IUnitOfWork unitOfWork, ICoreCmsUserWeChatMsgSubscriptionSwitchRepository dal, IServiceProvider serviceProvider)
        {
            this._dal = dal;
            _serviceProvider = serviceProvider;
            base.BaseDal = dal;
            _unitOfWork = unitOfWork;
        }



        /// <summary>
        /// 获取用户是否订阅
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public async Task<WebApiCallBack> IsTip(int userId)
        {
            var jm = new WebApiCallBack { data = true, otherData = false };

            using var container = _serviceProvider.CreateScope();

            var templateServices = container.ServiceProvider.GetService<ICoreCmsUserWeChatMsgTemplateServices>();
            var subscriptionServices = container.ServiceProvider.GetService<ICoreCmsUserWeChatMsgSubscriptionServices>();

            var setting = await templateServices.QueryAsync();
            var flag = false;
            foreach (var item in setting)
            {
                if (!string.IsNullOrEmpty(item.templateId))
                {
                    flag = true;
                    jm.otherData = true;
                    break;
                }
            }
            if (flag)
            {
                var res = await _dal.QueryByClauseAsync(p => p.userId == userId);
                if (res != null)
                {
                    if (res.isSwitch) jm.data = false;
                }
                else
                {
                    var count = await subscriptionServices.GetCountAsync(p => p.userId == userId);
                    if (count == setting.Count) jm.data = false;
                }
            }
            else
            {
                jm.data = false;
            }
            jm.status = true;
            jm.msg = "获取成功";

            return jm;
        }




        /// <summary>
        /// 获取用户是否关闭订阅
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public async Task<WebApiCallBack> CloseTip(int userId)
        {
            var jm = new WebApiCallBack();

            var res = await _dal.QueryByClauseAsync(p => p.userId == userId);
            if (res != null)
            {
                await _dal.UpdateAsync(
                    p => new CoreCmsUserWeChatMsgSubscriptionSwitch() { isSwitch = true },
                    p => p.userId == userId);
            }
            else
            {
                var st = new CoreCmsUserWeChatMsgSubscriptionSwitch();
                st.isSwitch = true;
                st.userId = userId;
                await _dal.InsertAsync(st);
            }


            jm.status = true;
            jm.msg = "关闭成功";

            jm.otherData = true; //是否关闭订阅

            return jm;
        }
    }
}