分支自 SuZhouGuanHong/TaiYuanTaiZhong
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
dengjunjie
2024-06-28 1e38f44af86775a341e4d0e4411d24ad35e417d3 
 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/PipelineJob.cs


@@ -1,17 +1,29 @@


using Quartz;


using HslCommunication;


using Microsoft.AspNetCore.Mvc;


using Newtonsoft.Json;


using Quartz;


using System;


using System.Collections.Generic;


using System.Linq;


using System.Net;


using System.Reflection;


using System.Text;


using System.Threading.Tasks;


using System.Xml.Linq;


using WIDESEA_Comm;


using WIDESEA_Comm.LogInfo;


using WIDESEA_Comm.TaskNo;


using WIDESEA_Core.BaseProvider;


using WIDESEA_Core.EFDbContext;


using WIDESEA_Core.FreeDB;


using WIDESEA_Core.Extensions;


using WIDESEA_Entity.DomainModels;


using WIDESEA_WCS.IRepositories;


using WIDESEA_WCS.Jobs;


using WIDESEA_WCS.JobsPart.Common;


using WIDESEA_WCS.Repositories;


using WIDESEA_WCS.WCSClient;


using WIDESEA_WMS.IRepositories;


using WIDESEA_WMS.Repositories;


using static System.Collections.Specialized.BitVector32;




namespace WIDESEA_WCS


@@ -26,20 +38,6 @@


        {


            try


            {


                var client = context.JobDetail.JobDataMap.Get("JobParams") as PLCClient;


                if (client == null)


                {


                    return Task.CompletedTask;


                }




                //自动重连


                if (!client.IsConnected)


                {


                    client.Connect();


                    return Task.CompletedTask;


                }




                //DoAction(client);


                ExecuteJob(context, DoAction);


            }


            catch { }


@@ -55,67 +53,11 @@


                client.Connect();


                return;


            }


            Loadinglevel(client);


        }


        /// <summary>


        /// ä¸Šæ–™åŒº


        /// </summary>


        /// <param name="client"></param>


        private void Loadinglevel(PLCClient client, string number = "上料区")


        {


            VOLContext Context = new VOLContext();


            Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context);


            Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context);


            Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context);


            Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context);


            var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName);


            var Gantry_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "桁架");


            if (!Gantry_client.IsConnected) return;


            var Gantryplc = repository.FindFirst(x => x.plcinfo_name == Gantry_client.PLCName);


            List<string> names = new List<string>() { "S01001001", "S01001002" };


            foreach (string name in names)


            {


                var station = stationinfoRepository.FindFirst(x => x.stationCode == name && x.enable && x.location_state == LocationStateEnum.Stroge.ToString());


                if (station == null)


                {


                    Gantry_client.WriteByOrder("W_RequestUnload", false, number);//信号为false桁架停止进入


                    continue;


                }


                var details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == name).ToList();


                var PalletSignal = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_PalletSignal").First(), client);//读取托盘信号:1:有,2无


                var MaterialSignal = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_MaterialSignal").First(), client);//读取货物信号:1:有,2无


                if (PalletSignal == 1 && MaterialSignal == 1)


                {


                    Gantry_client.WriteByOrder("W_AreaNr", (Int16)1, number);//区域货位号


                    Gantry_client.WriteByOrder("W_IndexNr", (Int16)1, number);//托盘上的第几个车轮


                    Gantry_client.WriteByOrder("W_Storage_Type", (Int16)1, number); //托盘类型1-横放;2-竖放


                    Gantry_client.WriteByOrder("W_Wheel_Type", (Int16)1, number);//车轮类型


                    Gantry_client.WriteByOrder("W_Wheel_id", "", number);//车轮SN号


                    Gantry_client.WriteByOrder("W_RequestUnload", true, number);


                }


                else


                {


                    Gantry_client.WriteByOrder("W_RequestUnload", false, number);


                }


                var Gantrydetails = plcRepository.Find(x => x.plcdetail_iotype == Gantryplc.plcinfo_iotyep && x.plcdetail_number == number).ToList();


                var Gantry_Out_of_Area = (bool)DBExtension.Read(Gantrydetails.Where(x => x.plcdetail_name == "R_Gantry_Out_of_Area").First(), Gantry_client);//桁架是否在区域内




                var QueryDate = (bool)DBExtension.Read(Gantrydetails.Where(x => x.plcdetail_name == "R_QueryDate").First(), Gantry_client);//信息查询


                if (QueryDate)


                {


                    var Date_Vaild = (bool)DBExtension.Read(Gantrydetails.Where(x => x.plcdetail_name == "R_Date_Vaild").First(), Gantry_client);//信息确认


                    if (!Date_Vaild)//信息有误，记录日志


                    {




                    }


                }


                var finished = (bool)DBExtension.Read(Gantrydetails.Where(x => x.plcdetail_name == "R_Unlod_finished").First(), Gantry_client);//夹取完成


                if (finished)


                {




                    Gantry_client.WriteByOrder("W_Storage_update", true, number);//货位状态更新


                }


            }


            client.WriteByOrder("W_Palpitate", client.ReadByOrder<bool>("R_Palpitate", "心跳"));


            Pipeline pipeline = new Pipeline();


            pipeline.Loadinglevel(client);


            pipeline.AutoEmptyTray(client);


            pipeline.StationState(client);


        }


    }


}