From 655481176b286fa91ef9d171fd8cbfac2be2545a Mon Sep 17 00:00:00 2001
From: kingno <30263@KINGNO>
Date: 星期四, 10 四月 2025 10:43:02 +0800
Subject: [PATCH] 打印机,数据库格式更新
---
src/Bro.M141.Process/M141Process.cs | 324 ++++++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 279 insertions(+), 45 deletions(-)
diff --git a/src/Bro.M141.Process/M141Process.cs b/src/Bro.M141.Process/M141Process.cs
index 91e0e62..2fad3d8 100644
--- a/src/Bro.M141.Process/M141Process.cs
+++ b/src/Bro.M141.Process/M141Process.cs
@@ -22,7 +22,11 @@
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
@@ -52,10 +56,20 @@
M141Process_Mysql mysqlhelper = new M141Process_Mysql();
+
+
+
public override void InitialProcessMethods()
{
base.InitialProcessMethods();
+
+ if (ThHeartPlc == null)
+ {
+ ThHeartPlc = new Thread(Heartplc);
+ ThHeartPlc.IsBackground = true;
+ ThHeartPlc.Start();
+ }
}
public override void ProcessRunStateChanged()
@@ -72,11 +86,16 @@
}
public PLCBase Plc1;
- Thread ThHeartPlc;
+ bool devicestate = false;
+ PLCBase Plc2;
+ public Thread ThHeartPlc;
+
+
+
public override void Open()
{
base.Open();
-
+ devicestate = true;
ML = DeviceCollection.FirstOrDefault(u => u is MachineLearningBase) as MachineLearningBase;
if (ML == null)
{
@@ -97,43 +116,119 @@
_positionCheckTimeDict.Clear();
_positionSpecHeads.Clear();
+ mysqlhelper.IniDBIP(M141Config.IPforall);
- if (ThHeartPlc == null)
- {
- ThHeartPlc = new Thread(Heartplc);
- ThHeartPlc.IsBackground = true;
- ThHeartPlc.Start();
- }
}
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);
+ 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
@@ -141,10 +236,93 @@
}
- 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
+ {
+
+ }
+
+ Thread.Sleep(1000);
}
}
-
/// <summary>
/// 缃戠粶棰勭儹
@@ -152,7 +330,6 @@
/// <exception cref="NotImplementedException"></exception>
private void NetWarmUp()
{
-
string warmUpImageFolder = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "WarmUp");
if (!Directory.Exists(warmUpImageFolder))
{
@@ -294,9 +471,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);
}
@@ -360,22 +536,16 @@
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)
{
@@ -704,6 +874,7 @@
try
{
ConcurrentDictionary<MeasureBind, IImageSet> imgSetDicts = new ConcurrentDictionary<MeasureBind, IImageSet>();
+ var positionSet = M141Config.WorkPositionCollection.Where(u => u.IsEnabled).FirstOrDefault(u => u.TriggerValue == triggerDatas[0]);
measureBinds.AsParallel().ForAll(b =>
{
@@ -715,6 +886,10 @@
try
{
imgSetDicts[b] = CollectHImage(camera, b.SnapshotOpConfig);
+ if (positionSet.ispiccover)
+ {
+ Plc1.WriteSingleAddress(positionSet.plcover, 1, out _);
+ }
}
catch (Exception ea)
{
@@ -815,6 +990,20 @@
p.SEQUENCE = $"{tempSequence}_{i}";
p.PID = $"{pidstr}T_{i}";
+ if (M141Config.Isreadbasketcode)
+ {
+ p.BasketCode = M141Config.basketcode;
+ }
+ else
+ {
+ p.BasketCode = mysqlhelper.Getbasketcode(p.SEQUENCE, out string sntem);
+ p.SN = sntem;
+ 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 });
@@ -827,9 +1016,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>();
@@ -930,24 +1119,27 @@
plcresult.Add(isOK);
List<string> specHeads = new List<string>();
string head = p.GetCSVHead(ref specHeads, positionName);
- if (!_positionSpecHeads.ContainsKey(positionName))
- {
- _positionSpecHeads[positionName] = specHeads;
- }
- string data = p.GetCSVData(_positionSpecHeads[positionName], positionName);
+ //_positionSpecHeads[positionName] = specHeads;
+
+ 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();
+ ReplyPlcData(positionSet, plcresult);
+ mysqlhelper.UpdateProduct(p);
if (positionSet.IsLastPosition)
{
UpdateProductResultAsync(p);
+ mysqlhelper.NewForAll(p, M141Config.StationCode);
+ if (M141Config.IsfinDevice)
+ {
+ SummaryAllprodata(p);
+ }
}
});
- ReplyPlcData(positionSet, plcresult);
+ //ReplyPlcData(positionSet, plcresult);
if (positionSet.IsLastPosition)
{
if (_ct != null)
@@ -993,6 +1185,48 @@
}
+ 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.Result = p.Result;
+ newp.SN = p.SN;
+ var plist = mysqlhelper.GetProductList(p.SEQUENCE);
+
+
+ if (plist != null)
+ {
+ foreach (var item in plist)
+ {
+ newp.Details.AddRange(item.Details);
+ }
+ }
+
+ //newp.Details.AddRange(p.Details);
+
+ List<string> specHeadListforall = new List<string>();
+ List<string> positionListforall = new List<string>();
+ string csvHeadforall = newp.GetCSVHead(ref specHeadListforall, ref positionListforall);
+ CSVRecordAsync($"AllDeviceProductRecord.csv", newp.GetCSVData(specHeadListforall, positionListforall), csvHeadforall);
+
+ }
+ catch (Exception exx)
+ {
+ LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, "AllDeviceProductRecord鏁版嵁姹囨�诲紓甯� " + exx.ToString());
+ }
+ });
+
+ }
+
+
+
+
#endregion
}
--
Gitblit v1.8.0