分支自 SuZhouGuanHong/TaiYuanTaiZhong
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
dengjunjie
2024-04-01 19c66ba052a7fb26c4d27deaa75ae46479eee342 
 ´úÂë¹ÜÀí/PCS/WCS_Server/WIDESEA_WCS/Common/Gantry.cs


@@ -11,6 +11,7 @@


using WIDESEA_Comm.LogInfo;


using WIDESEA_Comm.TaskNo;


using WIDESEA_Core.EFDbContext;


using WIDESEA_Core.FreeDB;


using WIDESEA_Entity.DomainModels;


using WIDESEA_WCS.IRepositories;


using WIDESEA_WCS.JobsPart.Common;


@@ -37,6 +38,7 @@


                VOLContext Context = new VOLContext();


                Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context);


                Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context);


                IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);


                Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context);


                Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context);


                Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context);


@@ -56,32 +58,47 @@


                        if (name == "3单元辊道下料查询车轮") number = "3单元辊道下料查询订单";


                        if (name == "辊道上料查询车轮") number = "辊道上料查询订单";


                        var wp_id = client.ReadByOrder<string>("R_o_wp_id", number);


                        var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == wp_id);


                        if (mes_Detail == null)




                        var Mes_Work = workinfoRepository.Find(x => x.SN == wp_id && x.processCode == (name != "辊道上料查询车轮" ? "17" : "28")).FirstOrDefault();


                        if (Mes_Work == null)


                        {


                            client.WriteByOrder("W_i_status", (byte)2, name);


                            client.WriteByOrder("R_oi_on", (byte)0, name);


                            #region æ—¥å¿—记录


                            WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{wp_id}\n\n写入桁架信息：\nW_i_status：2\nR_oi_on：0\n\n未查询到工单详情", "PCS");


                            #endregion


                            continue;


                        }


                        var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID);


                        if (mes_Head == null)


                        {


                            client.WriteByOrder("W_i_status", (byte)2, name);


                            client.WriteByOrder("R_oi_on", (byte)0, name);


                            #region æ—¥å¿—记录


                            WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{wp_id}\n\n写入桁架信息：\nW_i_status：2\nR_oi_on：0\n\n未查询到工单头表", "PCS");


                            WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{wp_id}\n\n写入桁架信息：\nW_i_status：2\nR_oi_on：0\n\n未查询到工单信息", "PCS");


                            #endregion


                            continue;


                        }




                        #region MyRegion


                        //var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == wp_id);


                        //if (mes_Detail == null)


                        //{


                        //    client.WriteByOrder("W_i_status", (byte)2, name);


                        //    client.WriteByOrder("R_oi_on", (byte)0, name);


                        //    #region æ—¥å¿—记录


                        //    WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{wp_id}\n\n写入桁架信息：\nW_i_status：2\nR_oi_on：0\n\n未查询到工单详情", "PCS");


                        //    #endregion


                        //    continue;


                        //}


                        //var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID);


                        //if (mes_Head == null)


                        //{


                        //    client.WriteByOrder("W_i_status", (byte)2, name);


                        //    client.WriteByOrder("R_oi_on", (byte)0, name);


                        //    #region æ—¥å¿—记录


                        //    WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{wp_id}\n\n写入桁架信息：\nW_i_status：2\nR_oi_on：0\n\n未查询到工单头表", "PCS");


                        //    #endregion


                        //    continue;


                        //}


                        #endregion






                        if (name != "辊道上料查询车轮")


                        {


                            //var geometry = dataRepository.FindFirst(x => x.TypeId == (Int32)wp_type);


                            var geometry = dataRepository.Find(x => x.Description == mes_Head.drawingNo).FirstOrDefault();


                            var geometry1 = detectionlineRepository.Find(x => x.Description == mes_Head.drawingNo).FirstOrDefault();


                            var geometry = dataRepository.Find(x => x.Description == Mes_Work.drawingNo).FirstOrDefault();


                            var geometry1 = detectionlineRepository.Find(x => x.Description == Mes_Work.drawingNo).FirstOrDefault();


                            if (geometry == null && geometry1 == null)


                            {


                                //DBExtension.Write(details.Where(x => x.plcdetail_name == "W_i_status").First(), client, (Int16)2);


@@ -121,8 +138,8 @@


                        }


                        else


                        {


                            var geometry = detectionlineRepository.Find(x => x.Description == mes_Head.drawingNo).FirstOrDefault();


                            var geometry1 = dataRepository.Find(x => x.Description == mes_Head.drawingNo).FirstOrDefault();


                            var geometry = detectionlineRepository.Find(x => x.Description == Mes_Work.drawingNo).FirstOrDefault();


                            var geometry1 = dataRepository.Find(x => x.Description == Mes_Work.drawingNo).FirstOrDefault();


                            if (geometry == null && geometry1 == null)


                            {


                                client.WriteByOrder("W_i_status", (byte)2, name);


@@ -183,6 +200,7 @@


                Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context);


                Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context);


                Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context);


                IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);


                Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context);


                Idt_patternRepository patternRepository = new dt_patternRepository(Context);


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


