From 745d1ce73a3b27d2a3507843c8060755a0c95765 Mon Sep 17 00:00:00 2001
From: quanzhou <quan.zhou@broconcentric.com>
Date: 星期二, 21 十月 2025 19:06:36 +0800
Subject: [PATCH] 打印机条码格式修改,增添一个点检功能方法

---
 src/Bro.M141.Process/M141Process.cs |  201 ++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 145 insertions(+), 56 deletions(-)

diff --git a/src/Bro.M141.Process/M141Process.cs b/src/Bro.M141.Process/M141Process.cs
index 4c0649f..fdec168 100644
--- a/src/Bro.M141.Process/M141Process.cs
+++ b/src/Bro.M141.Process/M141Process.cs
@@ -25,11 +25,14 @@
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Drawing.Imaging;
+using System.Drawing.Printing;
 using System.IO;
 using System.Linq;
 using System.Text;
 using Windows.ApplicationModel.Appointments;
+using Windows.Devices.PointOfService;
 using ZXing;
+using ZXing.QrCode;
 using static Bro.Common.Helper.EnumHelper;
 using static Bro.Process.ProcessControl;
 using static Org.BouncyCastle.Math.EC.ECCurve;
@@ -80,6 +83,8 @@
                 ThHeartPlc.IsBackground = true;
                 ThHeartPlc.Start();
             }
+
+            printDocument1.PrintPage += new PrintPageEventHandler(printDocument_Print);
         }
 
         public override void ProcessRunStateChanged()
@@ -98,6 +103,7 @@
         public PLCBase Plc1;
         bool devicestate = false;
         PLCBase Plc2;
+        public PLCBase Plc3;
         public Thread ThHeartPlc;
 
         public RabbitMQHelper mqtt;
@@ -122,6 +128,8 @@
             }
             _errorSpec = M141Config.SpecCollection.FirstOrDefault(u => u.Code == M141Config.CheckErrorSpecCode) as Spec;
 
+           
+
             //InitialProductList();
 
             NetWarmUp();
@@ -138,8 +146,12 @@
                 mqtt = new RabbitMQHelper(M141Config.zIP, M141Config.zport, M141Config.zuser, M141Config.zpassword);
                 mqtt.Connect(M141Config.MESchannel);
             }
+            else
+            {
+                LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"宸插叧闂笂浼爉es");
+            }
 
-            InitialContinuousNGAlarm();
+                InitialContinuousNGAlarm();
         }
 
 
@@ -191,6 +203,7 @@
 
             Dictionary<string, List<int>> StateDIC = new Dictionary<string, List<int>>();
             List<string> AlarmTypeList = new List<string>();
+           
 
             int numplc = 0;
             while (true)
@@ -235,18 +248,18 @@
                     //        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();
-                        //        }
-                        //    }
-                        //}
+                    //        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)
                 {
@@ -290,9 +303,7 @@
                                 var alrams = item1.AlarmDetails;
 
                                 var plcdev = DeviceCollection.FirstOrDefault(u => u.Id == item1.plcname) as PLCBase;
-
-                                  
-                                
+  
                                 foreach (var item in alrams.GroupBy(u => u.address))
                                 {
                                     int add = item.Key;
@@ -312,7 +323,7 @@
 
                                             AlarmTypeList.Add(item2.alarmtype);
 
-                                            LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"鎶ヨ绫诲埆{item2.alarmtype}鍔犲叆闃熷垪,闃熷垪涓暟涓簕AlarmTypeList.Count}");
+                                       
                                         }
                                     }
                                 }
@@ -328,45 +339,36 @@
                                     {
 
                                         StateDIC[StateDICKey] = new List<int>();
-
-                                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"鎶ヨ绫诲埆{StateDICKey}鍔犲叆瀛楀吀锛歋tateDIC");
+                                       
 
                                     }
 
-                                    //if (!StateDIC.ContainsKey(plcdev.Name))
-                                    //{
-
-                                    //       StateDIC[plcdev.Name] = new List<int>();
-                                    //}
                                 }
+                           
+                                List<int> list = new List<int>();
 
                                 Dictionary<string, AlarmTypeData> AlarmType = new Dictionary<string, AlarmTypeData>();
 
