完整项目更新

leiqunqing

2026-03-05 891207469b41c23d22805876a4e179d75832572f

 ´úÂë¹ÜÀí/WIDESEAWCS_Server/WIDESEAWCS_Server/WIDESEAWCS_Tasks/PLCJob.cs

@@ -1,27 +1,18 @@
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 OfficeOpenXml.FormulaParsing.Excel.Functions.Text;

using Quartz;

using SixLabors.ImageSharp.PixelFormats;

using System.Linq;

using System.Text;

using WIDESEAWCS_BasicInfoService;

using WIDESEAWCS_Common;

using WIDESEAWCS_Common.PLCEnum;

using WIDESEAWCS_Communicator;

using WIDESEAWCS_Core;

using WIDESEAWCS_Core.BaseRepository;

using WIDESEAWCS_Core.Helper;

using WIDESEAWCS_DTO.BasicInfo;

using WIDESEAWCS_IBasicInfoService;

using WIDESEAWCS_Model.Models;

using WIDESEAWCS_QuartzJob;

using WIDESEAWCS_QuartzJob.DeviceBase;

using WIDESEAWCS_QuartzJob.StackerCrane.Enum;



namespace WIDESEAWCS_Tasks

{

@@ -33,19 +24,29 @@
        private readonly IFormulaService _formulaService;

        private readonly IFormulaDetailService _formulaDetailService;

        private readonly IProcessInfoService _processInfoService;

        private readonly IProcessInfoDetailService _processDetailInfoService;

        private readonly IUnitOfWorkManage _unitOfWorkManage;

        public PLCJob(IBoxingService boxingService, IBoxingDetailService boxingDetailService, IFormulaService formulaService, IFormulaDetailService formulaDetailService, IProcessInfoService processInfoService, IUnitOfWorkManage unitOfWorkManage)

        private readonly IScanStationService _scanStationService;



        public PLCJob(IBoxingService boxingService,

            IBoxingDetailService boxingDetailService,

            IFormulaService formulaService,

            IFormulaDetailService formulaDetailService,

            IProcessInfoService processInfoService,

            IProcessInfoDetailService processDetailInfoService,

            IUnitOfWorkManage unitOfWorkManage,

            IScanStationService scanStationService

            )

        {

            _boxingService = boxingService;

            _boxingDetailService = boxingDetailService;

            _formulaService = formulaService;

            _formulaDetailService = formulaDetailService;

            _processInfoService = processInfoService;

            _processDetailInfoService = processDetailInfoService;

            _unitOfWorkManage = unitOfWorkManage;

            _scanStationService = scanStationService;

        }

        private readonly string set = "0x16,0x4D,0x0D,0x30,0x34,0x30,0x31,0x44,0x30,0x35,0x2E";//主机发送设置扫描模式为主机模式的命令,扫描器返回接收到的命令和<ACK>（0x06）后，将扫描模式更改为主机模式

        private readonly string Text = "开启扫码";//主机发送设置扫描模式为主机模式的命令,扫描器返回接收到的命令和<ACK>（0x06）后，将扫描模式更改为主机模式

        private readonly string command = "0x16,0x54,0x0D";//发送开始解码命令；"0x16,0x55,0x0D"发送停止解码命令

        public Task Execute(IJobExecutionContext context)

        {



@@ -57,32 +58,43 @@
                    OtherDevice device = (OtherDevice)value;

                    try

                    {



                        if (!device.IsConnected) throw new Exception(device.DeviceName + "连接失败");

                        var Heart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolHeart);

                        var EMG = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolEMG);