@@ -206,16 +224,9 @@


                            continue;


                        }


                        var wp_type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_type").First(), client);


                        var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == wp_id);


                        #region æµ‹è¯•ä½¿ç”¨


                        //if (mes_Detail == null)


                        //{


                        //    mes_Detail = mes_DetailRepository.FindFirst(x => x.jobID == (name == "3单元辊道下料查询订单" ? "01180127004-2" : "01180127004-1"));


                        //    mes_Detail.SN = wp_id;


                        //    mes_DetailRepository.Update(mes_Detail, true);


                        //}


                        #endregion


                        if (mes_Detail == null)




                        var Mes_Work = workinfoRepository.Find(x => x.SN == wp_id && x.processCode == (name != "辊道上料查询订单" ? "17" : "28")).FirstOrDefault();


                        if (Mes_Work == null)


                        {


                            client.WriteByOrder("W_i_status", (byte)2, name);


                            client.WriteByOrder("R_oi_on", (byte)0, name);


@@ -224,16 +235,30 @@


                            #endregion


                            continue;


                        }


                        var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID);


                        if (mes_Head == null)


                        {


                            client.WriteByOrder("W_i_status", (byte)2, name);


                            client.WriteByOrder("R_oi_on", (byte)0, name);


                            #region æ—¥å¿—记录


                            WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{wp_id}\n\n写入桁架信息：\nW_i_status：2\nR_oi_on：0\n\n未查询到工单头表", "PCS");


                            #endregion


                            continue;


                        }


                        #region MyRegion


                        //var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == wp_id);


                        //if (mes_Detail == null)


                        //{


                        //    client.WriteByOrder("W_i_status", (byte)2, name);


                        //    client.WriteByOrder("R_oi_on", (byte)0, name);


                        //    #region æ—¥å¿—记录


                        //    WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{wp_id}\n\n写入桁架信息：\nW_i_status：2\nR_oi_on：0\n\n未查询到工单详情", "PCS");


                        //    #endregion


                        //    continue;


                        //}


                        //var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID);


                        //if (mes_Head == null)


                        //{


                        //    client.WriteByOrder("W_i_status", (byte)2, name);


                        //    client.WriteByOrder("R_oi_on", (byte)0, name);


                        //    #region æ—¥å¿—记录


                        //    WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{wp_id}\n\n写入桁架信息：\nW_i_status：2\nR_oi_on：0\n\n未查询到工单头表", "PCS");


                        //    #endregion


                        //    continue;


                        //}


                        #endregion




                        var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == Mes_Work.jobID);




                        if (name != "辊道上料查询订单")


                        {


@@ -265,11 +290,11 @@


                            {


                                //1-好,允许加工，2-不在列表中，3-不加工车轮类型，4-手动入库模式人工未选择库区


                                client.WriteByOrder("W_i_status", (byte)1, name);


                                client.WriteByOrder("W_i_job_id", mes_Detail.jobID, name);


                                client.WriteByOrder("W_i_drawing_id", mes_Head.drawingNo, name);


                                client.WriteByOrder("W_i_heat_id", mes_Detail.heatID, name);


                                client.WriteByOrder("W_i_job_id", Mes_Work.jobID, name);


                                client.WriteByOrder("W_i_drawing_id", Mes_Work.drawingNo, name);


                                client.WriteByOrder("W_i_heat_id", Mes_Work.heatID, name);


                                //client.WriteByOrder("W_i_sourceheat", "", name);


                                client.WriteByOrder("W_i_batch_id", mes_Detail.heatBatchID, name);


                                client.WriteByOrder("W_i_batch_id", Mes_Work.heatBatchID, name);




                                //屏蔽工艺(屏蔽视觉检测/屏蔽涂油)


                                //if (name != "辊道上料查询车轮")


@@ -281,7 +306,7 @@


                                client.WriteByOrder("R_oi_on", (byte)0, name);


                                #region æ—¥å¿—记录


                                WriteDBLog.Success(name, $"读取桁架信息：\n车轮SN：{wp_id}\n轮型ID：{wp_type}\n\n写入桁架信息：\nW_i_status：1" +


                                    $"\nW_i_job_id：{mes_Detail.jobID}\nW_i_drawing_id：{mes_Head.drawingNo}\nW_i_heat_id：{mes_Detail.heatID}\nW_i_batch_id：{mes_Detail.heatBatchID}" +


                                    $"\nW_i_job_id：{Mes_Work.jobID}\nW_i_drawing_id：{Mes_Work.drawingNo}\nW_i_heat_id：{Mes_Work.heatID}\nW_i_batch_id：{Mes_Work.heatBatchID}" +


                                    $"\nW_i_skip_op_SJ1：{(name == "3单元辊道下料查询订单" ? true : mes_Head.skip_op_1)}\nW_i_skip_op_SJ2：{(name == "3单元辊道下料查询订单" ? true : mes_Head.skip_op_2)}" +


                                    $"\nW_i_skip_op_LT：{mes_Head.skip_op_3}\nR_oi_on：0", "PCS");


                                #endregion


@@ -305,15 +330,15 @@


                            {


                                //1-好,允许加工，2-不在列表中，3-不加工车轮类型，4-手动入库模式人工未选择库区


                                client.WriteByOrder("W_i_status", (byte)1, name);


                                client.WriteByOrder("W_i_job_id", mes_Detail.jobID, name);


                                client.WriteByOrder("W_i_drawing_id", mes_Head.drawingNo, name);


                                client.WriteByOrder("W_i_heat_id", mes_Detail.heatID, name);


                                client.WriteByOrder("W_i_job_id", Mes_Work.jobID, name);


                                client.WriteByOrder("W_i_drawing_id", Mes_Work.drawingNo, name);


                                client.WriteByOrder("W_i_heat_id", Mes_Work.heatID, name);


                                //client.WriteByOrder("W_i_sourceheat", "", name);


                                client.WriteByOrder("W_i_batch_id", mes_Detail.heatBatchID, name);


                                client.WriteByOrder("W_i_batch_id", Mes_Work.heatBatchID, name);


                                client.WriteByOrder("R_oi_on", (byte)0, name);


                                #region æ—¥å¿—记录


                                WriteDBLog.Success(name, $"读取桁架信息：\n车轮SN：{wp_id}\n轮型ID：{wp_type}\n\n写入桁架信息：\nW_i_status：1" + $"\nW_i_job_id：{mes_Detail.jobID}" +


                                    $"\nW_i_drawing_id：{mes_Head.drawingNo}\nW_i_heat_id：{mes_Detail.heatID}\nW_i_batch_id：{mes_Detail.heatBatchID}\nR_oi_on：0", "PCS");


                                WriteDBLog.Success(name, $"读取桁架信息：\n车轮SN：{wp_id}\n轮型ID：{wp_type}\n\n写入桁架信息：\nW_i_status：1" + $"\nW_i_job_id：{Mes_Work.jobID}" +


                                    $"\nW_i_drawing_id：{mes_Head.drawingNo}\nW_i_heat_id：{Mes_Work.heatID}\nW_i_batch_id：{Mes_Work.heatBatchID}\nR_oi_on：0", "PCS");


                                #endregion


                            }


                        }


@@ -344,6 +369,7 @@


                Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context);


                Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context);


                Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context);


                IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(Context);


                Idt_patternRepository patternRepository = new dt_patternRepository(Context);


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


                var Pipeline_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "链条机");


