netcore/src/Modularity/Extend/NCC.Extend/LqReimbursementApplicationService.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.LqReimbursementApplication;
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;
using NCC.Extend.Entitys.Dto.LqReimbursementApplication;
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.LqReimbursementApplication
{
    /// <summary>
    /// 报销申请表服务
    /// </summary>
    [ApiDescriptionSettings(Tag = "Extend", Name = "LqReimbursementApplication", Order = 200)]
    [Route("api/Extend/[controller]")]
    public class LqReimbursementApplicationService : ILqReimbursementApplicationService, IDynamicApiController, ITransient
    {
        private readonly ISqlSugarRepository<LqReimbursementApplicationEntity> _lqReimbursementApplicationRepository;
        private readonly SqlSugarScope _db;
        private readonly IUserManager _userManager;
        /// <summary>
        /// 初始化一个<see cref="LqReimbursementApplicationService"/>类型的新实例
        /// </summary>
        public LqReimbursementApplicationService(
            ISqlSugarRepository<LqReimbursementApplicationEntity> lqReimbursementApplicationRepository,
            IUserManager userManager)
        {
            _lqReimbursementApplicationRepository = lqReimbursementApplicationRepository;
            _db = _lqReimbursementApplicationRepository.Context;
            _userManager = userManager;
        }
        /// <summary>
        /// 获取报销申请表
        /// </summary>
        /// <param name="id">参数</param>
        /// <returns></returns>
        [HttpGet("{id}")]
        public async Task<dynamic> GetInfo(string id)
        {
            var entity = await _db.Queryable<LqReimbursementApplicationEntity>().FirstAsync(p => p.Id == id);
            var output = entity.Adapt<LqReimbursementApplicationInfoOutput>();
            return output;
        }
        /// <summary>
		/// 获取报销申请表列表
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [HttpGet("")]
        public async Task<dynamic> GetList([FromQuery] LqReimbursementApplicationListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            List<string> queryApplicationTime = input.applicationTime != null ? input.applicationTime.Split(',').ToObeject<List<string>>() : null;
            DateTime? startApplicationTime = queryApplicationTime != null ? Ext.GetDateTime(queryApplicationTime.First()) : null;
            DateTime? endApplicationTime = queryApplicationTime != null ? Ext.GetDateTime(queryApplicationTime.Last()) : null;
            List<string> queryApproveTime = input.approveTime != null ? input.approveTime.Split(',').ToObeject<List<string>>() : null;
            DateTime? startApproveTime = queryApproveTime != null ? Ext.GetDateTime(queryApproveTime.First()) : null;
            DateTime? endApproveTime = queryApproveTime != null ? Ext.GetDateTime(queryApproveTime.Last()) : null;
            var data = await _db.Queryable<LqReimbursementApplicationEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                .WhereIF(!string.IsNullOrEmpty(input.applicationUserId), p => p.ApplicationUserId.Contains(input.applicationUserId))
                .WhereIF(!string.IsNullOrEmpty(input.applicationUserName), p => p.ApplicationUserName.Contains(input.applicationUserName))
                .WhereIF(!string.IsNullOrEmpty(input.applicationStoreId), p => p.ApplicationStoreId.Contains(input.applicationStoreId))
                .WhereIF(queryApplicationTime != null, p => p.ApplicationTime >= new DateTime(startApplicationTime.ToDate().Year, startApplicationTime.ToDate().Month, startApplicationTime.ToDate().Day, 0, 0, 0))
                .WhereIF(queryApplicationTime != null, p => p.ApplicationTime <= new DateTime(endApplicationTime.ToDate().Year, endApplicationTime.ToDate().Month, endApplicationTime.ToDate().Day, 23, 59, 59))
                .WhereIF(!string.IsNullOrEmpty(input.amount), p => p.Amount.Contains(input.amount))
                .WhereIF(!string.IsNullOrEmpty(input.approveUser), p => p.ApproveUser.Equals(input.approveUser))
                .WhereIF(!string.IsNullOrEmpty(input.approveStatus), p => p.ApproveStatus.Contains(input.approveStatus))
                // .WhereIF(queryApproveTime != null, p => p.ApproveTime >= new DateTime(startApproveTime.ToDate().Year, startApproveTime.ToDate().Month, startApproveTime.ToDate().Day, 0, 0, 0))
                //.WhereIF(queryApproveTime != null, p => p.ApproveTime <= new DateTime(endApproveTime.ToDate().Year, endApproveTime.ToDate().Month, endApproveTime.ToDate().Day, 23, 59, 59))
                .WhereIF(!string.IsNullOrEmpty(input.purchaseRecordsId), p => p.PurchaseRecordsId.Contains(input.purchaseRecordsId))
                .Select(it => new LqReimbursementApplicationListOutput
                {
                    id = it.Id,
                    applicationUserId = it.ApplicationUserId,
                    applicationUserName = it.ApplicationUserName,
                    applicationStoreId = it.ApplicationStoreId,
                    applicationTime = it.ApplicationTime,
                    amount = it.Amount,
                    approveUser = it.ApproveUser,
                    approveStatus = it.ApproveStatus,
                    approveTime = it.ApproveTime,
                    purchaseRecordsId = it.PurchaseRecordsId,
                }).MergeTable().OrderBy(sidx + " " + input.sort).ToPagedListAsync(input.currentPage, input.pageSize);
            return PageResult<LqReimbursementApplicationListOutput>.SqlSugarPageResult(data);
        }
        /// <summary>
        /// 新建报销申请表
        /// </summary>
        /// <param name="input">参数</param>
        /// <returns></returns>
        [HttpPost("")]
        public async Task Create([FromBody] LqReimbursementApplicationCrInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var entity = input.Adapt<LqReimbursementApplicationEntity>();
            entity.Id = YitIdHelper.NextId().ToString();
            try
            {
                //开启事务
                _db.BeginTran();
                // 保存报销申请表
                var isOk = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
                if (!(isOk > 0)) throw NCCException.Oh(ErrorCode.COM1000);
                // 更新购买记录的审批单编号和审批状态为"待审批"
                if (input.selectedPurchaseRecordIds != null && input.selectedPurchaseRecordIds.Count > 0)
                {
                    // 先更新ApplicationId
                    await _db.Updateable<LqPurchaseRecordsEntity>()
                        .SetColumns(it => it.ApplicationId == entity.Id)
                        .Where(it => input.selectedPurchaseRecordIds.Contains(it.Id))
                        .ExecuteCommandAsync();
                    // 再更新ApproveStatus（分开更新确保都能执行）
                    await _db.Updateable<LqPurchaseRecordsEntity>()
                        .SetColumns(it => it.ApproveStatus == "待审批")
                        .Where(it => input.selectedPurchaseRecordIds.Contains(it.Id))
                        .ExecuteCommandAsync();
                }
                //关闭事务
                _db.CommitTran();
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw;
            }
        }
        /// <summary>
		/// 获取报销申请表无分页列表
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [NonAction]
        public async Task<dynamic> GetNoPagingList([FromQuery] LqReimbursementApplicationListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            List<string> queryApplicationTime = input.applicationTime != null ? input.applicationTime.Split(',').ToObeject<List<string>>() : null;
            DateTime? startApplicationTime = queryApplicationTime != null ? Ext.GetDateTime(queryApplicationTime.First()) : null;
            DateTime? endApplicationTime = queryApplicationTime != null ? Ext.GetDateTime(queryApplicationTime.Last()) : null;
            List<string> queryApproveTime = input.approveTime != null ? input.approveTime.Split(',').ToObeject<List<string>>() : null;
            DateTime? startApproveTime = queryApproveTime != null ? Ext.GetDateTime(queryApproveTime.First()) : null;
            DateTime? endApproveTime = queryApproveTime != null ? Ext.GetDateTime(queryApproveTime.Last()) : null;
            var data = await _db.Queryable<LqReimbursementApplicationEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                .WhereIF(!string.IsNullOrEmpty(input.applicationUserId), p => p.ApplicationUserId.Contains(input.applicationUserId))
                .WhereIF(!string.IsNullOrEmpty(input.applicationUserName), p => p.ApplicationUserName.Contains(input.applicationUserName))
                .WhereIF(!string.IsNullOrEmpty(input.applicationStoreId), p => p.ApplicationStoreId.Contains(input.applicationStoreId))
                .WhereIF(queryApplicationTime != null, p => p.ApplicationTime >= new DateTime(startApplicationTime.ToDate().Year, startApplicationTime.ToDate().Month, startApplicationTime.ToDate().Day, 0, 0, 0))
                .WhereIF(queryApplicationTime != null, p => p.ApplicationTime <= new DateTime(endApplicationTime.ToDate().Year, endApplicationTime.ToDate().Month, endApplicationTime.ToDate().Day, 23, 59, 59))
                .WhereIF(!string.IsNullOrEmpty(input.amount), p => p.Amount.Contains(input.amount))
                .WhereIF(!string.IsNullOrEmpty(input.approveUser), p => p.ApproveUser.Equals(input.approveUser))
                .WhereIF(!string.IsNullOrEmpty(input.approveStatus), p => p.ApproveStatus.Contains(input.approveStatus))
                //    .WhereIF(queryApproveTime != null, p => p.ApproveTime >= new DateTime(startApproveTime.ToDate().Year, startApproveTime.ToDate().Month, startApproveTime.ToDate().Day, 0, 0, 0))
                //      .WhereIF(queryApproveTime != null, p => p.ApproveTime <= new DateTime(endApproveTime.ToDate().Year, endApproveTime.ToDate().Month, endApproveTime.ToDate().Day, 23, 59, 59))
                .WhereIF(!string.IsNullOrEmpty(input.purchaseRecordsId), p => p.PurchaseRecordsId.Contains(input.purchaseRecordsId))
                .Select(it => new LqReimbursementApplicationListOutput
                {
                    id = it.Id,
                    applicationUserId = it.ApplicationUserId,
                    applicationUserName = it.ApplicationUserName,
                    applicationStoreId = it.ApplicationStoreId,
                    applicationTime = it.ApplicationTime,
                    amount = it.Amount,
                    approveUser = it.ApproveUser,
                    approveStatus = it.ApproveStatus,
                    approveTime = it.ApproveTime,
                    purchaseRecordsId = it.PurchaseRecordsId,
                }).MergeTable().OrderBy(sidx + " " + input.sort).ToListAsync();
            return data;
        }
        /// <summary>
		/// 导出报销申请表
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [HttpGet("Actions/Export")]
        public async Task<dynamic> Export([FromQuery] LqReimbursementApplicationListQueryInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var exportData = new List<LqReimbursementApplicationListOutput>();
            if (input.dataType == 0)
            {
                var data = Clay.Object(await this.GetList(input));
                exportData = data.Solidify<PageResult<LqReimbursementApplicationListOutput>>().list;
            }
            else
            {
                exportData = await this.GetNoPagingList(input);
            }
            List<ParamsModel> paramList = "[{\"value\":\"申请编号\",\"field\":\"id\"},{\"value\":\"申请人编号\",\"field\":\"applicationUserId\"},{\"value\":\"申请人姓名\",\"field\":\"applicationUserName\"},{\"value\":\"申请门店\",\"field\":\"applicationStoreId\"},{\"value\":\"申请时间\",\"field\":\"applicationTime\"},{\"value\":\"总金额\",\"field\":\"amount\"},{\"value\":\"审批人\",\"field\":\"approveUser\"},{\"value\":\"审批结果\",\"field\":\"approveStatus\"},{\"value\":\"审批时间\",\"field\":\"approveTime\"},{\"value\":\"关联购买编号\",\"field\":\"purchaseRecordsId\"},]".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<LqReimbursementApplicationListOutput>.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;
        }
        /// <summary>
        /// 批量删除报销申请表
        /// </summary>
        /// <param name="ids">主键数组</param>
        /// <returns></returns>
        [HttpPost("batchRemove")]
        public async Task BatchRemove([FromBody] List<string> ids)
        {
            var entitys = await _db.Queryable<LqReimbursementApplicationEntity>().In(it => it.Id, ids).ToListAsync();
            if (entitys.Count > 0)
            {
                try
                {
                    //开启事务
                    _db.BeginTran();
                    //批量删除报销申请表
                    await _db.Deleteable<LqReimbursementApplicationEntity>().In(d => d.Id, ids).ExecuteCommandAsync();
                    //关闭事务
                    _db.CommitTran();
                }
                catch (Exception)
                {
                    //回滚事务
                    _db.RollbackTran();
                    throw NCCException.Oh(ErrorCode.COM1002);
                }
            }
        }
        /// <summary>
        /// 更新报销申请表
        /// </summary>
        /// <param name="id">主键</param>
        /// <param name="input">参数</param>
        /// <returns></returns>
        [HttpPut("{id}")]
        public async Task Update(string id, [FromBody] LqReimbursementApplicationUpInput input)
        {
            try
            {
                //开启事务
                _db.BeginTran();
                // 获取原有的关联购买记录ID
                var oldEntity = await _db.Queryable<LqReimbursementApplicationEntity>().FirstAsync(p => p.Id == id);
                var oldIds = new List<string>();
                if (oldEntity != null && !string.IsNullOrEmpty(oldEntity.PurchaseRecordsId))
                {
                    // 获取原有购买记录ID列表
                    oldIds = oldEntity.PurchaseRecordsId.Split(',').Where(x => !string.IsNullOrEmpty(x)).ToList();
                }
                // 获取新的购买记录ID列表
                var newIds = input.selectedPurchaseRecordIds ?? new List<string>();
                // 确保 purchaseRecordsId 字段包含所有选中的记录ID（逗号分隔）
                if (newIds.Count > 0)
                {
                    input.purchaseRecordsId = string.Join(",", newIds);
                }
                else
                {
                    input.purchaseRecordsId = null;
                }
                // 找出需要移除关联的记录（在旧列表中但不在新列表中）
                var idsToRemove = oldIds.Where(x => !newIds.Contains(x)).ToList();
                if (idsToRemove.Count > 0)
                {
                    // 清除这些购买记录的审批单编号和审批状态
                    await _db.Updateable<LqPurchaseRecordsEntity>()
                        .SetColumns(it => new LqPurchaseRecordsEntity
                        {
                            ApplicationId = null,
                            ApproveStatus = "未审批"
                        })
                        .Where(it => idsToRemove.Contains(it.Id))
                        .ExecuteCommandAsync();
                }
                // 更新报销申请表（确保 purchaseRecordsId 字段被正确更新）
                var entity = input.Adapt<LqReimbursementApplicationEntity>();
                var isOk = await _db.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
                if (!(isOk > 0)) throw NCCException.Oh(ErrorCode.COM1001);
                // 更新所有选中的购买记录的审批单编号和审批状态为"待审批"
                // 包括新追加的记录和已存在的记录（确保状态正确）
                if (newIds.Count > 0)
                {
                    // 先更新ApplicationId
                    await _db.Updateable<LqPurchaseRecordsEntity>()
                        .SetColumns(it => it.ApplicationId == id)
                        .Where(it => newIds.Contains(it.Id))
                        .ExecuteCommandAsync();
                    // 再更新ApproveStatus（分开更新确保都能执行）
                    await _db.Updateable<LqPurchaseRecordsEntity>()
                        .SetColumns(it => it.ApproveStatus == "待审批")
                        .Where(it => newIds.Contains(it.Id))
                        .ExecuteCommandAsync();
                }
                //关闭事务
                _db.CommitTran();
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw;
            }
        }
        /// <summary>
        /// 删除报销申请表
        /// </summary>
        /// <returns></returns>
        [HttpDelete("{id}")]
        public async Task Delete(string id)
        {
            var entity = await _db.Queryable<LqReimbursementApplicationEntity>().FirstAsync(p => p.Id == id);
            _ = entity ?? throw NCCException.Oh(ErrorCode.COM1005);
            var isOk = await _db.Deleteable<LqReimbursementApplicationEntity>().Where(d => d.Id == id).ExecuteCommandAsync();
            if (!(isOk > 0)) throw NCCException.Oh(ErrorCode.COM1002);
        }
        /// <summary>
        /// 通过审批
        /// </summary>
        /// <param name="id">申请编号</param>
        /// <returns></returns>
        [HttpPost("{id}/Actions/Approve")]
        public async Task Approve(string id)
        {
            var userInfo = await _userManager.GetUserInfo();
            var entity = await _db.Queryable<LqReimbursementApplicationEntity>().FirstAsync(p => p.Id == id);
            _ = entity ?? throw NCCException.Oh(ErrorCode.COM1005);
            try
            {
                //开启事务
                _db.BeginTran();
                // 更新申请表的审批状态
                entity.ApproveStatus = "已审批";
                entity.ApproveTime = DateTime.Now;
                entity.ApproveUser = userInfo.userId;
                await _db.Updateable(entity).ExecuteCommandAsync();
                // 更新关联的购买记录
                if (!string.IsNullOrEmpty(entity.PurchaseRecordsId))
                {
                    var purchaseIds = entity.PurchaseRecordsId.Split(',').Where(x => !string.IsNullOrEmpty(x)).ToList();
                    if (purchaseIds.Count > 0)
                    {
                        await _db.Updateable<LqPurchaseRecordsEntity>()
                            .SetColumns(it => new LqPurchaseRecordsEntity
                            {
                                ApproveStatus = "已审批",
                                ApproveTime = DateTime.Now,
                                ApproveUser = userInfo.userId
                            })
                            .Where(it => purchaseIds.Contains(it.Id))
                            .ExecuteCommandAsync();
                    }
                }
                //关闭事务
                _db.CommitTran();
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw;
            }
        }
        /// <summary>
        /// 拒绝审批
        /// </summary>
        /// <param name="id">申请编号</param>
        /// <returns></returns>
        [HttpPost("{id}/Actions/Reject")]
        public async Task Reject(string id)
        {
            var userInfo = await _userManager.GetUserInfo();
            var entity = await _db.Queryable<LqReimbursementApplicationEntity>().FirstAsync(p => p.Id == id);
            _ = entity ?? throw NCCException.Oh(ErrorCode.COM1005);
            try
            {
                //开启事务
                _db.BeginTran();
                // 更新申请表的审批状态
                entity.ApproveStatus = "未通过";
                entity.ApproveTime = DateTime.Now;
                entity.ApproveUser = userInfo.userId;
                await _db.Updateable(entity).ExecuteCommandAsync();
                // 更新关联的购买记录
                if (!string.IsNullOrEmpty(entity.PurchaseRecordsId))
                {
                    var purchaseIds = entity.PurchaseRecordsId.Split(',').Where(x => !string.IsNullOrEmpty(x)).ToList();
                    if (purchaseIds.Count > 0)
                    {
                        await _db.Updateable<LqPurchaseRecordsEntity>()
                            .SetColumns(it => new LqPurchaseRecordsEntity
                            {
                                ApproveStatus = "未通过",
                                ApproveTime = DateTime.Now,
                                ApproveUser = userInfo.userId
                            })
                            .Where(it => purchaseIds.Contains(it.Id))
                            .ExecuteCommandAsync();
                    }
                }
                //关闭事务
                _db.CommitTran();
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw;
            }
        }
    }
}