using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Model.InterFaceModel;
|
using Model.ModelDto.BllSoDto;
|
using Model.ModelVm.BllSoVm;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
using WMS.BLL.Logic;
|
using WMS.BLL.LogServer;
|
using WMS.DAL;
|
using WMS.Entity.BllSoEntity;
|
using WMS.Entity.Context;
|
using WMS.Entity.DataEntity;
|
using WMS.Entity.LogEntity;
|
using WMS.Entity.SysEntity;
|
using WMS.IBLL.IBllSoServer;
|
|
namespace WMS.BLL.BllSoServer
|
{
|
public class WaveMageServer:DbHelper<BllWaveMage>,IWaveMageServer
|
{
|
private static readonly SqlSugarScope Db = DataContext.Db;
|
public WaveMageServer():base(Db)
|
{
|
}
|
|
//获取波次单信息
|
public async Task<List<WaveMageDto>> GetWaveMageList(GetWaveMageVm model, RefAsync<int> count)
|
{
|
Expression<Func<BllWaveMage, bool>> item = Expressionable.Create<BllWaveMage>()
|
.AndIF(!string.IsNullOrWhiteSpace(model.WaveNo), it => it.WaveNo.Contains(model.WaveNo.Trim()))
|
.AndIF(!string.IsNullOrWhiteSpace(model.Status), it => it.Status == model.Status)
|
.AndIF(model.LogisticsId != null, it => it.LogisticsId == model.LogisticsId)
|
.AndIF(!string.IsNullOrWhiteSpace(model.LotNo), it => it.LotNo.Contains(model.LotNo))
|
.ToExpression();//注意 这一句 不能少
|
|
var data = await GetAllWhereAsync(item)
|
.LeftJoin<SysLogisticsInfo>((a, b) => a.LogisticsId == b.Id)
|
.LeftJoin<SysUserInfor>((a, b, c) => a.CreateUser == c.Id)
|
.LeftJoin<SysUserInfor>((a, b, c, d) => a.CreateUser == d.Id)
|
.Select((a, b, c, d) => new WaveMageDto()
|
{
|
Id = a.Id,
|
WaveNo = a.WaveNo,
|
Status = a.Status,
|
Origin = a.Origin,
|
CustomerNo = a.CustomerNo,
|
CustomerName = a.CustomerName,
|
LotNo = a.LotNo,
|
LotText = a.LotText,
|
SupplierLot = a.SupplierLot,
|
LogisticsId = a.LogisticsId,
|
LogisticsName = b.CarrierName,
|
Address = a.Address,
|
|
CreateUserName = c.RealName,
|
UpdateUserName = c.RealName,
|
CreateTime = a.CreateTime,
|
UpdateTime = a.UpdateTime,
|
|
})
|
.OrderByDescending(a => a.CreateTime)
|
.ToPageListAsync(model.Page, model.Limit, count);
|
|
return data;
|
}
|
|
//获取添加波次单的出库单信息
|
public List<ExportNoticeDto> GetAddExNoticeInfo(int? logisticsId, string address)
|
{
|
try
|
{
|
|
Expression<Func<BllExportNotice, bool>> item = Expressionable.Create<BllExportNotice>()
|
.And(it=>it.IsDel =="0")
|
.And(it=>it.Status == "0")
|
.And(it=>it.Type == "0")
|
.And(it=>it.IsWave == "0")
|
.AndIF(logisticsId != null, it => it.LogisticsId == logisticsId)
|
.AndIF(!string.IsNullOrWhiteSpace(address), it => it.Address.Contains(address))
|
.ToExpression();//注意 这一句 不能少
|
var notice = Db.Queryable<BllExportNotice>().Where(item)
|
.LeftJoin<SysLogisticsInfo>((a, b) => a.LogisticsId == b.Id)
|
.Select((a, b) => new ExportNoticeDto()
|
{
|
Id = a.Id,
|
SONo = a.SONo,
|
Type = a.Type,
|
Status = a.Status,
|
Origin = a.Origin,
|
CustomerNo = a.CustomerNo,
|
CustomerName = a.CustomerName,
|
LotNo = a.LotNo,
|
LotText = a.LotText,
|
SupplierLot = a.SupplierLot,
|
LogisticsId = a.LogisticsId,
|
LogisticsName = b.CarrierName,
|
Address = a.Address,
|
IsWave = a.IsWave,
|
WaveNo = a.WaveNo,
|
IsDespatch = a.IsDespatch,
|
|
CreateTime = a.CreateTime,
|
UpdateTime = a.UpdateTime
|
|
}).ToList();
|
|
return notice;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
//添加波次单据
|
public void AddWaveMage(List<int> Ids, int userId)
|
{
|
try
|
{
|
var notice = Db.Queryable<BllExportNotice>().Where(m => m.IsDel == "0" && Ids.Contains(m.Id)).ToList();
|
if (notice.Count < 2)
|
{
|
throw new Exception("合并波次需要至少两条出库单据信息");
|
}
|
|
var soList = notice.Select(m => m.SONo).ToList();
|
|
var noticeDetail = Db.Queryable<BllExportNoticeDetail>().Where(m => m.IsDel == "0" && soList.Contains(m.SONo)).ToList();
|
|
var count1 = 0;
|
var list1 = new List<int>();
|
|
var count2 = 0;
|
var list2 = new List<string>();
|
|
foreach (var item in notice)
|
{
|
if (item.LogisticsId!= null)
|
{
|
if (!list1.Contains((int)item.LogisticsId))
|
{
|
list1.Add((int)item.LogisticsId);
|
}
|
}
|
else
|
{
|
if (count1<1)
|
{
|
count1 += 1;
|
}
|
|
}
|
|
if (!string.IsNullOrWhiteSpace(item.Address))
|
{
|
if (list2.Count(m => m == item.Address) == 0)
|
{
|
list2.Add(item.Address);
|
}
|
}
|
else
|
{
|
if (count2 < 1)
|
{
|
count2 += 1;
|
}
|
|
}
|
|
}
|
|
if (list1.Count == 0 && list2.Count == 0)
|
{
|
throw new Exception("承运商与收货地址不能都为空，请核实");
|
}
|
if ( list1.Count + count1>1 || list2.Count+count2>1)
|
{
|
throw new Exception("承运商或收货地址应一致，请核实");
|
}
|
|
Db.BeginTran();
|
|
var waveNo = new Common().GetMaxNo("WSO");
|
|
var wave = new BllWaveMage()
|
{
|
WaveNo = waveNo,
|
Status = "0",
|
Origin = "WMS",
|
CustomerNo = "",
|
CustomerName = "",
|
LotNo = "",
|
LotText = "",
|
SupplierLot = "",
|
|
Address = list2.Count>0?list2.First():"",
|
CreateUser = userId
|
|
};
|
|
if (list1.Count > 0)
|
{
|
wave.LogisticsId = list1.First();
|
}
|
Db.Insertable(wave).ExecuteCommand();
|
|
var date = DateTime.Now;
|
foreach (var demo in notice)
|
{
|
if (demo.Type != "0")//成品出库
|
{
|
throw new Exception("合并波次单的出库单类型应为成品出库");
|
}
|
if (demo.Status != "0")
|
{
|
throw new Exception("合并波次单的出库单状态应为等待执行");
|
}
|
if (demo.IsWave == "1")
|
{
|
throw new Exception("合并波次单含有已生成波次的出库单单");
|
}
|
demo.WaveNo = waveNo;
|
demo.IsWave = "1";
|
demo.UpdateTime = date;
|
demo.UpdateUser = userId;
|
}
|
foreach (var demo in noticeDetail)
|
{
|
if (demo.IsWave == "1")
|
{
|
throw new Exception("合并波次单含有已生成波次的出库单明细");
|
}
|
if (demo.Status != "0")
|
{
|
throw new Exception("合并波次单的出库单明细状态应为等待执行");
|
}
|
demo.WaveNo = waveNo;
|
demo.IsWave = "1";
|
demo.UpdateTime = date;
|
demo.UpdateUser = userId;
|
}
|
|
Db.Updateable(notice).ExecuteCommand();
|
Db.Updateable(noticeDetail).ExecuteCommand();
|
|
Db.CommitTran();
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
}
|
|
//删除波次出库单
|
public bool DelWaveExportNotice(int id, int userId)
|
{
|
try
|
{
|
Db.BeginTran();
|
var wave = Db.Queryable<BllWaveMage>().First(m => m.IsDel == "0" && m.Id == id);
|
if (wave == null)
|
{
|
throw new Exception("未查询到波次单信息");
|
}
|
|
if (wave.Status != "0")
|
{
|
throw new Exception("该波次单据状态不是等待执行，请核实");
|
}
|
var notice = Db.Queryable<BllExportNotice>().Where(m => m.IsDel == "0" && m.WaveNo == wave.WaveNo).ToList();
|
if (notice.Count == 0)
|
{
|
throw new Exception("未查询到该波次单下的出库单信息！！！");
|
}
|
if (notice.Count(m=>m.Status!="0") > 0)
|
{
|
throw new Exception("该波次单下的出库单状态有不是等待执行的！！！");
|
}
|
|
var noticeDetail = Db.Queryable<BllExportNoticeDetail>().Where(m => m.IsDel == "0" && m.WaveNo == wave.WaveNo).ToList();
|
if (noticeDetail.Count == 0)
|
{
|
throw new Exception("未查询到该波次单下的出库单信息！！！");
|
}
|
if (noticeDetail.Count(m => m.Status != "0") > 0)
|
{
|
throw new Exception("该波次单下的出库单明细状态有不是等待执行的！！！");
|
}
|
|
var date = DateTime.Now;
|
foreach (var item in notice)
|
{
|
item.IsWave = "0";
|
item.WaveNo = "";
|
item.UpdateTime = date;
|
item.UpdateUser = userId;
|
}
|
foreach (var item in noticeDetail)
|
{
|
item.IsWave = "0";
|
item.WaveNo = "";
|
item.UpdateTime = date;
|
item.UpdateUser = userId;
|
}
|
var a = Db.Updateable(notice).ExecuteCommand();
|
var b = Db.Updateable(noticeDetail).ExecuteCommand();
|
wave.IsDel = "1";
|
wave.UpdateTime = date;
|
wave.UpdateUser = userId;
|
var c = Db.Updateable(wave).ExecuteCommand();
|
|
if (a>0 && b>0 && c>0)
|
{
|
Db.CommitTran();
|
return true;
|
}
|
|
throw new Exception("更改错误，请核实");
|
|
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
}
|
|
//波次自动分配
|
public bool WaveAutoAllot(string waveNo, int userId)
|
{
|
try
|
{
|
#region 判断条件（出库单、出库单明细）
|
//波次单
|
var wave = Db.Queryable<BllWaveMage>().First(m => m.IsDel == "0" && m.WaveNo == waveNo);
|
//出库单
|
var noticeList = Db.Queryable<BllExportNotice>().Where(m => m.IsDel == "0" && m.WaveNo == waveNo).ToList();
|
var soList = noticeList.Select(m => m.SONo).ToList();
|
if (noticeList.Count == 0)
|
{
|
throw new Exception("未查询到出库单据信息");
|
}
|
if (noticeList.Count(m=> m.Status != "0" && m.Status != "1") > 0)
|
{
|
throw new Exception("参数异常,请检查状态是否为等待执行或部分分配;");
|
}
|
//出库单明细
|
var detailList2 = Db.Queryable<BllExportNoticeDetail>().Where(m => m.IsDel == "0" && soList.Contains(m.SONo) && m.WaveNo == waveNo && (m.AllotQty - m.Qty) <= 0).ToList();
|
if (!detailList2.Any())
|
{
|
throw new Exception("未查询到符合分配条件的出库单据明细信息");
|
}
|
|
#endregion
|
|
//包装信息
|
var packageNos = detailList2.Select(d => d.PackagNo).ToList();
|
var packList = Db.Queryable<SysPackag>().Where(m => packageNos.Contains(m.PackagNo)).ToList();
|
|
|
var assign = new AllotSku();
|
Db.BeginTran();
|
foreach (var notice in noticeList)
|
{
|
var detailList = detailList2.Where(m => m.SONo == notice.SONo).ToList();
|
var exAllotList = new List<BllExportAllot>();
|
foreach (var detail in detailList)
|
{
|
if (detail.AllotQty >= detail.Qty)
|
{
|
continue;
|
}
|
//还需要分配的数量
|
var needQty = detail.Qty - detail.AllotQty;
|
//库存明细 Status 0：待分配 1：部分分配 2：已分配
|
var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.SkuNo == detail.SkuNo && (m.Qty - m.FrozenQty - m.LockQty + m.InspectQty) > 0 && (m.Status == "0" || m.Status == "1") && m.IsDel == "0").ToList();
|
|
|
//判断单号是否指定批次
|
if (!string.IsNullOrWhiteSpace(detail.LotNo))
|
{
|
if (detail.LotNo.Contains(";"))
|
{
|
var lotNoList = detail.LotNo.Split(";");
|
var lotNoList2 = new List<string>();
|
|
foreach (var lotNoItem in lotNoList)
|
{
|
lotNoList2.Add(lotNoItem);
|
}
|
stockDetail = stockDetail.Where(m => m.SkuNo == detail.SkuNo && lotNoList2.Contains(m.LotNo) && m.IsDel == "0").ToList();
|
}
|
else
|
{
|
stockDetail = stockDetail.Where(m => m.SkuNo == detail.SkuNo && m.LotNo == detail.LotNo && m.IsDel == "0").ToList();
|
}
|
|
}
|
else
|
{
|
stockDetail = stockDetail.Where(m => m.SkuNo == detail.SkuNo && m.IsDel == "0" && string.IsNullOrWhiteSpace(m.LotNo)).ToList(); //
|
}
|
|
if (stockDetail.Count < 1)
|
{
|
throw new Exception("库存不足,无可出库库存");
|
}
|
|
stockDetail = stockDetail.Where(m => m.InspectStatus == "1").ToList();
|
|
//0:成品出库、1:领料出库、2:抽检出库、3：物料取样出库、4:不合格品出库、5:中间品出库、6:代储出库、7:其他出库、8:寄存出库
|
//if (notice.Type == "0" || notice.Type == "1")//成品
|
//{
|
// stockDetail = stockDetail.Where(m => m.InspectStatus == "1").ToList();
|
//}
|
//else if (notice.Type == "3")//取样出库
|
//{
|
// stockDetail = stockDetail.Where(m => m.InspectStatus == "0").ToList();
|
//}
|
//else if (notice.Type == "5" || notice.Type == "6" || notice.Type == "7" || notice.Type == "8")
|
//{
|
// stockDetail = stockDetail.Where(m => m.InspectStatus == "0" || m.InspectStatus == "1").ToList();
|
//}
|
//else if (notice.Type == "4")//不合格出库
|
//{
|
// stockDetail = stockDetail.Where(m => m.InspectStatus == "2").ToList();
|
//}
|
|
#region 包装信息
|
|
var pack = packList.FirstOrDefault(p => p.PackagNo == detail.PackagNo);
|
var pNum = 0;//托盘物品数量
|
var bNum = 0;//箱物品数量
|
if (pack != null)
|
{
|
//throw new Exception("未查询到物料包装");
|
if (pack.L5Num.HasValue)
|
{
|
pNum = Convert.ToInt32(pack.L5Num);
|
bNum = Convert.ToInt32(pack.L4Num);
|
}
|
else if (pack.L4Num.HasValue)
|
{
|
pNum = Convert.ToInt32(pack.L4Num);
|
bNum = Convert.ToInt32(pack.L3Num);
|
}
|
else if (pack.L3Num.HasValue)
|
{
|
pNum = Convert.ToInt32(pack.L3Num);
|
bNum = Convert.ToInt32(pack.L2Num);
|
}
|
else if (pack.L2Num.HasValue)
|
{
|
pNum = Convert.ToInt32(pack.L2Num);
|
bNum = Convert.ToInt32(pack.L1Num);
|
}
|
else if (pack.L1Num.HasValue)
|
{
|
pNum = Convert.ToInt32(pack.L1Num);
|
bNum = Convert.ToInt32(pack.L1Num);
|
}
|
}
|
|
|
//if (pNum == 0)
|
//{
|
// throw new Exception("未查询到物料包装托箱关系信息");
|
//}
|
#endregion
|
|
//取合适库存商品
|
Dictionary<int, decimal> stockQtyDic = new Dictionary<int, decimal>();//托出库物品数
|
Dictionary<string, int> zxQtyDic = new Dictionary<string, int>();//托出整箱数
|
//分配货物
|
//assign.AllocatePallets(stocks, pNum, bNum, needQty, stockQtyDic, zxQtyDic);
|
var house = "";
|
if (notice.Type == "0")
|
{
|
house = "W01";
|
}
|
var qty = assign.AllotPallets(stockDetail, decimal.Parse(needQty.ToString()), pNum, bNum, stockQtyDic,"");
|
|
foreach (var sc in stockQtyDic)
|
{
|
var s = stockDetail.FirstOrDefault(m => m.Id == sc.Key);
|
//添加分配表信息
|
var allot = new BllExportAllot
|
{
|
SONo = notice.SONo,
|
WaveNo = waveNo,
|
SODetailNo = detail.Id,
|
StockId = sc.Key,
|
LotNo = s.LotNo,
|
LotText = s.LotText,
|
SupplierLot = s.SupplierLot,
|
SkuNo = s.SkuNo,
|
SkuName = s.SkuName,
|
Standard = s.Standard,
|
PalletNo = s.PalletNo,
|
IsBale = detail.IsBale == "0" ? "0" : s.IsBale == "1" ? "0" : "1", //是否裹包
|
IsBelt = detail.IsBelt == "0" ? "0" : s.IsBelt == "1" ? "0" : "1", //是否打带
|
|
Qty = sc.Value,
|
CompleteQty = 0,
|
//BoxexQty = s.Qty, //箱内数量
|
Status = "0",
|
LogisticsId = notice.LogisticsId,
|
IsAdvance = "0",
|
OutMode = "",//出库口
|
|
CreateUser = userId,
|
CreateTime = DateTime.Now
|
};
|
exAllotList.Add(allot);
|
|
s.LockQty += stockQtyDic[s.Id];
|
|
if (s.LockQty == s.Qty)
|
{
|
s.Status = "2";
|
}
|
else
|
{
|
s.Status = "1";
|
}
|
|
var sd = Db.Updateable(s).UpdateColumns(it => new { it.LockQty, it.Status }).ExecuteCommand();
|
//if (notice.Type == "1" || notice.Type == "5" || notice.Type == "6" || notice.Type == "7" || notice.Type == "8")//1：领料出库、
|
//{
|
// if (string.IsNullOrWhiteSpace(detail.LotNo))
|
// {
|
// detail.LotNo = s.LotNo;
|
|
// }
|
// else
|
// {
|
// if (!detail.LotNo.Contains(s.LotNo))
|
// {
|
// detail.LotNo += ";" + s.LotNo;
|
// }
|
// }
|
//}
|
|
}
|
detail.AllotQty += qty;
|
detail.UpdateUser = userId;
|
detail.UpdateTime = DateTime.Now;
|
if (detail.Status == "0")
|
{
|
detail.Status = "1";
|
}
|
|
//库存总表
|
//var stock = Db.Queryable<DataStock>().First(d => d.IsDel == "0" && d.SkuNo == detail.SkuNo && d.LotNo == detail.LotNo);
|
//stock.LockQty += qty;
|
//Db.Updateable(stock).ExecuteCommand();
|
}
|
|
var mx = Db.Updateable(detailList).ExecuteCommand();
|
var fp = Db.Insertable(exAllotList).ExecuteCommand();
|
|
//修改分配单据的状态
|
if (notice.Status == "0" || notice.Status == "1")
|
{
|
var bl = 0;
|
var bl2 = 0;
|
foreach (var item in detailList)
|
{
|
if (item.AllotQty <= 0)
|
{
|
continue;
|
}
|
if (item.AllotQty < item.Qty)
|
{
|
bl = 1;
|
}
|
else
|
{
|
bl2 = 1;
|
}
|
}
|
|
switch (bl2)
|
{
|
case 1 when bl == 1:
|
notice.Status = "1";//证明部分分配数量全部大于等于出库数量 修改为已分配
|
break;
|
case 0 when bl == 1:
|
notice.Status = "1";//证明部分分配数量全部大于等于出库数量 修改为已分配
|
break;
|
case 1 when bl == 0:
|
notice.Status = "2";//证明分配数量全部大于等于出库数量 修改为已分配
|
break;
|
case 0 when bl == 0:
|
//证明所有分配数量全部小于等于出库数量 不做修改
|
break;
|
}
|
|
}
|
notice.UpdateUser = userId;
|
notice.UpdateTime = DateTime.Now;
|
|
var zd = Db.Updateable(notice).ExecuteCommand();
|
}
|
|
|
//修改波次单
|
if (noticeList.Count(m=>m.Status != "2") > 0)
|
{
|
throw new Exception("出库单分配数量不足");
|
}
|
|
wave.Status = "2";
|
wave.UpdateTime = DateTime.Now;
|
wave.UpdateUser = userId;
|
var sas = Db.Updateable(wave).ExecuteCommand();
|
|
//添加操作日志记录
|
var k = new OperationSOServer().AddLogOperationSo("出库作业", "波次管理", waveNo, "分配", $"自动分配了波次单据号为{waveNo}的单据信息", userId);
|
|
Db.CommitTran();
|
return true;
|
|
//if (zd > 0 && mx > 0 && fp > 0 && k)
|
//{
|
// Db.CommitTran();
|
// return true;
|
//}
|
//Db.RollbackTran();
|
//return false;
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception("自动分配失败" + e.Message);
|
}
|
}
|
|
//波次取消分配
|
public bool WaveCancelAllot(string waveNo, int userId)
|
{
|
try
|
{
|
var wave = Db.Queryable<BllWaveMage>().First(m => m.IsDel == "0" && m.WaveNo == waveNo);
|
if (wave == null)
|
{
|
throw new Exception("未查询到波次出库单据信息");
|
}
|
|
if (wave.Status != "1" && wave.Status!="2")
|
{
|
throw new Exception("请检查状态是否为已分配或部分分配");
|
}
|
|
var noticeList = Db.Queryable<BllExportNotice>().Where(m => m.IsDel == "0" && m.WaveNo == waveNo).ToList();
|
|
if (noticeList.Count == 0)
|
{
|
throw new Exception("未查询到波次的出库单据信息");
|
}
|
if (noticeList.Count(m=>m.Status != "1" && m.Status != "2") >0 )
|
{
|
throw new Exception("请检查状态是否为已分配或部分分配");
|
}
|
|
var soList = noticeList.Select(m => m.SONo).ToList();
|
|
//该单据的分配信息 Status 0：任务下发 1：待拣货 2：部分拣货 3：待回库 4：已完成
|
var allotList = Db.Queryable<BllExportAllot>().Where(o => o.IsDel == "0" && soList.Contains(o.SONo)).ToList();
|
//有已执行的分配数据不能取消
|
if (allotList.Any(o => o.Status != "0"))
|
{
|
throw new Exception("当前单据的分配信息已有执行中，不能取消分配");
|
}
|
Db.BeginTran();
|
|
//查询分配的明细
|
var detail2 = Db.Queryable<BllExportNoticeDetail>().Where(d => d.WaveNo == waveNo && soList.Contains(d.SONo) && d.AllotQty > 0 && d.IsDel == "0").ToList();
|
foreach (var notice in noticeList)
|
{
|
var detail = detail2.Where(m => m.SONo == notice.SONo).ToList();
|
|
foreach (var d in detail)
|
{
|
var orders = allotList.Where(o => o.SODetailNo == d.Id).ToList();
|
foreach (var o in orders)
|
{
|
var pq = Db.Queryable<DataStockDetail>().Where(t => t.Id == o.StockId);
|
|
var pq2 = !string.IsNullOrWhiteSpace(o.LotNo) ? pq.Where(t => t.LotNo == o.LotNo).ToList() : pq.Where(t => string.IsNullOrWhiteSpace(t.LotNo)).ToList();
|
|
var pallet = pq2.FirstOrDefault();
|
if (pallet != null)
|
{
|
pallet.LockQty -= o.Qty;
|
pallet.Status = pallet.LockQty == 0 ? "0" : "1"; //如果锁定数量是0状态变更为待分配 否则为部分分配
|
Db.Updateable(pallet).ExecuteCommand();
|
|
//库存总表
|
//var stock = Db.Queryable<DataStock>().First(t => t.SkuNo == pallet.SkuNo && t.IsDel == "0");
|
//stock.LockQty -= o.Qty;
|
//Db.Updateable(stock).ExecuteCommand();
|
}
|
|
}
|
Db.Deleteable<BllExportAllot>(orders).ExecuteCommand();
|
d.AllotQty = 0;
|
d.Status = "0";
|
d.UpdateUser = userId;
|
d.UpdateTime = DateTime.Now;
|
|
//if (notice.Type == "1" || notice.Type == "5" || notice.Type == "6" || notice.Type == "7" || notice.Type == "8")//1：领料出库、
|
//{
|
// if (d.IsIssueLotNo != "1")
|
// {
|
// d.LotNo = "";
|
// }
|
|
//}
|
}
|
notice.Status = "0";
|
notice.UpdateUser = userId;
|
notice.UpdateTime = DateTime.Now;
|
Db.Updateable(detail).ExecuteCommand();
|
Db.Updateable(notice).ExecuteCommand();
|
}
|
|
if (noticeList.Count(m=>m.Status!="0")>0)
|
{
|
throw new Exception("波次单取消分配有误，出库单含有未取消完成的");
|
}
|
|
wave.Status = "0";
|
wave.UpdateTime = DateTime.Now;
|
wave.UpdateUser = userId;
|
Db.Updateable(wave).ExecuteCommand();
|
|
//添加操作日志记录
|
var k = new OperationSOServer().AddLogOperationSo("出库作业", "波次管理", waveNo, "取消分配", $"取消分配了波次单据号为{wave.WaveNo}的单据信息", userId);
|
|
Db.CommitTran();
|
return true;
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
}
|
//波次下发出库
|
public List<OutCommandDto> WaveIssueOutHouse(string waveNo, string unstackingMode, string outMode, string loadingAddre, int userId, string url, out string str)
|
{
|
try
|
{
|
#region 集合
|
|
var outDto1 = new List<OutCommandDto>(); //先出库数据的集合（深度为1的储位）
|
var outDto2 = 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 wave = Db.Queryable<BllWaveMage>().First(m => m.IsDel == "0" && m.WaveNo == waveNo);
|
if (wave == null)
|
{
|
throw new Exception("未找到当前波次的单信息");
|
}
|
|
if (wave.Status !="2")
|
{
|
throw new Exception("当前波次的单状态不是已分配，不能下发出库，请核实");
|
}
|
|
var noticeList = Db.Queryable<BllExportNotice>().Where(m => m.WaveNo == waveNo && m.IsDel == "0").ToList();
|
if (noticeList.Count == 0)
|
{
|
throw new Exception($"未找到{waveNo}波次的出库单信息");
|
}
|
|
var soList = noticeList.Select(m => m.SONo).ToList();
|
|
//所有要出库的出库分配信息(未下发的信息和待拣货的信息)
|
var list = Db.Queryable<BllExportAllot>().Where(a => a.IsDel == "0" && soList.Contains(a.SONo) && a.WaveNo == waveNo && a.Status == "0").OrderBy(m=>m.SONo).OrderBy(m=>m.SkuNo).ToList();
|
if (list.Count == 0) //判断是否有需要下发的出库流水
|
{
|
throw new Exception("当前波次单据无需要下发的托盘");
|
}
|
|
#region 集合
|
//要出库的托盘集合
|
var outLpnList = list.Select(m => m.PalletNo).ToList();
|
//要出库的明细集合
|
var outStockDetail = Db.Queryable<DataStockDetail>().Where(m => m.IsDel == "0" && outLpnList.Contains(m.PalletNo)).ToList();
|
//物料编码表
|
var skuList = Db.Queryable<SysMaterials>().Where(w => w.IsDel == "0");
|
//包装表
|
var packagList = Db.Queryable<SysPackag>().Where(w => w.IsDel == "0");
|
Db.BeginTran();
|
try
|
{
|
List<LogTask> logTaskList = new List<LogTask>();//此次出库任务集合，为应对同托盘不同物料出库
|
//循环分配的信息生成出库任务
|
foreach (var item in list)
|
{
|
var taskNoStr = "";
|
string toLocation = string.Empty;//目标位置
|
string unstackingMode2 = unstackingMode;//拆垛方式，0:机器人拆垛 1:PDA拆垛
|
#region 判断是否需要拆箱
|
|
string isChai = "0";//是否需要拆箱，0:否 1:是
|
var skuInfo = skuList.First(w => w.SkuNo == item.SkuNo);
|
if (skuInfo == null)
|
{
|
throw new Exception("物料信息不存在！");
|
}
|
var packagInfo = packagList.First(w => w.PackagNo == skuInfo.PackagNo);
|
if (packagInfo == null)
|
{
|
throw new Exception("包装信息不存在！");
|
}
|
if (packagInfo.L2Name == "箱")
|
{
|
if (item.Qty % (decimal)packagInfo.L2Num != 0)//能整除说明不用拆箱，不能整除说明需要拆箱
|
{
|
isChai = "1";
|
unstackingMode2 = "1";//需要拆箱需走PDA拆垛
|
}
|
}
|
if (isChai == "0")
|
{
|
var boxInfo = Db.Queryable<DataBoxInfo>().Where(w => w.IsDel == "0" && w.PalletNo == item.PalletNo && w.BitBoxMark == "1").ToList();
|
if (boxInfo != null)//托盘上有零箱需要拆箱
|
{
|
isChai = "1";
|
unstackingMode2 = "1";//需要拆箱需走PDA拆垛
|
}
|
}
|
|
if (unstackingMode2 == "0")//机器人拆垛
|
{
|
toLocation = loadingAddre;//装车口
|
}
|
else //PDA拆垛
|
{
|
toLocation = outMode;//出库口
|
}
|
|
#endregion
|
|
// 储位号
|
var locateNo = outStockDetail.First(m => m.PalletNo == item.PalletNo).LocatNo;
|
|
#region 判断
|
|
//判断托盘是否在库内
|
if (string.IsNullOrWhiteSpace(locateNo))
|
{
|
|
//判断托盘是否在入库中
|
var imBl = com.GetImTask(item.PalletNo);
|
if (imBl != null)
|
{
|
flagList.Add(4);
|
continue;
|
}
|
var de = outStockDetail.First(m => m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo);
|
//判断是否是已经出过库又回库（状态为待拣货的 1）平库？
|
if (de != null && de.WareHouseNo == "W02")
|
{
|
item.Status = "1"; // 出库分配信息状态改为正在执行
|
item.OutMode = outMode;//出库口
|
Db.Updateable(item).ExecuteCommand();
|
var noticeDetail = Db.Queryable<BllExportNoticeDetail>().First(m => m.IsDel == "0" && m.Id == item.SODetailNo);
|
if (noticeDetail != null) //更新出库单据的下发数量
|
{
|
noticeDetail.FactQty += item.Qty;
|
Db.Updateable(noticeDetail).ExecuteCommand();
|
}
|
|
var notice2 = Db.Queryable<BllExportNotice>().First(m => m.IsDel == "0" && m.SONo == item.SONo);
|
if (notice2.Status == "0" || notice2.Status == "1" || notice2.Status == "2")
|
{
|
var detailList = Db.Queryable<BllExportNoticeDetail>().Where(m => m.IsDel == "0" && m.SONo == item.SONo).ToList();
|
if (detailList.Count(m => m.Qty >= m.AllotQty) > 0)
|
{
|
notice2.Status = "3"; //变更状态为正在执行
|
Db.Updateable(notice2).ExecuteCommand();
|
}
|
}
|
flagList.Add(0);
|
continue;
|
}
|
|
if (item.Status == "0")
|
{
|
//如果不在仓库内，当前分配信息直接更新出库完成
|
item.Status = "2";//状态
|
item.OutMode = outMode;//出库口
|
Db.Updateable(item).ExecuteCommand();
|
var noticeDetail = Db.Queryable<BllExportNoticeDetail>().First(m => m.IsDel == "0" && m.Id == item.SODetailNo);
|
if (noticeDetail != null) //更新出库单据的下发数量
|
{
|
noticeDetail.FactQty += item.Qty;
|
Db.Updateable(noticeDetail).ExecuteCommand();
|
}
|
|
var notice2 = Db.Queryable<BllExportNotice>().First(m => m.IsDel == "0" && m.SONo == item.SONo);
|
if (notice2.Status == "0" || notice2.Status == "1" || notice2.Status == "2")
|
{
|
var detailList = Db.Queryable<BllExportNoticeDetail>().Where(m => m.IsDel == "0" && m.SONo == item.SONo).ToList();
|
if (detailList.Count(m => m.Qty >= m.AllotQty) > 0)
|
{
|
notice2.Status = "3"; //变更状态为正在执行
|
Db.Updateable(notice2).ExecuteCommand();
|
}
|
}
|
}
|
flagList.Add(0);
|
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 = toLocation,//outMode,//目标位置
|
PalletNo = item.PalletNo,//托盘码
|
IsSend = 1,//是否可再次下发
|
IsCancel = 1,//是否可取消
|
IsFinish = 1,//是否可完成
|
Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务
|
Status = "0",//任务状态0：等待执行1正在执行2执行完成
|
OrderType = "1",//0 入库单 1 出库单 2 盘点单 3 移库单
|
Msg = "从" + locate.LocatNo + "到" + toLocation + "的出库任务", //关键信息
|
};
|
Db.Insertable(exTask).ExecuteCommand();
|
logTaskList.Add(exTask);
|
|
outDto1.Add(new OutCommandDto()
|
{
|
PalletNo = item.PalletNo,//托盘号
|
StartLocate = locate.LocatNo, // 起始位置
|
StartRoadway = locate.RoadwayNo,//其实巷道
|
EndLocate = toLocation,//outMode, // 目标位置
|
TaskNo = exTask.TaskNo, // 任务号
|
TaskType = "1",// 任务类型 (出库)
|
OutMode = "", //目标地址
|
Order = 1
|
});
|
taskNoStr = exTask.TaskNo;
|
}
|
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 = com.MoveAddress(slotBefore.LocatNo, slotBefore.RoadwayNo, item.SkuNo);
|
//当前移库库位的储位信息
|
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 = "1",//0 入库单 1 出库单 2 盘点单 3 移库单
|
|
Msg = stockNew.LocatNo + " ==>> " + newSlot + "的移库任务",
|
};
|
Db.Insertable(exYkTask).ExecuteCommand();
|
|
moveDto.Add(new OutCommandDto()
|
{
|
StartRoadway = slotBefore.RoadwayNo, //起始巷道
|
PalletNo = stockNew.PalletNo,//托盘号
|
StartLocate = stockNew.LocatNo, // 起始位置
|
EndLocate = newSlot, // 目标位置
|
EndRoadway = locatey.RoadwayNo, // 目标巷道
|
TaskNo = exYkTask.TaskNo, // 任务号
|
TaskType = "2",// 任务类型 (移库)
|
OutMode = "", //目标地址
|
Order = 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 = toLocation,//目标位置
|
PalletNo = stockNew.PalletNo,//托盘码
|
IsSend = 1,//是否可再次下发
|
IsCancel = 1,//是否可取消
|
IsFinish = 1,//是否可完成
|
Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务
|
Status = "0",//任务状态0：等待执行1正在执行2执行完成
|
OrderType = "1",//0 入库单 1 出库单 2 盘点单 3 移库单
|
Msg = locate.LocatNo + "的出库任务"
|
};
|
Db.Insertable(exYkTask1).ExecuteCommand();
|
|
outDto1.Add(new OutCommandDto()
|
{
|
StartRoadway = slotBefore.RoadwayNo, //起始巷道
|
PalletNo = stockNew.PalletNo,//托盘号
|
StartLocate = stockNew.LocatNo, // 起始位置
|
EndLocate = toLocation, // 目标位置
|
EndRoadway = "", // 目标巷道
|
TaskNo = exYkTask1.TaskNo, // 任务号
|
TaskType = "1",// 任务类型 (出库)
|
OutMode = "", //目标地址
|
Order = 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 = toLocation,//目标位置
|
PalletNo = item.PalletNo,//托盘码
|
IsSend = 1,//是否可再次下发
|
IsCancel = 1,//是否可取消
|
IsFinish = 1,//是否可完成
|
Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务
|
Status = "0",//任务状态0：等待执行1正在执行2执行完成
|
OrderType = "1",//0 入库单 1 出库单 2 盘点单 3 移库单
|
Msg = locate.LocatNo + "的出库任务"
|
};
|
Db.Insertable(exTask1).ExecuteCommand();
|
logTaskList.Add(exTask1);
|
outDto2.Add(new OutCommandDto()
|
{
|
StartRoadway = locate.RoadwayNo, //起始巷道
|
PalletNo = item.PalletNo,//托盘号
|
StartLocate = locate.LocatNo, // 起始位置
|
EndLocate = toLocation, // 目标位置
|
EndRoadway = locate.RoadwayNo, //目标巷道
|
TaskNo = exTask1.TaskNo, // 任务号
|
TaskType = "1",// 任务类型 (出库)
|
OutMode = "", //目标地址
|
Order = 1,
|
});
|
taskNoStr = exTask1.TaskNo;
|
#endregion
|
|
}
|
#endregion
|
|
#region 改变数据
|
if (item.Status == "0")//判断托盘是否下发过
|
{
|
var noticeDetail = Db.Queryable<BllExportNoticeDetail>().First(m => m.IsDel == "0" && m.Id == item.SODetailNo);
|
if (noticeDetail != null) //更新出库单据的下发数量
|
{
|
noticeDetail.FactQty += item.Qty;
|
Db.Updateable(noticeDetail).ExecuteCommand();
|
}
|
|
var notice2 = Db.Queryable<BllExportNotice>().First(m => m.IsDel == "0" && m.SONo == item.SONo);
|
if (notice2.Status == "0" || notice2.Status == "1" || notice2.Status == "2")
|
{
|
var detailList = Db.Queryable<BllExportNoticeDetail>().Where(m => m.IsDel == "0" && m.SONo == item.SONo).ToList();
|
if (detailList.Count(m => m.Qty >= m.AllotQty) > 0)
|
{
|
notice2.Status = "3"; //变更状态为正在执行
|
Db.Updateable(notice2).ExecuteCommand();
|
}
|
}
|
}
|
locate.Status = "3"; //要出库的储位改变状态 正在出库
|
Db.Updateable(locate).ExecuteCommand();
|
|
item.TaskNo = taskNoStr; // 出库分配信息中更新任务号
|
item.Status = "1"; // 出库分配信息状态改为正在执行
|
item.UnstackingMode = unstackingMode2;//拆垛方式
|
item.OutMode = unstackingMode2 == "1" ? outMode : "";//出库口
|
item.LoadingAddre = unstackingMode2 == "0" ? loadingAddre : "";//装车口
|
Db.Updateable(item).ExecuteCommand();
|
|
#endregion
|
|
flagList.Add(0);
|
}
|
else if (locate.Status == "3") //出库中
|
{
|
#region 改变数据
|
|
if (item.Status == "0")
|
{
|
var noticeDetail = Db.Queryable<BllExportNoticeDetail>().First(m => m.IsDel == "0" && m.Id == item.SODetailNo);
|
if (noticeDetail != null) //更新出库单据的下发数量
|
{
|
noticeDetail.FactQty += item.Qty;
|
Db.Updateable(noticeDetail).ExecuteCommand();
|
}
|
|
var notice2 = Db.Queryable<BllExportNotice>().First(m => m.IsDel == "0" && m.SONo == item.SONo);
|
if (notice2.Status == "0" || notice2.Status == "1" || notice2.Status == "2")
|
{
|
var detailList = Db.Queryable<BllExportNoticeDetail>().Where(m => m.IsDel == "0" && m.SONo == item.SONo).ToList();
|
if (detailList.Count(m => m.Qty >= m.AllotQty) > 0)
|
{
|
notice2.Status = "3"; //变更状态为正在执行
|
Db.Updateable(notice2).ExecuteCommand();
|
}
|
}
|
}
|
var taskNo = Db.Queryable<LogTask>().First(m => m.OrderType == "1" && m.TaskNo != item.TaskNo && m.Status == "1" && m.PalletNo == item.PalletNo);
|
if (taskNo == null)
|
{
|
taskNo = logTaskList.FirstOrDefault(m => m.PalletNo == item.PalletNo);//当前有同托盘不同物料出库
|
}
|
if (taskNo == null)
|
{
|
throw new Exception($"托盘号：{item.PalletNo},出库异常");
|
}
|
item.TaskNo = taskNo.TaskNo;
|
item.Status = "1"; // 出库分配信息状态改为正在执行
|
item.OutMode = unstackingMode2 == "1" ? taskNo.EndLocat : "";//出库口
|
item.LoadingAddre = unstackingMode2 == "0" ? taskNo.EndLocat : "";//装车口
|
Db.Updateable(item).ExecuteCommand();
|
flagList.Add(0);
|
#endregion
|
}
|
else if (locate.Status == "5") //移出中
|
{
|
flagList.Add(1);
|
}
|
}
|
|
//if (noticeList.Count(m => m.Status != "3") > 0)
|
//{
|
// throw new Exception("波次单下发出库有误，出库单含有不是正在执行的");
|
//}
|
|
wave.Status = "3";
|
wave.UpdateTime = DateTime.Now;
|
wave.UpdateUser = userId;
|
Db.Updateable(wave).ExecuteCommand();
|
|
outDto1.AddRange(moveDto);
|
outDto1.AddRange(outDto2);
|
//添加操作日志记录
|
var k = new OperationSOServer().AddLogOperationSo("出库作业", "波次管理", waveNo, "出库", $"点击出库按钮波次单号为：{waveNo}的波次单", userId);
|
Db.CommitTran();
|
|
str = string.Empty;
|
if (flagList.Count(m => m == 0) > 0)
|
{
|
str += "0.下发成功、";
|
}
|
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 (outDto1.Count > 0)
|
{
|
// 正式运行程序放开
|
var list2 = outDto1.Select(m => m.TaskNo).ToList();
|
var jsonData = JsonConvert.SerializeObject(outDto1);
|
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.StatusCode == 0)
|
//{
|
// //更改任务的发送返回时间//
|
// new TaskServer().EditTaskIssueOk(list2, time1, time2);
|
// str += "下发成功";
|
//}
|
//if (wcsModel.StatusCode == -1)
|
//{
|
// new TaskServer().EditTaskIssueNo(list2, time1, time2, wcsModel.Msg);
|
// throw new Exception(wcsModel.Msg);
|
//}
|
}
|
catch (Exception ex)
|
{
|
throw new Exception(ex.Message);
|
}
|
|
}
|
|
return outDto1;
|
}
|
catch (Exception e)
|
{
|
Db.RollbackTran();
|
throw new Exception(e.Message);
|
}
|
|
|
#endregion
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
/// <summary>
|
/// 判断出库是否需要拆箱
|
/// </summary>
|
/// <param name="waveNo"></param>
|
/// <returns></returns>
|
public string WaveIsNeedUnpack(string waveNo)
|
{
|
string result = "0";//是否需要拆箱，0：否 1：是
|
if (string.IsNullOrEmpty(waveNo))
|
{
|
throw new Exception("未找到对应波次单！");
|
}
|
try
|
{
|
var wave = Db.Queryable<BllWaveMage>().First(w => w.IsDel == "0" && w.WaveNo == waveNo);
|
if (wave == null)
|
{
|
throw new Exception("未找到对应出波次单！");
|
}
|
var noticeList = Db.Queryable<BllExportNotice>().Where(w => w.IsDel == "0" && w.WaveNo == waveNo).ToList();
|
if (noticeList.Count == 0)
|
{
|
throw new Exception("未找到对应出库单！");
|
}
|
|
var soList = noticeList.Select(m => m.SONo).ToList();
|
//物料编码表
|
var skuList = Db.Queryable<SysMaterials>().Where(w => w.IsDel == "0");
|
//包装表
|
var packagList = Db.Queryable<SysPackag>().Where(w => w.IsDel == "0");
|
//出库分配信息
|
var allotList = Db.Queryable<BllExportAllot>().Where(w => w.IsDel == "0" && soList.Contains(w.SONo)).ToList();
|
foreach (var item in allotList)
|
{
|
var skuInfo = skuList.First(w => w.SkuNo == item.SkuNo);
|
if (skuInfo == null)
|
{
|
throw new Exception("物料信息不存在！");
|
}
|
var packagInfo = packagList.First(w => w.PackagNo == skuInfo.PackagNo);
|
if (packagInfo == null)
|
{
|
throw new Exception("包装信息不存在！");
|
}
|
if (packagInfo.L2Name == "箱")
|
{
|
if (item.Qty % (decimal)packagInfo.L2Num != 0)//能整除说明不用拆箱，不能整除说明需要拆箱
|
{
|
result = "1";//需要拆箱
|
break;
|
}
|
}
|
var boxInfo = Db.Queryable<DataBoxInfo>().Where(w => w.IsDel == "0" && w.PalletNo == item.PalletNo && w.BitBoxMark == "1").ToList();
|
if (boxInfo != null)//托盘上有零箱需要拆箱
|
{
|
result = "1";//需要拆箱
|
break;
|
}
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
throw new Exception(ex.Message);
|
}
|
}
|
|
|
#region 数据归档
|
//获取波次单信息-数据归档
|
public List<WaveMageDto> GetArchivingWaveMageList(string waveNo, string status, string lotNo, int? logisticsId, int page, int limit, out int count)
|
{
|
string sqlString = string.Empty;
|
string sqlCount = string.Empty;
|
string sqlPub = string.Empty;
|
try
|
{
|
sqlCount += "SELECT DISTINCT COUNT(tb1.ID) FROM ArchivingWaveMage AS tb1 ";
|
|
sqlString += "SELECT DISTINCT tb1.Id,tb1.WaveNo,tb1.Status,tb1.Origin,tb1.LotNo, ";
|
sqlString += "tb1.LotText,tb1.SupplierLot,tb1.CustomerNo,tb1.CustomerName,";
|
sqlString += "tb1.LogisticsId,tb2.CarrierName as LogisticsName,tb1.Address,";
|
sqlString += "tb3.RealName as CreateUserName,tb4.RealName as UpdateUserName,tb1.CreateTime,tb1.UpdateTime ";
|
sqlString += " FROM ArchivingWaveMage AS tb1 ";
|
|
sqlPub += "LEFT JOIN SysLogisticsInfo AS tb2 ON tb1.LogisticsId = tb2.Id ";
|
sqlPub += "LEFT JOIN SysUserInfor AS tb3 ON tb1.CreateUser = tb3.Id ";
|
sqlPub += "LEFT JOIN SysUserInfor AS tb4 ON tb1.UpdateUser = tb4.Id ";
|
sqlPub += $"WHERE tb1.LotNo LIKE '%{lotNo}%' and tb1.IsDel = '0' ";
|
|
if (!string.IsNullOrWhiteSpace(waveNo))
|
{
|
sqlPub += $"AND tb1.WaveNo = '{waveNo}' ";
|
}
|
if (!string.IsNullOrWhiteSpace(status))
|
{
|
sqlPub += $"AND tb1.Status = '{status}' ";
|
}
|
if (logisticsId != null)
|
{
|
sqlPub += $"AND tb1.LogisticsId = '{logisticsId}' ";
|
}
|
|
sqlCount += sqlPub;
|
sqlPub += " order by tb1.CreateTime desc ";
|
|
|
if (page == 0)
|
{
|
page = 1;
|
}
|
sqlString += sqlPub + $" offset {((page - 1) * limit)} rows fetch next {limit} rows only;";
|
|
var com = new Common();
|
count = com.GetRowCount(sqlCount);
|
|
var modelList = Db.Ado.SqlQuery<WaveMageDto>(sqlString);
|
|
return modelList;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
#endregion
|
|
|
}
|
}
|
