diff --git a/Sln.Iot.CFX/CFXBusiness/CFXUnitProcessedDataGet.cs b/Sln.Iot.CFX/CFXBusiness/CFXUnitProcessedDataGet.cs index 9cc23d0..ed9050f 100644 --- a/Sln.Iot.CFX/CFXBusiness/CFXUnitProcessedDataGet.cs +++ b/Sln.Iot.CFX/CFXBusiness/CFXUnitProcessedDataGet.cs @@ -203,18 +203,53 @@ namespace Sln.Iot.CFX.CFXBusiness { Zone = new CommonUseZone() { - ZoneName = "Zone1", + ZoneName = "Zone", StageSequence = 1, StageName = "Conveyor1" }, }, + //new CommonUseZoneData() + //{ + // Zone = new CommonUseZone() + // { + // ZoneName = "Zone2", + // StageSequence = 2, + // StageName = "Conveyor2" + // }, + //} + } + }; + + return processData; + } + + /// + /// 升降回流数据 + /// + /// + public CommonProcessData ProcessDataGet4() + { + CommonProcessData processData = new CommonProcessData() + { + ZoneData = new List + { + //new CommonUseZoneData() + //{ + // Zone = new CommonUseZone() + // { + // ZoneName = "Zone1", + // StageSequence = 1, + // StageName = "Conveyor1" + + // }, + //}, new CommonUseZoneData() { Zone = new CommonUseZone() { - ZoneName = "Zone2", - StageSequence = 2, + ZoneName = "Zone", + StageSequence = 1, StageName = "Conveyor2" }, } diff --git a/Sln.Iot.CFX/CFXConnect/CFXConnect1.cs b/Sln.Iot.CFX/CFXConnect/CFXConnect1.cs index 34e4230..6f3bbb5 100644 --- a/Sln.Iot.CFX/CFXConnect/CFXConnect1.cs +++ b/Sln.Iot.CFX/CFXConnect/CFXConnect1.cs @@ -40,7 +40,7 @@ namespace Sln.Iot.CFX.CFXConnect CFXEventTools cFXEventTools = CFXEventTools.Instance; - public string CFXHandle { get; set; } = "CFX.A00.SDSH000001"; + public string CFXHandle { get; set; } = "CFX.A00.OT00470018"; protected override CFXMessage HandleRequest(CFXEnvelope request) { diff --git a/Sln.Iot.CFX/CFXConnect/CFXConnect2.cs b/Sln.Iot.CFX/CFXConnect/CFXConnect2.cs index a82e9d9..bf81a00 100644 --- a/Sln.Iot.CFX/CFXConnect/CFXConnect2.cs +++ b/Sln.Iot.CFX/CFXConnect/CFXConnect2.cs @@ -42,7 +42,7 @@ namespace Sln.Iot.CFX.CFXConnect CFXEventTools cFXEventTools = CFXEventTools.Instance; - public string CFXHandle { get; set; } = "SDSH000002"; + public string CFXHandle { get; set; } = "CFX.A00.OT00470019"; protected override CFXMessage HandleRequest(CFXEnvelope request) { @@ -112,7 +112,7 @@ namespace Sln.Iot.CFX.CFXConnect var validateresult = Endpoint.ExecuteRequest(uri, new CFXEnvelope(msg) { Source = Endpoint.CFXHandle, - Target = "CFX.A00.SDSH000002" + Target = "inline-control" }); if (validateresult == null) diff --git a/Sln.Iot.CFX/CFXConnect/CFXConnect3.cs b/Sln.Iot.CFX/CFXConnect/CFXConnect3.cs index 8f3beca..1f45799 100644 --- a/Sln.Iot.CFX/CFXConnect/CFXConnect3.cs +++ b/Sln.Iot.CFX/CFXConnect/CFXConnect3.cs @@ -42,7 +42,7 @@ namespace Sln.Iot.CFX.CFXConnect CFXEventTools cFXEventTools = CFXEventTools.Instance; - public string CFXHandle { get; set; } = "SDSH000003"; + public string CFXHandle { get; set; } = "CFX.A00.OT00470017"; protected override CFXMessage HandleRequest(CFXEnvelope request) { @@ -112,7 +112,7 @@ namespace Sln.Iot.CFX.CFXConnect var validateresult = Endpoint.ExecuteRequest(uri, new CFXEnvelope(msg) { Source = Endpoint.CFXHandle, - Target = "CFX.A00.SDSH000003" + Target = "inline-control" }); if (validateresult == null) diff --git a/Sln.Iot.CFX/CFXConnect/CFXConnect4.cs b/Sln.Iot.CFX/CFXConnect/CFXConnect4.cs new file mode 100644 index 0000000..eac3d15 --- /dev/null +++ b/Sln.Iot.CFX/CFXConnect/CFXConnect4.cs @@ -0,0 +1,132 @@ +using CFX.InformationSystem.UnitValidation; +using CFX.ResourcePerformance; +using CFX.Structures; +using CFX; +using Sln.Iot.CFX.RequestReceived; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using CFX.Production; +using Sln.Iot.CFX.CFXRequestes; +using Sln.Iot.CFX.CFXBusiness; +using Sln.Iot.CFX.Event; + +namespace Sln.Iot.CFX.CFXConnect +{ + /// + /// 提升机2连接 + /// + public class CFXConnect4 : CFXHelper + { + private static readonly Lazy lazy = new Lazy(() => new CFXConnect4()); + + public static CFXConnect4 Instance + { + get + { + return lazy.Value; + } + } + + AreYouThereRequestReceived4 areYouThereRequestReceived4 = new AreYouThereRequestReceived4(); + GetEndpointInformationRequestReceived4 getEndpointInformationRequestReceived4 = new GetEndpointInformationRequestReceived4(); + WhoIsThereRequestReceived4 whoIsThereRequestReceived4 = new WhoIsThereRequestReceived4(); + GetActiveRecipeRequestReceived4 getActiveRecipeRequestReceived4 = new GetActiveRecipeRequestReceived4(); + GetActiveFaultsRequestReceived4 getActiveFaultsRequestReceived4 = new GetActiveFaultsRequestReceived4(); + HandleFaultRequestReceived4 handleFaultRequestReceived4 = new HandleFaultRequestReceived4(); + ModifyStationParametersRequestReceived4 modifyStationParametersRequestReceived4 = new ModifyStationParametersRequestReceived4(); + + //HeartbeatEvent heartbeatEvent = new HeartbeatEvent(); + + CFXEventTools cFXEventTools = CFXEventTools.Instance; + + public string CFXHandle { get; set; } = "CFX.A00.OT00470020"; + + protected override CFXMessage HandleRequest(CFXEnvelope request) + { + CFXMessage response = null; + + if (request.MessageBody is AreYouThereRequest) //存在性检测请求 + { + areYouThereRequestReceived4.Handle(request.MessageBody as AreYouThereRequest, out response); + } + else if (request.MessageBody is GetEndpointInformationRequest) //获取终端节点信息请求 + { + getEndpointInformationRequestReceived4.Handle(request.MessageBody as GetEndpointInformationRequest, out response); + } + else if (request.MessageBody is WhoIsThereRequest) //设备存在性查询请求 + { + whoIsThereRequestReceived4.Handle(request.MessageBody as WhoIsThereRequest, out response); + } + else if (request.MessageBody is GetActiveRecipeRequest) //获取当前激活配方请求 + { + getActiveRecipeRequestReceived4.Handle(request.MessageBody as GetActiveRecipeRequest, out response); + } + else if (request.MessageBody is GetActiveFaultsRequest) //获取当前错误状态请求 + { + getActiveFaultsRequestReceived4.Handle(request.MessageBody as GetActiveFaultsRequest, out response); + } + else if (request.MessageBody is HandleFaultRequest) //处理错误请求 + { + handleFaultRequestReceived4.Handle(request.MessageBody as HandleFaultRequest, out response); + } + else if (request.MessageBody is ModifyStationParametersRequest) //设备修改参数请求 + { + modifyStationParametersRequestReceived4.Handle(request.MessageBody as ModifyStationParametersRequest, out response); + } + else //不支持的请求类型 + { + response = new NotSupportedResponse() + { + RequestResult = new RequestResult() + { + Result = StatusResult.Failed, + ResultCode = 0, + Message = $"不支持的请求类型:{request.MessageBody.GetType().Name}" + } + }; + } + + return response; + } + + /// + /// 发送生产单元验证请求接收通知 + /// + public void SendValidateUnitsRequest(string uri, string primaryIdentifier, string[] unitsIdentifier) + { + try + { + ValidateUnitsRequest msg = new ValidateUnitsRequest() + { + Validations = new List() + { + ValidationType.UnitTraceValidation, + }, + PrimaryIdentifier = primaryIdentifier, + Units = cFXEventTools.UnitPositionTrans(unitsIdentifier) + }; + + var validateresult = Endpoint.ExecuteRequest(uri, new CFXEnvelope(msg) + { + Source = Endpoint.CFXHandle, + Target = "inline-control" + }); + + if (validateresult == null) + { + return; + } + + var response = validateresult.MessageBody as ValidateUnitsResponse; + //响应逻辑 + } + catch (Exception ex) + { + + } + } + } +} diff --git a/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived1.cs b/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived1.cs index 1877e0d..fb9b775 100644 --- a/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived1.cs +++ b/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived1.cs @@ -52,7 +52,7 @@ public class AreYouThereRequestReceived1 : BaseAreYouThereRequestReceived Message = "", }, - CFXHandle = "CFX.A00.SDSH000001", + CFXHandle = "CFX.A00.OT00470018", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/" }; diff --git a/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived2.cs b/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived2.cs index bddc5d6..6a90ace 100644 --- a/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived2.cs +++ b/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived2.cs @@ -52,7 +52,7 @@ public class AreYouThereRequestReceived2 : BaseAreYouThereRequestReceived Message = "", }, - CFXHandle = "CFX.A00.SDSH000002", + CFXHandle = "CFX.A00.OT00470019", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/" }; diff --git a/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived3.cs b/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived3.cs index cd4760a..b75c2ef 100644 --- a/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived3.cs +++ b/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived3.cs @@ -52,7 +52,7 @@ public class AreYouThereRequestReceived3 : BaseAreYouThereRequestReceived Message = "", }, - CFXHandle = "CFX.A00.SDSH000003", + CFXHandle = "CFX.A00.OT00470017", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/" }; diff --git a/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived4.cs b/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived4.cs new file mode 100644 index 0000000..8ea5c98 --- /dev/null +++ b/Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived4.cs @@ -0,0 +1,63 @@ +#region << 版 本 注 释 >> + +/*-------------------------------------------------------------------- +* 版权所有 (c) 2025 WenJY 保留所有权利。 +* CLR版本:4.0.30319.42000 +* 机器名称:Mr.Wen's MacBook Pro +* 命名空间:Sln.Iot.CFX.CoreCommunications +* 唯一标识:8D142D51-E08D-42FC-8C59-4551A1B36306 +* +* 创建者:WenJY +* 电子邮箱: +* 创建时间:2025-10-24 14:58:25 +* 版本:V1.0.0 +* 描述: +* +*-------------------------------------------------------------------- +* 修改人: +* 时间: +* 修改说明: +* +* 版本:V1.0.0 +*--------------------------------------------------------------------*/ + +#endregion << 版 本 注 释 >> + +using CFX; +using CFX.Structures; +using Sln.Iot.CFX.RequestReceived; +using Sln.Iot.Serilog; + +namespace Sln.Iot.CFX.CFXRequestes; + +/// +/// 5.4.1.1-端点在位查询请求 +/// AreYouThereRequest/Response +/// +public class AreYouThereRequestReceived4 : BaseAreYouThereRequestReceived +{ + /// + /// 子类重写处理 + /// + /// + /// + public override CFXMessage SubHandle(AreYouThereRequest request) + { + CFXMessage response = new AreYouThereResponse() + { + Result = new RequestResult() + { + Result = StatusResult.Success, + ResultCode = 0, + Message = "", + }, + + CFXHandle = "CFX.A00.OT00470020", + RequestNetworkUri = "amqp://127.0.0.1:1235/", + RequestTargetAddress = "amqp://127.0.0.1:8888/" + }; + + return response; + } + +} \ No newline at end of file diff --git a/Sln.Iot.CFX/CFXRequestes/GetActiveFaultsRequestReceived4.cs b/Sln.Iot.CFX/CFXRequestes/GetActiveFaultsRequestReceived4.cs new file mode 100644 index 0000000..6d47d60 --- /dev/null +++ b/Sln.Iot.CFX/CFXRequestes/GetActiveFaultsRequestReceived4.cs @@ -0,0 +1,84 @@ +#region << 版 本 注 释 >> + +/*-------------------------------------------------------------------- +* 版权所有 (c) 2025 WenJY 保留所有权利。 +* CLR版本:4.0.30319.42000 +* 机器名称:Mr.Wen's MacBook Pro +* 命名空间:Sln.Iot.CFX +* 唯一标识:CB14024A-08C4-4FF4-BD6C-8E8667D00263 +* +* 创建者:WenJY +* 电子邮箱: +* 创建时间:2025-10-24 15:23:00 +* 版本:V1.0.0 +* 描述: +* +*-------------------------------------------------------------------- +* 修改人: +* 时间: +* 修改说明: +* +* 版本:V1.0.0 +*--------------------------------------------------------------------*/ + +#endregion << 版 本 注 释 >> + +using CFX; +using CFX.ResourcePerformance; +using CFX.Structures; +using Sln.Iot.CFX.RequestReceived; +using Sln.Iot.Repository.service; +using Sln.Iot.Serilog; + +namespace Sln.Iot.CFX.CFXRequestes; + +/// +/// 5.4.4.1.5 - 查询当前有无错误 +/// GetActiveFaultsRequest/Response +/// +public class GetActiveFaultsRequestReceived4 : BaseGetActiveFaultsRequestReceived +{ + private readonly ErrorService errorService = ErrorService.Instance; + + /// + /// 子类重写处理 + /// + /// + /// + public override CFXMessage SubHandle(GetActiveFaultsRequest request) + { + // 获取现在所有的错误 + var errorList = errorService.GetOvenList().ToList(); + + //List faults = new List(); + + //foreach (var fault in errorList) + //{ + // faults.Add(new Fault() + // { + // Description = fault.ErrorName, + // FaultCode = fault.ErrorCode, + // }); + //} + + CFXMessage response = new GetActiveFaultsResponse() + { + Result = new RequestResult() + { + Result = StatusResult.Success, + ResultCode = 0, + Message = "", + }, + ActiveFaults = new List() + { + new Fault() + { + Description = "测试错误1", + FaultCode = "5003", + } + } + }; + + return response; + } +} \ No newline at end of file diff --git a/Sln.Iot.CFX/CFXRequestes/GetActiveRecipeRequestReceived4.cs b/Sln.Iot.CFX/CFXRequestes/GetActiveRecipeRequestReceived4.cs new file mode 100644 index 0000000..ea5191c --- /dev/null +++ b/Sln.Iot.CFX/CFXRequestes/GetActiveRecipeRequestReceived4.cs @@ -0,0 +1,62 @@ +#region << 版 本 注 释 >> + +/*-------------------------------------------------------------------- +* 版权所有 (c) 2025 WenJY 保留所有权利。 +* CLR版本:4.0.30319.42000 +* 机器名称:Mr.Wen's MacBook Pro +* 命名空间:Sln.Iot.CFX +* 唯一标识:686D7EAB-9E42-43B2-B990-AF162E76F781 +* +* 创建者:WenJY +* 电子邮箱: +* 创建时间:2025-10-24 15:18:38 +* 版本:V1.0.0 +* 描述: +* +*-------------------------------------------------------------------- +* 修改人: +* 时间: +* 修改说明: +* +* 版本:V1.0.0 +*--------------------------------------------------------------------*/ + +#endregion << 版 本 注 释 >> + +using CFX; +using CFX.Production; +using CFX.Structures; +using Sln.Iot.CFX.RequestReceived; +using Sln.Iot.Serilog; + +namespace Sln.Iot.CFX.CFXRequestes; + +/// +/// 5.4.3.1.3 - 获取激活配方请求 +/// GetActiveRecipeRequest/Response +/// +public class GetActiveRecipeRequestReceived4 : BaseGetActiveRecipeRequestReceived +{ + /// + /// 子类重写处理 + /// + /// + /// + public override CFXMessage SubHandle(GetActiveRecipeRequest request) + { + CFXMessage response = new GetActiveRecipeResponse() + { + ActiveRecipeName = "No Recipe Device", + ActiveRecipeRevision = "1.0", + Result = new RequestResult() + { + Result = StatusResult.Success, + ResultCode = 0, + Message = "" + } + //配方数据 + }; + + return response; + } +} \ No newline at end of file diff --git a/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived1.cs b/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived1.cs index b9fe7d1..60119e3 100644 --- a/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived1.cs +++ b/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived1.cs @@ -55,14 +55,14 @@ public class GetEndpointInformationRequestReceived1 : BaseGetEndpointInformation }, EndpointInformation = new Endpoint() { - CFXHandle = "CFX.A00.SDSH000001", + CFXHandle = "CFX.A00.OT00470018", CFXVersion = "2.0", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/", - ModelNumber = "XYZ真空注胶机", + ModelNumber = "真空注胶机", NumberOfLanes = 1, Vendor = "木子贸易中山有限公司", - SerialNumber = "SDSH000001", + SerialNumber = "OT00470018", Stages = new List { new StageInformation() diff --git a/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived2.cs b/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived2.cs index 06c3d5b..e8a2ef2 100644 --- a/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived2.cs +++ b/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived2.cs @@ -55,14 +55,14 @@ public class GetEndpointInformationRequestReceived2 : BaseGetEndpointInformation }, EndpointInformation = new Endpoint() { - CFXHandle = "CFX.A00.SDSH000002", + CFXHandle = "CFX.A00.OT00470019", CFXVersion = "2.0", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/", - ModelNumber = "升降回流", + ModelNumber = "升降回流机-1", NumberOfLanes = 1, Vendor = "木子贸易中山有限公司", - SerialNumber = "SDSH000002", + SerialNumber = "OT00470019", Stages = new List { new StageInformation() @@ -74,15 +74,15 @@ public class GetEndpointInformationRequestReceived2 : BaseGetEndpointInformation StageSequence = 1, } }, - new StageInformation() - { - Stage = new Stage() - { - StageName = "ConveyorOut", - StageType = StageType.Work, - StageSequence = 2, - } - } + //new StageInformation() + //{ + // Stage = new Stage() + // { + // StageName = "ConveyorOut", + // StageType = StageType.Work, + // StageSequence = 2, + // } + //} }, SupportedTopics = CFXSupportedTopicList.SupportedTopics } diff --git a/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived3.cs b/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived3.cs index f1a700e..c88d8c8 100644 --- a/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived3.cs +++ b/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived3.cs @@ -55,14 +55,14 @@ public class GetEndpointInformationRequestReceived3 : BaseGetEndpointInformation }, EndpointInformation = new Endpoint() { - CFXHandle = "CFX.A00.SDSH000003", + CFXHandle = "CFX.A00.OT00470017", CFXVersion = "2.0", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/", ModelNumber = "隧道烤箱", NumberOfLanes = 1, Vendor = "木子贸易中山有限公司", - SerialNumber = "SDSH000003", + SerialNumber = "OT00470017", Stages = new List { new StageInformation() diff --git a/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived4.cs b/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived4.cs new file mode 100644 index 0000000..5172111 --- /dev/null +++ b/Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived4.cs @@ -0,0 +1,93 @@ +#region << 版 本 注 释 >> + +/*-------------------------------------------------------------------- +* 版权所有 (c) 2025 WenJY 保留所有权利。 +* CLR版本:4.0.30319.42000 +* 机器名称:Mr.Wen's MacBook Pro +* 命名空间:Sln.Iot.CFX.CoreCommunications +* 唯一标识:4063233D-BE40-415F-B28C-EBA14C47EA52 +* +* 创建者:WenJY +* 电子邮箱: +* 创建时间:2025-10-24 15:00:21 +* 版本:V1.0.0 +* 描述: +* +*-------------------------------------------------------------------- +* 修改人: +* 时间: +* 修改说明: +* +* 版本:V1.0.0 +*--------------------------------------------------------------------*/ + +#endregion << 版 本 注 释 >> + +using CFX; +using CFX.Structures; +using Sln.Iot.CFX.CFXBusiness; +using Sln.Iot.CFX.RequestReceived; +using Sln.Iot.Serilog; + +namespace Sln.Iot.CFX.CFXRequestes; + +/// +/// 5.4.1.4 - 获取端点信息请求 +/// GetEndpointInformationRequest/Response +/// +public class GetEndpointInformationRequestReceived4 : BaseGetEndpointInformationRequestReceived +{ + + /// + /// 子类重写处理 + /// + /// + /// + public override CFXMessage SubHandle(GetEndpointInformationRequest request) + { + CFXMessage response = new GetEndpointInformationResponse() + { + Result = new RequestResult() + { + Result = StatusResult.Success, + ResultCode = 0, + Message = "", + }, + EndpointInformation = new Endpoint() + { + CFXHandle = "CFX.A00.OT00470020", + CFXVersion = "2.0", + RequestNetworkUri = "amqp://127.0.0.1:1235/", + RequestTargetAddress = "amqp://127.0.0.1:8888/", + ModelNumber = "升降回流机-2", + NumberOfLanes = 1, + Vendor = "木子贸易中山有限公司", + SerialNumber = "OT00470020", + Stages = new List + { + //new StageInformation() + //{ + // Stage = new Stage() + // { + // StageName = "ConveyorIn", + // StageType = StageType.Work, + // StageSequence = 1, + // } + //}, + new StageInformation() + { + Stage = new Stage() + { + StageName = "ConveyorOut", + StageType = StageType.Work, + StageSequence = 1, + } + } + }, + SupportedTopics = CFXSupportedTopicList.SupportedTopics + } + }; + + return response; + } +} \ No newline at end of file diff --git a/Sln.Iot.CFX/CFXRequestes/HandleFaultRequestReceived4.cs b/Sln.Iot.CFX/CFXRequestes/HandleFaultRequestReceived4.cs new file mode 100644 index 0000000..0fa225c --- /dev/null +++ b/Sln.Iot.CFX/CFXRequestes/HandleFaultRequestReceived4.cs @@ -0,0 +1,65 @@ +#region << 版 本 注 释 >> + +/*-------------------------------------------------------------------- +* 版权所有 (c) 2025 WenJY 保留所有权利。 +* CLR版本:4.0.30319.42000 +* 机器名称:Mr.Wen's MacBook Pro +* 命名空间:Sln.Iot.CFX +* 唯一标识:F3C2C0B6-F8E7-4869-B396-291233785B23 +* +* 创建者:WenJY +* 电子邮箱: +* 创建时间:2025-10-24 15:20:11 +* 版本:V1.0.0 +* 描述: +* +*-------------------------------------------------------------------- +* 修改人: +* 时间: +* 修改说明: +* +* 版本:V1.0.0 +*--------------------------------------------------------------------*/ + +#endregion << 版 本 注 释 >> + +using CFX; +using CFX.ResourcePerformance; +using CFX.Structures; +using Sln.Iot.CFX.RequestReceived; +using Sln.Iot.Serilog; + +namespace Sln.Iot.CFX.CFXRequestes; + +/// +/// 5.4.4.1.4 - 处理故障请求 +/// HandleFaultRequest/Response +/// +public class HandleFaultRequestReceived4 : BaseHandleFaultRequestReceived +{ + + /// + /// 子类重写处理 + /// + /// + /// + public override CFXMessage SubHandle(HandleFaultRequest request) + { + if (request.HandleRemote == true) + { + //熄灭报警灯 + } + + CFXMessage response = new HandleFaultResponse() + { + Result = new RequestResult() + { + Result = StatusResult.Success, + ResultCode = 0, + Message = "", + }, + }; + + return response; + } +} \ No newline at end of file diff --git a/Sln.Iot.CFX/CFXRequestes/ModifyStationParametersRequestReceived4.cs b/Sln.Iot.CFX/CFXRequestes/ModifyStationParametersRequestReceived4.cs new file mode 100644 index 0000000..fb1bf6a --- /dev/null +++ b/Sln.Iot.CFX/CFXRequestes/ModifyStationParametersRequestReceived4.cs @@ -0,0 +1,63 @@ +#region << 版 本 注 释 >> + +/*-------------------------------------------------------------------- +* 版权所有 (c) 2025 WenJY 保留所有权利。 +* CLR版本:4.0.30319.42000 +* 机器名称:Mr.Wen's MacBook Pro +* 命名空间:Sln.Iot.CFX.CoreCommunications +* 唯一标识:8E7C0E19-8462-42CA-AC22-F89BF2927C6A +* +* 创建者:WenJY +* 电子邮箱: +* 创建时间:2025-10-24 15:00:54 +* 版本:V1.0.0 +* 描述: +* +*-------------------------------------------------------------------- +* 修改人: +* 时间: +* 修改说明: +* +* 版本:V1.0.0 +*--------------------------------------------------------------------*/ + +#endregion << 版 本 注 释 >> + +using CFX; +using CFX.ResourcePerformance; +using CFX.Structures; +using Sln.Iot.CFX.RequestReceived; +using Sln.Iot.Serilog; + +namespace Sln.Iot.CFX.CFXRequestes; + +/// +/// 5.4.1.5 - 广播查询请求 +/// WhoIsThereRequest/Response +/// +public class ModifyStationParametersRequestReceived4 : BaseModifyStationParametersRequestReceived +{ + /// + /// 子类重写处理 + /// + /// + /// + public override CFXMessage SubHandle(ModifyStationParametersRequest request) + { + //配方修改 + + //同时主动上报StationParameterModified + + CFXMessage response = new ModifyStationParametersResponse() + { + Result = new RequestResult() + { + Result = StatusResult.Success, + ResultCode = 0, + Message = "", + }, + }; + + return response; + } +} \ No newline at end of file diff --git a/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived1.cs b/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived1.cs index f80e9c6..6d67723 100644 --- a/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived1.cs +++ b/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived1.cs @@ -55,7 +55,7 @@ public class WhoIsThereRequestReceived1 : BaseWhoIsThereRequestReceived Message = "", }, - CFXHandle = "CFX.A00.SDSH000001", + CFXHandle = "CFX.A00.OT00470018", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/" }; diff --git a/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived2.cs b/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived2.cs index fac725b..3fd5475 100644 --- a/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived2.cs +++ b/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived2.cs @@ -55,7 +55,7 @@ public class WhoIsThereRequestReceived2 : BaseWhoIsThereRequestReceived Message = "", }, - CFXHandle = "CFX.A00.SDSH000002", + CFXHandle = "CFX.A00.OT00470019", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/" }; diff --git a/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived3.cs b/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived3.cs index a370a6c..f71363b 100644 --- a/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived3.cs +++ b/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived3.cs @@ -55,7 +55,7 @@ public class WhoIsThereRequestReceived3 : BaseWhoIsThereRequestReceived Message = "", }, - CFXHandle = "CFX.A00.SDSH000003", + CFXHandle = "CFX.A00.OT00470017", RequestNetworkUri = "amqp://127.0.0.1:1235/", RequestTargetAddress = "amqp://127.0.0.1:8888/" }; diff --git a/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived4.cs b/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived4.cs new file mode 100644 index 0000000..245ee3e --- /dev/null +++ b/Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived4.cs @@ -0,0 +1,70 @@ +#region << 版 本 注 释 >> + +/*-------------------------------------------------------------------- +* 版权所有 (c) 2025 WenJY 保留所有权利。 +* CLR版本:4.0.30319.42000 +* 机器名称:Mr.Wen's MacBook Pro +* 命名空间:Sln.Iot.CFX.CoreCommunications +* 唯一标识:8E7C0E19-8462-42CA-AC22-F89BF2927C6A +* +* 创建者:WenJY +* 电子邮箱: +* 创建时间:2025-10-24 15:00:54 +* 版本:V1.0.0 +* 描述: +* +*-------------------------------------------------------------------- +* 修改人: +* 时间: +* 修改说明: +* +* 版本:V1.0.0 +*--------------------------------------------------------------------*/ + +#endregion << 版 本 注 释 >> + +using CFX; +using CFX.Structures; +using Sln.Iot.CFX.CFXBusiness; +using Sln.Iot.CFX.RequestReceived; +using Sln.Iot.Serilog; + +namespace Sln.Iot.CFX.CFXRequestes; + +/// +/// 5.4.1.5 - 广播查询请求 +/// WhoIsThereRequest/Response +/// +public class WhoIsThereRequestReceived4 : BaseWhoIsThereRequestReceived +{ + /// + /// 子类重写处理 + /// + /// + /// + public override CFXMessage SubHandle(WhoIsThereRequest request) + { + if (CFXSupportedTopicList.IsSupportJudge(request.SupportedTopics)) + { + CFXMessage response = new WhoIsThereResponse() + { + Result = new RequestResult() + { + Result = StatusResult.Success, + ResultCode = 0, + Message = "", + }, + + CFXHandle = "CFX.A00.OT00470020", + RequestNetworkUri = "amqp://127.0.0.1:1235/", + RequestTargetAddress = "amqp://127.0.0.1:8888/" + }; + + return response; + } + else + { + return null; + } + } +} \ No newline at end of file diff --git a/Sln.Iot.CFX/CFXTest.cs b/Sln.Iot.CFX/CFXTest.cs index a3e2bd5..4ec9456 100644 --- a/Sln.Iot.CFX/CFXTest.cs +++ b/Sln.Iot.CFX/CFXTest.cs @@ -20,6 +20,7 @@ namespace Sln.Iot.CFX CFXConnect1 _cfxHelper = CFXConnect1.Instance; CFXConnect2 _cfxHelper2 = CFXConnect2.Instance; CFXConnect3 _cfxHelper3 = CFXConnect3.Instance; + CFXConnect4 _cfxHelper4 = CFXConnect4.Instance; CFXUnitProcessedDataGet cFXUnitProcessedDataGet = CFXUnitProcessedDataGet.Instance; //HeartbeatEvent heartbeatEvent = new HeartbeatEvent(); @@ -53,7 +54,7 @@ namespace Sln.Iot.CFX //// 发布所有事件 ////_cfxHelper.PublishEvent(new CFXEnvelope(heartbeatEvent.Handle("CFX.A00.SDSH000001"))); - _cfxHelper.PublishEvent(new CFXEnvelope(endpointConnectedEvent.Handle("CFX.A00.SDSH000001", "amqp://127.0.0.1:1235", "amqp://127.0.0.1:8888"))); + _cfxHelper.PublishEvent(new CFXEnvelope(endpointConnectedEvent.Handle("CFX.A00.OT00470018", "amqp://127.0.0.1:1235", "amqp://127.0.0.1:8888"))); _cfxHelper.PublishEvent(new CFXEnvelope(faultOccurredEvent.Handle("01", FaultSeverity.Warning, testGuid, "Error", testGuid))); _cfxHelper.PublishEvent(new CFXEnvelope(faultAcknowledgedEvent.Handle())); _cfxHelper.PublishEvent(new CFXEnvelope(stationStateChangedEvent.Handle(ResourceState.USD_Repair))); @@ -65,20 +66,34 @@ namespace Sln.Iot.CFX _cfxHelper.PublishEvent(new CFXEnvelope(stationOfflineEvent.Handle())); _cfxHelper.PublishEvent(new CFXEnvelope(stationOnlineEvent.Handle())); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "-1", "0", "-1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "0", "1", "0", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "1", "4", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "2", "2", "2", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "3", "2", "3", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "4", "2", "4", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "5", "2", "5", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "6", "1", "6", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "7", "2", "7", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "8", "2", "8", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "9", "2", "9", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "10", "3", "10", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "11", "3", "11", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000001", "制程设备", "12", "2", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "-1", "0", "-1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "0", "1", "0", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "4", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "2", "2", "2", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "3", "2", "3", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "4", "2", "4", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "5", "2", "5", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "6", "1", "6", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "7", "2", "7", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "8", "2", "8", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "9", "2", "9", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "10", "3", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "11", "3", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "12", "2", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "18", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "20", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "21", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "22", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "24", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "61", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "62", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "63", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "68", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "69", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470018", "制程设备", "1", "2", "70", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); _cfxHelper.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle("A123456", new string[1] { "A123" }))); _cfxHelper.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(testGuid, "A123456", new string[]{ "A123" }))); @@ -95,7 +110,7 @@ namespace Sln.Iot.CFX _cfxHelper.PublishEvent(new CFXEnvelope(workCompletedEvent.Handle(testGuid, "A123456", new string[] { "A123" }))); _cfxHelper.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(null, new string[1] { "A123" }))); _cfxHelper.PublishEvent(new CFXEnvelope(unitsProcessedEvent.Handle(testGuid, cFXUnitProcessedDataGet.ProcessDataGet1(new UnitsProcess1Entity())))); - _cfxHelper.PublishEvent(new CFXEnvelope(endpointShuttingDownEvent.Handle("CFX.A00.SDSH000001"))); + _cfxHelper.PublishEvent(new CFXEnvelope(endpointShuttingDownEvent.Handle("CFX.A00.OT00470018"))); _cfxHelper.SendValidateUnitsRequest("amqp://127.0.0.1:8888", "A123456", new string[1] { "A123" }); } @@ -108,7 +123,7 @@ namespace Sln.Iot.CFX //// 发布所有事件 ////_cfxHelper2.PublishEvent(new CFXEnvelope(heartbeatEvent.Handle("CFX.A00.SDSH000002"))); - _cfxHelper2.PublishEvent(new CFXEnvelope(endpointConnectedEvent.Handle("CFX.A00.SDSH000002", "amqp://127.0.0.1:1235", "amqp://127.0.0.1:8888"))); + _cfxHelper2.PublishEvent(new CFXEnvelope(endpointConnectedEvent.Handle("CFX.A00.OT00470019", "amqp://127.0.0.1:1235", "amqp://127.0.0.1:8888"))); _cfxHelper2.PublishEvent(new CFXEnvelope(faultOccurredEvent.Handle("01", FaultSeverity.Warning, testGuid, "Error", testGuid))); _cfxHelper2.PublishEvent(new CFXEnvelope(faultAcknowledgedEvent.Handle())); _cfxHelper2.PublishEvent(new CFXEnvelope(stationStateChangedEvent.Handle(ResourceState.USD_Repair))); @@ -120,20 +135,33 @@ namespace Sln.Iot.CFX _cfxHelper2.PublishEvent(new CFXEnvelope(stationOfflineEvent.Handle())); _cfxHelper2.PublishEvent(new CFXEnvelope(stationOnlineEvent.Handle())); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "-1", "0", "-1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "0", "1", "0", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "1", "4", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "2", "2", "2", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "3", "2", "3", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "4", "2", "4", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "5", "2", "5", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "6", "1", "6", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "7", "2", "7", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "8", "2", "8", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "9", "2", "9", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "10", "3", "10", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "11", "3", "11", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000002", "制程设备", "12", "2", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "-1", "0", "-1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "0", "1", "0", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "2", "2", "2", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "3", "2", "3", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "4", "2", "4", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "5", "2", "5", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "6", "1", "6", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "7", "2", "7", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "8", "2", "8", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "9", "2", "9", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "10", "3", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "11", "3", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "12", "2", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "18", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "24", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "25", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "21", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "22", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "40", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "41", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "20", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper2.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470019", "制程设备", "1", "4", "26", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); _cfxHelper2.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle("A123456", new string[1] { "A123" }))); _cfxHelper2.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(testGuid, "A123456", new string[] { "A123" }))); @@ -142,19 +170,79 @@ namespace Sln.Iot.CFX _cfxHelper2.PublishEvent(new CFXEnvelope(workStagePausedEvent.Handle(testGuid, "ConveyorIn", 1))); _cfxHelper2.PublishEvent(new CFXEnvelope(workStageResumedEvent.Handle(testGuid, "ConveyorIn", 1))); _cfxHelper2.PublishEvent(new CFXEnvelope(workStageCompletedEvent.Handle(testGuid, "ConveyorIn", 1))); - _cfxHelper2.PublishEvent(new CFXEnvelope(workStageStartedEvent.Handle(testGuid, "ConveyorOut", 2))); - _cfxHelper2.PublishEvent(new CFXEnvelope(workStagePausedEvent.Handle(testGuid, "ConveyorOut", 2))); - _cfxHelper2.PublishEvent(new CFXEnvelope(workStageResumedEvent.Handle(testGuid, "ConveyorOut", 2))); - _cfxHelper2.PublishEvent(new CFXEnvelope(workStageCompletedEvent.Handle(testGuid, "ConveyorOut", 2))); _cfxHelper2.PublishEvent(new CFXEnvelope(workCompletedEvent.Handle(testGuid, "A123456", new string[] { "A123" }))); _cfxHelper2.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(null, new string[1] { "A123" }))); _cfxHelper2.PublishEvent(new CFXEnvelope(unitsProcessedEvent.Handle(testGuid, cFXUnitProcessedDataGet.ProcessDataGet2()))); - _cfxHelper2.PublishEvent(new CFXEnvelope(endpointShuttingDownEvent.Handle("CFX.A00.SDSH000002"))); + _cfxHelper2.PublishEvent(new CFXEnvelope(endpointShuttingDownEvent.Handle("CFX.A00.OT00470019"))); _cfxHelper2.SendValidateUnitsRequest("amqp://127.0.0.1:8888", "A123456", new string[1] { "A123" }); } + public void Test4() + { + //// 实例化所有事件对象 + Guid testGuid = Guid.Parse("281fa09f-cbf6-498d-9f27-7ca77cb60399"); + + //// 发布所有事件 + ////_cfxHelper4.PublishEvent(new CFXEnvelope(heartbeatEvent.Handle("CFX.A00.SDSH000002"))); + + _cfxHelper4.PublishEvent(new CFXEnvelope(endpointConnectedEvent.Handle("CFX.A00.OT00470020", "amqp://127.0.0.1:1235", "amqp://127.0.0.1:8888"))); + _cfxHelper4.PublishEvent(new CFXEnvelope(faultOccurredEvent.Handle("01", FaultSeverity.Warning, testGuid, "Error", testGuid))); + _cfxHelper4.PublishEvent(new CFXEnvelope(faultAcknowledgedEvent.Handle())); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationStateChangedEvent.Handle(ResourceState.USD_Repair))); + _cfxHelper4.PublishEvent(new CFXEnvelope(faultClearedEvent.Handle(testGuid))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationStateChangedEvent.Handle(ResourceState.PRD))); + _cfxHelper4.PublishEvent(new CFXEnvelope(logEntryRecordedEvent.Handle())); + _cfxHelper4.PublishEvent(new CFXEnvelope(recipeActivatedEvent.Handle("RecipeA", "ConveyorOut", 1))); + _cfxHelper4.PublishEvent(new CFXEnvelope(recipeModifiedEvent.Handle("RecipeA"))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationOfflineEvent.Handle())); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationOnlineEvent.Handle())); + + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "-1", "0", "-1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "0", "1", "0", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "2", "2", "2", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "3", "2", "3", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "4", "2", "4", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "5", "2", "5", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "6", "1", "6", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "7", "2", "7", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "8", "2", "8", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "9", "2", "9", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "10", "3", "10", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "11", "3", "11", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "12", "2", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "18", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "24", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "25", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "21", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "22", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "40", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "41", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "20", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper4.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470020", "制程设备", "1", "4", "26", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper4.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle("A123456", new string[1] { "A123" }))); + _cfxHelper4.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(testGuid, "A123456", new string[] { "A123" }))); + + _cfxHelper4.PublishEvent(new CFXEnvelope(workStageStartedEvent.Handle(testGuid, "ConveyorOut", 1))); + _cfxHelper4.PublishEvent(new CFXEnvelope(workStagePausedEvent.Handle(testGuid, "ConveyorOut", 1))); + _cfxHelper4.PublishEvent(new CFXEnvelope(workStageResumedEvent.Handle(testGuid, "ConveyorOut", 1))); + _cfxHelper4.PublishEvent(new CFXEnvelope(workStageCompletedEvent.Handle(testGuid, "ConveyorOut", 1))); + + _cfxHelper4.PublishEvent(new CFXEnvelope(workCompletedEvent.Handle(testGuid, "A123456", new string[] { "A123" }))); + _cfxHelper4.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(null, new string[1] { "A123" }))); + _cfxHelper4.PublishEvent(new CFXEnvelope(unitsProcessedEvent.Handle(testGuid, cFXUnitProcessedDataGet.ProcessDataGet4()))); + _cfxHelper4.PublishEvent(new CFXEnvelope(endpointShuttingDownEvent.Handle("CFX.A00.OT00470020"))); + + _cfxHelper4.SendValidateUnitsRequest("amqp://127.0.0.1:8888", "A123456", new string[1] { "A123" }); + } + public void Test3() { //// 实例化所有事件对象 @@ -163,7 +251,7 @@ namespace Sln.Iot.CFX //// 发布所有事件 ////_cfxHelper3.PublishEvent(new CFXEnvelope(heartbeatEvent.Handle("CFX.A00.SDSH000003"))); - _cfxHelper3.PublishEvent(new CFXEnvelope(endpointConnectedEvent.Handle("CFX.A00.SDSH000003", "amqp://127.0.0.1:1235", "amqp://127.0.0.1:8888"))); + _cfxHelper3.PublishEvent(new CFXEnvelope(endpointConnectedEvent.Handle("CFX.A00.OT00470017", "amqp://127.0.0.1:1235", "amqp://127.0.0.1:8888"))); _cfxHelper3.PublishEvent(new CFXEnvelope(faultOccurredEvent.Handle("01", FaultSeverity.Warning, testGuid, "Error", testGuid))); _cfxHelper3.PublishEvent(new CFXEnvelope(faultAcknowledgedEvent.Handle())); _cfxHelper3.PublishEvent(new CFXEnvelope(stationStateChangedEvent.Handle(ResourceState.USD_Repair))); @@ -175,20 +263,34 @@ namespace Sln.Iot.CFX _cfxHelper3.PublishEvent(new CFXEnvelope(stationOfflineEvent.Handle())); _cfxHelper3.PublishEvent(new CFXEnvelope(stationOnlineEvent.Handle())); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "-1", "0", "-1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "0", "1", "0", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "1", "4", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "2", "2", "2", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "3", "2", "3", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "4", "2", "4", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "5", "2", "5", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "6", "1", "6", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "7", "2", "7", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "8", "2", "8", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "9", "2", "9", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "10", "3", "10", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "11", "3", "11", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); - _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("SDSH000003", "制程设备", "12", "2", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "-1", "0", "-1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "0", "1", "0", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "1", "4", "1", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "2", "2", "2", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "3", "2", "3", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "4", "2", "4", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "5", "2", "5", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "6", "1", "6", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "7", "2", "7", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "8", "2", "8", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "9", "2", "9", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + //_cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "10", "3", "10", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + //_cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "11", "3", "11", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "12", "2", "12", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "18", "2", "18", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "20", "2", "20", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "21", "2", "21", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "22", "2", "22", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "24", "2", "24", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "61", "2", "61", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "62", "2", "62", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "63", "2", "63", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "68", "2", "68", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "69", "2", "69", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); + + _cfxHelper3.PublishEvent(new CFXEnvelope(stationParametersModifiedEvent.Handle(ParameterSet("OT00470017", "制程设备", "70", "2", "70", "1000", "0", "60", "3600", "4", "1", "5", "0", "0")))); _cfxHelper3.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle("A123456", new string[1] { "A123" }))); _cfxHelper3.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(testGuid, "A123456", new string[] { "A123" }))); @@ -209,7 +311,7 @@ namespace Sln.Iot.CFX _cfxHelper3.PublishEvent(new CFXEnvelope(workCompletedEvent.Handle(testGuid, "A123456", new string[] { "A123" }))); _cfxHelper3.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(null, new string[1] { "A123" }))); _cfxHelper3.PublishEvent(new CFXEnvelope(unitsProcessedEvent.Handle(testGuid, cFXUnitProcessedDataGet.ProcessDataGet3(new UnitsProcess3Entity())))); - _cfxHelper3.PublishEvent(new CFXEnvelope(endpointShuttingDownEvent.Handle("CFX.A00.SDSH000003"))); + _cfxHelper3.PublishEvent(new CFXEnvelope(endpointShuttingDownEvent.Handle("CFX.A00.OT00470017"))); _cfxHelper3.SendValidateUnitsRequest("amqp://127.0.0.1:8888", "A123456", new string[1] { "A123" }); } diff --git a/Sln.Iot/Program.cs b/Sln.Iot/Program.cs index 59e6dea..cef41fc 100644 --- a/Sln.Iot/Program.cs +++ b/Sln.Iot/Program.cs @@ -78,17 +78,21 @@ namespace Sln.Iot // new Uri("amqp://127.0.0.1:30031")); - //CFX接口启动 - //真空注胶机 - CFXConnect1.Instance.Init("CFX.A00.SDSH000001", - new Uri("amqp://127.0.0.1:1235"), - new Uri("amqp://127.0.0.1:8888")); - ////升降回流 - //CFXConnect2.Instance.Init("CFX.A00.SDSH000002", + ////CFX接口启动 + ////真空注胶机 + //CFXConnect1.Instance.Init("CFX.A00.OT00470018", // new Uri("amqp://127.0.0.1:1235"), // new Uri("amqp://127.0.0.1:8888")); + ////升降回流1 + //CFXConnect2.Instance.Init("CFX.A00.OT00470019", + // new Uri("amqp://127.0.0.1:1236"), + // new Uri("amqp://127.0.0.1:8889")); + //升降回流2 + CFXConnect2.Instance.Init("CFX.A00.OT00470020", + new Uri("amqp://127.0.0.1:1235"), + new Uri("amqp://127.0.0.1:8888")); ////隧道烤箱 - //CFXConnect3.Instance.Init("CFX.A00.SDSH000003", + //CFXConnect3.Instance.Init("CFX.A00.OT00470017", // new Uri("amqp://127.0.0.1:1235"), // new Uri("amqp://127.0.0.1:8888")); @@ -99,8 +103,9 @@ namespace Sln.Iot log.Info($"系统启动成功,日志存放位置:{appConfig.logPath}"); CFXTest cFXTest = new CFXTest(); - cFXTest.Test1(); - //cFXTest.Test2(); + //cFXTest.Test1(); + cFXTest.Test2(); + //cFXTest.Test4(); //cFXTest.Test3(); //TestBusiness test = new TestBusiness();