using Microsoft.AspNetCore.Mvc; using NPOI.POIFS.Properties; using NPOI.SS.Formula.Functions; using OASystem.API.OAMethodLib; using OASystem.Domain.Dtos.Groups; using OASystem.Domain.Dtos.Statistics; using OASystem.Domain.Entities.Financial; using OASystem.Domain.ViewModels.Financial; using OASystem.Domain.ViewModels.Groups; using OASystem.Domain.ViewModels.Statistics; using OASystem.Infrastructure.Repositories.Groups; namespace OASystem.API.Controllers { /// /// 统计模块 /// [Route("api/[controller]")] [ApiController] public class StatisticsController : ControllerBase { private readonly IMapper _mapper; private readonly SqlSugarClient _sqlSugar; private readonly DelegationInfoRepository _groupRep; private readonly SetDataRepository _setDataRep; /// /// Init /// /// /// /// /// public StatisticsController(IMapper mapper, SqlSugarClient sqlSugar, DelegationInfoRepository groupRep, SetDataRepository setDataRep) { _mapper = mapper; _groupRep = groupRep; _setDataRep = setDataRep; _sqlSugar = sqlSugar; } #region 团组报表 /// /// 团组报表 /// Items /// /// 团组列表请求dto /// [HttpPost("PostGroupStatementItems")] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task PostGroupStatementItems(GroupStatementItemsDto _dto) { #region 参数验证 if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空")); if (_dto.PageId < 1) return Ok(JsonView(false, "页面Id为空")); PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase(); #region 页面操作权限验证 pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId); if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限")); #endregion #endregion if (_dto.PortType == 1 || _dto.PortType == 2 || _dto.PortType == 3) // web/Android/IOS { string sqlWhere = string.Empty; if (_dto.IsSure == 0) //未完成 { sqlWhere += string.Format(@" And IsSure = 0"); } else if (_dto.IsSure == 1) //已完成 { sqlWhere += string.Format(@" And IsSure = 1"); } if (!string.IsNullOrEmpty(_dto.SearchCriteria)) { string tj = _dto.SearchCriteria; sqlWhere += string.Format(@"And (ssd.Name Like '%{0}%' Or TeamName Like '%{1}%' Or ClientName Like '%{2}%' Or ClientName Like '%{3}%' Or su.CnName Like '%{4}%')", tj, tj, tj, tj, tj); } string sql = string.Format(@"Select row_number() over(order by gdi.VisitDate Desc) as Row_Number, gdi.Id,TourCode,ssd1.Id TeamLevId,ssd1.Name TeamLev,TeamName, ClientName,ClientUnit,VisitDate,ssd.Id TeamTypeId, ssd.Name TeamType, VisitDays,VisitPNumber,su.CnName JietuanOperator,IsSure,gdi.CreateTime, pr.LastCollectionTime From Grp_DelegationInfo gdi Left Join Sys_SetData ssd On gdi.TeamDid = ssd.Id Left Join Sys_SetData ssd1 On gdi.TeamLevSId = ssd1.Id Left Join Sys_Users su On gdi.JietuanOperator = su.Id Left Join ( SELECT Diid, MAX(CreateTime) LastCollectionTime FROM Fin_ProceedsReceived Where IsDel = 0 GROUP BY Diid ) pr On gdi.Id = pr.Diid Where gdi.IsDel = 0 {0} ", sqlWhere); RefAsync total = 0;//REF和OUT不支持异步,想要真的异步这是最优解 var _DelegationList = await _sqlSugar.SqlQueryable(sql).ToPageListAsync(_dto.PageIndex, _dto.PageSize, total);//ToPageAsync var _view = new { PageFuncAuth = pageFunAuthView, Data = _DelegationList }; return Ok(JsonView(true, "查询成功!", _view, total)); } else { return Ok(JsonView(false, "查询失败")); } } /// /// 团组报表 /// Details /// /// 团组列表请求dto /// [HttpPost("PostGroupStatementDetails")] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task PostGroupStatementDetails(GroupStatementDetailsDto _dto) { #region 参数验证 if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空")); if (_dto.PageId < 1) return Ok(JsonView(false, "页面Id为空")); if (_dto.DiId < 1) return Ok(JsonView(false, "团组Id为空")); PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase(); #region 页面操作权限验证 pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId); if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限")); #endregion #endregion if (_dto.PortType == 1 || _dto.PortType == 2 || _dto.PortType == 3) // web/Android/IOS { GroupStatementDetailsView _view = new GroupStatementDetailsView(); #region 费用类型 币种,转账 List _setDatas = await _sqlSugar.Queryable().Where(it => it.IsDel == 0).ToListAsync(); #endregion #region 团组收入 GroupIncomeView _giView = new GroupIncomeView(); /* * 应收报表 */ decimal frTotalAmount = 0.00M;//应收总金额 string _frSql = string.Format(@"Select fr.Id,fr.Diid,fr.PriceName,fr.Price,fr.Count,fr.Unit,fr.Currency, sd.Name As CurrencyCode,sd.Remark As CurrencyName,fr.Rate,fr.ItemSumPrice From Fin_ForeignReceivables fr Left Join Sys_SetData sd On fr.Currency = sd.Id Where fr.IsDel = 0 And fr.Diid = {0}",_dto.DiId); List _frViews = await _sqlSugar.SqlQueryable(_frSql).ToListAsync(); frTotalAmount = _frViews.Sum(it => it.ItemSumPrice); _giView.Receivables = _frViews; _giView.ReceivableStr = string.Format(@"应收款合计:{0} CNY(人名币)", frTotalAmount.ConvertToDecimal1().ToString("#0.00")); /* * 已收报表 */ decimal prTotalAmount = 0.00M;//已收总金额 string _prSql = string.Format(@"Select pr.Id,pr.Diid,pr.SectionTime,pr.Price,pr.Currency, sd1.Name As CurrencyCode,sd1.Remark As CurrencyName,pr.Client, pr.ReceivablesType,sd2.Name As ReceivablesTypeName,pr.Remark From Fin_ProceedsReceived pr Left Join Sys_SetData sd1 On pr.Currency = sd1.Id Left Join Sys_SetData sd2 On pr.ReceivablesType = sd2.Id Where pr.IsDel = 0 and pr.Diid = {0}", _dto.DiId); List _prViews = await _sqlSugar.SqlQueryable(_prSql).ToListAsync(); prTotalAmount = _prViews.Sum(it => it.Price); _giView.ProceedsReceiveds = _prViews; _giView.ProceedsReceivedStr = string.Format(@"已收款合计:{0} CNY(人名币)", prTotalAmount.ConvertToDecimal1().ToString("#0.00")); /* * 超支费用 * 未挪表 */ /* * 收款退还 */ decimal promTotalAmount = 0.00M;// 收款退还总金额 List _promView = new List(); string _ropSql = string.Format(@"Select u.CnName As Appliction,prom.Id As PrId,prom.DiId As PrDiId,prom.Price As PrPrice, prom.PriceName AS PrPriceName,prom.CurrencyId As PrCurrencyId, prom.PayType As PrPayType,prom.PriceType As PrPriceType,ccp.* From Fin_PaymentRefundAndOtherMoney prom Left Join Grp_CreditCardPayment ccp On prom.DiId = ccp.DIId And prom.Id = ccp.CId Left Join Sys_Users u On ccp.CreateUserId = u.Id Where prom.IsDel = 0 And prom.PayType = 1 And prom.PriceType = 1 And ccp.CTable = 285 And ccp.IsAuditGM = 1 And ccp.IsPay = 1 And prom.DiId = {0}", _dto.DiId); var _promDatas = await _sqlSugar.SqlQueryable(_ropSql).ToListAsync(); foreach (var ropItem in _promDatas) { string thisCueencyCode = "Unknown"; string thisCueencyName = "Unknown"; var currency = _setDatas.Where(it => it.Id == ropItem.PaymentCurrency).FirstOrDefault(); if (currency != null) { thisCueencyCode = currency.Name; thisCueencyName = currency.Remark; } string orbitalPrivateTransferStr = "Unknown"; var orbitalPrivateTransfer = _setDatas.Where(it => it.Id == ropItem.OrbitalPrivateTransfer).FirstOrDefault(); if (orbitalPrivateTransfer != null) { orbitalPrivateTransferStr = orbitalPrivateTransfer.Name; } string payStr = "Unknown"; var pay = _setDatas.Where(it => it.Id == ropItem.PayDId).FirstOrDefault(); if (pay != null) { payStr = pay.Name; } Gsd_PaymentRefundAndOtherMoneyView gsd_PaymentRefund = new Gsd_PaymentRefundAndOtherMoneyView() { Id = ropItem.Id, DiId = ropItem.DIId, PriceName = ropItem.PrPriceName, PayCurrencyCode = thisCueencyCode, PayCurrencyName = thisCueencyName, Price = ropItem.PrPrice, CNYPrice = ropItem.RMBPrice, ThisRate = ropItem.DayRate, Payee = ropItem.Payee, PayTime = ropItem.AuditGMDate, FeeType = orbitalPrivateTransferStr, PayType = payStr, PayStatus = ropItem.IsPay == 0 ? "未付款" : "已付款", Applicant = ropItem.Appliction }; _promView.Add(gsd_PaymentRefund); } promTotalAmount = _promView.Sum(it => it.CNYPrice); _giView.PaymentRefundAndOtherMoneys = _promView; _giView.PaymentRefundAndOtherMoneyStr = string.Format(@"人名币总费用:{0} CNY", promTotalAmount.ConvertToDecimal1().ToString("#0.00")); decimal BalancePayment = frTotalAmount - prTotalAmount + promTotalAmount; _view.GroupIncome = _giView; _view.GroupIncomeStr = string.Format(@"剩余尾款:{0} (包含了收款退还费用数据)", BalancePayment.ConvertToDecimal1().ToString("#0.00")); #endregion return Ok(JsonView(true, "查询成功!", _view)); } else { return Ok(JsonView(false, "查询成功")); } } #endregion } }