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

using System;
using System.Collections.Generic;
using System.Linq;
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.FromBody;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Extensions;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using SqlSugar;

namespace CoreCms.Net.Repository
{
    /// <summary>
    /// 单页 接口实现
    /// </summary>
    public class CoreCmsPagesRepository : BaseRepository<CoreCmsPages>, ICoreCmsPagesRepository
    {
        public CoreCmsPagesRepository(IUnitOfWork unitOfWork) : base(unitOfWork)
        {
        }


        /// <summary>
        /// 重写异步插入方法
        /// </summary>
        /// <param name="entity">实体数据</param>
        /// <returns></returns>
        public async Task<AdminUiCallBack> InsertAsync(CoreCmsPages entity)
        {
            var jm = new AdminUiCallBack();

            var have = await DbClient.Queryable<CoreCmsPages>().Where(p => p.code == entity.code).With(SqlWith.NoLock).AnyAsync();
            if (have)
            {
                jm.msg = "存在相同【区域编码】请更正";
                return jm;
            }

            entity.code = entity.code.Trim();

            var id = await DbClient.Insertable(entity).ExecuteReturnIdentityAsync();
            var bl = id > 0;

            if (bl && entity.type == 1)
            {
                //如果设为新默认，则修改其他为非默认。
                await DbClient.Updateable<CoreCmsPages>().Where(p => p.type == 1 && p.id != id).SetColumns(p => new CoreCmsPages() { type = 2 }).ExecuteCommandAsync();
            }

            jm.code = bl ? 0 : 1;
            jm.msg = bl ? GlobalConstVars.CreateSuccess : GlobalConstVars.CreateFailure;

            return jm;
        }

        /// <summary>
        /// 重写异步更新方法
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public async Task<AdminUiCallBack> UpdateAsync(CoreCmsPages entity)
        {
            var jm = new AdminUiCallBack();

            var have = await DbClient.Queryable<CoreCmsPages>().Where(p => p.code == entity.code && p.id != entity.id).With(SqlWith.NoLock).AnyAsync();
            if (have)
            {
                jm.msg = "存在相同【区域编码】请更正";
                return jm;
            }
            var oldModel = await DbClient.Queryable<CoreCmsPages>().In(entity.id).SingleAsync();
            if (oldModel == null)
            {
                jm.msg = "不存在此信息";
                return jm;
            }
            //事物处理过程开始
            var oldType = oldModel.type;
            var newType = entity.type;

            oldModel.code = entity.code;
            oldModel.name = entity.name;
            oldModel.description = entity.description;
            oldModel.layout = entity.layout;
            oldModel.type = entity.type;

            //事物处理过程结束
            var bl = await DbClient.Updateable(oldModel).ExecuteCommandHasChangeAsync();

            if (bl)
            {
                //如果不是默认的情况下
                if (oldType == 1 && newType != 1)
                {
                    //判断修改当前，而是否其他有默认
                    var haveDefault = await DbClient.Queryable<CoreCmsPages>().Where(p => p.type == 1 && p.id != oldModel.id).With(SqlWith.NoLock).AnyAsync();
                    //如果不存在，则当前不能调整为非默认。
                    if (!haveDefault)
                    {
                        await DbClient.Updateable<CoreCmsPages>().Where(p => p.id == oldModel.id).SetColumns(p => new CoreCmsPages() { type = 1 }).ExecuteCommandAsync();
                    }
                }
                //如果设为新默认，则修改其他为非默认。
                if (newType == 1)
                {
                    await DbClient.Updateable<CoreCmsPages>().Where(p => p.id != oldModel.id).SetColumns(p => new CoreCmsPages() { type = 2 }).ExecuteCommandAsync();
                }
            }


            jm.code = bl ? 0 : 1;
            jm.msg = bl ? GlobalConstVars.EditSuccess : GlobalConstVars.EditFailure;

            return jm;
        }

        /// <summary>
        /// 重写删除指定ID的数据
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<AdminUiCallBack> DeleteByIdAsync(int id)
        {
            var jm = new AdminUiCallBack();

            var model = await DbClient.Queryable<CoreCmsPages>().Where(p => p.id == id).FirstAsync();
            if (model == null)
            {
                jm.msg = GlobalConstVars.DataisNo;
                return jm;
            }
            if (model.type == 1)
            {
                jm.msg = "默认页面禁止删除";
                return jm;
            }

            var count = await DbClient.Queryable<CoreCmsPages>().CountAsync();
            if (count == 1)
            {
                jm.msg = "只有一个页面了，别删了。";
                return jm;
            }

            var bl = await DbClient.Deleteable<CoreCmsPages>(id).ExecuteCommandHasChangeAsync();
            if (bl)
            {
                await DbClient.Deleteable<CoreCmsPagesItems>().Where(p => p.pageCode == model.code).ExecuteCommandAsync();
            }
            jm.code = bl ? 0 : 1;
            jm.msg = bl ? GlobalConstVars.DeleteSuccess : GlobalConstVars.DeleteFailure;

            return jm;
        }


        /// <summary>
        /// 复制一个同样的数据
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<AdminUiCallBack> CopyByIdAsync(int id)
        {
            var jm = new AdminUiCallBack();

            var model = await DbClient.Queryable<CoreCmsPages>().Where(p => p.id == id).FirstAsync();
            if (model == null)
            {
                jm.msg = GlobalConstVars.DataisNo;
                return jm;
            }
            var oldCode = model.code;
            model.type = 2;
            model.code = model.code + DateTime.Now.ToString("yyyyMMddHHmmssfffff");
            model.name = model.name + "（复制）";

            var items = await DbClient.Queryable<CoreCmsPagesItems>().Where(p => p.pageCode == oldCode).ToListAsync();
            foreach (var item in items)
            {
                item.pageCode = model.code;
            }

            var bl = await DbClient.Insertable<CoreCmsPages>(model).ExecuteReturnIdentityAsync() > 0;
            if (bl)
            {
                await DbClient.Insertable<CoreCmsPagesItems>(items).ExecuteCommandAsync();
            }
            jm.code = bl ? 0 : 1;
            jm.msg = bl ? GlobalConstVars.DeleteSuccess : GlobalConstVars.DeleteFailure;

            return jm;
        }



        #region 更新设计==========================================================

        /// <summary>
        /// 更新设计
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public async Task<AdminUiCallBack> UpdateDesignAsync(FmPagesUpdate entity)
        {
            var jm = new AdminUiCallBack();

            var bl = false;

            var oldModel = await DbClient.Queryable<CoreCmsPages>().Where(p => p.code == entity.pageCode).SingleAsync();
            if (oldModel == null)
            {
                jm.msg = "不存在此信息";
                return jm;
            }
            //事物处理过程开始

            bl = await DbClient.Deleteable<CoreCmsPagesItems>().Where(p => p.pageCode == entity.pageCode).ExecuteCommandHasChangeAsync();
            var list = new List<CoreCmsPagesItems>();
            var count = 0;
            entity.datalist.ForEach(p =>
            {
                var model = new CoreCmsPagesItems
                {
                    widgetCode = p.sType,
                    pageCode = entity.pageCode,
                    positionId = count,
                    sort = count + 1,
                    parameters = p.sValue
                };
                list.Add(model);
                count++;
            });

            if (list.Any())
            {
                bl = await DbClient.Insertable(list).ExecuteCommandAsync() > 0;
            }
            //事物处理过程结束
            jm.code = bl ? 0 : 1;
            jm.msg = bl ? GlobalConstVars.EditSuccess : GlobalConstVars.EditFailure;


            return jm;
        }

        #endregion
    }
}