@@ -405,28 +431,38 @@


                            var Wheel_SN = client.ReadByOrder<string>("R_Wheel_id", name);//车轮SN号


                            if (string.IsNullOrEmpty(Wheel_SN))


                            {


                                WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN号为空", "PCS");


                                WriteDBLog.Error(name + "放料完成", $"读取桁架信息：\n车轮SN号为空", "PCS");


                                continue;


                            }




                            //var Wheel_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_id").First(), client).ToString();




                            var Detail = mes_DetailRepository.FindFirst(x => x.SN == Wheel_SN);


                            if (Detail == null)


                            var Mes_Work = workinfoRepository.Find(x => x.SN == Wheel_SN && x.processCode == "17").FirstOrDefault();


                            if (Mes_Work == null)


                            {


                                #region æ—¥å¿—记录


                                WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN号：{Wheel_SN}\n\n未查询到工单详情", "PCS");


                                #endregion


                                continue;


                            }


                            var Head = mes_HeadRepository.FindFirst(x => x.jobID == Detail.jobID && x.processCode == "17");


                            if (Head == null)


                            {


                                #region æ—¥å¿—记录


                                WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN号：{Wheel_SN}\n\n未查询到工单头表{Detail.jobID}", "PCS");


                                #endregion


                                continue;


                            }


                            #region MyRegion


                            //var Detail = mes_DetailRepository.FindFirst(x => x.SN == Wheel_SN);


                            //if (Detail == null)


                            //{


                            //    #region æ—¥å¿—记录


                            //    WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN号：{Wheel_SN}\n\n未查询到工单详情", "PCS");


                            //    #endregion


                            //    continue;


                            //}


                            //var Head = mes_HeadRepository.FindFirst(x => x.jobID == Detail.jobID && x.processCode == "17");


                            //if (Head == null)


                            //{


                            //    #region æ—¥å¿—记录


                            //    WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN号：{Wheel_SN}\n\n未查询到工单头表{Detail.jobID}", "PCS");


                            //    #endregion


                            //    continue;


                            //}


                            #endregion




                            #endregion




                            var AreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_AreaNr").First(), client);


