using SqlSugar.Extensions;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection.Metadata;
|
using System.Text;
|
using System.Threading.Tasks;
|
using System.Transactions;
|
using WIDESEA_Core;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_DTO.Inbound;
|
using WIDESEA_IStockRepository;
|
using WIDESEA_IStockService;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_StockService
|
{
|
public partial class StockInfoDetailService : ServiceBase<Dt_StockInfoDetail, IStockInfoDetailRepository>, IStockInfoDetailService
|
{
|
private readonly IStockInfoDetailRepository _stockInfoDetailRepository;
|
private readonly IStockInfoService _stockInfoService;
|
public StockInfoDetailService(IStockInfoDetailRepository BaseDal, IStockInfoDetailRepository stockInfoDetailRepository, IStockInfoService stockInfoService) : base(BaseDal)
|
{
|
_stockInfoDetailRepository = stockInfoDetailRepository;
|
_stockInfoService = stockInfoService;
|
}
|
|
public IStockInfoDetailRepository Repository => BaseDal;
|
public override WebResponseContent DeleteData(object[] keys)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
var DelStockInfoDetails = BaseDal.QueryData(x => keys.Contains(x.Id)).ToList();
|
if (DelStockInfoDetails == null || DelStockInfoDetails.Count < 1) throw new Exception($"未找到信息");
|
if (DelStockInfoDetails.FirstOrDefault(x => x.Status > StockStatusEmun.组盘暂存.ObjToInt()) != null)
|
throw new Exception($"库存明细状态不为组盘暂存暂不能删除");
|
var StockIds = DelStockInfoDetails.Select(x => x.StockId).ToList();
|
var StockInfoDetails = BaseDal.QueryData(x => StockIds.Contains(x.StockId)).Select(x => x.StockId).GroupBy(x => x).ToList();
|
List<Dt_StockInfo> StockInfos = new List<Dt_StockInfo>();
|
foreach (var item in StockInfoDetails)
|
{
|
if (item.Count() == DelStockInfoDetails.Where(x => x.StockId == item.Key).Count())
|
{
|
var StockInfo = Db.Queryable<Dt_StockInfo>().Where(x => item.Key == x.Id).First();
|
StockInfos.Add(StockInfo);
|
}
|
}
|
List<Dt_InboundOrder> inboundOrders = new List<Dt_InboundOrder>();
|
List<Dt_InboundOrderDetail> inboundOrderDetails = new List<Dt_InboundOrderDetail>();
|
foreach (var DelStockInfoDetail in DelStockInfoDetails.GroupBy(x => x.OrderNo))
|
{
|
var inboundOrder = BaseDal.Db.Queryable<Dt_InboundOrder>().Includes(x => x.Details).First(x => x.OrderNo == DelStockInfoDetail.Key);
|
if (inboundOrder != null)
|
{
|
foreach (var item in DelStockInfoDetail)
|
{
|
var inboundOrderDetail = inboundOrder.Details.FirstOrDefault(x => x.BatchNo == item.BatchNo);
|
if (inboundOrderDetail != null)
|
{
|
inboundOrderDetail.ReceiptQuantity -= 1;// item.StockQuantity;
|
if (inboundOrderDetail.ReceiptQuantity == 0) inboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.New.ObjToInt();
|
}
|
}
|
inboundOrderDetails.AddRange(inboundOrder.Details);
|
if (inboundOrder.Details.FirstOrDefault(x => x.OrderDetailStatus != OrderDetailStatusEnum.New.ObjToInt()) == null)
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.未开始.ObjToInt();
|
inboundOrders.Add(inboundOrder);
|
}
|
}
|
}
|
Db.Ado.BeginTran();
|
BaseDal.Db.Updateable(inboundOrderDetails).ExecuteCommand();
|
BaseDal.Db.Updateable(inboundOrders).ExecuteCommand();
|
_stockInfoService.DeleteData(StockInfos);
|
base.DeleteData(keys);
|
Db.Ado.CommitTran();
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
Db.Ado.RollbackTran();
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
}
|
}
|