                        var AutoExecuting = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolAutoExecuting);

                        var OnlineExecuting = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolOnlineExecuting);

                        var Error = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolError);

                        if (Heart && !EMG && AutoExecuting && OnlineExecuting && !Error)



                        if (/*Heart &&*/ !EMG && AutoExecuting && OnlineExecuting && !Error)

                        {

                            #region ä¸Šçº¿æ‰«ç 

                            HandleOnlineScan(device);

                            #endregion

                            //#region é›¶ä»¶æ£€æµ‹

                            //HandlePartDetection(device);

                            //#endregion



                            //#region ä¸Šçº¿æ‰«ç 

                            //HandleOnlineScan(device);

                            //#endregion



                            #region åŽ‹è£…扫码

                            HandlePressScan(device);

                            #endregion



                            #region åŽ‹è£…信息上传

                            HandlePressInfoUpload(device);

                            #endregion



                            #region æ£€æµ‹æ‰«ç 

                            HandleDetectScan(device);

                            #endregion



                            #region æ£€æµ‹ä¿¡æ¯ä¸Šä¼ 

                            HandleDetectInfoUpload(device);

                            #endregion



                            #region ä¸‹çº¿æ‰«ç 

                            HandleOfflineScan(device);



                            #endregion

                        }



                    }

                    catch (Exception ex)

                    {

@@ -93,79 +105,159 @@
            return Task.CompletedTask;

        }









        /// <summary>

        /// é›¶ä»¶æ£€æµ‹

        /// </summary>

        /// <param name="device"></param>

        /// <exception cref="InvalidOperationException"></exception>

        private void HandlePartDetection(OtherDevice device)

        {

            //DB800.1.4

            var Location5ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation5ScanStart);

            var Location5ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation5ScanDone);

            if (Location5ScanStart && !Location5ScanDone)

            {

                try

                {

                    if (_scanStationService.Repository.QueryFirst(x => x.StationCode == "001").IsScanned == 0)

                    {

                        device.SetValue(W_PLCDBName.wboolLocation5ScanDone, true);

                        return;

                    }

                    Dt_Boxing dt_Boxing = _boxingService.Repository.QueryData(x => true, 1, "Id desc").FirstOrDefault();

                    if (dt_Boxing == null)

                    {

                        throw new InvalidOperationException("无组盘数据");

                    }

                    Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == dt_Boxing.ProductCode);

                    if (dt_Formula == null)

                    {

                        throw new InvalidOperationException("无成品配方");

                    }

                    List<Dt_BoxingDetail> dt_BoxingDetails = _boxingDetailService.Repository.QueryData(x => x.BoxingId == dt_Boxing.Id);

                    List<Dt_FormulaDetail> dt_FormulaDetails = _formulaDetailService.Repository.QueryData(x => x.FormulaId == dt_Formula.Id && x.IsScanned == 1);

                    if (!_boxingDetailService.CheckComponentsMatchExactly(dt_BoxingDetails.Select(x => x.ComponentCode).ToList(), dt_FormulaDetails.Select(x => x.ComponentCode).ToList()))

                    {

                        throw new InvalidOperationException("零件与配方表中不同");

                    }

                    device.SetValue(W_PLCDBName.wboolLocation5ScanDone, true);

                }

                catch (Exception ex)

                {

                    WriteError(device.DeviceName, "检测零件流程执行异常", ex);

                }

            }

            else if (!Location5ScanStart && Location5ScanDone)

            {

                device.SetValue(W_PLCDBName.wboolLocation5ScanDone, false);

            }

        }



        /// <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)//控制扫码枪扫描托盘码，根据托盘码查询组盘数据，判断托盘绑定成品是否已绑定所有所需零件

            //DB800.1.4

            var Location5ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation5ScanStart);

            var Location5ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation5ScanDone);

            if (Location5ScanStart && !Location5ScanDone)//控制扫码枪扫描托盘码，根据托盘码查询组盘数据，判断托盘绑定成品是否已绑定所有所需零件

            {

                #region ä¸²å£è¿žæŽ¥

                SerialPortCommunicator portCommunicator1 = new SerialPortCommunicator("COM1", 9600, "上线扫码枪");

                bool IsConnected1 = false;

                SerialPortCommunicator portCommunicator2 = new SerialPortCommunicator("COM2", 9600, "上线扫码枪");

                bool IsConnected2 = false;

                if (!IsConnected1) IsConnected1 = portCommunicator1.Connect();

                if (!IsConnected2) IsConnected2 = portCommunicator2.Connect();

                byte[] dataToSend1 = Encoding.ASCII.GetBytes(command);//转成字节数组

                portCommunicator1.Write(dataToSend1);

                string receiveData = portCommunicator2.ToString(Encoding.UTF8);

                //if (receiveData == "0x16,0x54,0x0D")

                //{

                //    Console.WriteLine(receiveData);

                byte[] dataToSend2 = Encoding.ASCII.GetBytes("PL106");//转成字节数组

                portCommunicator2.Write(dataToSend2);

                //}

                string PalletCode = portCommunicator1.ToString(Encoding.UTF8);

                using (var uow = _unitOfWorkManage.CreateUnitOfWork())

                Dt_Boxing dt_Boxing1 = _boxingService.Repository.QueryData(x => true, 1, "Id desc").FirstOrDefault();

                if (dt_Boxing1 != null && dt_Boxing1.ProductCode == null)

                {

                    try

                    return;

                }

                //var PalletCode = "PL111";

                var PalletCode = TcpClientExample.Start("192.168.2.120", 2001);

                try

                {

                    if (!PalletCode.IsNotEmptyOrNull() || PalletCode == "NoRead")

                    {

                        if (PalletCode.IsNotEmptyOrNull())

                        {

                            var boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

                            if (boxing == null)

                            {

                                WriteError(device.DeviceName, "空托盘");

                                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, "无成品配方");

                                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, "零件有问题，请处理");

                                return;

                            }

                        }

                        //提交事务

                        uow.Commit();



                        IsConnected1 = !portCommunicator1.Disconnect();

                        IsConnected2 = !portCommunicator2.Disconnect();

                        #endregion

                        device.SetValue(W_PLCDBName.wboolLocation1ScanDone, true);

                        


                        throw new InvalidOperationException("托盘为空");

                    }

                    catch (Exception ex)



                    if (_boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode && x.ProductCode != null) != null)

                    {

                        WriteError(device.DeviceName, "上线扫码流程执行异常", ex);

                        device.SetValue(W_PLCDBName.wboolLocation5ScanDone, true);

                        throw new InvalidOperationException("托盘以存在");

                    }



                    Dt_Boxing dt_Boxing = new Dt_Boxing();

                    dt_Boxing.PalletCode = PalletCode;

                    _boxingService.Repository.AddData(dt_Boxing);







                    //Dt_ScanStation dt_ScanStation = _scanStationService.Repository.QueryFirst(x => x.StationCode == "001");

                    //if (dt_ScanStation == null)

                    //{

                    //    throw new InvalidOperationException("无工位数据");

                    //}

                    //Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == dt_ScanStation.StationEndProduct);



                    //if (dt_Formula == null)

                    //{

                    //    throw new InvalidOperationException("无成品配方");

                    //}



                    //List<Dt_FormulaDetail> dt_FormulaDetails = _formulaDetailService.Repository.QueryData(x => x.FormulaId == dt_Formula.Id && x.IsScanned == 1);

                    //if (dt_ScanStation.IsScanned == 0)

                    //{ 
                    //    Dt_Boxing dt_Boxing = new Dt_Boxing

                    //    {

                    //        PalletCode = PalletCode,

                    //        ProductCode = dt_Formula.ProductCode,

                    //        ProductName = dt_Formula.ProductName,

                    //        Creater = "admin",

                    //        CreateDate = new DateTime()

                    //    };



                    //    int id = _boxingService.Repository.AddData(dt_Boxing);

                    //    foreach (var item in dt_FormulaDetails)

                    //    {

                    //        Dt_BoxingDetail dt_BoxingDetail = new Dt_BoxingDetail()

                    //        {

                    //            BoxingId = id,

                    //            ComponentCode = item.ComponentCode,

                    //            ComponentName = item.ComponentName,

                    //            Creater = "admin",

                    //            CreateDate = new DateTime()

                    //        };

                    //        _boxingDetailService.Repository.AddData(dt_BoxingDetail);

                    //    }

                    //    device.SetValue(W_PLCDBName.wboolLocation5ScanDone, true);

                    //    return;

                    //}



                    //var boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

                    //if (boxing == null)

                    //{

                    //    throw new InvalidOperationException("未添加组盘信息");

                    //}



                    //List<Dt_BoxingDetail> dt_BoxingDetails = _boxingDetailService.Repository.QueryData(x => x.BoxingId == boxing.Id);





                    //if (!_boxingDetailService.CheckComponentsMatchExactly(dt_BoxingDetails.Select(x => x.ComponentCode).ToList(), dt_FormulaDetails.Select(x => x.ComponentCode).ToList()))

                    //{

                    //    throw new InvalidOperationException("零件与配方表中不同");

                    //}





                }

                catch (Exception ex)

                {

                    WriteError(device.DeviceName, "上线扫码流程执行异常", ex);

                }

            }

            else if (!Location1ScanStart && Location1ScanDone)

            else if (!Location5ScanStart && Location5ScanDone)

            {

                device.SetValue(W_PLCDBName.wboolLocation1ScanDone, false);

                device.SetValue(W_PLCDBName.wboolLocation5ScanDone, false);

            }

        }



