using System;
|
using System.Collections.Generic;
|
using System.Linq.Expressions;
|
using System.Text;
|
using Model.ModelDto;
|
using Model.ModelVm;
|
using SqlSugar;
|
using WMS.BLL.LogServer;
|
using WMS.DAL;
|
using WMS.Entity.BllAsnEntity;
|
using WMS.Entity.Context;
|
using WMS.Entity.DataEntity;
|
using WMS.Entity.SysEntity;
|
using WMS.IBLL.IBllAsnServer;
|
|
namespace WMS.BLL.BllAsnServer
|
{
|
public class AuditLogServer : DbHelper<BllAuditLog>, IAuditLogServer
|
{
|
private static readonly SqlSugarScope Db = DataContext.Db;
|
|
public AuditLogServer() : base(Db)
|
{
|
}
|
|
//获取审核记录信息
|
public List<AuditLogDto> GetAuditLogList(AuditLogVm model, out int count)
|
{
|
try
|
{
|
Expression<Func<BllAuditLog, bool>> item = Expressionable.Create<BllAuditLog>()
|
.AndIF(!string.IsNullOrWhiteSpace(model.AsnNo), it => it.OrderNo.Contains(model.AsnNo.Trim()))
|
.AndIF(!string.IsNullOrWhiteSpace(model.Status), it => it.Status == model.Status)
|
.AndIF(!string.IsNullOrWhiteSpace(model.StartTime), it => it.CreateTime >= Convert.ToDateTime(model.StartTime))
|
.AndIF(!string.IsNullOrWhiteSpace(model.EndTime), it => it.CreateTime <= Convert.ToDateTime(model.EndTime).AddDays(1))
|
.And(it => it.IsDel == "0")
|
.ToExpression();
|
var total = 0;
|
var data = GetAllWhereAsync(item)
|
.LeftJoin<SysUserInfor>((a, b) => a.CreateUser == b.Id)
|
.LeftJoin<SysUserInfor>((a, b, c) => a.AuditUser == c.Id)
|
.Select((a, b, c) => new AuditLogDto()
|
{
|
Id = a.Id,
|
OrderNo = a.OrderNo,
|
PalletNo = a.PalletNo,
|
|
Msg = a.Msg,
|
Status = a.Status,
|
Reason = a.Reason,
|
Opinion = a.Opinion,
|
StartStatus = a.StartStatus,
|
EndStatus = a.EndStatus,
|
FunctionCode = a.FunctionCode,
|
|
CreateUserName = b.RealName,
|
AuditUserName = c.RealName,
|
CreateTime = a.CreateTime,
|
AuditTime = a.AuditTime
|
}).OrderByDescending(a => a.CreateTime).OrderBy(a => a.Status).ToOffsetPage(model.Page, model.Limit, ref total);
|
count = total;
|
return data;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
//编辑审核
|
public void EditAudit(int id, string status, string opinion, int userId)
|
{
|
try
|
{
|
var log = Db.Queryable<BllAuditLog>().First(m => m.Id == id && m.IsDel == "0");
|
if (log == null)
|
{
|
throw new Exception("未查询到审核信息，请核实");
|
}
|
if (log.Status != "0")
|
{
|
throw new Exception("当亲审核信息已审核，不可重复审核");
|
}
|
Db.BeginTran();
|
try
|
{
|
if (status == "1")
|
{
|
if (log.FunctionCode == "001")//入库单撤销
|
{
|
//查询是否有当前单据的其它撤销审核
|
var logList = Db.Queryable<BllAuditLog>()
|
.Where(m => m.IsDel == "0" && m.Status == "0" && m.OrderNo == log.OrderNo && m.Id != id).ToList();
|
if (logList.Count > 0)
|
{
|
throw new Exception("请优先完成当前单据其它托盘绑定撤销");
|
}
|
//库存托盘明细
|
var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.ASNNo == log.OrderNo);
|
//if (stockDetail.Count() == 0)
|
//{
|
// throw new Exception("未查询到库存托盘明细信息");
|
//}
|
var stockDetailToList = stockDetail.ToList();
|
if (stockDetail.Count(m => m.Status != "0" || m.LockQty > 0) > 0)
|
{
|
throw new Exception("库存托盘明细存在出库或分配的货物，无法撤销");
|
}
|
//入库单
|
var notice = Db.Queryable<BllArrivalNotice>().First(m => m.IsDel == "0" && m.ASNNo == log.OrderNo);
|
if (notice == null)
|
{
|
throw new Exception("未查询到该托盘的单据信息");
|
}
|
//入库单明细
|
var noticeDetailList = Db.Queryable<BllArrivalNoticeDetail>().Where(m => m.IsDel == "0" && m.ASNNo == log.OrderNo);
|
if (noticeDetailList.Count() == 0)
|
{
|
throw new Exception("未查询到该托盘的单据明细信息");
|
}
|
|
var noticeDetailListToList = noticeDetailList.ToList();
|
//判断单据库存数量和单据数量是否对应的上
|
var asnQty = noticeDetailList.GroupBy(m => m.ASNNo)
|
.Select(m => SqlFunc.AggregateSum(m.CompleteQty)).First();
|
var stockQty = stockDetail.GroupBy(m => m.ASNNo).Select(m => SqlFunc.AggregateSum(m.Qty))
|
.First();
|
if (asnQty != stockQty && asnQty != null && stockQty != null)
|
{
|
throw new Exception("库存托盘明细存在出库或分配的货物，无法撤销");
|
}
|
//托盘绑定
|
var bindList = Db.Queryable<BllPalletBind>().Where(m =>
|
m.IsDel == "0" && m.ASNNo == log.OrderNo);
|
if (bindList.Count() == 0)
|
{
|
throw new Exception("未查询到单据的托盘绑定信息");
|
}
|
|
if (bindList.Count(m => m.Status == "1") > 0)
|
{
|
throw new Exception("当前入库单据的托盘绑定信息有正在执行的，请稍后完成后再撤销");
|
}
|
|
if (log.EndStatus == "等待执行")
|
{
|
foreach (var item in stockDetailToList)
|
{
|
//总库存
|
var stock = Db.Queryable<DataStock>()
|
.First(m => m.SkuNo == item.SkuNo && m.LotNo == item.LotNo);
|
//库存箱支明细
|
var stockInfo = Db.Queryable<DataBoxInfo>().Where(m => m.StockDetailId == item.Id).ToList();
|
//储位
|
var locate = Db.Queryable<SysStorageLocat>()
|
.First(m => m.IsDel == "0" && m.LocatNo == item.LocatNo);
|
if (item.Qty != null)
|
{
|
if (item.LockQty > 0)
|
{
|
throw new Exception("当前物料批次已被分配，无法撤销");
|
}
|
stock.Qty -= (int)item.Qty;
|
if (stock.Qty == 0)
|
{
|
Db.Deleteable(stock).ExecuteCommand();
|
}
|
else
|
{
|
Db.Updateable(stock).ExecuteCommand();
|
}
|
}
|
Db.Deleteable(item).ExecuteCommand();
|
Db.Deleteable(stockInfo).ExecuteCommand();
|
if (locate != null)
|
{
|
locate.Flag = "1";//储位标识修改为屏蔽
|
Db.Updateable(locate).ExecuteCommand();
|
}
|
}
|
|
notice.Status = "0";
|
Db.Updateable(notice).ExecuteCommand(); //修改入库单
|
|
foreach (var demo in noticeDetailListToList)
|
{
|
demo.Status = "0";
|
demo.FactQty = 0;
|
demo.CompleteQty = 0;
|
Db.Updateable(demo).ExecuteCommand(); //修改入库单明细
|
}
|
//箱支明细更改
|
foreach (var demo in bindList.ToList())
|
{
|
var boxInfo = Db.Queryable<BllBoxInfo>().Where(m => m.BindNo == demo.Id).ToList();
|
foreach (var demo2 in boxInfo)
|
{
|
if (demo2.Origin != "WMS")
|
{
|
if (notice.Type != "1" && notice.Type != "4")
|
{
|
demo2.ASNNo = null;
|
demo2.ASNDetailNo = null;
|
}
|
}
|
demo2.BindNo = null;
|
demo2.PalletNo = null;
|
demo2.Status = "0";
|
demo2.CompleteTime = null;
|
Db.Updateable(demo2).ExecuteCommand();
|
}
|
|
var pallet = Db.Queryable<SysPallets>().First(m => m.PalletNo == demo.PalletNo);
|
if (pallet.Status == "1")
|
{
|
pallet.Status = "0";
|
Db.Updateable(pallet).ExecuteCommand();
|
}
|
}
|
Db.Deleteable<BllPalletBind>(bindList.ToList()).ExecuteCommand(); //删除组托信息
|
|
}
|
|
if (log.EndStatus == "正在执行")
|
{
|
foreach (var item in stockDetailToList)
|
{
|
//总库存
|
var stock = Db.Queryable<DataStock>()
|
.First(m => m.SkuNo == item.SkuNo && m.LotNo == item.LotNo);
|
//库存箱支明细
|
var stockInfo = Db.Queryable<DataBoxInfo>().Where(m => m.StockDetailId == item.Id).ToList();
|
//储位
|
var locate = Db.Queryable<SysStorageLocat>()
|
.First(m => m.IsDel == "0" && m.LocatNo == item.LocatNo);
|
|
if (item.Qty != null)
|
{
|
if (item.LockQty > 0)
|
{
|
throw new Exception("当前物料批次已被分配，无法撤销");
|
}
|
stock.Qty -= (int)item.Qty;
|
if (stock.Qty == 0)
|
{
|
Db.Deleteable(stock).ExecuteCommand();
|
}
|
else
|
{
|
Db.Updateable(stock).ExecuteCommand();
|
}
|
|
}
|
|
Db.Deleteable(item).ExecuteCommand();
|
Db.Deleteable(stockInfo).ExecuteCommand();
|
if (locate != null)
|
{
|
locate.Flag = "1";//储位标识修改为屏蔽
|
Db.Updateable(locate).ExecuteCommand();
|
}
|
}
|
|
//修改入库单
|
notice.Status = "1";
|
Db.Updateable(notice).ExecuteCommand();
|
//修改入库单明细
|
foreach (var demo in noticeDetailListToList)
|
{
|
if (demo.Status == "0")
|
{
|
continue;
|
}
|
demo.Status = "1";
|
demo.CompleteQty = 0;
|
Db.Updateable(demo).ExecuteCommand();
|
|
#region 采购计划
|
if (notice.Type == "1")
|
{
|
//采购单明细
|
var planDetail = Db.Queryable<BllProcurePlanNoticeDetail>().First(it => it.OrderDetailCode == demo.OrderDetailCode && it.IsDel == "0");
|
if (planDetail != null)
|
{
|
planDetail.CompleteQty -= demo.CompleteQty;
|
planDetail.Status = "1";
|
Db.Updateable(planDetail).ExecuteCommand();
|
}
|
}
|
#endregion
|
}
|
#region 采购计划
|
if (notice.Type == "1")
|
{
|
//采购总单信息
|
var planOrd = Db.Queryable<BllProcurePlanNotice>().First(it => it.OrderCode == notice.OrderCode && it.IsDel == "0");
|
if (planOrd != null)
|
{
|
planOrd.Status = "1";
|
Db.Updateable(notice).ExecuteCommand();
|
}
|
}
|
#endregion
|
//修改托盘绑定
|
foreach (var demo in bindList.ToList())
|
{
|
if (demo.Status == "0")
|
{
|
continue;
|
}
|
var boxInfo = Db.Queryable<BllBoxInfo>().Where(m => m.BindNo == demo.Id).ToList();
|
foreach (var demo2 in boxInfo)
|
{
|
demo2.Status = "1";
|
demo2.CompleteTime = null;
|
Db.Updateable(demo2).ExecuteCommand();
|
}
|
demo.Status = "0";
|
demo.LocatNo = "";
|
demo.TaskNo = "";
|
demo.CompleteTime = null;
|
Db.Updateable(demo).ExecuteCommand();
|
}
|
|
#region 初始逻辑版本
|
|
//foreach (var item in stockDetail.ToList())
|
//{
|
// //入库单明细
|
// var noticeDetail = Db.Queryable<BllArrivalNoticeDetail>().First(m => m.IsDel == "0" && m.ASNNo == log.OrderNo && m.Id == item.ASNDetailNo);
|
// if (noticeDetail == null)
|
// {
|
// throw new Exception("未查询到该托盘的单据明细信息");
|
// }
|
// //总库存
|
// var stock = Db.Queryable<DataStock>()
|
// .First(m => m.SkuNo == item.SkuNo && m.LotNo == item.LotNo);
|
// //库存箱支明细
|
// var stockInfo = Db.Queryable<DataBoxInfo>().Where(m => m.StockDetailId == item.Id).ToList();
|
// //储位
|
// var locate = Db.Queryable<SysStorageLocat>()
|
// .First(m => m.IsDel == "0" && m.LocatNo == item.LocatNo);
|
// //托盘绑定
|
// var bind = Db.Queryable<BllPalletBind>().First(m =>
|
// m.IsDel == "0" && m.PalletNo == log.PalletNo && m.ASNNo == log.OrderNo);
|
// if (bind == null)
|
// {
|
// throw new Exception("未查询到托盘绑定信息");
|
// }
|
// if (bind.Status != "2")
|
// {
|
// throw new Exception("托盘绑定信息状态不是执行完成，无法撤销");
|
// }
|
// if (item.Qty != null)
|
// {
|
// stock.Qty -= (int)item.Qty;
|
// Db.Updateable(stock).ExecuteCommand();
|
// }
|
|
// Db.Deleteable(item).ExecuteCommand();
|
// Db.Deleteable(stockInfo).ExecuteCommand();
|
// if (locate != null)
|
// {
|
// locate.Flag = "1";//储位标识修改为屏蔽
|
// Db.Updateable(locate).ExecuteCommand();
|
// }
|
|
// notice.Status = "1";
|
// Db.Updateable(notice).ExecuteCommand();
|
|
// noticeDetail.Status = "1";
|
// noticeDetail.CompleteQty -= bind.Qty;
|
// Db.Updateable(noticeDetail).ExecuteCommand();
|
|
// bind.Status = "0";
|
// bind.LocatNo = "";
|
// bind.TaskNo = "";
|
// bind.CompleteTime = null;
|
// Db.Updateable(bind).ExecuteCommand();
|
//}
|
|
#endregion
|
}
|
|
}
|
else if (log.FunctionCode == "002")//托盘绑定撤销
|
{
|
//库存托盘明细
|
var stockDetail = Db.Queryable<DataStockDetail>()
|
.First(m => m.PalletNo == log.PalletNo && m.ASNNo == log.OrderNo);
|
if (stockDetail == null)
|
{
|
throw new Exception("未查询到库存托盘明细信息");
|
}
|
|
if (stockDetail.Status != "0" || stockDetail.LockQty > 0)
|
{
|
throw new Exception("库存托盘明细存在出库或分配的货物，无法撤销");
|
}
|
//入库单
|
var notice = Db.Queryable<BllArrivalNotice>().First(m => m.IsDel == "0" && m.ASNNo == log.OrderNo);
|
if (notice == null)
|
{
|
throw new Exception("未查询到该托盘的单据信息");
|
}
|
//入库单明细
|
var noticeDetail = Db.Queryable<BllArrivalNoticeDetail>().First(m => m.IsDel == "0" && m.ASNNo == log.OrderNo && m.Id == stockDetail.ASNDetailNo);
|
if (noticeDetail == null)
|
{
|
throw new Exception("未查询到该托盘的单据明细信息");
|
}
|
//总库存
|
var stock = Db.Queryable<DataStock>()
|
.First(m => m.SkuNo == stockDetail.SkuNo && m.LotNo == stockDetail.LotNo);
|
//库存箱支明细
|
var stockInfo = Db.Queryable<DataBoxInfo>().Where(m => m.StockDetailId == stockDetail.Id).ToList();
|
//储位
|
var locate = Db.Queryable<SysStorageLocat>()
|
.First(m => m.IsDel == "0" && m.LocatNo == stockDetail.LocatNo);
|
//托盘绑定
|
var bind = Db.Queryable<BllPalletBind>().First(m =>
|
m.IsDel == "0" && m.PalletNo == log.PalletNo && m.ASNNo == log.OrderNo);
|
if (bind == null)
|
{
|
throw new Exception("未查询到托盘绑定信息");
|
}
|
if (bind.Status != "2")
|
{
|
throw new Exception("托盘绑定信息状态不是执行完成，无法撤销");
|
}
|
|
if (stockDetail.Qty != null)
|
{
|
stock.Qty -= (int)stockDetail.Qty;
|
|
}
|
|
if (stock.Qty == 0)
|
{
|
Db.Deleteable(stock).ExecuteCommand();
|
}
|
else
|
{
|
Db.Updateable(stock).ExecuteCommand();
|
}
|
|
Db.Deleteable(stockDetail).ExecuteCommand();
|
Db.Deleteable(stockInfo).ExecuteCommand();
|
if (locate != null)
|
{
|
locate.Flag = "1";//储位标识修改为屏蔽
|
Db.Updateable(locate).ExecuteCommand();
|
}
|
|
notice.Status = "1";
|
noticeDetail.Status = "1";
|
noticeDetail.CompleteQty -= bind.Qty;
|
Db.Updateable(notice).ExecuteCommand();
|
Db.Updateable(noticeDetail).ExecuteCommand();
|
|
bind.Status = "0";
|
bind.LocatNo = "";
|
bind.TaskNo = "";
|
bind.CompleteTime = null;
|
Db.Updateable(bind).ExecuteCommand();
|
|
}
|
else
|
{
|
throw new Exception("记录的功能编号异常");
|
}
|
}
|
|
log.Status = status;
|
log.Opinion = opinion;
|
log.AuditTime = DateTime.Now;
|
log.AuditUser = userId;
|
Db.Updateable(log).ExecuteCommand();
|
new OperationASNServer().AddLogOperationAsn("入库作业", "审核记录", log.PalletNo, "编辑", $"编辑了单据号为{log.OrderNo}的审核记录", userId);
|
|
Db.CommitTran();
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
|
}
|
}
|
