using System;
|
using System.Collections.Generic;
|
using System.ComponentModel.Design;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Text;
|
using Model.InterFaceModel;
|
using Model.ModelDto.BllCheckDto;
|
using Model.ModelDto.BllSoDto;
|
using Model.ModelDto.DataDto;
|
using Model.ModelVm.BllCheckVm;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
using Utility.Tools;
|
using WMS.BLL.LogServer;
|
using WMS.DAL;
|
using WMS.Entity.BllAsnEntity;
|
using WMS.Entity.BllCheckEntity;
|
using WMS.Entity.BllSoEntity;
|
using WMS.Entity.Context;
|
using WMS.Entity.DataEntity;
|
using WMS.Entity.LogEntity;
|
using WMS.Entity.SysEntity;
|
using WMS.IBLL.IBllCheckServer;
|
|
namespace WMS.BLL.BllCheckServer
|
{
|
public class StockCheckServer : DbHelper<BllStockCheck>, IStockCheckServer
|
{
|
private static readonly SqlSugarScope Db = DataContext.Db;
|
public StockCheckServer() : base(Db)
|
{
|
}
|
|
//获取盘点单据
|
public List<StockCheckDto> GetStockCheckList(string crNo, string status, string palletNo, string skuNo, string skuName,
|
string lotNo, string startTime, string endTime, int page, int limit, out int count)
|
{
|
try
|
{
|
var strList = new List<string>();
|
|
if (!string.IsNullOrWhiteSpace(palletNo) || !string.IsNullOrWhiteSpace(skuNo) || !string.IsNullOrWhiteSpace(skuName) || !string.IsNullOrWhiteSpace(lotNo))
|
{
|
Expression<Func<BllStockCheckDetail, bool>> demo = Expressionable.Create<BllStockCheckDetail>()
|
.AndIF(!string.IsNullOrWhiteSpace(palletNo), m => m.PalletNo.Contains(palletNo.Trim()))
|
.AndIF(!string.IsNullOrWhiteSpace(skuNo), m => m.SkuNo.Contains(skuNo.Trim()))
|
.AndIF(!string.IsNullOrWhiteSpace(skuName), m => m.SkuName.Contains(skuName.Trim()))
|
.AndIF(!string.IsNullOrWhiteSpace(lotNo), m => m.LotNo.Contains(lotNo.Trim()))
|
.And(m => m.IsDel == "0")
|
.ToExpression();//注意 这一句 不能少
|
|
var detailList = Db.Queryable<BllStockCheckDetail>().Where(demo).Select(m => m.CRNo).Distinct().ToList();
|
strList = detailList;
|
}
|
|
Expression<Func<BllStockCheck, bool>> item = Expressionable.Create<BllStockCheck>()
|
.AndIF(!string.IsNullOrWhiteSpace(crNo), m => m.CRNo.Contains(crNo.Trim()))
|
.AndIF(!string.IsNullOrWhiteSpace(status), m => m.Status == int.Parse(status))
|
.AndIF(!string.IsNullOrWhiteSpace(startTime), m => m.CheckDate >= Convert.ToDateTime(startTime))
|
.AndIF(!string.IsNullOrWhiteSpace(endTime), m => m.CheckDate <= Convert.ToDateTime(endTime).AddDays(1))
|
.AndIF(!string.IsNullOrWhiteSpace(palletNo), m => strList.Contains(m.CRNo))
|
.AndIF(!string.IsNullOrWhiteSpace(skuNo), m => strList.Contains(m.CRNo))
|
.AndIF(!string.IsNullOrWhiteSpace(skuName), m => strList.Contains(m.CRNo))
|
.AndIF(!string.IsNullOrWhiteSpace(lotNo), m => strList.Contains(m.CRNo))
|
.And(m => m.IsDel == "0")
|
.ToExpression();//注意 这一句 不能少
|
var total = 0;
|
var list = Db.Queryable<BllStockCheck>().Where(item)
|
.LeftJoin<SysUserInfor>((a, b) => a.AuditUser == b.Id)
|
.LeftJoin<SysUserInfor>((a, b, c) => a.CreateUser == c.Id)
|
.LeftJoin<SysUserInfor>((a, b, c, d) => a.CreateUser == d.Id)
|
.LeftJoin<BllStockCheckDetail>((a, b, c, d, e) => a.CRNo == e.CRNo)
|
.Select((a, b, c, d, e) => new StockCheckDto()
|
{
|
Id = a.Id,
|
CrNo = a.CRNo,
|
CheckDate = a.CheckDate,
|
Status = a.Status,
|
AuditStatusNo = a.AuditStatusNo,
|
IsDoubleCheck = a.IsDoubleCheck,
|
AuditUserName = b.RealName,
|
AuditTime = a.AuditTime,
|
|
Qty = e.Qty, //库存数量
|
RealQty = e.RealQty, //实际数量
|
PalletNo = e.PalletNo, //托盘编码
|
CheckResult = e.CheckResult, //盘点结果
|
LotNo = e.LotNo, //批次
|
LotText = e.LotText, //批次描述
|
SkuName = e.SkuName, //物料名称
|
SkuNo = e.SkuNo, //物料编码
|
ZStatus = e.Status, //执行状态
|
|
CreateUserName = c.RealName,
|
UpdateUserName = d.RealName,
|
CreateTime = a.CreateTime,
|
UpdateTime = a.UpdateTime,
|
|
})
|
.OrderByDescending(a => a.CreateTime)
|
.ToOffsetPage(page, limit, ref total);
|
count = total;
|
|
return list;
|
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
//获取盘点单据明细
|
public List<StockCheckDetailDto> GetStockCheckDetailList(string crNo, int page, int limit, out int count)
|
{
|
try
|
{
|
var total = 0;
|
var list = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && m.CRNo == crNo)
|
.LeftJoin<SysUserInfor>((a, b) => a.CreateUser == b.Id)
|
.LeftJoin<SysUserInfor>((a, b, c) => a.UpdateUser == c.Id)
|
.Select((a, b, c) => new StockCheckDetailDto()
|
{
|
Id = a.Id,
|
CrNo = a.CRNo,
|
PalletNo = a.PalletNo,
|
Qty = a.Qty,
|
RealQty = a.RealQty,
|
CheckResult = a.CheckResult,
|
Status = a.Status,
|
SkuNo = a.SkuNo,
|
SkuName = a.SkuName,
|
Standard = a.Standard,
|
LotNo = a.LotNo,
|
LotText = a.LotText,
|
SupplierLot = a.SupplierLot,
|
|
CreateUserName = b.RealName,
|
UpdateUserName = c.RealName,
|
CreateTime = a.CreateTime,
|
UpdateTime = a.UpdateTime,
|
|
}).ToOffsetPage(page, limit, ref total);
|
count = total;
|
|
return list;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
//获取库存明细信息（盘点选择明细数据源）
|
public List<StockDetailDto> GetCheckStockDetailList(string houseNo, string roadwayNo, string locateNo, string skuNo, string lotNo, int page, int limit, out int count)
|
{
|
try
|
{
|
var roadway = Db.Queryable<SysStorageRoadway>().Where(a => a.IsDel == "0" && a.WareHouseNo == "W03" && a.Status == "0").Select(a => a.RoadwayNo).ToList();
|
if (roadway.Count == 0)
|
{
|
throw new Exception("获取失败，当前巷道已被全部禁用!");
|
}
|
Expression<Func<DataStockDetail, bool>> item = Expressionable.Create<DataStockDetail>()
|
.AndIF(!string.IsNullOrWhiteSpace(houseNo), m => m.WareHouseNo == houseNo)
|
.AndIF(!string.IsNullOrWhiteSpace(roadwayNo), m => m.RoadwayNo == roadwayNo)
|
.AndIF(!string.IsNullOrWhiteSpace(locateNo), m => m.LocatNo == locateNo)
|
.AndIF(roadway.Count > 0, m => roadway.Contains(m.RoadwayNo))
|
.AndIF(!string.IsNullOrWhiteSpace(skuNo), m => m.SkuNo.Contains(skuNo.Trim()))
|
.AndIF(!string.IsNullOrWhiteSpace(lotNo), m => m.LotNo.Contains(lotNo.Trim()))
|
.And(m => m.IsDel == "0" && m.SkuNo != "100099" && m.SkuNo != "100098" && m.SkuNo != "100097" && m.SkuNo != "100096" && m.SkuNo != "100095" && m.Status == "0")
|
.ToExpression();//注意 这一句 不能少
|
|
var total = 0;
|
var list = Db.Queryable<DataStockDetail>().Where(item).GroupBy(m => new { m.SkuNo, m.SkuName, m.Standard, m.LotNo, m.LotText, m.SupplierLot, m.LocatNo, m.PalletNo })
|
.Select(a => new StockDetailDto()
|
{
|
SkuNo = a.SkuNo,
|
SkuName = a.SkuName,
|
Standard = a.Standard,
|
LotNo = a.LotNo,
|
LotText = a.LotText,
|
SupplierLot = a.SupplierLot,
|
Qty = SqlFunc.AggregateSum(a.Qty),
|
LocatNo = a.LocatNo,
|
PalletNo = a.PalletNo
|
})
|
.ToOffsetPage(page, limit, ref total).ToList();
|
count = total;
|
return list;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
public EditStockCheckDto GetStockCheckDetailById(string crNo)
|
{
|
try
|
{
|
var notify = Db.Queryable<BllStockCheck>().First(m => m.CRNo == crNo && m.IsDel == "0");
|
if (notify == null)
|
{
|
throw new Exception($"未查询到{crNo}的盘点单据信息");
|
}
|
var detail = Db.Queryable<BllStockCheckDetail>().Where(m => m.CRNo == crNo && m.IsDel == "0").Select(m => new EditStockCheckDetailDto()
|
{
|
SkuNo = m.SkuNo,
|
SkuName = m.SkuName,
|
Standard = m.Standard,
|
LotNo = m.LotNo,
|
LotText = m.LotText,
|
SupplierLot = m.SupplierLot,
|
Qty = (int)m.Qty,
|
|
PalletNo = m.PalletNo
|
}).ToList();
|
var data = new EditStockCheckDto()
|
{
|
CrNo = crNo,
|
Detail = detail
|
};
|
|
return data;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
|
//添加盘点单、编辑盘点单
|
public void AddEditStockCheck(AddEditStockCheckVm model, int userId)
|
{
|
try
|
{
|
if (model.Detail.Count == 0)
|
{
|
throw new Exception("盘点明细不能为空");
|
}
|
Db.BeginTran();
|
var time = DateTime.Now;
|
|
//添加
|
if (string.IsNullOrWhiteSpace(model.CrNo))
|
{
|
var num = Db.Queryable<BllStockCheck>().Count(m => m.IsDel == "0" && m.Status != 3 && m.Status != 4);
|
if (num > 0)
|
{
|
throw new Exception("已有等待执行或正在执行的盘点单据请先完成或删除");
|
}
|
var crNo = new Common().GetMaxNo("CR");
|
//var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.IsDel == "0");
|
var check = new BllStockCheck()
|
{
|
CRNo = crNo,
|
Status = 0,
|
CreateUser = userId,
|
CreateTime = time
|
};
|
var list = new List<BllStockCheckDetail>();
|
foreach (var item in model.Detail)
|
{
|
var detail = new BllStockCheckDetail()
|
{
|
CRNo = crNo,
|
PalletNo = item.PalletNo,
|
Qty = item.Qty,
|
Status = 0, //0：未盘 1：已盘 2：已调整
|
SkuNo = item.SkuNo,
|
SkuName = item.SkuName,
|
Standard = item.Standard,
|
LotNo = item.LotNo,
|
LotText = item.LotText,
|
SupplierLot = item.SupplierLot,
|
|
CreateUser = userId,
|
CreateTime = time
|
};
|
list.Add(detail);
|
var sd = Db.Queryable<DataStockDetail>().First(m => m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo && m.Status == "0" && m.IsDel == "0");
|
sd.Status = "3";
|
|
Db.Updateable(sd).ExecuteCommand();
|
}
|
Db.Insertable(check).ExecuteCommand();
|
Db.Insertable(list).ExecuteCommand();
|
//添加操作日志记录
|
var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", crNo, "添加", $"添加了单据号为{crNo}的盘点单信息", userId);
|
}
|
else //编辑
|
{
|
var check = Db.Queryable<BllStockCheck>().First(m => m.IsDel == "0" && m.CRNo == model.CrNo);
|
if (check == null)
|
{
|
throw new Exception("未查询到盘点单据的信息");
|
}
|
check.UpdateUser = userId;
|
check.UpdateTime = time;
|
Db.Updateable(check).ExecuteCommand();
|
|
//盘点明细信息
|
var checkDetail = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && m.CRNo == model.CrNo).ToList();
|
|
//删除旧的
|
foreach (var d in checkDetail)
|
{
|
var mq = model.Detail.Where(o => o.SkuNo == d.SkuNo && o.LotNo == d.LotNo && o.PalletNo == d.PalletNo).ToList();
|
if (mq.Any()) //如果有这个物料及批次则跳过
|
{
|
continue;
|
}
|
|
var sd = Db.Queryable<DataStockDetail>().Where(m => m.IsDel == "0" && m.SkuNo == d.SkuNo && m.LotNo == d.LotNo && m.PalletNo == d.PalletNo && m.Status == "3").ToList();
|
foreach (var s in sd)
|
{
|
s.Status = "0";
|
|
}
|
d.IsDel = "1";
|
d.UpdateUser = userId;
|
d.UpdateTime = time;
|
//修改库存明细的状态（解除盘点锁定）
|
Db.Updateable(sd).ExecuteCommand();
|
Db.Updateable(d).ExecuteCommand();
|
}
|
|
//添加与修改
|
var list = new List<BllStockCheckDetail>();
|
foreach (var item in model.Detail)
|
{
|
var de = checkDetail.FirstOrDefault(m => m.PalletNo == item.PalletNo && m.SkuNo == item.SkuNo && m.LotNo == item.LotNo);
|
//新加项
|
if (de == null)
|
{
|
var detail = new BllStockCheckDetail()
|
{
|
CRNo = model.CrNo,
|
PalletNo = item.PalletNo,
|
Qty = item.Qty,
|
Status = 0, //0：未盘 1：已盘 2：已调整
|
SkuNo = item.SkuNo,
|
SkuName = item.SkuName,
|
Standard = item.Standard,
|
LotNo = item.LotNo,
|
LotText = item.LotText,
|
SupplierLot = item.SupplierLot,
|
|
CreateUser = userId,
|
CreateTime = time
|
};
|
list.Add(detail);
|
var sd = Db.Queryable<DataStockDetail>().Where(m => m.IsDel == "0" && m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo && m.Status == "0").ToList();
|
foreach (var s in sd)
|
{
|
s.Status = "3";
|
}
|
Db.Updateable(sd).ExecuteCommand();
|
}
|
else if (de.Qty != item.Qty)
|
{
|
de.Qty = item.Qty;
|
de.UpdateUser = userId;
|
de.UpdateTime = time;
|
Db.Updateable(de).ExecuteCommand();
|
}
|
|
}
|
|
if (list.Count > 0)
|
{
|
Db.Insertable(list).ExecuteCommand();
|
}
|
|
//添加操作日志记录
|
var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", model.CrNo, "编辑", $"编辑了单据号为{model.CrNo}的盘点单信息", userId);
|
}
|
Db.CommitTran();
|
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
}
|
|
//删除盘点单
|
public void DelStockCheck(int id, int userId)
|
{
|
try
|
{
|
var notice = Db.Queryable<BllStockCheck>().First(m => m.IsDel == "0" && m.Id == id);
|
if (notice == null || notice.Status != 0)
|
{
|
throw new Exception("未查询到状态为等待执行的盘点单信息");
|
}
|
|
var detail = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && m.CRNo == notice.CRNo).ToList();
|
if (detail.Count == 0)
|
{
|
throw new Exception("未查询到盘点单据明细信息");
|
}
|
Db.BeginTran();
|
var time = DateTime.Now;
|
foreach (var d in detail)
|
{
|
d.IsDel = "1";
|
d.UpdateTime = time;
|
d.UpdateUser = userId;
|
var item = Db.Queryable<DataStockDetail>().Where(m => m.IsDel == "0" && m.PalletNo == d.PalletNo && m.SkuNo == d.SkuNo && m.LotNo == d.LotNo && m.Status == "3").ToList();
|
foreach (var i in item)
|
{
|
i.Status = "0";
|
}
|
Db.Updateable(item).ExecuteCommand();
|
}
|
|
notice.IsDel = "1";
|
notice.UpdateTime = time;
|
notice.UpdateUser = userId;
|
|
Db.Updateable(notice).ExecuteCommand();
|
Db.Updateable(detail).ExecuteCommand();
|
//添加操作日志记录
|
var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", notice.CRNo, "删除", $"删除了单据号为{notice.CRNo}的盘点单信息", userId);
|
Db.CommitTran();
|
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
}
|
|
//调整库存
|
public bool StockAdjust(int id, int userId)
|
{
|
try
|
{
|
#region 判断
|
var notice = Db.Queryable<BllStockCheck>().First(m => m.IsDel == "0" && m.Id == id);
|
if (notice == null || notice.Status != 2)
|
{
|
throw new Exception("未查询到状态为盘点完成的盘点单信息");
|
}
|
|
var detail = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && m.CRNo == notice.CRNo).ToList();
|
if (detail.Count == 0)
|
{
|
throw new Exception("未查询到盘点单据明细信息");
|
}
|
#endregion
|
|
Db.BeginTran(); //开启事务
|
//盘点总表
|
var check = Db.Queryable<BllStockCheck>().First(m => m.IsDel == "0" && m.Id == id);
|
//盘点明细
|
var checkDetail = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && m.CRNo == check.CRNo).ToList();
|
//盘点记录
|
var checkLog = Db.Queryable<BllStockCheckLog>().Where(m => m.IsDel == "0" && m.CRNo == check.CRNo).ToList();
|
//对应库存记录
|
|
//时间
|
var time = DateTime.Now;
|
|
//循环盘点明细
|
foreach (var item in checkDetail)
|
{
|
//根据盘点明细物料信息获取库存明细
|
var dataStockDetail = Db.Queryable<DataStockDetail>().First(m => m.IsDel == "0" && m.PalletNo == item.PalletNo && m.SkuNo == item.SkuNo && m.SkuName == item.SkuName && m.LotNo == item.LotNo);
|
//根据盘点明细物料信息获取库存表
|
var dataStock = Db.Queryable<DataStock>().First(m => m.IsDel == "0" && m.SkuNo == item.SkuNo && m.SkuName == item.SkuName && m.LotNo == item.LotNo);
|
//根据盘点明细物料信息获取托盘绑定信息
|
var palletBind = Db.Queryable<BllPalletBind>().First(m => m.IsDel == "0" && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo);
|
//判断托盘绑定信息是否为空
|
if (palletBind == null)
|
{
|
throw new Exception("未查询到托盘绑定信息,请核查！");
|
}
|
item.Status = 4; //库存明细 4：已调整
|
item.UpdateTime = time; //修改时间
|
item.UpdateUser = userId; //修改人
|
//获取实际数量减去系统数量
|
var num = 0;
|
//判断盘点明细表中盘点状态为什么
|
//正常
|
if (item.CheckResult == 0)
|
{
|
//正常则不改变任何数量 改变库存明细
|
dataStockDetail.Status = "0"; //状态改为 0：待分配
|
Db.Updateable(dataStockDetail).ExecuteCommand(); //库存明细表
|
}
|
//盘亏\盘盈
|
else if (item.CheckResult == 1 || item.CheckResult == 2)
|
{
|
//获取对应物料当天库存信息
|
string strinfo = $"select top 1 * from DataStockInfo where IsDel = '0' and SkuNo = '{item.SkuNo}' order by CreateTime desc";
|
var datainfo = Db.Ado.SqlQuerySingle<DataStockInfo>(strinfo);
|
|
if (item.CheckResult == 1)
|
{
|
//盘亏 系统数量减去实际数量
|
num = (int)item.Qty - (int)item.RealQty;
|
//库存总表数量为实际数量
|
dataStock.Qty -= num;
|
Db.Updateable(dataStock).ExecuteCommand(); //库存表
|
}
|
else if (item.CheckResult == 2)
|
{
|
//盘盈 实际数量减去系统数量
|
num = (int)item.RealQty - (int)item.Qty;
|
//库存总表数量为实际数量
|
dataStock.Qty += num;
|
Db.Updateable(dataStock).ExecuteCommand(); //库存表
|
}
|
|
//库存明细表根据托盘修改数量
|
dataStockDetail.Qty = (int)item.RealQty;
|
dataStockDetail.Status = "0"; //状态改为 0：待分配
|
dataStockDetail.BitPalletMark = item.RealQty == palletBind.FullQty ? "0" : "1"; //判断是否满托
|
Db.Updateable(dataStockDetail).ExecuteCommand(); //库存明细表
|
|
#region 库存记录
|
|
//datainfo.ArrivalQty += 0;//入库数量
|
datainfo.ExportQty += (int)item.RealQty;//入库数量
|
datainfo.BalanceQty += (int)item.RealQty;//结存数量
|
datainfo.YearBalanceQty += (int)item.RealQty;//结存数量(月)
|
datainfo.YearExportQty += (int)item.RealQty;//入库数量（月）
|
Db.Updateable(datainfo).ExecuteCommand();
|
|
#endregion
|
}
|
Db.Updateable(item).ExecuteCommand(); //盘点明细表
|
}
|
|
//修改盘点总表信息
|
check.Status = 3; //状态为3：已调整
|
check.AuditTime = time; //操作时间
|
check.AuditUser = userId; //操作人
|
Db.Updateable(check).ExecuteCommand();//修改盘点总表
|
|
//添加操作日志记录
|
var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", check.CRNo, "调整", $"调整了单据号为{check.CRNo}的盘点单信息", userId);
|
|
Db.CommitTran();
|
return true;
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
//throw new NotImplementedException();
|
}
|
|
//作废盘点单
|
public bool ZuofeiCr(int id, int userId)
|
{
|
try
|
{
|
#region 判断
|
var notice = Db.Queryable<BllStockCheck>().First(m => m.IsDel == "0" && m.Id == id);
|
if (notice == null || notice.Status != 2)
|
{
|
throw new Exception("未查询到状态为盘点完成的盘点单信息");
|
}
|
|
var detail = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && m.CRNo == notice.CRNo).ToList();
|
if (detail.Count == 0)
|
{
|
throw new Exception("未查询到盘点单据明细信息");
|
}
|
#endregion
|
|
Db.BeginTran(); //开启事务
|
//盘点总表
|
var check = Db.Queryable<BllStockCheck>().First(m => m.IsDel == "0" && m.Id == id);
|
//盘点明细
|
var checkDetail = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && m.CRNo == check.CRNo).ToList();
|
//时间
|
var time = DateTime.Now;
|
|
//循环盘点明细
|
foreach (var item in checkDetail)
|
{
|
//根据盘点明细物料信息获取库存明细
|
var dataStockDetail = Db.Queryable<DataStockDetail>().First(m => m.IsDel == "0" && m.PalletNo == item.PalletNo && m.SkuNo == item.SkuNo && m.SkuName == item.SkuName && m.LotNo == item.LotNo);
|
|
dataStockDetail.Status = "0"; //状态改为 0：待分配
|
Db.Updateable(dataStockDetail).ExecuteCommand(); //库存明细表
|
|
}
|
//修改盘点总表信息
|
check.Status = 4; //状态为4：已作废
|
check.AuditTime = time; //操作时间
|
check.AuditUser = userId; //操作人
|
Db.Updateable(check).ExecuteCommand();//修改盘点总表
|
|
//添加操作日志记录
|
var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", check.CRNo, "作废", $"作废了单据号为{check.CRNo}的盘点单信息", userId);
|
|
Db.CommitTran();
|
return true;
|
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
//throw new NotImplementedException();
|
}
|
|
//盘点下发出库
|
public List<OutCommandDto> CheckOutHouse(string crNo, int userId, string url, out string str)
|
{
|
try
|
{
|
//测试url 发布服务器后删除
|
//url = "http://localhost:57061/api/WCSApi/AddTasks";
|
|
#region 集合
|
|
//获取未锁定巷道
|
var roadway = Db.Queryable<SysStorageRoadway>().Where(a => a.IsDel == "0" && a.WareHouseNo == "W03" && a.Status == "0").Select(a => a.RoadwayNo).ToList();
|
//验证是否存在未锁定巷道
|
if (roadway.Count == 0)
|
{
|
throw new Exception("当前无未锁定巷道，请解除！");
|
}
|
|
var outDtoList = new List<OutCommandDto>(); //出库数据的集合
|
var outDtoList1 = new List<OutCommandDto>(); //后出库数据的集合（深度为2的储位）
|
var moveDto = new List<OutCommandDto>(); //要移库数据的集合
|
//记录错误信息的集合
|
var flagList = new List<int>();//1:当前要出库的储位正在移出、2 出库的托盘储位信息错误(在储位表中未查询到)、3储位损坏不能出库、4 要出库的托盘正在入库
|
|
#endregion
|
var com = new Common();
|
//assign.IsHavePyTask();
|
var notice = Db.Queryable<BllStockCheck>().First(m => m.CRNo == crNo && m.IsDel == "0");
|
if (notice == null)
|
{
|
throw new Exception($"未找到{crNo}盘点单信息");
|
}
|
//所有要出库的盘点明细信息(等待的信息和待拣货的信息)
|
var list = Db.Queryable<BllStockCheckDetail>().Where(a => a.IsDel == "0" && a.CRNo == crNo && (a.Status == 0 || a.Status == 1)).ToList();
|
if (list.Count == 0) //判断是否有需要下发的盘点明细
|
{
|
throw new Exception("当前盘点单据无需要下发的托盘");
|
}
|
|
|
#region
|
//要出库的托盘集合
|
var outLpnList = list.Select(m => m.PalletNo).Distinct().ToList();
|
//要出库的明细集合
|
var outStockDetail = Db.Queryable<DataStockDetail>().Where(m => m.IsDel == "0" && roadway.Contains(m.RoadwayNo) && outLpnList.Contains(m.PalletNo)).ToList();
|
var outStockBox = Db.Queryable<DataBoxInfo>().Where(m => m.IsDel == "0" && outLpnList.Contains(m.PalletNo)).ToList();
|
|
if (outStockDetail.Count == 0)
|
{
|
throw new Exception("当前未禁用巷道无可分配货物不足，禁止出库！");
|
}
|
|
int? dataStockQtyCount = 0;
|
foreach (var item in outStockDetail)
|
{
|
dataStockQtyCount += item.Qty;
|
if (dataStockQtyCount >= list[0].Qty)
|
{
|
break;
|
}
|
}
|
if (dataStockQtyCount < list[0].Qty)
|
{
|
throw new Exception("当前未禁用巷道可分配货物不足，禁止出库！");
|
}
|
|
var time = DateTime.Now;
|
Db.BeginTran();
|
try
|
{
|
//循环盘点明细的信息生成出库任务
|
foreach (var item in list)
|
{
|
var taskNoStr = "";
|
//获取物料信息
|
var sku = Db.Queryable<SysMaterials>().First(m => m.IsDel == "0" && m.SkuNo == item.SkuNo);
|
|
if (item.Status == 0)
|
{
|
var de = outStockDetail.Where(m =>
|
m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo).Select(m => m.Id).ToList();
|
var bo = outStockBox.Where(m => de.Contains(m.StockDetailId)).ToList();
|
var logList = new List<BllStockCheckLog>();
|
foreach (var b in bo)
|
{
|
var checkLog = new BllStockCheckLog()
|
{
|
CRNo = item.CRNo,
|
PalletNo = item.PalletNo,
|
BoxNo = b.BoxNo,
|
BoxNo2 = b.BoxNo2,
|
BoxNo3 = b.BoxNo3,
|
Qty = b.Qty,
|
SkuNo = b.SkuNo,
|
SkuName = b.SkuName,
|
Standard = b.Standard,
|
LotNo = b.LotNo,
|
LotText = b.LotText,
|
SupplierLot = b.SupplierLot,
|
|
CreateUser = userId,
|
CreateTime = time
|
};
|
logList.Add(checkLog);
|
}
|
|
Db.Insertable(logList).ExecuteCommand();
|
}
|
// 储位号
|
var locateNo = outStockDetail.First(m => m.PalletNo == item.PalletNo && m.SkuNo == item.SkuNo && m.LotNo == item.LotNo).LocatNo;
|
|
#region 判断
|
|
//判断托盘是否在库内
|
if (string.IsNullOrWhiteSpace(locateNo))
|
{
|
//判断托盘是否在入库中
|
var imBl = com.GetImTask(item.PalletNo);
|
if (imBl != null)
|
{
|
flagList.Add(4);
|
continue;
|
}
|
//判断是否是已经出过库又回库（状态为待拣货的 1）
|
if (item.Status == 0)
|
{
|
//如果不在仓库内，当前明细信息直接更新出库完成
|
item.Status = 2;//状态
|
Db.Updateable(item).ExecuteCommand();
|
|
}
|
continue;
|
}
|
//当前出库的储位信息
|
var locate = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == locateNo && m.IsDel == "0");
|
if (locate == null)
|
{
|
flagList.Add(2);
|
continue;
|
}
|
//判断储位标志是否为损坏
|
if (locate.Flag == "2")
|
{
|
flagList.Add(3);
|
continue;
|
}
|
|
#endregion
|
|
if (locate.Status == "1") //有物品
|
{
|
#region 添加出库任务
|
if (locate.Depth == "01") //深度为1
|
{
|
|
var taskNo = new Common().GetMaxNo("TK");
|
var exTask = new LogTask //出库任务
|
{
|
TaskNo = taskNo,
|
Sender = "WMS",
|
Receiver = "WCS",
|
IsSuccess = 0, //是否下发成功 0失败 1成功
|
|
StartLocat = locate.LocatNo,//起始位置
|
EndLocat = "",//目标位置
|
PalletNo = item.PalletNo,//托盘码
|
IsSend = 1,//是否可再次下发
|
IsCancel = 1,//是否可取消
|
IsFinish = 1,//是否可完成
|
Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务
|
Status = "0",//任务状态0：等待执行1正在执行2执行完成
|
OrderType = "2",//0 入库单 1 出库单 2 盘点单 3 移库单
|
|
CreateTime = time,
|
Msg = locate.LocatNo + "==>>的盘点任务"
|
};
|
Db.Insertable(exTask).ExecuteCommand();
|
|
outDtoList1.Add(new OutCommandDto()
|
{
|
SkuType = sku.Type, //物料类型
|
StartRoadway = locate.RoadwayNo, //巷道号
|
PalletNo = item.PalletNo,//托盘号
|
StartLocat = locate.LocatNo, // 起始位置
|
EndLocat = "28", // 目标位置
|
TaskNo = exTask.TaskNo, // 任务号
|
Type = "1",// 任务类型 (出库)
|
OutMode = "", //目标地址
|
Order = 1,
|
LotNo = item.LotNo,
|
IsBale = "0",
|
IsBelt = "0",
|
PalletType = outStockDetail.First(m => m.PalletNo == item.PalletNo && m.SkuNo == item.SkuNo && m.LotNo == item.LotNo).PalletType
|
});
|
}
|
else if (locate.Depth == "02") //深度为2
|
{
|
//获取出库深度为2储位前面的储位信息
|
var slotBefore = com.GetLocateNoDepth1(locate.WareHouseNo, locate.LocatNo);
|
if (slotBefore.Status == "1") //前面的储位有货物、进行移库操作
|
{
|
//要出库深度为2的储位前面的储位中货物是否要出库
|
var isout = outStockDetail.Count(m => m.LocatNo == slotBefore.LocatNo);
|
|
if (isout <= 0) //进行移库
|
{
|
//去库存表中找到储位对应的托盘码操作
|
var stockNew = Db.Queryable<DataStockDetail>().First(m => m.LocatNo == slotBefore.LocatNo);
|
if (stockNew == null)
|
{
|
var slotChange = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == slotBefore.LocatNo);
|
slotChange.Status = "0";
|
Db.Updateable(slotChange).ExecuteCommand();
|
}
|
else
|
{
|
//获取移库的库位
|
var newSlot = MoveAddress(slotBefore.LocatNo, slotBefore.RoadwayNo, slotBefore.AreaNo);
|
//当前移库库位的储位信息
|
var locatey = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == newSlot && m.IsDel == "0");
|
if (!string.IsNullOrEmpty(newSlot))
|
{
|
#region 添加出库时发生的移库任务
|
|
var exYkTaskNo = new Common().GetMaxNo("TK");
|
var exYkTask = new LogTask //出库时产生移库任务
|
{
|
TaskNo = exYkTaskNo,
|
Sender = "WMS",
|
Receiver = "WCS",
|
IsSuccess = 0, //是否下发成功 0失败 1成功
|
|
StartLocat = stockNew.LocatNo,//起始位置
|
EndLocat = newSlot,//目标位置
|
PalletNo = stockNew.PalletNo,//托盘码
|
IsSend = 1,//是否可再次下发
|
IsCancel = 1,//是否可取消
|
IsFinish = 1,//是否可完成
|
Type = "2",//任务类型 0 入库任务 1 出库任务 2 移库任务
|
Status = "0",//任务状态0：等待执行1正在执行2执行完成
|
OrderType = "2",//0 入库单 1 出库单 2 盘点单 3 移库单
|
|
CreateTime = time,
|
|
Msg = stockNew.LocatNo + " ==>> " + newSlot + "的移库任务",
|
};
|
Db.Insertable(exYkTask).ExecuteCommand();
|
|
moveDto.Add(new OutCommandDto()
|
{
|
SkuType = sku.Type, //物料类型
|
StartRoadway = slotBefore.RoadwayNo, //起始巷道
|
PalletNo = stockNew.PalletNo,//托盘号
|
StartLocat = stockNew.LocatNo, // 起始位置
|
EndLocat = newSlot, // 目标位置
|
EndRoadway = locatey.RoadwayNo, // 目标巷道
|
TaskNo = exYkTask.TaskNo, // 任务号
|
Type = "2",// 任务类型 (移库)
|
OutMode = "", //目标地址
|
Order = 1,
|
LotNo = stockNew.LotNo,
|
Qty = 0, //拣货数量
|
FullQty = (int)stockNew.Qty, //托盘数量
|
//PalletType = stockNew.PalletType, //托盘类型(有无子托)0||空||null：无子托盘1：有子托盘
|
});
|
#endregion
|
|
#region 改变储位装填
|
var slotChange = Db.Queryable<SysStorageLocat>().First(m => m.Id == slotBefore.Id);
|
var slotChange2 = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == newSlot);
|
slotChange.Status = "5"; //改变状态（正在移出）
|
slotChange2.Status = "4"; // 改变状态（正在移入）
|
Db.Updateable(slotChange).ExecuteCommand();
|
Db.Updateable(slotChange2).ExecuteCommand();
|
#endregion
|
}
|
else
|
{
|
#region 添加出库任务
|
|
var exYkTaskNo1 = new Common().GetMaxNo("TK");
|
var exYkTask1 = new LogTask //出库移库没有库位了进行出库任务
|
{
|
TaskNo = exYkTaskNo1,
|
Sender = "WMS",
|
Receiver = "WCS",
|
IsSuccess = 0, //是否下发成功 0失败 1成功
|
|
StartLocat = stockNew.LocatNo,//起始位置
|
EndLocat = "",//目标位置
|
PalletNo = stockNew.PalletNo,//托盘码
|
IsSend = 1,//是否可再次下发
|
IsCancel = 1,//是否可取消
|
IsFinish = 1,//是否可完成
|
Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务
|
Status = "0",//任务状态0：等待执行1正在执行2执行完成
|
OrderType = "2",//0 入库单 1 出库单 2 盘点单 3 移库单
|
Msg = locate.LocatNo + "的出库任务"
|
};
|
Db.Insertable(exYkTask1).ExecuteCommand();
|
|
outDtoList1.Add(new OutCommandDto()
|
{
|
SkuType = sku.Type, //物料类型
|
StartRoadway = slotBefore.RoadwayNo, //起始巷道
|
PalletNo = stockNew.PalletNo,//托盘号
|
StartLocat = stockNew.LocatNo, // 起始位置
|
EndLocat = "", // 目标位置
|
TaskNo = exYkTask1.TaskNo, // 任务号
|
Type = "1",// 任务类型 (出库)
|
OutMode = "", //目标地址
|
Order = 1,
|
LotNo = "", // 批次
|
IsBale = "0", //是否裹包
|
IsBelt = "0", //是否打带
|
//IsStacking1 = item.IsAdvance, //是否拆桶（08暂定）
|
Qty = 0, //拣货数量
|
FullQty = (int)stockNew.Qty, //托盘数量
|
PalletType = stockNew.PalletType, //托盘类型(有无子托)0||空||null：无子托盘1：有子托盘
|
});
|
#endregion
|
|
#region MyRegion
|
|
var slotChange = Db.Queryable<SysStorageLocat>().First(m => m.Id == slotBefore.Id);
|
slotChange.Status = "3"; //改变状态（正在出库）
|
Db.Updateable(slotChange).ExecuteCommand();
|
|
#endregion
|
}
|
}
|
}
|
}
|
else if (slotBefore.Status == "2" || slotBefore.Status == "4") //前面储位状态是入库中或者移入中
|
{
|
flagList.Add(5);
|
continue;
|
}
|
|
#region 添加出库任务
|
|
var taskNo1 = new Common().GetMaxNo("TK");
|
var exTask1 = new LogTask //出库任务
|
{
|
TaskNo = taskNo1,
|
Sender = "WMS",
|
Receiver = "WCS",
|
IsSuccess = 0, //是否下发成功 0失败 1成功
|
|
StartLocat = locate.LocatNo,//起始位置
|
EndLocat = "",//目标位置
|
PalletNo = item.PalletNo,//托盘码
|
IsSend = 1,//是否可再次下发
|
IsCancel = 1,//是否可取消
|
IsFinish = 1,//是否可完成
|
Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务
|
Status = "0",//任务状态0：等待执行1正在执行2执行完成
|
OrderType = "2",//0 入库单 1 出库单 2 盘点单 3 移库单
|
Msg = locate.LocatNo + "的出库任务"
|
};
|
Db.Insertable(exTask1).ExecuteCommand();
|
|
outDtoList1.Add(new OutCommandDto()
|
{
|
SkuType = sku.Type, //物料类型
|
StartRoadway = locate.RoadwayNo, //起始巷道
|
PalletNo = item.PalletNo,//托盘号
|
StartLocat = locate.LocatNo, // 起始位置
|
EndLocat = "", // 目标位置
|
TaskNo = exTask1.TaskNo, // 任务号
|
Type = "1",// 任务类型 (出库)
|
OutMode = "", //目标地址
|
Order = 1,
|
IsBale = "0", //是否裹包
|
IsBelt = "0", //是否打带
|
IsStacking1 = "0", //是否拆桶（08暂定）
|
Qty = (int)item.Qty, //拣货数量
|
//FullQty = (int)item.BoxexQty, //托盘数量
|
//PalletType = stockDetail.PalletType, //托盘类型(有无子托)0||空||null：无子托盘1：有子托盘
|
});
|
taskNoStr = exTask1.TaskNo;
|
#endregion
|
|
}
|
|
|
|
#endregion
|
|
#region 改变数据
|
if (item.Status == 0)//判断托盘是否下发过
|
{
|
|
}
|
locate.Status = "3"; //要出库的储位改变状态 正在出库
|
Db.Updateable(locate).ExecuteCommand();
|
|
item.TaskNo = taskNoStr; // 出库分配信息中更新任务号
|
item.Status = 1; // 出库分配信息状态改为正在执行
|
Db.Updateable(item).ExecuteCommand();
|
|
|
#endregion
|
|
flagList.Add(0);
|
}
|
else if (locate.Status == "3") //出库中
|
{
|
#region 改变数据
|
//判断是否是已经出过库又回库（状态为待拣货的 1）
|
if (item.Status == 0)
|
{
|
}
|
var taskNo = Db.Queryable<LogTask>().First(m => m.OrderType == "2" && m.TaskNo != item.TaskNo && m.Status == "1" && m.PalletNo == item.PalletNo);
|
item.TaskNo = taskNo.TaskNo;
|
item.Status = 1; // 出库分配信息状态改为正在执行
|
Db.Updateable(item).ExecuteCommand();
|
|
#endregion
|
}
|
else if (locate.Status == "5") //移出中
|
{
|
flagList.Add(1);
|
}
|
}
|
|
//先移库后出库
|
outDtoList.AddRange(moveDto);
|
outDtoList.AddRange(outDtoList1);
|
|
if (outDtoList.Count > 0)
|
{
|
if (notice.Status == 0)
|
{
|
notice.Status = 1;
|
notice.UpdateUser = userId;
|
notice.UpdateTime = time;
|
notice.CheckDate = time;
|
Db.Updateable(notice).ExecuteCommand();
|
|
}
|
}
|
//添加操作日志记录
|
var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", crNo, "出库", $"点击出库按钮盘点单号为：{crNo}的盘点单", userId);
|
|
|
str = string.Empty;
|
if (flagList.Count(m => m == 1) > 0)
|
{
|
str += "1.当前要出库的储位正在移出、";
|
}
|
if (flagList.Count(m => m == 2) > 0)
|
{
|
str += "2.出库的托盘储位信息错误(在储位表中未查询到)、";
|
}
|
if (flagList.Count(m => m == 3) > 0)
|
{
|
str += "4.储位损坏不能出库、";
|
}
|
if (flagList.Count(m => m == 4) > 0)
|
{
|
str += "3.要出库的托盘正在入库、";
|
}
|
if (outDtoList.Count > 0)
|
{
|
//正式运行程序放开
|
var list2 = outDtoList.Select(m => m.TaskNo).ToList();
|
var jsonData = JsonConvert.SerializeObject(outDtoList);
|
string response = "";
|
|
try
|
{
|
var time1 = DateTime.Now;//发送时间 .ToString("yyyy-MM-dd HH:mm:ss")
|
response = HttpHelper.DoPost(url, jsonData, "下发给WCS出库命令", "WCS");
|
var time2 = DateTime.Now;//返回时间 .ToString("yyyy-MM-dd HH:mm:ss")
|
|
//解析返回数据
|
var wcsModel = JsonConvert.DeserializeObject<WcsModel>(response);
|
if (wcsModel.stateCode == 0)
|
{
|
//更改任务的发送返回时间//
|
new TaskServer().EditTaskIssueOk(list2, time1, time2);
|
str += "下发成功";
|
}
|
if (wcsModel.stateCode == -1)
|
{
|
new TaskServer().EditTaskIssueNo(list2, time1, time2, wcsModel.errMsg);
|
throw new Exception(wcsModel.errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
throw new Exception(ex.Message);
|
}
|
|
}
|
Db.CommitTran();
|
return outDtoList;
|
}
|
catch (Exception e)
|
{
|
|
throw new Exception(e.Message);
|
}
|
|
|
#endregion
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
}
|
|
//盘点出库完成
|
public void CheckSuccess(string taskNo, int userId, string url)
|
{
|
try
|
{
|
//当前任务信息
|
var task = Db.Queryable<LogTask>().First(m => m.TaskNo == taskNo && m.IsDel == "0");
|
if (task == null)
|
{
|
throw new Exception($"未查询到任务号为：‘{taskNo}’的任务信息");
|
}
|
if (task.Status == "2")
|
{
|
throw new Exception("当前任务已完成");
|
}
|
Db.BeginTran();
|
//库存中当前托盘的信息
|
var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.PalletNo == task.PalletNo).ToList();
|
var locateNo = stockDetail.Select(m => m.LocatNo).Distinct().FirstOrDefault();
|
//当前任务中的储位信息
|
var locate = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == locateNo);
|
|
|
task.Status = "2";//任务状态
|
task.IsSend = 0;
|
task.IsCancel = 0;
|
task.IsFinish = 0;
|
task.FinishDate = DateTime.Now;//完成时间
|
Db.Updateable(task).ExecuteCommand();
|
locate.Status = "0"; // 更改当前任务中的储位状态（改为0空储位）
|
Db.Updateable(locate).ExecuteCommand();
|
foreach (var item in stockDetail)
|
{
|
//获取对应物料当天库存信息
|
string strinfo = $"select top 1 * from DataStockInfo where IsDel = '0' and SkuNo = '{item.SkuNo}' order by CreateTime desc";
|
var datainfo = Db.Ado.SqlQuerySingle<DataStockInfo>(strinfo);
|
|
item.LocatNo = "";//储位更改（改为空）
|
item.WareHouseNo = "";//所属仓库更改（改为空）
|
item.RoadwayNo = "";//所属巷道更改（改为空）
|
item.AreaNo = "";//所属区域更改（改为空）
|
item.Status = "0"; //分配状态（改为待分配）
|
Db.Updateable(item).ExecuteCommand();
|
|
#region 库存记录
|
|
datainfo.ExportQty += item.LockQty.Value;//出库数量
|
datainfo.BalanceQty -= item.LockQty.Value;//结存数量
|
datainfo.YearBalanceQty -= item.LockQty.Value;//结存数量(月)
|
datainfo.YearExportQty += item.LockQty.Value;//出库数量（月）
|
Db.Updateable(datainfo).ExecuteCommand();
|
|
#endregion
|
}
|
//盘点明细（更改状态）
|
var checkDetails = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && (m.TaskNo == taskNo || (m.Status == 1 && m.PalletNo == task.PalletNo))).ToList();
|
|
foreach (var item in checkDetails)
|
{
|
item.Status = 2;
|
}
|
Db.Updateable(checkDetails).ExecuteCommand();
|
if (userId != 0)
|
{
|
//添加操作日志记录
|
var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskNo, "完成", $"点击完成按钮、完成任务号为：{taskNo}的任务", userId);
|
|
// 正式运行程序放开
|
var jsonData = JsonConvert.SerializeObject(task);
|
string response = "";
|
|
try
|
{
|
var time1 = DateTime.Now;//发送时间 .ToString("yyyy-MM-dd HH:mm:ss")
|
response = HttpHelper.DoPost(url, jsonData, "下发给WCS出库完成", "WCS");
|
var time2 = DateTime.Now;//返回时间 .ToString("yyyy-MM-dd HH:mm:ss")
|
|
//解析返回数据
|
var wcsModel = JsonConvert.DeserializeObject<WcsModel>(response);
|
}
|
catch (Exception ex)
|
{
|
Db.RollbackTran();
|
throw new Exception(ex.Message);
|
}
|
}
|
Db.CommitTran();
|
|
}
|
catch (Exception ex)
|
{
|
Db.RollbackTran();
|
throw new Exception("完成反馈失败：" + ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 取消盘点出库任务
|
/// </summary>
|
/// <param name="taskNo"></param>
|
/// <param name="userId"></param>
|
public void ExportSuccess(string taskNo, int userId, string url)
|
{
|
try
|
{
|
//当前任务信息
|
var task = Db.Queryable<LogTask>().First(m => m.TaskNo == taskNo && m.IsDel == "0");
|
if (task == null)
|
{
|
throw new Exception($"未查询到任务号为：‘{taskNo}’的任务信息");
|
}
|
if (task.Status == "2")
|
{
|
throw new Exception("当前任务已完成");
|
}
|
Db.BeginTran();
|
|
//库存中当前托盘的信息
|
var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.PalletNo == task.PalletNo).ToList();
|
var locateNo = stockDetail.Select(m => m.LocatNo).Distinct().FirstOrDefault();
|
//当前任务中的储位信息
|
var locate = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == locateNo);
|
|
task.Status = "3";//任务状态 3：已取消
|
task.IsSend = 1; //是否可再次下发
|
task.IsCancel = 0; //是否可取消
|
task.IsFinish = 0; //是否可完成
|
task.CancelDate = DateTime.Now;//取消时间
|
Db.Updateable(task).ExecuteCommand();
|
|
//获取移库任务对应目标储位信息
|
SysStorageLocat endlocat = new SysStorageLocat();
|
if (task.Type == "2")
|
{
|
endlocat = Db.Queryable<SysStorageLocat>().First(a => a.IsDel == "0" && a.WareHouseNo == "W03" && a.LocatNo == task.EndLocat);
|
if (endlocat == null)
|
{
|
throw new Exception("未查询到目标储位信息");
|
}
|
}
|
locate.Status = "1"; // 更改当前任务中的储位状态（改为有物品）
|
Db.Updateable(locate).ExecuteCommand();
|
if (endlocat != null)
|
{
|
endlocat.Status = "0"; //空储位 0
|
Db.Updateable(endlocat).ExecuteCommand();
|
}
|
|
foreach (var item in stockDetail)
|
{
|
//修改库存明细 状态改为待分配
|
item.Status = "0"; //状态改为0：待分配
|
item.LockQty -= item.Qty; //锁定数量减少
|
Db.Updateable(item).ExecuteCommand();
|
}
|
//盘点明细（更改状态）
|
var checkDetails = Db.Queryable<BllStockCheckDetail>().Where(m => m.IsDel == "0" && (m.TaskNo == taskNo || (m.Status == 1 && m.PalletNo == task.PalletNo))).ToList();
|
|
foreach (var item in checkDetails)
|
{
|
item.Status = 0; //盘点明细状态改为为0：待下发
|
}
|
Db.Updateable(checkDetails).ExecuteCommand();
|
if (userId != 0)
|
{
|
//添加操作日志记录
|
var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskNo, "取消", $"点击取消按钮、完成任务号为：{taskNo}的任务", userId);
|
|
// 正式运行程序放开
|
var jsonData = JsonConvert.SerializeObject(task);
|
string response = "";
|
|
try
|
{
|
var time1 = DateTime.Now;//发送时间 .ToString("yyyy-MM-dd HH:mm:ss")
|
response = HttpHelper.DoPost(url, jsonData, "下发给WCS取消出库", "WCS");
|
var time2 = DateTime.Now;//返回时间 .ToString("yyyy-MM-dd HH:mm:ss")
|
|
//解析返回数据
|
var wcsModel = JsonConvert.DeserializeObject<WcsModel>(response);
|
}
|
catch (Exception ex)
|
{
|
Db.RollbackTran();
|
throw new Exception(ex.Message);
|
}
|
}
|
|
Db.CommitTran();
|
}
|
catch (Exception ex)
|
{
|
Db.RollbackTran();
|
throw new Exception("完成反馈失败：" + ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 获取移库目标库位
|
/// </summary>
|
/// <param name="oldAddress">需要移动的库位地址</param>
|
/// <param name="roadWay">巷道</param>
|
/// <param name="area">区域</param>
|
/// <returns>目标库位地址 为"" 直接下发两次出库指令</returns>
|
public string MoveAddress(string oldAddress, string roadWay, string area)//01020201 排-列-层-深度
|
{
|
string nowAddress = "";
|
// 获取移库目标储位
|
var row = int.Parse(oldAddress.Substring(0, 2));
|
var lie = int.Parse(oldAddress.Substring(2, 2));
|
var ceng = int.Parse(oldAddress.Substring(4, 2));
|
|
var sqlString = $@"select LocatNo,[Row],[Column],Layer, (ABS(Row-{row}) + ABS([Column]-{lie}) + ABS(Layer-{ceng})) as distNum
|
from SysStorageLocat
|
where Flag = '0' and Status = '0' and Depth = '02' and RoadwayNo = '{roadWay}' and AreaNo = '{area}'
|
order by distNum;";
|
|
var addressModels = Db.Ado.SqlQuery<AddressCls>(sqlString).ToList();
|
if (addressModels.Count > 0) // 判断同巷道内排空库位
|
{
|
var listLocaete = new List<string>();
|
foreach (var item in addressModels)
|
{
|
// 目标内库位对应的外库位
|
string addressee = item.LocatNo.Substring(0, 6) + "01";
|
|
// 判断目标库位的外库位是否存在货物 (正常情况下正在移入情况不存在，因为移库先移入里面，后移入外面)
|
//SlotStatus 0: 空储位 1：有货 2：正在入库 3：正在出库 4：正在移入 5：正在移出
|
sqlString = $"select count(*) from SysStorageLocat where LocatNo = '{addressee}' and Status = '0' and Flag in ('0','1') ; ";
|
var rowNum = Db.Ado.SqlQuery<int>(sqlString).First();
|
if (rowNum == 0)
|
{
|
continue;
|
}
|
else
|
{
|
nowAddress = item.LocatNo;
|
break;
|
}
|
}
|
}
|
if (nowAddress == "")
|
{
|
// 判断同巷道外排空库位
|
sqlString = $@"select LocatNo,[Row],[Column],Layer, (ABS(Row-{row}) + ABS([Column]-{lie}) + ABS(Layer-{ceng})) as distNum
|
from SysStorageLocat
|
where Flag = '0' and Status = '0' and Depth = '01' and RoadwayNo = '{roadWay}' and AreaNo = '{area}'
|
order by distNum;";
|
var adderModeling = Db.Ado.SqlQuery<AddressCls>(sqlString).ToList();
|
if (adderModeling.Count > 0)
|
{
|
nowAddress = adderModeling[0].LocatNo;
|
}
|
else
|
{
|
// 库内不存在空储位
|
nowAddress = "";
|
}
|
}
|
|
|
return nowAddress;
|
}
|
|
#region 上游系统接口
|
|
//盘点结果返回erp
|
public bool FinishCr(int id, string url, int userId)
|
{
|
try
|
{
|
|
Db.BeginTran();
|
try
|
{
|
|
}
|
catch (Exception e)
|
{
|
Console.WriteLine(e);
|
throw;
|
}
|
throw new NotImplementedException();
|
|
|
|
Db.CommitTran();
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
}
|
#endregion
|
|
}
|
}
|
