|
@@ -114,36 +114,5 @@ namespace WCS.WorkEngineering.WebApi.Models.AGV.Request
|
|
|
/// </summary>
|
|
|
public string eqpCode { get; set; }
|
|
|
|
|
|
- /// <summary>
|
|
|
- /// 执行堆垛机任务 单例锁
|
|
|
- /// </summary>
|
|
|
- /// <param name="act"></param>
|
|
|
- public void EX(Action<AgvCallbackRequest> act)
|
|
|
- {
|
|
|
- var key = $"WCS:Lock:{act.}";
|
|
|
-
|
|
|
- try
|
|
|
- {
|
|
|
- if (ProtocolProxy.YG150Redis.Get(key) != null) throw new WarnException($"[{Entity.CODE}]--触发并发管控");
|
|
|
- ProtocolProxy.YG150Redis.Set(key, Entity.CODE);
|
|
|
- act(this);
|
|
|
- }
|
|
|
- catch (DoException ex)
|
|
|
- {
|
|
|
- ex.DoExceptionEX(Entity);
|
|
|
- }
|
|
|
- catch (WarnException ex)
|
|
|
- {
|
|
|
- ex.WarnExceptionEX(Entity);
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- ex.ExceptionEx(Entity);
|
|
|
- }
|
|
|
- finally
|
|
|
- {
|
|
|
- ProtocolProxy.YG150Redis.Del(key);
|
|
|
- }
|
|
|
- }
|
|
|
}
|
|
|
}
|