@@ -175,75 +267,63 @@
        /// <param name="device"></param>

        private void HandlePressScan(OtherDevice device)

        {

            //DB800.1.1

            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 ä¸²å£è¿žæŽ¥

                SerialPortCommunicator portCommunicator17 = new SerialPortCommunicator("COM17", 9600, "压装扫码枪");

                bool IsConnected17 = false;

                SerialPortCommunicator portCommunicator18 = new SerialPortCommunicator("COM18", 9600, "压装扫码枪");

                bool IsConnected18 = false;

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

                var PalletCode = TcpClientExample.Start("192.168.2.121", 2001);



                try

                {

                    try

                    if (!PalletCode.IsNotEmptyOrNull() || PalletCode == "NoRead")

                    {

                        if (PalletCode.IsNotEmptyOrNull())

                        {

                            Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

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



                            //压装扫码完成

                            device.SetValue(W_PLCDBName.wboolLocation2ScanDone, true);



                            //接收数据

                            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



                        throw new InvalidOperationException("托盘号为空");

                    }

                    catch (Exception ex)

                    Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

                    if (dt_Boxing == null)

                    {

                        WriteError(device.DeviceName, "压装扫码流程执行异常", ex);

                        device.SetValue(W_PLCDBName.wboolLocation2ScanDone, true);

                        throw new InvalidOperationException("托盘为空");

                    }

                    if (dt_Boxing.ProductCode == null && dt_Boxing.BoxingNo == null)

                    {

                        device.SetValue(W_PLCDBName.wboolLocation2ScanDone, true);

                        return;

                    }



                    Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == dt_Boxing.ProductCode);

                    //写入PLC

                    device.SetValue(W_PLCDBName.wrealPressPalletCode, dt_Boxing.Id % 100);

                    if(dt_Formula.PressNoTighten == 1)

                    {

                        device.SetValue(W_PLCDBName.wboolLocation8ScanDone,true);

                    }

                    else

                    {

                        device.SetValue(W_PLCDBName.wboolLocation8ScanDone, false);

                    }



                    device.SetValue(W_PLCDBName.wrealProductLength, dt_Formula.ProductLength);

                    device.SetValue(W_PLCDBName.wrealProductWidth, dt_Formula.ProductWidth);

                    device.SetValue(W_PLCDBName.wrealProductHeight, dt_Formula.ProductHeight + dt_Formula.GasketHeight);

                    device.SetValue(W_PLCDBName.wrealScrewDownsetDistance, dt_Formula.ScrewDownsetDistance);

                    //中心高度

                    device.SetValue(W_PLCDBName.wrealScrewTorque, dt_Formula.ScrewTorqueOutput + dt_Formula.GasketHeight);

                    device.SetValue(W_PLCDBName.wrealAutoScrewProgramNo, dt_Formula.DintAutoScrewOn);

                    device.SetValue(W_PLCDBName.wrealPressPressure, dt_Formula.PressPressureDiff);

                    device.SetValue(W_PLCDBName.wrealTighteningTorque, dt_Formula.PressTorqueDiff);

                    device.SetValue(W_PLCDBName.wrealFastenTorque, dt_Formula.PressFastenTorque);





                    //压装扫码完成

                    device.SetValue(W_PLCDBName.wboolLocation2ScanDone, true);





                }

                catch (Exception ex)

                {

                    WriteError(device.DeviceName, "压装扫码流程执行异常", ex);

                }

            }

            else if (!Location2ScanStart && Location2ScanDone)

