using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WIDESEA_Comm; using WIDESEA_Comm.LogInfo; using WIDESEA_Core.EFDbContext; using WIDESEA_Entity.DomainModels; using WIDESEA_WCS.IRepositories; 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.JobsPart.Common { public class GetStation { /// /// 当前库位同一行是否存在入库占用 /// true:是 false:否 /// /// /// public static bool InBusyStation(string StationCode) { bool OK = false; try { VOLContext Context = new VOLContext(); Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); var station = stationinfoRepository.Find(x => x.stationCode == StationCode).FirstOrDefault(); OK = stationinfoRepository.Find(x => x.area == station.area && x.line == station.line && x.location_state == LocationStateEnum.InBusy.ToString()).Any(); } catch (Exception ex) { } return OK; } /// /// 当前库位同一行是否存在出库占用 /// true:是 false:否 /// /// /// public static bool OutBusyStation(string StationCode) { bool OK = false; try { VOLContext Context = new VOLContext(); Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); var station = stationinfoRepository.Find(x => x.stationCode == StationCode).FirstOrDefault(); OK = stationinfoRepository.Find(x => x.area == station.area && x.line == station.line && x.location_state == LocationStateEnum.OutBusy.ToString()).Any(); } catch (Exception ex) { } return OK; } /// /// 当前库位外边的货位是否都为空 /// true:否 false:是 /// /// /// public static bool QueueStation(string StationCode) { bool OK = false; try { VOLContext Context = new VOLContext(); Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); var station = stationinfoRepository.Find(x => x.stationCode == StationCode).FirstOrDefault(); if (station.area == "10" || station.area == "11") { OK = stationinfoRepository.Find(x => x.area == station.area && x.line == station.line && x.column < station.column && x.location_state != LocationStateEnum.Empty.ToString()).Any(); } else { OK = stationinfoRepository.Find(x => x.area == station.area && x.line == station.line && x.column > station.column && x.location_state != LocationStateEnum.Empty.ToString()).Any(); } } catch (Exception ex) { } return OK; } /// /// 找可入库空托位 /// public static void EmptyStation() { try { VOLContext Context = new VOLContext(); Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); Idt_agvtaskRepository agvtaskService = new dt_agvtaskRepository(Context); var Stations = stationinfoRepository.Find(x => x.stationCode.Contains("DD") && x.quantity == 5 && x.enable).ToList(); foreach (var Station in Stations) { var area = Station.tray_type == "SmallTray" ? "11" : "10"; } } catch (Exception ex) { } } /// /// 获取空托盘货位 /// /// public static void EmptyPalletStation(dt_agvtask task) { dt_stationinfo EmptyStation = null; try { VOLContext Context = new VOLContext(); Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); Idt_agvtaskRepository agvtaskService = new dt_agvtaskRepository(Context); var Pipeline_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "链条机"); if (Pipeline_client == null) throw new Exception("链条机调度服务未开启!"); if (!Pipeline_client.IsConnected) throw new Exception("与链条机连接超时!"); var area = task.agv_Traytype == "SmallTray" ? "11" : "10"; #region 查找AB库区可出库空托货位 if (area == "11") { EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && (x.area == "2" || x.area == "3") && x.tray_status == TrayStateEnum.EmptyTray.ToString() && x.enable).OrderBy(x => x.area).ThenBy(x => x.line).ThenByDescending(x => x.column).FirstOrDefault(); #region 必须出完AB库空托才能出空托区 //if (EmptyStation != null) // if (QueueStation(EmptyStation.stationCode) || stationinfoRepository.Find(x => x.line == EmptyStation.line && x.area == EmptyStation.area && x.location_state.Contains("Busy")).Any()) return; #endregion #region AB库空托位占用出空托区 if (EmptyStation != null) if (QueueStation(EmptyStation.stationCode) || stationinfoRepository.Find(x => x.line == EmptyStation.line && x.area == EmptyStation.area && x.location_state.Contains("Busy")).Any()) EmptyStation = null; #endregion } #endregion #region 查找空托库区 if (EmptyStation == null) EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.area == area && x.tray_status == TrayStateEnum.EmptyTray.ToString() && x.enable).OrderBy(x => x.column).FirstOrDefault(); #endregion #region 空托货位不为空判断是否存在其他任务 if (EmptyStation != null) if (QueueStation(EmptyStation.stationCode) || stationinfoRepository.Find(x => x.line == EmptyStation.line && x.area == EmptyStation.area && x.location_state.Contains("Busy")).Any()) EmptyStation = null; #endregion #region 更新补空托队列任务 if (EmptyStation != null) { var PalletSignal = Pipeline_client.ReadByOrder("R_PalletSignal", task.agv_toaddress);//读取托盘信号:1:有,2无 var MaterialSignal = Pipeline_client.ReadByOrder("R_MaterialSignal", task.agv_toaddress);//读取货物信号:1:有,2无 if (PalletSignal == 2 && MaterialSignal == 2) { task.agv_fromaddress = EmptyStation.stationCode; task.StarQuantity = EmptyStation.quantity - 1; task.agv_taskstate = "Create"; agvtaskService.Update(task, true); EmptyStation.location_state = LocationStateEnum.Busy.ToString(); stationinfoRepository.Update(EmptyStation, true); WriteDBLog.Success("更新空盘队列任务", $"任务编号:{task.agv_tasknum}", "PCS"); } } #endregion } catch (Exception ex) { throw; } } public static dt_stationinfo Station(dt_stationinfo EmptyStation, Idt_stationinfoRepository stationinfoRepository) { dt_stationinfo stationinfo = null; try { if (stationinfoRepository.Find(x => x.area == EmptyStation.area && x.line == EmptyStation.line && x.location_state.Contains("Busy")).Any()) return stationinfo; stationinfo = stationinfoRepository.Find(x => x.area == EmptyStation.area && x.line == EmptyStation.line && x.quantity > 0 && x.enable).OrderByDescending(x => x.column).FirstOrDefault(); if (stationinfo != null) { if (stationinfo.quantity < 5) return stationinfo; else stationinfo = stationinfoRepository.Find(x => x.area == EmptyStation.area && x.line == EmptyStation.line && x.location_state == LocationStateEnum.Empty.ToString() && x.enable).OrderBy(x => x.column).FirstOrDefault(); } else { stationinfo = stationinfoRepository.Find(x => x.area == EmptyStation.area && x.line == EmptyStation.line && x.location_state == LocationStateEnum.Empty.ToString() && x.enable).OrderBy(x => x.column).FirstOrDefault(); } //if (stationinfo == null) } catch (Exception ex) { } return stationinfo; } /// /// 空托可入库货位 /// /// /// public static dt_stationinfo EmptyPalletStation(string area) { dt_stationinfo stationinfo = null; try { VOLContext Context = new VOLContext(); Idt_agvtaskRepository agvtaskService = new dt_agvtaskRepository(Context); Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); #region 查找空托盘库区 //if (stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Busy.ToString()).Any() && area != "10") if (stationinfoRepository.Find(x => x.stationCode == "A01001001" && x.quantity == 5 && x.location_state == LocationStateEnum.Stroge.ToString()).Any()) { var EmptyStation = stationinfoRepository.Find(x => x.stationCode == "C01005002" && x.location_state == LocationStateEnum.Empty.ToString()).FirstOrDefault(); if (EmptyStation != null) { if (!stationinfoRepository.Find(x => x.line == EmptyStation.line && x.area == EmptyStation.area && x.location_state != LocationStateEnum.Empty.ToString()).Any()) return EmptyStation; } EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01005002" && x.location_state == "Stroge" && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault(); if (EmptyStation != null) stationinfo = Station(EmptyStation, stationinfoRepository); if (stationinfo != null) return stationinfo; EmptyStation = stationinfoRepository.Find(x => x.area == EmptyStation.area && x.line == EmptyStation.line && x.enable).OrderByDescending(x => x.column).FirstOrDefault(); if (EmptyStation.quantity == 5) { EmptyStation = stationinfoRepository.Find(x => x.stationCode == "C01004002" && x.location_state == LocationStateEnum.Empty.ToString()).FirstOrDefault(); if (EmptyStation != null) { if (!stationinfoRepository.Find(x => x.line == EmptyStation.line && x.area == EmptyStation.area && x.location_state != LocationStateEnum.Empty.ToString()).Any()) return EmptyStation; } EmptyStation = stationinfoRepository.Find(x => x.quantity > 0 && x.stationCode == "C01004002" && x.location_state == "Stroge" && x.tray_status == "EmptyTray" && x.enable).FirstOrDefault(); if (EmptyStation != null) stationinfo = Station(EmptyStation, stationinfoRepository); } } else { if (stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Busy.ToString()).Any()) return stationinfo; stationinfo = stationinfoRepository.Find(x => x.area == area && x.quantity > 0 && x.enable).OrderBy(x => x.column).FirstOrDefault(); if (stationinfo != null) if (stationinfo.quantity < 5) return stationinfo; stationinfo = stationinfoRepository.Find(x => x.area == area && x.location_state == LocationStateEnum.Empty.ToString() && x.enable).OrderByDescending(x => x.column).FirstOrDefault(); } #endregion } catch (Exception ex) { throw; } return stationinfo; } } }