using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Common;
|
using Model;
|
using Model;
|
|
namespace BLL.DAL
|
{
|
public class DAL_ConveyorInfo
|
{
|
public IList<GetWCSConveyorInfo> GetList(AjaxConveyorInfoList Json, ref PageInfo pageInfo)
|
{
|
try
|
{
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("select a.*,b.userName as CreateUserName,c.userName as UpdateUserName from WCSConveyorInfo a left join UserInfo b on a.CreateUser = b.Id left join UserInfo c on a.UpdateUser = c.Id where a.IsDel = '0' ");
|
|
if (string.IsNullOrWhiteSpace(Json.SkuType) && string.IsNullOrWhiteSpace(Json.Conveyor) && string.IsNullOrWhiteSpace(Json.LotNo) && string.IsNullOrWhiteSpace(Json.IsEndLot) && string.IsNullOrWhiteSpace(Json.Status))
|
{
|
strSql.Append(" and IsEndLot = '0'");
|
}
|
|
if (!string.IsNullOrWhiteSpace(Json.SkuType))
|
{
|
strSql.Append(" and SkuType = '" + Json.SkuType + "' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.Conveyor))
|
{
|
strSql.Append(" and Conveyor = '" + Json.Conveyor + "' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.LotNo))
|
{
|
strSql.Append(" and LotNo like '%" + Json.LotNo + "%' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.IsEndLot))
|
{
|
strSql.Append(" and IsEndLot = '" + Json.IsEndLot + "' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.Status))
|
{
|
strSql.Append(" and Status = '" + Json.Status + "' ");
|
}
|
if (Json.BeginTime != null && Json.BeginTime != DateTime.MinValue && Json.BeginTime != DateTime.MaxValue)
|
{
|
strSql.Append($"and LoginTime >= '{Convert.ToDateTime(Json.BeginTime).ToShortDateString()}' ");
|
}
|
if (Json.BeginTime != null && Json.EndTime != DateTime.MinValue && Json.EndTime != DateTime.MaxValue)
|
{
|
strSql.Append($"and LoginTime <= '{Convert.ToDateTime(Json.EndTime).ToShortDateString() + " 23:59:59.999"}' ");
|
|
}
|
|
DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), null, "CreateTime", "Desc", ref pageInfo);
|
return ModelConvertHelper<GetWCSConveyorInfo>.DataTableToModel(dt);
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
public GetWCSConveyorInfo GetConveyorInfo(string Id)
|
{
|
GetWCSConveyorInfo getWCS = new GetWCSConveyorInfo();
|
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append($"select * from WCSConveyorInfo where Id = @id");
|
|
//DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);
|
|
SqlParam[] para = new SqlParam[]
|
{
|
new SqlParam("@id", Id),
|
};
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, para);
|
getWCS = ModelConvertHelper<GetWCSConveyorInfo>.ReaderToModel(dt);
|
|
return getWCS;
|
}
|
|
/// <summary>
|
/// 添加物料输送信息
|
/// </summary>
|
/// <param name="model"></param>
|
/// <param name="loginUser"></param>
|
/// <returns></returns>
|
public bool Add(WCSConveyorInfo model, string loginUser)
|
{
|
bool result = false;
|
try
|
{
|
//转换user信息 user Code变成id
|
|
UserInfo us = null;
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);
|
|
us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
|
if (us == null)
|
{
|
return false;
|
}
|
Hashtable ht = new Hashtable();
|
|
ht["SkuType"] = "'" + model.SkuType + "'";
|
ht["Conveyor"] = "'" + model.Conveyor + "'";
|
ht["LotNo"] = "'" + model.LotNo.Trim() + "'";
|
ht["SupplierLot"] = "'" + model.SupplierLot + "'";
|
ht["ManuFactureDate"] = "'" + model.ManuFactureDate + "'";
|
ht["IsEndLot"] = "0";
|
ht["Status"] = "0";
|
|
ht["IsDel"] = "0";
|
ht["CreateUser"] = "" + us.ID + "";
|
ht["CreateTime"] = "GetDate()";
|
|
var ret = DataFactory.SqlDataBase().InsertByHashtableNullParam("WCSConveyorInfo", ht);
|
|
if (ret == 1) result = true;
|
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 添加物料输送信息
|
/// </summary>
|
/// <param name="model"></param>
|
/// <param name="loginUser"></param>
|
/// <returns></returns>
|
public bool Upt(WCSConveyorInfo model, string loginUser)
|
{
|
bool result = false;
|
try
|
{
|
UserInfo us = null;
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);
|
|
us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
|
if (us == null)
|
{
|
return false;
|
}
|
|
|
|
StringBuilder sql = new StringBuilder();
|
if (model.Conveyor == "1")
|
{
|
model.Conveyor = "A";
|
}
|
else if (model.Conveyor == "2")
|
{
|
model.Conveyor = "B";
|
}
|
else if (model.Conveyor == "3")
|
{
|
model.Conveyor = "C";
|
}
|
else if (model.Conveyor == "4")
|
{
|
model.Conveyor = "C1";
|
}
|
else if (model.Conveyor == "5")
|
{
|
model.Conveyor = "D";
|
}
|
|
sql.Append($"update WcsConveyorInfo set SkuType = '{model.SkuType}',Conveyor = '{model.Conveyor}',LotNo = '{model.LotNo}',SupplierLot = '{model.SupplierLot}',ManuFactureDate = '{model.ManuFactureDate}',UpdateTime = getdate(),UpdateUser = '{us.ID}' Where Id = {model.Id}");
|
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret > 0) result = true;
|
return result;
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public bool Delete(string[] infoIds, string loginUser)
|
{
|
bool result = false;
|
try
|
{
|
UserInfo us = null;
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);
|
|
us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
|
if (us == null)
|
{
|
return false;
|
}
|
var dt2 = DataFactory.SqlDataBase().IsExist("WcsConveyorInfo", "Id", infoIds);
|
if (dt2 >= infoIds.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
foreach (string code in infoIds)
|
{
|
sql.Append("update WcsConveyorInfo set IsDel=1,UpdateTime = getdate(),UpdateUser = '" + us.ID + "' where Id='" + code + "';");
|
}
|
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret > infoIds.Length) result = true;
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public bool Run(string[] infoIds, string loginUser)
|
{
|
bool result = false;
|
try
|
{
|
UserInfo us = null;
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);
|
|
us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
|
if (us == null)
|
{
|
return false;
|
}
|
var dt2 = DataFactory.SqlDataBase().IsExist("WCSConveyorInfo", "Id", infoIds);
|
if (dt2 >= infoIds.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
foreach (string code in infoIds)
|
{
|
StringBuilder sql2 = new StringBuilder();
|
sql2.Append($"select * from WCSConveyorInfo where IsDel = 0 and Id = '{code}' ");
|
|
IDataReader dt3 = DataFactory.SqlDataBase().GetDataReaderBySQL(sql2, null);
|
|
var info = ModelConvertHelper<WCSConveyorInfo>.ReaderToModel(dt3);
|
|
sql.Append("update WcsConveyorInfo set Status=1,UpdateTime = getdate(),UpdateUser = '" + us.ID + "' where Id='" + code + "';");
|
sql.Append("update WcsConveyorInfo set Status=0,UpdateTime = getdate(),UpdateUser = '" + us.ID + "' where Id !='" + code + "' and IsDel = '0' and Conveyor = '"+ info.Conveyor + "';");
|
}
|
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret > infoIds.Length) result = true;
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
public bool JiePi(string[] infoIds, string loginUser)
|
{
|
bool result = false;
|
try
|
{
|
UserInfo us = null;
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);
|
|
us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
|
if (us == null)
|
{
|
return false;
|
}
|
var dt2 = DataFactory.SqlDataBase().IsExist("WCSConveyorInfo", "Id", infoIds);
|
if (dt2 >= infoIds.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
foreach (string code in infoIds)
|
{
|
sql.Append("update WcsConveyorInfo set IsEndLot=1,Status =0,UpdateTime = getdate(),UpdateUser = '" + us.ID + "' where Id='" + code + "';");
|
|
}
|
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret > infoIds.Length) result = true;
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
}
|
}
|