@@ -252,81 +332,146 @@
            }

        }





        /// <summary>

        /// åŽ‹è£…信息上传

        /// </summary>

        /// <param name="device"></param>

        /// <exception cref="NotImplementedException"></exception>

        private void HandlePressInfoUpload(OtherDevice device)

        {

            //DB800.1.5

            var Location6ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation6ScanStart);

            var Location6ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation6ScanDone);

            if (Location6ScanStart && !Location6ScanDone)//控制扫码枪扫描托盘码，根据托盘码查询托盘绑定成品加工所需数据，写入PLC

            {



                var PalletNum = device.GetValue<R_PLCDBName, int>(R_PLCDBName.rrealPressPalletCode);

                try

                {

                    if (!PalletNum.IsNotEmptyOrNull())

                    {

                        throw new InvalidOperationException("托盘为空");

                    }

                    Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.Id % 100 == PalletNum);

                    if (dt_Boxing == null)

                    {

                        device.SetValue(W_PLCDBName.wboolLocation6ScanDone, true);

                        throw new InvalidOperationException("未找到组盘数据");

                    }

                    Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == dt_Boxing.ProductCode);





                    //接收数据

                    decimal ScrewTorque = (decimal)device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectScrewTorque);

                    decimal ScrewAngle = (decimal)device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectScrewAngle);

                    decimal PressPressure = (decimal)device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectPressForce);

                    bool PressTightenOk = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rrealPressScrewByScrewOK);

                    bool PressTightenUnfinished = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rrealPressScrewByProcessUnfinished);







                    //添加到数据库

                    Dt_ProcessInfo dt_ProcessInfo = new Dt_ProcessInfo()

                    {

                        PalletCode = dt_Boxing.PalletCode,

                        ProductCode = dt_Formula.ProductCode,

                        ProductName = dt_Formula.ProductName,

                        ProductSn = dt_Boxing.BoxingNo,

                        ProductStatus = 1,

                        PressTightenOk = PressTightenOk ? 1 : 0,

                        PressTightenUnfinished = PressTightenUnfinished ? 1 : 0,

                        ScrewTorque = ScrewTorque,

                        ScrewAngle = ScrewAngle,

                        PressPressure = PressPressure,

                    };



                    if (

                        PressPressure > dt_Formula.ScrewDownsetDistance + dt_Formula.PressPressureDiff || PressPressure < dt_Formula.ScrewDownsetDistance - dt_Formula.PressPressureDiff ||

                        ScrewTorque > dt_Formula.PressFastenTorque + dt_Formula.PressTorqueDiff || ScrewTorque < dt_Formula.PressFastenTorque - dt_Formula.PressTorqueDiff

                        )

                    {

                        dt_ProcessInfo.ProductStatus = 0;

                    }



                    _processInfoService.Repository.AddData(dt_ProcessInfo);



                    // åŽ‹è£…信息上传完成

                    device.SetValue(W_PLCDBName.wboolLocation6ScanDone, true);

                }

                catch (Exception ex)

                {

                    WriteError(device.DeviceName, "压装信息上传流程执行异常", ex);

                }

            }

            else if (!Location6ScanStart && Location6ScanDone)

            {

                device.SetValue(W_PLCDBName.wboolLocation6ScanDone, false);

            }

        }





        /// <summary>

        /// æ£€æµ‹æ‰«ç 

        /// </summary>

        /// <param name="device"></param>

        private void HandleDetectScan(OtherDevice device)

        {

            //DB800.1.2

            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 ä¸²å£è¿žæŽ¥

                SerialPortCommunicator portCommunicator19 = new SerialPortCommunicator("COM19", 9600, "检测扫码枪");

                bool IsConnected19 = false;

                SerialPortCommunicator portCommunicator20 = new SerialPortCommunicator("COM20", 9600, "检测扫码枪");

                bool IsConnected20 = false;

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

                var PalletCode = TcpClientExample.Start("192.168.2.122", 2001);



                using (var uow = _unitOfWorkManage.CreateUnitOfWork())

                try

                {

                    try

                    if (!PalletCode.IsNotEmptyOrNull() || PalletCode == "NoRead")

                    {

                        if (PalletCode.IsNotEmptyOrNull())

                        {

                            Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

                            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

                        throw new InvalidOperationException("托盘为空");

                    }

                    catch (Exception ex)

                    Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

                    if (dt_Boxing == null)

                    {

                        WriteError(device.DeviceName, "检测扫码流程执行异常", ex);

                        device.SetValue(W_PLCDBName.wboolLocation3ScanDone, true);

                        throw new InvalidOperationException("托盘为空");

                    }

                    if (dt_Boxing.ProductCode == null && dt_Boxing.BoxingNo == null)

                    {

                        device.SetValue(W_PLCDBName.wboolLocation3ScanDone, true);

                        return;

                    }

                    Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == dt_Boxing.ProductCode);

                    if(dt_Formula.PressNoCheckBottomPlate == 1)

                    {

                        device.SetValue(W_PLCDBName.wboolLocation9ScanDone, true);

                    }

                    else

                    {

                        device.SetValue(W_PLCDBName.wboolLocation9ScanDone, false);

                    }



                    //写入PLC

                    device.SetValue(W_PLCDBName.wrealCheckPalletCode, dt_Boxing.Id % 100);

                    device.SetValue(W_PLCDBName.wrealP0P1Width, dt_Formula.P0P1Width);

                    device.SetValue(W_PLCDBName.wrealP0P2Width, dt_Formula.P0P2Width);

                    device.SetValue(W_PLCDBName.wrealP0P3Width, dt_Formula.P0P3Width);

                    device.SetValue(W_PLCDBName.wrealP1P3Height, dt_Formula.ScrewTorqueOutput + dt_Formula.GasketHeight);

                    device.SetValue(W_PLCDBName.wrealP2P3Height, dt_Formula.ProductHeight + dt_Formula.GasketHeight);

                    device.SetValue(W_PLCDBName.wrealProdHeightDiff, dt_Formula.DetectHeightDiff);

                    device.SetValue(W_PLCDBName.wrealScrewHeight, dt_Formula.ScrewPositionDiff);

                    






                    //检测扫码完成

                    device.SetValue(W_PLCDBName.wboolLocation3ScanDone, true);





                }

                catch (Exception ex)

                {

                    WriteError(device.DeviceName, "检测扫码流程执行异常", ex);

                }

            }

            else if (!Location3ScanStart && Location3ScanDone)

