From b7308bba3d7ffad271ce7fc7a93c8c45d76be87d Mon Sep 17 00:00:00 2001 From: 杨前锦 <1010338399@qq.com> Date: 星期五, 13 六月 2025 17:21:03 +0800 Subject: [PATCH] 优化印尼佳通-硫化胚胎出入库逻辑策略优化 --- HH.WCS.Mobox3/HH.WCS.Mobox3.FJJT/dispatch/NDCApi.cs | 253 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 253 insertions(+), 0 deletions(-) diff --git a/HH.WCS.Mobox3/HH.WCS.Mobox3.FJJT/dispatch/NDCApi.cs b/HH.WCS.Mobox3/HH.WCS.Mobox3.FJJT/dispatch/NDCApi.cs new file mode 100644 index 0000000..d0bf5cb --- /dev/null +++ b/HH.WCS.Mobox3/HH.WCS.Mobox3.FJJT/dispatch/NDCApi.cs @@ -0,0 +1,253 @@ +锘縰sing Newtonsoft.Json; +using System; +using System.Collections.Generic; +using System.Text; +using System.Xml; +using HH.WCS.Mobox3.FJJT.util; + +namespace HH.WCS.Mobox3.FJJT.dispatch { + public class NDCApi + { + public static string NDCApiUrl { set; get; } + static NDCApi() { + + NDCApiUrl = Settings.NDCApiUrl; + } + + public static AgvApiResult AddOrderNew(int ts, int pri, string taskNo, List<param> param) + { + var httpH = new HttpHelper(); + var agvApiResult = new AgvApiResult(); + var model = new AddOrderNewModel(); + model.ts_no = ts; + model.pri = pri; + model.task_no = taskNo; + model.param = param; + try { + LogHelper.Info($"浠诲姟{taskNo}涓嬪彂锛寋JsonConvert.SerializeObject(model)}" , "NDC"); + var result = httpH.WebPost(NDCApiUrl + "Add",JsonConvert.SerializeObject(model)); + LogHelper.Info($"浠诲姟涓嬪彂缁撴灉res={result}", "NDC"); + agvApiResult = JsonConvert.DeserializeObject<AgvApiResult>(result); + return agvApiResult; + } + catch (Exception e) { + LogHelper.Info($"浠诲姟涓嬪彂澶辫触 res={e.Message}", "NDC"); + agvApiResult.err_code = -1; + agvApiResult.err_msg = e.Message; + return agvApiResult; + } + } + + public static AgvApiResult AddOrderNew(AddOrderNewModel model) + { + var httpH = new HttpHelper(); + var agvApiResult = new AgvApiResult(); + try + { + LogHelper.Info($"浠诲姟{model.task_no}涓嬪彂锛寋JsonConvert.SerializeObject(model)}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}涓嬪彂锛寋JsonConvert.SerializeObject(model)}", "NDC"); + var result = httpH.WebPost(NDCApiUrl + "Add", JsonConvert.SerializeObject(model)); + LogHelper.Info($"浠诲姟涓嬪彂缁撴灉res={result}", "NDC"); + Console.WriteLine($"浠诲姟涓嬪彂缁撴灉res={result}"); + agvApiResult = JsonConvert.DeserializeObject<AgvApiResult>(result); + return agvApiResult; + } + catch (Exception e) + { + LogHelper.Info($"浠诲姟涓嬪彂澶辫触 res={e.Message}", "NDC"); + agvApiResult.err_code = -1; + agvApiResult.err_msg = e.Message; + return agvApiResult; + } + } + + public static AgvApiResult CancelOrder(string tsNo, bool is_force) + { + var httpH = new HttpHelper(); + var agvApiResult = new AgvApiResult(); + var model = new CancelOrderModel(); + model.task_no = tsNo; + model.is_force = is_force; + try { + LogHelper.Info($"浠诲姟{model.task_no}鍙栨秷锛寋JsonConvert.SerializeObject(model)}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}鍙栨秷锛寋JsonConvert.SerializeObject(model)}", "NDC"); + var result = httpH.WebPost(NDCApiUrl + "Cancel", JsonConvert.SerializeObject(model)); + LogHelper.Info($"浠诲姟{model.task_no}鍙栨秷缁撴灉={result}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}鍙栨秷缁撴灉={result}", "NDC"); + agvApiResult = JsonConvert.DeserializeObject<AgvApiResult>(result); + return agvApiResult; + } + catch (Exception e) { + LogHelper.Info($"CancelOrder res={e.Message}", "NDC"); + agvApiResult.err_code = -1; + agvApiResult.err_msg = e.Message; + return agvApiResult; + } + } + + public static AgvApiResult CancelOrder(CancelOrderModel model) + { + var httpH = new HttpHelper(); + var agvApiResult = new AgvApiResult(); + try + { + LogHelper.Info($"浠诲姟{model.task_no}鍙栨秷锛寋JsonConvert.SerializeObject(model)}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}鍙栨秷锛寋JsonConvert.SerializeObject(model)}", "NDC"); + var result = httpH.WebPost(NDCApiUrl + "Cancel", JsonConvert.SerializeObject(model)); + LogHelper.Info($"浠诲姟{model.task_no}鍙栨秷缁撴灉={result}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}鍙栨秷缁撴灉={result}", "NDC"); + agvApiResult = JsonConvert.DeserializeObject<AgvApiResult>(result); + return agvApiResult; + } + catch (Exception e) + { + LogHelper.Info($"CancelOrder res={e.Message}", "NDC"); + agvApiResult.err_code = -1; + agvApiResult.err_msg = e.Message; + return agvApiResult; + } + + } + + public static AgvApiResult ChangeOrderPri(string taskNo, int newPri) + { + var httpH = new HttpHelper(); + var agvApiResult = new AgvApiResult(); + var model = new ChangePriModel(); + model.task_no = taskNo; + model.pri = newPri; + try + { + LogHelper.Info($"浠诲姟{model.task_no}浼樺厛绾ф洿鏀癸紝{JsonConvert.SerializeObject(model)}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}浼樺厛绾ф洿鏀癸紝{JsonConvert.SerializeObject(model)}", "NDC"); + var result = httpH.WebPost(NDCApiUrl + "ChangePri", JsonConvert.SerializeObject(model)); + LogHelper.Info($"浠诲姟{model.task_no}浼樺厛绾ф洿鏀圭粨鏋�{result}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}浼樺厛绾ф洿鏀圭粨鏋�{result}", "NDC"); + agvApiResult = JsonConvert.DeserializeObject<AgvApiResult>(result); + return agvApiResult; + } + catch (Exception e) + { + LogHelper.Info($"ChangeOrderPri res={e.Message}", "NDC"); + agvApiResult.err_code = -1; + agvApiResult.err_msg = e.Message; + return agvApiResult; + } + } + + public static AgvApiResult ChangeOrderPri(ChangePriModel model) + { + var httpH = new HttpHelper(); + var agvApiResult = new AgvApiResult(); + try + { + LogHelper.Info($"浠诲姟{model.task_no}浼樺厛绾ф洿鏀癸紝{JsonConvert.SerializeObject(model)}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}浼樺厛绾ф洿鏀癸紝{JsonConvert.SerializeObject(model)}", "NDC"); + var result = httpH.WebPost(NDCApiUrl + "ChangePri", JsonConvert.SerializeObject(model)); + LogHelper.Info($"浠诲姟{model.task_no}浼樺厛绾ф洿鏀圭粨鏋�{result}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}浼樺厛绾ф洿鏀圭粨鏋�{result}", "NDC"); + agvApiResult = JsonConvert.DeserializeObject<AgvApiResult>(result); + return agvApiResult; + } + catch (Exception e) + { + LogHelper.Info($"ChangeOrderPri res={e.Message}", "NDC"); + agvApiResult.err_code = -1; + agvApiResult.err_msg = e.Message; + return agvApiResult; + } + } + + public static AgvApiResult ChangeOrderParam(string taskNo,int paramNo, string paramStr) + { + var httpH = new HttpHelper(); + var agvApiResult = new AgvApiResult(); + var model = new ChangeParamModel(); + model.task_no = taskNo; + model.param_no = paramNo; + model.param = paramStr; + try { + LogHelper.Info($"浠诲姟{model.task_no}鍙傛暟鏇存敼锛寋JsonConvert.SerializeObject(model)}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}鍙傛暟鏇存敼锛寋JsonConvert.SerializeObject(model)}", "NDC"); + var result = httpH.WebPost(NDCApiUrl + "ChangeParam", JsonConvert.SerializeObject(model)); + LogHelper.Info($"浠诲姟{model.task_no}鍙傛暟鏇存敼缁撴灉={result}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}鍙傛暟鏇存敼缁撴灉={result}", "NDC"); + agvApiResult = JsonConvert.DeserializeObject<AgvApiResult>(result); + return agvApiResult; + } + catch (Exception e) { + LogHelper.Info($"ChangeOrderParam res={e.Message}", "NDC"); + agvApiResult.err_code = -1; + agvApiResult.err_msg = e.Message; + return agvApiResult; + } + } + + public static AgvApiResult ChangeOrderParam(ChangeParamModel model) + { + var httpH = new HttpHelper(); + var agvApiResult = new AgvApiResult(); + try + { + LogHelper.Info($"浠诲姟{model.task_no}鍙傛暟鏇存敼锛寋JsonConvert.SerializeObject(model)}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}鍙傛暟鏇存敼锛寋JsonConvert.SerializeObject(model)}", "NDC"); + var result = httpH.WebPost(NDCApiUrl + "ChangeParam", JsonConvert.SerializeObject(model)); + LogHelper.Info($"浠诲姟{model.task_no}鍙傛暟鏇存敼缁撴灉={result}", "NDC"); + Console.WriteLine($"浠诲姟{model.task_no}鍙傛暟鏇存敼缁撴灉={result}", "NDC"); + agvApiResult = JsonConvert.DeserializeObject<AgvApiResult>(result); + return agvApiResult; + } + catch (Exception e) + { + LogHelper.Info($"ChangeOrderParam res={e.Message}", "NDC"); + agvApiResult.err_code = -1; + agvApiResult.err_msg = e.Message; + return agvApiResult; + } + } + } + + /// <summary> + /// 杩斿洖淇℃伅Model + /// </summary> + public class AgvApiResult + { + public int err_code { set; get; }//寮傚父鐮侊細0 - 姝e父锛屽叾瀹冨�涓哄紓甯搁敊璇爜 + public string err_msg { set; get; }//杩斿洖鐨勯敊璇弿杩帮紝鍦�err_code <> 0 鏃惰繑鍥�+ public object result { set; get; }//姝g‘杩斿洖鐨勭粨鏋滃唴瀹癸紝鍦�err_code = 0 涓旀湁杩斿洖鍐呭鏃�+ } + + public class AddOrderNewModel + { + public int ts_no { set; get; }//TS 鍙凤紝蹇呴』鏈夊� + public int pri { set; get; }//浼樺厛绾�+ public string task_no { set; get; }//涓婃父浠诲姟缂栫爜锛屽鏋�no_feedback = 1 鏃讹紝鍙互涓虹┖ + public List<param> param { set; get; } = new List<param>();//鍙傛暟鍒楄〃 + } + + + public class param + { + public string name { set; get; }//鍙傛暟鍚�+ public string value { set; get; }//鍙傛暟鍊�+ } + + public class CancelOrderModel + { + public string task_no { set; get; }//涓婃父浠诲姟缂栫爜 + public bool is_force { set; get; }//鏄惁寮哄埗鍙栨秷锛� 鈥�寮哄埗 + } + + public class ChangeParamModel + { + public string task_no { set; get; }//涓婃父浠诲姟缂栫爜 + public int param_no { set; get; }//鍙傛暟鍙�+ public string param { set; get; }//鍙傛暟鍐呭锛屽涓弬鏁颁互鑻辨枃鍒嗗彿(;)鍒嗛殧 + } + + public class ChangePriModel + { + public string task_no { set; get; }//涓婃父浠诲姟缂栫爜 + public int pri { set; get; }//鏂颁紭鍏堢骇 + } +} -- Gitblit v1.9.1