1

DeviceLibrary/manager/HttpManager.cs

@@ -56,7 +56,7 @@ namespace DeviceLibrary
         /// </summary>
         /// </summary>
         /// <param name="msgList"></param>
         /// <param name="msgList"></param>
         /// <returns></returns>
         /// <returns></returns>
-        public static string updateDeviceAlarmMsg(string serverBase,List<AlarmMsg> msgList)
+        public static string updateDeviceAlarmMsg(string serverBase, List<AlarmMsg> msgList)
         {
         {
             string msg = "";
             string msg = "";
             try
             try
@@ -472,45 +472,49 @@ namespace DeviceLibrary
         }
         }
 
 
         static string agvreporttask = AppConfigHelper.GetValue(SettingString.ITS_UpdateLine, "http://10.85.17.233/ESMTCommonInterface/CommonService.asmx/") + "UpdateAGVtranstask";
         static string agvreporttask = AppConfigHelper.GetValue(SettingString.ITS_UpdateLine, "http://10.85.17.233/ESMTCommonInterface/CommonService.asmx/") + "UpdateAGVtranstask";
+      
+        
         /// <summary>
         /// <summary>
         /// AGV反馈任务执行信息
         /// AGV反馈任务执行信息
         /// </summary>
         /// </summary>
         /// <param name="send"></param>
         /// <param name="send"></param>
         /// <returns></returns>
         /// <returns></returns>
-        public static void UpdateAGVtranstask(string txt,bool isError=false)
+        public static void UpdateAGVtranstask(string txt, bool isError = false)
         {
         {
 
 
-            Task.Factory.StartNew(() =>
-            {
-                try
-                {
-                    Dictionary<string, string> param = new Dictionary<string, string>();
-                    param.Add("info", txt);
-                    string addr = GetItsAddr("/UpdateAGVtranstask", param);
-                    while (!isError)
-                    {
-                        string resultStr = HttpHelper.Get(addr);
-                        itsData data = JsonHelper.DeserializeJsonToObject<itsData>(resultStr);
-                        //fbackkinfo":"no agvinfo","fbacktime":"20215306105317"}
-                        if (data == null)
-                        {
-                            log.Error($"上报任务执行信息失败:[{txt}][{resultStr}]");
-                        }
-                        else
-                        {
-                            log.Info($"上报任务执行信息成功:[{txt}][{resultStr}]");
-                            break;
-                        }
-                        Task.Delay(1000);
-                    }
-                }
-                catch (Exception e)
-                {
-                    log.Error("UpdateAGVtranstask", e);
-                }
-            }
-                );
-
+            Task task = Task.Factory.StartNew(() =>
+               {
+                   try
+                   {
+                       int cnt = 10;
+                       Dictionary<string, string> param = new Dictionary<string, string>();
+                       param.Add("info", txt);
+                       string addr = GetItsAddr("/UpdateAGVtranstask", param);
+                       while (cnt > 0)
+                       {
+                           string resultStr = HttpHelper.Get(addr);
+                           itsData data = JsonHelper.DeserializeJsonToObject<itsData>(resultStr);
+                           //fbackkinfo":"no agvinfo","fbacktime":"20215306105317"}
+                           if (data == null)
+                           {
+                               log.Error($"上报任务执行信息失败:[{txt}][{resultStr}]");
+                           }
+                           else
+                           {
+                               log.Info($"上报任务执行信息成功:[{txt}][{resultStr}]");
+                               break;
+                           }
+                           Task.Delay(1000);
+                           cnt--;
+                       }
+                   }
+                   catch (Exception e)
+                   {
+                       log.Error("UpdateAGVtranstask", e);
+                   }
+               }
+                   );
+            task.Wait();
         }
         }
         #endregion
         #endregion
     }
     }