@@ -448,9 +484,9 @@


                            station.quantity++;


                            if (station.quantity == 1)


                            {


                                station.stationType = Head.drawingNo;


                                station.Number = Head.jobID;


                                station.heatNumber = Detail.heatID;


                                station.stationType = Mes_Work.drawingNo;


                                station.Number = Mes_Work.workOrder;


                                station.heatNumber = Mes_Work.heatID;


                                station.tray_status = "StrogeTray";


                            }




@@ -473,11 +509,13 @@


                            //client.WriteByOrder("W_Enabl_Load", false, name);//是否允许




                            #region ä¿®æ”¹å·¥å•çŠ¶æ€


                            var Detail = mes_DetailRepository.FindFirst(x => x.jobID == Mes_Work.jobID && x.SN == Mes_Work.SN);


                            Detail.Status = "下线";


                            Detail.FinishTime = DateTime.Now;


                            count = mes_DetailRepository.Update(Detail, true);


                            if (count < 1)


                                throw new Exception($"工单子表信息更新失败！车轮SN号：{Detail.SN}");


                            var Head = mes_HeadRepository.FindFirst(x => x.jobID == Detail.jobID);


                            Head.finishNum = Head.finishNum + 1;


                            count = mes_HeadRepository.Update(Head, true);


                            if (count < 1)


