1删除部分不需要的文件 2货号对应原价导入功能

KJDService/KJD_WebService/BLL/PriceManage.cs

@@ -0,0 +1,285 @@
+using KJD_Web.Model;
+using KJD_Web.Utils;
+using MySql.Data.MySqlClient;
+using NaiBa.Util.Extension;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Web;
+using System.Web.Security;
+
+namespace KJD_Web.BLL
+{
+    public class PriceManage
+    {
+        public string AddPrice(string inputData)
+        {
+            if (!string.IsNullOrEmpty(inputData))
+            {
+                var time = RegexUtils.GetStringQuery(ref inputData, "time").ParseToInt();
+                string time1 = RegexUtils.GetStringQuery(ref inputData, "code");
+                if (time1 != EncrypUtil.Encryption(time))
+                    return "{\"code\":50000,\"msg\":\"校验失败\"}";
+
+                string user_name = RegexUtils.GetStringQuery(ref inputData, "user_name");
+                string ext_code = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "ext_code")).ParseToString();
+                int original_price = RegexUtils.GetStringQuery(ref inputData, "original_price").ParseToInt();
+                int markup_times = RegexUtils.GetStringQuery(ref inputData, "markup_times").ParseToInt();
+                int extra_price = RegexUtils.GetStringQuery(ref inputData, "extra_price").ParseToInt();
+                string notes = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "notes")).ParseToString();
+
+                if (string.IsNullOrEmpty(user_name))
+                {
+                    return "{\"code\":500,\"msg\":\"没有用户名\"}";
+                }
+
+                string conn = System.Configuration.ConfigurationManager.ConnectionStrings["ConnKJD"].ConnectionString;
+                MysqlUtils mySql = new MysqlUtils(conn);
+                string sqlExist = "select count(ext_code) from kjd.price_markup where ext_code=@ext_code";
+                string sql = "insert into kjd.price_markup " +
+                    "(ext_code,original_price,markup_times,extra_price,notes) " +
+                    "values (@ext_code,@original_price,@markup_times,@extra_price,@notes);";
+                List<MySqlParameter> paramLst = new List<MySqlParameter>();
+                paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@ext_code", Value = ext_code, });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@original_price", Value = original_price, });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@markup_times", Value = markup_times, });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@extra_price", Value = extra_price, });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@notes", Value = notes, });
+
+                var has = mySql.ExecuteFirst(sqlExist, paramLst.ToArray());
+                if (has != "0")
+                {
+                    mySql.Close();
+                    return "{\"code\":501,\"msg\":\"货号 " + ext_code + " 价格数据已存在\"}";
+                }
+
+                var rst = mySql.ExecuteNonQuery(sql, paramLst.ToArray());
+                mySql.Close();
+                if (rst)
+                {
+                    return "{\"code\":200,\"msg\":\"success\"}";
+                }
+                else
+                {
+                    return "{\"code\":502,\"msg\":\"" + mySql.Message + "\"}";
+                }
+            }
+            return "{\"code\":19999,\"msg\":\"输入为空\"}";
+        }
+
+        public string GetPriceList(string inputData)
+        {
+            if (!string.IsNullOrEmpty(inputData))
+            {
+                var time = RegexUtils.GetStringQuery(ref inputData, "time").ParseToInt();
+                string time1 = RegexUtils.GetStringQuery(ref inputData, "code");
+                if (time1 != EncrypUtil.Encryption(time))
+                    return "{\"code\":50000,\"msg\":\"校验失败\"}";
+
+                var user_name = RegexUtils.GetStringQuery(ref inputData, "user_name");
+                var password = RegexUtils.GetStringQuery(ref inputData, "password");
+
+                string start_original_price = RegexUtils.GetStringQuery(ref inputData, "start_original_price");
+                string end_original_price = RegexUtils.GetStringQuery(ref inputData, "end_original_price");
+                string start_markup_times = RegexUtils.GetStringQuery(ref inputData, "start_markup_times");
+                string end_markup_times = RegexUtils.GetStringQuery(ref inputData, "end_markup_times");
+                string start_extra_price = RegexUtils.GetStringQuery(ref inputData, "start_extra_price");
+                string end_extra_price = RegexUtils.GetStringQuery(ref inputData, "end_extra_price");
+                var search_ext_code = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "search_ext_code"));
+                var search_notes = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "search_notes"));
+                var in_ext_code = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "in_ext_code"));
+                int page = RegexUtils.GetStringQuery(ref inputData, "page").ParseToInt();
+                int page_size = RegexUtils.GetStringQuery(ref inputData, "page_size").ParseToInt(50);
+                if (string.IsNullOrEmpty(user_name))
+                {
+                    return "{\"code\":500,\"msg\":\"没有用户名\"}";
+                }
+
+
+                List<MySqlParameter> paramLst = new List<MySqlParameter>();
+                paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@search_ext_code", Value = "%" + search_ext_code + "%", });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@search_notes", Value = "%" + search_notes + "%", });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@start_original_price", Value = start_original_price.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@end_original_price", Value = end_original_price.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@start_markup_times", Value = start_markup_times.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@end_markup_times", Value = end_markup_times.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@start_extra_price", Value = start_extra_price.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@end_extra_price", Value = end_extra_price.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@in_ext_code", Value = "'" + in_ext_code?.Replace(",","','") + "'", });
+
+                string conn = System.Configuration.ConfigurationManager.ConnectionStrings["ConnKJD"].ConnectionString;
+                MysqlUtils mySql = new MysqlUtils(conn);
+
+                string sql = "select count(id) from kjd.price_markup p where 1=1";
+
+                string where = "";
+                if (!string.IsNullOrWhiteSpace(search_ext_code))
+                    where += " and p.ext_code like @search_ext_code";
+                if (!string.IsNullOrWhiteSpace(search_notes))
+                    where += " and p.notes like @search_notes";
+                if (!string.IsNullOrWhiteSpace(start_original_price))
+                    where += " and p.original_price >= @start_original_price";
+                if (!string.IsNullOrWhiteSpace(end_original_price))
+                    where += " and p.original_price <= @end_original_price";
+                if (!string.IsNullOrWhiteSpace(start_markup_times))
+                    where += " and p.markup_times >= @start_markup_times";
+                if (!string.IsNullOrWhiteSpace(end_markup_times))
+                    where += " and p.markup_times <= @end_markup_times";
+                if (!string.IsNullOrWhiteSpace(start_extra_price))
+                    where += " and p.extra_price >= @start_extra_price";
+                if (!string.IsNullOrWhiteSpace(end_extra_price))
+                    where += " and p.extra_price <= @end_extra_price";
+                if (!string.IsNullOrEmpty(in_ext_code))
+                    where += " and p.ext_code in (@in_ext_code)";
+                sql += where;
+
+                var count = mySql.ExecuteRowCount(sql, paramLst.ToArray());
+
+                DataTable dt;
+                if (count == 0)
+                {
+                    dt = new DataTable();
+                }
+                else
+                {
+                    sql = "select * from kjd.price_markup p where 1=1";
+
+                    //where子句
+                    sql += where;
+
+                    sql += " order by p.id desc";
+                    sql += " limit " + Math.Max(page - 1, 0) * page_size + "," + page_size;
+                    dt = mySql.ExecuteDataTable(sql, paramLst.ToArray());
+                }
+
+                mySql.Close();
+                if (dt != null)
+                {
+                    try
+                    {
+                        List<DBPriceResultParam> priceList = new List<DBPriceResultParam>();
+                        foreach (DataRow row in dt.Rows)
+                        {
+                            DBPriceResultParam price = new DBPriceResultParam
+                            {
+                                id = row["id"].ParseToInt(),
+                                extra_price = row["extra_price"].ParseToInt(),
+                                markup_times = row["markup_times"].ParseToInt(),
+                                original_price = row["original_price"].ParseToInt(),
+                                notes = row["notes"].ParseToString(),
+                                ext_code = row["ext_code"].ParseToString(),
+                                add_time = Convert.ToDateTime(row["add_time"]),
+                                mdy_time = Convert.ToDateTime(row["mdy_time"]),
+                            };
+                            priceList.Add(price);
+                        }
+                        var data = JsonUtils.SerializerObjectToString(priceList);
+                        return "{\"code\":200,\"msg\":\"success\",\"data\":" + data + ",\"count\":" + count + "}";
+                    }
+                    catch (Exception ex)
+                    {
+                        return "{\"code\":500,\"msg\":\"" + ex.Message + "\",\"data\":[],\"count\":" + 0 + "}";
+                    }
+                }
+                else
+                {
+                    return "{\"code\":500,\"msg\":\"" + mySql.Message + "\",\"data\":[],\"count\":" + 0 + "}";
+                }
+            }
+            return "{\"code\":19999,\"msg\":\"输入为空\"}";
+        }
+
+        public string DelDbPrice(string inputData)
+        {
+            if (!string.IsNullOrEmpty(inputData))
+            {
+                var time = RegexUtils.GetStringQuery(ref inputData, "time").ParseToInt();
+                string time1 = RegexUtils.GetStringQuery(ref inputData, "code");
+                if (time1 != EncrypUtil.Encryption(time))
+                    return "{\"code\":50000,\"msg\":\"校验失败\"}";
+
+                var user_name = RegexUtils.GetStringQuery(ref inputData, "user_name")?.Replace("'", "\\'");
+                var id = RegexUtils.GetStringQuery(ref inputData, "db_id")?.Replace("'", "\\'");
+
+                if (string.IsNullOrEmpty(user_name))
+                {
+                    return "{\"code\":500,\"msg\":\"没有用户名\"}";
+                }
+
+                string conn = System.Configuration.ConfigurationManager.ConnectionStrings["ConnKJD"].ConnectionString;
+                MysqlUtils mySql = new MysqlUtils(conn);
+                string sql = "delete from kjd.price_markup where id='" + id + "'";
+
+                var rst = mySql.ExecuteNonQuery(sql);
+                mySql.Close();
+                if (rst)
+                {
+                    return "{\"code\":200,\"msg\":\"success\"}";
+                }
+                else
+                    return "{\"code\":500,\"msg\":\"删除失败：" + mySql.Message + "\"}";
+            }
+            return "{\"code\":19999,\"msg\":\"输入为空\"}";
+        }
+
+        public string MdyDBPrice(string inputData, bool isAdmin = false)
+        {
+            if (!string.IsNullOrEmpty(inputData))
+            {
+                var time = RegexUtils.GetStringQuery(ref inputData, "time").ParseToInt();
+                string time1 = RegexUtils.GetStringQuery(ref inputData, "code");
+                if (time1 != EncrypUtil.Encryption(time))
+                    return "{\"code\":50000,\"msg\":\"校验失败\"}";
+
+                var user_name = RegexUtils.GetStringQuery(ref inputData, "user_name");
+                var id = RegexUtils.GetStringQuery(ref inputData, "db_id");
+                string notes = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "notes"));
+                string ext_code = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "ext_code"));
+                string original_price = RegexUtils.GetStringQuery(ref inputData, "original_price");
+                string markup_times = RegexUtils.GetStringQuery(ref inputData, "markup_times");
+                string extra_price = RegexUtils.GetStringQuery(ref inputData, "extra_price");
+
+                if (string.IsNullOrEmpty(user_name))
+                {
+                    return "{\"code\":500,\"msg\":\"没有用户名\"}";
+                }
+
+                List<MySqlParameter> paramLst = new List<MySqlParameter>();
+                paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@ext_code", Value = ext_code, });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@original_price", Value = original_price.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@markup_times", Value = markup_times.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.Int32, ParameterName = "@extra_price", Value = extra_price.ParseToInt(), });
+                paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@notes", Value = notes, });
+
+                string conn = System.Configuration.ConfigurationManager.ConnectionStrings["ConnKJD"].ConnectionString;
+                MysqlUtils mySql = new MysqlUtils(conn);
+                string sql = "update kjd.price_markup set";
+                if (notes != null)
+                    sql += " notes=@notes,";
+                //if (ext_code != null)
+                //    sql += " ext_code=@ext_code,";
+                if (original_price != null)
+                    sql += " original_price=@original_price,";
+                if (markup_times != null)
+                    sql += " markup_times=@markup_times,";
+                if (extra_price != null)
+                    sql += " extra_price=@extra_price,";
+                sql = sql.TrimEnd(',');
+                sql += " where id=@id;";
+
+                var rst = mySql.ExecuteNonQuery(sql);
+                mySql.Close();
+                if (rst)
+                {
+                    return "{\"code\":200,\"msg\":\"success\"}";
+                }
+                else
+                {
+                    return "{\"code\":500,\"msg\":\"更新失败：" + mySql.Message + "\"}";
+                }
+            }
+            return "{\"code\":19999,\"msg\":\"输入为空\"}";
+        }
+    }
+}

