BaseWorkflow.cs 57 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading;
  6. using Newtonsoft.Json.Linq;
  7. using SqlSugar;
  8. using WCS.Data;
  9. using WCS.Data.Models;
  10. using WCS.Data.Utils;
  11. using WCS.PLC.Model.Equipment;
  12. using WCS.WMSWorkflow;
  13. using static WCS.WMSWorkflow.ApiParam;
  14. namespace WCS.PLC
  15. {
  16. public class BaseWorkflow
  17. {
  18. private static int _putTaskStep = 0;
  19. #region private Method
  20. public static void MoveTaskToDis(WCS_TASK task)
  21. {
  22. TryCachHelper.TryTranExecute((db) =>
  23. {
  24. //添加机械手码垛位置条码信息
  25. var sysset = Current.SysSets.SingleOrDefault(v => v.SET_TYPE == "PalletizingPos" && v.SET_ID == task.TASK_POSIDTO && task.TASK_POSIDFROM != "1390");
  26. if (sysset != null)
  27. {
  28. string time = DateTime.Now.ToString("yyyyMMddhhmmss");
  29. db.Updateable<WCS_SYSSET>(it => new WCS_SYSSET()
  30. {
  31. SET_MEMO = task.TASK_BOXBARCODE,
  32. SET_EDITUSERNO = "wcs",
  33. SET_EDITTIME = time
  34. })
  35. .Where(it => it.SET_ID == sysset.SET_ID).ExecuteCommand();
  36. }
  37. //移动任务到历史列表
  38. var task_dis = ExtendsUtil.Mapper<WCS_TASK_DIS, WCS_TASK>(task);
  39. task_dis.TASK_DELETEUSER = "wcs";
  40. task_dis.TASK_DELETEDATE = db.GetDate();
  41. if (db.Insertable(task_dis).ExecuteCommand() <= 0)
  42. {
  43. throw new Exception(string.Format("任务[{0}]插入历史列表失败", task_dis.TASK_NO));
  44. }
  45. var taskdtlSet = db.Queryable<WCS_TASK_DTL>().Where(v => v.PARENTID == task.TASK_NO).ToList();
  46. foreach (var taskdtl in taskdtlSet)
  47. {
  48. var task_dis_dtl = ExtendsUtil.Mapper<WCS_TASK_DIS_DTL, WCS_TASK_DTL>(taskdtl);
  49. if (db.Insertable(task_dis_dtl).ExecuteCommand() <= 0)
  50. {
  51. throw new Exception(string.Format("任务[{0}]明细插入到历史列表失败", task_dis.TASK_NO));
  52. }
  53. if (db.Deleteable(taskdtl).ExecuteCommand() <= 0)
  54. {
  55. throw new Exception(string.Format("任务[{0}]明细删除失败", task_dis.TASK_NO));
  56. }
  57. }
  58. //删除当前任务
  59. if (db.Deleteable(task).ExecuteCommand() <= 0)
  60. {
  61. throw new Exception(string.Format("任务[{0}]删除失败", task_dis.TASK_NO));
  62. }
  63. });
  64. }
  65. public static void MoveAgvTaskToDis(Middle_AGVTask task)
  66. {
  67. TryCachHelper.TryTranExecute((db) =>
  68. {
  69. //移动任务到历史列表
  70. var task_dis = ExtendsUtil.Mapper<Middle_AGVTask_Dis, Middle_AGVTask>(task);
  71. task_dis.Task_FinishDate = db.GetDate();
  72. if (db.Insertable(task_dis).ExecuteCommand() <= 0)
  73. {
  74. throw new Exception(string.Format("任务[{0}]插入历史列表失败", task_dis.Task_Id));
  75. }
  76. //删除当前任务
  77. if (db.Deleteable(task).ExecuteCommand() <= 0)
  78. {
  79. throw new Exception(string.Format("任务[{0}]删除失败", task_dis.Task_Id));
  80. }
  81. });
  82. }
  83. #endregion;
  84. #region public Method
  85. /// <summary>
  86. /// 更新任务进程
  87. /// </summary>
  88. public static void PutTaskStep()
  89. {
  90. if (Interlocked.Exchange(ref _putTaskStep, 1) == 0)
  91. {
  92. try
  93. {
  94. var tasks =SugarBase.DB.Queryable<WCS_TASK>().Where(v => v.TASK_WKSTATUS >= 1).ToList();
  95. var agvtasks = Current.AgvTaskSet.Where(v => v.Task_WcsStatus == 106 || v.Task_WcsStatus == 99 || v.Task_WcsStatus == 4).ToList();
  96. if (tasks.Count == 0 && agvtasks.Count == 0) return;
  97. var tasks_NoFinish = tasks.Where(v => v.TASK_WKSTATUS < 99 && v.TASK_COMTYPE != 6 && (v.TASK_POSIDTO != "1288") && (v.TASK_POSIDTO != "1293")).ToList();
  98. if (tasks_NoFinish.Count > 0)
  99. {
  100. var PutTaskStepList = Current.WmsInterface.I_WCS_PutTaskStep(tasks_NoFinish);
  101. foreach (var item in PutTaskStepList)
  102. {
  103. var task = tasks.FirstOrDefault(v => v.TASK_WMSNO == item.WMSTaskNum);
  104. if (!item.ResType)
  105. {
  106. string msg = string.Format("任务[{0}]更新进程失败,原因:[{1}]", task.TASK_NO, item.ResMessage);
  107. LogMessageHelper.RecordLogMessage(msg);
  108. }
  109. }
  110. }
  111. var tasks_Finish = tasks.Where(v => v.TASK_WKSTATUS >= 99 && (v.TASK_POSIDTO != "1508") && (v.TASK_POSIDTO != "1509")&& (v.TASK_POSIDTO != "1288") && (v.TASK_POSIDTO != "1293")).ToList();
  112. if (tasks_Finish.Count > 0)
  113. {
  114. var PutTaskStepList_finish = Current.WmsInterface.I_WCS_PutTaskStep(tasks_Finish);
  115. foreach (var item in PutTaskStepList_finish)
  116. {
  117. var task = tasks.FirstOrDefault(v => v.TASK_WMSNO == item.WMSTaskNum);
  118. if (item.ResType)
  119. {
  120. if (task.TASK_WKSTATUS >= 99)
  121. {
  122. MoveTaskToDis(task);
  123. }
  124. }
  125. else
  126. {
  127. string msg = string.Format("任务[{0}]更新进程失败,原因:[{1}]", task.TASK_NO, item.ResMessage);
  128. LogMessageHelper.RecordLogMessage(msg);
  129. }
  130. }
  131. }
  132. var task_Finish2 = tasks.FirstOrDefault(v => v.TASK_WKSTATUS >= 99 && v.TASK_POSIDTO == "1508");
  133. if (task_Finish2 != null)
  134. {
  135. var tasks_Finishs = new List<WCS_TASK>();
  136. tasks_Finishs.Add(task_Finish2);
  137. var PutTaskStepList_finish = Current.WmsInterface.I_WCS_PutTaskStep(tasks_Finishs);
  138. foreach (var item in PutTaskStepList_finish)
  139. {
  140. var task = tasks.FirstOrDefault(v => v.TASK_WMSNO == item.WMSTaskNum);
  141. if (item.ResType)
  142. {
  143. if (task.TASK_WKSTATUS >= 99)
  144. {
  145. if (Current.TaskSet.Any(v => v.TASK_BOXBARCODE == task_Finish2.TASK_BOXBARCODE && v.TASK_COMTYPE == 1))
  146. {
  147. MoveTaskToDis(task);
  148. }
  149. }
  150. }
  151. else
  152. {
  153. string msg = string.Format("任务[{0}]更新进程失败,原因:[{1}]", task.TASK_NO, item.ResMessage);
  154. LogMessageHelper.RecordLogMessage(msg);
  155. }
  156. }
  157. }
  158. var task_Finish3 = tasks.FirstOrDefault(v => v.TASK_WKSTATUS >= 99 && v.TASK_POSIDTO == "1509");
  159. if (task_Finish3 != null)
  160. {
  161. var tasks_F = new List<WCS_TASK>();
  162. tasks_F.Add(task_Finish3);
  163. var PutTaskStepList_finish = Current.WmsInterface.I_WCS_PutTaskStep(tasks_F);
  164. foreach (var item in PutTaskStepList_finish)
  165. {
  166. var task = tasks.FirstOrDefault(v => v.TASK_WMSNO == item.WMSTaskNum);
  167. if (item.ResType)
  168. {
  169. if (task.TASK_WKSTATUS >= 99)
  170. {
  171. if (Current.TaskSet.Any(v => v.TASK_BOXBARCODE == task_Finish3.TASK_BOXBARCODE && v.TASK_COMTYPE == 1))
  172. {
  173. MoveTaskToDis(task);
  174. }
  175. }
  176. }
  177. else
  178. {
  179. string msg = string.Format("任务[{0}]更新进程失败,原因:[{1}]", task.TASK_NO, item.ResMessage);
  180. LogMessageHelper.RecordLogMessage(msg);
  181. }
  182. }
  183. }
  184. var tasks_Exception = tasks.Where(v => v.TASK_WKSTATUS >= 99 && (v.TASK_COMTYPE == 6 || v.TASK_POSIDTO == "1288" || v.TASK_POSIDTO == "1293")).ToList();
  185. foreach (var item in tasks_Exception)
  186. {
  187. MoveTaskToDis(item);
  188. }
  189. foreach (var item in agvtasks)
  190. {
  191. if (item.Task_WcsStatus == 99 || item.Task_WcsStatus == 4)
  192. {
  193. //if (item.Task_Type == 3 || (item.Task_Type == 1 && (item.Task_WorkshopNo == "18" || item.Task_WorkshopNo == "4" || item.Task_WorkshopNo == "5")))
  194. if (item.Task_Type == 3 || (item.Task_Type == 1 && item.Task_WorkshopNo == "18"))
  195. {
  196. var wcstask = Current.TaskSet.SingleOrDefault(v => v.TASK_ITEM8 == item.Task_Id.ToString());
  197. if (wcstask == null || wcstask.TASK_WKSTATUS >= 99)
  198. {
  199. if (item.Task_WcsStatus == 99) MoveAgvTaskToDis(item);//任务完成
  200. continue;
  201. }
  202. wcstask.TASK_WKSTATUS = 99;
  203. wcstask.TASK_EDITUSERNO = "wcs";
  204. wcstask.TASK_EDITDATETIME = DateTime.Now;
  205. int updateresult = SugarBase.DB.Updateable(wcstask)
  206. .UpdateColumns(it => new { it.TASK_WKSTATUS, it.TASK_EDITUSERNO, it.TASK_EDITDATETIME })
  207. .ExecuteCommand();
  208. if (updateresult <= 0)
  209. {
  210. LogMessageHelper.RecordLogMessage(string.Format("空熟化架呼叫AGV任务[{0}]已完成,完成WCS任务[{1}]失败。", item.Task_Id, wcstask.TASK_NO));
  211. continue;
  212. }
  213. else
  214. {
  215. if (item.Task_WcsStatus == 99) MoveAgvTaskToDis(item);//任务完成
  216. }
  217. }
  218. else if (item.Task_Type == 1 || item.Task_Type == 2 || item.Task_Type == 4)
  219. {
  220. if (item.Task_WcsStatus == 99) MoveAgvTaskToDis(item);//任务完成
  221. }
  222. }
  223. else if (item.Task_WcsStatus == 106 && item.Task_AgvStatus == 106)
  224. {
  225. MoveAgvTaskToDis(item);//任务完成
  226. }
  227. }
  228. }
  229. catch (Exception ex)
  230. {
  231. LogMessageHelper.RecordLogMessage(ex);
  232. }
  233. finally
  234. {
  235. Interlocked.Exchange(ref _putTaskStep, 0);
  236. }
  237. }
  238. }
  239. public static WCS_TASK GetInTask(GetInTaskParam param)
  240. {
  241. WCS_TASK wcstask = null;
  242. try
  243. {
  244. wcstask = SugarBase.DB.Queryable<WCS_TASK>().First(v => v.TASK_BOXBARCODE == param.ContainerBarCode);
  245. if (wcstask == null)
  246. {
  247. var reply = Current.WmsInterface.I_WCS_GetInTask(param);
  248. string errormsg = CheckGetInTask(param, reply);
  249. if (string.IsNullOrWhiteSpace(errormsg))
  250. {
  251. //添加wcs任务
  252. wcstask = new WCS_TASK();
  253. wcstask.TASK_WMSNO = reply.WMSTaskNum;
  254. wcstask.TASK_COMTYPE = reply.TaskType;
  255. wcstask.TASK_SYSTYPE = "WMS";
  256. wcstask.TASK_POSIDFROM = param.EquipmentNo;//起点地址
  257. wcstask.TASK_POSIDCUR = param.EquipmentNo;
  258. wcstask.TASK_POSIDNEXT = param.EquipmentNo;
  259. wcstask.TASK_POSIDMOVE = "";
  260. wcstask.TASK_PRIORITY = reply.Priority;
  261. wcstask.TASK_WKSTATUS = 0;
  262. wcstask.TASK_WHID = reply.WareHouseName;
  263. wcstask.TASK_ADDUSERNO = "WMS";
  264. wcstask.TASK_ADDDATETIME = DateTime.Now;
  265. wcstask.TASK_EDITUSERNO = "WMS";
  266. wcstask.TASK_EDITDATETIME = DateTime.Now;
  267. wcstask.TASK_NOTES = "";
  268. wcstask.TASK_RGVNO = "";
  269. wcstask.TASK_BOXBARCODE = param.ContainerBarCode;
  270. wcstask.TASK_WEIGHT = reply.TASK_WEIGHT;
  271. wcstask.TASK_STACKINGTYPE = reply.TASK_STACKINGTYPE;
  272. if (!string.IsNullOrWhiteSpace(reply.Memo1))
  273. {
  274. wcstask.TASK_IsWrapFilm = reply.Memo1.Trim() == "1" ? true : false;
  275. }
  276. if (string.IsNullOrWhiteSpace(param.Memo1))
  277. {
  278. wcstask.TASK_POSIDTO = reply.EndPostion;
  279. wcstask.TASK_SRMNO = reply.EndPostion;
  280. wcstask.PalletizingBoxSize = reply.PalletizingBoxSize;
  281. wcstask.TASK_ORDERTYPE = reply.IsLastBox ? 1 : 0;
  282. }
  283. else if (param.Memo1.Trim() == "1")
  284. {
  285. string srmno = string.Empty;
  286. wcstask.TASK_EndTunnelNum = ConveyorHelper.QueryTunnel(wcstask.TASK_WMSNO, reply.TunnelNum, out srmno);
  287. wcstask.TASK_POSIDTO = srmno;
  288. wcstask.TASK_SRMNO = srmno;
  289. }
  290. else if (param.Memo1.Trim() == "2")
  291. {
  292. wcstask.TASK_POSIDTO = reply.EndPostion;
  293. wcstask.TASK_EndTunnelNum = reply.TunnelNum;
  294. wcstask.TASK_SRMNO = Current.SysSets.Where(v => v.SET_ID.Contains("Tunnel")).FirstOrDefault(v => v.SET_VALUE == reply.TunnelNum).SET_VALUE;
  295. }
  296. else
  297. {
  298. throw new Exception(string.Format("托盘[{0}]调用WMS入库接口传递参数Memo1错误.", param.ContainerBarCode));
  299. }
  300. if (param.EquipmentNo == "1109" || param.EquipmentNo == "1114" || param.EquipmentNo == "1102" || param.EquipmentNo == "1094")
  301. {
  302. wcstask.TASK_MatureType = reply.TASK_MatureType;
  303. wcstask.TASK_MatureTemperat = reply.TASK_MatureTemperat;
  304. wcstask.TASK_MatureDate = reply.TASK_MatureDate;
  305. }
  306. int id = SugarBase.DB.Insertable(wcstask).ExecuteReturnIdentity();
  307. if (id <= 0)
  308. {
  309. throw new Exception(string.Format("WMS任务[{0}]添加WCS任务失败", reply.WMSTaskNum));
  310. }
  311. else
  312. {
  313. wcstask.TASK_NO = id;
  314. }
  315. }
  316. else
  317. {
  318. LogMessageHelper.RecordLogMessage(errormsg);
  319. AddLedErrorMsg(param.EquipmentNo, errormsg, 0);
  320. if (!string.IsNullOrWhiteSpace(param.Memo2))
  321. {
  322. //wms任务异常需要生成退回托盘任务
  323. wcstask = new WCS_TASK()
  324. {
  325. TASK_WMSNO = "wcs_" + DateTime.Now.ToString("yyyyMMddhhmmss"),
  326. TASK_COMTYPE = (int)ComTypeEnum.托盘异常退回,
  327. TASK_SYSTYPE = "WCS",
  328. TASK_POSIDFROM = param.EquipmentNo,//起点地址
  329. TASK_POSIDCUR = param.EquipmentNo,
  330. TASK_POSIDNEXT = param.EquipmentNo,
  331. TASK_POSIDMOVE = "",
  332. TASK_PRIORITY = 1,
  333. TASK_WKSTATUS = 1,
  334. TASK_WHID = string.IsNullOrWhiteSpace(reply.WareHouseName) ? Current.WareNameList[0] : reply.WareHouseName,
  335. TASK_ADDUSERNO = "WCS",
  336. TASK_ADDDATETIME = DateTime.Now,
  337. TASK_EDITUSERNO = "WCS",
  338. TASK_EDITDATETIME = DateTime.Now,
  339. TASK_NOTES = "",
  340. TASK_RGVNO = "",
  341. TASK_BOXBARCODE = param.ContainerBarCode,
  342. TASK_POSIDTO = param.Memo2.Trim()
  343. };
  344. int id = SugarBase.DB.Insertable(wcstask).ExecuteReturnIdentity();
  345. if (id <= 0)
  346. {
  347. throw new Exception(string.Format("WMS任务[{0}]添加WCS任务失败", reply.WMSTaskNum));
  348. }
  349. else
  350. {
  351. wcstask.TASK_NO = id;
  352. }
  353. var task_dtl = new WCS_TASK_DTL()
  354. {
  355. ID = Guid.NewGuid().ToString(),
  356. PARENTID = wcstask.TASK_NO,
  357. TASKNO = wcstask.TASK_NO,
  358. POSIDCUR = param.EquipmentNo,
  359. POSIDNEXT = param.EquipmentNo,
  360. DESCRIPTION = errormsg,
  361. EXECUTEDATE = DateTime.Now
  362. };
  363. SugarBase.DB.Insertable(task_dtl).ExecuteReturnIdentity();
  364. }
  365. }
  366. }
  367. }
  368. catch (Exception ex)
  369. {
  370. LogMessageHelper.RecordLogMessage(ex);
  371. }
  372. return wcstask;
  373. }
  374. public static bool WCS_GetOutTask(GetOutTaskParam param)
  375. {
  376. bool result = false;
  377. WCS_TASK wcstask = null;
  378. try
  379. {
  380. var reply = Current.WmsInterface.I_WCS_GetOutTask(param);
  381. if (reply.ResType)
  382. {
  383. if (!string.IsNullOrWhiteSpace(param.Memo1))
  384. {
  385. if(param.Memo1.Trim()=="1")
  386. {
  387. var agvtask = Current.AgvTaskSet.FirstOrDefault(v => v.Task_Id.ToString() == param.OutId);
  388. if (agvtask != null)
  389. {
  390. DateTime dt = SugarBase.DB.GetDate();
  391. int task_id = Convert.ToInt32(param.OutId);
  392. SugarBase.DB.Updateable<Middle_AGVTask>(it => new Middle_AGVTask()
  393. {
  394. Task_WcsStatus = 5,
  395. Task_UpdateUser = "wcs",
  396. Task_UpdateDate = dt
  397. })
  398. .Where(it => it.Task_Id == task_id).ExecuteCommand();
  399. }
  400. result = true;
  401. return result;
  402. }
  403. }
  404. if (string.IsNullOrWhiteSpace(reply.WMSTaskNum))
  405. {
  406. throw new Exception(string.Format("工位[{0}]申请出库任务反馈WMS任务号不能为空。", param.OutEndPostion));
  407. }
  408. if (reply.TaskType <= 0)
  409. {
  410. throw new Exception(string.Format("工位[{0}]申请出库任务反馈任务类型必须大于零。", param.OutEndPostion));
  411. }
  412. if (string.IsNullOrWhiteSpace(reply.OutWareCellNo))
  413. {
  414. throw new Exception(string.Format("工位[{0}]申请出库任务反馈出库位置不能为空。", param.OutEndPostion));
  415. }
  416. if (string.IsNullOrWhiteSpace(reply.WareHouseName))
  417. {
  418. throw new Exception(string.Format("工位[{0}]申请出库任务反馈仓库不能为空。", param.OutEndPostion));
  419. }
  420. if (string.IsNullOrWhiteSpace(reply.ContainerBarCode))
  421. {
  422. throw new Exception(string.Format("工位[{0}]申请出库任务反馈条码编号不能为空。", param.OutEndPostion));
  423. }
  424. if (reply.TaskType == 2 && string.IsNullOrWhiteSpace(reply.TunnelNum))
  425. {
  426. throw new Exception(string.Format("工位[{0}]申请出库任务反馈巷道号不能为空。", param.OutEndPostion));
  427. }
  428. if (reply.TASK_STACKINGTYPE <= 0 && (param.OutEndPostion == "1251" || param.OutEndPostion == "1261" || param.OutEndPostion == "1226" || param.OutEndPostion == "1234" || param.OutEndPostion == "1257" || param.OutEndPostion == "1252" || param.OutEndPostion == "1231" || param.OutEndPostion == "1258" || param.OutEndPostion == "1278" || param.OutEndPostion == "1283"))
  429. {
  430. throw new Exception(string.Format("工位[{0}]申请出库任务[1]垛型存在问题,传递值必须大于零。", param.OutEndPostion, reply.WMSTaskNum));
  431. }
  432. if (string.IsNullOrWhiteSpace(reply.PalletizingBoxSize) && Convert.ToInt32(reply.PalletizingBoxSize) <= 0 && (param.OutEndPostion == "1251" || param.OutEndPostion == "1261" || param.OutEndPostion == "1226" || param.OutEndPostion == "1234" || param.OutEndPostion == "1257" || param.OutEndPostion == "1252" || param.OutEndPostion == "1231" || param.OutEndPostion == "1258" || param.OutEndPostion == "1278" || param.OutEndPostion == "1283"))
  433. {
  434. throw new Exception(string.Format("工位[{0}]申请出库任务[1]箱子尺寸存在问题,传递值必须大于零。", param.OutEndPostion, reply.WMSTaskNum));
  435. }
  436. var task = SugarBase.DB.Queryable<WCS_TASK>().First(v => v.TASK_WMSNO == reply.WMSTaskNum);
  437. if (task == null)
  438. {
  439. var agvtask = Current.AgvTaskSet.FirstOrDefault(v => v.Task_Id.ToString() == param.OutId);
  440. string msg = TryCachHelper.TryTranExecute((db) =>
  441. {
  442. if (agvtask != null)
  443. {
  444. DateTime dt = db.GetDate();
  445. int task_id = Convert.ToInt32(param.OutId);
  446. db.Updateable<Middle_AGVTask>(it => new Middle_AGVTask()
  447. {
  448. Task_WcsStatus = 5,
  449. Task_UpdateUser = "wcs",
  450. Task_UpdateDate = dt
  451. })
  452. .Where(it => it.Task_Id == task_id).ExecuteCommand();
  453. }
  454. //添加wcs任务
  455. wcstask = new WCS_TASK();
  456. wcstask.TASK_WMSNO = reply.WMSTaskNum;
  457. wcstask.TASK_COMTYPE = reply.TaskType;
  458. wcstask.TASK_SYSTYPE = "WMS";
  459. wcstask.TASK_POSIDFROM = reply.OutWareCellNo;//起点地址
  460. wcstask.TASK_POSIDCUR = reply.OutWareCellNo;
  461. wcstask.TASK_POSIDNEXT = reply.OutWareCellNo;
  462. wcstask.TASK_POSIDMOVE = "";
  463. wcstask.TASK_PRIORITY = reply.Priority;
  464. wcstask.TASK_WKSTATUS = 0;
  465. wcstask.TASK_WHID = reply.WareHouseName;
  466. wcstask.TASK_ADDUSERNO = "WMS";
  467. wcstask.TASK_ADDDATETIME = DateTime.Now;
  468. wcstask.TASK_EDITUSERNO = "WMS";
  469. wcstask.TASK_EDITDATETIME = DateTime.Now;
  470. wcstask.TASK_NOTES = "";
  471. wcstask.TASK_RGVNO = "";
  472. wcstask.TASK_BOXBARCODE = reply.ContainerBarCode;
  473. wcstask.TASK_POSIDTO = param.OutEndPostion;
  474. wcstask.TASK_PRIORITY = reply.Priority;
  475. wcstask.TASK_ITEM8 = param.OutId;
  476. wcstask.TASK_ITEM9 = reply.Memo4;
  477. wcstask.TASK_ITEM10 = reply.Memo5;
  478. wcstask.PalletizingSonTraySize = reply.PalletizingSonTraySize;
  479. wcstask.PalletizingBoxSize = reply.PalletizingBoxSize;
  480. wcstask.SonTrayColorNo = reply.SonTrayColorNo;
  481. wcstask.TASK_MatureDate = reply.MatureDateLength;
  482. wcstask.TASK_WEIGHT = reply.TASK_WEIGHT;
  483. wcstask.TASK_STACKINGTYPE = reply.TASK_STACKINGTYPE;
  484. if (param.TASK_MatureDate == 12 && wcstask.TASK_MatureDate == 48)
  485. {
  486. wcstask.MatureNum = 4;
  487. }
  488. else
  489. {
  490. wcstask.MatureNum = 1;
  491. }
  492. if (wcstask.TASK_BOXBARCODE.Substring(0, 2) == "SH")
  493. {
  494. wcstask.TASK_ITEM2 = "2";
  495. }
  496. else if (wcstask.TASK_BOXBARCODE.Substring(0, 3) == "TPC")
  497. {
  498. wcstask.TASK_ITEM2 = "1";
  499. }
  500. else
  501. {
  502. wcstask.TASK_ITEM2 = "3";
  503. }
  504. if (string.IsNullOrWhiteSpace(reply.TunnelNum))
  505. {
  506. //wcstask.TASK_SRMNO = reply.EndPostion;
  507. }
  508. else
  509. {
  510. wcstask.TASK_FromTunnelNum = reply.TunnelNum;
  511. wcstask.TASK_SRMNO = Current.SysSets.Where(v => v.SET_ID.Contains("Tunnel")).FirstOrDefault(v => v.SET_VALUE == reply.TunnelNum).SET_TYPE;
  512. }
  513. int id = db.Insertable(wcstask).ExecuteReturnIdentity();
  514. if (id <= 0)
  515. {
  516. throw new Exception(string.Format("WMS任务[{0}]添加WCS任务失败", reply.WMSTaskNum));
  517. }
  518. });
  519. if (string.IsNullOrWhiteSpace(msg))
  520. {
  521. result = true;
  522. }
  523. else
  524. {
  525. throw new Exception(string.Format("WMS任务[{0}]添加WCS任务失败,消息[{1}]", reply.WMSTaskNum, msg));
  526. }
  527. }
  528. //var task = SugarBase.DB.Queryable<WCS_TASK>().First(v => v.TASK_WMSNO == reply.WMSTaskNum);
  529. //if (task == null)
  530. //{
  531. // //添加wcs任务
  532. // wcstask = new WCS_TASK();
  533. // wcstask.TASK_WMSNO = reply.WMSTaskNum;
  534. // wcstask.TASK_COMTYPE = reply.TaskType;
  535. // wcstask.TASK_SYSTYPE = "WMS";
  536. // wcstask.TASK_POSIDFROM = reply.OutWareCellNo;//起点地址
  537. // wcstask.TASK_POSIDCUR = reply.OutWareCellNo;
  538. // wcstask.TASK_POSIDNEXT = reply.OutWareCellNo;
  539. // wcstask.TASK_POSIDMOVE = "";
  540. // wcstask.TASK_PRIORITY = reply.Priority;
  541. // wcstask.TASK_WKSTATUS = 0;
  542. // wcstask.TASK_WHID = reply.WareHouseName;
  543. // wcstask.TASK_ADDUSERNO = "WMS";
  544. // wcstask.TASK_ADDDATETIME = DateTime.Now;
  545. // wcstask.TASK_EDITUSERNO = "WMS";
  546. // wcstask.TASK_EDITDATETIME = DateTime.Now;
  547. // wcstask.TASK_NOTES = "";
  548. // wcstask.TASK_RGVNO = "";
  549. // wcstask.TASK_BOXBARCODE = reply.ContainerBarCode;
  550. // wcstask.TASK_POSIDTO = param.OutEndPostion;
  551. // wcstask.TASK_PRIORITY = reply.Priority;
  552. // wcstask.TASK_ITEM8 = param.OutId;
  553. // wcstask.TASK_ITEM9 = reply.Memo4;
  554. // wcstask.TASK_ITEM10 = reply.Memo5;
  555. // if (wcstask.TASK_BOXBARCODE.Substring(0, 2) == "SH")
  556. // {
  557. // wcstask.TASK_ITEM2 = "2";
  558. // }
  559. // else if (wcstask.TASK_BOXBARCODE.Substring(0, 3) == "TPC")
  560. // {
  561. // wcstask.TASK_ITEM2 = "1";
  562. // }
  563. // else
  564. // {
  565. // wcstask.TASK_ITEM2 = "3";
  566. // }
  567. // if (string.IsNullOrWhiteSpace(reply.TunnelNum))
  568. // {
  569. // //wcstask.TASK_SRMNO = reply.EndPostion;
  570. // }
  571. // else
  572. // {
  573. // wcstask.TASK_FromTunnelNum = reply.TunnelNum;
  574. // wcstask.TASK_SRMNO = Current.SysSets.Where(v => v.SET_ID.Contains("Tunnel")).FirstOrDefault(v => v.SET_VALUE == reply.TunnelNum).SET_TYPE;
  575. // }
  576. // int id = SugarBase.DB.Insertable(wcstask).ExecuteReturnIdentity();
  577. // if (id <= 0)
  578. // {
  579. // throw new Exception(string.Format("WMS任务[{0}]添加WCS任务失败", reply.WMSTaskNum));
  580. // }
  581. // else
  582. // {
  583. // result = true;
  584. // }
  585. //}
  586. }
  587. else
  588. {
  589. var msg = string.Format("目标位置[{0}]获取出库任务失败,原因:[{1}]", param.OutEndPostion, reply.ResMessage);
  590. throw new Exception(msg);
  591. }
  592. }
  593. catch (Exception ex)
  594. {
  595. AddLedErrorMsg(param.OutEndPostion, ex.Message, 0);
  596. LogMessageHelper.RecordLogMessage(ex);
  597. }
  598. return result;
  599. }
  600. private static string CheckGetInTask(GetInTaskParam param, GetInTaskReply reply)
  601. {
  602. string errorMsg = string.Empty;
  603. if (reply == null)
  604. {
  605. throw new Exception(string.Format("托盘[{0}]调用WMS入库接口,反馈的对象为空。", param.ContainerBarCode));
  606. }
  607. if (reply.ResType)
  608. {
  609. if (string.IsNullOrWhiteSpace(reply.WMSTaskNum))
  610. {
  611. errorMsg = string.Format("托盘[{0}]调用WMS入库接口,反馈的WMS任务号不能为空。", param.ContainerBarCode);
  612. }
  613. else if (string.IsNullOrWhiteSpace(reply.EndPostion))
  614. {
  615. errorMsg = string.Format("托盘[{0}]调用WMS入库接口,反馈的目标地址不能为空。", param.ContainerBarCode);
  616. }
  617. else if (string.IsNullOrWhiteSpace(reply.EndPostion))
  618. {
  619. errorMsg = string.Format("托盘[{0}]调用WMS入库接口,反馈的目标地址不能为空。", param.ContainerBarCode);
  620. }
  621. else if (string.IsNullOrWhiteSpace(reply.WareHouseName))
  622. {
  623. errorMsg = string.Format("托盘[{0}]调用WMS入库接口,反馈的仓库名称不能为空。", param.ContainerBarCode);
  624. }
  625. else if (reply.TASK_WEIGHT < 1 && param.EquipmentNo == "1390")
  626. {
  627. errorMsg = string.Format("料箱[{0}]调用WMS入库接口,反馈的重量要大于0。", param.ContainerBarCode);
  628. }
  629. else if (reply.TASK_STACKINGTYPE < 1 && param.EquipmentNo == "1390")
  630. {
  631. errorMsg = string.Format("料箱[{0}]调用WMS入库接口,反馈的垛型要大于0。", param.ContainerBarCode);
  632. }
  633. //else if (string.IsNullOrWhiteSpace(reply.Memo1) && param.EquipmentNo == "1200" && param.ContainerBarCode.Contains("TPA"))
  634. //{
  635. // errorMsg = string.Format("托盘[{0}]18#调用WMS入库接口,反馈的是否缠膜不能为空。", param.ContainerBarCode);
  636. //}
  637. else if (!string.IsNullOrWhiteSpace(param.Memo1))
  638. {
  639. if (string.IsNullOrWhiteSpace(reply.TunnelNum) || reply.TunnelNum.Trim() == "0")
  640. {
  641. errorMsg = string.Format("托盘[{0}]调用WMS入库接口,没有返回巷道。", param.ContainerBarCode);
  642. }
  643. if (param.Memo1.Trim() == "2")
  644. {
  645. if (reply.EndPostion.Length < 10)
  646. {
  647. errorMsg = string.Format("托盘[{0}]调用WMS入库接口,没有分配货位。", param.ContainerBarCode);
  648. }
  649. }
  650. else if (param.Memo1.Trim() == "1")
  651. {
  652. }
  653. else
  654. {
  655. errorMsg = string.Format("托盘[{0}]调用WMS入库接口传递参数Memo1[{1}]错误.", param.ContainerBarCode, param.Memo1);
  656. }
  657. }
  658. }
  659. else
  660. {
  661. if (reply == null)
  662. {
  663. errorMsg = string.Format("托盘[{0}]调用WMS入库接口,反馈的对象为空。", param.ContainerBarCode);
  664. }
  665. else
  666. {
  667. errorMsg = string.Format("位置[{0}]条码[{1}]获取入库任务失败,反馈结果:[{2}]", param.EquipmentNo, param.ContainerBarCode, reply.ResMessage);
  668. }
  669. }
  670. return errorMsg;
  671. }
  672. /// <summary>
  673. /// 获取入库任务
  674. /// </summary>
  675. /// <param name="param"></param>
  676. public static WCS_TASK GetInTask_2(GetInTaskParam param)
  677. {
  678. WCS_TASK wcstask = null;
  679. try
  680. {
  681. if(!string.IsNullOrWhiteSpace(param.ContainerBarCode))
  682. {
  683. wcstask = SugarBase.DB.Queryable<WCS_TASK>().First(v => v.TASK_BOXBARCODE == param.ContainerBarCode);
  684. }
  685. if (wcstask == null)
  686. {
  687. var reply = Current.WmsInterface.I_WCS_GetInTask(param);
  688. if (reply.ResType)
  689. {
  690. if (string.IsNullOrWhiteSpace(reply.EndPostion))
  691. {
  692. throw new Exception(string.Format("托盘[{0}]调用WMS入库接口返回成功,但是没有返回目标地址。", reply.EndPostion));
  693. }
  694. //添加wcs任务
  695. wcstask = new WCS_TASK();
  696. wcstask.TASK_WMSNO = reply.WMSTaskNum;
  697. wcstask.TASK_COMTYPE = reply.TaskType;
  698. wcstask.TASK_SYSTYPE = "WMS";
  699. wcstask.TASK_POSIDFROM = param.EquipmentNo;//起点地址
  700. wcstask.TASK_POSIDCUR = param.EquipmentNo;
  701. wcstask.TASK_POSIDNEXT = param.EquipmentNo;
  702. wcstask.TASK_POSIDMOVE = "";
  703. wcstask.TASK_PRIORITY = reply.Priority;
  704. wcstask.TASK_WKSTATUS = 0;
  705. wcstask.TASK_WHID = reply.WareHouseName;
  706. wcstask.TASK_ADDUSERNO = "WMS";
  707. wcstask.TASK_ADDDATETIME = DateTime.Now;
  708. wcstask.TASK_EDITUSERNO = "WMS";
  709. wcstask.TASK_EDITDATETIME = DateTime.Now;
  710. wcstask.TASK_NOTES = "";
  711. wcstask.TASK_RGVNO = "";
  712. wcstask.TASK_BOXBARCODE = param.ContainerBarCode;
  713. if (string.IsNullOrWhiteSpace(param.Memo1))
  714. {
  715. wcstask.TASK_POSIDTO = reply.EndPostion;
  716. wcstask.TASK_SRMNO = reply.EndPostion;
  717. }
  718. else if (param.Memo1.Trim() == "1")
  719. {
  720. if (string.IsNullOrWhiteSpace(reply.TunnelNum) || reply.TunnelNum.Trim() == "0")
  721. {
  722. throw new Exception(string.Format("托盘[{0}]申请入库没有分配巷道,生成WCS任务失败。", param.ContainerBarCode));
  723. }
  724. else
  725. {
  726. string srmno = string.Empty;
  727. wcstask.TASK_EndTunnelNum = ConveyorHelper.QueryTunnel(wcstask.TASK_WMSNO, param.EquipmentNo, out srmno);
  728. wcstask.TASK_POSIDTO = wcstask.TASK_EndTunnelNum;
  729. wcstask.TASK_SRMNO = srmno;
  730. }
  731. }
  732. else if (param.Memo1.Trim() == "2")
  733. {
  734. wcstask.TASK_POSIDTO = reply.EndPostion;
  735. wcstask.TASK_EndTunnelNum = reply.TunnelNum;
  736. wcstask.TASK_SRMNO = Current.SysSets.Where(v => v.SET_ID.Contains("Tunnel")).FirstOrDefault(v => v.SET_VALUE == reply.TunnelNum).SET_VALUE;
  737. }
  738. else
  739. {
  740. throw new Exception(string.Format("托盘[{0}]调用WMS入库接口传递参数Memo1错误.", param.ContainerBarCode));
  741. }
  742. int id = SugarBase.DB.Insertable(wcstask).ExecuteReturnIdentity();
  743. if (id <= 0)
  744. {
  745. throw new Exception(string.Format("WMS任务[{0}]添加WCS任务失败", reply.WMSTaskNum));
  746. }
  747. else
  748. {
  749. wcstask.TASK_NO = id;
  750. }
  751. }
  752. else
  753. {
  754. string msg = string.Format("位置[{0}]条码[{1}]获取入库任务失败,反馈结果:[{2}]",param.EquipmentNo, param.ContainerBarCode, reply.ResMessage);
  755. LogMessageHelper.RecordLogMessage(msg);
  756. }
  757. }
  758. }
  759. catch (Exception ex)
  760. {
  761. //ThreadHelper.TaskThread(UploadExcTask, new { EquipmentNo = param.EquipmentNo, Alaram = ex.Message });
  762. LogMessageHelper.RecordLogMessage(ex);
  763. }
  764. return wcstask;
  765. }
  766. /// <summary>
  767. /// 上传设备异常信息
  768. /// </summary>
  769. //public static void UploadExcTask(UploadExcTaskParam param)
  770. //{
  771. // try
  772. // {
  773. // Log4netHelper.Logger_Info.InfoFormat(string.Format("开始:输送线[{0}]报警信息[{1}]上传WMS。", param.EquipmentNo, param.ExcMessage));
  774. // var reply = Current.WmsInterface.I_WCS_UploadExcTask(param);
  775. // if (reply.ResType)
  776. // {
  777. // Log4netHelper.Logger_Info.InfoFormat(string.Format("成功:输送线[{0}]报警信息[{1}]上传WMS。", param.EquipmentNo, param.ExcMessage));
  778. // }
  779. // else
  780. // {
  781. // throw new Exception(string.Format("失败:输送线[{0}]报警信息[{1}]上传WMS。原因:[{2}]", param.EquipmentNo, param.ExcMessage, reply.ResMessage));
  782. // }
  783. // }
  784. // catch (Exception ex)
  785. // {
  786. // Log4netHelper.Logger_Error.ErrorFormat(ex.ToString());
  787. // }
  788. // finally
  789. // {
  790. // Log4netHelper.Logger_Info.InfoFormat(string.Format("结束:输送线[{0}]报警信息[{1}]上传WMS。", param.EquipmentNo, param.ExcMessage));
  791. // }
  792. //}
  793. /// <summary>
  794. /// 添加异常信息
  795. /// </summary>
  796. /// <param name="db"></param>
  797. /// <param name="equipmentNo"></param>
  798. /// <param name="alaram"></param>
  799. /// <param name="task_no"></param>
  800. public static void AddLedErrorMsg(SqlSugarClient db, string equipmentNo, string alaram, int task_no, int alaramCount = 10)
  801. {
  802. int wmstask_no = 0;
  803. var task = db.Queryable<WCS_TASK>().First(v => v.TASK_NO == task_no);
  804. if (task != null)
  805. {
  806. wmstask_no = Convert.ToInt32(task.TASK_WMSNO);
  807. }
  808. CommonData.AddLedErrorMsg(db, equipmentNo, alaram, task_no, wmstask_no, alaramCount);
  809. }
  810. /// <summary>
  811. /// 添加异常信息
  812. /// </summary>
  813. /// <param name="db"></param>
  814. /// <param name="equipmentNo"></param>
  815. /// <param name="alaram"></param>
  816. /// <param name="task_no"></param>
  817. public static void AddLedErrorMsg(string equipmentNo, string alaram, int task_no)
  818. {
  819. int wmstask_no = 0;
  820. var task = Current.TaskSet.FirstOrDefault(v => v.TASK_NO == task_no);
  821. if (task != null)
  822. {
  823. wmstask_no = Convert.ToInt32(task.TASK_WMSNO);
  824. }
  825. TryCachHelper.TryExecute((db) => {
  826. CommonData.AddLedErrorMsg(db, equipmentNo, alaram, task_no, wmstask_no);
  827. });
  828. }
  829. private static int _upLoadExcToWMS = 0;
  830. /// <summary>
  831. /// 上传设备异常信息
  832. /// </summary>
  833. public static void UpLoadExcToWMS()
  834. {
  835. if (Interlocked.Exchange(ref _upLoadExcToWMS, 1) == 0)
  836. {
  837. string result = TryCachHelper.TryExecute((db) =>
  838. {
  839. var ExcMsg = db.Queryable<WCS_LEDALARMSMSG>().First(v => v.LED_ISUPLOADWMSFINISH == false);
  840. if (ExcMsg != null)
  841. {
  842. var param = new UploadExcTaskParam();
  843. param.OutId = ExcMsg.LED_ID;
  844. param.EquipmentNo = ExcMsg.LED_CONVYORNO;
  845. param.WCSTaskNum = ExcMsg.LED_WCSTASK_NO.ToString();
  846. param.WMSTaskNum = ExcMsg.LED_WMSTASK_NO.ToString();
  847. param.ExcCode = ExcMsg.LED_ALARMSMSG;
  848. param.ExcMessage = ExcMsg.LED_ALARMSMSG;
  849. var reply = Current.WmsInterface.I_WCS_UploadExcTask(param);
  850. if (reply.ResType)
  851. {
  852. //修改上传完成
  853. db.Updateable<WCS_LEDALARMSMSG>(it => new WCS_LEDALARMSMSG() { LED_ISUPLOADWMSFINISH = true, LED_UPDATETIME = DateTime.Now })
  854. .Where(it => it.LED_ID == ExcMsg.LED_ID)
  855. .ExecuteCommand();
  856. }
  857. }
  858. });
  859. Interlocked.Exchange(ref _upLoadExcToWMS, 0);
  860. }
  861. }
  862. private static int _putDevInfoToWMS = 0;
  863. /// <summary>
  864. /// 上传设PLC备信息
  865. /// </summary>
  866. public static void PutDevInfoToWMS()
  867. {
  868. if (Interlocked.Exchange(ref _putDevInfoToWMS, 1) == 0)
  869. {
  870. Thread.Sleep(2000);
  871. string result = TryCachHelper.TryTranExecute((db) =>
  872. {
  873. List<PutDevInfoParam> DevList = new List<PutDevInfoParam>();
  874. //var EquState = db.Queryable<WCS_EQUIPMENTINFO>().Where(v => v.Equ_Type == "srm").ToList();
  875. var EquState = Current.PlcSet.Where(v => v.PLC_EQUIPMENTTYPE == "srm" && v.PLC_WCSSYSTEM == Current.WcsSystem).ToList();
  876. foreach (var item in EquState)
  877. {
  878. var srmState = item.WCS_EquipmentInfoSet.FirstOrDefault(v => v.Equ_No == item.PLC_NAME);
  879. var param = new PutDevInfoParam();
  880. param.STA_EQUIPMENTNO = item.PLC_NAME;
  881. if (!string.IsNullOrWhiteSpace(srmState.EquSignal_Srm.SrmFault))
  882. {
  883. param.STA_ALARMS = string.Format("设备[{0}][{1}]", item.PLC_NAME, srmState.EquSignal_Srm.SrmFault);
  884. param.STA_ALARMSMSG = string.Format("设备[{0}][{1}]", item.PLC_NAME, srmState.EquSignal_Srm.SrmFault);
  885. }
  886. param.STA_DATA = srmState.EquSignal_Srm.ToJson();
  887. DevList.Add(param);
  888. }
  889. var convStatue = Current.PlcSet.Where(v => v.PLC_EQUIPMENTTYPE != "srm" && v.PLC_WCSSYSTEM == Current.WcsSystem).ToList();
  890. foreach (var item in convStatue)
  891. {
  892. foreach (var equinfo in item.WCS_EquipmentInfoSet)
  893. {
  894. var param = new PutDevInfoParam();
  895. if (equinfo.Equ_Type == EquipmentType.conveyor.ToString())
  896. {
  897. param.STA_EQUIPMENTNO = equinfo.Equ_No;
  898. string alarms = equinfo.EquSignal_Conv.ConvFault.ToString();
  899. if (string.IsNullOrWhiteSpace(alarms) == false && alarms != "0")
  900. {
  901. param.STA_ALARMS = string.Format("设备[{0}][{1}]", equinfo.Equ_No, alarms);
  902. param.STA_ALARMSMSG = string.Format("设备[{0}][{1}]", equinfo.Equ_No, alarms);
  903. }
  904. }
  905. else if (equinfo.Equ_Type == EquipmentType.rgv.ToString())
  906. {
  907. param.STA_EQUIPMENTNO = equinfo.Equ_No;
  908. string alarmagv= equinfo.EquSignal_Rgv.AlarmFault;
  909. if (string.IsNullOrWhiteSpace(alarmagv) == false && alarmagv != "0")
  910. {
  911. param.STA_ALARMS = string.Format("设备[{0}][{1}]", equinfo.Equ_No, alarmagv);
  912. param.STA_ALARMSMSG = string.Format("设备[{0}][{1}]", equinfo.Equ_No, alarmagv);
  913. }
  914. }
  915. DevList.Add(param);
  916. }
  917. }
  918. var reply = Current.WmsInterface.I_WCS_PutDevInfo(DevList);
  919. string resMessage = "接口返回Null";
  920. if (reply != null) resMessage = reply.ResMessage;
  921. if (reply == null || reply.ResType == false)
  922. {
  923. LogMessageHelper.RecordLogMessage(string.Format("上传设备PLC信息失败,原因:[{0}]。", resMessage));
  924. }
  925. });
  926. Interlocked.Exchange(ref _putDevInfoToWMS, 0);
  927. }
  928. }
  929. /// <summary>
  930. /// 称重上传
  931. /// </summary>
  932. /// <param name="param"></param>
  933. public static bool GetWeight(GetWeightParam param)
  934. {
  935. bool result = true;
  936. try
  937. {
  938. var reply = Current.WmsInterface.I_WCS_GetWeight(param);
  939. if (reply.ResType)
  940. {
  941. var task = Current.TaskSet.FirstOrDefault(v => v.TASK_WMSNO == param.WMSTaskNum);
  942. //修改任务,添加重量
  943. string resultmsg = TryCachHelper.TryTranExecute((db) =>
  944. {
  945. db.Updateable<WCS_TASK>(it => new WCS_TASK()
  946. {
  947. TASK_WKSTATUS = 2,
  948. TASK_GrossWeight = param.Weight,
  949. TASK_EDITDATETIME = DateTime.Now
  950. })
  951. .Where(it => it.TASK_NO == task.TASK_NO).ExecuteCommand();
  952. string msg = string.Format("称重任务[{0}]已称重,重量[{1}]克。", task.TASK_NO, param.Weight);
  953. CommonData.AddWCS_TASK_DTL(db, task.TASK_NO, task.TASK_NO, task.TASK_POSIDCUR, task.TASK_POSIDNEXT, msg);
  954. });
  955. if (!string.IsNullOrWhiteSpace(resultmsg))
  956. {
  957. throw new Exception(resultmsg);
  958. }
  959. }
  960. else
  961. {
  962. string error = string.Format("任务[{0}]重量[{1}]上传失败,原因:[{2}]", param.WMSTaskNum, param.Weight, reply.ResMessage);
  963. throw new Exception(error);
  964. }
  965. }
  966. catch (Exception ex)
  967. {
  968. result = false;
  969. LogMessageHelper.RecordLogMessage(ex.Message, ex);
  970. }
  971. return result;
  972. }
  973. #region WMS接口调用
  974. static List<int> AssignSrmTaskNoSet = new List<int>();
  975. public static void AssignSrm(WCS_TASK task)
  976. {
  977. if (AssignSrmTaskNoSet.Contains(task.TASK_NO))
  978. {
  979. Log4netHelper.Logger_Info.InfoFormat("任务[{0}]方法[AssignSrm]调用失败,WMS接口[I_WCS_GetTunnelList]调用正在执行中", task.TASK_NO);
  980. }
  981. else
  982. {
  983. AssignSrmTaskNoSet.Add(task.TASK_NO);
  984. ConveyorHelper.AssignSrm(task);
  985. AssignSrmTaskNoSet.Remove(task.TASK_NO);
  986. }
  987. }
  988. static List<int> PreparatoryAssignSrmTaskNoSet = new List<int>();
  989. public static void PreparatoryAssignSrmTunnel(WCS_TASK task)
  990. {
  991. if (PreparatoryAssignSrmTaskNoSet.Contains(task.TASK_NO))
  992. {
  993. Log4netHelper.Logger_Info.InfoFormat("任务[{0}]方法[AssignSrm]调用失败,WMS接口[I_WCS_GetTunnelList]调用正在执行中", task.TASK_NO);
  994. }
  995. else
  996. {
  997. PreparatoryAssignSrmTaskNoSet.Add(task.TASK_NO);
  998. ConveyorHelper.PreparatoryAssignSrmTunnel(task);
  999. PreparatoryAssignSrmTaskNoSet.Remove(task.TASK_NO);
  1000. }
  1001. }
  1002. static List<string> TrayList = new List<string>();
  1003. public static WCS_TASK GetWcsInTask(GetInTaskParam param)
  1004. {
  1005. WCS_TASK task = null;
  1006. if (TrayList.Contains(param.ContainerBarCode))
  1007. {
  1008. Log4netHelper.Logger_Info.InfoFormat("托盘[{0}]方法[GetInTask]调用失败,WMS接口[I_WCS_GetInTask]调用正在执行中", param.ContainerBarCode);
  1009. }
  1010. else
  1011. {
  1012. TrayList.Add(param.ContainerBarCode);
  1013. task = GetInTask(param);
  1014. TrayList.Remove(param.ContainerBarCode);
  1015. }
  1016. return task;
  1017. }
  1018. static List<string> AgvTaskNoSet = new List<string>();
  1019. public static void GetOutTask(GetOutTaskParam param)
  1020. {
  1021. if (AgvTaskNoSet.Contains(param.OutId))
  1022. {
  1023. Log4netHelper.Logger_Info.InfoFormat("呼叫位置[{0}]方法[GetOutTask]调用失败,WMS接口[I_WCS_GetOutTask]调用正在执行中", param.OutEndPostion);
  1024. }
  1025. else
  1026. {
  1027. AgvTaskNoSet.Add(param.OutId);
  1028. WCS_GetOutTask(param);
  1029. AgvTaskNoSet.Remove(param.OutId);
  1030. }
  1031. }
  1032. static List<string> GetWeightSet = new List<string>();
  1033. public static void ProInGetWeight(GetWeightParam param)
  1034. {
  1035. if (GetWeightSet.Contains(param.WMSTaskNum))
  1036. {
  1037. Log4netHelper.Logger_Info.InfoFormat("任务[{0}]调用方法[GetWeight]调用失败,WMS接口[I_WCS_GetWeight]调用正在执行中", param.WMSTaskNum);
  1038. }
  1039. else
  1040. {
  1041. GetWeightSet.Add(param.WMSTaskNum);
  1042. GetWeight(param);
  1043. GetWeightSet.Remove(param.WMSTaskNum);
  1044. }
  1045. }
  1046. #endregion;
  1047. private static int _putUpdateUnexecuteTask = 0;
  1048. /// <summary>
  1049. /// 更新未执行任务
  1050. /// </summary>
  1051. public static void UpdateUnexecuteTask()
  1052. {
  1053. if (Interlocked.Exchange(ref _putUpdateUnexecuteTask, 1) == 0)
  1054. {
  1055. Thread.Sleep(90000);
  1056. try
  1057. {
  1058. TryCachHelper.TryExecute((db) =>
  1059. {
  1060. //更新每台堆垛机未执行任务数量
  1061. var srmName = db.Queryable<WCS_PLC>().Where(v => v.PLC_EQUIPMENTTYPE == "srm").ToList();
  1062. foreach (var item in srmName)
  1063. {
  1064. var taskSRMCount = db.Queryable<WCS_TASK>().Where(v => (v.TASK_WKSTATUS == 0 || v.TASK_WKSTATUS == 1 || v.TASK_WKSTATUS == 5) && v.TASK_SRMNO == item.PLC_NAME).ToList();
  1065. //更新未执行任务数量
  1066. db.Updateable<WCS_PLC>(it => new WCS_PLC() { PLC_UNEXECUTETASK = taskSRMCount.Count }).Where(it => it.PLC_NAME == item.PLC_NAME).ExecuteCommand();
  1067. }
  1068. var rgvName = db.Queryable<WCS_PLC>().Where(v => v.PLC_EQUIPMENTTYPE == "rgv").ToList();
  1069. foreach (var item in rgvName)
  1070. {
  1071. var OutInMat = db.Queryable<WCS_RGVOutInInfo>().Where(v => v.RGVOUTIN_RGVNO == item.PLC_NAME && (v.RGVOUTIN_OUTINTYPE == "OnMat" || v.RGVOUTIN_OUTINTYPE == "OnUpMat")).Select(v => v.RGVOUTIN_CONVNO).ToList();
  1072. var taskRGVCount = db.Queryable<WCS_TASK>().Where(v => (OutInMat.Contains(v.TASK_POSIDCUR) && v.TASK_POSIDCUR == v.TASK_POSIDNEXT) || (v.TASK_WKSTATUS == 7 && v.TASK_RGVNO == item.PLC_NAME)).ToList();
  1073. db.Updateable<WCS_PLC>(it => new WCS_PLC() { PLC_UNEXECUTETASK = taskRGVCount.Count }).Where(it => it.PLC_NAME == item.PLC_NAME).ExecuteCommand();
  1074. }
  1075. });
  1076. }
  1077. catch (Exception ex)
  1078. {
  1079. LogMessageHelper.RecordLogMessage(ex);
  1080. }
  1081. finally
  1082. {
  1083. Interlocked.Exchange(ref _putTaskStep, 0);
  1084. }
  1085. }
  1086. }
  1087. #endregion;
  1088. }
  1089. }