|
|
using Microsoft.AspNetCore.Authorization;using Microsoft.AspNetCore.Mvc;using Microsoft.EntityFrameworkCore;using NUglify.Helpers;using Shentun.Peis.Enums;using Shentun.Peis.Models;using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using Volo.Abp.Application.Services;using Volo.Abp.Domain.Repositories;using Volo.Abp.Identity;
namespace Shentun.Peis.InternalReports{ /// <summary>
/// 内部报表 工作量统计
/// </summary>
[ApiExplorerSettings(GroupName = "Work")] [Authorize] public class InternalReportAppService : ApplicationService { private readonly IRepository<IdentityUser, Guid> _userRepository; private readonly IRepository<PatientRegister, Guid> _patientRegisterRepository; private readonly IRepository<RegisterCheckAsbitem, Guid> _registerAsbitemRepository; private readonly IRepository<RegisterCheck, Guid> _registerCheckRepository; private readonly IRepository<Asbitem, Guid> _asbitemRepository; private readonly IRepository<ItemType, Guid> _itemTypeRepository; private readonly IRepository<CustomerOrg, Guid> _customerOrgRepository;
public InternalReportAppService( IRepository<IdentityUser, Guid> userRepository, IRepository<PatientRegister, Guid> patientRegisterRepository, IRepository<RegisterCheckAsbitem, Guid> registerAsbitemRepository, IRepository<RegisterCheck, Guid> registerCheckRepository, IRepository<Asbitem, Guid> asbitemRepository, IRepository<ItemType, Guid> itemTypeRepository, IRepository<CustomerOrg, Guid> customerOrgRepository ) { this._userRepository = userRepository; this._patientRegisterRepository = patientRegisterRepository; this._registerAsbitemRepository = registerAsbitemRepository; this._registerCheckRepository = registerCheckRepository; this._asbitemRepository = asbitemRepository; this._itemTypeRepository = itemTypeRepository; this._customerOrgRepository = customerOrgRepository; }
/// <summary>
/// 登记人员工作量统计
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("api/app/internalreport/getregistrationpersonnelworkloadreport")] public async Task<List<GetRegistrationPersonnelWorkLoadReportDto>> GetRegistrationPersonnelWorkLoadReportAsync(GetRegistrationPersonnelWorkLoadReportRequestDto input) { var query = (from a in await _patientRegisterRepository.GetQueryableAsync() join b in await _userRepository.GetQueryableAsync() on a.CreatorId equals b.Id into bb from ab in bb.DefaultIfEmpty() where (a.CreationTime >= Convert.ToDateTime(input.StartDate) && a.CreationTime < Convert.ToDateTime(input.EndDate).AddDays(1)) select new { a, PersonnelName = ab != null ? ab.UserName : "" });
var sumCount = query.Count(); //总数
if (input.UserIds.Count > 0) { query = query.Where(m => input.UserIds.Contains(m.a.CreatorId.Value)); }
var entlistdto = query.GroupBy(g => new { g.a.CreatorId, g.PersonnelName }) .Select(s => new GetRegistrationPersonnelWorkLoadReportDto { PersonnelName = s.Key.PersonnelName, RegisterCount = s.Count(), Percentage = Math.Round(Convert.ToDecimal(s.Count() * 100) / sumCount, 2).ToString() }).ToList();
return entlistdto; }
/// <summary>
/// 医生工作量统计
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("api/app/internalreport/getdoctorpersonnelworkloadreport")] public async Task<List<GetDoctorPersonnelWorkLoadReportDto>> GetDoctorPersonnelWorkLoadReportAsync(GetDoctorPersonnelWorkLoadReportRequestDto input) { var query = (from a in await _registerAsbitemRepository.GetQueryableAsync() join c in await _asbitemRepository.GetQueryableAsync() on a.AsbitemId equals c.Id into cc from ac in cc.DefaultIfEmpty() join d in await _registerCheckRepository.GetQueryableAsync() on a.RegisterCheckId equals d.Id into dd from ad in dd.DefaultIfEmpty() join b in await _userRepository.GetQueryableAsync() on ad.CheckDoctorId equals b.Id.ToString() into bb from ab in bb.DefaultIfEmpty() where (a.CreationTime >= Convert.ToDateTime(input.StartDate) && a.CreationTime < Convert.ToDateTime(input.EndDate).AddDays(1) && ad.CompleteFlag == RegisterCheckCompleteFlag.Checked ) select new { a, CheckDoctorId = ad.CheckDoctorId, DoctorName = ab != null ? ab.UserName : ad.CheckDoctorId, AsbitemName = ac != null ? ac.DisplayName : "" });
if (input.UserIds.Count > 0) { query = query.Where(m => input.UserIds.Contains(m.CheckDoctorId)); }
//var ssd = query.ToQueryString();
var entlistdto = query.GroupBy(g => new { g.a.AsbitemId, g.a.CreatorId, }) .Select(s => new GetDoctorPersonnelWorkLoadReportDto { AsbitemName = s.FirstOrDefault().AsbitemName, CheckCount = s.Count(), DoctorName = s.FirstOrDefault().DoctorName, AvgChargePrice = Math.Round(s.Average(v => v.a.ChargePrice), 2), AvgStandardPrice = Math.Round(s.Average(v => v.a.StandardPrice), 2), SumChargePrice = Math.Round(s.Sum(v => v.a.ChargePrice * v.a.Amount), 2), SumStandardPrice = Math.Round(s.Sum(v => v.a.StandardPrice * v.a.Amount), 2) }).ToList();
return entlistdto; }
/// <summary>
/// 总检医生工作量统计
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("api/app/internalreport/getsumcheckdoctorworkloadreport")] public async Task<List<GetSumCheckDoctorWorkLoadReportDto>> GetSumCheckDoctorWorkLoadReportAsync(GetSumCheckDoctorWorkLoadReportRequestDto input) { var query = (from a in await _patientRegisterRepository.GetQueryableAsync() join b in await _userRepository.GetQueryableAsync() on a.SummaryDoctor equals b.Id.ToString() into bb from ab in bb.DefaultIfEmpty() where (!string.IsNullOrEmpty(a.SummaryDoctor) && a.SummaryDate != null && a.SummaryDate.Value >= Convert.ToDateTime(input.StartDate) && a.SummaryDate < Convert.ToDateTime(input.EndDate).AddDays(1)) select new { a, SumCheckDoctorName = ab != null ? ab.UserName : "" });
var sumCount = query.Count(); //总数
if (input.UserIds.Count > 0) { query = query.Where(m => input.UserIds.ToString().Contains(m.a.SummaryDoctor)); }
var entlistdto = query.GroupBy(g => new { g.a.SummaryDoctor, g.SumCheckDoctorName }) .Select(s => new GetSumCheckDoctorWorkLoadReportDto { SumCheckDoctorName = s.Key.SumCheckDoctorName, SumCheckCount = s.Count(), Percentage = Math.Round(Convert.ToDecimal(s.Count() * 100) / sumCount, 2).ToString() }).ToList();
return entlistdto; }
/// <summary>
/// 审核医生工作量统计
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("api/app/internalreport/getauditdoctorworkloadreport")] public async Task<List<GetAuditDoctorWorkLoadReportDto>> GetAuditDoctorWorkLoadReportAsync(GetAuditDoctorWorkLoadReportRequestDto input) { var query = (from a in await _patientRegisterRepository.GetQueryableAsync() join b in await _userRepository.GetQueryableAsync() on a.SummaryDoctor equals b.Id.ToString() into bb from ab in bb.DefaultIfEmpty() where (!string.IsNullOrEmpty(a.AuditDoctor) && a.AuditDate != null && a.AuditDate.Value >= Convert.ToDateTime(input.StartDate) && a.AuditDate.Value < Convert.ToDateTime(input.EndDate).AddDays(1)) select new { a, AuditDoctorName = ab != null ? ab.UserName : "" });
var sumCount = query.Count(); //总数
if (input.UserIds.Count > 0) { query = query.Where(m => input.UserIds.ToString().Contains(m.a.AuditDoctor)); }
var entlistdto = query.GroupBy(g => new { g.a.AuditDoctor, g.AuditDoctorName }) .Select(s => new GetAuditDoctorWorkLoadReportDto { AuditDoctorName = s.Key.AuditDoctorName, AuditCount = s.Count(), Percentage = Math.Round(Convert.ToDecimal(s.Count() * 100) / sumCount, 2).ToString() }).ToList();
return entlistdto; }
/// <summary>
/// 科室工作量统计 标准格式 只统计RegisterCheck表标记检查了的数据
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("api/app/internalreport/getitemtypeworkloadinstandard")] public async Task<List<GetItemTypeWorkLoadInStandardDto>> GetItemTypeWorkLoadInStandardAsync(GetItemTypeWorkLoadInStandardRequestDto input) {
var qeruy = from a in await _registerAsbitemRepository.GetQueryableAsync() join b in await _asbitemRepository.GetQueryableAsync() on a.AsbitemId equals b.Id join c in await _itemTypeRepository.GetQueryableAsync() on b.ItemTypeId equals c.Id join d in await _registerCheckRepository.GetQueryableAsync() on a.RegisterCheckId equals d.Id into dd from ad in dd.DefaultIfEmpty() where (!string.IsNullOrEmpty(ad.CheckDoctorId) && ad.CheckDate != null) select new { a.AsbitemId, a.StandardPrice, a.ChargePrice, a.Amount, AsbitemName = b.DisplayName, ItemTypeId = b.ItemTypeId, ItemTypeName = c.DisplayName, ad.CheckDate };
if (input.ItemTypeId.Any()) { qeruy = qeruy.Where(m => input.ItemTypeId.Contains(m.ItemTypeId)); }
if (!string.IsNullOrEmpty(input.StartDate) && !string.IsNullOrEmpty(input.EndDate)) { qeruy = qeruy.Where(m => m.CheckDate.Value >= Convert.ToDateTime(input.StartDate) && m.CheckDate.Value < Convert.ToDateTime(input.EndDate).AddDays(1)); }
var entlist = qeruy.GroupBy(g => new { g.ItemTypeId, g.AsbitemId }) .Select(s => new GetItemTypeWorkLoadInStandardDto { AsbitemName = s.First().AsbitemName, AsbitemCount = s.Count(), ItemTypeName = s.First().ItemTypeName, AvgChargePrice = Math.Round(s.Average(v => v.ChargePrice), 2), AvgStandardPrice = Math.Round(s.Average(v => v.StandardPrice), 2), SumChargePrice = Math.Round(s.Sum(v => v.ChargePrice * v.Amount), 2), SumStandardPrice = Math.Round(s.Sum(v => v.StandardPrice * v.Amount), 2) }).ToList();
return entlist;
}
/// <summary>
/// 科室工作量统计 单位和医生
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("api/app/internalreport/getitemtypeworkloadincustomeranddoctor")] public async Task<List<GetItemTypeWorkLoadInCustomerAndDoctorDto>> GetItemTypeWorkLoadInCustomerAndDoctorAsync(GetItemTypeWorkLoadInCustomerAndDoctorRequestDto input) { var qeruy = from a in await _registerAsbitemRepository.GetQueryableAsync() join b in await _asbitemRepository.GetQueryableAsync() on a.AsbitemId equals b.Id join c in await _itemTypeRepository.GetQueryableAsync() on b.ItemTypeId equals c.Id join d in await _registerCheckRepository.GetQueryableAsync() on a.RegisterCheckId equals d.Id into dd from ad in dd.DefaultIfEmpty() join e in await _patientRegisterRepository.GetQueryableAsync() on a.PatientRegisterId equals e.Id join f in await _customerOrgRepository.GetQueryableAsync() on e.CustomerOrgId equals f.Id into ff from af in ff.DefaultIfEmpty() join g in await _userRepository.GetQueryableAsync() on ad.CheckDoctorId equals g.Id.ToString() into gg from ag in gg.DefaultIfEmpty() where (!string.IsNullOrEmpty(ad.CheckDoctorId) && ad.CheckDate != null) select new { a.AsbitemId, a.StandardPrice, a.ChargePrice, a.Amount, AsbitemName = b.DisplayName, ItemTypeId = b.ItemTypeId, ItemTypeName = c.DisplayName, CustomerName = af.DisplayName, CustomerOrgId = e.CustomerOrgId, ad.CheckDoctorId, ad.CheckDate, DoctorName = ag != null ? ag.UserName : "" };
if (input.ItemTypeId.Any()) { qeruy = qeruy.Where(m => input.ItemTypeId.Contains(m.ItemTypeId)); }
if (!string.IsNullOrEmpty(input.StartDate) && !string.IsNullOrEmpty(input.EndDate)) { qeruy = qeruy.Where(m => m.CheckDate.Value >= Convert.ToDateTime(input.StartDate) && m.CheckDate.Value < Convert.ToDateTime(input.EndDate).AddDays(1)); }
var entlist = qeruy.GroupBy(g => new { g.CustomerOrgId, g.ItemTypeId, g.AsbitemId, g.CheckDoctorId }) .Select(s => new GetItemTypeWorkLoadInCustomerAndDoctorDto { AsbitemName = s.First().AsbitemName, DoctorCheckCount = s.Count(), ItemTypeName = s.First().ItemTypeName, CustomerName = s.First().CustomerName, DoctorName = s.First().DoctorName, AvgChargePrice = Math.Round(s.Average(v => v.ChargePrice), 2), AvgStandardPrice = Math.Round(s.Average(v => v.StandardPrice), 2), SumChargePrice = Math.Round(s.Sum(v => v.ChargePrice * v.Amount), 2), SumStandardPrice = Math.Round(s.Sum(v => v.StandardPrice * v.Amount), 2) }).ToList();
return entlist; }
/// <summary>
/// 科室工作量统计 单位和组合项目
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("api/app/internalreport/getitemtypeworkloadincustomerandasbitem")] public async Task<List<GetItemTypeWorkLoadInCustomerAndAsbitemDto>> GetItemTypeWorkLoadInCustomerAndAsbitemAsync(GetItemTypeWorkLoadInCustomerAndAsbitemRequestDto input) { var qeruy = from a in await _registerAsbitemRepository.GetQueryableAsync() join b in await _asbitemRepository.GetQueryableAsync() on a.AsbitemId equals b.Id join c in await _itemTypeRepository.GetQueryableAsync() on b.ItemTypeId equals c.Id join d in await _registerCheckRepository.GetQueryableAsync() on a.RegisterCheckId equals d.Id into dd from ad in dd.DefaultIfEmpty() join e in await _patientRegisterRepository.GetQueryableAsync() on a.PatientRegisterId equals e.Id join f in await _customerOrgRepository.GetQueryableAsync() on e.CustomerOrgId equals f.Id into ff from af in ff.DefaultIfEmpty() where (!string.IsNullOrEmpty(ad.CheckDoctorId) && ad.CheckDate != null) select new { a.AsbitemId, a.StandardPrice, a.ChargePrice, a.Amount, AsbitemName = b.DisplayName, ItemTypeId = b.ItemTypeId, ItemTypeName = c.DisplayName, CustomerName = af.DisplayName, CustomerOrgId = e.CustomerOrgId, ad.CheckDate };
if (input.ItemTypeId.Any()) { qeruy = qeruy.Where(m => input.ItemTypeId.Contains(m.ItemTypeId)); }
if (!string.IsNullOrEmpty(input.StartDate) && !string.IsNullOrEmpty(input.EndDate)) { qeruy = qeruy.Where(m => m.CheckDate.Value >= Convert.ToDateTime(input.StartDate) && m.CheckDate.Value < Convert.ToDateTime(input.EndDate).AddDays(1)); }
var entlist = qeruy.GroupBy(g => new { g.CustomerOrgId, g.ItemTypeId, g.AsbitemId }) .Select(s => new GetItemTypeWorkLoadInCustomerAndAsbitemDto { AsbitemName = s.First().AsbitemName, DoctorCheckCount = s.Count(), ItemTypeName = s.First().ItemTypeName, CustomerName = s.First().CustomerName, AvgChargePrice = Math.Round(s.Average(v => v.ChargePrice), 2), AvgStandardPrice = Math.Round(s.Average(v => v.StandardPrice), 2), SumChargePrice = Math.Round(s.Sum(v => v.ChargePrice * v.Amount), 2), SumStandardPrice = Math.Round(s.Sum(v => v.StandardPrice * v.Amount), 2) }).ToList();
return entlist; }
/// <summary>
/// 体检工作量统计
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost("api/app/internalreport/getpeisworkloadreportasync")] public async Task<List<GetPeisWorkLoadReportDto>> GetPeisWorkLoadReportAsync(GetPeisWorkLoadReportRequestDto input) { var query = (from a in await _registerAsbitemRepository.GetQueryableAsync() join c in await _asbitemRepository.GetQueryableAsync() on a.AsbitemId equals c.Id into cc from ac in cc.DefaultIfEmpty() join d in await _patientRegisterRepository.GetQueryableAsync() on a.PatientRegisterId equals d.Id join b in await _userRepository.GetQueryableAsync() on d.CreatorId.Value equals b.Id into bb from ab in bb.DefaultIfEmpty() where (a.CreationTime >= Convert.ToDateTime(input.StartDate) && a.CreationTime < Convert.ToDateTime(input.EndDate).AddDays(1) && d.CompleteFlag != PatientRegisterCompleteFlag.PreRegistration ) select new { a, RegisterId = d.CreatorId.Value, RegisterName = ab != null ? ab.UserName : "", AsbitemName = ac != null ? ac.DisplayName : "" });
if (input.UserIds.Any()) { query = query.Where(m => input.UserIds.Contains(m.RegisterId)); }
var entlistdto = query.GroupBy(g => new { g.a.AsbitemId, g.RegisterId }) .Select(s => new GetPeisWorkLoadReportDto { AsbitemName = s.FirstOrDefault().AsbitemName, PersonCount = s.Sum(v => v.a.Amount), RegisterName = s.FirstOrDefault().RegisterName, StandardPrice = Math.Round(s.FirstOrDefault().a.StandardPrice, 2).ToString(), StandardAmount = Math.Round(s.Sum(v => v.a.StandardPrice * v.a.Amount), 2).ToString(), ChargeAmount = Math.Round(s.Sum(v => v.a.ChargePrice * v.a.Amount), 2).ToString(), ChargePrice = Math.Round(s.Sum(v => v.a.ChargePrice * v.a.Amount) / s.Sum(v => v.a.Amount), 2).ToString(), PersonAmount = Math.Round(s.Where(m => m.a.PayTypeFlag == PayTypeFlag.PersonPay).Sum(v => v.a.ChargePrice * v.a.Amount), 2).ToString(), UnitAmount = Math.Round(s.Sum(v => v.a.ChargePrice * v.a.Amount) - (s.Where(m => m.a.PayTypeFlag == PayTypeFlag.PersonPay).Sum(v => v.a.ChargePrice * v.a.Amount)), 2).ToString(), PersonPaidAmount = Math.Round(s.Where(m => m.a.PayTypeFlag == PayTypeFlag.PersonPay && m.a.IsCharge == 'Y').Sum(v => v.a.ChargePrice * v.a.Amount), 2).ToString(), PersonUnPaidAmount = Math.Round(s.Where(m => m.a.PayTypeFlag == PayTypeFlag.PersonPay).Sum(v => v.a.ChargePrice * v.a.Amount) - (s.Where(m => m.a.PayTypeFlag == PayTypeFlag.PersonPay && m.a.IsCharge == 'Y').Sum(v => v.a.ChargePrice * v.a.Amount)), 2).ToString() }).ToList();
return entlistdto; }
}}
|
