jinko.yikatong/Src/Dlhis.Canteen/Order/Services/Implements/BalanceService.cs

using Dlhis.Canteen.Order.Request;
using Dlhis.Canteen.Order.Response;
using Dlhis.Entity.Basic.Entity;
using Dlhis.Entity.Canteen.Entities;
using Kurisu.Core.DataAccess.Dto;
using Kurisu.Core.User.Abstractions;
using Kurisu.SqlSugar.Attributes;
using Kurisu.SqlSugar.Extensions;
using Kurisu.SqlSugar.Services;
using SqlSugar;

namespace Dlhis.Canteen.Order.Services.Implements;

public class BalanceService : IBalanceService
{
    private readonly IDbContext _dbContext;
    private readonly ICurrentUser _currentUser;

    public BalanceService(IDbContext dbContext, ICurrentUser currentUser)
    {
        _dbContext = dbContext;
        _currentUser = currentUser;
    }

    public async Task<Pagination<BalanceRecordResponse>> GetPageAsync(BalanceRecordPageRequest request)
    {
        var page = await _dbContext.Queryable<BalanceRecordEntity>()
                .LeftJoin<GainfoEntity>((record, ga) => record.UserNo == ga.No)
                .LeftJoin<DepartmentEntity>((record, ga, department) => ga.DepartmentNo == department.No)
                .LeftJoin<CanteenBusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
                .LeftJoin<CanteenBusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
                .WhereIF(request.SearchDateTimePeriod?.Start.HasValue == true, record => record.CostDate >= request.SearchDateTimePeriod.Start)
                .WhereIF(request.SearchDateTimePeriod?.End.HasValue == true, record => record.CostDate <= request.SearchDateTimePeriod.End)
                .OrderBy(record => record.CreateTime, OrderByType.Desc)
                .Select((record, ga, department, bplace, bshift) => new BalanceRecordResponse
                {
                    Id = record.Id,
                    Amount = record.Amount,
                    BusinessPlaceCode = record.BusinessPlaceCode,
                    BusinessShiftCode = record.BusinessShiftCode,
                    CostDate = record.CostDate,
                    CostId = record.CostId,
                    DepartmentNo = record.DepartmentNo,
                    DeviceInfo = record.DeviceInfo,
                    IP = record.IP,
                    UserNo = record.UserNo,
                    UserCode = record.UserCode,
                    Type = record.Type,
                    SubsidiesFromMonth = record.SubsidiesFromMonth,
                    Status = record.Status,
                    Source = record.Source,
                    No = record.No,
                    IsCostCrossTenant = record.IsCostCrossTenant,
                    OriginTenantId = record.OriginTenantId,
                    Name = record.Name,
                    DepartmentName = department.Name,
                    BusinessPlaceName = bplace.Name,
                    BusinessShiftName = bshift.Name,
                })
                .ToPageListAsync(request);

        return page;
    }

    [IgnoreTenant]
    public async Task<Pagination<BalanceRecordResponse>> GetPageByDeviceUniqueNoAsync(BalanceRecordPageByDeviceUniqueNoRequest request)
    {
        var now = DateTime.Now;
        var start = DateTime.Today;
        var end = new DateTime(now.Year, now.Month, now.Day, 23, 59, 59);

        if (request.SearchDate.HasValue)
        {
            now = request.SearchDate.Value;
            start = new DateTime(now.Year, now.Month, now.Day);
            end = new DateTime(now.Year, now.Month, now.Day, 23, 59, 59);
        }

        var device = await _dbContext.Queryable<DeviceEntity>()
            .Where(x => x.UniqueNo == request.DeviceUniqueNo || x.Code == Guid.Parse(request.DeviceUniqueNo))
            .FirstAsync();

        if (device == null)
        {
            return new Pagination<BalanceRecordResponse>()
            {
                Data = new List<BalanceRecordResponse>()
            };
        }

        var page = await _dbContext.Queryable<BalanceRecordEntity>()
              .LeftJoin<GainfoEntity>((record, ga) => record.UserNo == ga.No)
              .LeftJoin<DepartmentEntity>((record, ga, department) => ga.DepartmentNo == department.No)
              .LeftJoin<CanteenBusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
              .LeftJoin<CanteenBusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
              .WhereIF(request.SearchDate.HasValue, record => record.CostDate >= start)
              .WhereIF(request.SearchDate.HasValue, record => record.CostDate <= end)
              .Where(record => record.DeviceInfo == device.Code.ToString() && record.TenantId == device.TenantId)
              .OrderBy(record => record.CreateTime, OrderByType.Desc)
              .Select((record, ga, department, bplace, bshift) => new BalanceRecordResponse
              {
                  Id = record.Id,
                  Amount = record.Amount,
                  BusinessPlaceCode = record.BusinessPlaceCode,
                  BusinessShiftCode = record.BusinessShiftCode,
                  CostDate = record.CostDate,
                  CostId = record.CostId,
                  DepartmentNo = record.DepartmentNo,
                  DeviceInfo = record.DeviceInfo,
                  IP = record.IP,
                  UserNo = record.UserNo,
                  UserCode = record.UserCode,
                  Type = record.Type,
                  SubsidiesFromMonth = record.SubsidiesFromMonth,
                  Status = record.Status,
                  Source = record.Source,
                  No = record.No,
                  IsCostCrossTenant = record.IsCostCrossTenant,
                  OriginTenantId = record.OriginTenantId,
                  Name = record.Name,
                  DepartmentName = department.Name,
                  BusinessPlaceName = bplace.Name,
                  BusinessShiftName = bshift.Name,
              })
              .ToPageListAsync(request);

        return page;
    }

    public async Task<Pagination<BalanceRecordUserResponse>> GetPageByUserAsync(BalanceRecordUserPageRequest request)
    {
        //当前用户
        var userId = _currentUser.GetIntSubjectId();

        var page = await _dbContext.Queryable<BalanceRecordEntity>()
             .LeftJoin<GainfoEntity>((record, ga) => record.UserNo == ga.No)
             .LeftJoin<DepartmentEntity>((record, ga, department) => ga.DepartmentNo == department.No)
             .LeftJoin<CanteenBusinessPlaceEntity>((record, ga, department, bplace) => record.BusinessPlaceCode == bplace.Code)
             .LeftJoin<CanteenBusinessShiftEntity>((record, ga, department, bplace, bshift) => record.BusinessShiftCode == bshift.Code)
             .WhereIF(request.SearchDateTimePeriod?.Start.HasValue == true, record => record.CostDate >= request.SearchDateTimePeriod.Start)
             .WhereIF(request.SearchDateTimePeriod?.End.HasValue == true, record => record.CostDate <= request.SearchDateTimePeriod.End)
             .Where((record, ga) => ga.IdentityUserId == userId)
             .OrderBy(record => record.CreateTime, OrderByType.Desc)
             .Select((record, ga, department, bplace, bshift) => new BalanceRecordUserResponse
             {
                 Id = record.Id,
                 Amount = record.Amount,
                 Type = record.Type,
                 Status = record.Status,
                 Source = record.Source,
                 No = record.No,
                 BusinessPlaceName = bplace.Name,
                 BusinessShiftName = bshift.Name,
             })
             .ToPageListAsync(request);

        return page;
    }
}