using Commom.Utility;
|
using Common;
|
using Model;
|
using Org.BouncyCastle.Bcpg.OpenPgp;
|
using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Text;
|
|
namespace BLL.DAL
|
{
|
public class DALCheckTask
|
{
|
/// <summary>
|
/// 加载盘库任务明细
|
/// </summary>
|
/// <param name="dictionarys">查询条件</param>
|
/// <param name="page">分页信息</param>
|
/// <returns></returns>
|
public IList<CheckTask> GetList(CheckTask checkTask, ref PageInfo page)
|
{
|
try
|
{
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append("select * from View_CheckTask_Userinfo where IsDel = 0 " + $" AND DepartGuid='{checkTask.DepartGuid}' ");
|
if (!string.IsNullOrEmpty(checkTask.CDNo))
|
{
|
stringBuilder.Append("and CDNO like '%" + checkTask.CDNo + "%' ");
|
}
|
if (!string.IsNullOrEmpty(checkTask.LocationCode))
|
{
|
stringBuilder.Append("and (LocationCode1 like '%" + checkTask.LocationCode + "%'" +
|
"or LocationCode2 like '%" + checkTask.LocationCode + "%') ");
|
}
|
if (!string.IsNullOrEmpty(checkTask.Palno))
|
{
|
stringBuilder.Append("and (Palno1 like '%" + checkTask.Palno + "%' or " +
|
"Palno1 like '%" + checkTask.Palno + "%') ");
|
}
|
if (!string.IsNullOrEmpty(checkTask.Statu))
|
{
|
stringBuilder.Append("and StatuId = " + checkTask.Statu.AddQuotes());
|
}
|
SqlParam[] para = null;
|
|
DataTable dt = DataFactory.SqlDataBase().GetPageList(stringBuilder.ToString(), para, "ID", "ASC", ref page);
|
IList<CheckTask> list = ModelConvertHelper<CheckTask>.DataTableToModel(dt);
|
|
return list;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
/// <summary>
|
/// 获取托盘内物料明细信息
|
/// </summary>
|
/// <param name="TaskID"></param>
|
/// <returns></returns>
|
public DataTable GetCheckTask(string TaskID)
|
{
|
try
|
{
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append("select * from CheckTask where Guid = " + TaskID.AddQuotes());
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(stringBuilder);
|
|
stringBuilder.Clear();
|
stringBuilder.Append("select '" + TaskID + "' as TaskID,unit as UnitFrist, * from CheckDataDetail where IsDel = 0 ");
|
stringBuilder.Append(" and CDNO = " + dt.Rows[0]["CDNO"].ToString().AddQuotes());
|
stringBuilder.Append(" and LocationCode in (" + dt.Rows[0]["LocationCode1"].ToString().AddQuotes() + ",");
|
stringBuilder.Append(dt.Rows[0]["LocationCode2"].ToString().AddQuotes() + ") ");
|
stringBuilder.Append("and Palno in (" + dt.Rows[0]["Palno1"].ToString().AddQuotes() + ",");
|
stringBuilder.Append(dt.Rows[0]["Palno2"].ToString().AddQuotes() + ") ");
|
DataTable dtItems = DataFactory.SqlDataBase().GetDataTableBySQL(stringBuilder);
|
|
return dtItems;
|
}
|
catch
|
{
|
return null;
|
}
|
}
|
|
/// <summary>
|
/// 实时保存物料实际数量
|
/// </summary>
|
/// <param name="LoginUserCode"></param>
|
/// <param name="Mats"></param>
|
/// <returns></returns>
|
public bool SetItems(string LoginUserCode, CheckMat Mats)
|
{
|
bool result = false;
|
try
|
{
|
StringBuilder sqlstr = new StringBuilder();
|
|
int rowCount = 0;
|
Hashtable ht = new Hashtable();
|
ht["AQuant"] = Mats.AQuant.AddQuotes();
|
ht["CheckUser"] = LoginUserCode.AddQuotes();
|
ht["UpdateTime"] = "convert(varchar(20),getdate(),120)";
|
|
rowCount += DataFactory.SqlDataBase().UpdateByHashtable("CheckDataDetail",
|
"Guid", Mats.Guid.AddQuotes(), ht);
|
|
if (rowCount > 0)
|
{
|
result = true;
|
}
|
|
return result;
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 自动生成盘库指令
|
/// </summary>
|
/// <param name="LoginUserCode"></param>
|
/// <returns></returns>
|
public bool AutoOrders(string LoginUserCode)
|
{
|
bool result = false;
|
try
|
{
|
StringBuilder stringBuilder = new StringBuilder();
|
// 查询WH_CMD表 确认是否存在盘库单待执行的指令
|
stringBuilder.Append("select count(CMDID) from WH_CMD where NumberNo like 'CTNO%' and CMDStatu = 0 and IsDel = 0;");
|
DataRow row = DataFactory.SqlDataBase().GetDataRowBySQL(stringBuilder);
|
// 不存在
|
if (row[0].ToString() == "0")
|
{
|
stringBuilder.Clear();
|
stringBuilder.Append("select top 1 * from CheckTask where statu = '01' and IsDel = 0 order by ID asc");
|
DataRow taskRow = DataFactory.SqlDataBase().GetDataRowBySQL(stringBuilder);
|
if (taskRow != null && taskRow["guid"].ToString() != "")
|
{
|
result = this.CreateOrder(taskRow["guid"].ToString(), LoginUserCode);
|
}
|
}
|
else
|
{
|
result = false;
|
}
|
}
|
catch
|
{
|
return result;
|
}
|
return result;
|
}
|
|
/// <summary>
|
/// 生成盘库指令
|
/// </summary>
|
/// <param name="TaskId"></param>
|
/// <param name="LoginUserCode"></param>
|
/// <returns></returns>
|
public bool CreateOrder(string TaskId, string LoginUserCode)
|
{
|
bool result = false;
|
try
|
{
|
// 获取任务明细
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append($@"
|
SELECT ct.*,
|
cd.AccessCode,
|
d.TypeName AccessName
|
FROM dbo.CheckTask ct
|
JOIN dbo.CheckData cd
|
ON cd.CDNO = ct.CDNO
|
LEFT OUTER JOIN dbo.Dictionary d
|
ON cd.AccessCode=d.Code AND d.TopCode='Access'
|
WHERE ct.statu = '01'
|
AND ct.guid = '{TaskId}';");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(stringBuilder);
|
|
if (dt != null && dt.Rows.Count > 0)
|
{
|
DALWMSApi dalWMSApi = new DALWMSApi();
|
|
foreach (DataRow drTask in dt.Rows)
|
{
|
string locationCode = drTask["LocationCode1"].ToString();
|
string palNo = drTask["Palno1"].ToString();
|
stringBuilder.Clear();
|
stringBuilder.Append($"SELECT TurnoverDemand FROM dbo.DepotsLocation WHERE LocationCode='{locationCode}' AND IsDel=0");
|
DataTable dtDL = DataFactory.SqlDataBase().GetDataTableBySQL(stringBuilder);
|
if (dtDL != null && dtDL.Rows.Count >= 0)
|
{
|
string turnoverDemand = dtDL.Rows[0]["TurnoverDemand"].ToString();
|
switch (turnoverDemand)
|
{
|
case "02":
|
{
|
dalWMSApi.Send(palNo, locationCode, drTask["AccessCode"].ToString());
|
stringBuilder.Clear();
|
stringBuilder.Append($"UPDATE dbo.DepotsLocation SET TurnoverDemand='04' WHERE LocationCode='{locationCode}'");
|
DataFactory.SqlDataBase().ExecuteBySql(stringBuilder);
|
break;
|
}
|
case "03":
|
{
|
var resultApi = dalWMSApi.OutStorage(palNo, locationCode);
|
if (resultApi.Code != "01")
|
{
|
return false;
|
}
|
break;
|
}
|
default:
|
break;
|
}
|
}
|
}
|
|
// 更改盘点任务数据状态
|
Hashtable htt = new Hashtable();
|
htt["statu"] = "'02'";
|
htt["CheckUser"] = LoginUserCode.AddQuotes();
|
htt["CheckTime"] = "convert(varchar(20),getdate(),120)";
|
|
DataFactory.SqlDataBase().UpdateByHashtable("CheckTask",
|
"Guid", TaskId.AddQuotes(), htt);
|
|
return true;
|
}
|
#region 原方法,注释
|
/*
|
if (dt.Rows.Count > 0)
|
{
|
DataRow row = dt.Rows[0];
|
Hashtable ht = new Hashtable();
|
ht["TaskID"] = TaskId.AddQuotes();
|
ht["CMDStatu"] = 0;
|
ht["CreateUser"] = LoginUserCode.AddQuotes();
|
ht["NumberNo"] = row["CDNO"].ToString().AddQuotes();
|
|
if (row["LocationCode2"].ToString() != "") // 外货位是否有盘库任务
|
{
|
// 生成外货位指令
|
ht["Palno"] = row["Palno2"].ToString().AddQuotes();
|
ht["CMDType"] = "'out'";
|
ht["OldAddre"] = row["LocationCode2"].ToString().AddQuotes();
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
|
// 收到WCS出库成功回执后 将货位状态设置为待入库状态 占住此位置
|
|
if (row["LocationCode1"].ToString() != "") // 判断内货位是否有盘库任务
|
{
|
// 生成内货位出库指令
|
ht["Palno"] = row["Palno1"].ToString().AddQuotes();
|
ht["CMDType"] = "'out'";
|
ht["OldAddre"] = row["LocationCode1"].ToString().AddQuotes();
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
|
|
// 生成内货位回库记录 -- 不主动下发wcs用来接收到申请货位请求时返回货位地址
|
ht["CMDType"] = "'to'";
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
|
}
|
|
// 生成外货位回库记录 -- 不主动下发wcs用来接收到申请货位请求时返回货位地址
|
ht["Palno"] = row["Palno2"].ToString().AddQuotes();
|
ht["CMDType"] = "'to'";
|
ht["OldAddre"] = row["LocationCode2"].ToString().AddQuotes();
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
|
|
// 更改盘点任务数据状态
|
Hashtable htt = new Hashtable();
|
htt["statu"] = "'02'";
|
htt["CheckUser"] = LoginUserCode.AddQuotes();
|
htt["CheckTime"] = "convert(varchar(20),getdate(),120)";
|
|
DataFactory.SqlDataBase().UpdateByHashtable("CheckTask",
|
"Guid", TaskId.AddQuotes(), htt);
|
|
return true;
|
}
|
else if (row["LocationCode1"].ToString() != "") // 内货位是否有出库任务
|
{
|
// 获取内货位对应的外货位是否存在托盘
|
DataRow dttRow = this.GetlLocationItem(row["LocationCode1"].ToString());
|
|
string newLocation = string.Empty;
|
if (dttRow != null)
|
{
|
// 存在托盘 先生成外货位移库命令
|
newLocation = this.GetNewLocation(dttRow["Addre"].ToString());
|
ht["Palno"] = dttRow["Palno"].ToString().AddQuotes();
|
ht["OldAddre"] = dttRow["Addre"].ToString().AddQuotes();
|
ht["NowAddre"] = newLocation.AddQuotes();
|
// 如果没有空余货位，直接出库
|
if (newLocation == "")
|
{
|
ht["CMDType"] = "'out'";
|
}
|
else
|
{
|
ht["CMDType"] = "'move'";
|
}
|
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
|
}
|
|
// 生成内货位出库命令
|
ht["Palno"] = row["Palno1"].ToString().AddQuotes();
|
ht["CMDType"] = "'out'";
|
ht["OldAddre"] = row["LocationCode1"].ToString().AddQuotes();
|
ht["NowAddre"] = "''";
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
|
|
// 生成内货位回库命令 -- 不主动下发wcs，用来接收到申请货位请求时返回货位地址
|
ht["CMDType"] = "'to'";
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
|
|
if (dttRow != null)
|
{
|
// 生成移库货位回移指令 ，移库不需要回移暂时不删除以防有变。
|
ht["Palno"] = dttRow["Palno"].ToString().AddQuotes();
|
ht["CMDType"] = "'move'";
|
ht["NowAddre"] = dttRow["Addre"].ToString().AddQuotes();
|
ht["OldAddre"] = newLocation.AddQuotes();
|
|
// 移库回库
|
if (newLocation == "")
|
{
|
ht["CMDType"] = "'to'";
|
ht["NowAddre"] = newLocation.AddQuotes(); ;
|
ht["OldAddre"] = dttRow["Addre"].ToString().AddQuotes();
|
}
|
else
|
{
|
ht["CMDType"] = "'move'";
|
ht["NowAddre"] = dttRow["Addre"].ToString().AddQuotes();
|
ht["OldAddre"] = newLocation.AddQuotes();
|
}
|
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
|
}
|
|
|
// 更改盘库任务状态
|
Hashtable htt = new Hashtable();
|
htt["statu"] = "'02'";
|
htt["CheckUser"] = LoginUserCode.AddQuotes();
|
htt["CheckTime"] = "convert(varchar(20),getdate(),120)";
|
|
DataFactory.SqlDataBase().UpdateByHashtable("CheckTask",
|
"Guid", TaskId.AddQuotes(), htt);
|
|
return true;
|
}
|
}
|
*/
|
#endregion
|
return result;
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 获取指定货位地址的外货位地址
|
/// </summary>
|
/// <returns></returns>
|
private DataRow GetlLocationItem(string Locationcode1)
|
{
|
string Locationcode2 = string.Empty;
|
if (Locationcode1.Contains("-001"))
|
{
|
Locationcode2 = Locationcode1.Replace("-001", "-002");
|
}
|
else
|
{
|
Locationcode2 = Locationcode1.Replace("-004", "-003");
|
}
|
|
StringBuilder stringBuilder = new StringBuilder(); // 一个货位地址只会对应一个托盘码
|
stringBuilder.Append("select top 1 * from log_Store where LocationCode = " + Locationcode2.AddQuotes());
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(stringBuilder);
|
if (dt.Rows.Count > 0)
|
{
|
return dt.Rows[0];
|
}
|
|
return null;
|
}
|
|
/// <summary>
|
/// 获取移库空货位地址
|
/// </summary>
|
/// <param name="Location">当前货位地址</param>
|
/// <returns>空货位地址</returns>
|
private string GetNewLocation(string Location)
|
{
|
string newLocation = ""; // 移库目标货位
|
int lRow = int.Parse(Location.Substring(3, 3));
|
int lColumn = int.Parse(Location.Substring(6, 3));
|
int lLayer = int.Parse(Location.Substring(9, 3));
|
|
// 获取外货架的所有空货位
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append("select LocationCode,LRow,LColumn,LLayer from DepotsLocation ");
|
stringBuilder.Append(" where IsDel = 0 and TurnoverDemand = '01'");
|
stringBuilder.Append(" and Type >= (select Type from DepotsLocation where LocationCode = " + Location.AddQuotes() + ") ");
|
stringBuilder.Append(" and (LocationCode like '%-002%' or LocationCode like '%-003%') ");
|
stringBuilder.Append(" order by LocationCode; ");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(stringBuilder);
|
|
if (dt != null)
|
{
|
int value = 600;
|
foreach (DataRow row in dt.Rows)
|
{
|
int dtrow = int.Parse(row["LRow"].ToString());
|
int dtColumn = int.Parse(row["LColumn"].ToString());
|
int dtLayer = int.Parse(row["LLayer"].ToString());
|
int number = 0;
|
|
int a = lRow - dtrow;
|
if (a < 0)
|
{
|
number += (0 - a);
|
}
|
else
|
{
|
number += a;
|
}
|
|
int b = lColumn - dtColumn;
|
if (b < 0)
|
{
|
number += (0 - b);
|
}
|
else
|
{
|
number += b;
|
}
|
|
int c = lLayer - dtLayer;
|
if (c < 0)
|
{
|
number += (0 - c);
|
}
|
else
|
{
|
number += c;
|
}
|
|
if (value > number)
|
{
|
value = number;
|
newLocation = row["LocationCode"].ToString();
|
}
|
}
|
|
return newLocation;
|
}
|
else
|
{
|
stringBuilder.Clear();
|
stringBuilder.Append("select LocationCode,LRow,LColumn,LLayer from DepotsLocation ");
|
stringBuilder.Append(" where IsDel = 0 and TurnoverDemand = '01'");
|
stringBuilder.Append(" and Type >= (select Type from DepotsLocation where LocationCode = " + Location.AddQuotes() + ") ");
|
stringBuilder.Append(" and (LocationCode like '%-001%' or LocationCode like '%-004%') ");
|
stringBuilder.Append(" order by LocationCode); ");
|
dt = DataFactory.SqlDataBase().GetDataTableBySQL(stringBuilder);
|
|
if (dt != null)
|
{
|
int value = 600;
|
foreach (DataRow row in dt.Rows)
|
{
|
int dtrow = int.Parse(row["LRow"].ToString());
|
int dtColumn = int.Parse(row["LColumn"].ToString());
|
int dtLayer = int.Parse(row["LLayer"].ToString());
|
int number = 0;
|
|
int a = lRow - dtrow;
|
if (a < 0)
|
{
|
number += (0 - a);
|
}
|
else
|
{
|
number += a;
|
}
|
|
int b = lColumn - dtColumn;
|
if (b < 0)
|
{
|
number += (0 - b);
|
}
|
else
|
{
|
number += b;
|
}
|
|
int c = lLayer - dtLayer;
|
if (c < 0)
|
{
|
number += (0 - c);
|
}
|
else
|
{
|
number += c;
|
}
|
|
if (value > number)
|
{
|
value = number;
|
newLocation = row["LocationCode"].ToString();
|
}
|
}
|
|
return newLocation;
|
}
|
}
|
|
return newLocation;
|
}
|
}
|
}
|
