using AngleSharp.Dom;
using DS.Module.Core;
using DS.Module.Core.Data;
using DS.Module.Core.Extensions;
using DS.Module.SqlSugar;
using DS.Module.UserModule;
using DS.WMS.Core.Check.Dtos;
using DS.WMS.Core.Check.Entity;
using DS.WMS.Core.Check.Interface;
using DS.WMS.Core.Check.View;
using DS.WMS.Core.Code.Entity;
using DS.WMS.Core.Fee.Dtos;
using DS.WMS.Core.Fee.Entity;
using DS.WMS.Core.Info.Entity;
using DS.WMS.Core.Op.Dtos;
using DS.WMS.Core.Op.Entity;
using DS.WMS.Core.Op.View;
using DS.WMS.Core.Sys.Entity;
using DS.WMS.Core.Sys.Interface;
using DS.WMS.Core.Sys.Method;
using Mapster;
using Microsoft.Extensions.DependencyInjection;
using SqlSugar;
namespace DS.WMS.Core.Check.Method
{
public class CheckBillService : ICheckBillService
{
private readonly IServiceProvider _serviceProvider;
private readonly ISqlSugarClient db;
private readonly IUser user;
private readonly ISaasDbService saasService;
private readonly ICommonService commonService;
///
///
///
///
public CheckBillService(IServiceProvider serviceProvider)
{
_serviceProvider = serviceProvider;
db = _serviceProvider.GetRequiredService();
user = _serviceProvider.GetRequiredService();
saasService = _serviceProvider.GetRequiredService();
commonService = _serviceProvider.GetRequiredService();
}
///
/// 业务明细查询列表
///
///
///
public DataResult> GetBusinessQueryList(PageRequest request)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var users = db.Queryable().Select(x => new { x.Id, x.UserName }).ToList();
//序列化查询条件
var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition);
var otherConditons = new List();
if (request.OtherQueryCondition.IsNotNull())
otherConditons = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.OtherQueryCondition);
var queryData = tenantDb.Queryable()
.Where(whereList);
if (otherConditons.Count > 0)
{
var businessIds = tenantDb.Queryable().Where(otherConditons).Select(x => x.BusinessId).Distinct().ToList();
queryData = queryData.Where(x => businessIds.Contains(x.Id));
}
var data = queryData.ToQueryPage(request.PageCondition);
return data;
}
///
/// 业务明细对应费用查询列表
///
///
///
public DataResult> GetFeeRecordQueryList(PageRequest request)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
//序列化查询条件
var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition);
var data = tenantDb.Queryable()
.Where(whereList).Select()
.ToQueryPage(request.PageCondition);
return data;
}
///
/// 客户对账列表
///
///
///
public DataResult> GetCheckBillList(PageRequest request)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var users = db.Queryable().Select(x => new { x.Id, x.UserName }).ToList();
//序列化查询条件
var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition);
var otherConditons = new List();
if (request.OtherQueryCondition.IsNotNull())
otherConditons = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.OtherQueryCondition);
var queryData = tenantDb.Queryable()
.Where(whereList)
.Select();
if (otherConditons.Count > 0)
{
var checkIds = tenantDb.Queryable().Where(otherConditons).Select(x => x.CheckId).Distinct().ToList();
queryData = queryData.Where(x => checkIds.Contains(x.Id));
}
var data = queryData.Mapper(it =>
{
var checkBillDetails = tenantDb.Queryable().Where(x => x.CheckId == it.Id).ToList();
it.CreateByName = users.Find(x => x.Id == it.CreateBy).UserName;
it.RMBDR = checkBillDetails.Sum(x => x.RMBDR);
it.RMBCR = checkBillDetails.Sum(x => x.RMBCR);
it.USDDR = checkBillDetails.Sum(x => x.USDDR);
it.USDCR = checkBillDetails.Sum(x => x.USDCR);
it.BALRMBDR = checkBillDetails.Sum(x => x.BALRMBDR);
it.BALRMBCR = checkBillDetails.Sum(x => x.BALRMBCR);
it.BALUSDDR = checkBillDetails.Sum(x => x.BALUSDDR);
it.BALUSDCR = checkBillDetails.Sum(x => x.BALUSDCR);
}
)
.ToQueryPage(request.PageCondition);
return data;
}
///
/// 详情
///
///
///
public DataResult GetCheckBillInfo(string id)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var data = tenantDb.Queryable()
.Where(a => a.Id == long.Parse(id))
.Select()
.First();
return DataResult.Success(data, MultiLanguageConst.DataQuerySuccess);
}
///
/// 客户对账明细列表
///
///
///
public DataResult> GetCheckBillBusinessList(PageRequest request)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
//序列化查询条件
var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition);
var data = tenantDb.Queryable()
.Where(whereList)
.ToQueryPage(request.PageCondition);
return data;
}
///
/// 客户对账明细对应费用列表
///
///
///
public DataResult> GetCheckBillFeeRecordsList(PageRequest request)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
//序列化查询条件
var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition);
var data = tenantDb.Queryable()
.Where(whereList)
.ToQueryPage(request.PageCondition);
return data;
}
///
/// 编辑
///
///
///
public DataResult EditCheckBill(CheckBillReq req)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
if (req.Id == 0)
{
var data = req.Adapt();
var sequence = commonService.GetSequenceNext();
if (!sequence.Succeeded)
{
return DataResult.Failed(sequence.Message, MultiLanguageConst.SequenceSetNotExist);
}
data.BillNo = sequence.Data;
var entity = tenantDb.Insertable(data).ExecuteReturnEntity();
if (req.BusinessIds.Count > 0)
{
var businessList = new List();
var feeList = new List();
foreach (var item in req.BusinessIds)
{
businessList.Add(new CheckBillBusiness()
{
CheckId = entity.Id,
BusinessId = item
});
var feeRecords = tenantDb.Queryable().Where(x => x.Id == item).ToList();
foreach (var record in feeRecords)
{
feeList.Add(new CheckBillFeeRecords()
{
CheckId = entity.Id,
BusinessId = item,
FeeRecordId = record.Id,
CheckBillAmount = record.Amount,
});
//对账标识
record.IsDebit = true;
record.DebitNo = entity.Id.ToString();
}
//更新费用记录
tenantDb.Updateable(feeRecords).ExecuteCommand();
}
tenantDb.Insertable(businessList).ExecuteCommand();
tenantDb.Insertable(feeList).ExecuteCommand();
}
return DataResult.Successed("添加成功!", entity.Id, MultiLanguageConst.DataCreateSuccess);
}
else
{
var info = tenantDb.Queryable().Where(x => x.Id == req.Id).First();
if ((bool)info.IsLocking)
return DataResult.Failed("客户对账信息已锁定");
info = req.Adapt(info);
tenantDb.Updateable(info).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommand();
var businessList = new List();
var feeList = new List();
if (req.BusinessIds.Count > 0)
{
var businessIds = tenantDb.Queryable().Where(x => x.CheckId == req.Id).Select(x => x.BusinessId).ToList();
var addBusinessIds = req.BusinessIds.AsQueryable().Except(businessIds);
if (addBusinessIds.Count() > 0)
{
foreach (var item in addBusinessIds)
{
businessList.Add(new CheckBillBusiness()
{
CheckId = info.Id,
BusinessId = item
});
var feeRecords = tenantDb.Queryable().Where(x => x.Id == item).ToList();
foreach (var record in feeRecords)
{
feeList.Add(new CheckBillFeeRecords()
{
CheckId = info.Id,
BusinessId = item,
FeeRecordId = record.Id,
CheckBillAmount = record.Amount,
});
//对账标识
record.IsDebit = true;
record.DebitNo = info.Id.ToString();
}
//更新费用记录
tenantDb.Updateable(feeRecords).ExecuteCommand();
}
tenantDb.Insertable(businessList).ExecuteCommand();
tenantDb.Insertable(feeList).ExecuteCommand();
}
}
return DataResult.Successed("更新成功!", MultiLanguageConst.DataUpdateSuccess);
}
}
///
/// 对账明细批量删除
///
/// 主表Id及明细业务Ids
///
public DataResult BatchDelCheckBillDetail(IdModel req)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var checkId = long.Parse(req.Id);
if (req.Id.IsNull())
return DataResult.Failed("主表Id不能为空");
var info = tenantDb.Queryable().First(x => x.Id == checkId);
if (info.IsNull())
return DataResult.Failed("客户对账信息不存在");
if (req.Ids.Length == 0)
return DataResult.Failed("明细业务Ids不能为空");
if ((bool)info.IsLocking)
return DataResult.Failed("客户对账信息已锁定");
var businessList = tenantDb.Queryable().Where(x => x.CheckId == checkId && req.Ids.Contains(x.BusinessId)).ToList();
if (businessList.Count > 0)
tenantDb.Deleteable(businessList).ExecuteCommand();
var feeList = tenantDb.Queryable().Where(x => x.CheckId == checkId && req.Ids.Contains(x.BusinessId)).ToList();
if (feeList.Count > 0)
{
#region 更新费用记录对账标识
var feeIds = feeList.Select(x => x.FeeRecordId).Distinct().ToList();
var feeRecords = tenantDb.Queryable().Where(x => feeIds.Contains(x.Id)).ToList();
foreach (var record in feeRecords)
{
//对账标识
record.IsDebit = false;
record.DebitNo = "";
}
//更新费用记录
tenantDb.Updateable(feeRecords).ExecuteCommand();
#endregion
tenantDb.Deleteable(feeList).ExecuteCommand();
}
return DataResult.Successed("删除成功!", MultiLanguageConst.DataDelSuccess);
}
///
/// 对账明细费用批量删除
///
/// 主表Id及费用Ids
///
public DataResult BatchDelCheckBillFeeRecords(IdModel req)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var checkId = long.Parse(req.Id);
if (req.Id.IsNull())
return DataResult.Failed("主表Id不能为空");
var info = tenantDb.Queryable().First(x => x.Id == checkId);
if (info.IsNull())
return DataResult.Failed("客户对账信息不存在");
if (req.Ids.Length == 0)
return DataResult.Failed("明细业务Ids不能为空");
if ((bool)info.IsLocking)
return DataResult.Failed("客户对账信息已锁定");
var feeList = tenantDb.Queryable().Where(x => x.CheckId == checkId && req.Ids.Contains(x.FeeRecordId)).ToList();
if (feeList.Count > 0)
{
#region 更新费用记录对账标识
var feeRecords = tenantDb.Queryable().Where(x => req.Ids.Contains(x.Id)).ToList();
foreach (var record in feeRecords)
{
//对账标识
record.IsDebit = false;
record.DebitNo = "";
}
//更新费用记录
tenantDb.Updateable(feeRecords).ExecuteCommand();
#endregion
tenantDb.Deleteable(feeList).ExecuteCommand();
}
return DataResult.Successed("删除成功!", MultiLanguageConst.DataDelSuccess);
}
///
/// 对账明细添加
///
/// 主表Id及明细业务Ids
///
public DataResult AddCheckBillDetail(IdModel req)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var checkId = long.Parse(req.Id);
if (req.Id.IsNull())
return DataResult.Failed("主表Id不能为空");
var info = tenantDb.Queryable().First(x => x.Id == checkId);
if (info.IsNull())
return DataResult.Failed("客户对账信息不存在");
if (req.Ids.Length == 0)
return DataResult.Failed("明细业务Ids不能为空");
if ((bool)info.IsLocking)
return DataResult.Failed("客户对账信息已锁定");
var businessList = new List();
var feeList = new List();
if (tenantDb.Queryable().Where(x => req.Ids.Contains(x.BusinessId) && x.CustomerId!= info.CustomerId).Any())
return DataResult.Failed("明细客户与对账客户不一致");
var businessIds = tenantDb.Queryable().Where(x => x.CheckId == checkId).Select(x => x.BusinessId).ToList();
if (businessIds.Where(x=> req.Ids.Contains(x)).Any())
return DataResult.Failed("明细业务存在已添加");
var addBusinessIds = req.Ids.AsQueryable().Except(businessIds);
if (addBusinessIds.Count() > 0)
{
foreach (var item in addBusinessIds)
{
businessList.Add(new CheckBillBusiness()
{
CheckId = info.Id,
BusinessId = item
});
var feeRecords = tenantDb.Queryable().Where(x => x.Id == item).ToList();
foreach (var record in feeRecords)
{
feeList.Add(new CheckBillFeeRecords()
{
CheckId = info.Id,
BusinessId = item,
FeeRecordId = record.Id,
CheckBillAmount = record.Amount,
});
//对账标识
record.IsDebit = true;
record.DebitNo = info.Id.ToString();
}
//更新费用记录
tenantDb.Updateable(feeRecords).ExecuteCommand();
}
tenantDb.Insertable(businessList).ExecuteCommand();
tenantDb.Insertable(feeList).ExecuteCommand();
}
return DataResult.Successed("添加成功!", MultiLanguageConst.DataUpdateSuccess);
}
///
/// 对账明细费用添加
///
/// 主表Id及明细业务费用Ids
///
public DataResult AddCheckBillFeeRecords(IdModel req)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var checkId = long.Parse(req.Id);
if (req.Id.IsNull())
return DataResult.Failed("主表Id不能为空");
var info = tenantDb.Queryable().First(x => x.Id == checkId);
if (info.IsNull())
return DataResult.Failed("客户对账信息不存在");
if (req.Ids.Length == 0)
return DataResult.Failed("明细业务费用Ids不能为空");
if ((bool)info.IsLocking)
return DataResult.Failed("客户对账信息已锁定");
var feeList = new List();
var feeIds = tenantDb.Queryable().Where(x => x.CheckId == checkId).Select(x => x.FeeRecordId).ToList();
if (feeIds.Where(x => req.Ids.Contains(x)).Any())
return DataResult.Failed("费用明细存在已添加");
var addFeeIds = req.Ids.AsQueryable().Except(feeIds);
if (addFeeIds.Count() > 0)
{
foreach (var item in addFeeIds)
{
var feeRecords = tenantDb.Queryable().Where(x => x.Id == item).ToList();
foreach (var record in feeRecords)
{
feeList.Add(new CheckBillFeeRecords()
{
CheckId = info.Id,
BusinessId = record.BusinessId,
FeeRecordId = record.Id,
CheckBillAmount = record.Amount,
});
//对账标识
record.IsDebit = true;
record.DebitNo = info.Id.ToString();
}
//更新费用记录
tenantDb.Updateable(feeRecords).ExecuteCommand();
}
tenantDb.Insertable(feeList).ExecuteCommand();
}
return DataResult.Successed("添加成功!", MultiLanguageConst.DataUpdateSuccess);
}
///
/// 锁定
///
///
///
public DataResult CheckBillLocking(IdModel req)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
if (req.Ids.Length == 0)
return DataResult.Failed("业务Ids不能为空");
if (tenantDb.Queryable().Where(x => req.Ids.Contains(x.Id) && x.IsLocking == true).Any())
return DataResult.Failed("存在已锁定的客户对账信息");
var list = tenantDb.Queryable().Where(x => req.Ids.Contains(x.Id)).ToList();
//tenantDb.Updateable(list).SetColumns(it=>it.IsLocking == true).ExecuteCommand();
foreach (var item in list)
{
item.IsLocking = true;
}
tenantDb.Updateable(list).ExecuteCommand();
return DataResult.Successed("更新成功!", MultiLanguageConst.DataUpdateSuccess);
}
///
/// 解除锁定
///
///
///
public DataResult CheckBillUnLocking(IdModel req)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
if (req.Ids.Length == 0)
return DataResult.Failed("业务Ids不能为空");
if (tenantDb.Queryable().Where(x => req.Ids.Contains(x.Id) && x.IsLocking == false).Any())
return DataResult.Failed("存在已解除锁定的客户对账信息");
var list = tenantDb.Queryable().Where(x => req.Ids.Contains(x.Id)).ToList();
//tenantDb.Updateable(list).SetColumns(it => it.IsLocking == false).ExecuteCommand();
foreach (var item in list)
{
item.IsLocking = false;
}
tenantDb.Updateable(list).ExecuteCommand();
return DataResult.Successed("更新成功!", MultiLanguageConst.DataUpdateSuccess);
}
///
/// 客户对账模板下拉列表
///
///
public DataResult> GetCheckBillTemplateList()
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var data = tenantDb.Queryable().Where(x => x.Status == StatusEnum.Enable)
.Select().ToList();
return DataResult>.Success(data);
}
///
/// TODO 客户对账模板打印数据
///
///
public DataResult GetCheckBillTemplatePrintInfo(string id)
{
var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var data = new CheckBillTemplatePrintRes();
var checkId = long.Parse(id);
var users = db.Queryable().Select(x => new { x.Id, x.UserName }).ToList();
var bill = tenantDb.Queryable().Where(x => x.Id == checkId).First();
if (bill.IsNull())
return DataResult.Failed("客户对账信息不存在");
if (bill.CheckBillTemplateId == 0)
return DataResult.Failed("请选择保存客户对账模板");
var template = tenantDb.Queryable().Where(x => x.Id == bill.CheckBillTemplateId && x.Status == StatusEnum.Enable).First();
if (template.IsNull())
return DataResult.Failed("客户对账模板不存在或着被禁用");
var feeList = tenantDb.Queryable().Where(x => x.TemplateId == bill.CheckBillTemplateId ).ToList();
if (feeList.Count==0)
return DataResult.Failed("客户对账模板费用信息不能为空");
var sortList = tenantDb.Queryable().Where(x => x.TemplateId == bill.CheckBillTemplateId).ToList();
if (sortList.Count == 0)
return DataResult.Failed("客户对账模板排序信息不能为空");
data = tenantDb.Queryable()
.Where(x => x.Id == checkId)
.Select()
.Mapper(it =>
{
var checkBillDetails = tenantDb.Queryable().Where(x => x.CheckId == it.Id).ToList();
it.CreateByName = users.Find(x => x.Id == it.CreateBy).UserName;
it.RMBDR = checkBillDetails.Sum(x => x.RMBDR);
it.RMBCR = checkBillDetails.Sum(x => x.RMBCR);
it.USDDR = checkBillDetails.Sum(x => x.USDDR);
it.USDCR = checkBillDetails.Sum(x => x.USDCR);
it.BALRMBDR = checkBillDetails.Sum(x => x.BALRMBDR);
it.BALRMBCR = checkBillDetails.Sum(x => x.BALRMBCR);
it.BALUSDDR = checkBillDetails.Sum(x => x.BALUSDDR);
it.BALUSDCR = checkBillDetails.Sum(x => x.BALUSDCR);
}
).First();
var businessList = tenantDb.Queryable().Where(x => x.CheckId == checkId).ToList();
var businessList1 = tenantDb.Queryable().AS("VW_CheckBill_Business").Where("CheckId=@id", new { CheckId = 1 }).ToList();
//foreach (var item in businessList1)
//{
// for (global::System.Int32 i = 0; i < feeList.Count; i++)
// {
// var fee = feeList[i];
// var str = fee.FeeName + "-" + fee.FeeType + "-" + fee.Currency;
// var sumFee = tenantDb.Queryable().Where(x => x.BusinessId == item.BusinessId && x.FeeId == fee.FeeId).Sum(x=>x.Amount);
// item[str] = sumFee;
// //var value = db.DynamicBuilder().CreateObjectByType(type, new Dictionary() { { "Id", 1 }, { "Name", "jack" } })
// }
// //item.CreateProperty
//}
var otherList = new List>();
for (global::System.Int32 i = 0; i < feeList.Count; i++)
{
var fee = feeList[i];
var str = fee.FeeName + "-" + fee.FeeType + "-" + fee.Currency;
//var sumFee = tenantDb.Queryable().Where(x => x.BusinessId == item.BusinessId && x.FeeId == fee.FeeId).Sum(x => x.Amount);
//item[str] = sumFee;
//var value = db.DynamicBuilder().CreateObjectByType(type, new Dictionary() { { "Id", 1 }, { "Name", "jack" } })
}
return DataResult.Success(data);
}
}
}