120 lines
3.4 KiB
C#
120 lines
3.4 KiB
C#
using MECF.Framework.Common.Fsm;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using Aitex.Core.RT.DataCenter;
|
||
using Aitex.Core.RT.Event;
|
||
using Aitex.Core.RT.OperationCenter;
|
||
using Aitex.Core.RT.SCCore;
|
||
using MECF.Framework.Common.Equipment;
|
||
|
||
namespace MECF.Framework.RT.Core
|
||
{
|
||
public abstract class OfflineTimeoutNotifiableModuleBase : ModuleFsmDevice
|
||
{
|
||
#region Variables
|
||
|
||
private CancellationTokenSource _notifyModuleOfflineCancellation;
|
||
|
||
#endregion
|
||
|
||
#region Constructors
|
||
|
||
public OfflineTimeoutNotifiableModuleBase()
|
||
{
|
||
IsStayOfflineTimeout = false;
|
||
_notifyModuleOfflineCancellation = new CancellationTokenSource();
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region Properties
|
||
|
||
public bool IsStayOfflineTimeout { get; protected set; }
|
||
|
||
public virtual bool IsBusy => false;
|
||
|
||
#endregion
|
||
|
||
#region Methods
|
||
|
||
|
||
protected virtual void InitOp()
|
||
{
|
||
OP.Subscribe($"{Module}.SetOnline", (string cmd, object[] args) => PutOnline());
|
||
OP.Subscribe($"{Module}.SetOffline", (string cmd, object[] args) => PutOffline());
|
||
}
|
||
|
||
protected virtual void InitData()
|
||
{
|
||
// PM1.Status需要特殊处理，已在PMModule中添加。
|
||
if(DATA.Poll(Module, "Status") == null)
|
||
DATA.Subscribe($"{Module}.Status", () => StringFsmStatus);
|
||
|
||
DATA.Subscribe($"{Module}.IsOnline", () => IsOnline);
|
||
DATA.Subscribe($"{Module}.IsOfflineTimeout", () => IsStayOfflineTimeout);
|
||
DATA.Subscribe($"{Module}.IsBusy", () => IsBusy);
|
||
}
|
||
|
||
protected virtual bool PutOnline()
|
||
{
|
||
IsStayOfflineTimeout = false;
|
||
IsOnline = true;
|
||
_notifyModuleOfflineCancellation.Cancel();
|
||
return true;
|
||
}
|
||
|
||
protected virtual bool PutOffline()
|
||
{
|
||
// 是否在Auto模式，仅Auto模式启用超时机制
|
||
var sta = DATA.Poll("Rt.Status").ToString();
|
||
|
||
IsOnline = false;
|
||
IsStayOfflineTimeout = false;
|
||
|
||
if (sta != "AutoRunning" && sta != "AutoIdle")
|
||
return true;
|
||
|
||
// 如果是Auto模式，启用超时机制。
|
||
var timeoutSec = SC.GetValue<int>("System.ModuleOfflineTimeout");
|
||
if (timeoutSec <= 0)
|
||
timeoutSec = 0;
|
||
|
||
if (timeoutSec > 0)
|
||
{
|
||
_notifyModuleOfflineCancellation?.Dispose();
|
||
_notifyModuleOfflineCancellation = new CancellationTokenSource();
|
||
NotifyModuleOfflineTask(timeoutSec * 1000);
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
private Task NotifyModuleOfflineTask(int delayTime)
|
||
{
|
||
var t1 = Task.Run(async () =>
|
||
{
|
||
await Task.Delay(delayTime, _notifyModuleOfflineCancellation.Token).ContinueWith(
|
||
x =>
|
||
{
|
||
IsStayOfflineTimeout = true;
|
||
EV.PostWarningLog(Module, $"{Module} offline timeout");
|
||
},
|
||
_notifyModuleOfflineCancellation.Token);
|
||
});
|
||
return t1;
|
||
}
|
||
|
||
public void InvokeOffline()
|
||
{
|
||
PutOffline();
|
||
}
|
||
|
||
public void InvokeOnline()
|
||
{
|
||
PutOnline();
|
||
}
|
||
|
||
#endregion
|
||
}
|
||
}
|