@@ -505,30 +543,40 @@


                        var Request = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Request_Load").First(), client);


                        if (!Request) continue;




                        var load_zone = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_load_zone").First(), client);


                        #region è¯»å–桁架信息


                        var Wheel_Type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_Type").First(), client);//车轮类型


                        var Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name);//车轮SN号


                        if (string.IsNullOrEmpty(Wheel_id)) continue;


                        //var Wheel_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_id").First(), client).ToString();




                        var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == Wheel_id);


                        if (mes_Detail == null)


                        var Work = workinfoRepository.Find(x => x.SN == Wheel_id && x.processCode == "17").FirstOrDefault();


                        if (Work == null)


                        {


                            #region æ—¥å¿—记录


                            client.WriteByOrder("W_Enabl_Load", false, name);//信号为false桁架停止进入


                            WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{Wheel_id}\n\n未查询到工单详情", "PCS");


                            #endregion


                            continue;


                            WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{Wheel_id}\n\n未查询到工单信息", "PCS");


                        }


                        var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID);


                        if (mes_Head == null)


                        {


                            #region æ—¥å¿—记录


                            client.WriteByOrder("W_Enabl_Load", false, name);//信号为false桁架停止进入


                            WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{Wheel_id}\n\n未查询到工单头表", "PCS");


                            #endregion


                            continue;


                        }




                        #region MyRegion


                        //var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == Wheel_id);


                        //if (mes_Detail == null)


                        //{


                        //    #region æ—¥å¿—记录


                        //    client.WriteByOrder("W_Enabl_Load", false, name);//信号为false桁架停止进入


                        //    WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{Wheel_id}\n\n未查询到工单详情", "PCS");


                        //    #endregion


                        //    continue;


                        //}


                        //var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID);


                        //if (mes_Head == null)


                        //{


                        //    #region æ—¥å¿—记录


                        //    client.WriteByOrder("W_Enabl_Load", false, name);//信号为false桁架停止进入


                        //    WriteDBLog.Error(name, $"读取桁架信息：\n车轮SN：{Wheel_id}\n\n未查询到工单头表", "PCS");


                        //    #endregion


                        //    continue;


                        //}


                        #endregion




                        #endregion






@@ -538,11 +586,12 @@


                        if (name == "2单元下料区") NGStation = "X02001003";


                        if (name == "3单元下料区") NGStation = "X03001002";




                        foreach (var station in Stations)     //任何一个下料位为空或禁用时,都会停止桁架


                        {


                            if (!station.enable || station.location_state == LocationStateEnum.Empty.ToString())


                                client.WriteByOrder("W_Enabl_Load", false, name);//信号为false桁架停止进入


                        }


                        //foreach (var station in Stations)     //任何一个下料位为空或禁用时,都会停止桁架


                        //{


                        //    if (!station.enable || station.location_state == LocationStateEnum.Empty.ToString())


                        //        client.WriteByOrder("W_Enabl_Load", false, name);//信号为false桁架停止进入


                        //}




                        #region MyRegion


                        //var currentAreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_Are00aNr").First(), client);


                        //var currentAreaCode = PipelineJob.area_code(name);   //根据下料口单元名获取区域代码


