ds8-solution-pro/ds-wms-service/DS.WMS.Core/ContainerManagement/Method/CM_CustFeeDuiService.cs

using DS.Module.Core;
using DS.Module.Core.Extensions;
using DS.Module.SqlSugar;
using DS.Module.UserModule;
using DS.WMS.ContainerManagement.Info.Dtos;
using DS.WMS.ContainerManagement.Info.Entity;
using DS.WMS.ContainerManagement.Info.Interface;
using DS.WMS.Core.Application.Dtos;
using DS.WMS.Core.Application.Entity;
using DS.WMS.Core;
using DS.WMS.Core.Info.Dtos;
using DS.WMS.Core.Info.Entity;
using DS.WMS.Core.Info.Interface;
using DS.WMS.Core.Invoice.Dtos;
using DS.WMS.Core.Op.View;
using DS.WMS.Core.Sys.Entity;
using Mapster;
using Microsoft.Extensions.DependencyInjection;
using Newtonsoft.Json;
using SqlSugar;
using DS.WMS.Core.Fee.Entity;
using DS.WMS.Core.Op.Entity;
using AngleSharp.Dom;
using NPOI.Util;

namespace DS.WMS.ContainerManagement.Info.Method;

//<TEntity> : FeeServiceBase, ISettlementService<TEntity> where TEntity : SettlementBase, new ()
public class CM_CustFeeDuiService : CMServiceBase, ICM_CustFeeDuiService
{
    private readonly IServiceProvider _serviceProvider;
    private readonly ISqlSugarClient db;
    private readonly IUser user;
    private readonly ISaasDbService saasService;

    /// <summary>
    ///
    /// </summary>
    /// <param name="serviceProvider"></param>
    public CM_CustFeeDuiService(IServiceProvider serviceProvider) : base(serviceProvider)
    {
        _serviceProvider = serviceProvider;
        db = _serviceProvider.GetRequiredService<ISqlSugarClient>();
        user = _serviceProvider.GetRequiredService<IUser>();
        saasService = _serviceProvider.GetRequiredService<ISaasDbService>();
    }

    /// <summary>
    /// 列表
    /// </summary>
    /// <param name="request"></param>
    /// <returns></returns>
    public async Task<DataResult<List<CM_CustFeeDuiRes>>> GetListByPage(PageRequest request)
    {
        var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
        //序列化查询条件
        var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition);
        var data = tenantDb.Queryable<CM_CustFeeDui>()
            .Where(whereList)
            .Select<CM_CustFeeDuiRes>().ToQueryPage(request.PageCondition);
        return data;
    }

    /// <summary>
    /// 编辑
    /// </summary>
    /// <param name="req"></param>
    /// <returns></returns>
    public async Task<DataResult> EditCM_CustFeeDui(CM_CustFeeDuiReq req)
    {
        var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
        if (req.Id == 0)
        {
            var data = req.Adapt<CM_CustFeeDui>();

            //var entity = tenantDb.Insertable(data).ExecuteReturnEntity();
            var entity = await tenantDb.Insertable(data).ExecuteReturnEntityAsync();

            //return DataResult.Successed("添加成功!", entity.Id, MultiLanguageConst.DataCreateSuccess);
            return await Task.FromResult(DataResult.Successed("添加成功!", entity.Id, MultiLanguageConst.DataCreateSuccess));
        }
        else
        {
            var info = await tenantDb.Queryable<CM_CustFeeDui>().Where(x => x.Id == req.Id).FirstAsync();

            info = req.Adapt(info);

            await tenantDb.Updateable(info).ExecuteCommandAsync();

            return await Task.FromResult(DataResult.Successed("更新成功!", MultiLanguageConst.DataUpdateSuccess));
        }
    }


    /// <summary>
    /// 详情
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    public DataResult<CM_CustFeeDuiRes> GetCM_CustFeeDui(string id)
    {
        var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
        var data = tenantDb.Queryable<CM_CustFeeDui>()
            .Where(a => a.Id == long.Parse(id))
            .Select<CM_CustFeeDuiRes>()
            .First();
        return DataResult<CM_CustFeeDuiRes>.Success(data, MultiLanguageConst.DataQuerySuccess);
    }

    #region 删除

    /// <summary>
    /// 删除
    /// </summary>
    /// <param name="ids">费用记录ID</param>
    /// <returns></returns>
    public async Task<DataResult> DeleteCM_CustFeeDuiAsync(params long[] ids)
    {

        foreach (var _id in ids) {
        if (await IsLockedAsync(_id, BusinessType.CM_CustFeeDui))
            return DataResult.FailedWithDesc(nameof(MultiLanguageConst.FeeLocked));
        }

        //如果包含费用 不允许删除
        var feeCount = await TenantDb.Queryable<FeeRecord>().Where(x => ids.Contains(x.BusinessId)).CountAsync();

        if (feeCount > 0) {
            return  DataResult.FailedWithDesc(nameof(MultiLanguageConst.CM_FeeExist));
        }

        int result = await TenantDb.Deleteable<CM_CustFeeDui>(x => ids.Contains(x.Id)).ExecuteCommandAsync();

        if (result > 0) {
            //删除所有明细
            await TenantDb.Deleteable<CM_CustFeeDui_Detail>(x => ids.Contains(x.Pid)).ExecuteCommandAsync();
            await TenantDb.Deleteable<CM_CustFeeDui_Calendar>(x => ids.Contains(x.Pid)).ExecuteCommandAsync();
        }

        //await WriteBackStatusAsync(model.BusinessId, model.BusinessType);

        return result > 0 ? DataResult.Success : DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed));
    }

    #endregion


    #region 加入账单

    /// <summary>
    /// 加入账单
    /// </summary>
    /// <param name="ids">箱当前状态ID</param>
    /// <returns></returns>
    //public async Task<DataResult> CM_CustFeeDui_AddCtn(CM_CustFeeDuiReq headreq, params long[] ids)
    //{

    //    foreach (var _id in ids)
    //    {
    //        if (await IsLockedAsync(_id, BusinessType.CM_CustFeeDui))
    //            return DataResult.FailedWithDesc(nameof(MultiLanguageConst.FeeLocked));
    //    }

    //    //int result = await TenantDb.Deleteable<CM_CustFeeDui>(x => ids.Contains(x.Id)).ExecuteCommandAsync();

    //    var currentStateList = await TenantDb.Queryable<CM_CurrentState>().Where(x => ids.Contains(x.Id)).ToListAsync();



    //    if (currentStateList==null || currentStateList.Count == 0 )
    //    {
    //        return DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed));
    //    }

    //    var head = await TenantDb.Queryable<CM_CustFeeDui>().Where(x => x.Id == headreq.Id).FirstAsync();

    //    //针对每个箱状态，寻找其对应的租入、租出
    //}

    #endregion
}