KJDService/KJD_WebService/BLL/UpadteManage.cs

@@ -1,4 +1,5 @@
 using KJD_Web.Utils;
+using NaiBa.Util.Extension;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -21,21 +22,25 @@ namespace KJD_Web.BLL
                 if (time1 != EncrypUtil.Encryption(time))
                     return "{\"code\":50000,\"msg\":\"校验失败\"}";
 
-                var version = 0;
-                int.TryParse(RegexUtils.GetStringQuery(ref inputData, "version"), out version);
+                var version = RegexUtils.GetStringQuery(ref inputData, "version").ParseToInt();
                 var serverVersion = System.Configuration.ConfigurationManager.ConnectionStrings["UpdateVersion"].ConnectionString;
                 var UpdateFiles = System.Configuration.ConfigurationManager.ConnectionStrings["UpdateFiles"].ConnectionString;
                 var UpdateExe = System.Configuration.ConfigurationManager.ConnectionStrings["UpdateExe"].ConnectionString;
                 var UpdateExeChk = System.Configuration.ConfigurationManager.ConnectionStrings["UpdateExeChk"].ConnectionString;
+                var LowVersion = System.Configuration.ConfigurationManager.ConnectionStrings["LowVersion"].ConnectionString;
 
-                if (version > 0)
+                if (version > LowVersion.ParseToInt())
                 {
                     return "{\"code\":200,\"msg\":\"success\",\"next_version\":" + serverVersion + ",\"exe_check\":\"" + UpdateExeChk +
                         "\",\"exe_address\":\"" + UpdateExe + "\",\"file_address\":\"" + UpdateFiles + "\"}";
                 }
