//using System;
|
//using System.Collections.Generic;
|
//using System.IO.Ports;
|
//using System.Linq;
|
//using System.Text;
|
//using System.Threading.Tasks;
|
//using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
|
//using Quartz;
|
//using WIDESEA_ISerialPortRepository;
|
//using WIDESEA_SerialPortRepository;
|
//using WIDESEAWCS_Model.Models;
|
//using WIDESEAWCS_QuartzJob;
|
|
//namespace WIDESEAWCS_Tasks
|
//{
|
// [DisallowConcurrentExecution]
|
// public class SerialPortJob : JobBase, IJob
|
// {
|
// //dispatchinfo
|
// //1 测试 OtherDevice WIDESEAWCS_Tasks SerialPortJob 1 NULL NULL NULL 1 2025-02-19 14:55:02.167 NULL NULL
|
// public enum CommandType
|
// {
|
// None = 0,
|
// Get = 1,
|
// Set = 2,
|
// }
|
|
// private readonly IPutakeRepository _putakeRepository;
|
// private readonly INJCommandsRepository _nJCommandsRepository;
|
// private readonly IProcessRepository _processRepository;
|
// private readonly ITorqueOpRepository _orqueOpRepository;
|
// public SerialPortJob(IPutakeRepository putakeRepository, INJCommandsRepository nJCommandsRepository, IProcessRepository processRepository, ITorqueOpRepository torqueOpRepository)
|
// {
|
// _putakeRepository = putakeRepository;
|
// _nJCommandsRepository = nJCommandsRepository;
|
// _processRepository = processRepository;
|
// _orqueOpRepository = torqueOpRepository;
|
// }
|
|
|
|
// private static SerialPort serialPort;
|
// private static CommandType commandType = CommandType.None;
|
// //private string commandGet = "824070241JNT\r";//读值
|
// //private string commandSet = "824070241JNT,0012500,+0001000[+TOL],-0001000[-TOL]\r";//设值
|
// private string setOK = "ParseOK";
|
// //private string getOK = "82407024103";
|
// //private string getError = "82407024104";
|
// public Task Execute(IJobExecutionContext context)
|
// {
|
// #region 先查到这条命令
|
// string commandSet = "";
|
// string commandGet = "";
|
// string getOK = "";
|
// string getError = "";
|
|
// var com = _nJCommandsRepository.QueryFirst(x => x.ID == 3);
|
// if (com != null)
|
// {
|
// commandSet = string.Format("{0}JNT,{1},{2},{3}\r", com.DeviceNum, com.TorqueValue, com.TorqueMax, com.TorqueMin);//"824070241JNT,0005000,+0001000[+TOL],-0001000[-TOL]\r"
|
// commandGet = string.Format("{0}\t", com.DeviceNum);// "824070241JNT\r"
|
// getOK = string.Format("{0}03", com.DeviceNum);// "82407024103"
|
// getError = string.Format("{0}04", com.DeviceNum);// "82407024104"
|
// }
|
// else
|
// {
|
// throw new Exception("未找到指定的命令数据！");
|
// }
|
// #endregion
|
|
// try
|
// {
|
// if (serialPort == null) { serialPort = new SerialPort("COM3"); serialPort.DataReceived += SerialPort_DataReceived; }
|
// if (!serialPort.IsOpen)
|
// {
|
// serialPort.Open();
|
|
|
|
// serialPort.Write(commandSet);//打开串口时先设值
|
// commandType = CommandType.Set;
|
// }
|
// switch (commandType)
|
// {
|
// case CommandType.Get://读值
|
// serialPort.Write(commandGet);
|
// break;
|
// case CommandType.Set://设值
|
// serialPort.Write(commandSet);
|
// break;
|
// }
|
// }
|
// catch (Exception ex)
|
// {
|
// throw new Exception(ex.Message);
|
// }
|
// return Task.CompletedTask;
|
// }
|
// private void SerialPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
|
// {
|
// # region 先查到这条命令
|
// string getError = "";
|
// string getOK = "";
|
|
// var com = _nJCommandsRepository.QueryFirst(x => x.ID == 3);
|
// if (com != null)
|
// {
|
// getOK = string.Format("{0}03", com.DeviceNum);// "82407024103"
|
|
// getError = string.Format("{0}04", com.DeviceNum);// "82407024104"
|
// }
|
// else
|
// {
|
// throw new Exception("未找到指定的命令数据！");
|
// }
|
// #endregion
|
|
// 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) //成功就保存到数据库中
|
// {
|
// //这里如果成了就存到数据库中的torqueop表中，并且在这判断torqueop表中的数据size和步骤，是否满足工艺表所要求的
|
// //_orqueOpRepository.
|
|
// commandType = CommandType.Set;
|
// }
|
// else if (data.Contains(getError) && commandType == CommandType.Get)
|
// {
|
// commandType = CommandType.Set;
|
|
|
// }
|
// }
|
// }
|
// }
|
//}
|
#region
|
//if (group == "电气")
|
//{
|
// //获取当前任务号 //IPutakeServer里面的待执行的第一条任务；
|
// var take = _putakeRepository.QueryData(x => x.Grouptype == group)
|
// .OrderBy(x => x.Dispatchtime)
|
// .FirstOrDefault();
|
// var takeid = take?.Njtakeid;//拿到任务号
|
|
// //调用Getcircuit拿到当前步骤
|
// var process = _processServer.Getcircuit(group, takeid);
|
|
// if (process != null && process.Status)
|
// {
|
// var list = JsonConvert.SerializeObject(process.Data);
|
// var data = JsonConvert.DeserializeObject<ProcessData>(list);
|
|
// if (data?.proNow != null)
|
// {
|
|
// int setpNum = data.proNow.SetpNum;
|
// int sum = data.proNow.TorqueSum;
|
// double torqueone = data.proNow.TorqueOne;
|
// double torquetwo = data.proNow.TorqueTwo;
|
|
// int onequantity = data.proNow.TorqueOneQuantity;
|
// int towquantity = data.proNow.TorqueTwoQuantity;
|
|
|
// //判断op表中这个值是否有该条任务的数据
|
// var op = _orqueOpRepository.QueryData(x => x.TakeId == takeid && x.GroupOp == group && x.ProcessSte == setpNum);
|
// if (op.Any())//判断是否有数据
|
// {
|
// //找到了就要对比现在op表中有多少条，是否和工艺表中的目标一致
|
|
// // 计算第一个扭矩的数量（在 ±1 误差范围内）//Math.Abs(5.2 - 4.5) = 0.7 // 计入 Math.Abs(6.0 - 4.5) = 1.5 不计入
|
// var oponecount = op.Count(x => Math.Abs(x.TorqueSize - torqueone) <= 1);
|
|
// int times = 0;
|
// if (op.Count() > onequantity)
|
// {
|
// times = onequantity;//如果第一条以及满足就移除onequantity数量的数据
|
// }
|
// else
|
// {
|
// times = op.Count();//没有满足就移除当前的数据数据
|
// }
|
|
// for (int i = 0; i < times; i++)
|
// {
|
// //移除第一次值的影响（以为有可能俩个目标值相近而产生误判）
|
// op.RemoveAt(0); //移除 op 列表的 第一个元素（即最早存入的记录）
|
|
// }
|
|
// // 计算第二个扭矩的数量（在 ±1 误差范围内）
|
// var optowcount = op.Count(x => Math.Abs(x.TorqueSize - torquetwo) <= 1);
|
// sum = oponecount + optowcount;
|
// //第一种，第一个扭力值没有扭完
|
// if (oponecount < onequantity && torqueone != 0)
|
// {
|
// //设值
|
// //var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
|
// // .Replace("[setNum]", (torqueone * 1000).ToString().PadLeft(7, '0')) + "\r";
|
// var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
|
// .Replace("[setNum]", Math.Round(torqueone * 1000).ToString().PadLeft(7, '0')) + "\r";
|
// //格式化成整数
|
|
// serialPortDevice.Communicator.Write(com);
|
// //WriteDebug("写入", com);
|
// }
|
// //第二种，第一个值扭完了，第二个没有扭完
|
// if (oponecount == onequantity && optowcount < towquantity && torquetwo != 0)
|
// {
|
// //设值
|
// var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
|
// .Replace("[setNum]", Math.Round(torquetwo * 1000).ToString().PadLeft(7, '0')) + "\r";
|
// serialPortDevice.Communicator.Write(com);
|
// }
|
// }
|
// //这里这个任务第一次执行，op表中肯定是没有数据的，所有第一次就要把工艺表中的值给它
|
// else //防止步骤一中torqueone的值为0导致报错
|
// {
|
// //设值
|
// var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue
|
// .Replace("[setNum]", Math.Round(torqueone * 1000).ToString().PadLeft(7, '0')) + "\r";
|
// serialPortDevice.Communicator.Write(com);
|
// }
|
|
// }
|
// else
|
// {
|
// Console.WriteLine("proNow 为空");
|
// }
|
// }
|
// else
|
// {
|
// Console.WriteLine($"Getcireit接口错误：{process?.Message}");
|
// }
|
//}
|
|
#endregion
|
|
|
#region 根据不同的group存值
|
//if (group == "电气")
|
//{
|
// var take = _putakeRepository.QueryData(x => x.Grouptype == group)
|
// .OrderBy(x => x.Dispatchtime)
|
// .FirstOrDefault();
|
// var takeid = take?.Njtakeid;//拿到任务号
|
|
// //调用Getcircuit拿到当前步骤
|
// var process = _processServer.Getcircuit(group, takeid);
|
|
// if (process != null && process.Status)
|
// {
|
// var list = JsonConvert.SerializeObject(process.Data);
|
// var dataz = JsonConvert.DeserializeObject<ProcessData>(list);
|
|
// if (dataz?.proNow != null)
|
// {
|
|
// int setpNum = dataz.proNow.SetpNum;
|
// int sum = dataz.proNow.TorqueSum;
|
// double torqueone = dataz.proNow.TorqueOne;
|
// int onequantity = dataz.proNow.TorqueOneQuantity;
|
// int towquantity = dataz.proNow.TorqueTwoQuantity;
|
// double torquetwo = dataz.proNow.TorqueTwo;
|
// Dt_TorqueOp Addop = new Dt_TorqueOp()
|
// {
|
// DeviceCode = devicecode,
|
// TakeId = takeid,
|
// GroupOp = group,
|
// ProcessSte = setpNum,
|
// TorqueSize = float.TryParse(torqueValue, out float torque) ? torque : 0.0f, // 这里进行字符串到float的转换
|
// CreateDate = DateTime.Now,
|
// };
|
// _orqueOpRepository.AddData(Addop);
|
// }
|
// }
|
|
|
// item.DeviceProParamName = CommandType.None.ToString();
|
//}
|
|
#endregion
|
