// 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()
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Keyword), u => u.ProjectCode.Contains(input.Keyword) || u.ProjectName.Contains(input.Keyword) || u.Purchaser.Contains(input.Keyword) || u.ProcurementAgency.Contains(input.Keyword) || u.Complainant.Contains(input.Keyword) || u.ProcurementSupervisionDepartment.Contains(input.Keyword) || u.Url.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.GetFirstAsync(u => u.Id == input.Id);
|
}
|
|
/// <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();
|
|
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>();
|
await _procurementComplaintRep.AsUpdateable(entity)
|
.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;
|
}
|
}
|
}
|