+                else if (version > 0)
+                {
+                    return "{\"code\":501,\"msg\":\"版本过低已无法直接升级，请联系管理员获取最新安装包\"}";
+                }
                 else
                 {
-                    return "{\"code\":501,\"msg\":\"failed\"}";
+                    return "{\"code\":502,\"msg\":\"get update version failed\"}";
                 }
             }
             return "{\"code\":19999,\"msg\":\"未知错误\"}";

KJDService/KJD_WebService/Global.asax.cs

@@ -48,6 +48,11 @@ namespace KJD_Web
                 hPath = hPath.Replace("/product_third/", "/ProductThirdService.asmx/");
                 Context.RewritePath(hPath);
             }
+            else if (!hPath.Contains(".asmx") && hPath.Contains("/price/"))
+            {
+                hPath = hPath.Replace("/price/", "/PriceService.asmx/");
+                Context.RewritePath(hPath);
+            }
         }
 
         protected void Application_AuthenticateRequest(object sender, EventArgs e)

KJDService/KJD_WebService/KJD_WebService.csproj

@@ -75,6 +75,7 @@
   </ItemGroup>
   <ItemGroup>
     <Content Include="Global.asax" />
+    <Content Include="PriceService.asmx" />
     <Content Include="ProductThirdService.asmx" />
     <Content Include="ProductService.asmx" />
     <Content Include="ShopService.asmx" />
