20230714多线程单纯重试版本

DSWeb.DJYMQ/DS7Service.cs

@@ -1514,6 +1514,8 @@ SELECT @ps_BillNo as N'billno'";
                     //dolist.Add(head);
                 }
 
+
+
                 //注释部分 为每消息队列文本包 起一个线程
                 //ThreadSaveDS6_List SaveThread = new ThreadSaveDS6_List();
                 ////有参调用实例方法，ParameterizedThreadStart是一个委托，input为object,返回值为void
@@ -1532,7 +1534,11 @@ SELECT @ps_BillNo as N'billno'";
         public static void Do_DingCangToDS6(string itemstr,int count=0)
         {
 
-            if (count >= 3) return;
+            if (count >= 3) { 
+                //记录包并return
+
+
+            };
 
             var head = JsonConvert.DeserializeObject<DingCangHead>(itemstr);
 
@@ -5014,6 +5020,8 @@ SELECT @ps_BillNo as N'billno'";
             }
         }
 
+
+
         public class ThreadSaveDS6_Single
         {
             //public static bool inworking { get; set; } = false;
@@ -5024,8 +5032,6 @@ SELECT @ps_BillNo as N'billno'";
 
                 var itemstr = (string)o;
 
-
-                
                 try
                 {
                     Do_DingCangToDS6(itemstr);