change - 添加所有设备的开始结束离站入站

Sln.Iot.Business/RFID01Business.cs

@@ -100,10 +100,14 @@ namespace Sln.Iot.Business
                             Task.Run(() =>
                             {
                                 //单元抵达事件
+                                connect1.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle(traycode, prodcode)));
                                 connect2.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle(traycode, prodcode)));
+                                connect3.PublishEvent(new CFXEnvelope(unitsArrivedEvent.Handle(traycode, prodcode)));
                                 _log.Info($"{traycode} 抵达设备");
                                 //工作开始事件
+                                connect1.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(tid, traycode, prodcode)));
                                 connect2.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(tid, traycode, prodcode)));
+                                connect3.PublishEvent(new CFXEnvelope(workStartedEvent.Handle(tid, traycode, prodcode)));
                                 _log.Info($"工作开始，ID:{tid}");
                                 //预热炉工段开启
                                 connect3.PublishEvent(new CFXEnvelope(workStageStartedEvent.Handle(tid, "PreHeatOven", 1)));

Sln.Iot.Business/RFID06Business.cs

@@ -108,12 +108,17 @@ namespace Sln.Iot.Business
                                 //固化炉工段完成事件
                                 connect3.PublishEvent(new CFXEnvelope(workStageCompletedEvent.Handle(tid, "CureOven", 3)));
                                 _log.Info($"固化炉工段完成, {tid}");
-                                //单元离站事件
-                                connect2.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(traycode, prodcode)));
-                                _log.Info($"{traycode} 单元离站 ");
+
                                 //工单完成事件
+                                connect1.PublishEvent(new CFXEnvelope(workCompletedEvent.Handle(tid, traycode, prodcode)));
                                 connect2.PublishEvent(new CFXEnvelope(workCompletedEvent.Handle(tid, traycode, prodcode)));
+                                connect3.PublishEvent(new CFXEnvelope(workCompletedEvent.Handle(tid, traycode, prodcode)));
                                 _log.Info($"工单完成 ID:{tid}");
+                                //单元离站事件
+                                connect1.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(traycode, prodcode)));
+                                connect2.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(traycode, prodcode)));
+                                connect3.PublishEvent(new CFXEnvelope(unitsDepartedEvent.Handle(traycode, prodcode)));
+                                _log.Info($"{traycode} 单元离站 ");
 
                                 //固化炉数据采集
                                 var unitsdata = unitsProcessPLCDataGetBusiness.CureOvenPlcDataGet();