From 66e0168fe68ae5641041b2bceb3f0bb9640df09f Mon Sep 17 00:00:00 2001
From: quanzhou <quan.zhou@broconcentric.com>
Date: 星期五, 22 八月 2025 09:21:39 +0800
Subject: [PATCH] 添加MES超时队列匹配功能，vision错误自动累加和清零动作
---
src/Bro.M141.Process/M141Process.cs | 1053 ++++++++++++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 945 insertions(+), 108 deletions(-)
diff --git a/src/Bro.M141.Process/M141Process.cs b/src/Bro.M141.Process/M141Process.cs
index 4444bcc..37c90e0 100644
--- a/src/Bro.M141.Process/M141Process.cs
+++ b/src/Bro.M141.Process/M141Process.cs
@@ -5,10 +5,12 @@
using Bro.Device.InsCamera;
using Bro.M135.Common;
using Bro.M135.DBManager;
+using Bro.M141.Process.UI;
using Bro.Process;
using Bro.Process.DataBase.Models;
using Bro.UI.Model.Winform;
using HalconDotNet;
+using MySql.Data.MySqlClient;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NPOI.SS.Formula.Functions;
@@ -17,12 +19,17 @@
using ScottPlot.Drawing.Colormaps;
using Sunny.UI;
using Sunny.UI.Win32;
+using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Drawing.Imaging;
using System.IO;
using System.Linq;
+using System.Text;
using Windows.ApplicationModel.Appointments;
+using ZXing;
+using static Bro.Common.Helper.EnumHelper;
+using static Bro.Process.ProcessControl;
using static Org.BouncyCastle.Math.EC.ECCurve;
namespace Bro.M141.Process
@@ -34,28 +41,43 @@
public M141Process(string productCode) : base(productCode) { }
#endregion
+
TaskFactory _taskFactory = new TaskFactory(TaskCreationOptions.LongRunning, TaskContinuationOptions.LongRunning);
+
public event Action<string, P_PRODUCT_DETAIL, string> OnSinglePostionDetectResultUpdate;
+
protected M141Config M141Config => Config as M141Config;
public static object _productListLock = new object();
public List<ProductModel> ProductList = new List<ProductModel>();
MachineLearningBase ML = null;
- TcpListenerWrap TcpListener = null;
Spec _errorSpec = null;
- TcpListenerWrap _realTimeServer = null;
+ //volatile int _productIndex = 0;
- volatile int _productIndex = 0;
+ public M141Process_Mysql mysqlhelper = new M141Process_Mysql();
- int _backgroundImageWidth = 2448;
+ public event Action RerefreshBasketcodeUI;
- M141Process_Mysql mysqlhelper = new M141Process_Mysql();
+ public Action<bool, string> OnContinuousNGAlarmRaised;
+
+ public void RerefreshBasketcode()
+ {
+ RerefreshBasketcodeUI?.Invoke();
+ }
+
+
public override void InitialProcessMethods()
{
base.InitialProcessMethods();
+ if (ThHeartPlc == null)
+ {
+ ThHeartPlc = new Thread(Heartplc);
+ ThHeartPlc.IsBackground = true;
+ ThHeartPlc.Start();
+ }
}
public override void ProcessRunStateChanged()
@@ -72,11 +94,19 @@
}
public PLCBase Plc1;
- Thread ThHeartPlc;
+ bool devicestate = false;
+ PLCBase Plc2;
+ public Thread ThHeartPlc;
+
+ public RabbitMQHelper mqtt;
+
+
+
public override void Open()
{
base.Open();
+ devicestate = true;
ML = DeviceCollection.FirstOrDefault(u => u is MachineLearningBase) as MachineLearningBase;
if (ML == null)
{
@@ -98,43 +128,131 @@
_positionSpecHeads.Clear();
mysqlhelper.IniDBIP(M141Config.IPforall);
+ RerefreshBasketcode();
- if (ThHeartPlc == null)
+
+ if (M141Config.ISupMES)
{
- ThHeartPlc = new Thread(Heartplc);
- ThHeartPlc.IsBackground = true;
- ThHeartPlc.Start();
+ mqtt = new RabbitMQHelper(M141Config.zIP, M141Config.zport, M141Config.zuser, M141Config.zpassword);
+ mqtt.Connect(M141Config.MESchannel);
}
+
+ InitialContinuousNGAlarm();
}
-
+
public override void Close()
{
+ devicestate = false;
base.Close();
- try
- {
- if (ThHeartPlc != null)
- {
- ThHeartPlc.Abort();
- }
- }
- catch
- {
-
- }
- ThHeartPlc = null;
}
+
public void Heartplc()
{
- while (true)
+ Thread.Sleep(1000);
+
+ //Open();
+
+ string _statisticFilePath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Statistic.json");
+ if (File.Exists(_statisticFilePath))
{
try
{
- if (Plc1 != null)
+ string dataStr = "";
+ using (StreamReader reader = new StreamReader(_statisticFilePath, System.Text.Encoding.UTF8))
{
- Plc1.WriteSingleAddress(1505, 0, out _);
+ dataStr = reader.ReadToEnd();
+ }
+
+ lock (StatisticRecordsFull)
+ {
+ var temRecords = JsonConvert.DeserializeObject<StatisticRecords_Full>(dataStr);
+ if (StatisticRecordsFull != null && temRecords != null)
+ {
+ StatisticRecordsFull.CurRecord = temRecords.CurRecord;
+ StatisticRecordsFull.HistoryRecord = temRecords.HistoryRecord;
+ }
+ }
+ }
+ catch (Exception ex)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"浜у搧缁熻淇℃伅鍙嶅簭鍒楀寲寮傚父");
+ StatisticRecordsFull = new StatisticRecords_Full();
+ }
+ }
+
+ int numsum = 0;
+ //List<int> Statelist = new List<int>();
+
+
+ Dictionary<string, List<int>> StateDIC = new Dictionary<string, List<int>>();
+ int numplc = 0;
+ while (true)
+ {
+ numplc++;
+ numsum++;
+
+
+ if (!devicestate)
+ {
+ Thread.Sleep(1000);
+ continue;
+ }
+ try
+ {
+ if (M141Config.WorkShiftList != null && M141Config.WorkShiftList.Count > 0 && numsum >= 0)
+ {
+ for (int i = 0; i < M141Config.WorkShiftList.Count; i++)
+ {
+ if (M141Config.WorkShiftList[i].IsClearProductSummary)
+ {
+ double timeshap = (DateTime.Now - M141Config.WorkShiftList[i].ShiftTime_Start).TotalMinutes % 1440;
+
+ if (timeshap > 0 && timeshap < 1)
+ {
+ StatisticRecordsFull.CurRecord.ProductSummary.RecordsList.Clear();
+ StatisticRecordsFull.CurRecord.DefectSummary.RecordsList.Clear();
+ numsum = -62;
+ }
+ }
+ }
+ }
+
+ lock (StatisticRecordsFull)
+ {
+ if (numsum > 20)
+ {
+ numsum = 0;
+ using (FileStream fileStream = new FileStream(_statisticFilePath, FileMode.OpenOrCreate, FileAccess.Write))
+ {
+ fileStream.Seek(0L, SeekOrigin.Begin);
+ string s = JsonConvert.SerializeObject(StatisticRecordsFull);
+ byte[] bytes = Encoding.UTF8.GetBytes(s);
+ fileStream.Write(bytes, 0, bytes.Length);
+ fileStream.SetLength(bytes.Length);
+ fileStream.Flush();
+ fileStream.Close();
+ }
+ }
+ }
+ }
+ catch (Exception ex)
+ {
+
+ }
+
+
+ try
+ {
+ if (numplc > 3)
+ {
+ numplc = 0;
+ if (Plc1 != null)
+ {
+ Plc1.WriteSingleAddress(M141Config.heartadd, 0, out _);
+ }
}
}
catch
@@ -142,10 +260,114 @@
}
- Thread.Sleep(3000);
+
+ try
+ {
+ string csvhead = "鏃堕棿";
+ string csvdata = DateTime.Now.ToString("yyyyMMddHHmmss") + "T";
+
+ if (Plc1 != null)
+ {
+ foreach (var item1 in M141Config.PLCAlarm)
+ {
+ try
+ {
+ if (!item1.isused)
+ {
+ continue;
+ }
+
+ var alrams = item1.AlarmDetails;
+ var plcdev = DeviceCollection.FirstOrDefault(u => u.Id == item1.plcname) as PLCBase;
+
+ if (!StateDIC.ContainsKey(plcdev.Name))
+ {
+ StateDIC[plcdev.Name] = new List<int>();
+ }
+
+ foreach (var item in alrams.GroupBy(u => u.address))
+ {
+ int add = item.Key;
+ var readres = plcdev.Read(add, 1, out _)[0];
+
+ var Allbin = Convert.ToString(readres, 2).PadLeft(16, '0').Select(c => c - '0').ToArray();
+
+ Allbin = Allbin.Reverse().ToArray();
+
+ foreach (var item2 in item)
+ {
+ item2.value = Allbin[item2.address2];
+ }
+ }
+ List<int> list = new List<int>();
+ foreach (var item in alrams)
+ {
+ csvhead += $",{item.alarmname}";
+ csvdata += $",{(item.value == 1 ? "1" : "")}";
+ list.Add(item.value);
+ }
+
+ if (!StateDIC[plcdev.Name].SequenceEqual(list))
+ {
+ StateDIC[plcdev.Name].Clear();
+ StateDIC[plcdev.Name].AddRange(list);
+
+ CSVRecordAsync($"PLCstate_{plcdev.Name}.csv", csvdata, csvhead);
+
+ var showdata = alrams.Where(u => u.value == 1).Select(u => u.alarmname).ToList();
+
+ if (showdata == null)
+ {
+ showdata = new List<string>();
+ }
+
+ if (showdata.Count > 0)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"{plcdev.Name}鎶ヨ 涓暟:{showdata.Count} {string.Join(',', showdata)}");
+ }
+ else
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"{plcdev.Name}鎶ヨ 涓暟:0");
+ }
+ }
+ }
+ catch
+ {
+
+ }
+ }
+ }
+
+ }
+ catch
+ {
+
+ }
+
+
+
+ try
+ {
+ if (Plc1 != null)
+ {
+ DateTime dt = DateTime.Now;
+ Plc1.WriteSingleAddress(10, dt.Year, out _);
+ Plc1.WriteSingleAddress(11, dt.Month, out _);
+ Plc1.WriteSingleAddress(12, dt.Day, out _);
+ Plc1.WriteSingleAddress(13, dt.Hour, out _);
+ Plc1.WriteSingleAddress(14, dt.Minute, out _);
+ Plc1.WriteSingleAddress(15, dt.Second, out _);
+ Plc1.WriteSingleAddress(16, (int)dt.DayOfWeek, out _);
+ }
+ }
+ catch
+ {
+
+ }
+
+ Thread.Sleep(1000);
}
}
-
/// <summary>
/// 缃戠粶棰勭儹
@@ -153,7 +375,6 @@
/// <exception cref="NotImplementedException"></exception>
private void NetWarmUp()
{
-
string warmUpImageFolder = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "WarmUp");
if (!Directory.Exists(warmUpImageFolder))
{
@@ -245,8 +466,6 @@
Dictionary<string, List<string>> _positionSpecHeads = new Dictionary<string, List<string>>();
-
-
volatile int uploadId = 0;
@@ -264,15 +483,6 @@
if (isSaveDB)
{
- if (M141Config.Isreadbasketcode)
- {
- p.BasketCode = M141Config.basketcode;
- }
- else
- {
- p.BasketCode = mysqlhelper.Getbasketcode(p.SEQUENCE);
- }
-
mysqlhelper.NewProduct(p);
}
@@ -304,9 +514,8 @@
p.PID = p.PID + "_" + sequence.Split('_')[sequence.Split('_').Length - 1];
p.Initial(M141Config.StationCode, M141Config.WorkPositionCollection.Where(u => u.IsEnabled).Select(u => u.PositionName).ToList());
- LogAsync(DateTime.Now, EnumHelper.LogLevel.Warning, $"鏈兘浠庢暟鎹簱鑾峰彇浜у搧瀵硅薄锛屼娇鐢ㄤ复鏃舵柊寤轰骇鍝佸璞�");
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Warning, $"鏈兘浠庢暟鎹簱鑾峰彇浜у搧瀵硅薄锛屼娇鐢ㄤ复鏃舵柊寤轰骇鍝佸璞� {sequence}");
}
-
NewProductIntoList(p, false);
}
@@ -334,33 +543,62 @@
throw new Exception($"浜у搧{string.Join(",", pidList)}妫�娴媨measureBind.GetDisplayText()}鏈兘鑾峰彇鍥剧墖瀵硅薄");
}
+ RunCustomizedMethod(products, triggerText, triggerSource, imgSet, measureBind.CustomizedMonitorId, resultList);
+ RunCustomizedMethod(products, triggerText, triggerSource, imgSet, measureBind.CustomizedCombineMethodId, resultList);
+
//妫�娴嬮『搴� ML->鑷畾涔夋娴�
if (!string.IsNullOrWhiteSpace(measureBind.DetectionId))
{
string detectionName = (ML.InitialConfig as MLInitialConfigBase).DetectionConfigs.FirstOrDefault(u => u.Id == measureBind.DetectionId)?.Name;
-
- //List<string> pidList2 = new List<string>();//pidList.Select(u => u.Split('_')[u.Split('_').Length - 1]).ToList();
- //Dictionary<string, string> dicpid = new Dictionary<string, string>();
-
- //for (int i = 0; i < pidList.Count; i++)
- //{
- // var tem = pidList[i].Split('_')[pidList[i].Split('_').Length - 1];
- // pidList2.Add(tem);
- // dicpid[tem] = pidList[i];
- //}
+ List<DetectResult> detectResults = ML?.RunMLDetectionSync(imgSet, pidList, measureBind.DetectionId, false, null, null, "", products[0].ImagePaths);
- List<DetectResult> detectResults = ML?.RunMLDetectionSync(imgSet, pidList, measureBind.DetectionId);
+
+ if (measureBind.WorkPosition == "P1" && M141Config.StationCode == "S5" && detectResults.GetDefectDescList().Count == 0)
+ {
+ var defecttem = detectResults.SelectMany(u => u.AllNetResults.SelectMany(m => m.DetectDetails)).Where(u => u.ClassName == M141Config.defectname).ToList();
+
+ List<Netdefectdetail> Netdefectdetails = mysqlhelper.GetNetdefectdetails(products[0].SEQUENCE);
+
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"{products[0].SN} S3S5妫�娴� S3鏁版嵁{Netdefectdetails.Count} S5鏁版嵁{defecttem.Count}");
+
+ Netdefectdetails.ForEach(x =>
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"{products[0].SN} S3S5妫�娴� S3鏁版嵁{x.name} {x.centerX},{x.centerY} ");
+ });
+
+ int num = 0;
+ foreach (var item1 in defecttem)
+ {
+ double x1 = item1.Rect.Point_LU.X + item1.Rect.Width / 2.0;
+ double y1 = item1.Rect.Point_LU.Y + item1.Rect.Height / 2.0;
+ num++;
+
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"{products[0].SN} S3S5妫�娴� 鍘熷潗鏍噞num} {x1},{y1}");
+ HOperatorSet.ProjectiveTransPixel(new HTuple(products[0].Centermatrix.ToArray()), y1, x1, out HTuple qx, out HTuple qy);
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"{products[0].SN} S3S5妫�娴� 鏂板潗鏍噞num} {qx},{qy}");
+
+
+ Netdefectdetail temc = new Netdefectdetail()
+ {
+ centerX = qx,
+ centerY = qy,
+ name = M141Config.defectname,
+ };
+ if (Netdefectdetails.Any(u => u == temc))
+ {
+ item1.IsAbandoned = false;
+ item1.FinalResult = ResultState.NG;
+
+ //products[0].Result = M141Config.defectname;
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"浜у搧{products[0].PID}_{products[0].SEQUENCE}宸ヤ綅{measureBind.WorkPosition} S3S5缁勫悎妫�娴嬫鍑虹己闄�:{item1.NetName}锛屼骇鍝佺粨鏋滀负{products[0].Result}");
+ break;
+ }
+ }
+ }
+
List<DetectResult> ngResults = new List<DetectResult>();
-
-
- //for (int i = 0; i < detectResults.Count; i++)
- //{
- // detectResults[i].PID = dicpid[detectResults[i].PID];
- //}
-
-
detectResults.GroupBy(u => u.PID).ToList().ForEach(u =>
{
if (u.ToList().Count > 0 && u.ToList().Any(m => m.ResultState != EnumHelper.ResultState.OK))
@@ -370,21 +608,14 @@
var errorSpec = _errorSpec.Copy();
errorSpec.Code = "妫�娴婽BD";
errorSpec.ActualValue = -999;
- DetectResult ngResult = new DetectResult() { Specs = new List<ISpec>() { errorSpec }, PID = u.Key };
+ DetectResult ngResult = new DetectResult() { Specs = new List<ISpec>() { errorSpec }, PID = u.Key, Id = Guid.NewGuid().ToString() };
ngResults.Add(ngResult);
}
}
});
-
detectResults.AddRange(ngResults);
resultList.AddRange(detectResults);
-
-
}
-
-
- RunCustomizedMethod(products, triggerText, triggerSource, imgSet, measureBind.CustomizedMonitorId, resultList);
- RunCustomizedMethod(products, triggerText, triggerSource, imgSet, measureBind.CustomizedCombineMethodId, resultList);
}
catch (Exception ex)
@@ -467,10 +698,19 @@
}
string ngImageFile = Path.Combine(folder, $"{id}.{post}");
- var bitmap = imgSet.HImage.ConvertHImageToBitmap();
- bitmap.Save(ngImageFile, M141Config.ImageFormatNG);
- LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{id}NG鍥剧墖宸蹭繚瀛�");
- bitmap.Dispose();
+ //var bitmap = imgSet.HImage.ConvertHImageToBitmap();
+ //bitmap.Save(ngImageFile, M141Config.ImageFormatNG);
+ //LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{id}NG鍥剧墖宸蹭繚瀛�");
+ //bitmap.Dispose();
+ try
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{id}NG鍥剧墖娴嬭瘯杞瓨{ngImageFile}");
+ imgSet.HImage.WriteImage(M141Config.ImageFormatOK.ToString().ToLower(), 0, ngImageFile);
+ }
+ catch (Exception)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"{id}NG鍥剧墖淇濆瓨澶辫触");
+ }
}
}
}
@@ -504,10 +744,19 @@
}
string ngImageFile = Path.Combine(folder, $"{id}.{post}");
- var bitmap = imgSet.HImage.ConvertHImageToBitmap();
- bitmap.Save(ngImageFile, M141Config.ImageFormatOK);
- LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{id}OK鍥剧墖宸蹭繚瀛�");
- bitmap.Dispose();
+ //var bitmap = imgSet.HImage.ConvertHImageToBitmap();
+ //bitmap.Save(ngImageFile, M141Config.ImageFormatOK);
+ //LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{id}OK鍥剧墖宸蹭繚瀛�");
+ //bitmap.Dispose();
+ try
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{id}OK鍥剧墖娴嬭瘯杞瓨{ngImageFile}");
+ imgSet.HImage.WriteImage(M141Config.ImageFormatOK.ToString().ToLower(), 0, ngImageFile);
+ }
+ catch (Exception)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"{id}OK鍥剧墖淇濆瓨澶辫触");
+ }
}
}
}
@@ -608,7 +857,7 @@
{
products.ForEach(p =>
{
- var pResults = resultList.Where(u => u.PID == p.PID).ToList();
+ var pResults = resultList.ToList();
p.AddNewDetectResults(M141Config.StationCode, measureBind.WorkPosition, pResults);
LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"浜у搧{p.PID}_{p.SEQUENCE}娣诲姞宸ヤ綅{measureBind.WorkPosition}妫�娴嬬粨鏋滐紝鏁伴噺{pResults.Count}");
});
@@ -728,7 +977,7 @@
imgSetDicts[b] = CollectHImage(camera, b.SnapshotOpConfig);
if (positionSet.ispiccover)
{
- Plc1.WriteSingleAddress(positionSet.plcover,1,out _);
+ Plc1.WriteSingleAddress(positionSet.plcover, 1, out _);
}
}
catch (Exception ea)
@@ -830,6 +1079,23 @@
p.SEQUENCE = $"{tempSequence}_{i}";
p.PID = $"{pidstr}T_{i}";
+ if (M141Config.Isreadbasketcode)
+ {
+ p.BasketCode = M141Config.basketcode;
+ p.Zword = M141Config.zwoid;
+ }
+ else
+ {
+ p.BasketCode = mysqlhelper.Getbasketcode(p.SEQUENCE, out string sntem, out string zword);
+ p.Zword = zword;
+ p.SN = sntem;
+ p.PID = $"{sntem}_{i}";
+ if ("NoRead".Equals(p.BasketCode))
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"{p.PID}_{p.SEQUENCE}鑾峰彇妗嗗叿鐮佸け璐� 璧嬪�糔oread");
+ }
+ }
+
if (positionSet.IsLastPosition)
{
p.Initial(M141Config.StationCode, new List<string>() { positionSet.PositionName });
@@ -842,9 +1108,9 @@
});
});
+ Thread.Sleep(50);
int de = 0;
-
measureBinds.Where(b => (b.CheckIndex == de || b.CheckIndex == 1) && b.ImageIndex == 0).AsParallel().ForAll(b =>
{
List<int> temint = new List<int>();
@@ -858,8 +1124,9 @@
//鍒濆鍖栦骇鍝佺殑妫�娴嬫鏁�
var checkIndexList = M141Config.MeasureBindCollection.Where(u => u.WorkPosition == b.WorkPosition && u.ProductIndices.Contains(i)).Select(u => u.CheckIndex).OrderBy(u => u).ToList();
- p.InitialPositionCheckList(b.WorkPosition, checkIndexList);
+ p.InitialPositionCheckList(b.WorkPosition, checkIndexList, M141Config.StationCode);
LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{p.PID}_{p.SEQUENCE}宸叉竻鐞唟b.WorkPosition}妫�娴嬫暟鎹�傚綋鍓嶅凡瀹屾垚宸ヤ綅{string.Join(",", p.Details.Select(u => u.PositionName))}");
+
});
//鍒濆鍖栧伐浣嶇殑妫�娴嬫鏁�
@@ -946,36 +1213,98 @@
List<string> specHeads = new List<string>();
string head = p.GetCSVHead(ref specHeads, positionName);
- _positionSpecHeads[positionName] = specHeads;
+ //_positionSpecHeads[positionName] = specHeads;
- string data = p.GetCSVData(_positionSpecHeads[positionName], positionName);
+ string data = p.GetCSVData(specHeads, positionName);
CSVRecordAsync($"{positionName}_Record_{DateTime.Now.ToString("yyyyMMdd")}.csv", data, head);
//UpdatePositionResultToDB(detail);
- var seqData = p.SEQUENCE.Split(new char[] { '_' }, StringSplitOptions.RemoveEmptyEntries).ToList();
+ //var seqData = p.SEQUENCE.Split(new char[] { '_' }, StringSplitOptions.RemoveEmptyEntries).ToList();
+
+ if (M141Config.StationCode == "S4" && isOK)
+ {
+ ////mysqlhelper.GetS2Result(productList[0].SEQUENCE);
+ //Plc1.WriteSingleAddress(1526, mysqlhelper.GetS2Result(productList[0].SEQUENCE) ? 1 : 2, out _);
+
+ bool temS2 = mysqlhelper.GetS2Result(p.SEQUENCE);
+ ReplyPlcData(positionSet, new List<bool>() { temS2 });
+ if (!temS2)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"{p.SN} S2宸ョ珯NG鎶涙枡");
+ }
+ }
+ else
+ {
+ ReplyPlcData(positionSet, plcresult);
+ }
+
+
mysqlhelper.UpdateProduct(p);
+
+
+
if (positionSet.IsLastPosition)
{
- UpdateProductResultAsync(p);
- mysqlhelper.NewForAll(p, M141Config.StationCode);
+
+
+ //鐝缁熻鏃堕棿鍒掑垎
+ if (M141Config.WorkShiftList.Count == 0)
+ {
+ //鐢熸垚涓�涓姤琛�
+ string name = $"ProductRecord_{DateTime.Now.ToString("yyyyMMdd")}.csv";
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"鍒涘缓{name}鏁版嵁鎶ヨ〃");
+ UpdateProductResultAsync(p, name);
+ }
+ else
+ {
+ foreach (var item in M141Config.WorkShiftList)
+ {
+ DateTime now = DateTime.Now;
+
+ if (item.ShiftTime_Start < item.ShiftTime_End)
+ {
+ if (now.TimeOfDay >= item.ShiftTime_Start.TimeOfDay && now.TimeOfDay < item.ShiftTime_End.TimeOfDay)
+ {
+ //鐢熸垚涓�涓姤琛�
+ string name = $"ProductRecord_{DateTime.Now.ToString("yyyyMMdd")}_{item.ShiftName}.csv";
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"鍒涘缓{name}鏁版嵁鎶ヨ〃");
+ UpdateProductResultAsync(p, name);
+ }
+ }
+ else
+ {
+ if (now.TimeOfDay >= item.ShiftTime_Start.TimeOfDay )
+ {
+ //鐢熸垚涓�涓姤琛�
+ string name = $"ProductRecord_{DateTime.Now.ToString("yyyyMMdd")}_{item.ShiftName}.csv";
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"鍒涘缓{name}鏁版嵁鎶ヨ〃");
+ UpdateProductResultAsync(p, name);
+ }
+ if (now.TimeOfDay < item.ShiftTime_End.TimeOfDay)
+ {
+ // 鐢熸垚涓�涓姤琛�
+ string name = $"ProductRecord_{DateTime.Now.AddDays(-1).ToString("yyyyMMdd")}_{item.ShiftName}.csv";
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"鍒涘缓{name}鏁版嵁鎶ヨ〃");
+ UpdateProductResultAsync(p, name);
+ }
+ }
+ }
+ }
+
+ //UpdateProductResultAsync(p);
+
+ mysqlhelper.NewForAll(p, M141Config.StationCode, M141Config.defectname);
+
if (M141Config.IsfinDevice)
{
+
SummaryAllprodata(p);
+
}
}
});
- ReplyPlcData(positionSet, plcresult);
- if (positionSet.IsLastPosition)
- {
- if (_ct != null)
- {
- UpdateCT(null, (float)((DateTime.Now - _ct.Value).TotalSeconds));
- }
- _ct = DateTime.Now;
- }
- //ReplyPlcData(positionName, config.TriggerValue);
cameraIds.ForEach(c =>
{
@@ -986,6 +1315,221 @@
LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"鐩告満{camera.Name}娓呯悊缂撳瓨");
}
});
+
+ //ReplyPlcData(positionSet, plcresult);
+ if (positionSet.IsLastPosition)
+ {
+ if (_ct != null)
+ {
+ UpdateCT(null, (float)((DateTime.Now - _ct.Value).TotalSeconds));
+ }
+ _ct = DateTime.Now;
+
+ if (M141Config.ISupMES && (M141Config.MESchannel == -1 || M141Config.MESchannel == 1))
+ {
+ if (M141Config.numpro >= 50)
+ {
+ M141Config.numpro = 0;
+ }
+
+ string Msgreceice = null;
+
+ if (pList[0].Result == "OK")
+ {
+ M141Config.numpro++;
+ Msgreceice = Task.Run(() => mqtt.MESForProduceAsync(pList[0], M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
+ }
+ else
+ {
+ if (M141Config.ISupNG)
+ {
+ Msgreceice = Task.Run(() => mqtt.MESForProduceAsync(pList[0], M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{pList[0].PID}鍚姩NG涓婁紶");
+
+ }
+ else
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{pList[0].PID}鍏抽棴NG涓婁紶");
+ }
+ }
+ M141Config.mesnum2++;
+ if (Msgreceice == null && !M141Config.ISupNG)
+ {
+ if (!M141Config.ISupNG)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{pList[0].PID}鏁版嵁NG锛屽紑鍚叧闂璑G涓婁紶MES");
+ }
+ else
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"浜у搧{pList[0].PID}鏁版嵁涓婁紶MES寮傚父 杩斿洖鏁版嵁涓簄ull");
+ }
+ }
+ else
+ {
+ try
+ {
+ var obj = JsonConvert.DeserializeObject<AutoLineMacBarcodeQueueBak>(Msgreceice);
+
+ if (obj.zstatus == "200")
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{pList[0].PID}鏁版嵁涓婁紶MES鎴愬姛 {Msgreceice}");
+ }
+ else
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"浜у搧{pList[0].PID}鏁版嵁涓婁紶MES澶辫触 {Msgreceice}");
+ }
+ }
+ catch
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"浜у搧{pList[0].PID}鏁版嵁涓婁紶MES寮傚父 {Msgreceice}");
+ }
+ }
+
+
+
+ int numplca = Convert.ToInt32(pList[0].SEQUENCE.Split('_')[0]);
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"plc缁欏嚭鐨勪骇鍝佸簭鍙蜂负{numplca}");
+
+ lock (plcnumlock)//1-29999
+ {
+
+ if (PlcNumForAll == -1)
+ {
+ PlcNumForAll = numplca;
+ }
+
+ int differ = numplca - PlcNumForAll;
+
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"涓や釜浜у搧涓棿鐨勫樊鍊糳iffer涓簕differ}");
+
+ if (differ > 1)
+ {
+ for (int i = PlcNumForAll + 1; i < numplca; i++)
+ {
+ try
+ {
+ var plist = mysqlhelper.GetProductList(i + "_1");
+ ProductModel newp = new ProductModel();
+ newp.SEQUENCE = plist[0].SEQUENCE;
+ newp.PID = plist[0].PID;
+ newp.BasketCode = plist[0].BasketCode;
+ newp.Zword = plist[0].Zword;
+ newp.Result = "NG";
+ newp.SN = plist[0].SN;
+
+ if (M141Config.IsfinDevice)
+ {
+ SummaryAllprodata(newp);
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鎻愬墠NG鍔犲叆姹囨�绘暟鎹姤琛ㄧ粺璁�");
+ }
+ if (M141Config.ISupNG)
+ {
+ var tems = Task.Run(() => mqtt.MESForProduceAsync(newp, M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
+ M141Config.mesnum2++;
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鍚姩NG涓婁紶");
+ }
+ else
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鍏抽棴NG涓婁紶");
+ }
+
+ }
+ catch
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{i + "_1"}涓婁紶澶辫触");
+ }
+ }
+ }
+ else if (differ == -29998 && differ == 1 && differ == 0)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"鐢熶骇杩囩▼涓湭澶卞幓浜у搧");
+ }
+ else if (differ < 0 && differ > -29998)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"PlcNumForAll涓簕PlcNumForAll}锛宯umplca涓簕numplca}");
+ //浜у搧浠庢柊璁℃暟鏃�
+ for (int i = PlcNumForAll + 1; i <= 29999; i++)
+ {
+ try
+ {
+ var plist = mysqlhelper.GetProductList(i + "_1");
+ ProductModel newp = new ProductModel();
+ newp.SEQUENCE = plist[0].SEQUENCE;
+ newp.PID = plist[0].PID;
+ newp.Zword = plist[0].Zword;
+ newp.BasketCode = plist[0].BasketCode;
+ newp.Result = "NG";
+ newp.SN = plist[0].SN;
+ if(M141Config.IsfinDevice)
+ {
+ SummaryAllprodata(newp);
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鎻愬墠NG鍔犲叆姹囨�绘暟鎹姤琛ㄧ粺璁�");
+ }
+ if (M141Config.ISupNG)
+ {
+ var tems = Task.Run(() => mqtt.MESForProduceAsync(newp, M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
+ M141Config.mesnum2++;
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鍚姩NG涓婁紶");
+ }
+ else
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鍏抽棴NG涓婁紶");
+ }
+ //var tems = Task.Run(() => mqtt.MESForProduceAsync(newp, M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
+ //M141Config.mesnum2++;
+ //LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"PlcNumForAll锛屽墠绔橬G鎺掓枡涓攑lc瑙﹀彂娓呴浂浜у搧{newp.PID}鏁版嵁涓婁紶,缁撴灉涓簕newp.Result}");
+
+ }
+ catch
+ {
+
+ }
+ }
+ for (int i = 1; i < numplca; i++)
+ {
+ try
+ {
+ var plist = mysqlhelper.GetProductList(i + "_1");
+ ProductModel newp = new ProductModel();
+ newp.SEQUENCE = plist[0].SEQUENCE;
+ newp.PID = plist[0].PID;
+ newp.BasketCode = plist[0].BasketCode;
+ newp.Zword = plist[0].Zword;
+ newp.Result = "NG";
+ newp.SN = plist[0].SN;
+ if (M141Config.IsfinDevice)
+ {
+ SummaryAllprodata(newp);
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鎻愬墠NG鍔犲叆姹囨�绘暟鎹姤琛ㄧ粺璁�");
+ }
+ if (M141Config.ISupNG)
+ {
+ var tems = Task.Run(() => mqtt.MESForProduceAsync(newp, M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
+ M141Config.mesnum2++;
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鍚姩NG涓婁紶");
+ }
+ else
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{newp.PID}鍏抽棴NG涓婁紶");
+ }
+
+ //var tems = Task.Run(() => mqtt.MESForProduceAsync(newp, M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
+ //M141Config.mesnum2++;
+ //LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"numplca锛屽墠绔橬G鎺掓枡涓攑lc瑙﹀彂娓呴浂浜у搧{newp.PID}鏁版嵁涓婁紶,缁撴灉涓簕newp.Result}");
+ }
+ catch
+ {
+ }
+ }
+ }
+ PlcNumForAll = numplca;
+ }
+
+ }
+
+ }
+
+ //ReplyPlcData(positionName, config.TriggerValue);
return pList;
@@ -1011,26 +1555,25 @@
}
-
-
-
public void SummaryAllprodata(ProductModel p)
{
+
_taskFactory.StartNew(() =>
{
try
{
-
ProductModel newp = new ProductModel();
newp.SEQUENCE = p.SEQUENCE;
newp.PID = p.PID;
newp.BasketCode = p.BasketCode;
+ newp.Zword = p.Zword;
newp.Result = p.Result;
newp.SN = p.SN;
- newp.Details.AddRange(p.Details);
+ Thread.Sleep(500);
var plist = mysqlhelper.GetProductList(p.SEQUENCE);
-
+
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"浜у搧{p.PID}妫�娴嬬粨鏋滀负{p.Result}浠庢暟鎹簱涓幏鍙栫殑鏁版嵁涓轰骇鍝亄plist[0].PID}妫�娴嬬粨鏋滀负{plist[0].Result}");
if (plist != null)
{
foreach (var item in plist)
@@ -1039,13 +1582,35 @@
}
}
+ //LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"AllDeviceProductRecord浠庢暟鎹簱鑾峰彇鍒版暟鎹畕p.SEQUENCE} plist鏁伴噺{plist.Count} Details鏁伴噺{newp.Details.Count}");
+
+ //newp.Details.AddRange(p.Details);
+
List<string> specHeadListforall = new List<string>();
List<string> positionListforall = new List<string>();
- string csvHeadforall = p.GetCSVHead(ref specHeadListforall, ref positionListforall);
- CSVRecordAsync($"AllDeviceProductRecord.csv", p.GetCSVData(specHeadListforall, positionListforall), csvHeadforall);
+ string csvHeadforall = newp.GetCSVHead(ref specHeadListforall, ref positionListforall);
+ string csvDataforall = newp.GetCSVData(specHeadListforall, positionListforall);
+
+ string data = "";
+
+ string Head = "鏃堕棿,PID,鏍忓叿鐮�,鐗╂枡鐮�,鏉＄爜,姹囨�绘娴嬬粨鏋�,S2_P1妫�娴嬫槑缁�,S2_P2妫�娴嬫槑缁�,S2_P3妫�娴嬫槑缁�,S3_P1妫�娴嬫槑缁�,S3_P2妫�娴嬫槑缁�,S4_P1妫�娴嬫槑缁�,S4_P2妫�娴嬫槑缁�,S5_P1妫�娴嬫槑缁�,S5_P2妫�娴嬫槑缁�,S5_P3妫�娴嬫槑缁�,Barcode,SPC_A,SPC_BF_A1,SPC_BF_A2,SPC_BF_A3,SPC_BF_A4,SPC_BF_A5,SPC_BF_A6,SPC_BF_A7,SPC_BF_A8,SPC_BF_A9,SPC_BS_A1,SPC_BS_A2,SPC_BS_A3,SPC_BS_A4,SPC_BS_A5,SPC_BS_A6,SPC_BS_A7,SPC_BS_A8,SPC_BS_A9,SPC_BT_A100RES,SPC_BT_A101RES,SPC_BT_A102RES,SPC_BT_A103RES,SPC_BT_A104RES,SPC_BT_A105RES,SPC_BT_A106RES,SPC_BT_A107RES,SPC_BT_A108RES,SPC_BT_A109RES,SPC_BT_A10RES,SPC_BT_A110RES,SPC_BT_A111RES,SPC_BT_A112RES,SPC_BT_A113RES,SPC_BT_A11RES,SPC_BT_A12RES,SPC_BT_A13RES,SPC_BT_A14RES,SPC_BT_A15RES,SPC_BT_A16RES,SPC_BT_A17RES,SPC_BT_A18RES,SPC_BT_A19RES,SPC_BT_A1RES,SPC_BT_A20RES,SPC_BT_A21RES,SPC_BT_A22RES,SPC_BT_A23RES,SPC_BT_A24RES,SPC_BT_A25RES,SPC_BT_A26RES,SPC_BT_A27RES,SPC_BT_A28RES,SPC_BT_A29RES,SPC_BT_A2RES,SPC_BT_A30RES,SPC_BT_A31RES,SPC_BT_A32RES,SPC_BT_A33RES,SPC_BT_A34RES,SPC_BT_A35RES,SPC_BT_A36RES,SPC_BT_A37RES,SPC_BT_A38RES,SPC_BT_A39RES,SPC_BT_A3RES,SPC_BT_A40RES,SPC_BT_A41RES,SPC_BT_A42RES,SPC_BT_A43RES,SPC_BT_A44RES,SPC_BT_A45RES,SPC_BT_A46RES,SPC_BT_A47RES,SPC_BT_A48RES,SPC_BT_A49RES,SPC_BT_A4RES,SPC_BT_A50RES,SPC_BT_A51RES,SPC_BT_A52RES,SPC_BT_A53RES,SPC_BT_A54RES,SPC_BT_A55RES,SPC_BT_A56RES,SPC_BT_A57RES,SPC_BT_A58RES,SPC_BT_A59RES,SPC_BT_A5RES,SPC_BT_A60RES,SPC_BT_A61RES,SPC_BT_A62RES,SPC_BT_A63RES,SPC_BT_A64RES,SPC_BT_A65RES,SPC_BT_A66RES,SPC_BT_A67RES,SPC_BT_A68RES,SPC_BT_A69RES,SPC_BT_A6RES,SPC_BT_A70RES,SPC_BT_A71RES,SPC_BT_A72RES,SPC_BT_A73RES,SPC_BT_A74RES,SPC_BT_A75RES,SPC_BT_A76RES,SPC_BT_A77RES,SPC_BT_A78RES,SPC_BT_A79RES,SPC_BT_A7RES,SPC_BT_A80RES,SPC_BT_A81RES,SPC_BT_A82RES,SPC_BT_A83RES,SPC_BT_A84RES,SPC_BT_A85RES,SPC_BT_A86RES,SPC_BT_A87RES,SPC_BT_A88RES,SPC_BT_A89RES,SPC_BT_A8RES,SPC_BT_A90RES,SPC_BT_A91RES,SPC_BT_A92RES,SPC_BT_A93RES,SPC_BT_A94RES,SPC_BT_A95RES,SPC_BT_A96RES,SPC_BT_A97RES,SPC_BT_A98RES,SPC_BT_A99RES,SPC_BT_A9RES,SPC_C";
+
+ for (int i = 0; i < Head.Split(",").ToList().Count(); i++)
+ {
+ int index = csvHeadforall.Split(",").ToList().IndexOf(Head.Split(",").ToList()[i]);
+ if (index != -1)
+ {
+ data += $"{string.Join(" ", csvDataforall.Split(",").ToList()[index])},";
+ }
+ else
+ {
+ data += "NA,";
+ }
+ }
+ CSVRecordAsync($"AllDeviceProductRecord.csv", data, Head);
}
- catch(Exception exx)
+ catch (Exception exx)
{
LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, "AllDeviceProductRecord鏁版嵁姹囨�诲紓甯� " + exx.ToString());
}
@@ -1056,13 +1621,285 @@
-
-
#endregion
+
+ List<DefectNGRecord> DefectNGRecordList = new List<DefectNGRecord>();
+
+ public void InitialContinuousNGAlarm()
+ {
+ DefectNGRecordList = M141Config.ContinuousNGAlarmColletion.Where(u => u.IsEnabled).Select(u =>
+ {
+ DefectNGRecord record = new DefectNGRecord();
+ record.DefectName = u.DefectType;
+ record.AlarmSetting = u;
+ return record;
+ }).ToList();
+ OnContinuousNGAlarmRaised = NGAlarmRaised;
+ if (M141Config.ContinuousNGAlarmAddress > 0 && Plc1 != null)
+ {
+ if (!Plc1.WriteSingleAddress(M141Config.ContinuousNGAlarmAddress, 0, out string error))
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"杩炵画NG鐩戞帶閫氱煡PLC閲嶇疆鎶ヨ澶辫触锛寋error}");
+ }
+ }
+ }
+ public async void CheckContinuousNGAlarmAsync(ProductModel product)
+ {
+ await Task.Run(() =>
+ {
+ if (!M141Config.IsEnableContinuousNGAlarm)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"杩炵画NG鎶ヨ鎬诲紑鍏冲凡鍏抽棴");
+ return;
+ }
+
+ if (DefectNGRecordList.Count == 0)
+ return;
+
+ string allMsg = "";
+ bool isAlarmRaised = false;
+ int alarmType = 0;
+ string ngItem = "";
+ try
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"杩炵画NG鏁版嵁璁板綍");
+ DefectNGRecordList.ForEach(d =>
+ {
+ string alarmMsg = "";
+ int alarmTypeTemp = 0;
+
+ if (product.Result == "OK")
+ {
+ if (d.CheckIsAlarmRaised(product.Result == "OK", out alarmMsg, out alarmTypeTemp))
+ {
+ allMsg += $"{alarmMsg}\r\n";
+
+ isAlarmRaised = true;
+ ngItem = "浜у搧缁撴灉";
+ alarmType = alarmTypeTemp;
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{product.PID}鏁版嵁缁撴灉涓簕product.Result}鍙備笌杩炵画NG缁熻");
+ }
+ }
+ else
+ {
+ if (product.Result.Contains(d.DefectName))
+ {
+ if (d.CheckIsAlarmRaised(!product.Result.Contains(d.DefectName), out alarmMsg, out alarmTypeTemp))
+ {
+ allMsg += $"{alarmMsg}\r\n";
+ isAlarmRaised = true;
+ ngItem = "浜у搧缁撴灉";
+ alarmType = alarmTypeTemp;
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{product.PID}鏁版嵁缁撴灉涓簕product.Result}鍙備笌杩炵画NG缁熻");
+ }
+ }
+ }
+ });
+ }
+ catch (Exception ex)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Warning, $"杩炵画NG鏁版嵁璁板綍澶辫触");
+ }
+ if (isAlarmRaised)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Warning, $"杩炵画NG鐩戞帶鎶ヨ锛寋allMsg}");
+ if (M141Config.IsOperatorReset)
+ {
+ if (M141Config.ContinuousNGAlarmAddress > 0 && Plc1 != null)
+ {
+ if (!Plc1.WriteSingleAddress(M141Config.ContinuousNGAlarmAddress, 1, out string error))
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"杩炵画NG鐩戞帶閫氱煡PLC閲嶇疆鎶ヨ澶辫触锛寋error}");
+ }
+ }
+ OnContinuousNGAlarmRaised?.Invoke(true, allMsg);
+ }
+ else
+ {
+ Task.Delay(50).Wait();
+ ResetContinuousNGAlarm();
+ }
+ }
+ });
+ }
+
+ object _continuousNGAlarmLock = new object();
+
+ FrmContinuousNGAlarm _continuousNGAlarmFrm = null;
+ private async void NGAlarmRaised(bool isRaiseAlarm, string alarmMsg)
+ {
+ await Task.Run(() =>
+ {
+ if (isRaiseAlarm)
+ {
+ if (_continuousNGAlarmFrm == null)
+ {
+ lock (_continuousNGAlarmLock)
+ {
+ if (_continuousNGAlarmFrm == null)
+ {
+ _continuousNGAlarmFrm = new FrmContinuousNGAlarm();
+
+ _continuousNGAlarmFrm.TopMost = true;
+
+ _continuousNGAlarmFrm.FormClosed += _continuousNGAlarmFrm_FormClosed;
+
+ Task.Run(() =>
+ {
+ _continuousNGAlarmFrm.ShowDialog();
+
+ });
+ }
+ }
+ }
+ Task.Delay(100).Wait();
+ _continuousNGAlarmFrm.ShowAlarmMsg(alarmMsg);
+ }
+ else
+ {
+ if (_continuousNGAlarmFrm != null)
+ {
+ _continuousNGAlarmFrm.Close();
+ }
+
+ }
+ });
+
+ }
+
+ private void _continuousNGAlarmFrm_FormClosed(object? sender, FormClosedEventArgs e)
+ {
+ ResetContinuousNGAlarm();
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"杩炵画NG鎶ヨ宸插浣�");
+ _continuousNGAlarmFrm = null;
+ }
+
+ public void ResetContinuousNGAlarm()
+ {
+ //杩炵画NG澶嶄綅
+ DefectNGRecordList.Where(u => u.IsAlarmRaised).ToList().ForEach(u => u.ResetAlarm());
+ if (M141Config.ContinuousNGAlarmAddress > 0 && Plc1 != null)
+ {
+ if (!Plc1.WriteSingleAddress(M141Config.ContinuousNGAlarmAddress, 0, out string error))
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"杩炵画NG鐩戞帶閫氱煡PLC閲嶇疆鎶ヨ澶辫触锛寋error}");
+ }
+ }
+
+ }
+
+ [ProcessMethod("", "ContinuousNGAlarmTest", "杩炵画NG鎶ヨ娴嬭瘯", InvokeType.TestInvoke)]
+ public ResponseMessage ContinuousNGAlarmTest(IOperationConfig config, IDevice invokeDevice, IDevice sourceDevice)
+ {
+ ProductModel p = new ProductModel();
+
+ p.Result = config.TriggerStr;
+
+ CheckContinuousNGAlarmAsync(p);
+
+ return new ResponseMessage();
+ }
}
+ public class DefectNGRecord
+ {
+ public string DefectName { get; set; }
+ public List<DateTime> NGRecords { get; set; } = new List<DateTime>();
+ public int ContinuousNGNum { get; set; } = 0;
+ public ContinuousNGAlarm AlarmSetting { get; set; }
+ private object _lockObj = new object();
+ public bool IsAlarmRaised = false;
+ bool _isContinuousAlarm = false;
-}
+ bool _timeAlarm = false;
+
+ public bool CheckIsAlarmRaised(bool isOK, out string alarmMsg, out int alarmType)
+ {
+ alarmType = 0;
+ alarmMsg = "";
+ bool isAlarmRasied = false;
+
+ if (IsAlarmRaised)
+ return false;
+
+ lock (_lockObj)
+ {
+ if (IsAlarmRaised)
+ return false;
+
+ if (isOK)
+ {
+ ContinuousNGNum = 0;
+ }
+ else
+ {
+ //杩炵画NG鏁伴噺闃堝��
+ if (AlarmSetting.ContinuousNumThreshold > 0)
+ {
+ ContinuousNGNum++;
+ CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{DefectName}杩炵画NG鏁伴噺涓猴細{ContinuousNGNum}涓�");
+ }
+ //鏃堕棿鍐匩G鏁伴噺闃堝��
+ if (AlarmSetting.TimePeriodNumThresold > 0)
+ {
+ NGRecords.Add(DateTime.Now);
+ }
+ }
+
+ if (NGRecords.Count >= AlarmSetting.TimePeriodNumThresold && NGRecords.Count > 0)
+ {
+
+ NGRecords = NGRecords.Skip(NGRecords.Count - AlarmSetting.TimePeriodNumThresold).OrderBy(u => u).ToList();
+
+ int timeInMinute = (int)Math.Ceiling((NGRecords[NGRecords.Count - 1] - NGRecords[0]).TotalMinutes);
+ //鐩戞帶鏃堕棿娈�
+ if (timeInMinute <= AlarmSetting.TimePeriod)
+ {
+ isAlarmRasied = true;
+ alarmMsg += $"{DefectName}{timeInMinute}鍒嗛挓鍐匩G{NGRecords.Count}涓� ";
+ alarmType = AlarmSetting.TimePeriodAlarmType;
+ _timeAlarm = true;
+ }
+ }
+
+ if (ContinuousNGNum >= AlarmSetting.ContinuousNumThreshold)
+ {
+ isAlarmRasied = true;
+ alarmMsg += $"{DefectName}杩炵画NG{ContinuousNGNum}涓� ";
+ alarmType = AlarmSetting.ContinuousAlarmType;
+ _isContinuousAlarm = true;
+ }
+ IsAlarmRaised = isAlarmRasied;
+ return isAlarmRasied;
+ }
+ }
+
+ public void ResetAlarm()
+ {
+ string msg = "";
+ lock (_lockObj)
+ {
+ IsAlarmRaised = false;
+ if (_isContinuousAlarm)
+ {
+ _isContinuousAlarm = false;
+ ContinuousNGNum = 0;
+ msg += "杩炵画NG鎶ヨ ";
+ }
+
+ if (_timeAlarm)
+ {
+
+ _timeAlarm = false;
+ NGRecords.Clear();
+ msg += "鏃舵鍐匩G鎶ヨ ";
+ }
+ }
+ CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{DefectName}{msg}宸查噸缃�");
+ }
+
+ }
+}
\ No newline at end of file
--
Gitblit v1.8.0