using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Text;
|
using Common;
|
using Model;
|
|
namespace BLL
|
{
|
public class DALGoodsPos : IDALGoodsPos
|
{
|
public bool Add(GoodsPos model, string loginUser)
|
{
|
bool result = false;
|
try
|
{
|
Hashtable ht = new Hashtable();
|
|
ht["Addre"] = "'" + model.Area + model.pai.PadLeft(2,'0') + model.lie.PadLeft(2, '0') + model.ceng.PadLeft(2, '0') + "'";
|
ht["pai"] = "'" + model.pai.PadLeft(2, '0') + "'";
|
ht["lie"] = "'" + model.lie.PadLeft(2, '0') + "'";
|
ht["ceng"] = "'" + model.ceng.PadLeft(2, '0') + "'";
|
ht["Property"] = "'" + model.property + "'";
|
ht["ALock"] = "'" + model.ALock + "'";
|
ht["StorageAraeNo"] = "'" + model.Area + "'";
|
ht["Demo"] = "'" + model.Demo + "'";
|
|
ht["guid"] = "NEWID()";
|
|
int _ret = DataFactory.SqlDataBase().InsertByHashtableNullParam("GoodsPos", ht);
|
|
if (_ret == 1) result = true;
|
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public bool UpdateLock(string[] Addre, string ALock)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("GoodsPos", "Addre", Addre);
|
if (dt >= Addre.Length)
|
{
|
Hashtable ht = new Hashtable();
|
string str = "";
|
if (ALock == "Lock") str = "NL";
|
if (ALock == "UnLock") str = "N";
|
ht["ALock"] = string.IsNullOrEmpty(ALock) ? "'N'" : "'" + str + "'";
|
|
int _ret = DataFactory.SqlDataBase().UpdateByHashtable("GoodsPos", "Addre", Addre ,ht);
|
if (_ret >= Addre.Length) result = true;
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public bool UpdateProperty(string[] Addre, string Property)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("GoodsPos", "Addre", Addre);
|
if (dt >= Addre.Length)
|
{
|
Hashtable ht = new Hashtable();
|
string str = "";
|
//if (ALock == "Lock") str = "NL";
|
//if (ALock == "UnLock") str = "N";
|
ht["Property"] = string.IsNullOrEmpty(Property) ? "'N'" : "'" + Property + "'";
|
|
int _ret = DataFactory.SqlDataBase().UpdateByHashtable("GoodsPos", "Addre", Addre, ht);
|
if (_ret >= Addre.Length) result = true;
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public bool BatchDelete(string[] MatNo)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("Material", "MatNo", MatNo);
|
if (dt >= MatNo.Length)
|
{
|
int _ret = DataFactory.SqlDataBase().BatchDeleteData("Material", "MatNo", MatNo);
|
if (_ret > MatNo.Length) result = true;
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public bool Delete(string MatNo)
|
{
|
throw new NotImplementedException();
|
}
|
|
public DataTable GetDataTable(string[] strWhere)
|
{
|
DataTable dt = null;
|
try
|
{
|
int index = 0;
|
string str = "@MatNo" + index;
|
SqlParam[] param = new SqlParam[strWhere.Length];
|
StringBuilder sql = new StringBuilder();
|
sql.Append("Select MatNo as 物料编码,MatName as 物料名称,packFormat as 包装规格,PackQuant as 包装量,UnitFrist as 计量单位(主),UnitSec as 计量单位(辅),Matweighttype as 物料轻重,storecondition as 储存环境,usefreq as 频率,sizeNum as 包装尺寸 FROM MatNo where MatNo in (");
|
|
for (int i = 0; i < param.Length - 1; i++)
|
{
|
string obj2 = strWhere[i];
|
str = "@MatNo" + index;
|
sql.Append(str).Append(",");
|
param[index] = new SqlParam(str, obj2);
|
index++;
|
}
|
str = "@MatNo" + index;
|
sql.Append(str);
|
param[index] = new SqlParam(str, strWhere[index]);
|
sql.Append(")");
|
|
dt = DataFactory.SqlDataBase().GetDataTableBySQL(sql, param, "");
|
|
return dt;
|
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public DataTable GetDataTable(int PageSize, int PageIndex, string strWhere)
|
{
|
throw new NotImplementedException();
|
}
|
//GetNullList
|
|
|
/// <summary>
|
/// 查询库位
|
/// </summary>
|
/// <param name="Json"></param>
|
/// <param name="pageInfo"></param>
|
/// <returns>库位集合</returns>
|
public IList<GoodsPos> GetList(AjaxGoodsPosList Json, ref PageInfo pageInfo)
|
{
|
try
|
{
|
|
IList<GoodsPos> list = new List<GoodsPos>();
|
StringBuilder strSql = new StringBuilder();
|
List<SqlParam> para = new List<SqlParam>();
|
strSql.Append("Select * from view_GoodsPos ");
|
|
|
if (Json.Addre != null && Json.Addre != "")
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("addre like '%"+Json.Addre+"%' ");
|
para.Add(new SqlParam("@addre", Json.Addre));
|
}
|
|
if (Json.pai != null && Json.pai != "")
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("pai = @pai ");
|
para.Add(new SqlParam("@pai", Json.pai.PadLeft(2,'0')));
|
}
|
|
if (Json.lie != null && Json.lie != "")
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("lie = @lie ");
|
para.Add(new SqlParam("@lie", Json.lie.PadLeft(2, '0')));
|
}
|
|
if (Json.ceng != null && Json.ceng != "")
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("ceng = @ceng ");
|
para.Add(new SqlParam("@ceng", Json.ceng.PadLeft(2, '0')));
|
}
|
|
if (Json.Area != null && Json.Area != "")
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("StorageAraeNo = '" + Json.Area + "' ");
|
para.Add(new SqlParam("@Area", Json.Area));
|
}
|
|
if (Json.statu != null && Json.statu != "")
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("statuNo = '"+ Json.statu + "' ");
|
para.Add(new SqlParam("@statu", Json.statu));
|
}
|
|
if (Json.property != null && Json.property != "")
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("propertyNo = '"+ Json.property + "' ");
|
para.Add(new SqlParam("@property", Json.property));
|
}
|
|
if (Json.ALock != null && Json.ALock != "")
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("ALockNo = '"+ Json.ALock + "' ");
|
para.Add(new SqlParam("@ALock", Json.ALock));
|
}
|
|
|
SqlParam[] param = null;
|
if (para != null)
|
param = para.ToArray();
|
|
|
DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), param, "Id", "ASC", ref pageInfo);
|
|
list = ModelConvertHelper<GoodsPos>.DataTableToModel(dt);
|
|
return list;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
/// <summary>
|
/// 获取库位信息
|
/// </summary>
|
/// <param name="addre"></param>
|
/// <returns></returns>
|
public GoodsPos GetModel(string addre)
|
{
|
try
|
{
|
GoodsPos us = null;
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("select * from GoodsPos where ");
|
strSql.Append("addre = '"+ addre + "'");
|
|
SqlParam[] para = new SqlParam[]
|
{
|
new SqlParam("@addre", "'" + addre + "'"),
|
};
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, para);
|
us = ModelConvertHelper<GoodsPos>.ReaderToModel(dt);
|
|
return us;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public bool IsExist(string name, string value)
|
{
|
bool result = false;
|
try
|
{
|
string[] para = new string[] { value };
|
int dt = DataFactory.SqlDataBase().IsExist("Material", name, para);
|
if (dt > 0) result = true;
|
return result;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
public bool IsExist(Hashtable ht)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("Material", ht);
|
if (dt > 0) result = true;
|
return result;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
/// <summary>
|
/// 更新库位状态
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool Update(GoodsPos model)
|
{
|
bool result = false;
|
try
|
{
|
StringBuilder sbstr = new StringBuilder();
|
sbstr.Append("update GoodsPos set statu= '"+ model.statu+ "',");
|
sbstr.Append("Property= '" + model.property+ "',ALock='"+ model.ALock+ "',");
|
sbstr.Append( "Demo='" + model.Demo+ "' ");
|
sbstr.Append("where Addre = '" + model.Area + "';");
|
|
// 数据库交互
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sbstr);
|
if (_ret == 1)
|
{
|
result = true;
|
}
|
|
return result;
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
|
public bool AnditMat(string[] MatNo, string AuditModel)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("Material", "MatNo", MatNo);
|
if (dt >= MatNo.Length)
|
{
|
Hashtable ht = new Hashtable();
|
|
ht["AuditFlag"] = string.IsNullOrEmpty(AuditModel) ? "'N'" :"'" + AuditModel + "'";
|
|
int _ret = DataFactory.SqlDataBase().UpdateByHashtable("Material", "MatNo", MatNo, ht);
|
|
if (_ret >= MatNo.Length) result = true;
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public IList<GoodsPos> GetPaiList(string StorageNO)
|
{
|
try
|
{
|
IList<GoodsPos> ls = new List<GoodsPos>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select distinct pai,cast( pai as decimal) as ord from goodsPos");
|
if (StorageNO != string.Empty)
|
{
|
strSql.Append(" where StorageAraeNo = '" + StorageNO + "'");
|
}
|
strSql.Append(" order by cast( pai as decimal);");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
ls = ModelConvertHelper<GoodsPos>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public IList<GoodsPos> GetLieList(string StorageNO)
|
{
|
try
|
{
|
IList<GoodsPos> ls = new List<GoodsPos>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select distinct lie,cast( lie as decimal) as ord from goodsPos");
|
if (StorageNO != string.Empty)
|
{
|
strSql.Append(" where StorageAraeNo = '" + StorageNO + "'");
|
}
|
strSql.Append(" order by cast( lie as decimal);");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
ls = ModelConvertHelper<GoodsPos>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public IList<GoodsPos> GetCengList(string StorageNO)
|
{
|
try
|
{
|
IList<GoodsPos> ls = new List<GoodsPos>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select distinct ceng,cast( ceng as decimal) as ord from goodsPos");
|
if (StorageNO != string.Empty)
|
{
|
strSql.Append(" where StorageAraeNo = '" + StorageNO + "'");
|
}
|
strSql.Append(" order by cast( ceng as decimal);");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
ls = ModelConvertHelper<GoodsPos>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public IList<GoodsProperty> GetPropertyList()
|
{
|
try
|
{
|
IList<GoodsProperty> ls = new List<GoodsProperty>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select PropertyNo,PropertyName from log_Property ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
ls = ModelConvertHelper<GoodsProperty>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public IList<GoodsStatu> GetStatuList()
|
{
|
try
|
{
|
IList<GoodsStatu> ls = new List<GoodsStatu>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select StatuNo,StatuName from log_Statu ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
ls = ModelConvertHelper<GoodsStatu>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public IList<GoodsALock> GetALockList()
|
{
|
try
|
{
|
IList<GoodsALock> ls = new List<GoodsALock>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select AlockNo,AlockName from log_ALock ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
ls = ModelConvertHelper<GoodsALock>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
public IList<GoodsArea> GetAreaList()
|
{
|
try
|
{
|
IList<GoodsArea> ls = new List<GoodsArea>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select StorageNo as AreaNo,StorageName as AreaName from StorageArea ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
ls = ModelConvertHelper<GoodsArea>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
public IList<GoodsPos> GetAddreList(string AreaNo)
|
{
|
try
|
{
|
IList<GoodsPos> ls = new List<GoodsPos>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select distinct Addre from goodsPos");
|
if (AreaNo != string.Empty)
|
{
|
strSql.Append(" where StorageAraeNo = '" + AreaNo + "'");
|
}
|
else
|
{
|
strSql.Append(" where 1=0");
|
}
|
strSql.Append(" order by addre;");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
ls = ModelConvertHelper<GoodsPos>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
}
|
}
|
