using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Commom.DotNetDevices;
|
using Common;
|
using Model;
|
using Model;
|
|
namespace BLL.DAL
|
{
|
public class DAL_ConveyorInfo
|
{
|
public List<WCSPlcInfo> GetList(AjaxPlcInfoList Json, ref PageInfo pageInfo)
|
{
|
try
|
{
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append("select a.IP,b.* from WCSPlcInfo b left join WCSIP a on b.PlcIP = a.Id where b.IsDel = 0 and a.Type = '1' ");
|
if (!string.IsNullOrWhiteSpace(Json.StationNum))
|
{
|
strSql.Append($"and b.StationNum = '{Json.StationNum}' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.Text))
|
{
|
strSql.Append($"and b.Text = '{Json.Text}' ");
|
}
|
DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), null, "CreateTime", "", ref pageInfo);
|
if (dt != null)
|
{
|
DALWcsMessage wcsSql = new DALWcsMessage();
|
var plcIpDt = wcsSql.GetPlcIps();
|
dt.Columns.Add("PlcStatusVal", Type.GetType("System.String"));
|
foreach (DataRow item in dt.Rows)
|
{
|
DataRow ipRows = plcIpDt.Select($" Id = {item["PlcIP"].ToString()} ")[0];
|
string plcStatus = "", plcValue = "";
|
var statusVal = "";
|
PlcIO plc = new PlcIO(ipRows["IP"].ToString(), 1, ref plcStatus);
|
if (plcStatus.Length > 0)
|
{
|
plc.ClosePlc();
|
}
|
else
|
{
|
plcValue = plc.GetPlcDBValue(int.Parse(item["DbNumber"].ToString()), item["PosType"].ToString(), item["PlcPos"].ToString());
|
}
|
|
switch (plcValue)
|
{
|
case "0": // 申请储位
|
statusVal = item["DbNumber"].ToString() =="7"|| item["DbNumber"].ToString() == "11" ? "有货，不可放货" : "空闲";
|
break;
|
case "10": // 申请储位
|
statusVal = "申请储位";
|
break;
|
case "20": // 到达出库口
|
statusVal = "出库完成";
|
break;
|
case "100": // 堆垛机可以取货
|
statusVal = "堆垛机可以取货";
|
break;
|
case "120": // 堆垛机可以取货
|
statusVal = "堆垛机可以放货";
|
break;
|
default:
|
statusVal = "连接PLC失败";
|
break;
|
}
|
|
item["PlcStatusVal"] = statusVal;
|
plc.ClosePlc();
|
}
|
|
var list = ModelConvertHelper<WCSPlcInfo>.DataTableToModel(dt);
|
return list.ToList();
|
}
|
else
|
{
|
List<WCSPlcInfo> list = new List<WCSPlcInfo>();
|
return list;
|
}
|
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
|
#region MyRegion
|
//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))
|
// {
|
// 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();
|
//}
|
#endregion
|
|
}
|
|
|
public string AddConveyor(ConveyorModel model, string loginUser,string orgin)
|
{
|
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 "未查询到当前登录人信息";
|
}
|
string plcStatus = ""; // PLC连接状态
|
PlcIO plc = new PlcIO("192.168.21.2", 1, ref plcStatus);
|
if (plcStatus.Length > 0)
|
{
|
return "连接输送线失败";
|
}
|
DALWcsMessage wcsSql = new DALWcsMessage();
|
var PlcInfoDt = wcsSql.GetPlcInfos();
|
DataRow[] plcRows = PlcInfoDt.Select($"Level = '2' and StationNum='{model.StartLocatNo}' ");
|
if (plcRows.Length == 0)
|
{
|
return "未查询到起始工位信息";
|
}
|
var posDt = wcsSql.GetPlcPos(plcRows[0]["Id"].ToString());
|
// 写入起始工位
|
var posRos101 = posDt.Select($"Name = 'StartLocatNo' ")[0];
|
plc.SetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), posRos101["PosType"].ToString(), model.StartLocatNo, posRos101["PlcPos"].ToString());
|
|
// 写入目的工位
|
var posRos102 = posDt.Select($"Name = 'EndLocatNo' ")[0];
|
plc.SetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), posRos102["PosType"].ToString(), model.EndLocatNo, posRos102["PlcPos"].ToString());
|
|
//写入托盘号
|
var posRos103 = posDt.Select($"Name = 'PalletNo' ")[0];// 托盘号
|
plc.SetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), posRos103["PosType"].ToString(), model.PalletNo, posRos103["PlcPos"].ToString());
|
|
//写入任务号
|
var posRos104 = posDt.Select($"Name = 'TaskNo' ")[0];
|
plc.SetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), posRos104["PosType"].ToString(), model.TaskNo, posRos104["PlcPos"].ToString());
|
|
// 写入wcs控制字流程10
|
bool inBl10 = plc.SetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), plcRows[0]["PosType"].ToString(),model.WcsPos, plcRows[0]["WcsPos"].ToString(), true);
|
|
|
plc.ClosePlc();
|
if (orgin == "Edit")
|
{
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "输送线监控",
|
FkNo = model.TaskNo + "-" + model.PalletNo,
|
Msg = "手动编辑输送线任务信息",
|
Type = "编辑",
|
};
|
oper.AddOperation(operation, loginUser);
|
}
|
return "";
|
|
}
|
catch(Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
|
public ConveyorModel GetConveyor(string id)
|
{
|
try
|
{
|
string plcStatus = ""; // PLC连接状态
|
ConveyorModel model = new ConveyorModel();
|
PlcIO plc = new PlcIO("192.168.21.2", 1, ref plcStatus);
|
if (plcStatus.Length > 0)
|
{
|
return model; //throw new Exception("连接输送线失败");
|
}
|
DALWcsMessage wcsSql = new DALWcsMessage();
|
var PlcInfoDt = wcsSql.GetPlcInfos();
|
DataRow[] plcRows = PlcInfoDt.Select($"Level = '2' and Id={id} ");
|
if (plcRows.Length == 0)
|
{
|
return model; //throw new Exception("未查询到起始工位信息");
|
}
|
var posDt = wcsSql.GetPlcPos(id);
|
|
// 获取起始工位
|
var posRos101 = posDt.Select($"Name = 'StartLocatNo' ")[0];
|
model.StartLocatNo = plc.GetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), posRos101["PosType"].ToString(), posRos101["PlcPos"].ToString());
|
|
// 获取目的工位
|
var posRos102 = posDt.Select($"Name = 'EndLocatNo' ")[0];
|
model.EndLocatNo = plc.GetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), posRos102["PosType"].ToString(), posRos102["PlcPos"].ToString());
|
|
// 获取托盘号
|
var posRos103 = posDt.Select($"Name = 'PalletNo' ")[0];// 托盘号
|
model.PalletNo = plc.GetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), posRos103["PosType"].ToString(), posRos103["PlcPos"].ToString());
|
|
// 获取任务号
|
var posRos104 = posDt.Select($"Name = 'TaskNo' ")[0];
|
model.TaskNo = plc.GetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), posRos104["PosType"].ToString(), posRos104["PlcPos"].ToString());
|
|
// 获取wcs控制字流程
|
model.WcsPos = plc.GetPlcDBValue(int.Parse(plcRows[0]["DbNumber"].ToString()), plcRows[0]["PosType"].ToString(), plcRows[0]["WcsPos"].ToString());
|
|
|
plc.ClosePlc();
|
|
|
return model;
|
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
|
/// <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 + "'";
|
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;
|
}
|
}
|
|
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;
|
}
|
}
|
}
|
}
|