-                                List<int> list = new List<int>();
-                             
                                 foreach (var item in alrams)
                                 {
-                                    if (!AlarmType.ContainsKey(item.alarmtype))
+                                    string key = item.alarmtype;
+
+                                    if (!AlarmType.TryGetValue(key, out var alarmData))
                                     {
-                                        AlarmType.Add(item.alarmtype, new AlarmTypeData()
+                                        // 涓嶅瓨鍦紝鍒涘缓鏂扮殑
+                                        alarmData = new AlarmTypeData()
                                         {
                                             CSVhead = csvhead,
                                             CSVdata = csvdata,
-                                        });
+                                        };
+                                        AlarmType.Add(item.alarmtype, alarmData);
 
                                     }
 
-                                    if (AlarmType.ContainsKey(item.alarmtype))
-                                    {
-                                        AlarmType[item.alarmtype].CSVhead += $",{item.alarmname}";
+                                    alarmData.CSVhead += $",{item.alarmname}";
+                                    alarmData.CSVdata += $",{(item.value == 1 ? "1" : "")}";
+                                    alarmData.AlarmTypeValue.Add(item.value);
 
-                                        AlarmType[item.alarmtype].CSVdata += $",{(item.value == 1 ? "1" : "")}";
-
-                                        AlarmType[item.alarmtype].AlarmTypeValue.Add(item.value);
-
-                                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"鎶ヨ绫诲埆{item.alarmtype}锛涙暟鍊納item.value}鍔犲叆瀛楀吀锛欰larmType");
-                                    }
-                                    
                                 }
                                 foreach(var item in AlarmType.Keys)
                                 {
@@ -377,13 +379,13 @@
 
                                     if (!StateDIC[key].SequenceEqual(list))
                                     {
-                                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"{plcdev.Name}鎶ヨ绫诲瀷锛歿item}鐨勪俊鍙峰彂鐢熷彉鍖�");
+                                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"{plcdev.Name}鎶ヨ绫诲瀷锛歿item}鐨勪俊鍙峰彂鐢熷彉鍖�,淇濆瓨鐨勬暟鎹负{AlarmType[item].CSVdata}");
 
                                         StateDIC[key].Clear();
 
                                         StateDIC[key].AddRange(list);
 
-                                        CSVRecordAsync($"PLCstate_{key}.csv", AlarmType[item].CSVhead, AlarmType[item].CSVdata);
+                                        CSVRecordAsync($"PLCstate_{DateTime.Now.ToString("yyyyMMdd")}_{key}.csv", AlarmType[item].CSVdata, AlarmType[item].CSVhead);
 
                                         var showdata = alrams.Where(u => u.value == 1).Select(u => u.alarmname).ToList();
 
@@ -404,9 +406,9 @@
 
                                 }                                
                             }
-                            catch
+                            catch(Exception EXC)
                             {
-
+                                LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"PLC鎶ヨ瀛樺偍璁板綍鍙戠敓寮傚父 {EXC.ToString()}");
                             }
                         }
                     }
@@ -442,7 +444,7 @@
 
         public class AlarmTypeData
         {
-            public List <int> AlarmTypeValue;
+            public List <int> AlarmTypeValue = new List<int>();
 
             public string CSVhead;
 
@@ -640,6 +642,9 @@
 
                         if (measureBind.WorkPosition == "P1" && M141Config.StationCode == "S5" && detectResults.GetDefectDescList().Count == 0)
                         {
+                            var defecttem1 = detectResults.SelectMany(u => u.AllNetResults).SelectMany(m => m.DetectDetails).Select(detail => detail.ClassName).ToList();
+                            LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"{products[0].SN}  S3S5妫�娴� 缂洪櫡鍚嶇О闆嗗悎涓簕string.Join(",", defecttem1)}");
+
                             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);
@@ -891,7 +896,6 @@
             });
         }
 
-
         public async Task RunImageCheckAsync(List<ProductModel> products, string triggerText, string triggerSource, MeasureBind measureBind)
         {
             await Task.Run(() =>
@@ -970,7 +974,6 @@
             });
         }
 
-
         private void RunCustomizedMethod(List<ProductModel> products, string triggerText, string triggerSource, IImageSet imgSet, string methodId, List<DetectResult> resultList)
         {
             try
@@ -1017,10 +1020,6 @@
                 LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"鑷畾涔夋娴嬭繃绋嬪紓甯革紝{ex.GetExceptionMessage()}");
             }
         }
-
-
-
-
 
         #region plc
         public ResponseMessage RunImageCheck_plc(IOperationConfig config)
@@ -1099,7 +1098,6 @@
 
             CheckPositionDoneAsync_plc(measureBinds[0].WorkPosition, inputSequence, config, cameraIds);
 
-         
             return msg;
 
         }
@@ -1150,8 +1148,6 @@
                     LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"鐩告満{camera.Name}妫�娴嬪墠娓呯悊缂撳瓨瀹屾垚");
                 }
             });
