AGV交互.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554
  1. using DBHelper;
  2. using System;
  3. using System.Linq;
  4. using WCS.Core;
  5. using WCS.Entity;
  6. using WCS.Entity.Protocol;
  7. using WCS.Service.Extensions;
  8. using WCS.Service.Helpers;
  9. namespace WCS.Service.Works.Stations
  10. {
  11. //[WorkTitle(typeof(ProductHandler), "AGV交互", false)]
  12. //class AGV交互 : DeviceWork<Device<IStation521, IStation520>>
  13. //{
  14. // protected override bool SelectDevice(WCS_DEVICE dev)
  15. // {
  16. // return new string[] { "2122", "2131", "2143", "2088" }.Contains(dev.CODE);
  17. // }
  18. // protected override void Do(Device<IStation521, IStation520> dev)
  19. // {
  20. // AGV(dev);
  21. // }
  22. // void AGV(Device<IStation521, IStation520> dev)
  23. // {
  24. // Ltc.Log("AGV交互");
  25. // var station = dev.Entity.CODE;
  26. // DB.Do(db =>
  27. // {
  28. // var agvTasks = db.Default.Set<WCS_AGVTask>().Where(v => v.Station == station).Where(v => v.Status < AGVTaskStatus.完成);
  29. // var agvtask = agvTasks.Where(v => v.TaskType == AGVTaskType.成品入库)
  30. // .OrderByDescending(v => v.Status).ThenBy(v => v.CreateTime)
  31. // .FirstOrDefault();
  32. // if (agvtask == null)
  33. // return;
  34. // if (Ltc.Do(agvtask, agvtask => agvtask.Status == AGVTaskStatus.新建))
  35. // {
  36. // if (station != "2088")
  37. // {
  38. // if (agvTasks.Where(v => v.TaskType == AGVTaskType.原膜出库 && v.Status > AGVTaskStatus.确认 && v.Status < AGVTaskStatus.取放完成).Any())
  39. // {
  40. // var msg = "有正在执行的出库AGV任务";
  41. // throw new Exception(msg);
  42. // }
  43. // }
  44. // var qtyIn = db.Default.Set<WCS_TASK>().Where(v => v.TYPE == TaskType.组盘 && v.STATUS < WCS.Entity.TaskStatus.已完成 && v.ADDRFROM == station).Count();
  45. // if (qtyIn >= 6)
  46. // {
  47. // var msg = $"{agvtask.Workshop}车间入库任务数量已达{qtyIn},暂停执行";
  48. // throw new Exception(msg);
  49. // }
  50. // short inTemp = 0;
  51. // string devs = "";
  52. // if (station == "2143")
  53. // {
  54. // inTemp = 2274;
  55. // devs = "2143,2140,2141,2274";
  56. // }
  57. // if (inTemp > 0)
  58. // {
  59. // var flag = devs.Split(',').Select(v => Device.Find(v).Device<IStation521>()).Any(v => v.Data.GOODSEND == inTemp);
  60. // if (flag)
  61. // {
  62. // throw new Exception("交通管制,入库缓存位已被占用");
  63. // }
  64. // }
  65. // var outStation = dev.Entity.CODE;
  66. // if (outStation == "2088")
  67. // outStation = "2086";
  68. // var outTask = db.Default.Set<WCS_TASK>().Where(v => v.TYPE == TaskType.出库 && v.STATUS < WCS.Entity.TaskStatus.已完成)
  69. // .Where(v => v.ADDRNEXT == v.ADDRTO || v.ADDRCURRENT == station).Where(v => v.ADDRTO == outStation)
  70. // .FirstOrDefault();
  71. // if (outTask != null)
  72. // {
  73. // var msg = "交通管制,与任务" + outTask.ID + "路径冲突";
  74. // throw new Exception(msg);
  75. // }
  76. // agvtask.Status = AGVTaskStatus.执行;
  77. // agvtask.UpdateTime = DateTime.Now;
  78. // db.Default.SaveChanges();
  79. // }
  80. // else if (Ltc.Do(agvtask, v => v.Status < v.AGVStatus))
  81. // {
  82. // if (Ltc.Do(dev, v => v.Data2.RES == true))
  83. // return;
  84. // if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.请求_允许 || v.AGVStatus == AGVTaskStatus.请求_允许2))
  85. // {
  86. // if (Ltc.Do(dev, v => v.Data.TASKNUM > 0))
  87. // return;
  88. // if (Ltc.Do(dev, v => v.Data.PH_STATUS == true))
  89. // return;
  90. // agvtask.Status = agvtask.AGVStatus;
  91. // agvtask.UpdateTime = DateTime.Now;
  92. // db.Default.SaveChanges();
  93. // }
  94. // else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.取放完成 || v.AGVStatus == AGVTaskStatus.取放完成2))
  95. // {
  96. // agvtask.Status = agvtask.AGVStatus;
  97. // agvtask.UpdateTime = DateTime.Now;
  98. // db.Default.SaveChanges();
  99. // //if (Ltc.Do(dev, v => v.Data.PH_STATUS))
  100. // //{
  101. // dev.Data2.RES = true;
  102. // //}
  103. // }
  104. // else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.完成 || v.AGVStatus == AGVTaskStatus.取消))
  105. // {
  106. // agvtask.Status = agvtask.AGVStatus;
  107. // agvtask.UpdateTime = DateTime.Now;
  108. // db.Default.SaveChanges();
  109. // }
  110. // }
  111. // });
  112. // }
  113. //}
  114. [WorkTitle(typeof(ProductHandler), "AGV入库", true)]
  115. internal class AGV入库 : DeviceWork<Device<IStation521, IStation520, IStation523>>
  116. {
  117. protected override bool SelectDevice(WCS_DEVICE dev)
  118. {
  119. return new string[] { "2122", "2131", "2143", "2088", "3001" }.Contains(dev.CODE);
  120. }
  121. protected override void Do(Device<IStation521, IStation520, IStation523> dev)
  122. {
  123. var station = dev.Entity.CODE;
  124. DB.Do(db =>
  125. {
  126. var agvTasks = db.Default.Set<WCS_AGVTask>().Where(v => v.Station == station).Where(v => v.Status < AGVTaskStatus.完成).Where(v => v.TaskType == AGVTaskType.入库).OrderBy(v => v.CreateTime).ToArray();
  127. foreach (var agvtask in agvTasks)
  128. {
  129. var position = agvtask.Position.Replace("_In", "");
  130. if (position.Contains("_Back_")) position = position.Substring(0, position.IndexOf("_0"));
  131. if (!ProtocolProxy.AllDatas.ContainsKey(position)) ProtocolProxy.AllDatas[position] = new ProdLineData();
  132. var pld = ProtocolProxy.AllDatas[position] as ProdLineData;
  133. pld.Frame = LogicHandler.Frame;
  134. pld.Code = position;
  135. pld.TaskList.Add(agvtask);
  136. try
  137. {
  138. if (Ltc.Do(agvtask, agvtask => agvtask.Status == AGVTaskStatus.新建 && agvtask.AGVStatus == AGVTaskStatus.取消))
  139. {
  140. agvtask.Status = agvtask.AGVStatus;
  141. agvtask.UpdateTime = DateTime.Now;
  142. db.Default.SaveChanges();
  143. }
  144. if (Ltc.Do(agvtask, agvtask => agvtask.Status == AGVTaskStatus.新建))
  145. {
  146. //相关错误会在入库扫码位报出,此处只做拦截处理
  147. if (!SystemConfigHelpers.GetDeviceConfig(dev.Entity.CODE)) return;
  148. if (station != "2088" && station != "3001")
  149. {
  150. if (db.Default.Set<WCS_AGVTask>().Where(v => v.TaskType == AGVTaskType.叫料 && v.Status > AGVTaskStatus.确认 && v.Status < AGVTaskStatus.取放完成 && v.Station == station).Any())
  151. {
  152. var msg = $"[{station}]有正在执行的出库AGV任务";
  153. throw new Exception(msg);
  154. }
  155. if (db.Default.Set<WCS_AGVTask>().Where(v => v.TaskType == AGVTaskType.入库 && v.Status > AGVTaskStatus.新建 && v.Status < AGVTaskStatus.完成扫码 && v.Station == station).Any())
  156. {
  157. var msg = $"[{station}]有正在执行的入库AGV任务";
  158. throw new Exception(msg);
  159. }
  160. var qtyIn = db.Default.Set<WCS_TASK>().Where(v => v.TYPE == TaskType.组盘 && v.STATUS < WCS.Entity.TaskStatus.已完成 && v.ADDRFROM == station).Count();
  161. var max = 6;
  162. max = 9;
  163. if (qtyIn >= max)
  164. {
  165. var msg = $"{agvtask.Workshop}车间入库任务数量已达{qtyIn},暂停执行-{station}";
  166. throw new Exception(msg);
  167. }
  168. }
  169. if (dev.Data2.RES) throw new Exception($"[{station}]顶升下降信号未清除");
  170. if (Ltc.Do(dev, v => v.Data.TASKNUM == dev.Entity.Code())) throw new Exception($"[{station}]待分配任务");
  171. short inTemp = 0;
  172. Device<IStation521, IStation520>[] arr = null;
  173. Device<IStation521, IStation520>[] arrout = null;
  174. if (station == "2143")
  175. {
  176. inTemp = 2274;
  177. arr = Device.Find("2143", "2140", "2141", "2274").Select(v => v.Device<IStation521, IStation520>()).ToArray();
  178. arrout = Device.Find("2326", "2140", "2143").Select(v => v.Device<IStation521, IStation520>()).ToArray();
  179. }
  180. else if (station == "2131")
  181. {
  182. inTemp = 2273;
  183. arr = Device.Find("2131", "2128", "2129", "2273").Select(v => v.Device<IStation521, IStation520>()).ToArray();
  184. arrout = Device.Find("2327", "2128", "2131").Select(v => v.Device<IStation521, IStation520>()).ToArray();
  185. }
  186. else if (station == "2122")
  187. {
  188. inTemp = 2272;
  189. arr = Device.Find("2122", "2119", "2120", "2272").Select(v => v.Device<IStation521, IStation520>()).ToArray();
  190. arrout = Device.Find("2328", "2119", "2122").Select(v => v.Device<IStation521, IStation520>()).ToArray();
  191. }
  192. else if (station == "3001")
  193. {
  194. if (db.Default.Set<WCS_AGVTask>().Count(v => v.TaskType == AGVTaskType.入库 && v.Station == "3001" && v.Status >= AGVTaskStatus.确认 && v.Status < AGVTaskStatus.完成扫码) >= 2) throw new Exception($"流量管控");
  195. inTemp = 3005;
  196. arr = Device.Find("3001", "3005").Select(v => v.Device<IStation521, IStation520>()).ToArray();
  197. arrout = Device.Find("3001", "3012").Select(v => v.Device<IStation521, IStation520>()).ToArray();
  198. }
  199. if (inTemp > 0)
  200. {
  201. if (arr.Any(v => v.Data2.CONFIRM)) continue;
  202. if (arrout.Any(v => v.Data2.CONFIRM)) continue;
  203. var flag = arr.Any(v => v.Data.GOODSEND == inTemp);
  204. if (flag) throw new Exception($"[{station}]交通管制,入库缓存位已被占用");
  205. flag = arrout.Any(v => v.Data.GOODSEND == dev.Entity.Code());
  206. if (flag) throw new Exception($"交通管制,{station}被出库任务占用");
  207. }
  208. else
  209. {
  210. var outStation = dev.Entity.CODE;
  211. if (outStation == "2088") outStation = "2086";
  212. var outTask = db.Default.Set<WCS_TASK>().Where(v => v.TYPE == TaskType.出库 && v.STATUS < WCS.Entity.TaskStatus.已完成)
  213. .Where(v => v.ADDRTO == outStation).Where(v => v.ADDRNEXT == v.ADDRTO).ToList()
  214. .Where(v =>
  215. {
  216. var curr = v.AddrCurrent(db);
  217. return (curr != v.ADDRTO) && (curr != "2084");
  218. })
  219. .FirstOrDefault();
  220. if (outTask != null)
  221. {
  222. var msg = $"[{station}]交通管制,与出库任务[{outTask.ID}]路径冲突";
  223. throw new Exception(msg);
  224. }
  225. }
  226. agvtask.Status = AGVTaskStatus.执行;
  227. agvtask.UpdateTime = DateTime.Now;
  228. db.Default.SaveChanges();
  229. }
  230. else if (Ltc.Do(agvtask, v => v.Status < v.AGVStatus || v.AGVStatus == AGVTaskStatus.确认))
  231. {
  232. if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.确认 && v.Status != AGVTaskStatus.确认))
  233. {
  234. if (agvTasks.Any(v => v.Status >= AGVTaskStatus.确认 && v.Status != AGVTaskStatus.执行 && v.Status < AGVTaskStatus.完成扫码 && v.Station == "3001"))
  235. throw new Exception($"同时放货任务数量最大为1");
  236. // 缓存位与取放货位没有光电 任务 去往缓存位任务 ,如果楼上没有出库任务,就不会有去往3006的任务
  237. var inTemp = Device.Find("3006", "3001", "3012", "3004", "3005").Select(v => v.Device<IStation521, IStation523>());
  238. if (inTemp.Any(v => v.Data.PH_STATUS == true
  239. || v.Data.TASKNUM > 0
  240. || v.Data.GOODSEND == 3006
  241. || v.Data2.Status.HasFlag(StationStatus.运行状态位)
  242. || v.Data.GOODSTYPE == 2)) return;
  243. if (db.Default.Set<WCS_TASK>().Any(v => v.STATUS < TaskStatus.已完成 && v.ADDRNEXT == "3060")) return;
  244. if (db.Default.Set<WCS_AGVTask>().Any(v => v.AGVStatus >= AGVTaskStatus.确认 && v.TaskType == AGVTaskType.叫料
  245. && v.Station == "3001" && v.Status < AGVTaskStatus.完成)) return;
  246. //3005没有出库任务
  247. var con3005 = Device.Find("3005").Device<IStation521, IStation523>();
  248. if ((con3005.Data.PH_STATUS && con3005.Data.GOODSEND is 3001 or 0) || con3005.Data2.Status.HasFlag(StationStatus.运行状态位)) return;
  249. agvtask.Status = agvtask.AGVStatus;
  250. agvtask.UpdateTime = DateTime.Now;
  251. db.Default.SaveChanges();
  252. }
  253. else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.请求_允许 || v.AGVStatus == AGVTaskStatus.请求_允许2))
  254. {
  255. if (Ltc.Do(dev, v => v.Data2.RES))
  256. continue;
  257. if (Ltc.Do(dev, v => v.Data.TASKNUM > 0))
  258. continue;
  259. if (Ltc.Do(dev, v => !v.Data3.Status.Has(StationStatus.自动)))
  260. continue;
  261. if (Ltc.Do(dev, v => v.Data.PH_STATUS == true || v.Data.TASKNUM != 0))
  262. continue;
  263. if (agvtask.AGVStatus == AGVTaskStatus.请求_允许2)
  264. {
  265. if (agvtask.Status < AGVTaskStatus.取放完成) throw new Exception($"[{station}]请求放第二卷之前必须完成第一卷放货");
  266. }
  267. agvtask.Status = agvtask.AGVStatus;
  268. agvtask.UpdateTime = DateTime.Now;
  269. db.Default.SaveChanges();
  270. }
  271. else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.取放完成 || v.AGVStatus == AGVTaskStatus.取放完成2))
  272. {
  273. if (Ltc.Do(dev, v => v.Data2.RES))
  274. {
  275. Configs.UploadException(dev.Entity.CODE, "顶升下降信号未清除");
  276. continue;
  277. }
  278. if (Ltc.Do(dev, v => v.Data.PH_STATUS == false))
  279. {
  280. Configs.UploadException(dev.Entity.CODE, "AGV放货完成后输送线无光电信号");
  281. continue;
  282. }
  283. agvtask.Status = agvtask.AGVStatus;
  284. agvtask.UpdateTime = DateTime.Now;
  285. db.Default.SaveChanges();
  286. dev.Data2.RES = true;
  287. }
  288. else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.完成))
  289. {
  290. agvtask.Status = agvtask.AGVStatus;
  291. agvtask.UpdateTime = DateTime.Now;
  292. db.Default.SaveChanges();
  293. }
  294. else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.取消))
  295. {
  296. agvtask.Status = agvtask.AGVStatus;
  297. agvtask.UpdateTime = DateTime.Now;
  298. db.Default.SaveChanges();
  299. }
  300. }
  301. }
  302. catch (Exception ex)
  303. {
  304. Ltc.Log("AGV任务" + agvtask.ID + ":" + ex.GetBaseException().Message);
  305. Configs.UploadException?.Invoke(position, ex.GetBaseException().Message);
  306. }
  307. }
  308. });
  309. }
  310. }
  311. [WorkTitle(typeof(ProductHandler), "车间叫料", false)]
  312. internal class 车间叫料 : DeviceWork<Device<IStation521, IStation520, IStation523>>
  313. {
  314. protected override bool SelectDevice(WCS_DEVICE dev)
  315. {
  316. return new string[] { "2086", "2122", "2131", "2143", "3001" }.Contains(dev.CODE);
  317. }
  318. protected override void Do(Device<IStation521, IStation520, IStation523> dev)
  319. {
  320. var station = dev.Entity.CODE;
  321. var taskId = dev.Data.TASKNUM;
  322. //if (Ltc.Do(dev, v => v.Entity.WakeupOn(10000,"叫料")))
  323. {
  324. DB.Do(db =>
  325. {
  326. var agvTasks = db.Default.Set<WCS_AGVTask>().Where(v => v.Station == station && v.TaskType == AGVTaskType.叫料)
  327. .Where(v => v.Status < AGVTaskStatus.完成).ToArray();
  328. foreach (var agvtask in agvTasks)
  329. {
  330. var position = agvtask.Position;
  331. if (!ProtocolProxy.AllDatas.ContainsKey(position))
  332. ProtocolProxy.AllDatas[position] = new ProdLineData();
  333. var pld = ProtocolProxy.AllDatas[position] as ProdLineData;
  334. pld.Frame = LogicHandler.Frame;
  335. pld.Code = position;
  336. pld.TaskList.Add(agvtask);
  337. try
  338. {
  339. if (Ltc.Do(agvtask, agvtask => agvtask.Status == AGVTaskStatus.新建))
  340. {
  341. if (station == "2086")
  342. {
  343. var count1 = ProtocolProxy.WMS120Redis.Get("MaxLineCallTaskCount_13_14").ToInt();
  344. var qty = db.Default.Set<WCS_AGVTask>().Where(v => v.TaskType == AGVTaskType.叫料 && v.Status > AGVTaskStatus.新建 && v.Status < AGVTaskStatus.完成)
  345. .Where(v => v.Position == agvtask.Position).Count();
  346. if (Ltc.Do(qty, OutTaskQty => OutTaskQty >= count1))
  347. {
  348. throw new Exception($"{agvtask.Position}正在执行的叫料任务数量已达{qty},暂停出库");
  349. }
  350. }
  351. else if (station == "3001")
  352. {
  353. var qty = db.Default.Set<WCS_AGVTask>().Where(v => v.TaskType == AGVTaskType.叫料 && v.Status > AGVTaskStatus.新建 && v.Status < AGVTaskStatus.完成)
  354. .Where(v => v.Position == agvtask.Position).Count();
  355. if (Ltc.Do(qty, OutTaskQty => OutTaskQty >= 5))
  356. {
  357. throw new Exception($"{agvtask.Position}正在执行的叫料任务数量已达{qty},暂停出库");
  358. }
  359. }
  360. else
  361. {
  362. var count2 = ProtocolProxy.WMS120Redis.Get("MaxLineCallTaskCount_1_2_3").ToInt();
  363. var qty = db.Default.Set<WCS_AGVTask>().Where(v => v.TaskType == AGVTaskType.叫料 && v.Status > AGVTaskStatus.新建 && v.Status < AGVTaskStatus.完成)
  364. .Where(v => v.Position == agvtask.Position).Count();
  365. if (Ltc.Do(qty, OutTaskQty => OutTaskQty >= count2))
  366. {
  367. throw new Exception($"{agvtask.Position}正在执行的叫料任务数量已达{qty},暂停出库");
  368. }
  369. }
  370. var res = WMS.GetOutTask(agvtask.Position, dev.Entity.CODE);
  371. var sc = Device.Find(res.TunnelNum).ROUTES.Where(v => v.NEXT.IsSC()).Select(v => v.NEXT).FirstOrDefault();
  372. var loc = string.Format("{0}-{1}-{2}", res.Row, res.Colomn, res.Layer);
  373. var addrNext = dev.Entity.CODE;
  374. if (agvtask.Workshop == 1)
  375. addrNext = "2108";
  376. else if (agvtask.Workshop == 2)
  377. addrNext = "2366";
  378. else if (agvtask.Workshop == 3)
  379. addrNext = "2385";
  380. else if (agvtask.Station == "2086")
  381. addrNext = "2325";
  382. else if (agvtask.Station == "3001")
  383. {
  384. addrNext = "3045";
  385. }
  386. var task = new WCS_TASK
  387. {
  388. TYPE = TaskType.出库,
  389. STATUS = WCS.Entity.TaskStatus.新建,
  390. ADDRFROM = loc,
  391. ADDRTO = dev.Entity.CODE,
  392. BARCODE = res.ContainerBarCode,
  393. TUNNEL = res.TunnelNum,
  394. WMSTASK = int.Parse(res.WMSTaskNum),
  395. UPDATEUSER = "WCS",
  396. SCSTATION = res.Memo1,
  397. DEVICE = sc.CODE,
  398. //ADDRCURRENT = loc,
  399. AgvTask = agvtask.ID,
  400. ADDRNEXT = addrNext
  401. };
  402. db.Default.Set<WCS_TASK>().Add(task);
  403. agvtask.Status = AGVTaskStatus.确认;
  404. agvtask.UpdateTime = DateTime.Now;
  405. db.Default.SaveChanges();
  406. }
  407. else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.完成))
  408. {
  409. //if (Ltc.Do(agvtask, v => v.Status != AGVTaskStatus.取放完成 && v.Status != AGVTaskStatus.取放完成2))
  410. // continue;
  411. agvtask.Status = agvtask.AGVStatus;
  412. agvtask.UpdateTime = DateTime.Now;
  413. db.Default.SaveChanges();
  414. }
  415. else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.取消))
  416. {
  417. //if (Ltc.Do(agvtask, v => v.Status != AGVTaskStatus.新建))
  418. // continue;
  419. agvtask.Status = agvtask.AGVStatus;
  420. agvtask.UpdateTime = DateTime.Now;
  421. db.Default.SaveChanges();
  422. }
  423. }
  424. catch (Exception ex)
  425. {
  426. if (ex.Message.Contains("库存不足"))
  427. {
  428. agvtask.Status = AGVTaskStatus.取消;
  429. agvtask.UpdateTime = DateTime.Now;
  430. db.Default.SaveChanges();
  431. }
  432. Ltc.Log("AGV任务" + agvtask.ID + ":" + ex.GetBaseException().Message);
  433. Configs.UploadException?.Invoke(agvtask.Position, ex.GetBaseException().Message);
  434. }
  435. }
  436. });
  437. }
  438. if (Ltc.Do(dev, v => v.Data.TASKNUM == 0))
  439. return;
  440. if (Ltc.Do(dev, v => v.Data.GOODSEND != dev.Entity.Code()))
  441. return;
  442. if (Ltc.Do(dev, v => !v.Data3.Status.Has(StationStatus.自动)))
  443. return;
  444. DB.Do(db =>
  445. {
  446. var task = db.Default.Set<WCS_TASK>().Find(taskId);
  447. if (task == null)
  448. {
  449. var msg = $"WCS任务号{taskId}不存在";
  450. throw new Exception(msg);
  451. }
  452. if (Ltc.Do(task, task => task.TYPE != TaskType.出库))
  453. return;
  454. if (task.AgvTask == 0)
  455. {
  456. throw new Exception("人工出库任务,请手动搬走");
  457. }
  458. var agvtask = db.Default.Set<WCS_AGVTask>().Find(task.AgvTask);
  459. if (agvtask == null)
  460. {
  461. var msg = $"AGV任务号{task.AgvTask}不存在";
  462. throw new Exception(msg);
  463. }
  464. if (Ltc.Do(agvtask, agvtask => agvtask.Station != station))
  465. return;
  466. if (Ltc.Do(agvtask, agvtask => agvtask.Status == AGVTaskStatus.确认))
  467. {
  468. if (Ltc.Do(dev, v => v.Data.PH_STATUS == false))
  469. return;
  470. var flag = db.Default.Set<WCS_AGVTask>().Where(v => v.Station == station && v.TaskType == AGVTaskType.叫料)
  471. .Where(v => v.Status > AGVTaskStatus.确认 && v.Status < AGVTaskStatus.取放完成)
  472. .Any();
  473. if (flag)
  474. throw new Exception("有未完成的AGV出库任务");
  475. task.STATUS = WCS.Entity.TaskStatus.已完成;
  476. task.UPDATETIME = DateTime.Now;
  477. task.ENDTIME = DateTime.Now;
  478. agvtask.Status = AGVTaskStatus.执行;
  479. agvtask.UpdateTime = DateTime.Now;
  480. db.Default.SaveChanges();
  481. }
  482. else if (Ltc.Do(agvtask, agvtask => agvtask.Status < agvtask.AGVStatus))
  483. {
  484. if (Ltc.Do(agvtask, agvtask => agvtask.AGVStatus == AGVTaskStatus.请求_允许 || agvtask.AGVStatus == AGVTaskStatus.请求_允许2))
  485. {
  486. if (Ltc.Do(agvtask, agvtask => agvtask.Status < AGVTaskStatus.确认))
  487. return;
  488. if (Ltc.Do(dev, v => v.Data2.RES == true))
  489. throw new Exception("任务清零信号未清除");
  490. agvtask.Status = agvtask.AGVStatus;
  491. agvtask.UpdateTime = DateTime.Now;
  492. db.Default.SaveChanges();
  493. }
  494. else if (Ltc.Do(agvtask, agvtask => agvtask.AGVStatus == AGVTaskStatus.取放完成 || agvtask.AGVStatus == AGVTaskStatus.取放完成2))
  495. {
  496. if (Ltc.Do(dev, v => v.Data2.RES == true))
  497. throw new Exception("任务清零信号未清除");
  498. if (Ltc.Do(dev, v => v.Data.PH_STATUS == true))
  499. throw new Exception("AGV取货完成后依然有光电信号");
  500. if (Ltc.Do(agvtask, agvtask => agvtask.Status < AGVTaskStatus.请求_允许))
  501. throw new Exception("AGV任务状态有误");
  502. agvtask.Status = agvtask.AGVStatus;
  503. agvtask.UpdateTime = DateTime.Now;
  504. db.Default.SaveChanges();
  505. dev.Data2.RES = true;
  506. }
  507. }
  508. });
  509. }
  510. }
  511. }