using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using S7.Net;
|
using logtxtWrite;
|
|
|
|
using iWareModel;
|
using iWareCommon.Utils;
|
namespace iWareSda
|
{
|
public class SS7 : PLCService
|
{
|
private PlcS7 plcS7 = null;
|
public SS7(SS7Param s7Param)
|
{
|
plcS7 = new PlcS7(s7Param.cpu, s7Param.ip, s7Param.rack, s7Param.slot);
|
_LogType = LogType.SS7;
|
}
|
/// <summary>
|
/// 打开S7连接
|
/// </summary>
|
/// <returns></returns>
|
public override MessageModel OpenService()
|
{
|
MessageModel fre = new MessageModel();
|
try
|
{
|
var code = plcS7.Open();
|
if (code == ErrorCode.NoError)
|
{
|
base.IsConnected = true;
|
fre.result = true;
|
return fre;
|
}
|
base.IsConnected = false;
|
fre.result = false;
|
fre.resMsg = "打开失败," + code.ToString();
|
return fre;
|
}
|
catch (Exception ex)
|
{
|
base.IsConnected = false;
|
Log4NetHelper.WriteErrorLog(_LogType, "初始化s7Init出现异常", ex);
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// S7读取
|
/// </summary>
|
/// <param name="dbNumber">DB块名</param>
|
/// <param name="offset">偏移量</param>
|
/// <param name="type"></param>
|
/// <returns></returns>
|
public override MessageModel WriteValuePoint(string dbNumber, string offset, object value, Object proObj)
|
{
|
MessageModel fre = new MessageModel();
|
object objReuslt = new object();
|
var address = GetAddress(dbNumber, offset, value.GetType());
|
try
|
{
|
if (value.GetType() == typeof(bool))
|
{//布尔要转换成1和0写入
|
int myData = Convert.ToInt32(value);
|
objReuslt = plcS7.Write(address, myData);
|
}
|
//浮点
|
else if (value.GetType() == typeof(double) || value.GetType() == typeof(float))
|
{
|
double MyData = Convert.ToDouble(value);
|
objReuslt = plcS7.Write(address, MyData.ConvertToUInt());
|
|
}
|
//整数
|
else if (value.GetType() == typeof(Int32) || value.GetType() == typeof(short))
|
{
|
short MyData = Convert.ToInt16(value);
|
objReuslt = plcS7.Write(address, MyData.ConvertToUshort());
|
}
|
//双整数
|
else if (value.GetType() == typeof(Int32))
|
{
|
int myData = Convert.ToInt32(value);
|
objReuslt = plcS7.Write(address, myData);
|
}
|
//Char
|
else if (value.GetType() == typeof(Char))
|
{//char要转换成int类型，写给PLC
|
int myData = Convert.ToInt32(value);
|
byte b = (byte)myData;
|
objReuslt = plcS7.Write(address, b);
|
}
|
else
|
{
|
objReuslt = plcS7.Write(address, value);
|
}
|
ValidateReusltForWrite(objReuslt, address);
|
Log4NetHelper.WriteInfoLog(LogType.SS7, String.Format("写入地址:{0},值:{1}", address, value.ToString()));
|
fre.result = true;
|
return fre;
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SS7, String.Format("写入出现异常:" + ex.Message + "，地址:{0},值:{1}", address, value.ToString()), ex);
|
fre.result = false;
|
fre.resMsg = "写入异常:" + ex.Message;
|
return fre;
|
}
|
}
|
|
/// <summary>
|
/// S7读取
|
/// </summary>
|
/// <param name="address">地址</param>
|
/// <param name="type"></param>
|
/// <returns></returns>
|
public override object ReadValuePoint(string dbNumber, string offset, Type type)
|
{
|
var address = GetAddress(dbNumber, offset, type);
|
object objReuslt = null;
|
try
|
{
|
objReuslt = plcS7.Read(address);
|
ValidateReusltForRead(objReuslt, address);
|
if (type == typeof(Char))
|
{//特别处理char类型
|
char _plcData = (char)Convert.ToInt32(objReuslt);
|
objReuslt = _plcData.ToString();
|
}
|
else if (type == typeof(double))
|
{
|
objReuslt = ((uint)objReuslt).ConvertToDouble();
|
}
|
else if (type == typeof(bool))
|
{
|
return Convert.ToBoolean(objReuslt);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SS7, String.Format("读取出现异常:" + ex.Message + "，地址:{0}", address), ex);
|
throw;
|
}
|
return objReuslt;
|
|
}
|
|
public override string GetAddress(string dbNumber, string offset, Type type = default(Type))
|
{
|
var address = "";
|
if (type == typeof(bool))
|
{//布尔要转换成1和0写入
|
address = "DB" + dbNumber + "." + "DBX" + offset;
|
}
|
//浮点
|
else if (type == typeof(double) || type == typeof(float))
|
{
|
address = "DB" + dbNumber + "." + "DBD" + offset;
|
}
|
//整数
|
else if (type == typeof(Int32) || type == typeof(short))
|
{
|
address = "DB" + dbNumber + "." + "DBW" + offset;
|
}
|
//双整数
|
else if (type == typeof(Int32))
|
{
|
address = "DB" + dbNumber + "." + "DBD" + offset;
|
}
|
//Char
|
else if (type == typeof(Char))
|
{//char要转换成int类型，写给PLC
|
address = "DB" + dbNumber + "." + "DBB" + offset;
|
}
|
else
|
{
|
address = "DB" + dbNumber + "." + "DBW" + offset;
|
}
|
return address;
|
}
|
|
public override void Close()
|
{
|
if (plcS7 != null)
|
plcS7.Close();
|
}
|
|
#region 私有方法
|
|
/// <summary>
|
/// 验证结果（读取）
|
/// </summary>
|
/// <param name="objReuslt"></param>
|
private void ValidateReusltForRead(Object objReuslt, string address)
|
{
|
if (objReuslt.GetType() == typeof(ErrorCode))
|
{
|
ErrorCode errCode = (ErrorCode)objReuslt;
|
if (errCode != ErrorCode.NoError)
|
{
|
throw new Exception(String.Format("读取" + address + "出现异常：" + errCode.ToString()));
|
}
|
}
|
}
|
|
/// <summary>
|
/// 验证结果（写入）
|
/// </summary>
|
/// <param name="objReuslt"></param>
|
private void ValidateReusltForWrite(Object objReuslt, string address)
|
{
|
if (objReuslt.GetType() == typeof(ErrorCode))
|
{
|
ErrorCode errCode = (ErrorCode)objReuslt;
|
if (errCode != ErrorCode.NoError)
|
{
|
throw new Exception(String.Format("写入" + address + "出现异常：" + errCode.ToString()));
|
}
|
}
|
}
|
|
#endregion
|
}
|
}
|
