using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
|
namespace XImaging.Automation.Library.HxDriverLib.Messaging
|
{
|
public class BiosenDriverMessage : IMessage
|
{
|
#region 消息类型定义
|
/// <summary>
|
/// 消息类型0: 心跳包
|
/// </summary>
|
public static int MESSAGE_TYPE_HEARTBEAT { get; } = 0;
|
/// <summary>
|
/// 消息类型1：方法消息（延迟返回消息）
|
/// </summary>
|
public static int MESSAGE_TYPE_TASK { get; } = 1;
|
/// <summary>
|
/// 消息类型2：查询方法消息（即时返回消息）
|
/// </summary>
|
public static int MESSAGE_TYPE_QUERY { get; } = 2;
|
/// <summary>
|
/// 消息类型3：错误处理消息（无返回消息）
|
/// </summary>
|
public static int MESSAGE_TYPE_TROUBLESHOOT { get; } = 3;
|
/// <summary>
|
/// 消息类型4：确认消息
|
/// </summary>
|
public static int MESSAGE_TYPE_ACK { get; } = 4;
|
/// <summary>
|
/// 消息类型5：完成消息
|
/// </summary>
|
public static int MESSAGE_TYPE_FINISH { get; } = 5;
|
#endregion
|
|
#region 方法状态定义
|
public static int METHOD_STATUS_NULL { get; } = -1;
|
/// <summary>
|
/// 方法状态0：准备执行（指令队列中）
|
/// </summary>
|
public static int METHOD_STATUS_SCHEDULED { get; } = 0;
|
/// <summary>
|
/// 方法状态1：正在执行
|
/// </summary>
|
public static int METHOD_STATUS_INPROGRES { get; } = 1;
|
/// <summary>
|
/// 方法状态2：执行完成且成功
|
/// </summary>
|
public static int METHOD_STATUS_COMPLETED { get; } = 2;
|
/// <summary>
|
/// 方法状态3：执行完成且失败
|
/// </summary>
|
public static int METHOD_STATUS_FAILED { get; } = 3;
|
/// <summary>
|
/// 方法状态4：该方法在指令队列中被取消
|
/// </summary>
|
public static int METHOD_STATUS_CANCELED { get; } = 4;
|
#endregion
|
|
protected string m_strGUID;
|
protected int m_strEndpoint;
|
protected JObject m_jsonOriginMessage;
|
protected string m_strMessageID;
|
protected int m_iMessageType;
|
protected string m_strMethod;
|
protected string m_strEquipmentID;
|
protected string m_strWorkflowID;
|
protected string m_strExperimentID;
|
protected JObject m_jsonParameters;
|
protected int m_iTroubleshoot;
|
protected string m_strTimestamp;
|
|
public string GUID { get { return m_strGUID; } }
|
|
public int LocalEndpoint { get { return m_strEndpoint; } }
|
|
/// <summary>
|
/// 消息ID，唯一
|
/// </summary>
|
public string MessageID { get { return m_strMessageID; } }
|
/// <summary>
|
/// 消息类型，见定义
|
/// </summary>
|
public int MessageType { get { return m_iMessageType; } }
|
/// <summary>
|
/// 方法名称
|
/// </summary>
|
public string Method { get { return m_strMethod; } }
|
/// <summary>
|
/// 设备ID
|
/// </summary>
|
public string EquipmentID { get { return m_strEquipmentID; } }
|
/// <summary>
|
/// 工作流ID
|
/// </summary>
|
public string WorkflowID { get { return m_strWorkflowID; } }
|
/// <summary>
|
///
|
/// </summary>
|
public string ExperimentID { get { return m_strExperimentID; } }
|
/// <summary>
|
/// 消息生成时间
|
/// </summary>
|
public string Timestamp { get { return m_strTimestamp; } }
|
}
|
|
public class ReqMessage : BiosenDriverMessage
|
{
|
#region 私有成员
|
|
protected string m_strDescription;
|
protected int m_iEstimateTime;
|
protected int m_iTimeout;
|
protected long m_lExpiredTime;
|
|
#endregion
|
/// <summary>
|
/// 原始消息
|
/// </summary>
|
public JObject OriginJSON { get { return m_jsonOriginMessage; } }
|
|
/// <summary>
|
/// 方法需要的参数
|
/// </summary>
|
public JObject Parameters { get { return m_jsonParameters; } }
|
/// <summary>
|
///
|
/// </summary>
|
public int Troubleshoot { get { return m_iTroubleshoot; } }
|
/// <summary>
|
/// 方法描述文字
|
/// </summary>
|
public string Description { get { return m_strDescription; } }
|
|
public int EstimateTime { get { return m_iEstimateTime; } }
|
|
public int Timeout { get { return m_iTimeout; } }
|
/// <summary>
|
/// 消息逾期时间
|
/// </summary>
|
public long ExpiredTime { get { return m_lExpiredTime; } }
|
|
/// <summary>
|
/// 构造类1
|
/// </summary>
|
/// <param name="message"></param>
|
public ReqMessage(string message)
|
{
|
JObject obj = (JObject)JsonConvert.DeserializeObject(message);
|
LogConstant.logger.Print("Parse message " + message + " to HxMessage.");
|
|
this.m_jsonOriginMessage = obj;
|
this.m_strGUID = obj["guid"].ToString();
|
this.m_strEndpoint = obj.Value<int>("endpoint");
|
this.m_strMessageID = obj["message_id"].ToString();
|
this.m_iMessageType = obj.Value<int>("message_type");
|
this.m_strEquipmentID = obj["equipment_id"].ToString();
|
|
if (this.MessageType != MESSAGE_TYPE_HEARTBEAT)
|
{
|
this.m_strWorkflowID = obj["workflow_id"].ToString();
|
this.m_strExperimentID = obj["experiment_id"].ToString();
|
this.m_strMethod = obj["method"].ToString();
|
this.m_strDescription = obj["description"].ToString();
|
}
|
|
if (this.MessageType == MESSAGE_TYPE_TASK || this.MessageType == MESSAGE_TYPE_QUERY)
|
{
|
this.m_jsonParameters = (JObject)obj["parameters"];
|
this.m_iEstimateTime = obj.Value<int>("estimate_time");
|
this.m_iTimeout = obj.Value<int>("timeout");
|
}
|
else
|
{
|
this.m_jsonParameters = null;
|
this.m_iEstimateTime = 0;
|
this.m_iTimeout = 0;
|
}
|
|
if (this.MessageType == MESSAGE_TYPE_TROUBLESHOOT)
|
this.m_iTroubleshoot = obj.Value<int>("troubleshoot");
|
else
|
this.m_iTroubleshoot = 0;
|
|
this.m_lExpiredTime = obj.Value<long>("expired");
|
this.m_strTimestamp = obj["timestamp"].ToString();
|
}
|
}
|
|
public class ResMessage : BiosenDriverMessage
|
{
|
#region 私有成员
|
private JObject m_jsonData;
|
private int m_iMethodStatus;
|
private string m_strErrorCode;
|
private string m_strErrorText;
|
|
#endregion
|
/// <summary>
|
/// 方法需要的参数
|
/// </summary>
|
public JObject Data { get { return m_jsonData; } }
|
/// <summary>
|
///
|
/// </summary>
|
public int MethodStatus { get { return m_iMethodStatus; } }
|
/// <summary>
|
/// 错误码
|
/// </summary>
|
public string ErrorCode { get { return m_strErrorCode; } }
|
/// <summary>
|
/// 错误描述
|
/// </summary>
|
public string ErrorText { get { return m_strErrorText; } }
|
/// <summary>
|
/// 错误处理方案
|
/// </summary>
|
public int Troubleshoot { get { return m_iTroubleshoot; } }
|
|
public ResMessage(string message)
|
{
|
JObject obj = (JObject)JsonConvert.DeserializeObject(message);
|
LogConstant.logger.Print("Parse message " + message + " to HxMessage.");
|
|
this.m_strGUID = obj["guid"].ToString();
|
|
if (obj.ContainsKey("endpoint"))
|
this.m_strEndpoint = obj.Value<int>("endpoint");
|
else
|
this.m_strEndpoint = 0;
|
|
this.m_strMessageID = obj["message_id"].ToString();
|
this.m_iMessageType = obj.Value<int>("message_type");
|
this.m_strEquipmentID = obj["equipment_id"].ToString();
|
|
if (this.MessageType != MESSAGE_TYPE_HEARTBEAT)
|
{
|
this.m_strWorkflowID = obj["workflow_id"].ToString();
|
this.m_strExperimentID = obj["experiment_id"].ToString();
|
this.m_strMethod = obj["method"].ToString();
|
}
|
|
if (this.MessageType == MESSAGE_TYPE_FINISH)
|
{
|
this.m_jsonData = (JObject)obj["data"];
|
this.m_iMethodStatus = obj.Value<int>("method_status");
|
|
if (this.MethodStatus == METHOD_STATUS_COMPLETED)
|
{
|
this.m_strErrorCode = "";
|
this.m_strErrorText = "";
|
this.m_iTroubleshoot = 0;
|
}
|
else
|
{
|
this.m_strErrorCode = obj["error_code"].ToString();
|
this.m_strErrorText = obj["error_text"].ToString();
|
this.m_iTroubleshoot = obj.Value<int>("troubleshoot");
|
}
|
}
|
else
|
{
|
this.m_jsonData = null;
|
this.m_iMethodStatus = METHOD_STATUS_NULL;
|
this.m_strErrorCode = null;
|
this.m_strErrorText = null;
|
this.m_iTroubleshoot = 0;
|
}
|
|
this.m_strTimestamp = obj["timestamp"].ToString();
|
}
|
}
|
|
public class PostMessage
|
{
|
#region 私有成员
|
private string m_strMessageType;
|
private string m_strMessageID;
|
private string m_strEquipmentID;
|
private string m_strWorkflowID;
|
private string m_strExperimentID;
|
private string m_strMethodMessageID;
|
private string m_strMethod;
|
// private JObject m_jsonData;
|
private string m_strTimestamp;
|
#endregion
|
|
public string MessageType { get { return this.m_strMessageType; } }
|
public string MessageID { get { return this.m_strMessageID; } }
|
public string EquipmentID { get { return this.m_strEquipmentID; } }
|
public string WorkflowID { get { return this.m_strWorkflowID; } }
|
|
public string ExperimentID { get { return this.m_strExperimentID; } }
|
public string MethodMessageID { get { return this.m_strMethodMessageID; } }
|
public string Method { get { return this.m_strMethod; } }
|
// public JObject Data { get { return this.m_jsonData; } }
|
public string Timestamp { get { return this.m_strTimestamp; } }
|
|
public PostMessage(ReqMessage rMessage)
|
{
|
this.m_strMessageID = Guid.NewGuid().ToString();
|
this.m_strEquipmentID = rMessage.EquipmentID;
|
this.m_strWorkflowID = rMessage.WorkflowID;
|
this.m_strExperimentID = rMessage.ExperimentID;
|
this.m_strMethodMessageID = rMessage.MessageID;
|
this.m_strMethod = rMessage.Method;
|
this.m_strTimestamp = DateTime.Now.ToString();
|
}
|
|
public virtual JObject ToJObject()
|
{
|
return JObject.FromObject(new { });
|
}
|
}
|
|
public class DataObjectMessage : PostMessage
|
{
|
private string m_strMessageType;
|
private JObject m_jsonData;
|
|
public new string MessageType { get { return this.m_strMessageType; } }
|
|
public JObject Data { get { return this.m_jsonData; } }
|
|
public DataObjectMessage(ReqMessage rMessage, JObject obj) : base(rMessage)
|
{
|
this.m_strMessageType = "data";
|
this.m_jsonData = obj;
|
}
|
|
public override JObject ToJObject()
|
{
|
JObject obj = JObject.FromObject(
|
new
|
{
|
message_type = MessageType,
|
message_id = MessageID,
|
method = Method,
|
equipment_id = EquipmentID,
|
workflow_id = WorkflowID,
|
experiment_id = ExperimentID,
|
method_message_id = MethodMessageID,
|
data = Data,
|
timestamp = DateTime.Now
|
}
|
);
|
return obj;
|
}
|
|
public override string ToString()
|
{
|
return this.ToJObject().ToString();
|
}
|
}
|
|
|
public class FileObjectMessage : PostMessage
|
{
|
private string m_strMessageType;
|
private string m_strFilepath;
|
|
public new string MessageType { get { return this.m_strMessageType; } }
|
|
public string FilePath { get { return this.m_strFilepath; } }
|
|
public FileObjectMessage(ReqMessage rMessage, string fileFullPath) : base(rMessage)
|
{
|
this.m_strMessageType = "file";
|
this.m_strFilepath = fileFullPath;
|
}
|
|
public override JObject ToJObject()
|
{
|
JObject obj = JObject.FromObject(
|
new
|
{
|
message_type = MessageType,
|
message_id = MessageID,
|
method = Method,
|
equipment_id = EquipmentID,
|
workflow_id = WorkflowID,
|
experiment_id = ExperimentID,
|
method_message_id = MethodMessageID,
|
file = m_strFilepath,
|
timestamp = DateTime.Now
|
}
|
);
|
return obj;
|
}
|
|
public override string ToString()
|
{
|
return this.ToJObject().ToString();
|
}
|
}
|
|
public class ErrorObjectMessage : PostMessage
|
{
|
private string m_strMessageType;
|
private JObject m_jsonError;
|
public new string MessageType { get { return this.m_strMessageType; } }
|
public JObject Data { get { return this.m_jsonError; } }
|
|
public ErrorObjectMessage(ReqMessage rMessage, JObject obj) : base(rMessage)
|
{
|
this.m_strMessageType = "error";
|
this.m_jsonError = obj;
|
}
|
|
public override JObject ToJObject()
|
{
|
return this.m_jsonError;
|
}
|
|
public override string ToString()
|
{
|
return this.ToJObject().ToString();
|
}
|
}
|
|
}
|
