分支自 SuZhouGuanHong/TaiYuanTaiZhong
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
dengjunjie
2024-04-27 0b5ccdca6263cf7a2cee460f30c76ef1efea2811 
 ´úÂë¹ÜÀí/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,7 @@






                ///查找上料区的货位


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


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


                foreach (var station in Stations)


                {


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


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


                }


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




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


                if (Station != null)


@@ -106,25 +101,29 @@


                        WriteDBLog.Error("上料区", $"写入桁架信息：\nW_RequestUnload：false\n\n{Station.stationCode}车轮数量与SN号数量不一致", "PCS");


                        #endregion


                        return;


                        //throw new Exception("上料位车轮数量与SN号数量不一致，上料位编号：" + Station.stationCode);


                    }


                    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)


                        {


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


                            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_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,11 +139,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;


                        }


@@ -162,7 +160,6 @@


                        if (Station.quantity <= 0)


                        {


                            Station.stationType = string.Empty;


                            //Station.location_state = LocationStateEnum.Empty.ToString();


                            Station.Number = string.Empty;


                            Station.heatNumber = string.Empty;


                            Station.tray_status = "EmptyTray";


@@ -171,23 +168,40 @@


                        if (count < 1)


                        {


                            WriteDBLog.Error("取料完成", $"上料位信息更新失败！上料位编号：{Station.stationCode}", "PCS");


                            //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);//车轮类型


                        #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桁架停止进入


@@ -195,7 +209,6 @@


            catch (Exception ex)


            {


                WriteDBLog.Error("上料区", $"错误信息：{ex.Message}", "PCS");


                //WritePCSLog.LogAdd(requestin.AreaNr.ToString(), respone.success == 1 ? "成功 " : "失败", "WMS", "AGV", json, JsonConvert.SerializeObject(respone), remark, "检测线上料区", ex.Message);


            }


        }


        /// <summary>


@@ -215,37 +228,41 @@


                List<string> stationCodes = new List<string>() { "S01001001", "S01001002", "W01001001", "W01001002", "W01001003" };


                foreach (var stationCode in stationCodes)


                {


                    if (agvtaskService.Find(x => x.agv_fromaddress == stationCode || x.agv_toaddress == stationCode).Any())


                    if (agvtaskService.Find(x => x.agv_fromaddress == stationCode /*|| x.agv_toaddress == stationCode*/).Any())


                        continue;


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


                    if (station == null) continue;


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


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




                        #region ç©ºæ‰˜å ç›˜


                        var EmptyStations = stationinfoRepository.Find(x => x.stationCode.Contains("DD") && x.quantity < 5 && x.enable).ToList();


                        var EmptyStation = EmptyStations.Where(x => x.tray_type == station.tray_type && x.location_state == LocationStateEnum.Stroge.ToString()).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();


                        }


                            EmptyStation = EmptyStations.Where(x => x.location_state == LocationStateEnum.Empty.ToString()).FirstOrDefault();


                        #endregion




                        if (EmptyStation == null)//查找库内空托盘


                            EmptyStation = GetStation.EmptyPalletStation(area);






                        if (EmptyStation != null)


                        {


@@ -258,7 +275,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 +313,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,22 +329,25 @@


                            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)


                        {


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


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


                            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))//系统货位为空，光电检测有料


                        {


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


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


                            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 +412,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 = "上线";