using Apache.NMS;
|
using Apache.NMS.ActiveMQ;
|
using Rhea.Common;
|
using Tiger.Model;
|
using Tiger.Model.SeaStone.Shelf;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using System.IO;
|
using Newtonsoft.Json;
|
using Tiger.Business.WMS.Seastone;
|
using Tiger.IBusiness;
|
using Tiger.Model.Entitys.MES.Position;
|
|
namespace Tiger.Business.WMS.Transaction
|
{
|
/// <summary>
|
/// WMS事务基类
|
/// </summary>
|
public abstract class WMSTransactionBase : TransactionBase, IWMSTransaction
|
{
|
/// <summary>
|
/// WMS事务基类
|
/// </summary>
|
public WMSTransactionBase()
|
{
|
//MQTTThread = new Thread(new ThreadStart(MQTT));
|
//MQTTThread.Start();
|
//Logger.Console.Info($"Start Transaction MQTT Thread(ID: {TransID}]");
|
}
|
|
/// <summary>
|
/// 关闭事务
|
/// </summary>
|
/// <param name="needSaveHistoryLog"></param>
|
/// <returns></returns>
|
public override bool Close(bool needSaveHistoryLog = false)
|
{
|
return base.Close(needSaveHistoryLog);
|
}
|
|
public override void Dispose()
|
{
|
try
|
{
|
//MQTTThread?.Abort();
|
//删除使用的MQTT Topic
|
//MQTTHelper.DeleteTopic(TransID);
|
Logger.Console.Info($"Dispose Transaction(ID: {TransID}]");
|
}
|
catch (System.Exception ex)
|
{
|
Logger.Console.Fatal(ex, $"Dispose Transaction Exception(ID: {TransID}]");
|
}
|
base.Dispose();
|
}
|
|
#region WMS业务
|
/// <summary>
|
/// 执行中条码
|
/// </summary>
|
public string ProcessingSn { get; set; }
|
/// <summary>
|
/// 执行中单据明细
|
/// </summary>
|
public string ProcessingOrderDetail { get; set; }
|
/// <summary>
|
/// 重置事务操作
|
/// </summary>
|
/// <returns></returns>
|
public ApiAction Reset()
|
{
|
var action = new ApiAction();
|
|
ResetTrans();
|
action.IsSuccessed = true;
|
//action.LocaleMsg = new($"操作已重置，请重新扫描");
|
action.LocaleMsg = new("WMS.Transaction.Reset");
|
|
return action;
|
}
|
/// <summary>
|
/// 重置事务数据，有需要则重写此方法
|
/// </summary>
|
public virtual void ResetTrans()
|
{
|
ProcessingSn = null;
|
}
|
#endregion
|
|
#region MQTT
|
/// <summary>
|
/// 设置当前条码的MQTT信息
|
/// </summary>
|
public ApiAction<ScanOutput> SetOutPutMqttMsg(ApiAction<ScanOutput> action, string locale = null)
|
{
|
MQTT.Message msg = new()
|
{
|
IsSuccessed = action.IsSuccessed,
|
Content = Biz.T(action.LocaleMsg, locale),
|
};
|
switch (action.Status)
|
{
|
case ApiAction.StatusCodes.Success:
|
msg.Voice = MQTT.Voice.Success;
|
msg.Color = "#FF1E90FF";
|
break;
|
case ApiAction.StatusCodes.Warning:
|
msg.Voice = MQTT.Voice.Warning;
|
msg.Color = "#FFB8860B";
|
break;
|
case ApiAction.StatusCodes.Error:
|
case ApiAction.StatusCodes.Failed:
|
msg.Voice = MQTT.Voice.Fail;
|
msg.Color = "#FFFF0000";
|
break;
|
case ApiAction.StatusCodes.Exception:
|
msg.Voice = MQTT.Voice.Fail;
|
msg.Color = "#FF8B0000";
|
break;
|
case ApiAction.StatusCodes.Normal:
|
case ApiAction.StatusCodes.NeedConfrim:
|
case ApiAction.StatusCodes.Confrimed:
|
default:
|
msg.Voice = MQTT.Voice.Silent;
|
msg.Color = "#FF000000";
|
break;
|
}
|
if (action.IsSuccessed)
|
{
|
msg.Voice = MQTT.Voice.Success;
|
msg.Color = "#FF228B22";
|
}
|
else if (!action.IsSuccessed)
|
{
|
msg.Voice = MQTT.Voice.Fail;
|
msg.Color = "#FFFF0000";
|
}
|
else
|
{
|
msg.Voice = MQTT.Voice.Silent;
|
msg.Color = "#FF000000";
|
}
|
action.Data.MqttMsg = msg;
|
return action;
|
}
|
|
private Thread MQTTThread;
|
private void Mqtt()
|
{
|
try
|
{
|
//Create the Connection factory
|
IConnectionFactory factory = new ConnectionFactory(ApiConfig.Configuration["MQTTService:IPAddress"]);
|
|
//Create the connection
|
using (IConnection connection = factory.CreateConnection())
|
{
|
connection.ClientId = $"{Environment.MachineName}-Receive-{TransID}";
|
connection.Start();
|
|
//Create the Session
|
using (ISession session = connection.CreateSession())
|
{
|
//Create the Consumer
|
IMessageConsumer consumer = session.CreateConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQTopic(TransID));
|
consumer.Listener += new MessageListener(consumer_Listener);
|
while (!IsFinished)
|
{
|
|
}
|
}
|
connection.Stop();
|
connection.Close();
|
}
|
}
|
catch (System.Exception e)
|
{
|
Console.WriteLine(e.Message);
|
}
|
}
|
private string ReceiveMsg;
|
private void consumer_Listener(IMessage message)
|
{
|
try
|
{
|
ITextMessage msg = (ITextMessage)message;
|
Console.WriteLine("MQTT Receive: " + msg.Text);
|
}
|
catch (System.Exception e)
|
{
|
Console.WriteLine(e.Message);
|
}
|
}
|
|
#endregion
|
}
|
}
|
