周转表支持商品编码 多个查询

AutoTurnOver.DB/dc_auto_turnover.cs

@@ -161,8 +161,9 @@ from dc_auto_turnover as dat
                             sqlCount += " and dat.bailun_sku =" + $"'%{m.key_words}%'";
                             break;
                         case 3:
-                            sql += " and dat.product_inner_code =" + $"'{m.key_words}'";
-                            sqlCount += " and dat.product_inner_code =" + $"'{m.key_words}'";
+                            sql += " and dat.product_inner_code in @product_inner_code ";
+                            sqlCount += " and dat.product_inner_code in @product_inner_code ";
+                            parameters.Add("product_inner_code", m.key_words.Split(',').ToList());
                             break;
                         case 4:
                             sql += " and dat.product_inner_code like " + $"'%{m.key_words}%'";

AutoTurnOver.Utility/HttpHelper.cs

@@ -56,19 +56,35 @@ namespace AutoTurnOver.Utility
                     request.ContentType = "text/html; charset=UTF-8";
                     break;
             }
-            StringBuilder builder = new StringBuilder();
-            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
-            Stream responseStream = response.GetResponseStream();
-            StreamReader reader = new StreamReader(responseStream, Encoding.UTF8);
-            while (reader.Peek() != -1)
+            try
             {
-                builder.Append(reader.ReadLine());
+                StringBuilder builder = new StringBuilder();
+                HttpWebResponse response = (HttpWebResponse)request.GetResponse();
+                Stream responseStream = response.GetResponseStream();
+                StreamReader reader = new StreamReader(responseStream, Encoding.UTF8);
+                while (reader.Peek() != -1)
+                {
+                    builder.Append(reader.ReadLine());
+                }
+                responseStream.Dispose();
+                reader.Close();
+                response.Close();
+
+                return builder.ToString();
+            }
+            catch (WebException ex)
+            {
+               var  response = (HttpWebResponse)ex.Response;
+                Stream myResponseStream = response.GetResponseStream();//获取返回值
+                StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.GetEncoding("utf-8"));
+
+                string retString = myStreamReader.ReadToEnd();
+                throw;
             }
-            responseStream.Dispose();
-            reader.Close();
-            response.Close();
 
-            return builder.ToString();
+
+
+
         }
     }
 }