M200.git - Gitblit

			@@ -103,6 +103,7 @@
			public PLCBase Plc1;
			bool devicestate = false;
			PLCBase Plc2;
			public PLCBase Plc3;
			public Thread ThHeartPlc;

			public RabbitMQHelper mqtt;
			@@ -145,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, $"已关闭上传mes");
			}

			InitialContinuousNGAlarm();
			InitialContinuousNGAlarm();
			}


			@@ -318,7 +323,7 @@

			AlarmTypeList.Add(item2.alarmtype);

			LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"报警类别{item2.alarmtype}加入队列,队列个数为{AlarmTypeList.Count}");

			}
			}
			}
			@@ -334,8 +339,7 @@
			{

			StateDIC[StateDICKey] = new List<int>();

			LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"报警类别{StateDICKey}加入字典：StateDIC");


			}

			@@ -358,7 +362,7 @@
			CSVdata = csvdata,
			};
			AlarmType.Add(item.alarmtype, alarmData);
			LogAsync(DateTime.Now, EnumHelper.LogLevel.Detail, $"报警{item.alarmname}类别{key}作为key加入AlarmType字典");

			}

			alarmData.CSVhead += $",{item.alarmname}";
			@@ -638,6 +642,10 @@

			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);
			@@ -889,7 +897,6 @@
			});
			}


			public async Task RunImageCheckAsync(List<ProductModel> products, string triggerText, string triggerSource, MeasureBind measureBind)
			{
			await Task.Run(() =>
			@@ -968,7 +975,6 @@
			});
			}


			private void RunCustomizedMethod(List<ProductModel> products, string triggerText, string triggerSource, IImageSet imgSet, string methodId, List<DetectResult> resultList)
			{
			try
			@@ -1015,10 +1021,6 @@
			LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"自定义检测过程异常，{ex.GetExceptionMessage()}");
			}
			}





			#region plc
			public ResponseMessage RunImageCheck_plc(IOperationConfig config)
			@@ -1097,7 +1099,6 @@

			CheckPositionDoneAsync_plc(measureBinds[0].WorkPosition, inputSequence, config, cameraIds);


			return msg;

			}
			@@ -1148,8 +1149,6 @@
			LogAsync(DateTime.Now, EnumHelper.LogLevel.Action, $"相机{camera.Name}检测前清理缓存完成");
			}
			});



			inputSequence = triggerDatas[triggerDatas.Length - 1];

			@@ -1241,7 +1240,6 @@
			{
			try
			{

			string index = config.TriggerStr.Split(',')[1];
			var positionSet = M141Config.WorkPositionCollection.FirstOrDefault(u => u.PositionName == positionName);

			@@ -1406,216 +1404,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连接或者数据上传接口");
			//}
			}

			//ReplyPlcData(positionName, config.TriggerValue);
			@@ -1696,7 +1690,7 @@
			data += "NA,";
			}
			}
			CSVRecordAsync($"AllDeviceProductRecord.csv", data, Head);
			CSVRecordAsync($"AllDeviceProductRecord_{DateTime.Now.ToString("yyyyMMdd")}.csv", data, Head);

			}
			catch (Exception exx)
			@@ -1890,20 +1884,16 @@
			}






			#region 打印机相关
			PrintDocument printDocument1 = new PrintDocument();
			string Printmessage = "";

			public void StartPrint(string str)
			public void StartPrint(string str, string PrinterName)
			{
			try
			{
			int ttwith = 320;
			int ttheigh = 160;
			int ttwith = 240;
			int ttheigh = 80;
			Printmessage = str;

			this.printDocument1.DefaultPageSettings.PrinterSettings.PrinterName = "Honeywell PX240S (300 dpi)";
			@@ -1921,6 +1911,7 @@
			}



			//C229M2508250500002
			private void printDocument_Print(object sender, PrintPageEventArgs e)
			{
			@@ -1936,14 +1927,14 @@
			{
			DisableECI = true,//设置内容编码
			CharacterSet = "UTF-8", //设置二维码的宽度和高度
			Width = 123,
			Height = 123,
			Width = 60,
			Height = 60,
			Margin = 1//设置二维码的边距,单位不是固定像素
			};

			writer.Options = options;
			Bitmap map = writer.Write(Printmessage);
			e.Graphics.DrawImage(map, new System.Drawing.Point(90, 10));
			e.Graphics.DrawImage(map, new System.Drawing.Point(90, 4));

			// 在二维码下方画内容文字
			using (Font font = new Font("Arial", 10))
			@@ -1952,7 +1943,7 @@
			// 让文字居中到二维码下方
			SizeF textSize = e.Graphics.MeasureString(Printmessage, font);
			float textX = 90 + (map.Width - textSize.Width) / 2;
			float textY = 10 + map.Height;
			float textY = 1 + map.Height;

			e.Graphics.DrawString(Printmessage, font, brush3, textX, textY);
			}
			@@ -1969,11 +1960,6 @@


			#endregion






			}