MeiXinLaiRui/NiuJuKongZhi.git

			@@ -1,84 +1,230 @@
			ï»¿using System;
			using System.Collections.Generic;
			using System.Drawing.Imaging;
			using System.IO.Ports;
			using System.Linq;
			using System.Text;
			using System.Threading.Tasks;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
			using Quartz;
			using SqlSugar;
			using StackExchange.Profiling.Internal;
			using WIDESEA_ISerialPortRepository;
			using WIDESEA_SerialPortRepository;
			using WIDESEAWCS_Model.Models;
			using WIDESEAWCS_QuartzJob;
			using WIDESEAWCS_QuartzJob.DTO;
			using WIDESEAWCS_QuartzJob.StackerCrane.Enum;
			using WIDESEAWCS_Tasks.ConveyorLineJob;
			using WIDESEAWCS_Tasks.StackerCraneJob;

			namespace WIDESEAWCS_Tasks
			{
			[DisallowConcurrentExecution]
			public class SerialPortJob : JobBase, IJob
			public class SerialPortJob : JobBase, IJob, IDisposable
			{
			public void Dispose()
			{
			GC.SuppressFinalize(this);
			}

			public enum CommandType
			{
			None = 0,
			Get = 1,
			Set = 2,
			}
			private static SerialPort serialPort;
			private static CommandType commandType = CommandType.None;
			private string commandGet = "824070241JNT\r";//è¯»å¼
			private string commandSet = "824070241JNT,0005000,+0001000[+TOL],-0001000[-TOL]\r";//è®¾å¼
			private string setOK = "ParseOK";
			private string getOK = "82407024103";
			private string getError = "82407024104";

			public enum CommandResult
			{
			SetOK = 0,
			GetOK = 1,
			GetError = 2,
			}
			private readonly IPutakeRepository _putakeRepository;
			private readonly IProcessRepository _processRepository;
			private readonly ITorqueOpRepository _orqueOpRepository;
			public SerialPortJob(IPutakeRepository putakeRepository, IProcessRepository processRepository, ITorqueOpRepository torqueOpRepository)
			{
			_putakeRepository = putakeRepository;
			_processRepository = processRepository;
			_orqueOpRepository = torqueOpRepository;
			}

			public Task Execute(IJobExecutionContext context)
			{
			try
			{
			if (serialPort == null) { serialPort = new SerialPort("COM3"); serialPort.DataReceived += SerialPort_DataReceived; }
			if (!serialPort.IsOpen)
			SerialPortDevice serialPortDevice = (SerialPortDevice)context.JobDetail.JobDataMap.Get("JobParams");
			if (serialPortDevice != null)
			{
			serialPort.Open();
			List<DeviceProDTO> deviceProDTOs = serialPortDevice.DeviceProDTOs;
			foreach (var item in deviceProDTOs)
			{
			if (item.DeviceProParamName != CommandType.Get.ToString() && item.DeviceProParamName != CommandType.Set.ToString())
			{
			DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandType) && x.ProtocolDetailType == nameof(CommandType.Set));
			if (deviceProtocolDetail != null)
			{
			//æè¦åç«¯è¿åç»æä¸ä¸ªç»å«ï¼åä»»å¡id
			//åæ¥ç¶æåç»ï¼ææ¶é´éåº
			string group = "çµæ°";


			//è¿éå¤æç»å«ä¸ä¸ªçæ¯é£ä¸ªï¼å°±æ¥é£ä¸ªå·¥èºè¡¨çå¼
			if (group=="çµæ°")
			{

			//åçå·¥èºè¡¨ä¸æ¥éª¤ä¸ä¸è¦æçå¼æå¤å°ä¸ª åæ¥çDt_TorqueOpè¡¨ä¸æ¯å¦æè¯¥ä»»å¡å·idåæ¥éª¤æ»æ°æ¯å¦æ»¡è¶³å·¥èºè¡¨
			// æ¥è¯¢ææå·¥èºæ°æ®ï¼æç§æ¥éª¤å· SetpNum éå¢æåº
			var processList = _processRepository.QueryData(x => x.CraftType == group)
			.OrderBy(x => x.SetpNum)
			.ToList();

			foreach (var process in processList)
			{
			float torqueone = process.TorqueOne;//è¯»å°å¼äº
			float torquetow = process.TorqueTwo;
			if (torqueone!=0)
			{
			serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (torqueone * 1000).ToString().PadLeft(7, '0')) + "\r");
			}
			if (torquetow != 0)
			{
			serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (torquetow * 1000).ToString().PadLeft(7, '0')) + "\r");
			}

			// è®¡ç®å½åæ¥éª¤æéç Torque æ»æ°
			int requiredTorqueCount = process.TorqueOneQuantity + process.TorqueTwoQuantity;

			// æ¥è¯¢å½åæ¥éª¤ç TorqueOp è®°å½ï¼å¹é ProcessSteåç»ï¼æ£æ¥æ¯å¦è¾¾å°è¦æ±
			int torqueCount = _orqueOpRepository.QueryData(x => x.ProcessSte == process.SetpNum&& x.GroupOp== group).Count();

			if (torqueCount < requiredTorqueCount)
			{
			// å¦ææ°éä¸æ»¡è¶³ï¼åæ¢è¯»å

			break;
			}
			//ç¬¦åè¦æ±ï¼ç»§ç»è¯»åä¸ä¸æ¥

			}

			}
			if (group == "æºæ¢°")
			{

			}
			if (group == "å°æ²")
			{

			}
			//æå¼ä¸²å£æ¶åè®¾å¼
			item.DeviceProParamName = CommandType.Set.ToString();
			}
			}

			if (CommandType.Get.ToString() == item.DeviceProParamName)
			{
			DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandType) && x.ProtocolDetailType == nameof(CommandType.Get));
			//åéè®¾å¤å·
			if (deviceProtocolDetail != null)
			{
			serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue, "\r");//æå¼ä¸²å£æ¶åè®¾å¼
			}
			}
			else if (CommandType.Set.ToString() == item.DeviceProParamName)
			{
			DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandType) && x.ProtocolDetailType == nameof(CommandType.Set));
			//è®¾å¼
			if (deviceProtocolDetail != null)
			{
			serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue, "\r");//æå¼ä¸²å£æ¶åè®¾å¼
			}
			}



			serialPort.Write(commandSet);//æå¼ä¸²å£æ¶åè®¾å¼
			commandType = CommandType.Set;
			if (serialPortDevice.Communicator.Buffers.Count > 0)
			{
			string? receiveData = serialPortDevice.Communicator.ToString(Encoding.Default);
			if (!string.IsNullOrEmpty(receiveData))
			{
			Console.WriteLine(DateTime.Now.ToString("HH:mm:ss.fff") + receiveData);

			if (item.DeviceProParamName == CommandType.Set.ToString())
			{
			DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandResult) && x.ProtocolDetailType == nameof(CommandResult.SetOK));
			//parseok
			if (deviceProtocolDetail != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue))
			{
			item.DeviceProParamName = CommandType.Get.ToString();




			}
			}
			else if (item.DeviceProParamName == CommandType.Get.ToString())
			{
			DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandResult) && x.ProtocolDetailType == nameof(CommandResult.GetOK));
			//03æå

			if (deviceProtocolDetail != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue))
			{
			//è¿éæåä¹åï¼è¦åå¨å°çDt_TorqueOpï¼åä»»å¡å·ï¼ç»ï¼å¼ï¼
			string group = "";
			if (group == "çµæ°")
			{
			var putake = _putakeRepository.QueryData(x => x.Pustatus == 2 && x.Grouptype == group).OrderByDescending(x => x.Dispatchtime).FirstOrDefault();//æ¯æ¬¡é½æ¿ææ©çé£æ¡
			var punjid = putake.ID;
			var Nj = new Dt_TorqueOp()
			{
			TakeId = putake.Njtakeid,
			GroupOp = group,
			//ProcessSte= processList
			TorqueSize = receiveData

			};
			_orqueOpRepository.AddData(Nj);

			}
			if (group == "æºæ¢°")
			{

			}
			if (group == "å°æ²")


			item.DeviceProParamName = CommandType.Set.ToString();

			}
			}
			else if (item.DeviceProParamName == CommandType.Get.ToString())
			{
			DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandResult) && x.ProtocolDetailType == nameof(CommandResult.GetError));
			if (deviceProtocolDetail != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue))
			{
			item.DeviceProParamName = CommandType.Set.ToString();



			}
			}
			}
			}
			}

			}
			switch (commandType)
			{
			case CommandType.Get:
			serialPort.Write(commandGet);
			break;
			case CommandType.Set:
			serialPort.Write(commandSet);
			break;
			}

			}
			catch (Exception ex)
			{
			throw new Exception(ex.Message);
			WriteError("CommonConveyorLineJob", "test", ex);
			}
			WriteDebug("CommonConveyorLineJob", "test");
			return Task.CompletedTask;
			}
			private void SerialPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
			{
			byte[] buffers = new byte[1024];
			while (serialPort.BytesToRead > 0)
			{
			serialPort.Read(buffers, 0, serialPort.BytesToRead > buffers.Length ? buffers.Length : serialPort.BytesToRead);
			string data = Encoding.Default.GetString(buffers);
			if (data.Contains(setOK) && commandType == CommandType.Set)
			{
			commandType = CommandType.Get;
			}
			else if (data.Contains(getOK) && commandType == CommandType.Get)
			{
			commandType = CommandType.Set;


			}
			else if (data.Contains(getError) && commandType == CommandType.Get)
			{
			commandType = CommandType.Set;


			}
			}
			}
			}
			}