人工出库，人工入库，人工移库，PDA扫码确认外协物料已被取走接口

dengjunjie

2024-04-27 0b5ccdca6263cf7a2cee460f30c76ef1efea2811

 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs

@@ -5,6 +5,7 @@
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using System.Xml.Linq;
using WIDESEA_Comm.DBItem;
using WIDESEA_Comm.ItemDB;
using WIDESEA_Core.EFDbContext;
@@ -41,121 +42,11 @@
                client.Connect();
                return;
            }
            client.WriteByOrder("W_Palpitate", client.ReadByOrder<bool>("R_Palpitate", "心跳"));
            Gantry gantry = new Gantry();
            gantry.QueryWheeldata(client);
            gantry.QueryOrder(client);
            gantry.QueryWheeldata(client);
            gantry.Layofflevel(client);
            gantry.Stupidproofmeasure(client);
        }

        #region
        static List<MachineDB> MachineDBs = new List<MachineDB>();
        static List<WheelDataDB> wheelDataDBs = new List<WheelDataDB>();
        private void DoAction(PLCClient client)
        {
            try
            {
                VOLContext Context = new VOLContext();
                Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context);
                Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context);

                var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName);
                var numbers = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep).GroupBy(x => x.plcdetail_number).ToList();
                foreach (var number in numbers)
                {
                    if (number.Key.Contains("辊道下料"))
                    {
                        PropertyInfo[] propertyInfos = typeof(WheelDataDB).GetProperties();//获取所有属性
                        WheelDataDB dBItem = wheelDataDBs.Where(x => x.R_Name == number.Key).FirstOrDefault();
                        if (dBItem == null)
                        {
                            dBItem = new();
                            dBItem.OnReadSignal += HandleReadSignal;
                            wheelDataDBs.Add(dBItem);
                        }
                        List<dt_plcinfodetail> details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == number.Key).ToList();
                        for (int i = 0; i < propertyInfos.Length; i++)
                        {
                            if (i == 0)
                            {
                                dBItem.R_Name = number.Key;
                            }
                            else
                            {
                                object readData = DBExtension.Read(details.Where(x => x.plcdetail_name == propertyInfos[i].Name).FirstOrDefault(), client);
                                if (readData != null) { }
                                object obj = propertyInfos[i].GetValue(dBItem);
                                if (obj != readData)
                                    propertyInfos[i].SetValue(dBItem, readData);
                            }
                        }
                    }
                    else
                    {

                        PropertyInfo[] propertyInfos = typeof(MachineDB).GetProperties();//获取所有属性
                        MachineDB dBItem = MachineDBs.Where(x => x.R_Name == number.Key).FirstOrDefault();
                        if (dBItem == null)
                        {
                            dBItem = new();
                            dBItem.OnReadSignal += HandleReadSignal;
                            MachineDBs.Add(dBItem);
                        }
                        List<dt_plcinfodetail> details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == number.Key).ToList();
                        for (int i = 0; i < propertyInfos.Length; i++)
                        {
                            if (i == 0)
                            {
                                dBItem.R_Name = number.Key;
                            }
                            else
                            {
                                object readData = DBExtension.Read(details.Where(x => x.plcdetail_name == propertyInfos[i].Name).FirstOrDefault(), client);
                                if (readData != null) { }
                                object obj = propertyInfos[i].GetValue(dBItem);
                                if (obj != readData)
                                    propertyInfos[i].SetValue(dBItem, readData);
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {

                throw;
            }
        }
        #endregion
        public void HandleReadSignal(string type, MachineDB DBItem)
        {
            switch (type)
            {
                case OperationType.OperationType_Record:

                    break;
                case OperationType.OperationType_Processor:

                    break;
                case OperationType.OperationType_WheelData:

                    break;
            }
        }
        public void HandleReadSignal(string type, WheelDataDB DBItem)
        {
            switch (type)
            {
                case OperationType.OperationType_Record:

                    break;
                case OperationType.OperationType_Processor:

                    break;
                case OperationType.OperationType_WheelData:

                    break;
            }
        }
    }
}