using Commom.Utility;
|
using Common;
|
using Model;
|
using Model.WcsModel;
|
using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Text;
|
|
namespace BLL.DAL
|
{
|
public class DAL_PlcPos
|
{
|
/// <summary>
|
/// 根据ID获取流程字信息
|
/// </summary>
|
/// <returns></returns>
|
public WCSPlcPos GetPlcPos(string Id)
|
{
|
try
|
{
|
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append($"select * from WCSPlcPos where IsDel = 0 and Id = '{Id}' order by createTime;");
|
|
IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
|
var model = ModelConvertHelper<WCSPlcPos>.ReaderToModel(dt);
|
return model;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
/// <summary>
|
/// 获取工位对应的流程字数据集合
|
/// </summary>
|
/// <param name="Json">查询条件</param>
|
/// <param name="pageInfo">分页信息</param>
|
/// <returns></returns>
|
public IList<WCSPlcPos> GetPlcPosList(AjaxPlcPosList Json, ref PageInfo pageInfo)
|
{
|
try
|
{
|
IList<WCSPlcPos> list = new List<WCSPlcPos>();
|
StringBuilder sqlString = new StringBuilder();
|
List<SqlParam> para = new List<SqlParam>();
|
|
sqlString.Append("select tb1.Id,tb1.PlcInfoId,tb1.StationNum,tb1.PlcPos, ");
|
sqlString.Append("tb1.PosType,tb1.LedIP,tb1.Name,tb1.CreateUser,tb2.RealName as CreateUserName,tb1.CreateTime ");
|
sqlString.Append("from WCSPlcPos as tb1 left join UserInfo as tb2 on tb1.CreateUser = tb2.ID ");
|
sqlString.Append("where tb1.IsDel = 0 ");
|
if (!string.IsNullOrWhiteSpace(Json.StationNum))
|
{
|
sqlString.Append($"and tb1.StationNum like '%{Json.StationNum}%' ");
|
}
|
|
if (!string.IsNullOrWhiteSpace(Json.PlcPos))
|
{
|
sqlString.Append($"and tb1.PlcPos like '%{Json.PlcPos}%' ");
|
}
|
|
DataTable dt = DataFactory.SqlDataBase().GetPageList(sqlString.ToString(), null, "CreateTime", "DESC", ref pageInfo);
|
|
list = ModelConvertHelper<WCSPlcPos>.DataTableToModel(dt);
|
|
return list;
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
/// <summary>
|
/// 删除工位对应的流程字信息
|
/// </summary>
|
/// <param name="ID">ID集合</param>
|
/// <returns></returns>
|
public bool DeletePlcPos(string[] ID)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("WCSPlcPos", "ID", ID);
|
if (dt >= ID.Length)
|
{
|
int i = 0;
|
while (i < ID.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
sql.Append("update WCSPlcPos set IsDel=1 where Id='" + ID[i] + "'");
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret >= ID.Length) result = true;
|
i++;
|
}
|
|
}
|
return result;
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 新增编辑流程字信息
|
/// </summary>
|
/// <param name="model">流程字信息</param>
|
/// <returns>true:保存成功 false:保存失败</returns>
|
public bool AddPlcPos(AjaxPlcPos model)
|
{
|
bool bl = false;
|
try
|
{
|
int rowCount = 0;
|
Hashtable ht = new Hashtable();
|
if (model.Operation == "Add")
|
{
|
string[] StationNumlist = model.StationNum.Split('-');
|
// add
|
ht["PlcInfoId"] = model.PlcInfoId;
|
ht["StationNum"] = StationNumlist[0].AddQuotes();
|
ht["PlcPos"] = model.PlcPos.AddQuotes();
|
ht["PosType"] = model.PosType.AddQuotes();
|
ht["LedIP"] = model.LedIP.AddQuotes();
|
ht["Name"] = model.Name.AddQuotes();
|
ht["CreateUser"] = model.CreateUser;
|
|
rowCount = DataFactory.SqlDataBase().InsertByHashtableNullParam("WCSPlcPos", ht);
|
}
|
else
|
{
|
// Edit
|
string[] StationNumlist = model.StationNum.Split('-');
|
ht["PlcInfoId"] = model.PlcInfoId;
|
ht["StationNum"] = StationNumlist[0].AddQuotes();
|
ht["PlcPos"] = model.PlcPos.AddQuotes();
|
ht["PosType"] = model.PosType.AddQuotes();
|
ht["LedIP"] = model.LedIP.AddQuotes();
|
ht["Name"] = model.Name.AddQuotes();
|
|
rowCount = DataFactory.SqlDataBase().UpdateByHashtable("WCSPlcPos", "id", model.Id.ToString(), ht);
|
}
|
|
if (rowCount == 1)
|
{
|
bl = true;
|
}
|
}
|
catch (Exception)
|
{
|
bl = false;
|
}
|
|
return bl;
|
}
|
|
|
/// <summary>
|
/// 获取工位下拉框
|
/// </summary>
|
/// <param name="PlcInfoId">工位ID</param>
|
/// <returns></returns>
|
public string GetPlcPosHtml(string PlcInfoId = "")
|
{
|
try
|
{
|
StringBuilder sb = new StringBuilder();
|
string resMenuTemplate = "<option value='{0}' {1}>{2}</option>";
|
sb.AppendFormat(resMenuTemplate, "", "", "选择");
|
|
StringBuilder sqlString = new StringBuilder();
|
sqlString.Append("select * from WCSPlcInfo where IsDel = 0 and Level ='2';");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
|
foreach (DataRow row in dt.Rows)
|
{
|
sb.AppendFormat(resMenuTemplate, row["Id"].ToString(), row["Id"].ToString() == PlcInfoId ? "selected='selected'" :
|
string.Empty, row["StationNum"].ToString()+"-"+ row["Text"].ToString());
|
}
|
|
return sb.ToString();
|
}
|
catch
|
{
|
return "";
|
}
|
}
|
|
|
/// <summary>
|
/// 验证是否存在重复项
|
/// </summary>
|
/// <param name="sqlWhere">查询条件</param>
|
/// <returns></returns>
|
public bool IsExist(string sqlWhere)
|
{
|
return DataFactory.SqlDataBase().IsExist("WCSPlcPos", sqlWhere);
|
}
|
}
|
}
|
