机械臂cs.cs 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710
  1. using Newtonsoft.Json;
  2. using PlcSiemens.Core.Extension;
  3. using ServiceCenter.Extensions;
  4. using ServiceCenter.Logs;
  5. using ServiceCenter.SqlSugars;
  6. using SqlSugar;
  7. using System.ComponentModel;
  8. using WCS.Core;
  9. using WCS.Entity;
  10. using WCS.Entity.Protocol.Protocol.Robot;
  11. using WCS.Entity.Protocol.Robot;
  12. using WCS.Entity.Protocol.Station;
  13. using WCS.WorkEngineering.Extensions;
  14. using WCS.WorkEngineering.Model.WMS;
  15. using WCS.WorkEngineering.Worlds.环形库.环形库;
  16. using DeviceFlags = WCS.WorkEngineering.Extensions.DeviceFlags;
  17. using TaskStatus = WCS.Entity.TaskStatus;
  18. namespace WCS.WorkEngineering.Systems
  19. {
  20. /// <summary>
  21. /// 机械臂
  22. /// </summary>
  23. [BelongTo(typeof(RingWorld1))]
  24. [Description("机械臂")]
  25. public class 机械臂 : DeviceSystem<Device<IRobot520, IRobot521, IRobot522>>
  26. {
  27. protected override bool ParallelDo => true;
  28. /// <summary>
  29. /// 取货点设备集合
  30. /// </summary>
  31. private Dictionary<string, List<Device>> PickUpDevices = new();
  32. /// <summary>
  33. /// 放货设备
  34. /// </summary>
  35. private Dictionary<string, List<Device<IStation520, IStation521, IStation523, IRobot530>>> PutDevices = new();
  36. public 机械臂()
  37. {
  38. //获取所有的机械臂 集合
  39. var devices = Device.All.Where(v => v.HasFlag(DeviceFlags.Robot));
  40. //开始分配
  41. foreach (var robot in devices)
  42. {
  43. //取货设备
  44. PickUpDevices.Add(robot.Code, robot.Sources.Where(v => v.HasFlag(DeviceFlags.输送机)).Select(v => v).ToList());
  45. PutDevices.Add(robot.Code, robot.Targets.Where(v => v.HasFlag(DeviceFlags.输送机)).Select(v => new Device<IStation520, IStation521, IStation523, IRobot530>(v, World)).ToList());
  46. }
  47. }
  48. public override void Do(Device<IRobot520, IRobot521, IRobot522> obj)
  49. {
  50. #region 处理完成任务
  51. //判断DB520 完成任务确认清除信号 是否为1
  52. if (obj.Data.OkAck == 1 && obj.Data2 is { TaskFinishId1: 0, TaskFinishId2: 0 }) obj.Data.OkAck = 0;
  53. if (obj.Data2.TaskFinishId1 > 0 || obj.Data2.TaskFinishId2 > 0)
  54. {
  55. //处理完成的任务信息
  56. var tasks = new List<WCS_TaskInfo>();
  57. //开始处理
  58. SqlSugarHelper.Do(db =>
  59. {
  60. World.Log($"机械臂任务处理:开始--完成任务{obj.Data2.TaskFinishId1}--{obj.Data2.TaskFinishId2}", LogLevelEnum.Low);
  61. var isDP = obj.Entity.GetIsDirectPalletizing(db.Default);
  62. //根据DB521任务号获取对应任务
  63. var taskInfoList = db.Default.Queryable<WCS_TaskInfo>().Where(v => v.ID == obj.Data2.TaskFinishId1 || v.ID == obj.Data2.TaskFinishId2).ToList();
  64. foreach (var task in taskInfoList.Where(task => task.Status == Entity.TaskStatus.StackerExecution))
  65. {
  66. //根据任务类型做不同的处理
  67. switch (task.Type)
  68. {
  69. case TaskType.SetPlate: //工字轮入库
  70. if (isDP)
  71. {
  72. //完成任务
  73. task.Status = Entity.TaskStatus.ConveyorExecution;
  74. task.EndTime = DateTime.Now;
  75. db.Default.UpdateableRowLock(task).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
  76. task.AddWCS_TASK_DTL(db.Default, task.AddrTo, "直接码垛任务完成码垛");
  77. }
  78. else
  79. {
  80. //完成任务
  81. task.Status = Entity.TaskStatus.Finish;
  82. task.EndTime = DateTime.Now;
  83. db.Default.UpdateableRowLock(task).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
  84. task.AddWCS_TASK_DTL(db.Default, task.AddrTo, "入库任务结束");
  85. }
  86. break;
  87. case TaskType.OutDepot:
  88. //var pall = db.Default.Queryable<WCS_TaskInfo>().Where(x => x.AddrTo == task.AddrTo && x.Type == TaskType.Delivery && x.Status < TaskStatus.Finish).First() ?? throw new Exception($"未找到对应的托盘搬运任务,无法进行绑盘");
  89. task.Status = Entity.TaskStatus.StackerCompleted;
  90. task.EditTime = DateTime.Now;
  91. db.Default.UpdateableRowLock(task).UpdateColumns(x => new { x.Status, x.EditTime }).ExecuteCommand();
  92. task.AddWCS_TASK_DTL(db.Default, task.AddrTo, "出库任务结束");
  93. break;
  94. case TaskType.TransferDepot:
  95. task.Status = Entity.TaskStatus.Finish;
  96. task.EndTime = DateTime.Now;
  97. db.Default.UpdateableRowLock(task).UpdateColumns(x => new { x.Status, x.EndTime }).ExecuteCommand();
  98. task.AddWCS_TASK_DTL(db.Default, task.AddrTo, "移库任务结束");
  99. break;
  100. }
  101. tasks.Add(task);
  102. }
  103. });
  104. if (!tasks.Any()) throw new KnownException("数据库提交事务错误", LogLevelEnum.High);
  105. // 写入信号
  106. obj.Data.OkAck = 1;
  107. World.Log($"机械臂任务处理:结束--完成任务{obj.Data2.TaskFinishId1}--{obj.Data2.TaskFinishId2}", LogLevelEnum.Mid);
  108. }
  109. #endregion 处理完成任务
  110. //robot是否可以下发任务
  111. if (obj.Data2.VoucherNo != obj.Data.VoucherNo)
  112. {
  113. World.Log($"凭证号不一致,DB520:{obj.Data.VoucherNo},DB521:{obj.Data2.VoucherNo}", LogLevelEnum.Mid);
  114. return;
  115. }
  116. if (obj.Data2.RobotMode != RobotMode.Automatic)
  117. {
  118. World.Log($"robot处于{obj.Data2.RobotMode.GetDescription()}模式", LogLevelEnum.Mid);
  119. return;
  120. }
  121. if (obj.Data2.RunStatus != RobotRunStatus.Idle)
  122. {
  123. World.Log($"robot处于{obj.Data2.RunStatus.GetDescription()}状态", LogLevelEnum.Mid);
  124. return;
  125. }
  126. //判断是否有任务是机器人执行中
  127. //再检查是否有等待执行的货物
  128. var inMaxQuantity = 0; //出入库的周期检查比为1:3
  129. var taskss = new List<WCS_TaskInfo>();
  130. var isDP = false; //当前机械臂是否直接码垛
  131. SqlSugarHelper.Do(db =>
  132. {
  133. isDP = obj.Entity.GetIsDirectPalletizing(db.Default);
  134. var code = $"RobotMaxConsecutiveStorageCount{obj.Entity.Code.Last()}";
  135. inMaxQuantity = db.Default.Queryable<fjSysConfig>().First(x => x.Code == code).SContent.ToInt();
  136. //获取当前堆垛机的所有未完成任务 ,就算查到了未提交的事务也无所谓,无非下一个周期再执行一次
  137. taskss = db.Default.Queryable<WCS_TaskInfo>().NoLock().Where(v => v.Status < Entity.TaskStatus.Finish && v.Device == obj.Entity.Code).ToList();
  138. //任务集合是否有处于堆垛机执行状态的任务
  139. if (taskss.Any(v => v.Status == Entity.TaskStatus.StackerExecution)) throw new KnownException($"有任务处于堆垛机执行状态", LogLevelEnum.High);
  140. });
  141. if (isDP) //直接码垛
  142. {
  143. }
  144. else
  145. {
  146. //获取入库次数
  147. var inQuantity = obj.Entity.GetFlag<int>("InQuantity");
  148. //入库任务优先 或 上一个周期是出库任务并且出库任务无优先
  149. if (inQuantity < inMaxQuantity) //入库任务
  150. {
  151. //判断本次优先执行楼层,并设置下次执行时优先楼层
  152. var floor = obj.Entity.GetFlag<int>("FloorIn");
  153. floor = floor % 2 + 1;
  154. obj.Entity.SetFlag("FloorIn", floor);
  155. obj.Entity.SetFlag("InQuantity", inQuantity + 1);
  156. //获取当前机械臂所有的取货站台
  157. var pickUpDevices = obj.Entity.Sources.Where(x => x.HasFlag(DeviceFlags.输送机)).Where(x => x.DeviceGroup.Any()).Select(
  158. x =>
  159. {
  160. var group = x.DeviceGroup.Select(s => new Device<IStation523, IStation524>(s, World)).ToList();
  161. return new Tuple<Device<IStation523, IStation524>, List<Device<IStation523, IStation524>>>(new Device<IStation523, IStation524>(x, World), group);
  162. }).ToList();
  163. if (!pickUpDevices.Any()) throw new KnownException($"机械臂{obj.Entity.Code}无取货路径点", LogLevelEnum.High);
  164. //获取取货设备的设备组中都是停止运行的
  165. var arrIn = pickUpDevices.Where(x => x.Item2.All(a => !a.Data.Status.HasFlag(StationStatus.Run)))
  166. .Where(x =>
  167. {
  168. var inStock = x.Item2.Any(a => a.Data2.TaskNumber > 0 && a.Data.Status.HasFlag(StationStatus.PH_Status));
  169. var minDevice = x.Item2.OrderBy(o => o.Entity.Code.ToShort()).First();
  170. return minDevice.Data2.TaskNumber > 0 && minDevice.Data.Status.HasFlag(StationStatus.PH_Status) && minDevice.Data2.CmdType.HasFlag(StationCmd.Res7) && inStock;
  171. }).ToList();
  172. //.OrderBy(x => x.Item1.Data2.TaskNumber)
  173. if (!arrIn.Any())
  174. {
  175. World.Log($"[{obj.Entity.Code}]等待入库任务输送到位");
  176. obj.Entity.SetFlag("InQuantity", inMaxQuantity + 100); //在无货物的情况下,只检查一次,下次直接查询是否有出库任务,避免无效检查周期的产生
  177. return;
  178. }
  179. //先按可取货位数量排序,再按任务号排序
  180. var devGroup = arrIn.OrderByDescending(x => x.Item2.Count(i => i.Data2.TaskNumber > 0 && i.Data.Status.HasFlag(StationStatus.PH_Status)))
  181. .ThenByDescending(x =>
  182. {
  183. int number;
  184. List<Device<IStation523, IStation524>> devices = new List<Device<IStation523, IStation524>>();
  185. var deviceCodes = GetDeviceCodeList(x.Item1.Entity.Code);
  186. devices = Device.All.Where(x => deviceCodes.Contains(x.Code)).Select(x => new Device<IStation523, IStation524>(x, World)).ToList();
  187. number = devices.Count(x => x.Data2.TaskNumber > 0 && x.Data.Status.HasFlag(StationStatus.PH_Status) && !x.Data.Status.HasFlag(StationStatus.Run));
  188. return number;
  189. }).First().Item2
  190. .Where(x => x.Data2.TaskNumber > 0 && x.Data.Status.HasFlag(StationStatus.PH_Status));
  191. //可用取货位数量为1,且出库任务有优先
  192. if (devGroup.Count() == 1 && (obj.Entity.GetFlag<bool>($"isOut-{obj.Entity.Code}") || taskss.Any(v => v.Device == obj.Entity.Code && v.Status == TaskStatus.WaitingToExecute && v.Type == TaskType.OutDepot)))
  193. {
  194. obj.Entity.SetFlag("InQuantity", inMaxQuantity + 100); //跳过入库任务执行出库任务,下次直接查询是否有出库任务,避免无效检查周期的产生
  195. return;
  196. }
  197. if (!devGroup.Any())
  198. {
  199. obj.Entity.SetFlag("InQuantity", inMaxQuantity + 100); //在无有效取货位的情况下,只检查一次,下次直接查询是否有出库任务,避免无效检查周期的产生
  200. throw new KnownException($"无有效入库取货位", LogLevelEnum.High);
  201. }
  202. //如果入库任务只有一个
  203. //等待下发的任务信息
  204. var taskList = new List<Tuple<WCS_TaskInfo, Device<IStation523, IStation524>>>();
  205. SqlSugarHelper.Do(db =>
  206. {
  207. foreach (var dev in devGroup)
  208. {
  209. var task = db.Default.Queryable<WCS_TaskInfo>().First(v => v.Type == TaskType.SetPlate && v.Status == Entity.TaskStatus.FinishOfShunt && dev.Data2.TaskNumber == v.ID);
  210. if (task == null) continue;
  211. task.Status = Entity.TaskStatus.StackerExecution;
  212. task.LastInteractionPoint = dev.Entity.Code;
  213. task.SrmStation = dev.Entity.Code;
  214. task.Device = obj.Entity.Code;
  215. task.EditWho = "WCS";
  216. db.Default.UpdateableRowLock(task).UpdateColumns(x => new { x.Status, x.AddrTo, x.Line, x.Col, x.Layer, x.Depth, x.LastInteractionPoint, x.SrmStation, x.Device, x.EditWho }).ExecuteCommand();
  217. task.AddWCS_TASK_DTL(db.Default, dev.Entity.Code, task.AddrTo, "任务下发机械臂执行");
  218. taskList.Add(new(task, dev));
  219. }
  220. });
  221. if (!taskList.Any()) return;
  222. switch (taskList.Count)
  223. {
  224. case 1:
  225. var task = taskList.FirstOrDefault().Item1;
  226. var dev = taskList.FirstOrDefault().Item2;
  227. //下发任务
  228. obj.Data.TaskNumber1 = task.ID;
  229. obj.Data.SLine1 = dev.Entity.Code.ToShort();
  230. obj.Data.SCol1 = 0;
  231. obj.Data.SLayer1 = 0;
  232. obj.Data.SDepth1 = 0;
  233. obj.Data.ELine1 = task.Line.ToShort();
  234. obj.Data.ECol1 = task.Col.ToShort();
  235. obj.Data.ELayer1 = task.Layer.ToShort();
  236. obj.Data.EDepth1 = task.Depth.ToShort();
  237. obj.Data.TaskNumber2 = 0;
  238. obj.Data.SLine2 = 0;
  239. obj.Data.SCol2 = 0;
  240. obj.Data.SLayer2 = 0;
  241. obj.Data.SDepth2 = 0;
  242. obj.Data.ELine2 = 0;
  243. obj.Data.ECol2 = 0;
  244. obj.Data.ELayer2 = 0;
  245. obj.Data.EDepth2 = 0;
  246. obj.Data.TaskSum = taskList.Count.ToShort();
  247. obj.Data.GoodsType = task.GoodsType switch
  248. {
  249. 18 => 1,
  250. 34 => 2,
  251. 50 => 3,
  252. _ => 0
  253. };
  254. obj.Data.TaskType = 3;
  255. obj.Data.VoucherNo++;
  256. break;
  257. case 2:
  258. taskList = taskList.OrderBy(x => x.Item1.Depth).ToList();
  259. //一工位取深度较大的任务
  260. var taskInfo = taskList[1];
  261. task = taskInfo.Item1;
  262. dev = taskInfo.Item2;
  263. obj.Data.TaskNumber1 = task.ID;
  264. obj.Data.SLine1 = dev.Entity.Code.ToShort();
  265. obj.Data.SCol1 = 0;
  266. obj.Data.SLayer1 = 0;
  267. obj.Data.SDepth1 = 0;
  268. obj.Data.ELine1 = task.Line.ToShort();
  269. obj.Data.ECol1 = task.Col.ToShort();
  270. obj.Data.ELayer1 = task.Layer.ToShort();
  271. obj.Data.EDepth1 = task.Depth.ToShort();
  272. //二工位取深度较少的值
  273. taskInfo = taskList[0];
  274. task = taskInfo.Item1;
  275. dev = taskInfo.Item2;
  276. obj.Data.TaskNumber2 = task.ID;
  277. obj.Data.SLine2 = dev.Entity.Code.ToShort();
  278. obj.Data.SCol2 = 0;
  279. obj.Data.SLayer2 = 0;
  280. obj.Data.SDepth2 = 0;
  281. obj.Data.ELine2 = task.Line.ToShort();
  282. obj.Data.ECol2 = task.Col.ToShort();
  283. obj.Data.ELayer2 = task.Layer.ToShort();
  284. obj.Data.EDepth2 = task.Depth.ToShort();
  285. obj.Data.TaskSum = taskList.Count.ToShort();
  286. obj.Data.GoodsType = task.GoodsType switch
  287. {
  288. 18 => 1,
  289. 34 => 2,
  290. 50 => 3,
  291. _ => 0
  292. };
  293. obj.Data.TaskType = 3;
  294. obj.Data.VoucherNo++;
  295. break;
  296. default:
  297. throw new KnownException($"无法执行多个任务", LogLevelEnum.Mid);
  298. }
  299. World.Log($"机械臂任务处理:下发入库任务{obj.Data.TaskNumber1}--{obj.Data.TaskNumber2}--{obj.Data.VoucherNo}", LogLevelEnum.Mid);
  300. }
  301. else //出库任务
  302. {
  303. //判断本次优先执行楼层,并设置下次执行时优先楼层
  304. var floor = obj.Entity.GetFlag<int>("FloorOut");
  305. floor = floor % 2 + 1;
  306. obj.Entity.SetFlag("FloorOut", floor);
  307. obj.Entity.SetFlag("InQuantity", 0);
  308. //获取当前堆垛机所有的取货站台
  309. var arrOut = PutDevices.First(v => v.Key == obj.Entity.Code).Value;
  310. if (!arrOut.Any()) throw new KnownException($"机械臂{obj.Entity.Code}无放货路径点", LogLevelEnum.High);
  311. //获取可以放货的设备集合
  312. arrOut = arrOut.Where(v => v.Data3.Status.HasFlag(StationStatus.PH_Status) && v.Data.TaskNumber == 0 && v.Data.GoodsEnd == 0).ToList();//有光电
  313. if (!arrOut.Any())
  314. {
  315. World.Log($"[{obj.Entity.Code}]等待出库任务输送到位");
  316. return;
  317. }
  318. var taskInfoList = new List<WCS_TaskInfo>();
  319. var nextAdd = "";
  320. SqlSugarHelper.Do(db =>
  321. {
  322. //所有出库点设备号,即
  323. var allOutCode = arrOut.Select(v => new
  324. {
  325. v.Entity.Code,
  326. v.Data4.Type
  327. }).ToList();
  328. //两个工位同时码垛,并不会一个执行一次,只有一个托盘任务全部执行完毕,才会继续执行下一个,先生成任务的码垛工位会优先执行
  329. var taskInfos = db.Default.Queryable<WCS_TaskInfo>().NoLock().Where(v =>
  330. (v.Status == TaskStatus.WaitingToExecute || v.Status == TaskStatus.ConveyorExecution) &&
  331. v.Type == TaskType.OutDepot && v.Device == obj.Entity.Code)
  332. .ToList().Where(v => allOutCode.Any(x => v.SrmStation == x.Code && v.PalletType == x.Type))
  333. .ToList();
  334. var deliveryTask = db.Default.Queryable<WCS_TaskInfo>().Where(x => x.Status > 0 && x.Type == TaskType.Delivery).ToList().Select(x => x.AddrTo);
  335. taskInfos = taskInfos.Where(x => deliveryTask.Contains(x.SrmStation)).ToList();
  336. if (!taskInfos.Any())
  337. {
  338. World.Log("等待空托盘到位");
  339. return;
  340. }
  341. if (!taskInfos.Any()) throw new KnownException($"未找到站台{JsonConvert.SerializeObject(allOutCode)}可用的出库任务", LogLevelEnum.Mid);
  342. var srmStation = taskInfos.GroupBy(x => x.SrmStation).Where(x => x.Any(s => s.Status == TaskStatus.WaitingToExecute)).Select(x => new
  343. {
  344. x.Key,
  345. x.OrderByDescending(t => t.AddTime).First().AddTime
  346. }).OrderBy(x => x.AddTime).First().Key;
  347. taskInfos = taskInfos.Where(x => x.SrmStation == srmStation).ToList(); //找到一个可以放货的待执行站台
  348. //如果全部是待执行状态,需要验证待执行的任务的数量是否与任务总数相等
  349. if (taskInfos.All(x => x.Status == TaskStatus.WaitingToExecute))
  350. {
  351. var task = taskInfos.First();
  352. if (task.FullQty != taskInfos.Count) throw new KnownException($"等待站台{srmStation}所有码垛出库任务完成初始化", LogLevelEnum.Mid);
  353. }
  354. taskInfos = taskInfos.Where(x => x.Status == TaskStatus.WaitingToExecute).OrderBy(x => x.ProdLine).ToList();
  355. if (taskInfos.FirstOrDefault().WarehouseCode.Contains("S")) //如果是南侧,翻转排序
  356. {
  357. taskInfos = taskInfos.OrderByDescending(x => x.ProdLine).ToList();
  358. }
  359. var surplusTaskNumber = taskInfos.Count; //剩余任务数量
  360. taskInfos = taskInfos.Take(2).ToList();
  361. var warehouseCode = taskInfos.FirstOrDefault().WarehouseCode;
  362. var exTaskNumber = taskInfos.Count;//执行任务数量
  363. surplusTaskNumber -= exTaskNumber;
  364. if (exTaskNumber == 2) //有两个任务
  365. {
  366. var minDepth = taskInfos!.MinBy(x => x.Depth);
  367. var maxDepth = taskInfos.MaxBy(x => x.Depth);
  368. //产品类型不同时,只能取一个
  369. if (minDepth.GoodsType != maxDepth.GoodsType)
  370. {
  371. //南边取位号较大的,北边取位号较小的
  372. taskInfos = warehouseCode.Contains("S") ? taskInfos.OrderByDescending(x => x.ProdLine).Take(1).ToList() : taskInfos.OrderBy(x => x.ProdLine).Take(1).ToList();
  373. }
  374. //深度之和等于6(机械臂当前无法同时执行两个三深度的取货任务)
  375. else if (taskInfos.Sum(x => x.Depth) == 6)
  376. {
  377. taskInfos = warehouseCode.Contains("S") ? taskInfos.OrderByDescending(x => x.ProdLine).Take(1).ToList() : taskInfos.OrderBy(x => x.ProdLine).Take(1).ToList();
  378. }
  379. else if (taskInfos[0].SrmStation != taskInfos[1].SrmStation)
  380. {
  381. taskInfos = warehouseCode.Contains("S") ? taskInfos.OrderByDescending(x => x.ProdLine).Take(1).ToList() : taskInfos.OrderBy(x => x.ProdLine).Take(1).ToList();
  382. }
  383. else if (warehouseCode.Contains("S"))
  384. {
  385. //从大到小 一抓偶数
  386. var max = taskInfos.MaxBy(x => x.ProdLine).ProdLine;
  387. if ((max & 1) == 1) //抓一不是偶数
  388. {
  389. taskInfos = taskInfos.OrderByDescending(x => x.ProdLine).Take(1).ToList();
  390. }
  391. }
  392. else if (warehouseCode.Contains("N"))
  393. {
  394. //从小到达 一抓奇数
  395. var mix = taskInfos.MinBy(x => x.ProdLine).ProdLine;
  396. if ((mix & 1) == 0) //抓一不是奇数
  397. {
  398. taskInfos = taskInfos.OrderBy(x => x.ProdLine).Take(1).ToList();
  399. }
  400. }
  401. }
  402. #region 计算剩余可执行任务数
  403. //如果有两个任务,且只有一个任务可以执行,剩余任务数+1
  404. if (exTaskNumber == 2 && taskInfoList.Count == 1) surplusTaskNumber += 1;
  405. if (surplusTaskNumber >= 1) obj.Entity.SetFlag($"isOut-{obj.Entity.Code}", true); //剩余任务数大于或等于1,下次满足条件时可以优先执行出库任务
  406. else obj.Entity.SetFlag($"isOut-{obj.Entity.Code}", false); //剩余任务数等于或小于0,下次满足条件时不可以优先执行出库任务
  407. #endregion 计算剩余可执行任务数
  408. foreach (var task in taskInfos)
  409. {
  410. task.Status = Entity.TaskStatus.StackerExecution;
  411. task.LastInteractionPoint = task.Device;
  412. task.StartTime = DateTime.Now;
  413. task.EditWho = "WCS";
  414. nextAdd = task.SrmStation;
  415. db.Default.UpdateableRowLock(task).UpdateColumns(x => new { x.Status, x.LastInteractionPoint, x.StartTime, x.EditWho }).ExecuteCommand();
  416. task.AddWCS_TASK_DTL(db.Default, task.Device, task.SrmStation, "任务下发机械臂执行");
  417. taskInfoList.Add(task);
  418. }
  419. });
  420. if (!taskInfoList.Any()) return;
  421. switch (taskInfoList.Count)
  422. {
  423. case 1:
  424. var task = taskInfoList.FirstOrDefault();
  425. //下发任务
  426. obj.Data.TaskNumber1 = task.ID;
  427. obj.Data.SLine1 = task.Line.ToShort();
  428. obj.Data.SCol1 = task.Col.ToShort();
  429. obj.Data.SLayer1 = task.Layer.ToShort();
  430. obj.Data.SDepth1 = task.Depth.ToShort();
  431. obj.Data.ELine1 = nextAdd.ToShort();
  432. obj.Data.ECol1 = task.ProdLine;
  433. obj.Data.ELayer1 = 0;
  434. obj.Data.EDepth1 = 0;
  435. obj.Data.TaskNumber2 = 0;
  436. obj.Data.SLine2 = 0;
  437. obj.Data.SCol2 = 0;
  438. obj.Data.SLayer2 = 0;
  439. obj.Data.SDepth2 = 0;
  440. obj.Data.ELine2 = 0;
  441. obj.Data.ECol2 = 0;
  442. obj.Data.ELayer2 = 0;
  443. obj.Data.EDepth2 = 0;
  444. obj.Data.TaskSum = taskInfoList.Count.ToShort();
  445. obj.Data.GoodsType = task.GoodsType switch
  446. {
  447. 18 => 1,
  448. 34 => 2,
  449. 50 => 3,
  450. _ => 0
  451. };
  452. obj.Data.TaskType = 4;
  453. obj.Data.VoucherNo++;
  454. break;
  455. case 2:
  456. taskInfoList = taskInfoList.OrderBy(x => x.Depth).ToList();
  457. //一工位取深度较大的任务
  458. var taskInfo = taskInfoList[1];
  459. obj.Data.TaskNumber1 = taskInfo.ID;
  460. obj.Data.SLine1 = taskInfo.Line.ToShort();
  461. obj.Data.SCol1 = taskInfo.Col.ToShort();
  462. obj.Data.SLayer1 = taskInfo.Layer.ToShort();
  463. obj.Data.SDepth1 = taskInfo.Depth.ToShort();
  464. obj.Data.ELine1 = nextAdd.ToShort();
  465. obj.Data.ECol1 = taskInfo.WarehouseCode.Contains("S") ? taskInfoList.Max(x => x.ProdLine) : taskInfoList.Min(x => x.ProdLine);
  466. obj.Data.ELayer1 = 0;
  467. obj.Data.EDepth1 = 0;
  468. //二工位取深度较少的值
  469. taskInfo = taskInfoList[0];
  470. obj.Data.TaskNumber2 = taskInfo.ID;
  471. obj.Data.SLine2 = taskInfo.Line.ToShort();
  472. obj.Data.SCol2 = taskInfo.Col.ToShort();
  473. obj.Data.SLayer2 = taskInfo.Layer.ToShort();
  474. obj.Data.SDepth2 = taskInfo.Depth.ToShort();
  475. obj.Data.ELine2 = nextAdd.ToShort();
  476. obj.Data.ECol2 = taskInfo.WarehouseCode.Contains("S") ? taskInfoList.Min(x => x.ProdLine) : taskInfoList.Max(x => x.ProdLine);
  477. obj.Data.ELayer2 = 0;
  478. obj.Data.EDepth2 = 0;
  479. obj.Data.TaskSum = taskInfoList.Count.ToShort();
  480. obj.Data.GoodsType = taskInfo.GoodsType switch
  481. {
  482. 18 => 1,
  483. 34 => 2,
  484. 50 => 3,
  485. _ => 0
  486. };
  487. obj.Data.TaskType = 4;
  488. obj.Data.VoucherNo++;
  489. break;
  490. default:
  491. throw new KnownException($"无法执行多个任务", LogLevelEnum.Mid);
  492. }
  493. World.Log($"机械臂任务处理:下发出库任务{obj.Data.TaskNumber1}--{obj.Data.TaskNumber2}--{obj.Data.VoucherNo}", LogLevelEnum.Mid);
  494. }
  495. }
  496. }
  497. public override bool Select(Device dev)
  498. {
  499. return dev.Code is "Robot1" or "Robot2" or "Robot3" or "Robot4" or "Robot5" or "Robot6";
  500. }
  501. public List<string> GetDeviceCodeList(string code)
  502. {
  503. return code switch
  504. {
  505. "424" => new List<string>()
  506. {
  507. "424",
  508. "425",
  509. "422",
  510. "426",
  511. "427"
  512. },
  513. "433" => new List<string>()
  514. {
  515. "433",
  516. "434",
  517. "431",
  518. "435",
  519. "436"
  520. },
  521. "442" => new List<string>()
  522. {
  523. "442",
  524. "443",
  525. "440",
  526. "444",
  527. "445"
  528. },
  529. "642" => new List<string>()
  530. {
  531. "642",
  532. "643",
  533. "640",
  534. "644",
  535. "645"
  536. },
  537. "633" => new List<string>()
  538. {
  539. "633",
  540. "634",
  541. "631",
  542. "635",
  543. "636"
  544. },
  545. "624" => new List<string>()
  546. {
  547. "624",
  548. "625",
  549. "622",
  550. "226",
  551. "627"
  552. },
  553. "824" => new List<string>()
  554. {
  555. "824",
  556. "825",
  557. "822",
  558. "826",
  559. "827"
  560. },
  561. "833" => new List<string>()
  562. {
  563. "833",
  564. "834",
  565. "831",
  566. "835",
  567. "836"
  568. },
  569. "842" => new List<string>()
  570. {
  571. "842",
  572. "843",
  573. "840",
  574. "844",
  575. "845"
  576. },
  577. "1042" => new List<string>()
  578. {
  579. "1042",
  580. "1043",
  581. "1040",
  582. "1044",
  583. "1045"
  584. },
  585. "1033" => new List<string>()
  586. {
  587. "1033",
  588. "1034",
  589. "1031",
  590. "1035",
  591. "1036"
  592. },
  593. "1024" => new List<string>()
  594. {
  595. "1024",
  596. "1025",
  597. "1022",
  598. "1026",
  599. "1027"
  600. },
  601. "1224" => new List<string>()
  602. {
  603. "1224",
  604. "1225",
  605. "1222",
  606. "1226",
  607. "1227"
  608. },
  609. "1233" => new List<string>()
  610. {
  611. "1233",
  612. "1234",
  613. "1231",
  614. "1235",
  615. "1236"
  616. },
  617. "1242" => new List<string>()
  618. {
  619. "1242",
  620. "1243",
  621. "1240",
  622. "1244",
  623. "1245"
  624. },
  625. "1442" => new List<string>()
  626. {
  627. "1442",
  628. "1443",
  629. "1440",
  630. "1444",
  631. "1445"
  632. },
  633. "1433" => new List<string>()
  634. {
  635. "1433",
  636. "1434",
  637. "1431",
  638. "1435",
  639. "1436"
  640. },
  641. "1424" => new List<string>()
  642. {
  643. "1424",
  644. "1425",
  645. "1422",
  646. "1426",
  647. "1427"
  648. },
  649. _ => new List<string>()
  650. };
  651. }
  652. }
  653. }