@@ -84,6 +85,7 @@
     <Content Include="Web.config" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="BLL\PriceManage.cs" />
     <Compile Include="BLL\ProductThirdManage.cs" />
     <Compile Include="BLL\ProductManage.cs" />
     <Compile Include="BLL\ShopManage.cs" />
@@ -94,11 +96,16 @@
       <DependentUpon>Global.asax</DependentUpon>
     </Compile>
     <Compile Include="Model\CommentParam.cs" />
+    <Compile Include="Model\DBPriceResultParam.cs" />
     <Compile Include="Model\OrderParam.cs" />
     <Compile Include="Model\DBProductResultParam.cs" />
     <Compile Include="Model\ProductSelectResultParam.cs" />
     <Compile Include="Model\ShopModel\ShopParam.cs" />
     <Compile Include="Model\UserLoginResultParam.cs" />
+    <Compile Include="PriceService.asmx.cs">
+      <DependentUpon>PriceService.asmx</DependentUpon>
+      <SubType>Component</SubType>
+    </Compile>
     <Compile Include="ProductThirdService.asmx.cs">
       <DependentUpon>ProductThirdService.asmx</DependentUpon>
       <SubType>Component</SubType>

KJDService/KJD_WebService/Model/DBPriceResultParam.cs

@@ -0,0 +1,19 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Web;
+
+namespace KJD_Web.Model
+{
+    public class DBPriceResultParam
+    {
+        public int id { get; set; }
+        public string ext_code { get; set; }
+        public int original_price { get; set; }
+        public int markup_times { get; set; }
+        public int extra_price { get; set; }
+        public string notes { get; set; }
+        public DateTime add_time { get; set; }
+        public DateTime mdy_time { get; set; }
+    }
+}

