/***********************************************************************
 *            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.Threading.Tasks;
using CoreCms.Net.Caching.Manual;
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.Basics;
using CoreCms.Net.Model.ViewModels.UI;
using SqlSugar;

namespace CoreCms.Net.Repository
{
    /// <summary>
    /// 表单 接口实现
    /// </summary>
    public class CoreCmsFormRepository : BaseRepository<CoreCmsForm>, ICoreCmsFormRepository
    {
        public CoreCmsFormRepository(IUnitOfWork unitOfWork) : base(unitOfWork)
        {
        }

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

            var check = CheckItems(entity.items);
            if (check.code == 1)
            {
                return check;
            }

            entity.model.createTime = DateTime.Now;

            var id = await DbClient.Insertable(entity.model).ExecuteReturnIdentityAsync();
            entity.items.ForEach(p =>
            {
                p.formId = id;
            });

            var bl = await DbClient.Insertable(entity.items).ExecuteCommandAsync() > 0;

            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(FMForm entity)
        {
            var jm = new AdminUiCallBack();

            var check = CheckItems(entity.items);
            if (check.code == 1)
            {
                return check;
            }

            var oldModel = await DbClient.Queryable<CoreCmsForm>().In(entity.model.id).SingleAsync();
            if (oldModel == null)
            {
                jm.msg = "不存在此信息";
                return jm;
            }
            //事物处理过程开始
            //oldModel.id = entity.model.id;
            oldModel.name = entity.model.name;
            oldModel.type = entity.model.type;
            oldModel.sort = entity.model.sort;
            oldModel.images = entity.model.images;
            oldModel.videoPath = entity.model.videoPath;
            oldModel.description = entity.model.description;
            oldModel.headType = entity.model.headType;
            oldModel.headTypeValue = entity.model.headTypeValue;
            oldModel.headTypeVideo = entity.model.headTypeVideo;
            oldModel.buttonName = entity.model.buttonName;
            oldModel.buttonColor = entity.model.buttonColor;
            oldModel.isLogin = entity.model.isLogin;
            oldModel.times = entity.model.times;
            //oldModel.qrcode = entity.model.qrcode;
            oldModel.returnMsg = entity.model.returnMsg;
            oldModel.endDateTime = entity.model.endDateTime;
            //oldModel.createTime = entity.model.createTime;
            oldModel.updateTime = DateTime.Now;

            //事物处理过程结束
            var bl = await DbClient.Updateable(oldModel).ExecuteCommandHasChangeAsync();
            jm.code = bl ? 0 : 1;
            jm.msg = bl ? GlobalConstVars.EditSuccess : GlobalConstVars.EditFailure;
            if (bl)
            {
                //查询已经存在的数据
                var items = await DbClient.Queryable<CoreCmsFormItem>().Where(p => p.formId == oldModel.id).ToListAsync();
                //找到提交的数据是否有老数据
                var oldPostItems = entity.items.Where(p => p.id > 0).ToList();
                if (oldPostItems.Any())
                {
                    var oldPostItemsIds = oldPostItems.Select(p => p.id).ToList();
                    //找到数据库中和提交的数据库中都不存在差集数据进行删除
                    var deletes = items.Where(p => !oldPostItemsIds.Contains(p.id)).ToList();
                    if (deletes.Any())
                    {
                        await DbClient.Deleteable<CoreCmsFormItem>(deletes).ExecuteCommandHasChangeAsync();
                    }
                    //对提交的老数据进行更新处理
                    var oldDataItems = items.Where(p => oldPostItemsIds.Contains(p.id)).ToList();
                    if (oldDataItems.Any())
                    {
                        oldDataItems.ForEach(p =>
                        {
                            var child = oldPostItems.Find(o => o.id == p.id);
                            if (child != null)
                            {
                                p.name = child.name;
                                p.type = child.type;
                                p.validationType = child.validationType;
                                p.value = child.value;
                                p.defaultValue = child.defaultValue;
                                //p.formId = child.formId;
                                p.required = child.required;
                                p.sort = child.sort;

                            }
                        });
                        await DbClient.Updateable(oldDataItems).ExecuteCommandHasChangeAsync();
                    }
                }
                else
                {
                    await DbClient.Deleteable<CoreCmsFormItem>(items).ExecuteCommandHasChangeAsync();
                }

                //新数据
                var newPostItems = entity.items.Where(p => p.id == 0).ToList();
                if (newPostItems.Any())
                {
                    entity.items.ForEach(p =>
                    {
                        p.formId = oldModel.id;
                    });
                    await DbClient.Insertable(newPostItems).ExecuteCommandAsync();
                }
            }
            return jm;
        }

        public AdminUiCallBack CheckItems(List<CoreCmsFormItem> items)
        {
            var jm = new AdminUiCallBack();

            if (!items.Any())
            {
                jm.msg = "请添加字段数据";
                return jm;
            }

            foreach (var item in items)
            {
                if (string.IsNullOrEmpty(item.name))
                {
                    jm.msg = "字段名称不能为空";
                    return jm;
                }

                if (!string.IsNullOrEmpty(item.defaultValue))
                {
                    item.defaultValue = item.defaultValue.Trim();
                    item.defaultValue = item.defaultValue.Replace("，", ",");
                }
                if (!string.IsNullOrEmpty(item.value))
                {
                    item.value = item.value.Trim();
                    item.value = item.value.Replace("，", ",");
                }

                if (item.type == GlobalEnumVars.FormFieldTypes.goods.ToString() && string.IsNullOrEmpty(item.value))
                {
                    jm.msg = "【商品】字段必须要选择商品";
                    return jm;
                }
                else if (item.type == GlobalEnumVars.FormFieldTypes.radio.ToString() && string.IsNullOrEmpty(item.value))
                {
                    jm.msg = "【单选】字段必须要至少有二个以上值,并且以逗号分隔";
                    return jm;
                }
                else if (item.type == GlobalEnumVars.FormFieldTypes.radio.ToString() && !string.IsNullOrEmpty(item.value))
                {
                    var arr = item.value.Split(",");
                    if (arr.Length < 2)
                    {
                        jm.msg = "【单选】字段必须要至少有二个以上值,并且以逗号分隔";
                        return jm;
                    }
                }
                else if (item.type == GlobalEnumVars.FormFieldTypes.checbox.ToString() && string.IsNullOrEmpty(item.value))
                {
                    jm.msg = "【多选项】字段必须要至少有二个或以上值,并且以逗号分隔";
                    return jm;
                }
                else if (item.type == GlobalEnumVars.FormFieldTypes.checbox.ToString() && !string.IsNullOrEmpty(item.value))
                {
                    var arr = item.value.Split(",");
                    if (arr.Length < 2)
                    {
                        jm.msg = "【多选项】字段必须要至少有二个词组或以上值,并且以逗号分隔";
                        return jm;
                    }
                }
                else if (item.type == GlobalEnumVars.FormFieldTypes.date.ToString())
                {
                    //没有值的时候设置下默认值
                }
                else if (item.type == GlobalEnumVars.FormFieldTypes.time.ToString())
                {
                    //没有值的时候设置下默认值
                }
            }

            jm.code = 0;

            return jm;
        }

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

            var isHaveSubmitData = await DbClient.Queryable<CoreCmsFormSubmit>().AnyAsync(p => p.formId == id);
            if (isHaveSubmitData)
            {
                jm.msg = "此表单已经存在用户提交数据，禁止删除";
                return jm;
            }


            var bl = await DbClient.Deleteable<CoreCmsForm>(id).ExecuteCommandHasChangeAsync();
            jm.code = bl ? 0 : 1;
            jm.msg = bl ? GlobalConstVars.DeleteSuccess : GlobalConstVars.DeleteFailure;
            if (bl)
            {
                await DbClient.Deleteable<CoreCmsFormItem>().Where(p => p.formId == id).ExecuteCommandHasChangeAsync();
            }

            return jm;
        }

        /// <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<CoreCmsForm>> QueryPageAsync(Expression<Func<CoreCmsForm, bool>> predicate,
            Expression<Func<CoreCmsForm, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
            int pageSize = 20, bool blUseNoLock = false)
        {
            RefAsync<int> totalCount = 0;
            List<CoreCmsForm> page;
            if (blUseNoLock)
            {
                page = await DbClient.Queryable<CoreCmsForm>()
                .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                .WhereIF(predicate != null, predicate).Select(p => new CoreCmsForm
                {
                    id = p.id,
                    name = p.name,
                    type = p.type,
                    sort = p.sort,
                    images = p.images,
                    videoPath = p.videoPath,
                    description = p.description,
                    headType = p.headType,
                    headTypeValue = p.headTypeValue,
                    headTypeVideo = p.headTypeVideo,
                    buttonName = p.buttonName,
                    buttonColor = p.buttonColor,
                    isLogin = p.isLogin,
                    times = p.times,
                    qrcode = p.qrcode,
                    returnMsg = p.returnMsg,
                    endDateTime = p.endDateTime,
                    createTime = p.createTime,
                    updateTime = p.updateTime,
                })
                .Mapper(it => it.Items, it => it.Items.First().formId)
                .With(SqlWith.NoLock).ToPageListAsync(pageIndex, pageSize, totalCount);
            }
            else
            {
                page = await DbClient.Queryable<CoreCmsForm>()
                .OrderByIF(orderByExpression != null, orderByExpression, orderByType)
                .WhereIF(predicate != null, predicate).Select(p => new CoreCmsForm
                {
                    id = p.id,
                    name = p.name,
                    type = p.type,
                    sort = p.sort,
                    images = p.images,
                    videoPath = p.videoPath,
                    description = p.description,
                    headType = p.headType,
                    headTypeValue = p.headTypeValue,
                    headTypeVideo = p.headTypeVideo,
                    buttonName = p.buttonName,
                    buttonColor = p.buttonColor,
                    isLogin = p.isLogin,
                    times = p.times,
                    qrcode = p.qrcode,
                    returnMsg = p.returnMsg,
                    endDateTime = p.endDateTime,
                    createTime = p.createTime,
                    updateTime = p.updateTime,

                })
                .Mapper(it => it.Items, it => it.Items.First().formId)
                .ToPageListAsync(pageIndex, pageSize, totalCount);
            }
            var list = new PageList<CoreCmsForm>(page, pageIndex, pageSize, totalCount);
            return list;
        }

    }
}