SiWeiBoHeng/FaDianJi.git

			@@ -1,20 +1,24 @@
			ï»¿using Autofac.Core;
			using HslCommunication;
			using HslCommunication.Core;
			using Microsoft.VisualBasic.FileIO;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
			using Quartz;
			using SixLabors.ImageSharp.PixelFormats;
			using System;
			ï»¿using System;
			using System.Collections;
			using System.Collections.Generic;
			using System.ComponentModel;
			using System.Linq;
			using System.Reflection;
			using System.Text;
			using System.Threading.Tasks;
			using Autofac.Core;
			using HslCommunication;
			using HslCommunication.Core;
			using Microsoft.VisualBasic.FileIO;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.RefAndLookup;
			using Quartz;
			using SixLabors.ImageSharp.PixelFormats;
			using WIDESEAWCS_BasicInfoService;
			using WIDESEAWCS_Communicator;
			using WIDESEAWCS_Core.BaseRepository;
			using WIDESEAWCS_Core.Helper;
			using WIDESEAWCS_Model.Models;
			using WIDESEAWCS_QuartzJob;
			using WIDESEAWCS_QuartzJob.DeviceBase;
			using WIDESEAWCS_QuartzJob.StackerCrane.Enum;
			@@ -29,13 +33,15 @@
			private readonly IFormulaService _formulaService;
			private readonly IFormulaDetailService _formulaDetailService;
			private readonly IProcessInfoService _processInfoService;
			public PLCJob(IBoxingService boxingService, IBoxingDetailService boxingDetailService, IFormulaService formulaService, IFormulaDetailService formulaDetailService, IProcessInfoService processInfoService)
			private readonly IUnitOfWorkManage _unitOfWorkManage;
			public PLCJob(IBoxingService boxingService, IBoxingDetailService boxingDetailService, IFormulaService formulaService, IFormulaDetailService formulaDetailService, IProcessInfoService processInfoService, IUnitOfWorkManage unitOfWorkManage)
			{
			_boxingService = boxingService;
			_boxingDetailService = boxingDetailService;
			_formulaService = formulaService;
			_formulaDetailService = formulaDetailService;
			_processInfoService = processInfoService;
			_unitOfWorkManage = unitOfWorkManage;
			}
			private readonly string set = "0x16,0x4D,0x0D,0x30,0x34,0x30,0x31,0x44,0x30,0x35,0x2E";//ä¸»æºåéè®¾ç½®æ«ææ¨¡å¼ä¸ºä¸»æºæ¨¡å¼çå½ä»¤,æ«æå¨è¿åæ¥æ¶å°çå½ä»¤å<ACK>ï¼0x06ï¼åï¼å°æ«ææ¨¡å¼æ´æ¹ä¸ºä¸»æºæ¨¡å¼
			private readonly string Text = "å¼å¯æ«ç ";//ä¸»æºåéè®¾ç½®æ«ææ¨¡å¼ä¸ºä¸»æºæ¨¡å¼çå½ä»¤,æ«æå¨è¿åæ¥æ¶å°çå½ä»¤å<ACK>ï¼0x06ï¼åï¼å°æ«ææ¨¡å¼æ´æ¹ä¸ºä¸»æºæ¨¡å¼
			@@ -44,6 +50,14 @@
			static bool IsConnected1 = false;
			SerialPortCommunicator portCommunicator2 = new SerialPortCommunicator("COM2", 9600, "ä¸çº¿æ«ç æª");
			static bool IsConnected2 = false;
			SerialPortCommunicator portCommunicator17 = new SerialPortCommunicator("COM17", 9600, "åè£æ«ç æª");
			static bool IsConnected17 = false;
			SerialPortCommunicator portCommunicator18 = new SerialPortCommunicator("COM18", 9600, "åè£æ«ç æª");
			static bool IsConnected18 = false;
			SerialPortCommunicator portCommunicator19 = new SerialPortCommunicator("COM19", 9600, "åè£æ«ç æª");
			static bool IsConnected19 = false;
			SerialPortCommunicator portCommunicator20 = new SerialPortCommunicator("COM20", 9600, "åè£æ«ç æª");
			static bool IsConnected20 = false;
			public Task Execute(IJobExecutionContext context)
			{

			@@ -64,11 +78,43 @@
			if (Heart && !EMG && AutoExecuting && OnlineExecuting && !Error)
			{
			#region ä¸çº¿æ«ç
			HandleOnlineScan(device);
			#endregion

			#region åè£æ«ç
			HandlePressScan(device);
			#endregion

			#region æ£æµæ«ç
			HandleDetectScan(device);
			#endregion

			#region ä¸çº¿æ«ç
			HandleOfflineScan(device);

			#endregion
			}

			}
			catch (Exception ex)
			{
			WriteError(device.DeviceName, "éè¯¯", ex);
			}
			}
			}
			return Task.CompletedTask;
			}

			/// <summary>
			/// ä¸çº¿æ«ç
			/// </summary>
			/// <param name="device"></param>
			private void HandleOnlineScan(OtherDevice device)
			{
			var Location1ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation1ScanStart);
			var Location1ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation1ScanDone);
			if (Location1ScanStart && !Location1ScanDone)//æ§å¶æ«ç æªæ«ææçç ï¼æ ¹æ®æçç æ¥è¯¢ç»çæ°æ®ï¼å¤ææçç»å®æåæ¯å¦å·²ç»å®æææéé¶ä»¶
			{
			#region MyRegion
			#region ä¸²å£è¿æ¥
			if (!IsConnected1) IsConnected1 = portCommunicator1.Connect();
			if (!IsConnected2) IsConnected2 = portCommunicator2.Connect();
			@@ -82,56 +128,285 @@
			portCommunicator2.Write(dataToSend2);
			//}
			string PalletCode = portCommunicator1.ToString(Encoding.UTF8);
			using (var uow = _unitOfWorkManage.CreateUnitOfWork())
			{
			try
			{
			if (PalletCode.IsNotEmptyOrNull())
			{
			var boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);
			if (boxing == null)
			{
			WriteInfo(device.DeviceName, "ç©ºæç");
			device.SetValue(W_PLCDBName.wboolLocation1ScanDone, true);
			return;
			}
			List<Dt_BoxingDetail> dt_BoxingDetails = _boxingDetailService.Repository.QueryData(x => x.BoxingId == boxing.Id);
			Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == boxing.ProductCode);
			if (dt_Formula == null)
			{
			WriteError(device.DeviceName, "æ æåéæ¹");
			device.SetValue(W_PLCDBName.wboolLocation1ScanDone, true);
			return;
			}
			List<Dt_FormulaDetail> dt_FormulaDetails = _formulaDetailService.Repository.QueryData(x => x.FormulaId == dt_Formula.Id);
			//æ¯è¾é¶ä»¶æ¯å¦é½å¨
			if (!_boxingDetailService.IsComponentCodesEqual(dt_BoxingDetails, dt_FormulaDetails))
			{
			WriteError(device.DeviceName, "é¶ä»¶æé®é¢ï¼è¯·å¤ç");
			device.SetValue(W_PLCDBName.wboolLocation1ScanDone, true);
			return;
			}
			}
			//æäº¤äºå¡
			uow.Commit();

			IsConnected1 = !portCommunicator1.Disconnect();
			IsConnected2 = !portCommunicator2.Disconnect();
			#endregion
			#endregion

			device.SetValue(W_PLCDBName.wboolLocation1ScanDone, true);


			}
			catch (Exception ex)
			{
			WriteError(device.DeviceName, "ä¸çº¿æ«ç æµç¨æ§è¡å¼å¸¸", ex);
			}
			}
			}
			else if (!Location1ScanStart && Location1ScanDone)
			{
			device.SetValue(W_PLCDBName.wboolLocation1ScanDone, false);
			}
			#endregion
			}


			#region åè£æ«ç
			var Location2ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation2ScanStart);
			if (Location2ScanStart)//æ§å¶æ«ç æªæ«ææçç ï¼æ ¹æ®æçç æ¥è¯¢æçç»å®æåå å·¥æéæ°æ®ï¼åå¥PLC
			/// <summary>
			/// åè£æ«ç
			/// </summary>
			/// <param name="device"></param>
			private void HandlePressScan(OtherDevice device)
			{

			var Location2ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation2ScanStart);
			var Location2ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation2ScanDone);
			if (Location2ScanStart && !Location2ScanDone)//æ§å¶æ«ç æªæ«ææçç ï¼æ ¹æ®æçç æ¥è¯¢æçç»å®æåå å·¥æéæ°æ®ï¼åå¥PLC
			{
			#region MyRegion
			#region ä¸²å£è¿æ¥
			if (!IsConnected17) IsConnected17 = portCommunicator17.Connect();
			if (!IsConnected18) IsConnected18 = portCommunicator18.Connect();
			byte[] dataToSend1 = Encoding.ASCII.GetBytes(command);//è½¬æåèæ°ç»
			portCommunicator17.Write(dataToSend1);
			string receiveData = portCommunicator18.ToString(Encoding.UTF8);
			byte[] dataToSend2 = Encoding.ASCII.GetBytes("PL106");//è½¬æåèæ°ç»
			portCommunicator18.Write(dataToSend2);
			//}
			string PalletCode = portCommunicator17.ToString(Encoding.UTF8);
			using (var uow = _unitOfWorkManage.CreateUnitOfWork())
			{
			try
			{
			if (PalletCode.IsNotEmptyOrNull())
			{
			Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);
			if (dt_Boxing == null)
			{
			WriteInfo(device.DeviceName, "ç©ºæç");
			device.SetValue(W_PLCDBName.wboolLocation2ScanDone, true);
			return;
			}
			#endregion
			Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == dt_Boxing.ProductCode);
			//åå¥PLC
			device.SetValue(W_PLCDBName.wrealProductLength, dt_Formula.ProductLength);
			device.SetValue(W_PLCDBName.wrealProductWidth, dt_Formula.ProductWidth);
			device.SetValue(W_PLCDBName.wrealProductHeight, dt_Formula.ProductHeight);
			device.SetValue(W_PLCDBName.wrealScrewDownsetDistance, dt_Formula.ScrewDownsetDistance);
			device.SetValue(W_PLCDBName.wrealScrewTorqueOutput, dt_Formula.ScrewTorqueOutput);
			device.SetValue(W_PLCDBName.wDintAutoScrewOn, dt_Formula.DintAutoScrewOn);

			#region æ£æµæ«ç
			var Location3ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation3ScanStart);
			#endregion
			//åè£æ«ç å®æ
			device.SetValue(W_PLCDBName.wboolLocation2ScanDone, true);

			#region ä¸çº¿æ«ç
			var Location4ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation4ScanStart);
			#endregion
			//æ¥æ¶æ°æ®
			float PressHeight = device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectPressHeight);
			float ScrewTorque = device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectScrewTorque);
			float ScrewAngle = device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectScrewAngle);

			//æ·»å å°æ°æ®åº
			Dt_ProcessInfo dt_ProcessInfo = new Dt_ProcessInfo()
			{
			PalletCode = PalletCode,
			ProductCode = dt_Formula.ProductCode,
			ProductName = dt_Formula.ProductName,
			PressHeight = PressHeight,
			ScrewTorque = ScrewTorque,
			ScrewAngle = ScrewAngle

			};
			_processInfoService.Repository.AddData(dt_ProcessInfo);
			}
			//æäº¤äºå¡
			uow.Commit();

			IsConnected17 = !portCommunicator17.Disconnect();
			IsConnected18 = !portCommunicator18.Disconnect();
			#endregion
			#endregion

			//var a = _boxingService.Repository.QueryFirst(x => x.PalletCode == "1232123");
			//WriteInfo(device.DeviceName, "infoLog");

			//WriteDebug(device.DeviceName, "debugLog");
			}
			catch (Exception ex)
			{
			WriteError(device.DeviceName, "éè¯¯", ex);
			WriteError(device.DeviceName, "åè£æ«ç æµç¨æ§è¡å¼å¸¸", ex);
			}
			}
			}
			return Task.CompletedTask;
			else if (!Location2ScanStart && Location2ScanDone)
			{
			device.SetValue(W_PLCDBName.wboolLocation2ScanDone, false);
			}
			}

			/// <summary>
			/// æ£æµæ«ç
			/// </summary>
			/// <param name="device"></param>
			private void HandleDetectScan(OtherDevice device)
			{
			var Location3ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation3ScanStart);
			var Location3ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation3ScanDone);
			if (Location3ScanStart && !Location3ScanDone)
			{
			#region MyRegion
			#region ä¸²å£è¿æ¥
			if (!IsConnected19) IsConnected19 = portCommunicator19.Connect();
			if (!IsConnected20) IsConnected20 = portCommunicator20.Connect();
			byte[] dataToSend1 = Encoding.ASCII.GetBytes(command);//è½¬æåèæ°ç»
			portCommunicator19.Write(dataToSend1);
			string receiveData = portCommunicator20.ToString(Encoding.UTF8);
			byte[] dataToSend2 = Encoding.ASCII.GetBytes("PL106");//è½¬æåèæ°ç»
			portCommunicator20.Write(dataToSend2);
			//}
			string PalletCode = portCommunicator19.ToString(Encoding.UTF8);

			using (var uow = _unitOfWorkManage.CreateUnitOfWork())
			{
			try
			{
			if (PalletCode.IsNotEmptyOrNull())
			{
			Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);
			if (dt_Boxing == null)
			{
			WriteInfo(device.DeviceName, "ç©ºæç");
			device.SetValue(W_PLCDBName.wboolLocation1ScanDone, true);
			return;
			}
			Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == dt_Boxing.ProductCode);
			//åå¥PLC
			device.SetValue(W_PLCDBName.wrealXDirectionDistance1, dt_Formula.XDirectionDistance1);
			device.SetValue(W_PLCDBName.wrealYDirectionHeight1, dt_Formula.YDirectionHeight1);
			device.SetValue(W_PLCDBName.wrealXDirectionDistance2, dt_Formula.XDirectionDistance2);
			device.SetValue(W_PLCDBName.wrealYDirectionHeight2, dt_Formula.YDirectionHeight2);
			device.SetValue(W_PLCDBName.wrealXDirectionDistance3, dt_Formula.XDirectionDistance3);
			device.SetValue(W_PLCDBName.wrealYDirectionHeight3, dt_Formula.YDirectionHeight3);

			//æ£æµæ«ç å®æ
			device.SetValue(W_PLCDBName.wboolLocation3ScanDone, true);

			//æ¥æ¶æ°æ®
			float Height1 = device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectHeight1);
			float Height2 = device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectHeight2);
			float Height3 = device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectHeight3);

			Dt_ProcessInfo dt_ProcessInfo = _processInfoService.Repository.QueryFirst(x => x.PalletCode == PalletCode);
			if (dt_ProcessInfo == null)
			{
			WriteInfo(device.DeviceName, "æåæªåè£");
			device.SetValue(W_PLCDBName.wboolLocation1ScanDone, true);
			return;
			}
			dt_ProcessInfo.Height1 = Height1;
			dt_ProcessInfo.Height2 = Height2;
			dt_ProcessInfo.Height3 = Height3;
			_processInfoService.Repository.UpdateData(dt_ProcessInfo);

			}
			//æäº¤äºå¡
			uow.Commit();

			IsConnected19 = !portCommunicator19.Disconnect();
			IsConnected20 = !portCommunicator20.Disconnect();
			#endregion
			#endregion
			}
			catch (Exception ex)
			{
			WriteError(device.DeviceName, "æ£æµæ«ç æµç¨æ§è¡å¼å¸¸", ex);
			}
			}
			}
			else if (!Location3ScanStart && Location3ScanDone)
			{
			device.SetValue(W_PLCDBName.wboolLocation3ScanDone, false);
			}

			}

			/// <summary>
			/// ä¸çº¿æ«ç
			/// </summary>
			/// <param name="device"></param>
			private void HandleOfflineScan(OtherDevice device)
			{
			var Location4ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation4ScanStart);
			var Location4ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation4ScanDone);
			if (Location4ScanStart && !Location4ScanDone)//æ§å¶æ«ç æªæ«ææçç ï¼æ ¹æ®æçç æ¥è¯¢ç»çæ°æ®ï¼å¤ææçç»å®æåæ¯å¦å·²ç»å®æææéé¶ä»¶
			{
			if (!IsConnected17) IsConnected17 = portCommunicator17.Connect();
			if (!IsConnected18) IsConnected18 = portCommunicator18.Connect();
			byte[] dataToSend1 = Encoding.ASCII.GetBytes(command);//è½¬æåèæ°ç»
			portCommunicator17.Write(dataToSend1);
			string receiveData = portCommunicator18.ToString(Encoding.UTF8);
			byte[] dataToSend2 = Encoding.ASCII.GetBytes("PL106");//è½¬æåèæ°ç»
			portCommunicator18.Write(dataToSend2);
			//}
			string PalletCode = portCommunicator17.ToString(Encoding.UTF8);
			using (var uow = _unitOfWorkManage.CreateUnitOfWork())
			{
			try
			{
			if (PalletCode.IsNotEmptyOrNull())
			{
			Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);
			if (dt_Boxing == null)
			{
			WriteInfo(device.DeviceName, "è¯¥æçä¸ºç©ºæç");
			device.SetValue(W_PLCDBName.wboolLocation4ScanDone, true);
			return;
			}

			_boxingService.Repository.DeleteData(dt_Boxing);
			List<Dt_BoxingDetail> dt_BoxingDetails = _boxingDetailService.Repository.QueryData(x => x.BoxingId == dt_Boxing.Id);
			foreach (Dt_BoxingDetail dt_BoxingDetail in dt_BoxingDetails)
			{
			_boxingDetailService.Repository.DeleteDataById(dt_BoxingDetail.Id);
			}
			uow.Commit();
			//ä¸çº¿æ«ç å®æ
			device.SetValue(W_PLCDBName.wboolLocation4ScanDone, true);
			}
			IsConnected17 = !portCommunicator17.Disconnect();
			IsConnected18 = !portCommunicator18.Disconnect();
			}
			catch (Exception ex)
			{
			WriteError(device.DeviceName, "ä¸çº¿æ«ç æµç¨æ§è¡å¼å¸¸", ex);
			}
			}
			}
			else if (!Location4ScanStart && Location4ScanDone)
			{
			device.SetValue(W_PLCDBName.wboolLocation2ScanDone, false);
			}
			}
			}
			}