@@ -552,8 +601,8 @@


                        #endregion






                        var wheel = PipelineJob.QueryMateriel(mes_Head.drawingNo);


                        var wheel1 = PipelineJob.QueryMateriel1(mes_Head.drawingNo);


                        var wheel = PipelineJob.QueryMateriel(Work.drawingNo);


                        var wheel1 = PipelineJob.QueryMateriel1(Work.drawingNo);


                        if (wheel == null && wheel1 == null)


                        {


                            #region æ—¥å¿—记录


@@ -565,22 +614,23 @@




                        var PartStatus = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_PartStatus").First(), client);//1:ok;2:nok


                        #region æ—¥å¿—记录


                        WriteDBLog.Success(name + "申请放料", $"读取桁架信息：\n车轮SN：{Wheel_id}\n轮型ID：{Wheel_Type}\n车轮状态：{PartStatus}", "PCS");


                        WriteDBLog.Success(name + "申请放料", $"读取桁架信息：\n车轮SN：{Wheel_id}\n轮型ID：{Wheel_Type}\n车轮状态：{PartStatus}\n是否进入下料区：{load_zone}", "PCS");


                        if (load_zone) continue;


                        #endregion


                        if ((Int16)PartStatus == 1)


                        {


                            dt_stationinfo Stationinfo = null;


                            if (mes_Detail.heatID != null)


                            if (Work.heatID != null)


                            {


                                Stationinfo = Stations


                           .Where(x => x.enable


                           && x.stationCode != NGStation


                           && x.location_state == LocationStateEnum.Stroge.ToString()


                           && x.quantity < 5


                           && x.stationType == mes_Head.drawingNo


                           && x.stationType == Work.drawingNo


                           && x.tray_type == ((wheel == null ? wheel1.e : wheel.e) < 1100 ? "SmallTray" : "LargeTray")


                           && x.Number == mes_Detail.jobID


                           && x.heatNumber == mes_Detail.heatID)


                           && x.Number == Work.workOrder


                           && x.heatNumber == Work.heatID)


                           .OrderByDescending(x => x.quantity)


                           .FirstOrDefault();


                            }


@@ -591,9 +641,9 @@


                           && x.stationCode != NGStation


                           && x.location_state == LocationStateEnum.Stroge.ToString()


                           && x.quantity < 5


                           && x.stationType == mes_Head.drawingNo


                           && x.stationType == Work.drawingNo


                           && x.tray_type == ((wheel == null ? wheel1.e : wheel.e) < 1100 ? "SmallTray" : "LargeTray")


                           && x.Number == mes_Detail.jobID)


                           && x.Number == Work.workOrder)


                           .OrderByDescending(x => x.quantity)


                           .FirstOrDefault();


                            }


@@ -613,23 +663,12 @@


                                var NG = Stations.Where(x => x.enable && x.stationCode == NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity > 0).FirstOrDefault();


                                if (NG != null)


                                {


                                    if (NG.stationType != mes_Head.drawingNo)


                                        agvtask(stationinfoRepository, NG, (wheel == null ? wheel1.e : wheel.e), "TaskType_OutsourceInbound");


                                    if (NG.stationType != Work.drawingNo || NG.Number != Work.workOrder)


                                        agvtask(stationinfoRepository, NG, Work, "TaskType_OutsourceInbound");


                                }


                                #endregion




                                Stationinfo = Stations.Where(x => x.enable && x.stationCode != NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity == 0).FirstOrDefault();




                                #region æ²¡æ‰˜ç›˜å¯ç”¨,触发入库任务


                                if (Stationinfo == null)


                                {


                                    var stationinfos = Stations.Where(x => x.enable && x.stationCode != NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity > 0).ToList();


                                    foreach (var stationinfo in stationinfos)


                                    {


                                        agvtask(stationinfoRepository, stationinfo, (wheel == null ? wheel1.e : wheel.e), name == "3单元下料区" ? "TaskType_OutsourceInbound" : "TaskType_Inbound");


                                    }


                                }


                                #endregion




                                #region MyRegion


                                //var stationinfo = Stations.Where(x => x.enable && x.stationCode != NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity > 0).FirstOrDefault();