-
-
 
             inputSequence = triggerDatas[triggerDatas.Length - 1];
 
@@ -1237,13 +1233,12 @@
 
         public async Task<List<ProductModel>> CheckPositionDoneAsync_plc(string positionName, string inputSequence, IOperationConfig config, List<string> cameraIds)
         {
-           
+
             string triggerSource = config.TriggerSource;
             return await _taskFactory.StartNew(() =>
             {
                 try
                 {
-                    
                     string index = config.TriggerStr.Split(',')[1];
                     var positionSet = M141Config.WorkPositionCollection.FirstOrDefault(u => u.PositionName == positionName);
 
@@ -1456,6 +1451,14 @@
                                     if (obj.zstatus == "200")
                                     {
                                         LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"浜у搧{pList[0].PID}鏁版嵁涓婁紶MES鎴愬姛  {Msgreceice}");
+
+                                        if (M141Config.Isprint && !string.IsNullOrEmpty(obj.tary_label))
+                                        {
+                                            StartPrint(obj.tary_label);
+                                        }
+
+
+
                                     }
                                     else
                                     {
@@ -1609,7 +1612,10 @@
                             }
 
                         }
-
+                        else
+                        {
+                            LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"宸插叧闂璵es杩炴帴鎴栬�呮暟鎹笂浼犳帴鍙�");
+                        }
                     }
 
                     //ReplyPlcData(positionName, config.TriggerValue);
@@ -1882,6 +1888,89 @@
 
             return new ResponseMessage();
         }
+
+
+        #region  鎵撳嵃鏈虹浉鍏�
+        PrintDocument printDocument1 = new PrintDocument();
+        string Printmessage = "";
+
+        public void StartPrint(string str)
+        {
+            try
+            {
+                int ttwith = 240;
+                int ttheigh = 80;
+                Printmessage = str;
+
+                this.printDocument1.DefaultPageSettings.PrinterSettings.PrinterName = "Honeywell PX240S (300 dpi)";
+                this.printDocument1.DefaultPageSettings.PaperSize = new PaperSize("Custum", ttwith, ttheigh);
+
+                this.printDocument1.PrintController = new System.Drawing.Printing.StandardPrintController();
+                this.printDocument1.Print();
+
+            }
+            catch
+            {
+
+            }
+
+        }
+
+
+        //C229M2508250500002
+        private void printDocument_Print(object sender, PrintPageEventArgs e)
+        {
+            Font fntTxt = new Font("榛戜綋", 15, System.Drawing.FontStyle.Bold);//姝f枃鏂囧瓧               
+            System.Drawing.Brush brush = new SolidBrush(System.Drawing.Color.Black);//鐢诲埛           
+            try
+            {
+                var g = e.Graphics;
+                g.Clear(Color.White);
+                BarcodeWriter writer = new BarcodeWriter();
+                writer.Format = BarcodeFormat.QR_CODE;
+                QrCodeEncodingOptions options = new QrCodeEncodingOptions()
+                {
+                    DisableECI = true,//璁剧疆鍐呭缂栫爜
+                    CharacterSet = "UTF-8",  //璁剧疆浜岀淮鐮佺殑瀹藉害鍜岄珮搴�
+                    Width = 60,
+                    Height = 60,
+                    Margin = 1//璁剧疆浜岀淮鐮佺殑杈硅窛,鍗曚綅涓嶆槸鍥哄畾鍍忕礌
+                };
+
+                writer.Options = options;
+                Bitmap map = writer.Write(Printmessage);
+                e.Graphics.DrawImage(map, new System.Drawing.Point(90, 4));
+
+                // 鍦ㄤ簩缁寸爜涓嬫柟鐢诲唴瀹规枃瀛�
+                using (Font font = new Font("Arial", 10))
+                using (Brush brush3 = new SolidBrush(Color.Black))
+                {
+                    // 璁╂枃瀛楀眳涓埌浜岀淮鐮佷笅鏂�
+                    SizeF textSize = e.Graphics.MeasureString(Printmessage, font);
+                    float textX = 90 + (map.Width - textSize.Width) / 2;
+                    float textY = 1 + map.Height;
+
+                    e.Graphics.DrawString(Printmessage, font, brush3, textX, textY);
+                }
+
+            }
+            catch (Exception ee)
+            {
+     
+                LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, ee.ToString());
+            }
+        }
+
+
+
+
+        #endregion
+
+
+
+
+
+
     }
 
     public class DefectNGRecord

--
Gitblit v1.8.0