WmsApi.cs 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379
  1. using ServiceCenter;
  2. using ServiceCenter.Extensions;
  3. using ServiceCenter.Logs;
  4. using ServiceCenter.Redis;
  5. using ServiceCenter.WebApi;
  6. using WCS.WorkEngineering.WebApi.Models.AGV.Response;
  7. using WCS.WorkEngineering.WebApi.Models.WCS.Response;
  8. using WCS.WorkEngineering.WebApi.Models.WMS.Request;
  9. using WCS.WorkEngineering.WebApi.Models.WMS.Response;
  10. namespace WCS.WorkEngineering.WebApi.Controllers
  11. {
  12. /// <summary>
  13. /// AGV相关接口控制器
  14. /// </summary>
  15. public static class WmsApi
  16. {
  17. private static string _WMSUrl = null!;
  18. private static string _wareHouseId = null!;
  19. /// <summary>
  20. /// WMS URL
  21. /// </summary>
  22. public static string WMSUrl
  23. {
  24. get
  25. {
  26. _WMSUrl ??= RedisHub.Default.Check("WMSUrl");
  27. if (string.IsNullOrEmpty(_WMSUrl))
  28. {
  29. throw new KnownException($"请在Redis配置WMSUrl", LogLevelEnum.High);
  30. }
  31. return _WMSUrl;
  32. }
  33. }
  34. /// <summary>
  35. /// 仓库编号
  36. /// </summary>
  37. public static string wareHouseId = ServiceHub.WarehouseName;
  38. /// <summary>
  39. /// 上传重量等信息
  40. /// </summary>
  41. /// <param name="taskCode">任务号</param>
  42. /// <param name="weight">rfid</param>
  43. /// <returns></returns>
  44. public static SRes WcsUploadInfo(int taskCode, decimal weight) => WcsUploadInfo(taskCode, weight, "");
  45. /// <summary>
  46. /// 上传重量等信息
  47. /// </summary>
  48. /// <param name="taskCode">任务号</param>
  49. /// <param name="RFID">重量</param>
  50. /// <returns></returns>
  51. public static SRes WcsUploadInfo(int taskCode, string RFID) => WcsUploadInfo(taskCode, 0, RFID);
  52. /// <summary>
  53. /// 上传重量等信息
  54. /// </summary>
  55. /// <param name="taskCode">任务号</param>
  56. /// <param name="weight">重量</param>
  57. /// <param name="RFID">rfid</param>
  58. /// <returns></returns>
  59. /// <exception cref="KnownException"></exception>
  60. public static SRes WcsUploadInfo(int taskCode, decimal weight, string RFID)
  61. {
  62. var res = APICaller.CallApi2<SRes>(WMSUrl + "/api/Hj/WcsUploadInfo", new WcsUploadInfoRequest
  63. {
  64. TaskCode = taskCode,
  65. Weight = weight,
  66. RFID = RFID
  67. });
  68. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  69. {
  70. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  71. }
  72. return res;
  73. }
  74. /// <summary>
  75. /// 获取巷道
  76. /// </summary>
  77. /// <param name="wcsTaskNum">WMS任务ID</param>
  78. /// <returns></returns>
  79. /// <exception cref="Exception"></exception>
  80. public static SRes<string> GetTunnelPriorityList(int wcsTaskNum)
  81. {
  82. var res = APICaller.CallApi2<SRes<string>>(WMSUrl + "/api/Hj/GetTunnelPriorityList", new GetTunnelPriorityListRequest
  83. {
  84. TaskNum = wcsTaskNum,
  85. });
  86. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  87. {
  88. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  89. }
  90. return res;
  91. }
  92. /// <summary>
  93. /// 分配货位
  94. /// </summary>
  95. /// <param name="wcsTaskNum">WMS任务ID</param>
  96. /// <param name="tunnel">货位</param>
  97. /// <param name="device">设备号</param>
  98. /// <returns></returns>
  99. /// <exception cref="Exception"></exception>
  100. public static SRes<ApplyStockInLocResponse> GetLocalIn(int wcsTaskNum, string tunnel, string device)
  101. {
  102. var res = APICaller.CallApi2<SRes<ApplyStockInLocResponse>>(WMSUrl + "/api/Hj/ApplyStockInLoc", new ApplyStockInLocRequest
  103. {
  104. TaskNum = wcsTaskNum,
  105. TunnelNum = tunnel.GetLastDigit(),
  106. PickUpEquipmentNo = device.ToString(),
  107. });
  108. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  109. {
  110. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  111. }
  112. return res;
  113. }
  114. /// <summary>
  115. /// 堆垛机出库任务执行完成
  116. /// </summary>
  117. /// <param name="taskNum"></param>
  118. /// <returns></returns>
  119. /// <exception cref="KnownException"></exception>
  120. public static SRes<int> SrmPickOutCompleted(int taskNum)
  121. {
  122. var res = APICaller.CallApi2<SRes<int>>(WMSUrl + "/api/Hj/SrmPickOutCompleted", new SrmPickOutCompletedRequest
  123. {
  124. TaskNum = taskNum,
  125. });
  126. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  127. {
  128. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  129. }
  130. return res;
  131. }
  132. /// <summary>
  133. /// 一楼空工字轮申请出库
  134. /// </summary>
  135. /// <param name="outEndPostion">出库位置</param>
  136. /// <returns></returns>
  137. public static SRes ApplyStockOutTask(string outEndPostion) => ApplyStockOutTask(outEndPostion, 2);
  138. /// <summary>
  139. /// 申请出库任务
  140. /// </summary>
  141. /// <param name="outEndPostion">出库位置</param>
  142. /// <param name="outType">出库类型</param>
  143. /// <returns></returns>
  144. /// <exception cref="KnownException"></exception>
  145. public static SRes ApplyStockOutTask(string outEndPostion, int outType)
  146. {
  147. var request = new ApplyStockOutTaskRequest
  148. {
  149. OutEndPostion = outEndPostion,
  150. OutType = outType,
  151. WarehouseCode = wareHouseId,
  152. };
  153. switch (outEndPostion)
  154. {
  155. case "1012":
  156. request.Tunnel = "1";
  157. break;
  158. case "1014":
  159. request.Tunnel = "2";
  160. break;
  161. case "1016":
  162. request.Tunnel = "3";
  163. break;
  164. }
  165. var res = APICaller.CallApi2<SRes>(WMSUrl + "/api/Hj/ApplyStockOutTask", request);
  166. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  167. {
  168. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  169. }
  170. return res;
  171. }
  172. /// <summary>
  173. /// 获取各巷道剩余空轮数量
  174. /// </summary>
  175. /// <returns></returns>
  176. /// <exception cref="KnownException"></exception>
  177. public static SRes<GetTunnelEmptyConResponse> GetTunnelEmptyConCount()
  178. {
  179. var res = APICaller.CallApi2<SRes<GetTunnelEmptyConResponse>>(WMSUrl + "/api/Hj/GetTunnelEmptyConCount", new GetTunnelEmptyConCountRequest { });
  180. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  181. {
  182. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  183. }
  184. return res;
  185. }
  186. /// <summary>
  187. /// 完成任务
  188. /// </summary>
  189. /// <param name="taskNo"></param>
  190. /// <returns></returns>
  191. /// <exception cref="KnownException"></exception>
  192. public static SRes<int> CompleteTask(int taskNo)
  193. {
  194. var res = APICaller.CallApi2<SRes<int>>(WMSUrl + "/api/Hj/CompleteTask", new CompleteTaskRequest
  195. {
  196. TaskNum = taskNo,
  197. OperationType = Models.WMS.Request.CompleteTask.自动完成,
  198. WCSUpdateName = "WCS"
  199. });
  200. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  201. {
  202. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  203. }
  204. return res;
  205. }
  206. /// <summary>
  207. /// 二深位获取移库任务
  208. /// </summary>
  209. /// <param name="taskNo">任务</param>
  210. /// <returns></returns>
  211. /// <exception cref="KnownException"></exception>
  212. public static SRes<AddWcsMoveTaskResponse> AddWcsMoveTask(int taskNo)
  213. {
  214. var res = APICaller.CallApi2<SRes<AddWcsMoveTaskResponse>>(WMSUrl + "/api/Hj/AddWcsMoveTask", new CompleteTaskRequest
  215. {
  216. TaskNum = taskNo,
  217. });
  218. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  219. {
  220. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  221. }
  222. return res;
  223. }
  224. /// <summary>
  225. /// 向WMS获取入库任务 一次单卷
  226. /// </summary>
  227. /// <param name="barcode">产品条码</param>
  228. /// <param name="devCode">设备条码</param>
  229. /// <param name="getTunnel"></param>
  230. /// <returns></returns>
  231. /// <exception cref="Exception"></exception>
  232. public static I_WCS_GetInTaskResponse I_WCS_GetInTask(string barcode, string devCode, bool getTunnel = false)
  233. {
  234. var res = APICaller.CallApi<I_WCS_GetInTaskResponse>(WMSUrl + "/api/Task/I_WCS_GetInTask", new List<I_WCS_GetInTaskRequest>()
  235. {
  236. new I_WCS_GetInTaskRequest(){
  237. ContainerBarCode = barcode,
  238. WareHouseId = wareHouseId,
  239. EquipmentNo = devCode,
  240. Memo1 = getTunnel ? "1" : "" //1:分巷道 2:分货位
  241. }
  242. });
  243. if (!res.ResType) throw new KnownException(res.ResMessage, LogLevelEnum.High);
  244. return res;
  245. }
  246. /// <summary>
  247. /// 处理任务验证接口
  248. /// </summary>
  249. /// <param name="taskNo">需要处理的任务进行验证</param>
  250. /// <param name="state">目标状态</param>
  251. /// <returns></returns>
  252. /// <exception cref="KnownException"></exception>
  253. public static SRes HandleTaskVerify(List<int> taskNo, int state)
  254. {
  255. var res = APICaller.CallApi2<SRes>(WMSUrl + "/api/Hj/CancelTaskVerify", new CancelTaskVerifyRequest
  256. {
  257. TaskNo = taskNo,
  258. State = state
  259. });
  260. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  261. {
  262. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  263. }
  264. return res;
  265. }
  266. /// <summary>
  267. /// 处理任务接口
  268. /// </summary>
  269. /// <param name="taskNo">处理</param>
  270. /// <param name="state">目标状态</param>
  271. /// <returns></returns>
  272. /// <exception cref="KnownException"></exception>
  273. public static SRes CarryTaskInfo(List<int> taskNo, int state)
  274. {
  275. var res = APICaller.CallApi2<SRes>(WMSUrl + "/api/Hj/CarryTaskInfo", new CancelTaskVerifyRequest
  276. {
  277. TaskNo = taskNo,
  278. State = state
  279. });
  280. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  281. {
  282. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  283. }
  284. return res;
  285. }
  286. /// <summary>
  287. /// WMS完成或取消任务验证
  288. /// </summary>
  289. /// <param name="sRes"></param>
  290. /// <param name="id"></param>
  291. /// <param name="type">99完成,106取消</param>
  292. /// <returns></returns>
  293. public static SRes? HandleTaskVerify(SRes<HandleTaskResponse> sRes, int id, int type)
  294. {
  295. try
  296. {
  297. var res = WmsApi.HandleTaskVerify(new List<int>() { id }, type);
  298. return res;
  299. }
  300. catch (Exception ex)
  301. {
  302. sRes.ResDataList.Add(new HandleTaskResponse()
  303. {
  304. IsSuccess = false,
  305. TaskNo = id,
  306. Message = $"WMS错误:{ex.Message}",
  307. });
  308. return null;
  309. }
  310. }
  311. /// <summary>
  312. /// WMS完成或取消任务执行
  313. /// </summary>
  314. /// <param name="sRes"></param>
  315. /// <param name="id"></param>
  316. /// <param name="type">99完成,106取消</param>
  317. /// <returns></returns>
  318. public static SRes? CarryTaskInfo(SRes<HandleTaskResponse> sRes, int id, int type)
  319. {
  320. try
  321. {
  322. var res = WmsApi.CarryTaskInfo(new List<int>() { id }, type);
  323. return res;
  324. }
  325. catch (Exception ex)
  326. {
  327. sRes.ResDataList.Add(new HandleTaskResponse()
  328. {
  329. IsSuccess = false,
  330. TaskNo = id,
  331. Message = $"WMS错误:{ex.Message}",
  332. });
  333. return null;
  334. }
  335. }
  336. /// <summary>
  337. /// 工字轮/芯股进入主线扫码
  338. /// </summary>
  339. /// <param name="codeList">工字轮条码组</param>
  340. /// <returns></returns>
  341. /// <exception cref="KnownException"></exception>
  342. public static SRes? EnteMainLine(List<string> codeList)
  343. {
  344. var res = APICaller.CallApi<SRes>(WMSUrl + "/api/FJ/EnteMainLine", new EnteMainLineRequest
  345. {
  346. IShapedWheelCodes = codeList
  347. });
  348. if (res.ResCode != ResponseStatusCodeEnum.Sucess)
  349. {
  350. throw new KnownException(res.ResMsg, LogLevelEnum.High);
  351. }
  352. return res;
  353. }
  354. }
  355. }