@@ -675,9 +714,23 @@




                                    #region è´§ä½æ•°é‡ä¸Žå…‰ç”µä¸åŒ¹é…ï¼ŒæŠ¥è­¦


                                    if (list.Count > 0 && MaterialSignal != 1)


                                    {


                                        client.WriteByOrder("W_Enabl_Load", false, name);//信号为false桁架停止进入


                                        Pipeline_client.WriteByOrder("W_AlarmSignal", (Int16)2, name);//报警


                                    //else if (list.Count < 1 && MaterialSignal == 1)


                                    //    Pipeline_client.WriteByOrder("W_AlarmSignal", (Int16)2, name);//报警


                                        Stationinfo.location_state = LocationStateEnum.Abnormal.ToString();


                                        Stationinfo.remark = "车轮数量与光电不匹配";


                                        stationinfoRepository.Update(Stationinfo, true);


                                        //WriteDBLog.Error(name+"申请下料",$"{Stationinfo.stationCode}的货位","PCS");


                                    }


                                    else if (list.Count < 1 && MaterialSignal == 1)


                                    {


                                        client.WriteByOrder("W_Enabl_Load", false, name);//信号为false桁架停止进入


                                        Pipeline_client.WriteByOrder("W_AlarmSignal", (Int16)2, name);//报警


                                        Stationinfo.location_state = LocationStateEnum.Abnormal.ToString();


                                        Stationinfo.remark = "车轮数量与光电不匹配";


                                        stationinfoRepository.Update(Stationinfo, true);


                                    }




                                    #endregion




                                    //缓存架上车轮数量与SN号数量不一致


@@ -703,6 +756,17 @@


                                    continue;


                                }


                            }


                            else


                            {


                                #region æ²¡æ‰˜ç›˜å¯ç”¨,触发入库任务


                                var stationinfos = Stations.Where(x => x.enable && x.stationCode != NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity > 0).ToList();


                                foreach (var stationinfo in stationinfos)


                                {


                                    agvtask(stationinfoRepository, stationinfo, Work, name == "3单元下料区" ? "TaskType_OutsourceInbound" : "TaskType_Inbound");


                                }


                                #endregion


                            }




                        }


                        else if ((Int16)PartStatus == 2)


                        {


@@ -728,18 +792,18 @@


                        && x.stationCode == NGStation


                        && x.location_state == LocationStateEnum.Stroge.ToString()


                        && x.quantity < 5


                        && x.stationType == mes_Head.drawingNo


                        && x.stationType == Work.drawingNo


                        && x.tray_type == ((wheel == null ? wheel1.e : wheel.e) < 1100 ? "SmallTray" : "LargeTray")


                        /*&& x.Number == mes_Detail.jobID*/).FirstOrDefault();


                            //}




                            if (Stationinfo == null)


                            {


                                var stationinfo = Stations.Where(x => x.enable && x.stationCode == NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity > 0).FirstOrDefault();


                                if (stationinfo != null)


                                {


                                    agvtask(stationinfoRepository, stationinfo, (wheel == null ? wheel1.e : wheel.e), "TaskType_OutsourceInbound");


                                }


                                //var stationinfo = Stations.Where(x => x.enable && x.stationCode == NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity > 0).FirstOrDefault();


                                //if (stationinfo != null)


                                //{


                                //    agvtask(stationinfoRepository, stationinfo, (wheel == null ? wheel1.e : wheel.e), "TaskType_OutsourceInbound");


                                //}


                                Stationinfo = Stations.Where(x => x.enable && x.stationCode == NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity == 0).FirstOrDefault();


                            }


                            if (Stationinfo != null)


@@ -772,8 +836,8 @@


                                    #region è´§ä½æ•°é‡ä¸Žå…‰ç”µä¸åŒ¹é…ï¼ŒæŠ¥è­¦


                                    if (list.Count > 0 && MaterialSignal != 1)


                                        Pipeline_client.WriteByOrder("W_AlarmSignal", (Int16)2, name);//报警


                                    //else if (list.Count < 1 && MaterialSignal == 1)


                                    //    Pipeline_client.WriteByOrder("W_AlarmSignal", (Int16)2, name);//报警


                                    else if (list.Count < 1 && MaterialSignal == 1)


                                        Pipeline_client.WriteByOrder("W_AlarmSignal", (Int16)2, name);//报警


                                    #endregion




                                    //缓存架上车轮数量与SN号数量不一致


