// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
//
// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
//
// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！

using Admin.NET.Core.Service;
using Microsoft.AspNetCore.Http;

using Furion.DatabaseAccessor;
using Furion.FriendlyException;
using Mapster;
using SqlSugar;
using System.ComponentModel;
using System.ComponentModel.DataAnnotations;
using Microsoft.AspNetCore.Mvc;
using Admin.NET.Application;
using Admin.NET.Core;
using FZCZTB.NET.MD;
using Furion.DynamicApiController;
using Furion.DependencyInjection;
using System.Collections.Generic;
using System.Linq;
using NewLife.Xml;
using AngleSharp.Dom;
namespace FZCZTB.TSCL.Application;

/// <summary>
/// 政府采购投诉数据处理服务 🧩
/// </summary>
[ApiDescriptionSettings(ApplicationConst.GroupName, Order = 100)]
public class ProcurementComplaintService : IDynamicApiController, ITransient
{
    private readonly SqlSugarRepository<ProcurementComplaint> _procurementComplaintRep;
    private readonly ISqlSugarClient _sqlSugarClient;

    public ProcurementComplaintService(SqlSugarRepository<ProcurementComplaint> procurementComplaintRep, ISqlSugarClient sqlSugarClient)
    {
        _procurementComplaintRep = procurementComplaintRep;
        _sqlSugarClient = sqlSugarClient;
    }

    /// <summary>
    /// 分页查询政府采购投诉数据处理 🔖
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [DisplayName("分页查询政府采购投诉数据处理")]
    [ApiDescriptionSettings(Name = "Page"), HttpPost]
    public async Task<SqlSugarPagedList<ProcurementComplaintOutput>> Page(PageProcurementComplaintInput input)
    {
        input.Keyword = input.Keyword?.Trim();
        var query = _procurementComplaintRep.AsQueryable().Includes(x=>x.Complaints)
            .WhereIF(!string.IsNullOrWhiteSpace(input.Keyword), u => u.Complaints.Any(uu=>uu.ItemDescription.Contains(input.Keyword)))
            .WhereIF(!string.IsNullOrWhiteSpace(input.ProjectCode), u => u.ProjectCode.Contains(input.ProjectCode.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.ProjectName), u => u.ProjectName.Contains(input.ProjectName.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Purchaser), u => u.Purchaser.Contains(input.Purchaser.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.ProcurementAgency), u => u.ProcurementAgency.Contains(input.ProcurementAgency.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Complainant), u => u.Complainant.Contains(input.Complainant.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.ProcurementSupervisionDepartment), u => u.ProcurementSupervisionDepartment.Contains(input.ProcurementSupervisionDepartment.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Url), u => u.Url.Contains(input.Url.Trim()))
            .WhereIF(input.DecisionDateRange?.Length == 2, u => u.DecisionDate >= input.DecisionDateRange[0] && u.DecisionDate <= input.DecisionDateRange[1])
            .Select<ProcurementComplaintOutput>();
		return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
    }

    /// <summary>
    /// 获取政府采购投诉数据处理详情 ℹ️
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [DisplayName("获取政府采购投诉数据处理详情")]
    [ApiDescriptionSettings(Name = "Detail"), HttpGet]
    public async Task<ProcurementComplaint> Detail([FromQuery] QueryByIdProcurementComplaintInput input)
    {
     
        return await _procurementComplaintRep.AsQueryable().Where(x=>x.Id==input.Id).Includes(x=>x.Complaints.OrderBy(xx=>xx.sort).ToList()).FirstAsync();
    }

    /// <summary>
    /// 增加政府采购投诉数据处理 ➕
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [DisplayName("增加政府采购投诉数据处理")]
    [ApiDescriptionSettings(Name = "Add"), HttpPost]
    public async Task<bool> Add(AddProcurementComplaintInput input)
    {
        var entity = input.Adapt<ProcurementComplaint>();
        entity.Id = Guid.NewGuid();
        int index = 0;
        if (entity.Complaints != null)
            foreach (var item in entity.Complaints)
        {
            item.Id = Guid.NewGuid();
                item.sort = index++;
            }

        return await _sqlSugarClient.InsertNav(entity).Include(x=>x.Complaints).ExecuteCommandAsync();
    }

    /// <summary>
    /// 更新政府采购投诉数据处理 ✏️
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [DisplayName("更新政府采购投诉数据处理")]
    [ApiDescriptionSettings(Name = "Update"), HttpPost]
    public async Task Update(UpdateProcurementComplaintInput input)
    {
        var entity = input.Adapt<ProcurementComplaint>();
        int index = 0;
        if(entity.Complaints!=null)
        foreach (var item in entity.Complaints)
        {
            item.Id = Guid.NewGuid();
            item.sort=    index++;
        }
        await _procurementComplaintRep.AsSugarClient().UpdateNav(entity).Include(x=>x.Complaints)
        .ExecuteCommandAsync();
    }

