quanzhou
2026-03-07 f6326d8e85b55a290ca88c9f14a0f2a9ecbf6971
src/Bro.M141.Process/M141Process.cs
@@ -643,6 +643,7 @@
                        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();
@@ -961,15 +962,11 @@
                                LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"产品{p.PID}_{p.SEQUENCE}工位{measureBind.WorkPosition}的第{measureBind.CheckIndex}检测完成,{msg}");
                            }
                        });
                    }
                    catch (Exception ex)
                    {
                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"{measureBind.WorkPosition},产品{string.Join(",", products.Select(u => u.PID))}的NG图片保存异常,{ex.GetExceptionMessage()}");
                    }
                }
            });
        }
@@ -1403,219 +1400,212 @@
                        }
                        _ct = DateTime.Now;
                        if (M141Config.ISupMES && (M141Config.MESchannel == -1 || M141Config.MESchannel == 1))
                        {
                            if (M141Config.numpro >= 50)
                            {
                                M141Config.numpro = 0;
                            }
                        //if (M141Config.ISupMES && (M141Config.MESchannel == -1 || M141Config.MESchannel == 1))
                        //{
                        //    if (M141Config.numpro >= 50)
                        //    {
                        //        M141Config.numpro = 0;
                        //    }
                            string Msgreceice = null;
                        //    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上传");
                        //    if (pList[0].Result == "OK")
                        //    {
                        //        //M141Config.numpro++;
                        //        //Msgreceice = Task.Run(() => mqtt.MESForProduceAsync(pList[0], M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
                        //        LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"产品{pList[0].PID}汇总OK暂时不上传");
                        //    }
                        //    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,开启关闭NG上传MES");
                                }
                                else
                                {
                                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{pList[0].PID}数据上传MES异常 返回数据为null");
                                }
                            }
                            else
                            {
                                try
                                {
                                    var obj = JsonConvert.DeserializeObject<AutoLineMacBarcodeQueueBak>(Msgreceice);
                        //        }
                        //        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,开启关闭NG上传MES");
                        //        }
                        //        else
                        //        {
                        //            LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{pList[0].PID}数据上传MES异常 返回数据为null");
                        //        }
                        //    }
                        //    else
                        //    {
                        //        try
                        //        {
                        //            var obj = JsonConvert.DeserializeObject<AutoLineMacBarcodeQueueBak>(Msgreceice);
                                    if (obj.zstatus == "200")
                                    {
                                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"产品{pList[0].PID}数据上传MES成功  {Msgreceice}");
                        //            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);
                                        }
                        //                if (M141Config.Isprint && !string.IsNullOrEmpty(obj.tary_label))
                        //                {
                        //                    StartPrint(obj.tary_label, "Honeywell PX240S(300 dpi)");
                        //                }
                        //            }
                        //            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
                        //    {
                                    }
                                    else
                                    {
                                        LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{pList[0].PID}数据上传MES失败  {Msgreceice}");
                                    }
                                }
                                catch
                                {
                                    LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{pList[0].PID}数据上传MES异常  {Msgreceice}");
                                }
                            }
                        //        if (PlcNumForAll == -1)
                        //        {
                        //            PlcNumForAll = numplca;
                        //        }
                        //        int differ = numplca - PlcNumForAll;
                        //        LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"两个产品中间的差值differ为{differ}");
                            int numplca = Convert.ToInt32(pList[0].SEQUENCE.Split('_')[0]);
                            LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"plc给出的产品序号为{numplca}");
                        //        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;
                            lock (plcnumlock)//1-29999
                            {
                        //                    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上传");
                        //                    }
                                if (PlcNumForAll == -1)
                                {
                                    PlcNumForAll = numplca;
                                }
                        //                }
                        //                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},numplca为{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上传");
                        //                    }
                                int differ = numplca - PlcNumForAll;
                        //                }
                        //                catch
                        //                {
                                LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"两个产品中间的差值differ为{differ}");
                        //                }
                        //            }
                        //            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上传");
                        //                    }
                                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;
                        //                    //var tems = Task.Run(() => mqtt.MESForProduceAsync(newp, M141Config.mesnum2.ToString(), M141Config.numpro)).Result;
                        //                    //M141Config.mesnum2++;
                        //                    //LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"numplca,前站NG排料且plc触发清零产品{newp.PID}数据上传,结果为{newp.Result}");
                        //                }
                        //                catch
                        //                {
                        //                }
                        //            }
                        //        }
                        //        PlcNumForAll = numplca;
                        //    }
                                            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},numplca为{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,前站NG排料且plc触发清零产品{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,前站NG排料且plc触发清零产品{newp.PID}数据上传,结果为{newp.Result}");
                                        }
                                        catch
                                        {
                                        }
                                    }
                                }
                                PlcNumForAll = numplca;
                            }
                        }
                        else
                        {
                            LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"已关闭mes连接或者数据上传接口");
                        }
                        //}
                        //else
                        //{
                        //    LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"已关闭mes连接或者数据上传接口");
                        //}
                    }
                    //ReplyPlcData(positionName, config.TriggerValue);
@@ -1631,7 +1621,6 @@
            });
        }
        public void ReplyPlcData(WorkPositionSet p, List<bool> result)
        {
@@ -1696,7 +1685,7 @@
                            data += "NA,";
                        }
                    }
                    CSVRecordAsync($"AllDeviceProductRecord.csv", data, Head);
                    CSVRecordAsync($"AllDeviceProductRecord_{DateTime.Now.ToString("yyyyMMdd")}.csv", data, Head);
                }
                catch (Exception exx)
@@ -1706,9 +1695,6 @@
            });
        }
        #endregion
@@ -1894,27 +1880,29 @@
        PrintDocument printDocument1 = new PrintDocument();
        string Printmessage = "";
        public void StartPrint(string str)
        public void StartPrint(string str, string PrinterName)
        {
            try
            {
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"打印机打印{str}");
                int ttwith = 240;
                int ttheigh = 80;
                Printmessage = str;
                this.printDocument1.DefaultPageSettings.PrinterSettings.PrinterName = "Honeywell PX240S (300 dpi)";
                this.printDocument1.DefaultPageSettings.PrinterSettings.PrinterName = PrinterName;
                this.printDocument1.DefaultPageSettings.PaperSize = new PaperSize("Custum", ttwith, ttheigh);
                this.printDocument1.PrintController = new System.Drawing.Printing.StandardPrintController();
                this.printDocument1.Print();
            }
            catch
            catch(Exception ex)
            {
                LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"打印机打印出错:{ex.ToString()}");
            }
        }
        //C229M2508250500002
@@ -1965,11 +1953,6 @@
        #endregion
    }