using Rhea.Common;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using Tiger.Business.SqlSugarHepler;
|
using Tiger.IBusiness;
|
using Tiger.Model;
|
using Tiger.Model.Entitys.WMS.DTOS;
|
|
namespace Tiger.Business.WMS
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class SplitBoxBusiness : ISplitBoxBusiness
|
{
|
/// <summary>
|
/// 分合箱
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public int SaveSplitBoxData(SplitBoxDTO input)
|
{
|
//var DB = Biz.Db;// 数据库地址
|
var type = "P";
|
//var DB = Biz.DataSource["Test"].Client;
|
var DB = Biz.DataSource["WMS57"].Client;
|
var oldsns = input.OldSns;// 旧的Sn
|
var oldData = DB.Queryable<WMS_ITEM_PKG>().Where(i => oldsns.Contains(i.SN) || oldsns.Contains(i.PARENT_SN)).ToList();// 获取历史数据
|
if (!oldData.Any(i => string.IsNullOrWhiteSpace(i.PARENT_SN)))
|
{
|
type = "B";
|
var olddataparnet = oldData.Select(i => i.PARENT_SN).Distinct().ToList();// 获取栈板号
|
var oldData2 = DB.Queryable<WMS_ITEM_PKG>().Where(i => olddataparnet.Contains(i.SN) && string.IsNullOrWhiteSpace(i.PARENT_SN)).ToList();// 获取顶级数据
|
oldData.AddRange(oldData2);// 获取所有的历史数据
|
}
|
|
var oldSnData = oldData.Where(i => string.IsNullOrWhiteSpace(i.PARENT_SN)).ToList();// 获取栈板对应NULL数据
|
if (type == "B")
|
{
|
oldSnData = oldData.Where(i => string.IsNullOrWhiteSpace(i.PARENT_SN) || input.OldSns.Contains(i.SN)).ToList();// 获取栈板对应NULL数据以及箱号对应的栈板号数据
|
}
|
|
//var oldParentSnData = oldData.Where(i => oldsns.Contains(i.PARENT_SN)).ToList(); // 获取父级数据
|
//var oldCorrespondence = oldParentSnData.Select(i => new { i.SN, i.PARENT_SN }).ToDictionary(i => i.SN, i => i.PARENT_SN).ToList();// 获取旧的对应关系
|
|
var newsnList = input.NewSnList;
|
var palletList = newsnList.Select(i => i.Pallet).Distinct().ToList(); // 获取所有的栈板号
|
var dicBox = new Dictionary<string, string>(); // 对应关系（新）
|
var dicCount = new Dictionary<string, int>(); // 栈板号——数量对应关系
|
|
#region 获取新的对应关系
|
|
foreach (var pallet in palletList)
|
{
|
var cartonList = newsnList.Where(i => i.Pallet == pallet).Select(i => i.Carton).Distinct().ToList();// 查询栈板号绑定的箱号
|
int sqn = 0;
|
foreach (var carton in cartonList)
|
{
|
var data = newsnList.Where(i => i.Pallet == pallet && i.Carton == carton).ToList();
|
if (!dicBox.ContainsKey(carton) && carton != pallet)
|
{
|
dicBox.Add(carton, pallet);// 箱号——栈板号
|
}
|
foreach (var item in data)
|
{
|
if (!dicBox.ContainsKey(item.SN))
|
{
|
sqn++;
|
dicBox.Add(item.SN, carton);// SN——箱号
|
}
|
}
|
}
|
dicBox.Add(pallet, null);// 栈板号——NULL
|
dicCount.Add(pallet, sqn);// 栈板号——NULL
|
}
|
|
#endregion 获取新的对应关系
|
|
if (oldSnData.Any())
|
{
|
DB.Deleteable(oldSnData).ExecuteCommand();// 删除Box-Pallet和Pallet-Null数据
|
}
|
|
if (dicBox.Any())
|
{
|
var newboxdata = dicBox.Keys.ToList();
|
var oldboxdata = oldData.Where(i => newboxdata.Contains(i.SN)).ToList();// 需要更新的数据
|
foreach (var boxdata in oldboxdata)
|
{
|
boxdata.PARENT_SN = dicBox[boxdata.SN];// 更新箱号/栈板号
|
}
|
DB.Updateable(oldboxdata).ExecuteCommand();
|
|
//var insertData =
|
|
var dataLst = new List<WMS_ITEM_PKG>();
|
foreach (var item in dicBox.Keys)
|
{
|
var data = oldData.Where(i => i.SN == item).FirstOrDefault();
|
|
if (data == null)
|
{
|
dataLst.Add(new WMS_ITEM_PKG()
|
{
|
ID = null,
|
SN = item,
|
ITEM_CODE = oldData[0].ITEM_CODE,
|
UNIT = oldData[0].UNIT,
|
TRANS_NO = oldData[0].TRANS_NO,
|
QTY = dicCount[item],
|
AUTH_ORG = oldData[0].AUTH_ORG,
|
PARENT_SN = dicBox[item]
|
});// 添加顶层数据
|
}
|
}
|
if (dataLst.Any())
|
{
|
DB.Insertable(dataLst).ExecuteCommand();// 插入新的Box-Pallet/Pallet-Null数据
|
}
|
}
|
|
return oldsns.Count();
|
}
|
}
|
}
|