@@ -337,57 +482,179 @@
        }



        /// <summary>

        /// æ£€æµ‹ä¿¡æ¯ä¸Šä¼ 

        /// </summary>

        /// <param name="device"></param>

        /// <exception cref="NotImplementedException"></exception>

        private void HandleDetectInfoUpload(OtherDevice device)

        {



            //DB800.1.6

            var Location7ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation7ScanStart);

            var Location7ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation7ScanDone);

            if (Location7ScanStart && !Location7ScanDone)

            {

                var PalletNum = device.GetValue<R_PLCDBName, int>(R_PLCDBName.rrealCheckPalletCode);



                try

                {

                    if (!PalletNum.IsNotEmptyOrNull())

                    {

                        throw new InvalidOperationException("托盘为空");

                    }

                    Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.Id % 100 == PalletNum);



                    if (dt_Boxing == null)

                    {

                        throw new InvalidOperationException("未找到组盘数据");

                    }

                    Dt_Formula dt_Formula = _formulaService.Repository.QueryFirst(x => x.ProductCode == dt_Boxing.ProductCode);



                    //接收数据

                    decimal Height1 = (decimal)device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectHeight1);//113

                    decimal Height2 = (decimal)device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectHeight2);//92

                    decimal Height3 = (decimal)device.GetValue<R_PLCDBName, float>(R_PLCDBName.rrealDetectHeight3);//11

                    if(dt_Formula.PressNoCheckBottomPlate == 1)

                    {

                        Height3 = 0;

                    }



                    //bool CheckUnfinished = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rrealDetectByInspectUnfinished);



                    


                    Dt_ProcessInfo dt_ProcessInfo = _processInfoService.Repository.QueryFirst(x => x.PalletCode == dt_Boxing.PalletCode);

                    int id = 0;

                    if (dt_ProcessInfo == null)

                    {

                        dt_ProcessInfo = new Dt_ProcessInfo()

                        {

                            PalletCode = dt_Boxing.PalletCode,

                            ProductCode = dt_Formula.ProductCode,

                            ProductName = dt_Formula.ProductName,

                            ProductSn = dt_Boxing.BoxingNo,

                        };

                        id = _processInfoService.Repository.AddData(dt_ProcessInfo);

                    }

                    else

                    {

                        id = dt_ProcessInfo.Id;

                    }

                    decimal? ThreadPositionHeight = Height1 - Height3 - dt_Formula.GasketHeight;

                    decimal? ProductCheckHeight = Height2 - Height3 - dt_Formula.GasketHeight;



                    dt_ProcessInfo.Id = id;

                    dt_ProcessInfo.ThreadPositionHeight = ThreadPositionHeight;

                    dt_ProcessInfo.ProductCheckHeight = ProductCheckHeight;

                    dt_ProcessInfo.Height1 = Height1;

                    dt_ProcessInfo.Height2 = Height2;

                    dt_ProcessInfo.Height3 = Height3;



                    if(

                        ProductCheckHeight > dt_Formula.ProductHeight + dt_Formula.DetectHeightDiff || ProductCheckHeight < dt_Formula.ProductHeight - dt_Formula.DetectHeightDiff ||

                        ThreadPositionHeight > dt_Formula.ScrewTorqueOutput + dt_Formula.ScrewPositionDiff || ThreadPositionHeight < dt_Formula.ScrewTorqueOutput - dt_Formula.ScrewPositionDiff

                        )

                    {

                        dt_ProcessInfo.ProductStatus = 0;

                    }



                    _processInfoService.Repository.UpdateData(dt_ProcessInfo);

                    //检测信息上传完成

                    device.SetValue(W_PLCDBName.wboolLocation7ScanDone, true);



                }

                catch (Exception ex)

                {

                    WriteError(device.DeviceName, "检测扫码流程执行异常", ex);

                }

            }

            else if (!Location7ScanStart && Location7ScanDone)

            {

                device.SetValue(W_PLCDBName.wboolLocation7ScanDone, false);

            }



        }





        /// <summary>

        /// ä¸‹çº¿æ‰«ç 

        /// </summary>

        /// <param name="device"></param>

        private void HandleOfflineScan(OtherDevice device)

        {

            //DB800.1.3



            var Location4ScanStart = device.GetValue<R_PLCDBName, bool>(R_PLCDBName.rboolLocation4ScanStart);

            var Location4ScanDone = device.GetValue<W_PLCDBName, bool>(W_PLCDBName.wboolLocation4ScanDone);

            if (Location4ScanStart && !Location4ScanDone)//控制扫码枪扫描托盘码，根据托盘码查询组盘数据，判断托盘绑定成品是否已绑定所有所需零件

            {

                SerialPortCommunicator portCommunicator21 = new SerialPortCommunicator("COM21", 9600, "下线扫码枪");

                bool IsConnected21 = false;

                SerialPortCommunicator portCommunicator22 = new SerialPortCommunicator("COM22", 9600, "下线扫码枪");

                bool IsConnected22 = false;

                if (!IsConnected21) IsConnected21 = portCommunicator21.Connect();

                if (!IsConnected22) IsConnected22 = portCommunicator22.Connect();

                byte[] dataToSend1 = Encoding.ASCII.GetBytes(command);//转成字节数组

                portCommunicator21.Write(dataToSend1);

                string receiveData = portCommunicator22.ToString(Encoding.UTF8);

                byte[] dataToSend2 = Encoding.ASCII.GetBytes("PL106");//转成字节数组

                portCommunicator22.Write(dataToSend2);

                //}

                string PalletCode = portCommunicator21.ToString(Encoding.UTF8);

                var PalletCode = TcpClientExample.Start("192.168.2.123", 2001);

                using (var uow = _unitOfWorkManage.CreateUnitOfWork())

                {

                    try

                    {

                        if (PalletCode.IsNotEmptyOrNull())

                        if (!PalletCode.IsNotEmptyOrNull() || PalletCode == "NoRead")

                        {

                            Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

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

                            throw new InvalidOperationException("托盘为空");

                        }

                        IsConnected21 = !portCommunicator21.Disconnect();

                        IsConnected22 = !portCommunicator22.Disconnect();

                        Dt_Boxing dt_Boxing = _boxingService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

                        WriteInfo("下线扫码组盘数据",$"{PalletCode}_boxingService查询{dt_Boxing}");



                        if (dt_Boxing != null)

                        {

                            WriteInfo("下线扫码组盘数据", $"{PalletCode}_boxingService删除{dt_Boxing}");

                            _boxingService.Repository.DeleteData(dt_Boxing);

                            
                            List<Dt_BoxingDetail> dt_BoxingDetails = _boxingDetailService.Repository.QueryData(x => x.BoxingId == dt_Boxing.Id);

                            if (dt_BoxingDetails != null)

                            {

                                WriteInfo("下线扫码组盘数据", $"{PalletCode}_boxingService删除{dt_BoxingDetails}");

                                _boxingDetailService.Repository.DeleteData(dt_BoxingDetails);

                            }

                        }

                        Dt_ProcessInfo dt_ProcessInfo = _processInfoService.Repository.QueryFirst(x => x.PalletCode == PalletCode);

                        WriteInfo("下线扫码组盘数据", $"{PalletCode}_processInfoService查询{dt_ProcessInfo}");

                        if (dt_ProcessInfo != null)

                        {

                            Dt_ProcessInfoDetail dt_ProcessInfoDetail = new Dt_ProcessInfoDetail()

                            {

                                PalletCode = PalletCode,

                                ProductCode = dt_ProcessInfo.ProductCode?.ToString() ?? "",

                                ProductName = dt_ProcessInfo.ProductName?.ToString() ?? "",

                                ProductSn = dt_ProcessInfo.ProductSn,

                                PressTightenOk = dt_ProcessInfo.PressTightenOk,

                                PressTightenUnfinished = dt_ProcessInfo.PressTightenUnfinished,

                                ProductStatus = dt_ProcessInfo.ProductStatus,

                                ScrewTorque = dt_ProcessInfo.ScrewTorque,

                                ScrewAngle = dt_ProcessInfo.ScrewAngle,

                                PressPressure = dt_ProcessInfo.PressPressure,

                                ThreadPositionHeight = dt_ProcessInfo.ThreadPositionHeight,

                                ProductCheckHeight = dt_ProcessInfo.ProductCheckHeight,

                                Height1 = dt_ProcessInfo.Height1,

                                Height2 = dt_ProcessInfo.Height2,

                                Height3 = dt_ProcessInfo.Height3,

                                Creater = "admin",

                                CreateDate = DateTime.Now

                            };

                            _processDetailInfoService.Repository.AddData(dt_ProcessInfoDetail);

                            WriteInfo("下线扫码组盘数据", $"{PalletCode}_processInfoService删除{dt_ProcessInfo}");

                            _processInfoService.DeleteData(dt_ProcessInfo);

                            
                        }

                        uow.Commit();

                        //下线扫码完成

                        device.SetValue(W_PLCDBName.wboolLocation4ScanDone, true);

                    }

                    catch (Exception ex)

                    {

                        WriteError(device.DeviceName, "下线扫码流程执行异常", ex);



                    }

                }

            }

            else if (!Location4ScanStart && Location4ScanDone)

            {

                device.SetValue(W_PLCDBName.wboolLocation2ScanDone, false);

                device.SetValue(W_PLCDBName.wboolLocation4ScanDone, false);

            }

        }

    }