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


@@ -18,6 +18,7 @@


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;


@@ -77,13 +78,13 @@






                ///查找上料区的货位


                var Stations = stationinfoRepository.Find(x => x.area == area_code(number));


                var Stations = stationinfoRepository.Find(x => x.area == area_code(number)).OrderBy(x => x.lastUpdateTime);//根据时间先后排序


                //缓存架未启用禁止桁架进入


                foreach (var station in Stations)


                {


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


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


                }


                //foreach (var station in Stations)


                //{


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


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


                //}




                var Station = Stations?.Where(x => x.enable && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity > 0).OrderBy(x => x.quantity).FirstOrDefault();


                if (Station != null)


@@ -111,20 +112,25 @@


                    var details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == Station.stationCode).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无




                    var AreaNr = Gantry_client.ReadByOrder<Int16>("W_AreaNr", number);//读取货位号信息


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


                    {


                        var area = Convert.ToInt16(Station.stationCode.Substring(Station.stationCode.Length - 1, 1));


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


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


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


                        Gantry_client.WriteByOrder("W_Wheel_Type", (Int16)Convert.ToInt16(QueryMateriel(Station.stationType) == null ? QueryMateriel1(Station.stationType).TypeId : QueryMateriel(Station.stationType).TypeId), number);//车轮类型


                        Gantry_client.WriteByOrder("W_Wheel_id", SNS[SNS.Length - 1], number);//车轮SN号


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


                        #region æ—¥å¿—记录


                        WriteDBLog.Success("上料区申请", $"读取托盘光电信号：{PalletSignal}\n读取第一个车轮光电信号：{MaterialSignal}\n\n" +


                            $"写入桁架信息：\n区域货位号：{area}\n托盘上的第几个车轮：{SNS.Length}\n托盘类型：{1}\n车轮类型：{(QueryMateriel(Station.stationType).TypeId == null ? QueryMateriel1(Station.stationType).TypeId : QueryMateriel(Station.stationType).TypeId)}" +


                            $"\n车轮SN号：{SNS[SNS.Length - 1]}\nW_RequestUnload：true", "PCS");


                        #endregion


                        if (AreaNr == 0)


                        {


                            var area = Convert.ToInt16(Station.stationCode.Substring(Station.stationCode.Length - 1, 1));


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


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


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


                            Gantry_client.WriteByOrder("W_Wheel_Type", (Int16)Convert.ToInt16(QueryMateriel(Station.stationType) == null ? QueryMateriel1(Station.stationType).TypeId : QueryMateriel(Station.stationType).TypeId), number);//车轮类型


                            Gantry_client.WriteByOrder("W_Wheel_id", SNS[SNS.Length - 1], number);//车轮SN号


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


                            #region æ—¥å¿—记录


                            WriteDBLog.Success("上料区申请", $"读取托盘光电信号：{PalletSignal}\n读取第一个车轮光电信号：{MaterialSignal}\n\n" +


                                $"写入桁架信息：\n区域货位号：{area}\n托盘上的第几个车轮：{SNS.Length}\n托盘类型：{1}\n车轮类型：{(QueryMateriel(Station.stationType).TypeId == null ? QueryMateriel1(Station.stationType).TypeId : QueryMateriel(Station.stationType).TypeId)}" +


                                $"\n车轮SN号：{SNS[SNS.Length - 1]}\nW_RequestUnload：true", "PCS");


                            #endregion


                        }


                    }


                    else


                    {


@@ -140,10 +146,10 @@


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


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


                        {


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


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


                            Station.remark = $"未查询到SN号：{SNS[SNS.Length - 1]}的订单";


                            stationinfoRepository.Update(Station, true);


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


                            //throw new Exception($"未查询到SN号：{SNS[SNS.Length - 1]}的订单，上料位编号：{Station.stationCode}");


                            WriteDBLog.Error("上料区信息查询", $"写入桁架信息：\nW_RequestUnload：false\n\n{Station.stationCode}未查询到SN号：{SNS[SNS.Length - 1]}的订单", "PCS");


                            return;


@@ -174,20 +180,39 @@


                            //throw new Exception($"上料位信息更新失败！上料位编号：{Station.stationCode}");


                            return;


                        }




                        #region æ¸…空信息


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


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


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


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


                        //Gantry_client.WriteByOrder("W_Wheel_id", SNS[SNS.Length - 1], number);//车轮SN号


                        #endregion




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


                        #region æ—¥å¿—记录


                        WriteDBLog.Success("取料完成", $"写入桁架信息：\n货位状态更新：{true}\nW_RequestUnload：{false}", "PCS");


                        #endregion


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


                        //while (finished)


                        //{


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


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


                        //}


                    }


                    //else if (!finished && updatefinished)


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




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


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


                        if (Station.quantity > 0 && (PalletSignal != 1 || MaterialSignal != 1))


                        {


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


                            Station.remark = "车轮数量大于0，光电检测无托盘或无车轮";


                            stationinfoRepository.Update(Station, true);


                            client.WriteByOrder("W_AlarmSignal", (Int16)2, number);//报警


                            WriteDBLog.Error(number + "报警", $"货位编号：{Station.stationCode}；错误信息：{Station.remark}", "PCS");


                        }


                        else if (Station.quantity < 1 && MaterialSignal == 1)


                        {


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


                            Station.remark = "车轮数量小于0，光电检测有车轮";


                            stationinfoRepository.Update(Station, true);


                            client.WriteByOrder("W_AlarmSignal", (Int16)2, number);//报警


                            WriteDBLog.Error(number + "报警", $"货位编号：{Station.stationCode}；错误信息：{Station.remark}", "PCS");


                        }


                    }


                }


                else


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


