netcore/src/Modularity/Extend/NCC.Extend/LqXmzlService.cs

using NCC.Common.Core.Manager;
using NCC.Common.Enum;
using NCC.Common.Extension;
using NCC.Common.Filter;
using NCC.Dependency;
using NCC.DynamicApiController;
using NCC.FriendlyException;
using NCC.Extend.Interfaces.LqXmzl;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using NCC.Extend.Entitys.lq_xmzl;
using NCC.Extend.Entitys.Dto.LqXmzl;
using Yitter.IdGenerator;
using NCC.Common.Helper;
using NCC.JsonSerialization;
using NCC.Common.Model.NPOI;
using NCC.Common.Configuration;
using NCC.DataEncryption;
using NCC.ClayObject;
namespace NCC.Extend.LqXmzl
{
    /// <summary>
    /// 项目资料服务
    /// </summary>
    [ApiDescriptionSettings(Tag = "绿纤项目资料服务", Name = "LqXmzl", Order = 200)]
    [Route("api/Extend/[controller]")]
    public class LqXmzlService : ILqXmzlService, IDynamicApiController, ITransient
    {
        private readonly ISqlSugarRepository<LqXmzlEntity> _lqXmzlRepository;
        private readonly SqlSugarScope _db;
        private readonly IUserManager _userManager;
        /// <summary>
        /// 初始化一个<see cref="LqXmzlService"/>类型的新实例
        /// </summary>
        public LqXmzlService(ISqlSugarRepository<LqXmzlEntity> lqXmzlRepository, IUserManager userManager)
        {
            _lqXmzlRepository = lqXmzlRepository;
            _db = _lqXmzlRepository.Context;
            _userManager = userManager;
        }
        #region 获取项目资料
        /// <summary>
        /// 获取项目资料
        /// </summary>
        /// <param name="id">参数</param>
        /// <returns></returns>
        [HttpGet("{id}")]
        public async Task<dynamic> GetInfo(string id)
        {
            var entity = await _db.Queryable<LqXmzlEntity>().FirstAsync(p => p.Id == id);
            var output = entity.Adapt<LqXmzlInfoOutput>();
            return output;
        }
        #endregion
        #region 获取项目资料列表
        /// <summary>
        /// 获取项目资料列表
        /// </summary>
        /// <param name="input">请求参数</param>
        /// <returns></returns>
        [HttpGet("")]
        public async Task<dynamic> GetList([FromQuery] LqXmzlListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            var data = await _db.Queryable<LqXmzlEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                .WhereIF(!string.IsNullOrEmpty(input.xmbh), p => p.Xmbh.Contains(input.xmbh))
                .WhereIF(!string.IsNullOrEmpty(input.xmmc), p => p.Xmmc.Contains(input.xmmc))
                .WhereIF(!string.IsNullOrEmpty(input.bzjg), p => p.Bzjg.Equals(input.bzjg))
                .WhereIF(!string.IsNullOrEmpty(input.xmsc), p => p.Xmsc.Equals(input.xmsc))
                .WhereIF(!string.IsNullOrEmpty(input.jcfwtc), p => p.Jcfwtc.Equals(input.jcfwtc))
                .WhereIF(!string.IsNullOrEmpty(input.fl1), p => p.Fl1.Contains(input.fl1))
                .WhereIF(!string.IsNullOrEmpty(input.fl2), p => p.Fl2.Contains(input.fl2))
                .WhereIF(!string.IsNullOrEmpty(input.fl3), p => p.Fl3.Contains(input.fl3))
                .WhereIF(!string.IsNullOrEmpty(input.fl4), p => p.Fl4.Contains(input.fl4))
                .WhereIF(!string.IsNullOrEmpty(input.fl), p => p.Fl.Contains(input.fl))
                .WhereIF(!string.IsNullOrEmpty(input.qt1), p => p.Qt1.Contains(input.qt1))
                .WhereIF(!string.IsNullOrEmpty(input.qt2), p => p.Qt2.Contains(input.qt2))
                .WhereIF(!string.IsNullOrEmpty(input.sgf), p => p.Sgf.Equals(input.sgf))
                .WhereIF(!string.IsNullOrEmpty(input.beautyType), p => p.BeautyType.Contains(input.beautyType))
                .WhereIF(input.isEffective != 0, p => p.IsEffective.Equals(input.isEffective))
                .WhereIF(!string.IsNullOrEmpty(input.sourceType), p => p.SourceType.Contains(input.sourceType))
                .Select(it => new LqXmzlListOutput
                {
                    id = it.Id,
                    xmbh = it.Xmbh,
                    xmmc = it.Xmmc,
                    bzjg = it.Bzjg,
                    xmsc = it.Xmsc,
                    jcfwtc = it.Jcfwtc,
                    fl1 = it.Fl1,
                    fl2 = it.Fl2,
                    fl3 = it.Fl3,
                    fl4 = it.Fl4,
                    fl = it.Fl,
                    qt1 = it.Qt1,
                    qt2 = it.Qt2,
                    sgf = it.Sgf,
                    beautyType = it.BeautyType,
                    sourceType = it.SourceType,
                    isEffective = it.IsEffective,
                }).MergeTable().OrderBy(sidx + " " + input.sort).ToPagedListAsync(input.currentPage, input.pageSize);
            return PageResult<LqXmzlListOutput>.SqlSugarPageResult(data);
        }
        #endregion
        #region 新建项目资料
        /// <summary>
        /// 新建项目资料
        /// </summary>
        /// <param name="input">参数</param>
        /// <returns></returns>
        [HttpPost("")]
        public async Task Create([FromBody] LqXmzlCrInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var entity = input.Adapt<LqXmzlEntity>();
            entity.Id = YitIdHelper.NextId().ToString();
            var isOk = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
            if (!(isOk > 0)) throw NCCException.Oh(ErrorCode.COM1000);
        }
        #endregion
        #region 获取项目资料无分页列表
        /// <summary>
        /// 获取项目资料无分页列表
        /// </summary>
        /// <param name="input">请求参数</param>
        /// <returns></returns>
        [NonAction]
        public async Task<dynamic> GetNoPagingList([FromQuery] LqXmzlListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            var data = await _db.Queryable<LqXmzlEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                .WhereIF(!string.IsNullOrEmpty(input.xmbh), p => p.Xmbh.Contains(input.xmbh))
                .WhereIF(!string.IsNullOrEmpty(input.xmmc), p => p.Xmmc.Contains(input.xmmc))
                .WhereIF(!string.IsNullOrEmpty(input.bzjg), p => p.Bzjg.Equals(input.bzjg))
                .WhereIF(!string.IsNullOrEmpty(input.xmsc), p => p.Xmsc.Equals(input.xmsc))
                .WhereIF(!string.IsNullOrEmpty(input.jcfwtc), p => p.Jcfwtc.Equals(input.jcfwtc))
                .WhereIF(!string.IsNullOrEmpty(input.fl1), p => p.Fl1.Contains(input.fl1))
                .WhereIF(!string.IsNullOrEmpty(input.fl2), p => p.Fl2.Contains(input.fl2))
                .WhereIF(!string.IsNullOrEmpty(input.fl3), p => p.Fl3.Contains(input.fl3))
                .WhereIF(!string.IsNullOrEmpty(input.fl4), p => p.Fl4.Contains(input.fl4))
                .WhereIF(!string.IsNullOrEmpty(input.fl), p => p.Fl.Contains(input.fl))
                .WhereIF(!string.IsNullOrEmpty(input.qt1), p => p.Qt1.Contains(input.qt1))
                .WhereIF(!string.IsNullOrEmpty(input.qt2), p => p.Qt2.Contains(input.qt2))
                .WhereIF(!string.IsNullOrEmpty(input.sgf), p => p.Sgf.Equals(input.sgf))
                .Select(it => new LqXmzlListOutput
                {
                    id = it.Id,
                    xmbh = it.Xmbh,
                    xmmc = it.Xmmc,
                    bzjg = it.Bzjg,
                    xmsc = it.Xmsc,
                    jcfwtc = it.Jcfwtc,
                    fl1 = it.Fl1,
                    fl2 = it.Fl2,
                    fl3 = it.Fl3,
                    fl4 = it.Fl4,
                    fl = it.Fl,
                    qt1 = it.Qt1,
                    qt2 = it.Qt2,
                    sgf = it.Sgf,
                }).MergeTable().OrderBy(sidx + " " + input.sort).ToListAsync();
            return data;
        }
        #endregion
        #region 导出项目资料
        /// <summary>
        /// 导出项目资料
        /// </summary>
        /// <param name="input">请求参数</param>
        /// <returns></returns>
        [HttpGet("Actions/Export")]
        public async Task<dynamic> Export([FromQuery] LqXmzlListQueryInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var exportData = new List<LqXmzlListOutput>();
            if (input.dataType == 0)
            {
                var data = Clay.Object(await this.GetList(input));
                exportData = data.Solidify<PageResult<LqXmzlListOutput>>().list;
            }
            else
            {
                exportData = await this.GetNoPagingList(input);
            }
            List<ParamsModel> paramList = "[{\"value\":\"主键\",\"field\":\"id\"},{\"value\":\"项目编号\",\"field\":\"xmbh\"},{\"value\":\"项目名称\",\"field\":\"xmmc\"},{\"value\":\"标准价格\",\"field\":\"bzjg\"},{\"value\":\"时长（分）\",\"field\":\"xmsc\"},{\"value\":\"基础服务提成\",\"field\":\"jcfwtc\"},{\"value\":\"分类1汇总表\",\"field\":\"fl1\"},{\"value\":\"分类2汇总表\",\"field\":\"fl2\"},{\"value\":\"分类3工资用\",\"field\":\"fl3\"},{\"value\":\"分类4品项用\",\"field\":\"fl4\"},{\"value\":\"统计类别\",\"field\":\"tjlb\"},{\"value\":\"折扣类别\",\"field\":\"zklb\"},{\"value\":\"分类\",\"field\":\"fl\"},{\"value\":\"其它1\",\"field\":\"qt1\"},{\"value\":\"其它2\",\"field\":\"qt2\"},{\"value\":\"溯源金额\",\"field\":\"syje\"},{\"value\":\"Cell金额\",\"field\":\"cellje\"},{\"value\":\"手工费\",\"field\":\"sgf\"},]".ToList<ParamsModel>();
            ExcelConfig excelconfig = new ExcelConfig();
            excelconfig.FileName = "项目资料.xls";
            excelconfig.HeadFont = "微软雅黑";
            excelconfig.HeadPoint = 10;
            excelconfig.IsAllSizeColumn = true;
            excelconfig.ColumnModel = new List<ExcelColumnModel>();
            List<string> selectKeyList = input.selectKey.Split(',').ToList();
            foreach (var item in selectKeyList)
            {
                var isExist = paramList.Find(p => p.field == item);
                if (isExist != null)
                {
                    excelconfig.ColumnModel.Add(new ExcelColumnModel() { Column = isExist.field, ExcelColumn = isExist.value });
                }
            }
            var addPath = FileVariable.TemporaryFilePath + excelconfig.FileName;
            ExcelExportHelper<LqXmzlListOutput>.Export(exportData, excelconfig, addPath);
            var fileName = _userManager.UserId + "|" + addPath + "|xls";
            var output = new
            {
                name = excelconfig.FileName,
                url = "/api/File/Download?encryption=" + DESCEncryption.Encrypt(fileName, "NCC")
            };
            return output;
        }
        #endregion
        #region 批量删除项目资料
        /// <summary>
        /// 批量删除项目资料
        /// </summary>
        /// <param name="ids">主键数组</param>
        /// <returns></returns>
        [HttpPost("batchRemove")]
        public async Task BatchRemove([FromBody] List<string> ids)
        {
            throw NCCException.Oh("不允许删除项目资料");
            var entitys = await _db.Queryable<LqXmzlEntity>().In(it => it.Id, ids).ToListAsync();
            if (entitys.Count > 0)
            {
                try
                {
                    //开启事务
                    _db.BeginTran();
                    //批量删除项目资料
                    await _db.Deleteable<LqXmzlEntity>().In(d => d.Id, ids).ExecuteCommandAsync();
                    //关闭事务
                    _db.CommitTran();
                }
                catch (Exception)
                {
                    //回滚事务
                    _db.RollbackTran();
                    throw NCCException.Oh(ErrorCode.COM1002);
                }
            }
        }
        #endregion
        #region 更新项目资料
        /// <summary>
        /// 更新项目资料
        /// </summary>
        /// <param name="id">主键</param>
        /// <param name="input">参数</param>
        /// <returns></returns>
        [HttpPut("{id}")]
        public async Task Update(string id, [FromBody] LqXmzlUpInput input)
        {
            var entity = input.Adapt<LqXmzlEntity>();
            var isOk = await _db.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
            if (!(isOk > 0)) throw NCCException.Oh(ErrorCode.COM1001);
        }
        #endregion
        #region 删除项目资料
        /// <summary>
        /// 删除项目资料
        /// </summary>
        /// <param name="id">主键</param>
        /// <returns></returns>
        [HttpDelete("{id}")]
        public async Task Delete(string id)
        {
            throw NCCException.Oh("不允许删除项目资料");
        }
        #endregion
        #region 获取字段去重数据
        /// <summary>
        /// 获取指定字段的去重数据
        /// </summary>
        /// <param name="fieldName">字段名称，支持：fl1、fl2、fl3、fl4、fl、qt1、beautyType、sourceType</param>
        /// <returns>去重后的字段数据</returns>
        [HttpGet("GetDistinctFieldData")]
        public async Task<dynamic> GetDistinctFieldData([FromQuery] string fieldName)
        {
            try
            {
                // 验证字段名称
                var validFields = new[] { "fl1", "fl2", "fl3", "fl4", "fl", "qt1", "qt2", "beautyType", "sourceType" };
                if (!validFields.Contains(fieldName))
                {
                    throw NCCException.Oh($"无效的字段名称: {fieldName}。支持的字段: {string.Join(", ", validFields)}");
                }
                List<string> distinctValues = new List<string>();
                switch (fieldName)
                {
                    case "fl1":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.Fl1))
                            .Select(p => p.Fl1)
                            .Distinct()
                            .ToListAsync();
                        break;
                    case "fl2":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.Fl2))
                            .Select(p => p.Fl2)
                            .Distinct()
                            .ToListAsync();
                        break;
                    case "fl3":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.Fl3))
                            .Select(p => p.Fl3)
                            .Distinct()
                            .ToListAsync();
                        break;
                    case "fl4":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.Fl4))
                            .Select(p => p.Fl4)
                            .Distinct()
                            .ToListAsync();
                        break;
                    case "fl":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.Fl))
                            .Select(p => p.Fl)
                            .Distinct()
                            .ToListAsync();
                        break;
                    case "qt1":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.Qt1))
                            .Select(p => p.Qt1)
                            .Distinct()
                            .ToListAsync();
                        break;
                    case "qt2":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.Qt2))
                            .Select(p => p.Qt2)
                            .Distinct()
                            .ToListAsync();
                        break;
                    case "beautyType":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.BeautyType))
                            .Select(p => p.BeautyType)
                            .Distinct()
                            .ToListAsync();
                        break;
                    case "sourceType":
                        distinctValues = await _db.Queryable<LqXmzlEntity>()
                            .Where(p => !string.IsNullOrEmpty(p.SourceType))
                            .Select(p => p.SourceType)
                            .Distinct()
                            .ToListAsync();
                        break;
                }
                return new
                {
                    fieldName = fieldName,
                    values = distinctValues.OrderBy(x => x).ToList()
                };
            }
            catch (Exception ex)
            {
                throw NCCException.Oh($"获取字段去重数据失败：{ex.Message}");
            }
        }
        #endregion
    }
}