通信

yanjinhui

2025-03-24 17199b61f960f0317cdcab1492c2511757036814

 ÏîÄ¿´úÂë/WIDESEAWCS_Server Õýʽ/WIDESEAWCS_Tasks/SerialPort/SerialPortJob.cs

@@ -5,16 +5,27 @@
using System.Linq;
using System.Net.WebSockets;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using AutoMapper;
using HslCommunication.WebSocket;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Logical;
using Quartz;
using SqlSugar;
using StackExchange.Profiling.Internal;
using WIDESEA_ISerialPortRepository;
using WIDESEA_SerialPortRepository;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.BaseRepository;
using WIDESEAWCS_DTO.SerialPort;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_QuartzJob.DTO;
using WIDESEAWCS_TaskInfoService;
using WIDESEAWCS_Tasks.SerialPort;

namespace WIDESEAWCS_Tasks
{
@@ -42,14 +53,19 @@
        private readonly IPutakeRepository _putakeRepository;
        private readonly IProcessRepository _processRepository;
        private readonly ITorqueOpRepository _orqueOpRepository;
        private WebSocketServer _webSocketContext;

        public SerialPortJob(IPutakeRepository putakeRepository, IProcessRepository processRepository, ITorqueOpRepository torqueOpRepository, WebSocketServer webSocketContext)
        private WebSocketServer _webSocketContext;
        private readonly IProcessServer _processServer;
        private readonly IPutakeServer _putakeServer;

        public SerialPortJob(IPutakeServer putakeServer,IProcessServer processServer, IPutakeRepository putakeRepository, IProcessRepository processRepository, ITorqueOpRepository torqueOpRepository, WebSocketServer webSocketContext)
        {
            _putakeRepository = putakeRepository;
            _processRepository = processRepository;
            _orqueOpRepository = torqueOpRepository;
            _webSocketContext = webSocketContext;
            _processServer = processServer;
            _putakeServer = putakeServer;
        }

        public Task Execute(IJobExecutionContext context)
@@ -72,12 +88,62 @@
                                string group = item.DeviceProDataBlock;
                                if (group == "电气")
                                {
                                    //查看步骤
                                    var com = item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (5 * 1000).ToString().PadLeft(7, '0'))+"\r";
                                    serialPortDevice.Communicator.Write(com+"\r");
                                    //打开串口时先设值
                                    
                                     
                                    //获取当前任务号  //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;
                                            int onequantity = data.proNow.TorqueOneQuantity;
                                            int towquantity = data.proNow.TorqueTwoQuantity;
                                            double torquetwo = data.proNow.TorqueTwo;

                                            //判断op表中这个值是否有该条任务的数据
                                            var op = _orqueOpRepository.QueryData(x => x.TakeId == takeid && x.GroupOp == group&&x.ProcessSte== setpNum);
                                            if (op.Any())//判断是否有数据
                                            {
                                                //找到了就要对比现在op表中有多少条，是否和工艺表中的目标一致
                                               var oponecount=op.Count(x=>x.TorqueSize== torqueone);//第一个扭的数量
                                                var optowcount = op.Count(x => x.TorqueSize == torquetwo);//第二个扭的数量
                                                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);
                                                }
                                                //第二种，第一个值扭完了，第二个没有扭完
                                                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);
                                                }
                                            }

                                        }
                                    }
                                }
                                #endregion
                                item.DeviceProParamName = CommandType.Set.ToString();
@@ -122,9 +188,6 @@
                                    {
                                        item.DeviceProParamName = CommandType.Get.ToString();




                                    }
                                }
                                else if (item.DeviceProParamName == CommandType.Get.ToString())
@@ -133,24 +196,55 @@
                                    //03成功
                                    if (deviceProtocolDetail != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue))
                                    {

                                        //把这条数据插入op表中
                                        string group = item.DeviceProDataBlock; // è®¾å¤‡æ‰€å±žç»„别
                                        string devicecode = item.DeviceChildCode;//设备编号
                                        string torqueValue = ExtractTorqueValue(receiveData);
                                       
                                        if (group == "电气")
                                        {
                                            #region
                                            var take = _putakeRepository.QueryData(x => x.Grouptype == group)
                                                                .OrderBy(x => x.Dispatchtime)
                                                                .FirstOrDefault();
                                            var takeid = take?.Njtakeid;//拿到任务号

                                            item.DeviceProParamName = CommandType.Set.ToString();
                                            //调用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,

                                                    };
                                                }
                                            }
                                          
                                            
                                                    #endregion

                                                    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();



                                            //}
                                        }
                                      
                                    }
                                }
                            }
@@ -171,7 +265,19 @@
            WriteDebug("CommonConveyorLineJob", "test");
            return Task.CompletedTask;
        }
       

        /// <summary>
        /// å°†0004000转为4.0
        /// 0004500转为4.5
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        private string ExtractTorqueValue(string data)
        {
            Match match = Regex.Match(data, @"\b0*(\d{1,4})000\b");
            return match.Success ? (double.Parse(match.Groups[1].Value) / 10.0).ToString("0.0") : "0.0";
        }



    }