1

src/Khd.Core.EntityFramework/DefaultDbContext.cs

@@ -79,5 +79,7 @@ namespace Khd.Core.EntityFramework
         public DbSet<MesBaseBarcodeInfo> MesBaseBarcodeInfo { get; set; }
 
         public DbSet<PlcPoint> PlcPoint { get; set; }
+
+
     }
 }

src/Khd.Core.Wcs/MainCentralControl.cs

@@ -64,6 +64,7 @@ namespace Khd.Core.Wcs
                 //创建定时器
                 SystemTimer systemTimer = new SystemTimer(_host);
                 systemTimer.Start();
+
                 //创建任务
                 CreateTaskByRecord createTaskByRecord = new(_host);
                 createTaskByRecord.StartPoint();

src/Khd.Core.Wcs/Wcs/CreateTaskByRecord.cs

@@ -10,7 +10,6 @@ using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using SixLabors.ImageSharp;
 using System.Data;
-using System.Linq;
 using Z.EntityFramework.Plus;
 
 namespace Khd.Core.Wcs.Wcs

src/Khd.Core.Wcs/Wcs/SystemTimer.cs

@@ -193,11 +193,13 @@ namespace Khd.Core.Wcs.Wcs
         private void PlcHearBeat220Logic()
         {
             BasePlcpoint HeartBeat30 = StaticData.BasePlcpointList.First(t => t.plcpointNo == "putTray");
+            int errorCount = 0;
             while (true)
             {
                 try
                 {
                     StaticData.PlcDic[2].Read(HeartBeat30.plcpointAddress);
+                    errorCount = 0;
                 }
                 catch
                 {
@@ -208,6 +210,7 @@ namespace Khd.Core.Wcs.Wcs
                     }
                     catch (Exception ex2)
                     {
+                        errorCount++;
                         _logger.Error("Plc短线重连失败" + ex2.Message);
                     }
                 }
@@ -222,12 +225,14 @@ namespace Khd.Core.Wcs.Wcs
         {
             BasePlcpoint HeartBeat30 = StaticData.BasePlcpointList.First(t => t.plcpointNo == "HeartBeat30");
             bool heartBeatCount = false;
+            int errorCount = 0;
             while (true)
             {
                 try
                 {
                     heartBeatCount = !heartBeatCount;
                     StaticData.PlcDic[0].WriteToPoint(HeartBeat30.plcpointAddress, heartBeatCount, HeartBeat30.plcpointLength?.ToString());
+                    errorCount = 0;
                 }
                 catch
                 {
@@ -238,6 +243,7 @@ namespace Khd.Core.Wcs.Wcs
                     }
                     catch (Exception ex2)
                     {
+                        errorCount++;
                         _logger.Error("Plc短线重连失败" + ex2.Message);
                     }
                 }
@@ -252,12 +258,14 @@ namespace Khd.Core.Wcs.Wcs
         {
             BasePlcpoint HeartBeat31 = StaticData.BasePlcpointList.First(t => t.plcpointNo == "CTUHeart");
             bool heartBeatCount = false;
+            int errorCount = 0;
             while (true)
             {
                 try
                 {
                     heartBeatCount = !heartBeatCount;
                     StaticData.PlcDic[1].WriteToPoint(HeartBeat31.plcpointAddress, heartBeatCount, HeartBeat31.plcpointLength?.ToString());
+                    errorCount = 0;
                 }
                 catch (Exception ex)
                 {
@@ -270,6 +278,7 @@ namespace Khd.Core.Wcs.Wcs
                         }
                         catch (Exception ex2)
                         {
+                            errorCount++;
                             _logger.Error("Plc短线重连失败" + ex2.Message);
                         }
                     }