@@ -220,32 +245,53 @@


                    var details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == stationCode).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无


                    var station = stationinfoRepository.Find(x => x.stationCode == stationCode).FirstOrDefault();


                    var station = stationinfoRepository.Find(x => x.stationCode == stationCode && x.enable).FirstOrDefault();


                    if (station == null) continue;


                    if (PalletSignal == 1 && MaterialSignal == 2 && (station.stationCode.Contains("S0100100") ? station.tray_status == "EmptyTray" : true))


                    {


                        var area = station.tray_type == "SmallTray" ? "11" : "10";


                        var task = agvtaskService.Find(x => (x.agv_toaddress.Contains("W") || x.agv_toaddress.Contains("X")) && x.agv_taskstate == "Queue" /*&& x.agv_tasktype == "TaskType_EmptyPallet" */ && x.agv_Traytype == station.tray_type).OrderBy(x => x.agv_createtime).FirstOrDefault();


                        var task = agvtaskService.Find(x => (x.agv_toaddress.Contains("W") || x.agv_toaddress.Contains("X")) && x.agv_taskstate == "Queue" /*&& x.agv_tasktype == "TaskType_EmptyPallet" */ && x.agv_Traytype == station.tray_type).OrderByDescending(x => x.agv_grade).ThenBy(x => x.agv_createtime).FirstOrDefault();


                        if (task != null)


                        {


                            task.agv_fromaddress = station.stationCode;


                            task.StarQuantity = 0;


                            task.agv_taskstate = "Create";


                            if (station.stationCode.Contains("S0100100"))


                                task.agv_grade = 3;


                            agvtaskService.Update(task, true);


                            station.location_state = LocationStateEnum.Busy.ToString();


                            stationinfoRepository.Update(station, true);


                            continue;




                        }


                        var EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains("A") && x.location_state != LocationStateEnum.Busy.ToString() && x.enable)


                        .OrderByDescending(x => x.line).OrderBy(x => x.column).FirstOrDefault();


                        if (EmptyStation == null)


                        {


                            EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == LocationStateEnum.Busy.ToString() && x.enable).OrderByDescending(x => x.column).FirstOrDefault();//最后一个货位有任务则不能生成入库任务


                            if (EmptyStation != null) continue;


                            EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == LocationStateEnum.Stroge.ToString() && x.enable).OrderByDescending(x => x.column).FirstOrDefault();//找最外面没堆满5个的货位


                            if (EmptyStation == null)


                                EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == LocationStateEnum.Empty.ToString() && x.enable).OrderBy(x => x.column).FirstOrDefault();


                        }


                        var EmptyStation = GetStation.EmptyPalletStation(area);




                        #region æŸ¥æ‰¾åº“区一空托盘空货位


                       // EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains("A") && x.location_state != LocationStateEnum.Busy.ToString() && x.enable)


                       //.OrderBy(x => x.column).ThenByDescending(x => x.line).FirstOrDefault();//查找没有任务的空托盘货位




                       // if (EmptyStation != null)


                       // {


                       //     if (stationinfoRepository.Find(x => x.area == EmptyStation.area && x.stationCode.Contains("A") && x.column == EmptyStation.column && x.location_state.Contains("Busy")).Any())


                       //     {


                       //         EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains("A") && x.column != EmptyStation.column && x.location_state != LocationStateEnum.Busy.ToString() && x.enable).OrderBy(x => x.column).ThenByDescending(x => x.line).FirstOrDefault();//排除当列存在任务的货位


                       //     }


                       //     if (EmptyStation != null && EmptyStation.line == 2)//如果任务存在第二行,排查第一行是否有货


                       //     {


                       //         if (stationinfoRepository.Find(x => x.area == EmptyStation.area && x.stationCode.Contains("A") && x.column == EmptyStation.column && x.line == 1 && x.location_state != LocationStateEnum.Empty.ToString()).Any()) EmptyStation = null;


                       //     }


                       // }




                       // if (EmptyStation == null)


                       // {


                       //     EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == LocationStateEnum.Busy.ToString() && x.enable).OrderByDescending(x => x.column).FirstOrDefault();//最后一个货位有任务则不能生成入库任务


                       //     if (EmptyStation != null) continue;


                       //     EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == LocationStateEnum.Stroge.ToString() && x.enable).OrderByDescending(x => x.column).FirstOrDefault();//找最外面没堆满5个的货位


                       //     if (EmptyStation == null)


                       //         EmptyStation = stationinfoRepository.Find(x => x.area == area && x.quantity < 5 && x.stationCode.Contains(area == "10" ? "D" : "C") && x.location_state == LocationStateEnum.Empty.ToString() && x.enable).OrderBy(x => x.column).FirstOrDefault();


                       // }




                        #endregion




                        if (EmptyStation != null)


                        {


@@ -258,7 +304,7 @@


                                agv_fromaddress = station.stationCode,


                                agv_id = Guid.NewGuid(),


                                agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"),


                                agv_grade = 1,


                                agv_grade = station.stationCode.Contains("S0100100") ? 3 : 1,


                                agv_createtime = DateTime.Now,


                                agv_taskstate = "Create",


                                //agv_materielid = station.stationType,


@@ -296,7 +342,7 @@


        {


            try


            {


                List<string> names = new List<string>() { "1单元下料区", "2单元下料区", "3单元下料区", "上料区" };


                List<string> names = new List<string>() { "1单元下料区", "2单元下料区", "3单元下料区" };/*, "上料区"*/


                foreach (var name in names)


                {


                    VOLContext Context = new VOLContext();


@@ -312,6 +358,7 @@


                            Station.remark = "车轮数量大于0，光电检测无托盘或无车轮";


                            stationinfoRepository.Update(Station, true);


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


                            WriteDBLog.Error(name + "报警", $"货位编号：{Station.stationCode}；错误信息：{Station.remark}", "PCS");


                            continue;


                        }


                        if (Station.location_state == LocationStateEnum.Stroge.ToString() && PalletSignal != 1)


@@ -320,6 +367,7 @@


                            Station.remark = "货位有货，光电检测无托盘";


                            stationinfoRepository.Update(Station, true);


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


                            WriteDBLog.Error(name + "报警", $"货位编号：{Station.stationCode}；错误信息：{Station.remark}", "PCS");


                            continue;


                        }


                        if (Station.location_state == LocationStateEnum.Empty.ToString() && (PalletSignal == 1 || MaterialSignal == 1))//系统货位为空，光电检测有料


@@ -328,6 +376,7 @@


                            Station.remark = "货位无货，光电检测有料";


                            stationinfoRepository.Update(Station, true);


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


                            WriteDBLog.Error(name + "报警", $"货位编号：{Station.stationCode}；错误信息：{Station.remark}", "PCS");


                            continue;


                        }


                        //if (Station.quantity < 1 && MaterialSignal == 1)//系统货位无车轮，光电检测有车轮


@@ -392,8 +441,10 @@


            VOLContext Context = new VOLContext();


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


            //var mes_Detail = freeDB.Select<dt_mes_detail>().Where(x => x.SN == SN).First();


            var mes_Detail = mes_DetailRepository.Find(x => x.SN == SN).FirstOrDefault();


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


            var mes_Detail = mes_DetailRepository.Find(x => x.SN == SN && x.jobID == Mes_Work.jobID).FirstOrDefault();


            if (mes_Detail != null)


            {


                mes_Detail.Status = "上线";