|
using HPSocketCS;
|
using iWareCc.Cache.Entity;
|
using iWareCc.Conveyor.Datagram;
|
using iWareCc.Conveyor.Service;
|
using iWareCc.Conveyor.Socket;
|
using iWareCcTest.Properties;
|
using iWareCc.Util;
|
using iWareCommon.Utils;
|
using iWareDataCore.BASE.Entity;
|
using iWareDataCore.ORM;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace iWareCc.Conveyor.Entity
|
{
|
public class GateEntity
|
{
|
/// <summary>
|
/// 库位
|
/// </summary>
|
public PlaceViewEntity Place { get; private set; }
|
|
|
|
#region Client
|
/// <summary>
|
/// 用于收发报文的Socket服务（客户端）
|
/// </summary>
|
public SocketClient Socket { get; set; }
|
|
/// <summary>
|
/// Client内存日志
|
/// </summary>
|
public List<string> ClientReceiveLogger { get; set; }
|
|
/// <summary>
|
/// Client内存发送日志
|
/// </summary>
|
public List<string> ClientSendLogger { get; set; }
|
#endregion
|
|
/// <summary>
|
/// 用于发送报文的Socket服务(服务端)
|
/// </summary>
|
public SocketServer SocketServer { get; set; }
|
|
/// <summary>
|
/// Server接收端内存接收日志
|
/// </summary>
|
public List<string> ServerReceiveLogger { get; set; }
|
|
/// <summary>
|
/// Server接收端内存发送日志
|
/// </summary>
|
public List<string> ServerSendLogger { get; set; }
|
|
/// <summary>
|
/// 缓存接收报文的字符串
|
/// </summary>
|
public string DatagramReceivePool { get; set; }
|
|
/// <summary>
|
/// 缓存接收报文的字符串
|
/// </summary>
|
public string DatagramReceiveAlermPool { get; set; }
|
|
/// <summary>
|
/// 缓存接收报文的字符串
|
/// </summary>
|
public string DatagramReceiveSCPool { get; set; }
|
|
/// <summary>
|
/// 缓存发送报文的字符串
|
/// </summary>
|
public string DatagramSendPool { get; set; }
|
|
/// <summary>
|
/// 发送标志
|
/// </summary>
|
public bool SendFlag { get; set; }
|
|
|
|
/// <summary>
|
/// 未捕获心跳次数
|
/// </summary>
|
public int DisconnectTimes = 5;
|
|
/// <summary>
|
/// 上传获得的心跳数
|
/// </summary>
|
public string LastHandShakeCount = "0";
|
|
/// <summary>
|
/// 报警
|
/// </summary>
|
public string AlarmCode = "0";
|
|
/// <summary>
|
/// 是否在线
|
/// </summary>
|
public bool IsOnline { get; set; }
|
|
|
/// <summary>
|
/// 任务号
|
/// </summary>
|
public string TaskId { get; set; }
|
|
/// <summary>
|
/// 取消
|
/// </summary>
|
public bool Canceled { get; set; }
|
|
|
/// <summary>
|
/// 到位
|
/// </summary>
|
public bool ROccupied { get; set; }
|
|
/// <summary>
|
/// 是否为空
|
/// </summary>
|
public bool RIsEmpty { get; set; }
|
|
/// <summary>
|
/// 扫描到的物料号
|
/// </summary>
|
public string RCheckMaterialCode { get; set; }
|
|
/// <summary>
|
/// 放货完成（开始任务）
|
/// </summary>
|
public bool WPutFinishSymbol { get; set; }
|
|
/// <summary>
|
/// 取货完成（开始任务）
|
/// </summary>
|
public bool WPickFinishSymbol { get; set; }
|
|
/// <summary>
|
/// 滚动开始
|
/// </summary>
|
public bool WStartRotation { get; set; }
|
|
/// <summary>
|
/// 是否入库
|
/// </summary>
|
public bool WIsInStorage { get; set; }
|
|
/// <summary>
|
/// 错误数量
|
/// </summary>
|
public int ErrorCount { get; set; }
|
|
/// <summary>
|
/// WCS需要写入的OPC地址
|
/// </summary>
|
public OpcReadItem OpcReadItems { get; set; }
|
|
/// <summary>
|
/// WCS需要读取的OPC地址
|
/// </summary>
|
public OpcWriteItem OpcWriteItems { get; set; }
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
/// <param name="conveyor">调用该货口的输送机</param>
|
public GateEntity(PlaceViewEntity place)
|
{
|
this.Place = place;
|
this.DatagramReceivePool = "";
|
this.DatagramSendPool = "";
|
this.DatagramReceiveAlermPool = "";
|
this.DatagramReceiveSCPool = "";
|
this.SendFlag = false;
|
this.ErrorCount = 0;
|
//Client
|
//this.ClientReceiveLogger = new List<string>();
|
//this.ClientSendLogger = new List<string>();
|
//this.Socket = new GateEntitySocket(this, new TcpClient(), place.Ip, place.Point);
|
//Server
|
this.ServerReceiveLogger = new List<string>();
|
this.ServerSendLogger = new List<string>();
|
this.SocketServer = new GateSocketServer( this,new TcpServer(),place.Ip, place.Point);
|
switch (place.PlaceTypeName)
|
{
|
//入库输送机(Conveyor1)
|
//起始点
|
case "gate11":
|
OpcWriteItems = CacheEntity.IsRealMode ? new OpcWriteItem
|
{
|
WStartRotation = "S7:[S7_Connection_1]DB600,X2366.0",//滚动开始
|
WIsInStorage= "S7:[S7_Connection_1]DB600,X2366.0"//是否入库
|
} : new OpcWriteItem
|
{
|
WStartRotation = "S7:[@LOCALSERVER]DB1,X682.2",//滚动开始
|
WIsInStorage= "S7:[S7_Connection_1]DB600,X2366.0"//是否入库
|
};
|
OpcReadItems = CacheEntity.IsRealMode ? new OpcReadItem
|
{
|
ROccupied = "S7:[S7_Connection_1]DB600,X262.3",//是否到位
|
RIsEmpty = "S7:[S7_Connection_1]DB600,X262.2"//是否为空端口
|
|
} : new OpcReadItem
|
{
|
ROccupied = "S7:[@LOCALSERVER]DB1,X688.0",//允许开始
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1"//是否为空端口
|
|
};
|
break;
|
//目标点
|
case "gate12":
|
OpcWriteItems = CacheEntity.IsRealMode ? new OpcWriteItem
|
{
|
WStartRotation = "S7:[S7_Connection_1]DB601,X516.4"//滚动开始
|
} : new OpcWriteItem
|
{
|
|
WStartRotation = "S7:[@LOCALSERVER]DB1,X952.1"//滚动开始
|
};
|
OpcReadItems = CacheEntity.IsRealMode ? new OpcReadItem
|
{
|
ROccupied = "S7:[S7_Connection_1]DB601,X516.2",//是否到位
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1"//是否为空端口
|
} : new OpcReadItem
|
{
|
|
ROccupied = "S7:[@LOCALSERVER]DB1,X1466.1",//是否到位
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1"//是否为空端口
|
|
};
|
break;
|
case "gate13":
|
OpcWriteItems = CacheEntity.IsRealMode ? new OpcWriteItem
|
{
|
WStartRotation = "S7:[S7_Connection_1]DB601,X516.4"//滚动开始
|
} : new OpcWriteItem
|
{
|
|
WStartRotation = "S7:[@LOCALSERVER]DB1,X952.1"//滚动开始
|
};
|
OpcReadItems = CacheEntity.IsRealMode ? new OpcReadItem
|
{
|
ROccupied = "S7:[S7_Connection_1]DB601,X516.2",//是否到位
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1"//是否为空端口
|
} : new OpcReadItem
|
{
|
|
ROccupied = "S7:[@LOCALSERVER]DB1,X1466.1",//是否到位
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1",//是否为空端口
|
|
};
|
break;
|
case "gate14":
|
OpcWriteItems = CacheEntity.IsRealMode ? new OpcWriteItem
|
{
|
WStartRotation = "S7:[S7_Connection_1]DB601,X516.4"//滚动开始
|
} : new OpcWriteItem
|
{
|
|
WStartRotation = "S7:[@LOCALSERVER]DB1,X952.1"//滚动开始
|
};
|
OpcReadItems = CacheEntity.IsRealMode ? new OpcReadItem
|
{
|
ROccupied = "S7:[S7_Connection_1]DB601,X516.2",//是否到位
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1"//是否为空端口
|
} : new OpcReadItem
|
{
|
|
ROccupied = "S7:[@LOCALSERVER]DB1,X1466.1",//是否到位
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1"//是否为空端口
|
|
};
|
break;
|
case "gate15":
|
OpcWriteItems = CacheEntity.IsRealMode ? new OpcWriteItem
|
{
|
WPickFinishSymbol = "S7:[S7_Connection_1]DB601,X516.4"//取货完成
|
} : new OpcWriteItem
|
{
|
|
WPickFinishSymbol = "S7:[@LOCALSERVER]DB1,X952.1"//取货完成
|
};
|
OpcReadItems = CacheEntity.IsRealMode ? new OpcReadItem
|
{
|
ROccupied = "S7:[S7_Connection_1]DB601,X516.2",//是否到位
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1"//是否为空端口
|
} : new OpcReadItem
|
{
|
|
ROccupied = "S7:[@LOCALSERVER]DB1,X1466.1",//是否到位
|
RIsEmpty = "S7:[@LOCALSERVER]DB1,X684.1"//是否为空端口
|
};
|
break;
|
|
//出库输送机conveyor2
|
//起始点
|
case "gate21":
|
OpcWriteItems = CacheEntity.IsRealMode ? new OpcWriteItem
|
{
|
WStartRotation = "S7:[S7_Connection_1]DB600,X2366.0"//滚动开始
|
} : new OpcWriteItem
|
{
|
WStartRotation = "S7:[S7_Connection_1]DB600,X2366.0"//滚动开始
|
};
|
OpcReadItems = CacheEntity.IsRealMode ? new OpcReadItem
|
{
|
ROccupied = "S7:[S7_Connection_1]DB600,X262.3",//是否到位
|
RIsEmpty = "S7:[S7_Connection_1]DB600,X262.2"//是否为空端口
|
} : new OpcReadItem
|
{
|
ROccupied = "S7:[S7_Connection_1]DB600,X262.3",//是否到位
|
RIsEmpty = "S7:[S7_Connection_1]DB600,X262.2"//是否为空端口
|
};
|
break;
|
//目标点
|
case "gate22":
|
OpcWriteItems = CacheEntity.IsRealMode ? new OpcWriteItem
|
{
|
WStartRotation = "S7:[S7_Connection_1]DB600,X2366.0"//滚动开始
|
} : new OpcWriteItem
|
{
|
|
WStartRotation = "S7:[S7_Connection_1]DB600,X2366.0"//滚动开始
|
};
|
OpcReadItems = CacheEntity.IsRealMode ? new OpcReadItem
|
{
|
ROccupied = "S7:[S7_Connection_1]DB601,X516.2",//是否到位
|
RIsEmpty = "S7:[S7_Connection_1]DB600,X262.2",//是否为空端口
|
} : new OpcReadItem
|
{
|
ROccupied = "S7:[@LOCALSERVER]DB1,X3018.0",//是否到位
|
RIsEmpty = "S7:[S7_Connection_1]DB600,X262.2",//是否为空端口
|
};
|
break;
|
|
|
}
|
}
|
|
|
/// <summary>
|
/// 发送任务
|
/// </summary>
|
/// <returns>是否发送成功</returns>
|
public bool SendOk()
|
{
|
try
|
{
|
var flag = CacheEntity.OpcWcfServiceClient.WriteValue(this.OpcWriteItems.WStartRotation, true);
|
LogTextHelper.WriteLine(Resources.LogDir + @"\输送机发送报文\" + Place.PlaceTypeName, "发送自动开始标志={0},结果={1}", true, flag);
|
return flag;
|
|
}
|
catch (Exception)
|
{
|
return false;
|
}
|
|
}
|
|
/// <summary>
|
/// 发送任务
|
/// </summary>
|
/// <returns>是否发送成功</returns>
|
public bool SendProcessCard(string processCardNumber, int roadwayNo, int taskType)
|
{
|
try
|
{
|
var flag = CacheEntity.OpcWcfServiceClient.WriteValues(new string[] { }, new object[] { roadwayNo, taskType, processCardNumber });
|
LogTextHelper.WriteLine(Resources.LogDir + @"\输送机发送报文\" + Place.PlaceTypeName, "发送流转卡--> processCardNumber={0},roadwayNo={1},taskType={2},结果={3}", processCardNumber, roadwayNo, taskType, flag);
|
return flag;
|
|
}
|
catch (Exception)
|
{
|
return false;
|
}
|
}
|
|
/// <summary>
|
/// 发送任务号
|
/// </summary>
|
/// <param name="taskid">任务号</param>
|
/// <returns>是否发送成功</returns>
|
public bool SendTaskId(string taskid)
|
{
|
try
|
{
|
var flag = CacheEntity.OpcWcfServiceClient.WriteValues(new string[] { this.OpcWriteItems.WTaskId }, new object[] { taskid });
|
LogTextHelper.WriteLine(Resources.LogDir + @"\输送机发送报文\" + Place.PlaceTypeName, "发送任务号--> taskId={0},结果={1}", taskid, flag);
|
return flag;
|
|
}
|
catch (Exception)
|
{
|
return false;
|
|
}
|
}
|
|
|
/// <summary>
|
/// 发送取货完成
|
/// </summary>
|
/// <returns>是否发送成功</returns>
|
public bool SendPickSymbol()
|
{
|
try
|
{
|
var flag = CacheEntity.OpcWcfServiceClient.WriteValues(new string[] { this.OpcWriteItems.WPutFinishSymbol }, new object[] { true });
|
LogTextHelper.WriteLine(Resources.LogDir + @"\输送机发送报文\" + Place.PlaceTypeName, "发送取货完成={0},结果={1}", true, flag);
|
return flag;
|
|
}
|
catch (Exception)
|
{
|
return false;
|
}
|
|
}
|
|
|
/// <summary>
|
/// 重置流转卡
|
/// </summary>
|
/// <param name="processCardNumber">流转卡号</param>
|
/// <returns>是否重置成功</returns>
|
public bool ResetProcessCard(string processCardNumber)
|
{
|
try
|
{
|
var flag = CacheEntity.OpcWcfServiceClient.WriteValues(new string[] {}, new object[] { processCardNumber });
|
LogTextHelper.WriteLine(Resources.LogDir + @"\输送机发送报文\" + Place.PlaceTypeName, "重置流转卡--> processCardNumber={0},结果={1}", processCardNumber, flag);
|
return flag;
|
}
|
catch (Exception)
|
{
|
return false;
|
|
}
|
}
|
|
/// <summary>
|
/// 发送手动开始
|
/// </summary>
|
/// <returns>是否发送成功</returns>
|
public bool SendStartSymbolManual(out string msg)
|
{
|
using (var dbModel = new DbModelCore())
|
{
|
try
|
{
|
msg = "";
|
if (!this.ROccupied)
|
{
|
msg = string.Format("端口{0}上没有检测到物料", this.Place.PlaceTypeName);
|
return false;
|
|
}
|
|
var flag = CacheEntity.OpcWcfServiceClient.WriteValues(new string[] { this.OpcWriteItems.WStartRotation }, new object[] { true });
|
LogTextHelper.WriteLine(Resources.LogDir + @"\输送机发送报文\" + Place.PlaceTypeName, "发送手动放货完成={0},结果={1}", true, flag);
|
|
if (flag)
|
{
|
var pvc = dbModel.BASEPlaceMaterialViews.FirstOrDefault(x => x.placetypename == this.Place.PlaceTypeName);
|
if (pvc != null)
|
{
|
dbModel.BASEPlaceMaterialViews.Remove(pvc);
|
dbModel.SaveChanges();
|
}
|
}
|
|
return flag;
|
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
return false;
|
}
|
|
|
}
|
|
|
}
|
|
/// <summary>
|
/// 发送开始
|
/// </summary>
|
/// <returns>是否发送成功</returns>
|
public bool SendStartSymbol(out string msg)
|
{
|
using (var dbModel = new DbModelCore())
|
{
|
try
|
{
|
msg = "";
|
if (!this.ROccupied)
|
{
|
msg = string.Format("端口{0}上没有检测到物料", this.Place.PlaceTypeName);
|
return false;
|
|
}
|
|
var flag = CacheEntity.OpcWcfServiceClient.WriteValues(new string[] { this.OpcWriteItems.WPutFinishSymbol }, new object[] { true });
|
LogTextHelper.WriteLine(Resources.LogDir + @"\输送机发送报文\" + Place.PlaceTypeName, "发送放货完成={0},结果={1}", true, flag);
|
|
if (flag)
|
{
|
var pvc = dbModel.BASEPlaceMaterialViews.FirstOrDefault(x => x.placetypename == this.Place.PlaceTypeName );
|
if (pvc != null)
|
{
|
dbModel.BASEPlaceMaterialViews.Remove(pvc);
|
dbModel.SaveChanges();
|
}
|
}
|
|
return flag;
|
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
return false;
|
}
|
}
|
}
|
|
#region 使用Socket通讯发送信息
|
/// <summary>
|
/// 发送入库滚动的任务
|
/// </summary>
|
/// <param name="taskid">任务号</param>
|
/// <returns>是否发送成功</returns>
|
public bool SendGateTask()
|
{
|
try
|
{
|
if (!new GateService(this).Send(new GateDatagramParse(new GateDatagramProp
|
{
|
Name = this.Place.PlaceTypeName,
|
Roll = "T",
|
InOut = "T"
|
}).ParseByteDatagram()))
|
{
|
LogTextHelper.WriteLine(Resources.LogDir, "在类{0}中执行方法{1}时出现异常：{2}", this.ToString(), "SendGateTask", "发送命令失败");
|
return false;
|
}
|
return true;
|
}
|
catch (Exception)
|
{
|
return false;
|
|
}
|
}
|
/// <summary>
|
/// 发送物料宽度
|
/// </summary>
|
/// <returns></returns>
|
public bool SendMaterialWindTask(string materialwind,string thick)
|
{
|
try
|
{
|
int wind = int.Parse(materialwind);
|
string mwind = "";
|
if (wind < 1000 && wind >= 100)
|
{
|
mwind = wind.ToString();
|
}
|
else if (wind < 100 && wind >= 10)
|
{
|
mwind = "0" + wind.ToString();
|
}
|
else if (wind < 10 && wind > 0)
|
{
|
mwind = "00" + wind.ToString();
|
}
|
else
|
{
|
mwind = "999";
|
}
|
int thic = int.Parse(thick);
|
string wthik = "";
|
if (thic < 10)
|
{
|
wthik = "0" + thic.ToString();
|
}
|
else if (thic >= 10 && thic < 100)
|
{
|
wthik = thic.ToString();
|
}
|
else
|
{
|
wthik = "99";
|
}
|
|
|
if (!new GateService(this).Send(new GateDatagramParse(new GateDatagramProp
|
{
|
Name = this.Place.PlaceTypeName,
|
Wind= mwind,
|
Thick= wthik
|
}).ParseByteDatagram()))
|
{
|
LogTextHelper.WriteLine(Resources.LogDir, "在类{0}中执行方法{1}时出现异常：{2}", this.ToString(), "SendGateTask", "发送命令失败");
|
return false;
|
}
|
return true;
|
}
|
catch (Exception)
|
{
|
return false;
|
|
}
|
}
|
/// <summary>
|
/// 发送报警信息
|
/// </summary>
|
/// <param name="taskid">任务号</param>
|
/// <returns>是否发送成功</returns>
|
public bool SendGateAlarmTask(int msg)
|
{
|
try
|
{
|
if (!new GateService(this).Send(new GateDatagramParse(new GateDatagramProp
|
{
|
Name = this.Place.PlaceTypeName,
|
Alarmcode =("0"+(msg+1).ToString())
|
}).ParseByteDatagram()))
|
{
|
LogTextHelper.WriteLine(Resources.LogDir, "在类{0}中执行方法{1}时出现异常：{2}", this.ToString(), "SendGateTask", "发送命令失败");
|
return false;
|
}
|
return true;
|
}
|
catch (Exception)
|
{
|
return false;
|
|
}
|
}
|
/// <summary>
|
/// 发送不入库直接滚动的任务
|
/// </summary>
|
/// <returns></returns>
|
public bool SendNotIngGateTask()
|
{
|
try
|
{
|
if (!new GateService(this).Send(new GateDatagramParse(new GateDatagramProp
|
{
|
Name = this.Place.PlaceTypeName,
|
Roll = "F",
|
InOut = "F"
|
}).ParseByteDatagram()))
|
{
|
LogTextHelper.WriteLine(Resources.LogDir, "在类{0}中执行方法{1}时出现异常：{2}", this.ToString(), "SendGateTask", "发送命令失败");
|
return false;
|
}
|
return true;
|
}
|
catch (Exception)
|
{
|
return false;
|
|
}
|
}
|
#endregion
|
|
}
|
}
|
