using DS.Module.Core;
using DS.Module.Core.Data;
using DS.Module.Core.Extensions;
using DS.WMS.Core.Op.Entity.TaskInteraction;
using DS.WMS.Core.Op.Interface.TaskInteraction;

namespace DS.WMS.Core.Op.Method.TaskInteraction
{
    /// <summary>
    /// 邮件配置服务
    /// </summary>
    public class TaskMailService : ServiceBase, ITaskMailService
    {
        /// <summary>
        /// 初始化
        /// </summary>
        /// <param name="provider"></param>
        public TaskMailService(IServiceProvider provider) : base(provider)
        {
        }

        /// <summary>
        /// 获取分页列表
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public async Task<DataResult<List<BusinessTaskMail>>> GetListAsync(PageRequest request)
        {
            var whereList = request.GetConditionalModels(Db);
            return await TenantDb.Queryable<BusinessTaskMail>().Includes(x => x.Receiver).Includes(x => x.Sender)
                .Where(whereList).ToQueryPageAsync(request.PageCondition);
        }

        /// <summary>
        /// 详情
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<DataResult<BusinessTaskMail>> GetAsync(long id)
        {
            var entity = await TenantDb.Queryable<BusinessTaskMail>()
                .Includes(x => x.Receiver).Includes(x => x.Sender).Includes(x => x.Attachments)
                .Where(x => x.Id == id).FirstAsync();

            return DataResult<BusinessTaskMail>.Success(entity);
        }

        /// <summary>
        /// 根据配置名获取
        /// </summary>
        /// <param name="name"></param>
        /// <returns></returns>
        public async Task<BusinessTaskMail> GetAsync(string name)
        {
            return await TenantDb.Queryable<BusinessTaskMail>()
                .Includes(x => x.Receiver).Includes(x => x.Sender).Includes(x => x.Attachments)
                .Where(x => x.Name == name).FirstAsync();
        }

        /// <summary>
        /// 编辑
        /// </summary>
        /// <param name="taskMail"></param>
        /// <returns></returns>
        public async Task<DataResult> EditAsync(BusinessTaskMail taskMail)
        {
            await TenantDb.Ado.BeginTranAsync();
            try
            {
                if (taskMail.Id == 0)
                {
                    taskMail.Receiver ??= new();
                    taskMail.Sender ??= new();

                    taskMail = await TenantDb.InsertNav(taskMail).Include(x => x.Receiver).Include(x => x.Sender).ExecuteReturnEntityAsync();
                }
                else
                {
                    await TenantDb.UpdateNav(taskMail).Include(x => x.Receiver).Include(x => x.Sender).ExecuteCommandAsync();
                }

                if (taskMail.Attachments?.Count > 0)
                {
                    var list = taskMail.Attachments.FindAll(x => x.TaskMailId == 0);
                    foreach (var item in list)
                        item.TaskMailId = taskMail.Id;

                    await TenantDb.Deleteable<BusinessTaskAttachment>().Where(x => x.TaskMailId == taskMail.Id).ExecuteCommandAsync();
                    await TenantDb.Insertable(taskMail.Attachments).ExecuteCommandAsync();
                }

                await TenantDb.Ado.CommitTranAsync();
                return DataResult.Success;
            }
            catch (Exception ex)
            {
                await TenantDb.Ado.RollbackTranAsync();
                await ex.LogAsync(Db);
                return DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed));
            }

        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public async Task<DataResult> DeleteAsync(IdModel model)
        {
            await TenantDb.Ado.BeginTranAsync();
            try
            {
                await TenantDb.DeleteNav<BusinessTaskMail>(x => model.Ids.Contains(x.Id))
                    .Include(x => x.Receiver).Include(x => x.Sender).Include(x => x.Attachments)
                    .ExecuteCommandAsync();

                await TenantDb.Ado.CommitTranAsync();
                return DataResult.Success;
            }
            catch (Exception ex)
            {
                await TenantDb.Ado.RollbackTranAsync();
                await ex.LogAsync(Db);
                return DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed));
            }
        }


    }
}