wangsr
/
Shihong-Delta.Injection.Iot
generated from wenjy/Sln.Iot
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

merge into: wangsr:master
Branches Tags
wangsr:CFXTest
wangsr:master
...
pull from: wangsr:CFXTest
Branches Tags
wangsr:CFXTest
wangsr:master

3 Commits
master ... CFXTest

Author SHA1 Message Date
SoulStar 341bab8d40 cfx - 最终验证 3 days ago
SoulStar 5e93cbd541 change - 随便改 2 months ago
SoulStar e966f2b130 change - ForTest 2 months ago
27 changed files with 965 additions and 189 deletions
Show Stats

111
Sln.Iot.CFX/CFXBusiness/CFXUnitProcessedDataGet.cs
Unescape Escape View File

@ -23,29 +23,29 @@ namespace Sln.Iot.CFX.CFXBusiness
/// <returns></returns>
public CommonProcessData ProcessDataGet1(UnitsProcess1Entity entity)
{
//entity = new UnitsProcess1Entity()
//{
// GlueAmountSetValue1 = 123.4f,
// GluePushSpeedSetValue1 = 10.1f,
// BarrelA1TempActValue1 = 60,
// BarrelA2TempActValue1 = 60,
// BarrelB1TempActValue1 = 60,
// BarrelB2TempActValue1 = 60,
// PumpAPressureActValue1 = 3.5f,
// PumpBPressureActValue1 = 3.2f,
// VacuumDegreeActValue1 = 3000.4f,
// PressureHoldTimeSetValue1 = 100,
// GlueAmountSetValue2 = 123.4f,
// GluePushSpeedSetValue2 = 10.1f,
// BarrelA1TempActValue2 = 60,
// BarrelA2TempActValue2 = 60,
// BarrelB1TempActValue2 = 60,
// BarrelB2TempActValue2 = 60,
// PumpAPressureActValue2 = 3.5f,
// PumpBPressureActValue2 = 3.2f,
// VacuumDegreeActValue2 = 3000.4f,
// PressureHoldTimeSetValue2 = 100,
//};
entity = new UnitsProcess1Entity()
{
GlueAmountSetValue1 = 123.4f,
GluePushSpeedSetValue1 = 10.1f,
BarrelA1TempActValue1 = 60,
BarrelA2TempActValue1 = 60,
BarrelB1TempActValue1 = 60,
BarrelB2TempActValue1 = 60,
PumpAPressureActValue1 = 3.5f,
PumpBPressureActValue1 = 3.2f,
VacuumDegreeActValue1 = 3000.4f,
PressureHoldTimeSetValue1 = 100,
GlueAmountSetValue2 = 123.4f,
GluePushSpeedSetValue2 = 10.1f,
BarrelA1TempActValue2 = 60,
BarrelA2TempActValue2 = 60,
BarrelB1TempActValue2 = 60,
BarrelB2TempActValue2 = 60,
PumpAPressureActValue2 = 3.5f,
PumpBPressureActValue2 = 3.2f,
VacuumDegreeActValue2 = 3000.4f,
PressureHoldTimeSetValue2 = 100,
};
CommonProcessData processData = new CommonProcessData()
{
@ -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;
}
/// <summary>
/// 升降回流数据
/// </summary>
/// <returns></returns>
public CommonProcessData ProcessDataGet4()
{
CommonProcessData processData = new CommonProcessData()
{
ZoneData = new List<CommonUseZoneData>
{
//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"
},
}
@ -230,18 +265,18 @@ namespace Sln.Iot.CFX.CFXBusiness
/// <returns></returns>
public CommonProcessData ProcessDataGet3(UnitsProcess3Entity entity)
{
//entity = new UnitsProcess3Entity()
//{
// PreheatOvenTempActValue = 800,
// PreCureOven1TempActValue = 800,
// PreCureOven2TempActValue = 800,
// PreCureOven3TempActValue = 800,
// PreCureOven4TempActValue = 800,
// CureOven1TempActValue = 800,
// CureOven2TempActValue = 800,
// CureOven3TempActValue = 800,
// CureOven4TempActValue = 800,
//};
entity = new UnitsProcess3Entity()
{
PreheatOvenTempActValue = 800,
PreCureOven1TempActValue = 800,
PreCureOven2TempActValue = 800,
PreCureOven3TempActValue = 800,
PreCureOven4TempActValue = 800,
CureOven1TempActValue = 800,
CureOven2TempActValue = 800,
CureOven3TempActValue = 800,
CureOven4TempActValue = 800,
};
CommonProcessData processData = new CommonProcessData()
{

2
Sln.Iot.CFX/CFXConnect/CFXConnect1.cs
Unescape Escape View File

@ -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)
{

4
Sln.Iot.CFX/CFXConnect/CFXConnect2.cs
Unescape Escape View File

@ -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)

4
Sln.Iot.CFX/CFXConnect/CFXConnect3.cs
Unescape Escape View File

@ -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)

132
Sln.Iot.CFX/CFXConnect/CFXConnect4.cs
Unescape Escape View File

@ -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
{
/// <summary>
/// 提升机2连接
/// </summary>
public class CFXConnect4 : CFXHelper
{
private static readonly Lazy<CFXConnect4> lazy = new Lazy<CFXConnect4>(() => 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;
}
/// <summary>
/// 发送生产单元验证请求接收通知
/// </summary>
public void SendValidateUnitsRequest(string uri, string primaryIdentifier, string[] unitsIdentifier)
{
try
{
ValidateUnitsRequest msg = new ValidateUnitsRequest()
{
Validations = new List<ValidationType>()
{
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)
{
}
}
}
}

2
Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived1.cs
Unescape Escape View File

@ -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/"
};

2
Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived2.cs
Unescape Escape View File

@ -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/"
};

2
Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived3.cs
Unescape Escape View File

@ -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/"
};

63
Sln.Iot.CFX/CFXRequestes/AreYouThereRequestReceived4.cs
Unescape Escape View File

@ -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;
/// <summary>
/// 5.4.1.1-端点在位查询请求
/// AreYouThereRequest/Response
/// </summary>
public class AreYouThereRequestReceived4 : BaseAreYouThereRequestReceived
{
/// <summary>
/// 子类重写处理
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
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;
}
}