@@ -870,7 +934,7 @@


        /// <summary>


        /// AGV任务


        /// </summary>


        public void agvtask(Idt_stationinfoRepository stationinfoRepository, dt_stationinfo stationinfo, float e, string tasktype)


        public void agvtask(Idt_stationinfoRepository stationinfoRepository, dt_stationinfo stationinfo, VV_Mes_Workinfo Work, string tasktype)


        {


            VOLContext Context = new VOLContext();


            Idt_agvtaskRepository agvtaskRepository = new dt_agvtaskRepository(Context);


@@ -878,23 +942,24 @@




            var task = agvtaskRepository.Find(x => x.agv_fromaddress == stationinfo.stationCode).FirstOrDefault();


            if (task != null) return;


            var mes_Head = mes_HeadRepository.Find(x => x.jobID == stationinfo.Number).FirstOrDefault();


            if (mes_Head == null)


            {


                stationinfo.remark = "触发入库任务,但未找到工单头表！";


                stationinfo.location_state = LocationStateEnum.Abnormal.ToString();


                stationinfoRepository.Update(stationinfo, true);


                return;


            }


            //var mes_Head = mes_HeadRepository.Find(x => x.jobID == Work.jobID).FirstOrDefault();


            //if (mes_Head == null)


            //{


            //    stationinfo.remark = "触发入库任务,但未找到工单头表！";


            //    stationinfo.location_state = LocationStateEnum.Abnormal.ToString();


            //    stationinfoRepository.Update(stationinfo, true);


            //    return;


            //}




            dt_stationinfo TargetLocation = null;


            int CompeletedNum = Convert.ToInt32(mes_Head.quantity) - Convert.ToInt32(mes_Head.finishNum);


            if (mes_Head.quantity <= 50) tasktype = "TaskType_OutsourceInbound";


            //int CompeletedNum = Convert.ToInt32(mes_Head.quantity) - Convert.ToInt32(mes_Head.finishNum);


            //if (mes_Head.quantity <= 50) tasktype = "TaskType_OutsourceInbound";




            if (tasktype == "TaskType_OutsourceInbound")


                TargetLocation = StationTask.GetEmptyLocation(stationinfoRepository);


            else if (tasktype == "TaskType_Inbound")


                TargetLocation = StationTask.GetEmptyLocation(stationinfoRepository, mes_Head, stationinfo, CompeletedNum, e);


                TargetLocation = GetLocation.GetEmptyLocation(stationinfoRepository, Work, stationinfo);


            //TargetLocation = GetLocation.GetEmptyLocation(stationinfoRepository, mes_Head, stationinfo);


            if (TargetLocation != null)


            {


                dt_agvtask agvtask = new dt_agvtask()


@@ -911,8 +976,8 @@


                    agv_toaddress = TargetLocation.stationCode,


                    agv_userid = "系统",


                    bindSN = stationinfo.bindSN,


                    agv_worktype = Convert.ToInt32(mes_Head.processCode),


                    agv_materbarcode = mes_Head.materialCode,


                    agv_worktype = Convert.ToInt32(Work.processCode),


                    agv_materbarcode = Work.materialCode,


                    agv_Traytype = stationinfo.tray_type,


                    jobID = stationinfo.Number,


                    agv_TrayStatus = stationinfo.tray_status


@@ -922,6 +987,8 @@


                stationinfoRepository.Update(stationinfo, true);


                TargetLocation.location_state = LocationStateEnum.InBusy.ToString();


                TargetLocation.stationType = agvtask.agv_materielid;


                TargetLocation.heatNumber = stationinfo.heatNumber;


                TargetLocation.Number = agvtask.jobID;


                stationinfoRepository.Update(TargetLocation, true);


            }


        }