using BLL.IDAL;
|
using Common;
|
using Model;
|
using NLog;
|
using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace BLL.DAL
|
{
|
public class DAL_Pub
|
{
|
private Logger logger = LogManager.GetCurrentClassLogger();
|
public int SplitPosCode(string strSplit, ref int pai, ref int lie, ref int ceng)
|
{
|
pai = 0;
|
lie = 0;
|
ceng = 0;
|
try
|
{
|
pai = int.Parse(strSplit.Substring(strSplit.Length - 9, 3));
|
lie = int.Parse(strSplit.Substring(strSplit.Length - 6, 3));
|
ceng = int.Parse(strSplit.Substring(strSplit.Length - 3, 3));
|
}
|
catch
|
{
|
return -1;
|
}
|
|
return 0;
|
}
|
/// <summary>
|
/// 移库获取移动目标货位,返回1表示分配的是里边库位，且该库位被外边货物挡住，需要先移库，返回0，表示该库位没被挡住
|
/// </summary>
|
/// <param name="newPos"></param>
|
/// <param name="oriPos"></param>
|
/// <returns></returns>
|
public int GetEmptyPos(ref string newPos, int height, string oriPos = null)
|
{
|
int iret = 0;
|
newPos = null;
|
string newP = null;
|
try
|
{
|
if (oriPos == null)//普通入库，优先最底层，第一列，...
|
{
|
//按顺序获取外边第一个空库位
|
DepotsLocation dl = new DepotsLocation();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("select top(1) * from View_GetEmptyPos where ( LRow = 2 or LRow = 3 ) and Height >= ");
|
strSql.Append(height);
|
strSql.Append(" order by Height, LLayer, LRow, LColumn");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
if (dt != null)
|
{
|
dl = ModelConvertHelper<DepotsLocation>.ReaderToModel(dt);
|
int LColumn = dl.LColumn;
|
int LLayer = dl.LLayer;
|
newP = dl.LocationCode;
|
//检测对应里边库位是否为空
|
StringBuilder sqlFindIn = new StringBuilder();
|
if (dl.LRow == 2)
|
{
|
sqlFindIn.Append("select * from View_GetEmptyPos where LRow = 1 and LColumn = @LColumn and LLayer = @LLayer");
|
}
|
else
|
{
|
sqlFindIn.Append("select * from View_GetEmptyPos where LRow = 4 and LColumn = @LColumn and LLayer = @LLayer");
|
}
|
SqlParam[] para = new SqlParam[]
|
{
|
new SqlParam("@LColumn", LColumn),
|
new SqlParam("@LLayer", LLayer)
|
};
|
IDataReader dt1 = DataFactory.SqlDataBase().GetDataReaderBySQL(sqlFindIn, para);
|
dl = ModelConvertHelper<DepotsLocation>.ReaderToModel(dt1);
|
if (dl != null)
|
{
|
newP = dl.LocationCode;
|
}
|
newPos = newP;
|
}
|
else
|
{
|
//找里边空库位，该库位对应外边库位肯定是占用状态，被外库位挡着，需要移库
|
DepotsLocation dl2 = new DepotsLocation();
|
StringBuilder strSql2 = new StringBuilder();
|
strSql2.Append("select top(1) * from View_GetEmptyPos where ( LRow = 1 or LRow = 4 ) and Height >= ");
|
strSql2.Append(height);
|
strSql2.Append(" order by Height, LLayer, LRow, LColumn");
|
|
IDataReader dt2 = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql2);
|
|
dl2 = ModelConvertHelper<DepotsLocation>.ReaderToModel(dt2);
|
|
if (dl2 != null)
|
{
|
newP = dl2.LocationCode;
|
return 1;
|
}
|
else
|
{
|
return -2;
|
}
|
}
|
}
|
else
|
{
|
//移库,优先将外边移到对应里边库位，若里边不为空，找外边最近库位，然后再优先移到该最近库位对应里边库位
|
int row = 0, column = 0, layer = 0;
|
//解析库位坐标
|
SplitPosCode(oriPos, ref row, ref column, ref layer);
|
//
|
List<DepotsLocation> lst3 = new List<DepotsLocation>();
|
StringBuilder strSQLInner = new StringBuilder();
|
StringBuilder strSql3 = new StringBuilder();
|
//原始库位为外边库位，则判断对应里边库位是否为空，为空则分配出去
|
if (row == 2)
|
{
|
strSQLInner.Append("select * from View_GetEmptyPos where LRow = 1 and LColumn = ");
|
strSQLInner.Append(column);
|
strSQLInner.Append(" and LLayer = ");
|
strSQLInner.Append(layer);
|
|
IDataReader dr = DataFactory.SqlDataBase().GetDataReaderBySQL(strSQLInner);
|
if (dr != null && dr.IsEmpty())
|
{
|
DepotsLocation dl = new DepotsLocation();
|
dl = ModelConvertHelper<DepotsLocation>.ReaderToModel(dr);
|
newPos = dl.LocationCode;
|
return 0;
|
}
|
}
|
if (row == 3)
|
{
|
strSQLInner.Append("select * from View_GetEmptyPos where LRow = 4 and LColumn = ");
|
strSQLInner.Append(column);
|
strSQLInner.Append(" and LLayer = ");
|
strSQLInner.Append(layer);
|
|
IDataReader dr = DataFactory.SqlDataBase().GetDataReaderBySQL(strSQLInner);
|
if (dr != null && dr.IsEmpty())
|
{
|
DepotsLocation dl = new DepotsLocation();
|
dl = ModelConvertHelper<DepotsLocation>.ReaderToModel(dr);
|
newPos = dl.LocationCode;
|
return 0;
|
}
|
}
|
//获取2/3排是空库位货位
|
strSql3.Append("select * from View_GetEmptyPos where (LRow = 2 or LRow = 3) and Height >= ");
|
strSql3.Append(height + " and LocationCode != '" + oriPos + "' ");
|
strSql3.Append(" order by Height, LLayer, LColumn, LRow");
|
|
IDataReader dt3 = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql3);
|
if (dt3 == null)
|
{
|
return 0;
|
}
|
lst3 = (List<DepotsLocation>)ModelConvertHelper<DepotsLocation>.DataReaderToModel(dt3);
|
int sum = 100000;
|
DepotsLocation depotsLocation = new DepotsLocation();
|
//获取最近外层库位
|
for (int j = 0; j < lst3.Count; j++)
|
{
|
|
DepotsLocation dl = lst3[j];
|
|
// liudl注释 神逻辑看不懂
|
//if ((dl != null) && (dl.Height > height))
|
//{
|
// break;//后边库位高度与实际不符，不在对比，除非depotsLocation为空
|
//}
|
|
int vAbs = (Math.Abs(dl.LRow - row) + Math.Abs(dl.LLayer - layer));
|
if (sum > vAbs)
|
{
|
sum = vAbs;
|
depotsLocation = dl;
|
}
|
}
|
StringBuilder strSqlIn = new StringBuilder();
|
//判断该外层库位对应里边库位是否为空
|
if (depotsLocation.LRow == 2)
|
{
|
strSqlIn.Append("select * from View_GetEmptyPos where LRow = 1 and LColumn = @LColumn and LLayer = @LLayer");
|
}
|
else
|
{
|
strSqlIn.Append("select * from View_GetEmptyPos where LRow = 4 and LColumn = @LColumn and LLayer = @LLayer");
|
}
|
SqlParam[] param = new SqlParam[]
|
{
|
new SqlParam("@LLayer", depotsLocation.LLayer),
|
new SqlParam("@LColumn", depotsLocation.LColumn)
|
};
|
List<DepotsLocation> lstIn = new List<DepotsLocation>();
|
IDataReader dtIn = DataFactory.SqlDataBase().GetDataReaderBySQL(strSqlIn, param);
|
//不为空，则将里边库位分配出去
|
if (dtIn != null)
|
{
|
lstIn = (List<DepotsLocation>)ModelConvertHelper<DepotsLocation>.DataReaderToModel(dtIn);
|
if ((lstIn.Count > 0) && (lstIn[0].LocationCode != oriPos))
|
{
|
depotsLocation = lstIn[0];
|
}
|
}
|
newPos = depotsLocation.LocationCode;
|
}
|
}
|
catch (Exception ex)
|
{
|
iret = -1;
|
}
|
return iret;
|
}
|
//检查出库单是否所有托盘出库完成更改出库单状态，并更新该条指令状态
|
public int Erp_to(string taskID, string palno, string oldAddre)
|
{
|
int r = -1;
|
try
|
{
|
StringBuilder SQL = new StringBuilder();
|
SQL.Append("select * from Erp_Out where Ordno= '" + taskID + "' ");
|
DataTable dd = DataFactory.SqlDataBase().GetDataTableBySQL(SQL);
|
if (dd.Rows.Count > 0)
|
{
|
StringBuilder hql = new StringBuilder();
|
hql.Append("update WH_CMD set IsDel =1 where TaskID = '" + taskID + "' and OldAddre ='" + oldAddre + "' and Palno ='" + palno + "' and CMDType='to'");
|
DataFactory.SqlDataBase().ExecuteBySql(hql);
|
StringBuilder aql = new StringBuilder();
|
aql.Append("update DepotsLocation set TurnoverDemand ='02' where LocationCode = '" + oldAddre + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(aql);
|
//查询该指令下单号所有是否都出库，是则更改出库单状态
|
StringBuilder sql = new StringBuilder();
|
sql.Append("select * from WH_CMD where TaskID = '" + taskID + "' and IsDel=0");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (dt.Rows.Count <= 0)
|
{
|
StringBuilder eql = new StringBuilder();
|
eql.Append("update Erp_Out set Statu ='ER03' where Ordno = '" + taskID + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(eql);
|
}
|
|
}
|
return r = 0;
|
}
|
catch (Exception)
|
{
|
|
return r;
|
}
|
}
|
|
/// <summary>
|
/// 移库更改库存明细表托盘位置和指令表托盘位置
|
/// </summary>
|
/// <param name="taskID"></param>
|
/// <param name="palno"></param>
|
/// <param name="oldAddre"></param>
|
/// <param name="nowAddre"></param>
|
/// <returns></returns>
|
public int UpdatemoveStore(string taskID, string palno, string oldAddre, string nowAddre)
|
{
|
int r = -1;
|
try
|
{
|
if (taskID == "" || taskID == null)
|
{
|
StringBuilder sql = new StringBuilder();
|
sql.Append("update log_Store set Addre='" + nowAddre + "' where Addre = '" + oldAddre + "' and Palno='" + palno + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(sql);
|
this.UpdateDeopotsLocation(nowAddre, "02");
|
this.UpdateDeopotsLocation(oldAddre, "01");
|
|
//更改未生成指令的出库单，对应的出库明细表中的托盘的库位地址
|
sql.Clear();
|
sql.Append("Update ErpOutDetail set addre = '" + nowAddre + "' ");
|
sql.Append("where Palno = '" + palno + "' and OrdNo in ");
|
sql.Append("(select OrdNo from Erp_Out where Statu = 'ER01' and Erp_Out.IsDel = 0);");
|
DataFactory.SqlDataBase().ExecuteBySql(sql);
|
|
//查询指令表中是不是有移走的托盘指令，有则更改该托盘新货位
|
StringBuilder hql = new StringBuilder();
|
hql.Append("select * from WH_CMD where OldAddre = '" + oldAddre + "' and Palno='" + palno + "' and CMDType !='move' and IsDel=0");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(hql);
|
if (dt.Rows.Count > 0)
|
{
|
StringBuilder eql = new StringBuilder();
|
eql.Append("update WH_CMD set OldAddre='" + nowAddre + "' where OldAddre = '" + oldAddre + "' and Palno='" + palno + "' and CMDType !='move' and IsDel=0 ");
|
DataFactory.SqlDataBase().ExecuteBySql(eql);
|
}
|
//更改指令表该条指令状态
|
StringBuilder ql = new StringBuilder();
|
ql.Append("update WH_CMD set IsDel=1 where OldAddre = '" + oldAddre + "' and Palno='" + palno + "' and NowAddre='" + nowAddre + "' and CMDType ='move' and IsDel=0 ");
|
DataFactory.SqlDataBase().ExecuteBySql(ql);
|
}
|
|
return r = 0;
|
}
|
catch (Exception)
|
{
|
return r;
|
}
|
}
|
|
/// <summary>
|
/// 更改指令状态，查看是否出完所有托盘是则改出库单状态
|
/// </summary>
|
/// <param name="taskID"></param>
|
/// <param name="palno"></param>
|
/// <param name="oldAddre"></param>
|
/// <returns></returns>
|
public int UpdateOut(string taskID, string palno, string oldAddre)
|
{
|
int r = -1;
|
try
|
{
|
//StringBuilder hql = new StringBuilder();
|
//hql.Append("update WH_CMD set IsDel =1 where TaskID = '" + taskID + "' and OldAddre ='" + oldAddre + "' and Palno ='" + palno + "' and CMDType='out'");
|
//DataFactory.SqlDataBase().ExecuteBySql(hql);
|
////查询该指令下单号所有是否都出库和回库表中该订单是否需要回库，没有指令和回库则更改出库单状态
|
//StringBuilder sql = new StringBuilder();
|
//sql.Append("select * from WH_CMD where TaskID = '" + taskID + "' and IsDel=0");
|
//DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
//查询回库表中是否有该订单需要回库
|
//StringBuilder ql = new StringBuilder();
|
//ql.Append("select * from Picking where OrdNo = '" + taskID + "' and IsDel=0");
|
//DataTable tt = DataFactory.SqlDataBase().GetDataTableBySQL(ql);
|
//if (tt.Rows.Count <= 0)
|
//{
|
// eql.Append($"update Erp_Out set Statu ='03',CompletionTime=GETDATE() where Ordno = '" + taskID + "'");
|
//}
|
//else
|
//{
|
// eql.Append($"update Erp_Out set Statu ='04',CompletionTime=GETDATE() where Ordno = '" + taskID + "'");
|
//}
|
//eql.Append($"select 1 from View_ErpOutDetail where OrdNo='{taskID}'");
|
//DataTable tt = DataFactory.SqlDataBase().GetDataTableBySQL(eql);
|
//if (tt != null && tt.Rows.Count <= 0)
|
//{
|
StringBuilder eql = new StringBuilder();
|
eql.Clear();
|
eql.Append($"update Erp_Out set Statu ='03',CompletionTime=GETDATE() where Ordno = '" + taskID + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(eql);
|
//}
|
|
return r = 0;
|
}
|
catch (Exception)
|
{
|
|
return r;
|
}
|
}
|
|
/// <summary>
|
/// 查询出库托盘下是否有物料，有则回库,没有则更改货位状态为空货位
|
/// </summary>
|
/// <param name="taskID"></param>
|
/// <param name="palno"></param>
|
/// <param name="oldAddre"></param>
|
/// <returns></returns>
|
public int InsertPicking(string taskID, string palno, string oldAddre)
|
{
|
int r = -1;
|
try
|
{
|
//出库指令更新完库存后判断托盘是否还有物料，有则回库表插入数据，没有则更改货位状态为空货位
|
StringBuilder sql = new StringBuilder();
|
sql.Append("select 1 from log_Store where log_Store.Palno='" + palno + "' and IsDel=0");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (dt.Rows.Count > 0)
|
{
|
Hashtable ht = new Hashtable();
|
ht["OrdNo"] = "'" + taskID + "'";
|
ht["Palno"] = "'" + palno + "'";
|
ht["Addre"] = "'" + oldAddre + "'";
|
ht["IsDel"] = 0;
|
|
StringBuilder ql = new StringBuilder();
|
ql.Append("select * from Picking where OrdNo='" + taskID + "' and Palno='" + palno + "' AND IsDel=0 ");
|
DataTable tt = DataFactory.SqlDataBase().GetDataTableBySQL(ql);
|
if (tt != null && tt.Rows.Count <= 0)
|
{
|
DataFactory.SqlDataBase().InsertByHashtableNullParam("Picking", ht);
|
}
|
StringBuilder hql = new StringBuilder();
|
hql.Append("update DepotsLocation set TurnoverDemand ='03' where LocationCode = '" + oldAddre + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(hql);
|
}
|
else
|
{
|
StringBuilder hql = new StringBuilder();
|
hql.Append("update DepotsLocation set TurnoverDemand ='01' where LocationCode = '" + oldAddre + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(hql);
|
// 删除回库表数据
|
hql.Clear();
|
hql.Append($"UPDATE dbo.Picking SET IsDel=1 WHERE Palno='{palno}' AND Addre='{oldAddre}' AND IsDel=0");
|
DataFactory.SqlDataBase().ExecuteBySql(hql);
|
}
|
|
return r = 0;
|
}
|
catch (Exception)
|
{
|
|
return r;
|
}
|
|
}
|
|
/// <summary>
|
/// 查询单号该out指令是不是出库单的
|
/// </summary>
|
/// <param name="taskID"></param>
|
/// <returns></returns>
|
public int UpdateStore(string taskID, string palno, string OldAddre)
|
{
|
int r = 0;
|
try
|
{
|
StringBuilder SQL = new StringBuilder();
|
SQL.Append("select * from View_ErpOutDetail where OrdNo= '" + taskID + "' and Palno='" + palno + "'and LocationCode = '" + OldAddre + "' and Statu='02'");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(SQL);
|
//如果该指令任务号是出库单单号匹配则更改库存表
|
if (dt.Rows.Count > 0)
|
{
|
for (int i = 0; i < dt.Rows.Count; i++)
|
{
|
// 空托盘出库 物料编码为null
|
if (dt.Rows[i]["MatNo"].ToString() == "")
|
{
|
StringBuilder sql = new StringBuilder();
|
sql.Append("select quant from log_Store where LocationCode= '" + dt.Rows[i]["LocationCode"].ToString());
|
sql.Append("' and log_Store.Palno='" + dt.Rows[i]["Palno"].ToString() + "' and isnull(matno,'') = '' and IsDel=0");
|
DataTable ddd = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (ddd.Rows.Count > 0)
|
{
|
int subtract = ddd.Rows[0]["Quant"].ToInt() - dt.Rows[i]["CurQuant"].ToInt();
|
if (subtract <= 0)
|
{
|
StringBuilder ht = new StringBuilder();
|
ht.Append("delete from log_Store where LocationCode= '" + dt.Rows[i]["LocationCode"].ToString() + "' and Palno='" + dt.Rows[i]["Palno"].ToString() + "' and isnull(MatNo,'')=''");
|
DataFactory.SqlDataBase().ExecuteBySql(ht);
|
|
}
|
else
|
{
|
StringBuilder ht = new StringBuilder();
|
ht.Append("update log_Store set Quant='" + subtract + "' where LocationCode= '" + dt.Rows[i]["LocationCode"].ToString() + "' and Palno='" + dt.Rows[i]["Palno"].ToString() + "' and isnull(MatNo,'')=''");
|
DataFactory.SqlDataBase().ExecuteBySql(ht);
|
}
|
}
|
|
}
|
else // 物料出库
|
{
|
//查询出库存明细表数量减去出库单数量并更新库存表 //lijiangang修改：增加合格证Certificate条件图号条件
|
StringBuilder hql = new StringBuilder();
|
hql.Append("select log_Store.Guid,log_Store.Quant,Log_Stroe_Mat.Quant as MatQuant from log_Store left join Log_Stroe_Mat on log_Store.MatNo = Log_Stroe_Mat.MatNo" +
|
" where log_Store.LocationCode= '" + dt.Rows[i]["LocationCode"].ToString() + "' and log_Store.Palno='" + dt.Rows[i]["Palno"].ToString() + "' " +
|
" and log_Store.MatNo='" + dt.Rows[i]["MatNo"].ToString() + "' " +
|
"and isnull(log_Store.TuNo,'') = '" + dt.Rows[i]["TuNo"].ToString() + "' and log_Store.lingno = '" + dt.Rows[i]["lingno"].ToString() + "'");
|
DataTable dd = DataFactory.SqlDataBase().GetDataTableBySQL(hql);
|
if (dd.Rows.Count > 0)
|
{
|
//更新库存明细表
|
int subtract = dd.Rows[0]["Quant"].ToInt() - dt.Rows[i]["CurQuant"].ToInt();
|
if (subtract <= 0)
|
{
|
StringBuilder ht = new StringBuilder();
|
//ht.Append("delete from log_Store where log_Store.Guid='" + dd.Rows[0]["Guid"].ToString() + "'");
|
ht.Append("update log_Store set isdel = '1' where log_Store.Guid='" + dd.Rows[0]["Guid"].ToString() + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(ht);
|
|
}
|
else
|
{
|
StringBuilder ht = new StringBuilder();
|
ht.Append("update log_Store set Quant='" + subtract + "' where log_Store.Guid='" + dd.Rows[0]["Guid"].ToString() + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(ht);
|
}
|
//更新库存总表
|
int subtractnum = dd.Rows[0]["MatQuant"].ToInt() - dt.Rows[i]["CurQuant"].ToInt();
|
StringBuilder qt = new StringBuilder();
|
qt.Append("update Log_Stroe_Mat set Quant='" + subtractnum + "' where Log_Stroe_Mat.MatNo='" + dt.Rows[i]["MatNo"].ToString() + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(qt);
|
}
|
}
|
}
|
|
r = 1;
|
}
|
else // 库内托盘出库重新组盘
|
{
|
if (string.IsNullOrWhiteSpace(taskID))
|
{
|
StringBuilder hql = new StringBuilder();
|
hql.Append("update DepotsLocation set TurnoverDemand ='03' where LocationCode = '" + OldAddre + "'");
|
DataFactory.SqlDataBase().ExecuteBySql(hql);
|
}
|
|
}
|
return r;
|
}
|
catch (Exception)
|
{
|
r = -1;
|
return r;
|
}
|
|
}
|
|
//生成入库指令
|
public int GenPalletInOrder(Order order)
|
{
|
try
|
{
|
Hashtable ht = new Hashtable();
|
DateTime t = DateTime.Now;
|
ht["TaskID"] = order.TaskID;
|
ht["Palno"] = order.Palno;
|
ht["CMDType"] = order.CMDType;
|
ht["OldAddre"] = order.OldAddre;
|
ht["NowAddre"] = order.NowAddre;
|
ht["CMDStatu"] = order.CMDStatu;
|
ht["CreateUser"] = order.CreateUser;
|
ht["CreateTime"] = t;
|
ht["IsDel"] = 0;
|
|
int r = DataFactory.SqlDataBase().InsertByHashtable("WH_CMD", ht);
|
if (r > 0)
|
{
|
return 0;
|
}
|
else
|
{
|
return -1;
|
}
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 改变库位状态
|
/// </summary>
|
/// <param name="Location">库位地址</param>
|
/// <param name="statu">库位状态</param>
|
/// <returns></returns>
|
public bool UpdateLocationState(string Location, string statu)
|
{
|
try
|
{
|
bool bl = false;
|
StringBuilder sbStr = new StringBuilder();
|
sbStr.Append("Update DepotsLocation set TurnoverDemand = '" + statu + "' ");
|
sbStr.Append("where LocationCode = '" + Location + "';");
|
|
int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sbStr);
|
if (rowCount > 0)
|
{
|
bl = true;
|
}
|
|
return bl;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
//从CMD表获取第一条命令
|
public int GetErpInCmd(ref IList<ErpInCmd> lst)
|
{
|
int ir = 0;
|
lst.Clear();
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append("select top(1)* from WH_CMD where (CMDStatu = 1 or CMDStatu = 0 or CMDStatu = -1) and IsDel = 0 Order by CreateTime");
|
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
if (dt.Rows.Count > 0)
|
lst = ModelConvertHelper<ErpInCmd>.DataTableToModel(dt);
|
}
|
}
|
catch (Exception ex)
|
{
|
ir = -1;
|
}
|
return ir;
|
}
|
//通过托盘码从组盘表获得订单号
|
public int GetOrdByPalletNo(string PalletNo, string CMDID, ref string OrdNo)
|
{
|
int ir = 0;
|
bool bl = false;
|
OrdNo = "";
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
// 判断组盘表里是否存在此托盘码
|
strSQL.Append("select * from IPalletBind where PalletNo = '");
|
strSQL.Append(PalletNo);
|
// 过滤已删除数据
|
strSQL.Append("' and Statu = '1' and IsDel = '0';");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
if (dt.Rows.Count > 0)
|
{
|
OrdNo = dt.Rows[0]["OrdNo"].ToString();
|
bl = true;
|
}
|
}
|
|
// 判断空托盘表里是否存在此托盘码
|
strSQL.Clear();
|
strSQL.Append("select id from IPalletEmptyIn where PalletNo = '" + PalletNo + "'");
|
strSQL.Append(" and Statu = '1' and isDel = '0';");
|
DataTable dtt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dtt.Rows.Count > 0)
|
{
|
bl = true;
|
}
|
|
if (!bl)
|
{
|
// 此托盘无单据关联，将该指令的statu状态置为 -5（非法托盘)
|
strSQL.Clear();
|
strSQL.Append("Update WH_CMD set CMDStatu = '-5' where CMDID='" + CMDID + "';");
|
DataFactory.SqlDataBase().ExecuteBySql(strSQL);
|
ir = -1;
|
}
|
}
|
catch
|
{
|
ir = -1;
|
}
|
|
return ir;
|
}
|
//更新cmd命令表
|
public int UpdateCmd(string PalletNo, int status, string OrdNo, string OriPos, string NewPos = "")
|
{
|
int ir = 0;
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
strSQL.Append("update WH_CMD set OldAddre = @OldAddre, NowAddre = @NowAddre, TaskID = @OrdNo, CMDStatu = @CMDStatu ");
|
if (status == 3)
|
{
|
strSQL.Append(" ,IsDel=1");
|
}
|
strSQL.Append(" where Palno = @Palno and IsDel = 0");
|
SqlParam[] param = new SqlParam[]
|
{
|
new SqlParam("@OldAddre", OriPos),
|
new SqlParam("@NowAddre", NewPos),
|
new SqlParam("@OrdNo", OrdNo),
|
new SqlParam("@CMDStatu", status),
|
new SqlParam("@Palno", PalletNo)
|
|
};
|
ir = DataFactory.SqlDataBase().ExecuteBySql(strSQL, param);
|
}
|
catch (Exception ex)
|
{
|
ir = -1;
|
}
|
return ir;
|
}
|
//更新Log_store库存明细表
|
public int UpdateLogStore(string Pos, IList<PalletBind> lst)
|
{
|
int r = -1;
|
try
|
{
|
foreach (PalletBind pb in lst)
|
{
|
int has = 0;
|
StringBuilder strSQL = new StringBuilder();
|
StringBuilder strSQL2 = new StringBuilder();
|
|
strSQL.Append("select Quant,LocationCode from log_Store where MatNo = '");
|
strSQL.Append(pb.MatNo);
|
strSQL.Append("' and LingNo = '");
|
strSQL.Append(pb.LingNo);
|
strSQL.Append("' and Palno = '");
|
strSQL.Append(pb.PalletNo);
|
strSQL.Append("'");
|
strSQL.Append(" and isnull(Certificate,'') = '" + pb.HeGeZheng + "'");
|
strSQL.Append(" and isnull(tuno,'') = '" + pb.TuNo + "'");
|
strSQL.Append(" and isnull(BatchNo,'') = '" + pb.BatchNo + "'");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
if (dt.Rows.Count > 0)
|
{
|
has = int.Parse(dt.Rows[0]["Quant"].ToString());
|
has += int.Parse(pb.MatCount);
|
if (has > 0)
|
{
|
strSQL2.Append("update log_Store set Quant = '");
|
strSQL2.Append(has.ToString());
|
strSQL2.Append("' where ");
|
strSQL2.Append("MatNo = '");
|
strSQL2.Append(pb.MatNo);
|
strSQL2.Append("' and LingNo = '");
|
strSQL2.Append(pb.LingNo);
|
strSQL2.Append("' and Palno = '" + pb.PalletNo);
|
strSQL2.Append("' and isnull(Certificate,'') = '" + pb.HeGeZheng);
|
strSQL2.Append("' and isnull(tuno,'') = '" + pb.TuNo + "'");
|
strSQL2.Append("' and isnull(BatchNo,'') = '" + pb.BatchNo + "'");
|
|
r = DataFactory.SqlDataBase().ExecuteBySql(strSQL2);
|
}
|
}
|
else
|
{
|
DateTime t = DateTime.Now;
|
Hashtable ht = new Hashtable();
|
ht["LocationCode"] = Pos;
|
ht["Palno"] = pb.PalletNo;
|
ht["MatNo"] = pb.MatNo;
|
ht["LingNo"] = pb.LingNo;
|
ht["TuNo"] = pb.TuNo;
|
ht["PageNo"] = pb.PageNo;
|
ht["Quant"] = pb.MatCount;
|
ht["CQuant"] = 0;
|
ht["Certificate"] = pb.HeGeZheng;
|
ht["DepartGuid"] = pb.DepartGuid;
|
ht["MatGuid"] = pb.MatGuid;
|
ht["BatchNo"] = pb.BatchNo;
|
ht["BatchName"] = pb.BatchDemo;
|
|
// ht["CreateTime"] = t.ToString("yyyy-MM-dd HH:mm:ss");
|
//ht["Demo"] = pb.Demo;
|
//ht["CheckTime"] = t.ToString("yyyy-MM-dd HH:mm:ss");
|
|
r = DataFactory.SqlDataBase().InsertByHashtable("log_Store", ht);
|
}
|
}
|
|
//入库完成后往入库单物料位置表ErpInPosition插入货位和托盘信息，方便查看入库单物料存放位置
|
StringBuilder strSQL1 = new StringBuilder();
|
strSQL1.Append("select Quant,LocationCode from log_Store where MatNo = '");
|
strSQL1.Append(pb.MatNo);
|
strSQL1.Append("' and LingNo = '");
|
strSQL1.Append(pb.LingNo);
|
strSQL1.Append("' and Palno = '");
|
strSQL1.Append(pb.PalletNo);
|
strSQL1.Append("'");
|
strSQL1.Append(" and isnull(Certificate,'') = '" + pb.HeGeZheng + "'");
|
strSQL1.Append(" and isnull(tuno,'') = '" + pb.TuNo + "'");
|
strSQL1.Append(" and isnull(BatchNo,'') = '" + pb.BatchNo + "'");
|
|
DataTable dt1 = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL1);
|
Hashtable ErpInPosition = new Hashtable();
|
ErpInPosition["OrdNo"] = pb.OrdNo;
|
ErpInPosition["MatNo"] = pb.MatNo;
|
ErpInPosition["PalletNo"] = pb.PalletNo;
|
ErpInPosition["AddreNo"] = dt1.Rows[0]["LocationCode"].ToString();
|
ErpInPosition["MatCount"] = pb.MatCount.ToInt();
|
int q = DataFactory.SqlDataBase().InsertByHashtable("ErpInPosition", ErpInPosition);
|
}
|
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
return r;
|
}
|
//空托盘更新库存总表
|
public int UpdateLogStoreMat(string Pos, string PalletNo, int count)
|
{
|
int r = -1;
|
try
|
{
|
DateTime t = DateTime.Now;
|
Hashtable ht = new Hashtable();
|
ht["MatNo"] = PalletNo;
|
ht["Quant"] = count;
|
ht["CreateUser"] = "SuperUser";
|
ht["CreateTime"] = t.ToString("yyyy-MM-dd HH:mm:ss");
|
ht["IsDel"] = 0;
|
|
r = DataFactory.SqlDataBase().InsertByHashtable("log_Stroe_Mat", ht);
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
|
|
|
return r;
|
}
|
//空托盘更新库存明细表
|
public int UpdatePalletLogStore(string Pos, string PalletNo, int count)
|
{
|
int r = -1;
|
try
|
{
|
|
int has = 0;
|
StringBuilder strSQL = new StringBuilder();
|
StringBuilder strSQL2 = new StringBuilder();
|
|
strSQL.Append("select Quant,Palno from log_Store where LocationCode = '" + Pos + "' and Palno='" + PalletNo + "'");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
if (dt.Rows.Count > 0)
|
{
|
has = int.Parse(dt.Rows[0]["Quant"].ToString());
|
has += count;
|
if (has > 0)
|
{
|
strSQL2.Append("update log_Store set Quant = '");
|
strSQL2.Append(has.ToString());
|
strSQL2.Append("' where ");
|
strSQL2.Append(" LocationCode = '");
|
strSQL2.Append(Pos);
|
strSQL2.Append("' and Palno = '");
|
strSQL2.Append(PalletNo);
|
strSQL2.Append("'");
|
r = DataFactory.SqlDataBase().ExecuteBySql(strSQL2);
|
}
|
}
|
else
|
{
|
DateTime t = DateTime.Now;
|
Hashtable ht = new Hashtable();
|
ht["LocationCode"] = Pos;
|
ht["Palno"] = PalletNo;
|
ht["Quant"] = count.ToString();
|
|
r = DataFactory.SqlDataBase().InsertByHashtable("log_Store", ht);
|
}
|
}
|
|
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
return r;
|
}
|
//更新Log_store_mat物料明细表
|
public int UpdateLogStoreMat(string Pos, IList<PalletBind> lst)
|
{
|
int r = -1;
|
try
|
{
|
foreach (PalletBind em in lst)
|
{
|
int has = 0;
|
StringBuilder strSQL = new StringBuilder();
|
StringBuilder strSQL2 = new StringBuilder();
|
|
strSQL.Append("select Quant from Log_Stroe_Mat where MatNo = '");
|
strSQL.Append(em.MatNo);
|
strSQL.Append("'");
|
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
if (dt.Rows.Count > 0)
|
{
|
has = int.Parse(dt.Rows[0]["Quant"].ToString());
|
has += int.Parse(em.MatCount);
|
if (has > 0)
|
{
|
strSQL2.Append("update log_Stroe_Mat set Quant = '");
|
strSQL2.Append(has.ToString());
|
strSQL2.Append("' where ");
|
strSQL2.Append("MatNo = '");
|
strSQL2.Append(em.MatNo);
|
strSQL2.Append("'");
|
r = DataFactory.SqlDataBase().ExecuteBySql(strSQL2);
|
}
|
}
|
else
|
{
|
DateTime t = DateTime.Now;
|
Hashtable ht = new Hashtable();
|
ht["MatNo"] = em.MatNo;
|
ht["Quant"] = em.MatCount;
|
ht["CreateUser"] = "SuperUser";
|
ht["CreateTime"] = t.ToString("yyyy-MM-dd HH:mm:ss");
|
ht["IsDel"] = 0;
|
|
r = DataFactory.SqlDataBase().InsertByHashtable("log_Stroe_Mat", ht);
|
}
|
}
|
|
|
|
}
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
return r;
|
}
|
//更新DeopotsLocation库位表
|
public int UpdateDeopotsLocation(string Pos, string statu)//1空；2合格；3待入；4待出；
|
{
|
int r = -1;
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append("update DepotsLocation set TurnoverDemand = @statu where LocationCode = @Pos");
|
|
SqlParam[] param = new SqlParam[]
|
{
|
new SqlParam("@statu", statu),
|
new SqlParam("@Pos", Pos)
|
};
|
|
r = DataFactory.SqlDataBase().ExecuteBySql(strSQL, param);
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
|
return r;
|
}
|
//ErpIn逻辑状态判断
|
public int UpdateErp(string PalletNo)
|
{
|
int r = 0;
|
try
|
{
|
//获取该托盘上所有物料信息
|
StringBuilder strSQL = new StringBuilder();
|
strSQL.Append("select OrdNo from IPalletBind where PalNo = '");
|
strSQL.Append(PalletNo);
|
strSQL.Append("' and IsDel = 0 Group By OrdNo");
|
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
//遍历所有入库单是否需要关单
|
for (int i = 0; i < dt.Rows.Count; i++)
|
{
|
bool bErpInClose = true;
|
string OrdNo = dt.Rows[i]["OrdNo"].ToString();
|
//该订单下所有物料
|
StringBuilder strSQLErpIn = new StringBuilder();
|
strSQLErpIn.Append("select * from ErpInDetail where OrdNo = '");
|
strSQLErpIn.Append(OrdNo);
|
strSQLErpIn.Append("'");
|
|
DataTable dt2 = DataFactory.SqlDataBase().GetDataTableBySQL(strSQLErpIn);
|
if (dt2 != null)
|
{
|
//该入库单下所有物料是否已经入库
|
for (int j = 0; j < dt2.Rows.Count; j++)
|
{
|
//某一种物料
|
int ErpInCount = int.Parse(dt2.Rows[j]["CurQuant"].ToString());
|
string MatNo = dt2.Rows[j]["MatNo"].ToString();
|
//该入库单下该物料已经入库数量
|
StringBuilder strGetAllMatCount = new StringBuilder();
|
strGetAllMatCount.Append("select * from IPalletBind where OrdNo = '");
|
strGetAllMatCount.Append(OrdNo);
|
strGetAllMatCount.Append("' and MatGuid = '");
|
strGetAllMatCount.Append(MatNo);
|
strGetAllMatCount.Append("' and Statu = '03'");
|
|
DataTable dtAll = DataFactory.SqlDataBase().GetDataTableBySQL(strGetAllMatCount);
|
if (dtAll != null)
|
{
|
int sum = 0;
|
for (int m = 0; m < dtAll.Rows.Count; m++)
|
{
|
sum += int.Parse(dtAll.Rows[m]["MatCount"].ToString());
|
}
|
if (sum < ErpInCount)
|
{
|
bErpInClose = false;
|
}
|
}
|
|
}
|
}
|
if (bErpInClose)
|
{
|
//入库单执行完成，
|
UpdateErpInStatus(OrdNo, "03");
|
DelPalletBind(OrdNo);
|
}
|
}
|
}
|
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
return r;
|
}
|
//更新Erpin入库单表
|
public int UpdateErpInStatus(string OrdNo, string status)
|
{
|
int r = 0;
|
try
|
{
|
StringBuilder strUpdateErpIn = new StringBuilder();
|
strUpdateErpIn.Append($"update Erp_in set Statu = '{status}',CompletionTime=GETDATE() where OrdNo = '{OrdNo}'");
|
r = DataFactory.SqlDataBase().ExecuteBySql(strUpdateErpIn);
|
}
|
catch
|
{
|
r = -1;
|
}
|
return r;
|
}
|
|
public bool UpdateErpInStatu(string PalletNo, string status)
|
{
|
bool bl = false;
|
try
|
{
|
// 根据托盘码获取关联入库单号
|
StringBuilder sbstr = new StringBuilder();
|
sbstr.Append("select distinct OrdNo from IPalletBind where Palno = '" + PalletNo + "' and Statu = '02' and IsDel = '0'");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sbstr);
|
if (dt != null)
|
{
|
sbstr.Clear();
|
// 更改所有入库单，单据状态
|
foreach (DataRow row in dt.Rows)
|
{
|
sbstr.Append("Update Erp_in set Statu = '" + status);
|
sbstr.Append("' where OrdNo = '" + row["OrdNo"].ToString() + "';");
|
}
|
|
int rowCout = DataFactory.SqlDataBase().ExecuteBySql(sbstr);
|
if (rowCout > 0)
|
{
|
bl = true;
|
}
|
}
|
}
|
catch
|
{
|
bl = false;
|
}
|
|
return bl;
|
}
|
|
//删除托盘绑定
|
public int DelPalletBind(string OrdNo)
|
{
|
int r = 0;
|
try
|
{
|
//获取该订单下所有托盘
|
StringBuilder strAllPallet = new StringBuilder();
|
strAllPallet.Append("select * from IPalletBind where OrdNo = '");
|
strAllPallet.Append(OrdNo);
|
strAllPallet.Append("' and Statu = '03' and IsDel=0 ");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strAllPallet);
|
if (dt != null)
|
{
|
//该订单下的所有托盘
|
for (int i = 0; i < dt.Rows.Count; i++)
|
{
|
bool delFlag = true;
|
string PalletNo = dt.Rows[i]["PalNo"].ToString();
|
StringBuilder strAllOrd = new StringBuilder();
|
strAllOrd.Append("select * from IPalletBind where PalNo = '");
|
strAllOrd.Append(PalletNo);
|
strAllOrd.Append("' and Statu = '03' and IsDel=0");
|
DataTable dt2 = DataFactory.SqlDataBase().GetDataTableBySQL(strAllOrd);
|
if (dt2 != null)
|
{
|
//该托盘下的所有订单
|
for (int j = 0; j < dt2.Rows.Count; j++)
|
{
|
string erpOrdNo = dt2.Rows[j]["OrdNo"].ToString();
|
StringBuilder strOrdStatu = new StringBuilder();
|
strOrdStatu.Append("select * from Erp_in where OrdNo = '");
|
strOrdStatu.Append(erpOrdNo);
|
strOrdStatu.Append("'");
|
//所有订单完成，才能删除
|
DataTable dt3 = DataFactory.SqlDataBase().GetDataTableBySQL(strOrdStatu);
|
if (dt3 != null)
|
{
|
//订单状态，有一个订单没完成，就不能删除该托盘
|
for (int k = 0; k < dt3.Rows.Count; k++)
|
{
|
string Statu = dt3.Rows[k]["Statu"].ToString();
|
if (Statu != "03")
|
{
|
delFlag = false;
|
}
|
}
|
}
|
if (delFlag)
|
{
|
//改托盘上所有订单都关闭，则关闭
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append("update IPalletBind set IsDel = 1 where OrdNo = '");
|
strSQL.Append(erpOrdNo);
|
strSQL.Append("'and PalNo = '");
|
strSQL.Append(PalletNo);
|
strSQL.Append("' and IsDel=0");
|
|
r = DataFactory.SqlDataBase().ExecuteBySql(strSQL);
|
}
|
}
|
}
|
|
}
|
}
|
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
return r;
|
}
|
//根据物料删除托盘绑定
|
public int DelPalletBind(string OrdNo, string MatNo)
|
{
|
int r = 0;
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append("update IPalletBind set IsDel = 1 where OrdNo = '");
|
strSQL.Append(OrdNo);
|
strSQL.Append("' and MatNo = '");
|
strSQL.Append(MatNo);
|
strSQL.Append("'");
|
|
r = DataFactory.SqlDataBase().ExecuteBySql(strSQL);
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
return r;
|
}
|
//根据入库单更新托盘绑定状态
|
public int UpdatePalletBindStatus(string PalletNo, string taskId, string status)
|
{
|
int r = 0;
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append("update IPalletBind set Statu = '");
|
strSQL.Append(status);
|
strSQL.Append("' where Palno = '");
|
strSQL.Append(PalletNo);
|
strSQL.Append("' and IsDel = '0' and Statu = '02' ;");
|
// liudl 注释 存在一个托盘多个入库单情况
|
//strSQL.Append("' and OrdNo = '")
|
//strSQL.Append(taskId);
|
//strSQL.Append("'");
|
|
r = DataFactory.SqlDataBase().ExecuteBySql(strSQL);
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
return r;
|
}
|
//更新PallletBind托盘绑定表状态
|
public int UpdatePalletBind(string PalletNo, int status)
|
{
|
int r = -1;
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append($"update IPalletBind set Statu = '0{status}' where Palno = '{PalletNo}' and Statu='01' and IsDel = 0");
|
r = DataFactory.SqlDataBase().ExecuteBySql(strSQL);
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
|
return r;
|
}
|
|
public int GetPalletNoAndOutPosByInPos(string InPos, ref string OutPos, ref string PalletNo)
|
{
|
int pai = 0, lie = 0, ceng = 0;
|
SplitPosCode(InPos, ref pai, ref lie, ref ceng);
|
|
StringBuilder strSQL = new StringBuilder();
|
if (pai == 1)
|
{
|
strSQL.Append("select top(1) * from View_GetEmptyPos where LRow = 2 and LColumn = ");
|
strSQL.Append(lie);
|
strSQL.Append(" and LLayer = ");
|
strSQL.Append(ceng);
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
if (dt.Rows.Count > 0)
|
{
|
DepotsLocation dl = new DepotsLocation();
|
dl = (DepotsLocation)ModelConvertHelper<DepotsLocation>.DataTableToModel(dt);
|
OutPos = dl.LocationCode;
|
}
|
}
|
}
|
if (pai == 4)
|
{
|
strSQL.Append("select top(1) * from View_GetEmptyPos where LRow = 3 and LColumn = ");
|
strSQL.Append(lie);
|
strSQL.Append(" and LLayer = ");
|
strSQL.Append(ceng);
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
if (dt.Rows.Count > 0)
|
{
|
DepotsLocation dl = new DepotsLocation();
|
dl = (DepotsLocation)ModelConvertHelper<DepotsLocation>.DataTableToModel(dt);
|
OutPos = dl.LocationCode;
|
}
|
}
|
}
|
StringBuilder strSQLPalletNo = new StringBuilder();
|
strSQLPalletNo.Append("select top(1) * from Log_Store where Addre = '");
|
strSQLPalletNo.Append(OutPos);
|
strSQLPalletNo.Append("'");
|
DataTable dt2 = DataFactory.SqlDataBase().GetDataTableBySQL(strSQLPalletNo);
|
if (dt2 != null)
|
{
|
if (dt2.Rows.Count > 0)
|
PalletNo = dt2.Rows[0]["Palno"].ToString();
|
}
|
|
return 0;
|
}
|
|
public int DelPalletEmptyIn(string PalletNo)
|
{
|
int ir = 0;
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append("Update IPalletEmptyIn set IsDel = 1 where IsDel = 0 and PalNo = '");
|
strSQL.Append(PalletNo);
|
strSQL.Append("'");
|
|
ir = DataFactory.SqlDataBase().ExecuteBySql(strSQL);
|
}
|
catch (Exception ex)
|
{
|
ir = -1;
|
}
|
return ir;
|
}
|
|
public int UpdatePalletEmptyInStatus(string PalletNo, string status)
|
{
|
int ir = 0;
|
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append("Update IPalletEmptyIn set Statu = '");
|
strSQL.Append(status);
|
strSQL.Append("' where IsDel = 0 and PalNo = '");
|
strSQL.Append(PalletNo);
|
strSQL.Append("'");
|
|
ir = DataFactory.SqlDataBase().ExecuteBySql(strSQL);
|
}
|
catch (Exception ex)
|
{
|
ir = -1;
|
}
|
return ir;
|
}
|
|
public int GetPalletEmptyCount(string PalletNo, ref int count)
|
{
|
int r = -1;
|
count = 0;
|
try
|
{
|
StringBuilder strSQL = new StringBuilder();
|
|
strSQL.Append("select * from IPalletEmptyIn where PalNo = '");
|
strSQL.Append(PalletNo);
|
strSQL.Append("' and Statu = '02'");
|
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
|
if (dt != null)
|
{
|
if (dt.Rows.Count > 0)
|
{
|
count = int.Parse(dt.Rows[0]["PalCount"].ToString());
|
r = 0;
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
return r;
|
}
|
|
public int GetOutPosParamByInnerPos(string Pos, ref DepotsLocation dl)
|
{
|
int r = -1;
|
try
|
{
|
int pai = 0, lie = 0, ceng = 0;
|
r = SplitPosCode(Pos, ref pai, ref lie, ref ceng);
|
StringBuilder strSQL = new StringBuilder();
|
strSQL.Append("select tb1.*,tb2.Palno from DepotsLocation as tb1 ");
|
strSQL.Append("left join log_Store as tb2 on tb1.LocationCode = tb2.Addre ");
|
strSQL.Append("where LRow = ");
|
if (pai == 1)
|
strSQL.Append(2);
|
else
|
strSQL.Append(3);
|
strSQL.Append(" and LColumn = ");
|
strSQL.Append(lie);
|
strSQL.Append(" and LLayer = ");
|
strSQL.Append(ceng);
|
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSQL);
|
if (dt != null)
|
{
|
IList ls = new List<DepotsLocation>();
|
ls = (IList)ModelConvertHelper<DepotsLocation>.DataTableToModel(dt);
|
dl = (DepotsLocation)ls[0];
|
r = 0;
|
}
|
}
|
catch (Exception ex)
|
{
|
r = -1;
|
}
|
|
return r;
|
}
|
|
public int InsertIPalletReturn(string PalletNo, string Address)
|
{
|
int r = -1;
|
if (string.IsNullOrEmpty(PalletNo) || string.IsNullOrEmpty(Address))
|
{
|
return -1;
|
}
|
try
|
{
|
string[] para = new string[] { PalletNo };
|
int ie = DataFactory.SqlDataBase().IsExist("IPalletReturn", "PalletNo", para);
|
if (ie > 0)
|
{
|
Hashtable ht = new Hashtable();
|
ht["Address"] = Address;
|
ie = DataFactory.SqlDataBase().UpdateByHashtable("IPalletReturn", "PalletNo", PalletNo, ht);
|
}
|
else
|
{
|
Hashtable ht = new Hashtable();
|
ht["PalletNo"] = PalletNo;
|
ht["Address"] = Address;
|
ie = DataFactory.SqlDataBase().InsertByHashtable("IPalletReturn", ht);
|
}
|
if (ie > 0)
|
r = 0;
|
}
|
catch (Exception)
|
{
|
r = -1;
|
}
|
|
return r;
|
}
|
|
#region 空取异常处理
|
/// <summary>
|
/// 出库单空取异常处理
|
/// </summary>
|
/// <param name="cmd"></param>
|
/// <returns></returns>
|
public bool SetErpOut(ErpInCmd cmd)
|
{
|
bool bl = false;
|
try
|
{
|
// 将该出库单明细表中该托盘码对应的物料备注改空取
|
StringBuilder sqlString = new StringBuilder();
|
sqlString.Append("update ErpOutDetail set Demo = '托盘空取异常' ");
|
sqlString.Append("where OrdNo = '" + cmd.TaskID + "' and Palno = '" + cmd.Palno + "'");
|
sqlString.Append(" and Addre = '" + cmd.OldAddre + "';");
|
int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
if (rowCount <= 0)
|
{
|
// 盘库异常在这里返回 不执行。
|
bl = false;
|
return bl;
|
}
|
// 将该出库单备注改为: 空取异常请进行盘库操作 (空托出库 = 2 出库单出库 = 1)
|
sqlString.Clear();
|
sqlString.Append("update Erp_Out SET Demo = '空取异常请进行盘库操作' where IsDel = '0' and Ordno = '" + cmd.TaskID + "'; ");
|
rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
if (rowCount <= 0)
|
{
|
bl = false;
|
return bl;
|
}
|
// 处理出库单状态并删除该指令
|
this.UpdateOut(cmd.TaskID, cmd.Palno, cmd.OldAddre);
|
|
// 库位状态应改位空托盘
|
sqlString.Clear();
|
sqlString.Append("update DepotsLocation set TurnoverDemand = '01' where LocationCode = '" + cmd.OldAddre + "';");
|
rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
if (rowCount <= 0)
|
{
|
bl = false;
|
return bl;
|
}
|
|
return true;
|
}
|
catch (Exception ex)
|
{
|
logger.ErrorException("出库单空取异常处理：", ex);
|
return bl;
|
}
|
}
|
|
/// <summary>
|
/// 移库空取异常处理
|
/// </summary>
|
/// <param name="cmd"></param>
|
/// <param name="statu"></param>
|
/// <returns></returns>
|
public bool SetMove(ErpInCmd cmd)
|
{
|
bool bl = false;
|
try
|
{
|
// 将原库位和目标库位置为空货位，库位信息备注置为空取异常 删除指令
|
StringBuilder sqlString = new StringBuilder();
|
sqlString.Append("update DepotsLocation set TurnoverDemand = '01',Demo= '移库空取异常，请进行盘库。'");
|
sqlString.Append("where LocationCode = '" + cmd.OldAddre + "';");
|
int rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
if (rowCount <= 0)
|
{
|
bl = false;
|
return bl;
|
}
|
|
sqlString.Clear();
|
sqlString.Append("update DepotsLocation set TurnoverDemand = '01' ");
|
sqlString.Append("where LocationCode = '" + cmd.NowAddre + "';");
|
rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
if (rowCount <= 0)
|
{
|
bl = false;
|
return bl;
|
}
|
|
// 删除指令保证后续指令继续进行
|
sqlString.Clear();
|
sqlString.Append("Update WH_CMD set isdel = '1' where CMDid = '" + cmd.CMDID.ToString() + "';");
|
rowCount = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
if (rowCount <= 0)
|
{
|
bl = false;
|
return bl;
|
}
|
|
return true;
|
}
|
catch (Exception ex)
|
{
|
logger.ErrorException("移库空取异常处理：", ex);
|
return bl;
|
}
|
}
|
#endregion
|
}
|
|
public class Order
|
{
|
public string TaskID;
|
public string NumberNo;
|
public string Palno;
|
public string CMDType;
|
public string OldAddre;
|
public string NowAddre;
|
public int CMDStatu;
|
public string CreateUser;
|
public DateTime CreateTime;
|
public string Demo;
|
public int IsDel;
|
public string guid;
|
}
|
}
|
