using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using Model;
|
using Common;
|
using System.Data;
|
|
namespace BLL
|
{
|
public class DALErpInDetail : IDALErpInDetail
|
{
|
public IList<ErpDetails> GetList(AjaxErpInList models)
|
{
|
try
|
{
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("select * from View_ErpInDetail where Ordno ='" + models.OrdNo);
|
strSql.Append("' and DepartGuid = '" + models.DepartGuid + "' ");
|
strSql.Append("order by [dbo].PadLeft(PageNo,'0',3) asc ");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);
|
|
return ModelConvertHelper<ErpDetails>.DataTableToModel(dt);
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
|
public IList<ErpMat> GetList(string OrdNo)
|
{
|
try
|
{
|
IList<ErpMat> ls = new List<ErpMat>();
|
List<SqlParam> para = new List<SqlParam>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select * from View_ErpInDetail ");
|
|
|
if (!string.IsNullOrEmpty(OrdNo))
|
{
|
if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
|
strSql.Append("OrdNo = @OrdNo ");
|
para.Add(new SqlParam("@OrdNo", OrdNo));
|
}
|
|
|
SqlParam[] param = null;
|
if (para != null)
|
param = para.ToArray();
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, param);
|
ls = ModelConvertHelper<ErpMat>.DataReaderToModel(dt);
|
|
return ls;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public IList<ErpDetails> GetList(AjaxErpInList models, ref PageInfo pageInfo)
|
{
|
try
|
{
|
IList<ErpDetails> ls = new List<ErpDetails>();
|
List<SqlParam> para = new List<SqlParam>();
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select * from View_ErpInDetail where ");
|
strSql.Append("OrdNo = @OrdNo and DepartGuid = @DepartGuid ");
|
para.Add(new SqlParam("@OrdNo", models.OrdNo));
|
para.Add(new SqlParam("@DepartGuid", models.DepartGuid));
|
|
SqlParam[] param = para.ToArray();
|
DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(),param, "[dbo].PadLeft(PageNo,'0',3)", "asc" ,ref pageInfo);
|
ls = ModelConvertHelper<ErpDetails>.DataTableToModel(dt);
|
|
return ls;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
public IList<ErpMat> Getposition(string ordNo, string matNo)
|
{
|
try
|
{
|
IList<ErpMat> ls = new List<ErpMat>();
|
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("Select * from ErpInPosition where OrdNo='"+ordNo+ "' and MatNo='"+matNo+"'");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);
|
ls = ModelConvertHelper<ErpMat>.DataTableToModel(dt);
|
|
return ls;
|
}
|
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("Roles", name, para);
|
if (dt > 0) result = true;
|
return result;
|
}
|
catch
|
{
|
return result;
|
}
|
|
}
|
|
public DataTable GetDataTable(string[] strWhere)
|
{
|
DataTable dt = null;
|
try
|
{
|
int index = 0;
|
string str = "@RoleNum" + index;
|
SqlParam[] param = new SqlParam[strWhere.Length];
|
StringBuilder sql = new StringBuilder();
|
sql.Append("Select RoleNum as 角色编号, RoleName as 角色名,CreatUser as 创建人,CreatTime as 创建时间,UpdateUser as 更新人,UpdateTime as 更新时间,Demo as 备注 FROM View_GetRoles where RoleNum in (");
|
|
for (int i = 0; i < param.Length - 1; i++)
|
{
|
string obj2 = strWhere[i];
|
str = "@RoleNum" + index;
|
sql.Append(str).Append(",");
|
param[index] = new SqlParam(str, obj2);
|
index++;
|
}
|
str = "@RoleNum" + 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 bool Delete(List<ErpMat> EMats)
|
{
|
bool result = false;
|
try
|
{
|
foreach (ErpMat tm in EMats)
|
{
|
int n = DataFactory.SqlDataBase().DeleteData("ErpInDetail", "OrdNo", tm.OrdNo);
|
if (n >= 0)
|
result = true;
|
}
|
//foreach (ErpMat tm in EMats)
|
//{
|
// List<SqlParam> para = new List<SqlParam>();
|
// StringBuilder strSql = new StringBuilder();
|
// StringBuilder sp1 = new StringBuilder();
|
// StringBuilder sp2 = new StringBuilder();
|
|
// strSql.Append(" DELETE FROM ErpInDetail where OrdNo = @OrdNo");
|
|
// SqlParam[] param = new SqlParam[] {
|
|
// new SqlParam("@OrdNo", tm.OrdNo)
|
// };
|
|
// int n = DataFactory.SqlDataBase().ExecuteBySql(strSql, param);
|
// if (n < 0)
|
// return false;
|
//}
|
//try
|
//{
|
////向库存明细表插入更新数据
|
//for (int j = 0; j < EMats.Count; j++)
|
//{
|
// int sum = 0;
|
// StringBuilder mql = new StringBuilder();
|
// mql.Append("select CurQuant from ErpInDetail where OrdNo='"+EMats[j].OrdNo+"' and MatNo='" + EMats[j].MatNo + "' and addreNo='" + EMats[j].addreNo + "' and PalNo='" + EMats[j].Palno + "'");
|
// DataTable dl = DataFactory.SqlDataBase().GetDataTableBySQL(mql);
|
// if (dl.Rows.Count > 0)
|
// {
|
// try
|
// {
|
// sum = int.Parse(EMats[j].CurQuant.ToString()) - int.Parse(dl.Rows[0]["CurQuant"].ToString());
|
// }
|
// catch (Exception)
|
// {
|
|
// sum = 0;
|
// }
|
|
// }
|
// else
|
// {
|
// sum = int.Parse(EMats[j].CurQuant.ToString());
|
// }
|
// StringBuilder select1 = new StringBuilder();
|
// select1.Append("select Quant from log_Store where MatNo='" + EMats[j].MatNo + "' and Palno='" + EMats[j].Palno + "'and Addre='" + EMats[j].addreNo + "' ");
|
// DataTable slstock = DataFactory.SqlDataBase().GetDataTableBySQL(select1);
|
// if (slstock.Rows.Count > 0)
|
// {
|
// StringBuilder select2 = new StringBuilder();
|
// sum = int.Parse(slstock.Rows[0]["Quant"].ToString()) + sum;
|
// select2.Append(" update log_Store set Quant='" + sum + "' where Addre='" + EMats[j].addreNo + "' and MatNo='" + EMats[j].MatNo + "' and Palno='" + EMats[j].Palno + "' ");
|
// DataFactory.SqlDataBase().ExecuteBySql(select2);
|
// }
|
// else
|
// {
|
// StringBuilder select2 = new StringBuilder();
|
// select2.Append("insert into log_Store (Addre,Palno,MatNo,Quant)values('" + EMats[j].addreNo + "','" + EMats[j].Palno + "','" + EMats[j].MatNo + "','" + EMats[j].CurQuant + "')");
|
// int ad = DataFactory.SqlDataBase().ExecuteBySql(select2);
|
// }
|
//}
|
////向库存总表插入更新数据
|
//for (int j = 0; j < EMats.Count; j++)
|
//{
|
// int sum = 0;
|
// StringBuilder mql = new StringBuilder();
|
// mql.Append("select CurQuant from ErpInDetail where OrdNo='" + EMats[j].OrdNo + "' and MatNo='" + EMats[j].MatNo + "' and addreNo='" + EMats[j].addreNo + "' and PalNo='" + EMats[j].Palno + "'");
|
// DataTable dl = DataFactory.SqlDataBase().GetDataTableBySQL(mql);
|
// if (dl.Rows.Count > 0)
|
// {
|
// try
|
// {
|
// sum = int.Parse(EMats[j].CurQuant.ToString()) - int.Parse(dl.Rows[0]["CurQuant"].ToString());
|
// }
|
// catch (Exception)
|
// {
|
|
// sum = 0;
|
// }
|
|
// }
|
// else
|
// {
|
// sum = int.Parse(EMats[j].CurQuant.ToString());
|
// }
|
// StringBuilder hql = new StringBuilder();
|
// hql.Append("select * from Log_Stroe_Mat where MatNo='" + EMats[j].MatNo + "'");
|
// DataTable dd = DataFactory.SqlDataBase().GetDataTableBySQL(hql);
|
// if (dd.Rows.Count > 0)
|
// {
|
// StringBuilder hql2 = new StringBuilder();
|
// int quant = int.Parse(dd.Rows[0]["Quant"].ToString()) + sum;
|
// hql2.Append("Update Log_Stroe_Mat set Quant='" + quant + "' where MatNo='" + EMats[j].MatNo + "'");
|
// DataFactory.SqlDataBase().ExecuteBySql(hql2);
|
// }
|
// else
|
// {
|
// StringBuilder hql2 = new StringBuilder();
|
// hql2.Append("insert into Log_Stroe_Mat (MatNo,Quant)values('" + EMats[j].MatNo + "','" + EMats[j].CurQuant + "')");
|
// DataFactory.SqlDataBase().ExecuteBySql(hql2);
|
// }
|
|
//}
|
//int dt = DataFactory.SqlDataBase().ExecuteBySql(strSql, param);
|
// result = true;
|
//}
|
//catch
|
//{
|
// result = false;
|
//}
|
|
|
return result;
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public DataTable GetPrintData(string OrdNo)
|
{
|
DataTable ds = null;
|
try
|
{
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append(" Select * from View_ErpInDetail where ");
|
strSql.Append("OrdNo = @OrdNo ");
|
|
SqlParam[] para = new SqlParam[]
|
{
|
new SqlParam("@OrdNo", OrdNo),
|
};
|
strSql.Append(" order by [dbo].PadLeft(PageNo,'0',3) asc;");
|
|
ds = DataFactory.SqlDataBase().GetDataTableBySQL(strSql, para, "table2");
|
|
return ds;
|
}
|
catch
|
{
|
return ds;
|
}
|
}
|
}
|
}
|