38
Sln.Iot.CFX/CFXRequestes/GetActiveFaultsRequestReceived1.cs
Unescape Escape View File

@ -48,27 +48,27 @@ public class GetActiveFaultsRequestReceived1 : BaseGetActiveFaultsRequestReceive
public override CFXMessage SubHandle(GetActiveFaultsRequest request)
{
// 获取现在所有的错误
var errorList1 = errorService.GetV1List().ToList();
var errorList2 = errorService.GetV2List().ToList();
//var errorList1 = errorService.GetV1List().ToList();
//var errorList2 = errorService.GetV2List().ToList();
List<Fault> faults = new List<Fault>();
//List<Fault> faults = new List<Fault>();
foreach (var fault in errorList1)
{
faults.Add(new Fault()
{
Description = fault.ErrorName,
FaultCode = fault.ErrorCode,
});
}
foreach (var fault in errorList2)
{
faults.Add(new Fault()
{
Description = fault.ErrorName,
FaultCode = fault.ErrorCode,
});
}
//foreach (var fault in errorList1)
//{
// faults.Add(new Fault()
// {
// Description = fault.ErrorName,
// FaultCode = fault.ErrorCode,
// });
//}
//foreach (var fault in errorList2)
//{
// faults.Add(new Fault()
// {
// Description = fault.ErrorName,
// FaultCode = fault.ErrorCode,
// });
//}
CFXMessage response = new GetActiveFaultsResponse()
{

20
Sln.Iot.CFX/CFXRequestes/GetActiveFaultsRequestReceived2.cs
Unescape Escape View File

@ -48,18 +48,18 @@ public class GetActiveFaultsRequestReceived2 : BaseGetActiveFaultsRequestReceive
public override CFXMessage SubHandle(GetActiveFaultsRequest request)
{
// 获取现在所有的错误
var errorList = errorService.GetLiftList().ToList();
//var errorList = errorService.GetLiftList().ToList();
List<Fault> faults = new List<Fault>();
//List<Fault> faults = new List<Fault>();
foreach (var fault in errorList)
{
faults.Add(new Fault()
{
Description = fault.ErrorName,
FaultCode = fault.ErrorCode,
});
}
//foreach (var fault in errorList)
//{
// faults.Add(new Fault()
// {
// Description = fault.ErrorName,
// FaultCode = fault.ErrorCode,
// });
//}
CFXMessage response = new GetActiveFaultsResponse()
{

18
Sln.Iot.CFX/CFXRequestes/GetActiveFaultsRequestReceived3.cs
Unescape Escape View File

@ -50,16 +50,16 @@ public class GetActiveFaultsRequestReceived3 : BaseGetActiveFaultsRequestReceive
// 获取现在所有的错误
var errorList = errorService.GetOvenList().ToList();
List<Fault> faults = new List<Fault>();
//List<Fault> faults = new List<Fault>();
foreach (var fault in errorList)
{
faults.Add(new Fault()
{
Description = fault.ErrorName,
FaultCode = fault.ErrorCode,
});
}
//foreach (var fault in errorList)
//{
// faults.Add(new Fault()
// {
// Description = fault.ErrorName,
// FaultCode = fault.ErrorCode,
// });
//}
CFXMessage response = new GetActiveFaultsResponse()
{

84
Sln.Iot.CFX/CFXRequestes/GetActiveFaultsRequestReceived4.cs
Unescape Escape View File

@ -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;
/// <summary>
/// 5.4.4.1.5 - 查询当前有无错误
/// GetActiveFaultsRequest/Response
/// </summary>
public class GetActiveFaultsRequestReceived4 : BaseGetActiveFaultsRequestReceived
{
private readonly ErrorService errorService = ErrorService.Instance;
/// <summary>
/// 子类重写处理
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
public override CFXMessage SubHandle(GetActiveFaultsRequest request)
{
// 获取现在所有的错误
var errorList = errorService.GetOvenList().ToList();
//List<Fault> faults = new List<Fault>();
//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<Fault>()
{
new Fault()
{
Description = "测试错误1",
FaultCode = "5003",
}
}
};
return response;
}
}

22
Sln.Iot.CFX/CFXRequestes/GetActiveRecipeRequestReceived1.cs
Unescape Escape View File

@ -54,18 +54,18 @@ public class GetActiveRecipeRequestReceived1 : BaseGetActiveRecipeRequestReceive
string restr1 = string.Empty;
string restr2 = string.Empty;
//获取现在激活的配方
var res1 = _plc.ReadBytes(_plc.DeltaInstance1, "D600", 10);
var res2 = _plc.ReadBytes(_plc.DeltaInstance2, "D600", 10);
////获取现在激活的配方
//var res1 = _plc.ReadBytes(_plc.DeltaInstance1, "D600", 10);
//var res2 = _plc.ReadBytes(_plc.DeltaInstance2, "D600", 10);
if (res1.IsSuccess)
{
restr1 = Encoding.ASCII.GetString(res1.Content);
}
if (res2.IsSuccess)
{
restr2 = Encoding.ASCII.GetString(res2.Content);
}
//if (res1.IsSuccess)
//{
// restr1 = Encoding.ASCII.GetString(res1.Content);
//}
//if (res2.IsSuccess)
//{
// restr2 = Encoding.ASCII.GetString(res2.Content);
//}
CFXMessage response = new GetActiveRecipeResponse()
{

62
Sln.Iot.CFX/CFXRequestes/GetActiveRecipeRequestReceived4.cs
Unescape Escape View File

@ -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;
/// <summary>
/// 5.4.3.1.3 - 获取激活配方请求
/// GetActiveRecipeRequest/Response
/// </summary>
public class GetActiveRecipeRequestReceived4 : BaseGetActiveRecipeRequestReceived
{
/// <summary>
/// 子类重写处理
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
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;
}
}

6
Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived1.cs
Unescape Escape View File

@ -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<StageInformation>
{
new StageInformation()

24
Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived2.cs
Unescape Escape View File

@ -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<StageInformation>
{
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
}

4
Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived3.cs
Unescape Escape View File

@ -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<StageInformation>
{
new StageInformation()

93
Sln.Iot.CFX/CFXRequestes/GetEndpointInformationRequestReceived4.cs
Unescape Escape View File

@ -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;
/// <summary>
/// 5.4.1.4 - 获取端点信息请求
/// GetEndpointInformationRequest/Response
/// </summary>
public class GetEndpointInformationRequestReceived4 : BaseGetEndpointInformationRequestReceived
{
/// <summary>
/// 子类重写处理
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
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<StageInformation>
{
//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;
}
}

65
Sln.Iot.CFX/CFXRequestes/HandleFaultRequestReceived4.cs
Unescape Escape View File

@ -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;
/// <summary>
/// 5.4.4.1.4 - 处理故障请求
/// HandleFaultRequest/Response
/// </summary>
public class HandleFaultRequestReceived4 : BaseHandleFaultRequestReceived
{
/// <summary>
/// 子类重写处理
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
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;
}
}

63
Sln.Iot.CFX/CFXRequestes/ModifyStationParametersRequestReceived4.cs
Unescape Escape View File

@ -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;
/// <summary>
/// 5.4.1.5 - 广播查询请求
/// WhoIsThereRequest/Response
/// </summary>
public class ModifyStationParametersRequestReceived4 : BaseModifyStationParametersRequestReceived
{
/// <summary>
/// 子类重写处理
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
public override CFXMessage SubHandle(ModifyStationParametersRequest request)
{
//配方修改
//同时主动上报StationParameterModified
CFXMessage response = new ModifyStationParametersResponse()
{
Result = new RequestResult()
{
Result = StatusResult.Success,
ResultCode = 0,
Message = "",
},
};
return response;
}
}

2
Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived1.cs
Unescape Escape View File

@ -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/"
};

2
Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived2.cs
Unescape Escape View File

@ -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/"
};

2
Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived3.cs
Unescape Escape View File

@ -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/"
};

70
Sln.Iot.CFX/CFXRequestes/WhoIsThereRequestReceived4.cs
Unescape Escape View File

@ -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;
/// <summary>
/// 5.4.1.5 - 广播查询请求
/// WhoIsThereRequest/Response
/// </summary>
public class WhoIsThereRequestReceived4 : BaseWhoIsThereRequestReceived
{
/// <summary>
/// 子类重写处理
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
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;
}
}
}