KJDService/KJD_WebService/PriceService.asmx

@@ -0,0 +1 @@
+<%@ WebService Language="C#" CodeBehind="PriceService.asmx.cs" Class="KJD_Web.PriceService" %>

KJDService/KJD_WebService/PriceService.asmx.cs

@@ -0,0 +1,100 @@
+using KJD_Web.BLL;
+using KJD_Web.Utils;
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Web;
+using System.Web.Services;
+
+namespace KJD_Web
+{
+    /// <summary>
+    /// PriceService 的摘要说明
+    /// </summary>
+    [WebService(Namespace = "http://tempuri.org/")]
+    [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
+    [System.ComponentModel.ToolboxItem(false)]
+    // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消注释以下行。 
+    // [System.Web.Script.Services.ScriptService]
+    public class PriceService : System.Web.Services.WebService
+    {
+        private string GetRequestJsonString()
+        {
+            Context.Response.ContentType = "text/html;charset=utf-8";
+            Context.Response.ContentEncoding = System.Text.Encoding.GetEncoding("utf-8");
+
+            using (Stream s = HttpContext.Current.Request.InputStream) // 获得json 字符流
+            {
+                // 还原数据流
+                byte[] b = new byte[s.Length];
+                s.Read(b, 0, (int)s.Length);
+                string jsonText = Encoding.UTF8.GetString(b); // JSON字符串
+                if (string.IsNullOrEmpty(jsonText))
+                {
+                    var qs = HttpContext.Current.Request.QueryString;
+                    if (qs != null && qs.Keys.Count > 0)
+                    {
+                        jsonText = "{";
+                        foreach (var key in qs.Keys)
+                        {
+                            jsonText += "\"" + key + "\":" + "\"" + qs[key.ToString()] + "\";";
+                        }
+                        jsonText = jsonText.TrimEnd(';') + "}";
+                    }
+                }
+                return jsonText;
+            }
+        }
+
+        [WebMethod]
+        public void get_price_list()
+        {
+            string jsontext = GetRequestJsonString();
+
+            var result = jsontext;
+            result = new PriceManage().GetPriceList(jsontext);
+
+            Context.Response.Write(result);
+            Context.Response.End();
+        }
+
+        [WebMethod]
+        public void add_price()
+        {
+            string jsontext = GetRequestJsonString();
+
+            var result = jsontext;
+            result = new PriceManage().AddPrice(jsontext);
+
+            Context.Response.Write(result);
+            Context.Response.End();
+        }
+
+        [WebMethod]
+        public void del_db_price()
+        {
+            string jsontext = GetRequestJsonString();
+
+            var result = jsontext;
+            result = new PriceManage().DelDbPrice(jsontext);
+
+            Context.Response.Write(result);
+            Context.Response.End();
+        }
+
+     
+        [WebMethod]
+        public void mdy_db_price()
+        {
+            string jsontext = GetRequestJsonString();
+
+            var result = jsontext;
+            result = new PriceManage().MdyDBPrice(jsontext);
+
+            Context.Response.Write(result);
+            Context.Response.End();
+        }
+    }
+}

KJDService/KJD_WebService/Web.config

@@ -6,10 +6,11 @@
 <configuration>
   <connectionStrings>
     <add name="ConnKJD" connectionString="Max Pool Size=512;Database='kjd';Data Source='nj-cynosdbmysql-grp-hl51pkfr.sql.tencentcdb.com';Port=27660;User Id='kjd';Password='Temukjd0625';Charset=utf8mb4;"/>
-    <add name="UpdateVersion" connectionString="100"/>
+    <add name="UpdateVersion" connectionString="525"/>
+    <add name="LowVersion" connectionString="523"/>
     <add name="UpdateExe" connectionString="http://1.13.195.131:9000/Download/Update.exe"/>
-    <add name="UpdateFiles" connectionString="http://1.13.195.131:9000/Download/Update.zip"/>
-    <add name="UpdateExeChk" connectionString="2CDEA1FB"/>
+    <add name="UpdateFiles" connectionString="http://1.13.195.131:9000/Download/Update525.zip"/>
+    <add name="UpdateExeChk" connectionString="324527ACE5020DCA77D65A5037718B65"/>
   </connectionStrings>
   <!--
     有关 web.config 更改的说明，请参见 http://go.microsoft.com/fwlink/?LinkId=235367。