    /// <summary>
    /// 删除政府采购投诉数据处理 ❌
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [DisplayName("删除政府采购投诉数据处理")]
    [ApiDescriptionSettings(Name = "Delete"), HttpPost]
    public async Task Delete(DeleteProcurementComplaintInput input)
    {
        //var entity = await _procurementComplaintRep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
        var entity = await _sqlSugarClient.Queryable<ProcurementComplaint>().Includes(x=>x.Complaints).Where(x=>x.Id== input.Id).FirstAsync() ?? throw Oops.Oh(ErrorCodeEnum.D1002);
        //await _procurementComplaintRep.FakeDeleteAsync(entity);   //假删除
        await _sqlSugarClient.DeleteNav(entity).Include(x => x.Complaints).ExecuteCommandAsync();   //真删除
    }

    /// <summary>
    /// 批量删除政府采购投诉数据处理 ❌
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [DisplayName("批量删除政府采购投诉数据处理")]
    [ApiDescriptionSettings(Name = "BatchDelete"), HttpPost]
    public async Task<bool > BatchDelete([Required(ErrorMessage = "主键列表不能为空")]List<DeleteProcurementComplaintInput> input)
    {
        var exp = Expressionable.Create<ProcurementComplaint>();
        foreach (var row in input) exp = exp.Or(it => it.Id == row.Id);
        var list = await _procurementComplaintRep.AsQueryable().Where(exp.ToExpression()).ToListAsync();

        // return await _procurementComplaintRep.FakeDeleteAsync(list);   //假删除
        return await _sqlSugarClient.DeleteNav(list).Include(x => x.Complaints).ExecuteCommandAsync(); ;   //真删除
    }
    
    /// <summary>
    /// 导出政府采购投诉数据处理记录 🔖
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [DisplayName("导出政府采购投诉数据处理记录")]
    [ApiDescriptionSettings(Name = "Export"), HttpPost, NonUnify]
    public async Task<IActionResult> Export(PageProcurementComplaintInput input)
    {
        var list = (await Page(input)).Items?.Adapt<List<ExportProcurementComplaintOutput>>() ?? new();
        //if (input.SelectKeyList?.Count > 0) list = list.Where(x => input.SelectKeyList.Contains(x.Id)).ToList();
        return ExcelHelper.ExportTemplate(list, "政府采购投诉数据处理导出记录");
    }
    
    /// <summary>
    /// 下载政府采购投诉数据处理数据导入模板 ⬇️
    /// </summary>
    /// <returns></returns>
    [DisplayName("下载政府采购投诉数据处理数据导入模板")]
    [ApiDescriptionSettings(Name = "Import"), HttpGet, NonUnify]
    public IActionResult DownloadTemplate()
    {
        return ExcelHelper.ExportTemplate(new List<ExportProcurementComplaintOutput>(), "政府采购投诉数据处理导入模板");
    }
    
    private static readonly object _procurementComplaintImportLock = new object();
    /// <summary>
    /// 导入政府采购投诉数据处理记录 💾
    /// </summary>
    /// <returns></returns>
    //[DisplayName("导入政府采购投诉数据处理记录")]
    //[ApiDescriptionSettings(Name = "Import"), HttpPost, NonUnify, UnitOfWork]
    //public IActionResult ImportData([Required] IFormFile file)
    //{
    //    lock (_procurementComplaintImportLock)
    //    {
    //        var stream = ExcelHelper.ImportData<ImportProcurementComplaintInput, ProcurementComplaint>(file, (list, markerErrorAction) =>
    //        {
    //            _sqlSugarClient.Utilities.PageEach(list, 2048, pageItems =>
    //            {
                    
    //                // 校验并过滤必填基本类型为null的字段
    //                var rows = pageItems.Where(x => {
    //                    return true;
    //                }).Adapt<List<ProcurementComplaint>>();
                    
    //                var storageable = _procurementComplaintRep.Context.Storageable(rows)
    //                    .SplitError(it => string.IsNullOrWhiteSpace(it.Item.ProjectCode), "项目编号不能为空")
    //                    .SplitError(it => it.Item.ProjectCode?.Length > 50, "项目编号长度不能超过50个字符")
    //                    .SplitError(it => string.IsNullOrWhiteSpace(it.Item.ProjectName), "项目名称不能为空")
    //                    .SplitError(it => it.Item.ProjectName?.Length > 200, "项目名称长度不能超过200个字符")
    //                    .SplitError(it => string.IsNullOrWhiteSpace(it.Item.Purchaser), "采购人不能为空")
    //                    .SplitError(it => it.Item.Purchaser?.Length > 100, "采购人长度不能超过100个字符")
    //                    .SplitError(it => string.IsNullOrWhiteSpace(it.Item.ProcurementAgency), "采购代理机构不能为空")
    //                    .SplitError(it => it.Item.ProcurementAgency?.Length > 100, "采购代理机构长度不能超过100个字符")
    //                    .SplitError(it => it.Item.Complainant?.Length > 100, "投诉人长度不能超过100个字符")
    //                    .SplitError(it => it.Item.ProcurementSupervisionDepartment?.Length > 100, "采购监督部门长度不能超过100个字符")
    //                    .SplitError(it => it.Item.Url?.Length > 255, "线上地址长度不能超过255个字符")
    //                    .SplitInsert(_ => true)
    //                    .ToStorage();
                    
    //                storageable.AsInsertable.ExecuteCommand();// 不存在插入
    //                storageable.AsUpdateable.ExecuteCommand();// 存在更新
                    
    //                // 标记错误信息
    //                markerErrorAction.Invoke(storageable, pageItems, rows);
    //            });
    //        });
            
    //        return stream;
    //    }
    //}
}