206
Sln.Iot.CFX/CFXTest.cs
Unescape Escape View File

@ -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" });
}

51
Sln.Iot/Program.cs
Unescape Escape View File

@ -61,45 +61,52 @@ namespace Sln.Iot
//配置文件加载
var appConfig = AppConfigSetting.Load();
//PLC连接初始化
PLCConnect.Instance.InitConnect();
//PLCConnect.Instance.InitConnect();
//CFX接口启动
//真空注胶机
CFXConnect1.Instance.Init("CFX.A00.SDSH000001",
new Uri("amqp://127.0.0.1:1235"),
new Uri("amqp://127.0.0.1:30031"));
//升降回流
CFXConnect2.Instance.Init("CFX.A00.SDSH000002",
new Uri("amqp://127.0.0.1:1236"),
new Uri("amqp://127.0.0.1:30031"));
//隧道烤箱
CFXConnect3.Instance.Init("CFX.A00.SDSH000003",
new Uri("amqp://127.0.0.1:1237"),
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:30031"));
////升降回流
//CFXConnect2.Instance.Init("CFX.A00.SDSH000002",
// new Uri("amqp://127.0.0.1:1236"),
// new Uri("amqp://127.0.0.1:30031"));
////隧道烤箱
//CFXConnect3.Instance.Init("CFX.A00.SDSH000003",
// new Uri("amqp://127.0.0.1:1237"),
// 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",
//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"));
//业务类启动
BusinessStart business = new BusinessStart();
//BusinessStart business = new BusinessStart();
log.Info($"系统启动成功,日志存放位置:{appConfig.logPath}");
//CFXTest cFXTest = new CFXTest();
CFXTest cFXTest = new CFXTest();
//cFXTest.Test1();
cFXTest.Test2();
//cFXTest.Test4();
//cFXTest.Test3();
//TestBusiness test = new TestBusiness();

Write Preview
Loading…
Cancel
Save