using StoreHub.KJDWebService.Models; using StoreHub.Framework.Repositorys; using Microsoft.Extensions.Configuration; using StoreHub.KJDWebService.Commons; using MySql.Data.MySqlClient; using NaiBa.Util.Extension; using Newtonsoft.Json.Linq; using System; using System.Collections.Generic; using System.Data; using System.Linq; namespace StoreHub.KJDWebService.Services { public class ProductThirdService : ServiceBase { public ProductThirdService(SqlRepository sqlRepository, IConfiguration configuration) : base(sqlRepository, configuration) { } public string AddProduct(string inputData) { if (!string.IsNullOrEmpty(inputData)) { var time = 0; int.TryParse(RegexUtils.GetStringQuery(ref inputData, "time"), out time); 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 spu_id = RegexUtils.GetStringQuery(ref inputData, "spu_id"); string skc_id = RegexUtils.GetStringQuery(ref inputData, "skc_id"); string cat_id = RegexUtils.GetStringQuery(ref inputData, "cat_id"); string cat_name = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "cat_name")); string ext_code = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "ext_code")); string product_name = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "product_name")); string product_json = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "product_json")); string size_json = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "size_json")); string main_img = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "main_img")); string notes = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "notes")); if (string.IsNullOrEmpty(user_name)) { return "{\"code\":500,\"msg\":\"没有用户名\"}"; } string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = ""; var json_sign = RegexUtils.GetStringJson(ref product_json, "signedImageUrl"); // 取商品json数据里不同签名的部分 var product_md5 = EncrypUtil.GetMd5(product_json?.Replace(json_sign, "") + size_json); var product_md5_2 = EncrypUtil.GetMd5(product_json?.Replace("'", "\\'").Replace(json_sign, "") + size_json); sql = "select id from kjd.third_product where product_md5='" + product_md5 + "' or product_md5='" + product_md5_2 + "';"; var rst = mySql.ExecuteFirstInt(sql).ParseToLong(); if (rst <= 0) { //sql = "insert into kjd.third_product (spu_id,skc_id,cat_id,cat_name,product_name,ext_code,main_img,product_json,size_json,notes,product_md5,add_time,mdy_time) " + // "values ('" + spu_id + "','" + skc_id + "','" + cat_id + "','" + cat_name + "','" + product_name + "','" + // ext_code + "','" + main_img + "','" + product_json + "','" + size_json + "','" + notes + "','" + product_md5 + "','" + // DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "','" + // DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "');"; //rst = mySql.ExecuteInsertId(sql); sql = "insert into kjd.third_product (spu_id,skc_id,cat_id,cat_name,product_name," + "ext_code,main_img,product_json,size_json,notes,product_md5,add_time,mdy_time) " + "values (@spu_id,@skc_id,@cat_id,@cat_name,@product_name," + "@ext_code,@main_img,@product_json,@size_json,@notes,@product_md5," + "@add_time,@mdy_time);"; string add_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); string mdy_time = add_time; List paramLst = new List(); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@spu_id", Value = spu_id, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@skc_id", Value = skc_id, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@cat_id", Value = cat_id, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@cat_name", Value = cat_name, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@product_name", Value = product_name, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@ext_code", Value = ext_code, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@main_img", Value = main_img, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@product_json", Value = product_json, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@size_json", Value = size_json, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@notes", Value = notes.ParseToString(), }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@product_md5", Value = product_md5, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@add_time", Value = add_time, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@mdy_time", Value = mdy_time, }); rst = mySql.ExecuteInsertId(sql, paramLst.ToArray()); mySql.Close(); } if (rst > 0) { return "{\"code\":200,\"msg\":\"success\",\"id\":" + rst + "}"; } else { return "{\"code\":500,\"msg\":\"" + mySql.Message + "\"}"; } } return "{\"code\":19999,\"msg\":\"输入为空\"}"; } public string GetProductList(string inputData, bool isDetail = false) { var timeCalc = DateTime.Now; 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 password = RegexUtils.GetStringQuery(ref inputData, "password")?.Replace("'", "\\'"); var search_spu = RegexUtils.GetStringQuery(ref inputData, "search_spu")?.Replace("'", "\\'"); var search_skc = RegexUtils.GetStringQuery(ref inputData, "search_skc")?.Replace("'", "\\'"); var search_cat = RegexUtils.GetStringQuery(ref inputData, "search_cat")?.Replace("'", "\\'"); var search_ext_code = RegexUtils.GetStringQuery(ref inputData, "search_ext_code")?.Replace("'", "\\'"); var search_prod_name = RegexUtils.GetStringQuery(ref inputData, "search_prod_name")?.Replace("'", "\\'"); var search_notes = RegexUtils.GetStringQuery(ref inputData, "search_notes")?.Replace("'", "\\'"); var search_db_ids = RegexUtils.GetStringQuery(ref inputData, "search_db_ids")?.Replace("'", "\\'"); int page = RegexUtils.GetStringQuery(ref inputData, "page").ParseToInt(); int page_size= RegexUtils.GetStringQuery(ref inputData, "page_size").ParseToInt(50); string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "select count(id) from kjd.third_product where 1=1"; string where = ""; if (!string.IsNullOrWhiteSpace(search_spu)) where += " and spu_id like '%" + search_spu + "%'"; if (!string.IsNullOrWhiteSpace(search_skc)) where += " and skc_id like '%" + search_skc + "%'"; if (!string.IsNullOrWhiteSpace(search_cat)) where += " and cat_name like '%" + search_cat + "%'"; if (!string.IsNullOrWhiteSpace(search_ext_code)) where += " and ext_code like '%" + search_ext_code + "%'"; if (!string.IsNullOrWhiteSpace(search_prod_name)) where += " and product_name like '%" + search_prod_name + "%'"; if (!string.IsNullOrWhiteSpace(search_notes)) where += " and notes like '%" + search_notes + "%'"; if (!string.IsNullOrEmpty(search_db_ids)) where += " and id in (" + search_db_ids + ")"; sql += where; var count = mySql.ExecuteRowCount(sql); DataTable dt; if (count == 0) { dt = new DataTable(); } else { if (isDetail) sql = "select * from kjd.third_product where 1=1"; else sql = "select id,spu_id,skc_id,cat_id,cat_name,change_cat_id,change_cat_name,ext_code,product_name,main_img,notes," + "add_time,mdy_time from kjd.third_product where 1=1"; sql += where; sql += " order by id desc"; sql += " limit " + Math.Max(page - 1, 0) * page_size + "," + page_size; dt = mySql.ExecuteDataTable(sql); } mySql.Close(); if (dt != null) { try { List productLst = new List(); foreach (DataRow row in dt.Rows) { DBProductResultParam prod = new DBProductResultParam { id = Convert.ToInt32(row["id"]), skc_id = row["skc_id"].ToString(), spu_id = row["spu_id"].ToString(), cat_id = row["cat_id"].ToString(), cat_name = row["cat_name"].ToString(), change_cat_id = row["change_cat_id"].ToString(), change_cat_name = row["change_cat_name"].ToString(), product_name = row["product_name"].ToString(), main_img = row["main_img"].ToString(), ext_code = row["ext_code"].ToString(), //product_json = row["product_json"].ToString(), //size_json = row["size_json"].ToString(), add_time = Convert.ToDateTime(row["add_time"]), mdy_time = Convert.ToDateTime(row["mdy_time"]), notes = row["notes"].ToString(), }; if (isDetail) { prod.product_json = row["product_json"].ToString(); prod.size_json = row["size_json"].ToString(); } productLst.Add(prod); } var data = JsonUtils.SerializeObjectToString(productLst); var seconds = (DateTime.Now - timeCalc).TotalSeconds.ToString("0.000"); return "{\"code\":200,\"msg\":\"success\",\"data\":" + data + ",\"count\":" + count + ",\"seconds\":" + seconds + "}"; } 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 GetProductListEmptyProductJsonForBak(string inputData, bool isDetail = false) { var timeCalc = DateTime.Now; 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 password = RegexUtils.GetStringQuery(ref inputData, "password")?.Replace("'", "\\'"); var search_spu = RegexUtils.GetStringQuery(ref inputData, "search_spu")?.Replace("'", "\\'"); var search_skc = RegexUtils.GetStringQuery(ref inputData, "search_skc")?.Replace("'", "\\'"); var search_cat = RegexUtils.GetStringQuery(ref inputData, "search_cat")?.Replace("'", "\\'"); var search_ext_code = RegexUtils.GetStringQuery(ref inputData, "search_ext_code")?.Replace("'", "\\'"); var search_prod_name = RegexUtils.GetStringQuery(ref inputData, "search_prod_name")?.Replace("'", "\\'"); var search_notes = RegexUtils.GetStringQuery(ref inputData, "search_notes")?.Replace("'", "\\'"); var search_db_ids = RegexUtils.GetStringQuery(ref inputData, "search_db_ids")?.Replace("'", "\\'"); int page = RegexUtils.GetStringQuery(ref inputData, "page").ParseToInt(); int page_size = RegexUtils.GetStringQuery(ref inputData, "page_size").ParseToInt(50); string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "select count(id) from kjd.third_product where 1=1"; string where = ""; if (!string.IsNullOrWhiteSpace(search_spu)) where += " and spu_id like '%" + search_spu + "%'"; if (!string.IsNullOrWhiteSpace(search_skc)) where += " and skc_id like '%" + search_skc + "%'"; if (!string.IsNullOrWhiteSpace(search_cat)) where += " and cat_name like '%" + search_cat + "%'"; if (!string.IsNullOrWhiteSpace(search_ext_code)) where += " and ext_code like '%" + search_ext_code + "%'"; if (!string.IsNullOrWhiteSpace(search_prod_name)) where += " and product_name like '%" + search_prod_name + "%'"; if (!string.IsNullOrWhiteSpace(search_notes)) where += " and notes like '%" + search_notes + "%'"; if (!string.IsNullOrEmpty(search_db_ids)) where += " and id in (" + search_db_ids + ")"; where += " AND add_time BETWEEN '26-1-11 17:33:35' and '26-1-15 9:30:00' and product_json='{}'"; //where += " and product_json='{}' "; sql += where; var count = mySql.ExecuteRowCount(sql); DataTable dt; if (count == 0) { dt = new DataTable(); } else { if (isDetail) sql = "select * from kjd.third_product where 1=1"; else sql = "select id,spu_id,skc_id,cat_id,cat_name,change_cat_id,change_cat_name,ext_code,product_name,main_img,notes," + "add_time,mdy_time from kjd.third_product where 1=1"; sql += where; //sql += " order by id desc"; sql += " order by id"; sql += " limit " + Math.Max(page - 1, 0) * page_size + "," + page_size; dt = mySql.ExecuteDataTable(sql); } mySql.Close(); if (dt != null) { try { List productLst = new List(); foreach (DataRow row in dt.Rows) { DBProductResultParam prod = new DBProductResultParam { id = Convert.ToInt32(row["id"]), skc_id = row["skc_id"].ToString(), spu_id = row["spu_id"].ToString(), cat_id = row["cat_id"].ToString(), cat_name = row["cat_name"].ToString(), change_cat_id = row["change_cat_id"].ToString(), change_cat_name = row["change_cat_name"].ToString(), product_name = row["product_name"].ToString(), main_img = row["main_img"].ToString(), ext_code = row["ext_code"].ToString(), //product_json = row["product_json"].ToString(), //size_json = row["size_json"].ToString(), add_time = Convert.ToDateTime(row["add_time"]), mdy_time = Convert.ToDateTime(row["mdy_time"]), notes = row["notes"].ToString(), }; if (isDetail) { prod.product_json = row["product_json"].ToString(); prod.size_json = row["size_json"].ToString(); } productLst.Add(prod); } var data = JsonUtils.SerializeObjectToString(productLst); var seconds = (DateTime.Now - timeCalc).TotalSeconds.ToString("0.000"); return "{\"code\":200,\"msg\":\"success\",\"data\":" + data + ",\"count\":" + count + ",\"seconds\":" + seconds + "}"; } 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 GetProductListBak(string inputData, bool isDetail = false) { var timeCalc = DateTime.Now; 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 password = RegexUtils.GetStringQuery(ref inputData, "password")?.Replace("'", "\\'"); var search_spu = RegexUtils.GetStringQuery(ref inputData, "search_spu")?.Replace("'", "\\'"); var search_skc = RegexUtils.GetStringQuery(ref inputData, "search_skc")?.Replace("'", "\\'"); var search_cat = RegexUtils.GetStringQuery(ref inputData, "search_cat")?.Replace("'", "\\'"); var search_ext_code = RegexUtils.GetStringQuery(ref inputData, "search_ext_code")?.Replace("'", "\\'"); var search_prod_name = RegexUtils.GetStringQuery(ref inputData, "search_prod_name")?.Replace("'", "\\'"); var search_notes = RegexUtils.GetStringQuery(ref inputData, "search_notes")?.Replace("'", "\\'"); var search_db_ids = RegexUtils.GetStringQuery(ref inputData, "search_db_ids")?.Replace("'", "\\'"); int page = RegexUtils.GetStringQuery(ref inputData, "page").ParseToInt(); int page_size = RegexUtils.GetStringQuery(ref inputData, "page_size").ParseToInt(50); string conn = "ConnKJDBAK"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "select count(id) from kjd.third_product where 1=1"; string where = ""; if (!string.IsNullOrWhiteSpace(search_spu)) where += " and spu_id = '" + search_spu + "'"; if (!string.IsNullOrWhiteSpace(search_skc)) where += " and skc_id = '" + search_skc + "'"; if (!string.IsNullOrWhiteSpace(search_cat)) where += " and cat_name like '%" + search_cat + "%'"; if (!string.IsNullOrWhiteSpace(search_ext_code)) where += " and ext_code like '%" + search_ext_code + "%'"; if (!string.IsNullOrWhiteSpace(search_prod_name)) where += " and product_name like '%" + search_prod_name + "%'"; if (!string.IsNullOrWhiteSpace(search_notes)) where += " and notes like '%" + search_notes + "%'"; if (!string.IsNullOrEmpty(search_db_ids)) where += " and id in (" + search_db_ids + ")"; sql += where; var count = mySql.ExecuteRowCount(sql); DataTable dt; if (count == 0) { dt = new DataTable(); } else { if (isDetail) sql = "select * from kjd.third_product where 1=1"; else sql = "select id,spu_id,skc_id,cat_id,cat_name,change_cat_id,change_cat_name,ext_code,product_name,main_img,notes," + "add_time,mdy_time from kjd.third_product where 1=1"; sql += where; sql += " order by id desc"; sql += " limit " + Math.Max(page - 1, 0) * page_size + "," + page_size; dt = mySql.ExecuteDataTable(sql); } mySql.Close(); if (dt != null) { try { List productLst = new List(); foreach (DataRow row in dt.Rows) { DBProductResultParam prod = new DBProductResultParam { id = Convert.ToInt32(row["id"]), skc_id = row["skc_id"].ToString(), spu_id = row["spu_id"].ToString(), cat_id = row["cat_id"].ToString(), cat_name = row["cat_name"].ToString(), change_cat_id = row["change_cat_id"].ToString(), change_cat_name = row["change_cat_name"].ToString(), product_name = row["product_name"].ToString(), main_img = row["main_img"].ToString(), ext_code = row["ext_code"].ToString(), //product_json = row["product_json"].ToString(), //size_json = row["size_json"].ToString(), add_time = Convert.ToDateTime(row["add_time"]), mdy_time = Convert.ToDateTime(row["mdy_time"]), notes = row["notes"].ToString(), }; if (isDetail) { prod.product_json = row["product_json"].ToString(); prod.size_json = row["size_json"].ToString(); } productLst.Add(prod); } var data = JsonUtils.SerializeObjectToString(productLst); var seconds = (DateTime.Now - timeCalc).TotalSeconds.ToString("0.000"); return "{\"code\":200,\"msg\":\"success\",\"data\":" + data + ",\"count\":" + count + ",\"seconds\":" + seconds + "}"; } 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 DelDbProd(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("'", "\\'"); string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "delete from kjd.third_product 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 MdyProductNotes(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")?.Replace("'", "\\'"); var id = RegexUtils.GetStringQuery(ref inputData, "db_id")?.Replace("'", "\\'"); string notes = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "notes"))?.Replace("'", "\\'"); if (string.IsNullOrEmpty(user_name)) { return "{\"code\":500,\"msg\":\"没有用户名\"}"; } string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "update kjd.third_product set"; if (notes != null) sql += " notes='" + notes + "',"; 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\":\"输入为空\"}"; } public string MdyProductCategory(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")?.Replace("'", "\\'"); var id = RegexUtils.GetStringQuery(ref inputData, "db_id")?.Replace("'", "\\'"); string change_cat_id = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "change_cat_id"))?.Replace("'", "\\'"); string change_cat_name = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "change_cat_name"))?.Replace("'", "\\'"); if (string.IsNullOrEmpty(user_name)) { return "{\"code\":500,\"msg\":\"没有用户名\"}"; } string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "update kjd.third_product set"; if (change_cat_id != null) sql += " change_cat_id='" + change_cat_id + "',"; if (change_cat_name != null) sql += " change_cat_name='" + change_cat_name + "',"; 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\":\"输入为空\"}"; } public string MdyDBProduct(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")?.Replace("'", "\\'"); var id = RegexUtils.GetStringQuery(ref inputData, "db_id")?.Replace("'", "\\'"); string product_name = RegexUtils.GetStringQuery(ref inputData, "product_name"); string notes = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "notes")); string ext_code = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "ext_code")); string product_json = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "product_json")); string size_json = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "size_json")); if (string.IsNullOrEmpty(id)) { return "{\"code\":500,\"msg\":\"没有指定商品\"}"; } if (string.IsNullOrEmpty(user_name)) { return "{\"code\":500,\"msg\":\"没有用户名\"}"; } string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "update kjd.third_product set"; if (product_name != null) sql += " product_name=@product_name,"; if (notes != null) sql += " notes=@notes,"; if (ext_code != null) sql += " ext_code=@ext_code,"; if (product_json != null) sql += " product_json=@product_json,"; if (size_json != null) sql += " size_json=@size_json,"; sql = sql.TrimEnd(','); sql += " where id=" + id + ";"; List paramLst = new List(); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@product_name", Value = product_name, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@ext_code", Value = ext_code, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@product_json", Value = product_json, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@size_json", Value = size_json, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@notes", Value = notes, }); var rst = mySql.ExecuteNonQuery(sql, paramLst.ToArray()); mySql.Close(); if (rst) { return "{\"code\":200,\"msg\":\"success\"}"; } else { return "{\"code\":500,\"msg\":\"更新失败：" + mySql.Message + "\"}"; } } return "{\"code\":19999,\"msg\":\"输入为空\"}"; } public string AddUserSelectProduct(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 out_product_Id = RegexUtils.GetStringQuery(ref inputData, "out_product_id")?.Replace("'", "\\'"); var shop_id = RegexUtils.GetStringQuery(ref inputData, "shop_id")?.Replace("'", "\\'"); var shop_account = RegexUtils.GetStringQuery(ref inputData, "shop_account")?.Replace("'", "\\'"); var user_name = RegexUtils.GetStringQuery(ref inputData, "main_user_name")?.Replace("'", "\\'"); var sub_user_name = RegexUtils.GetStringQuery(ref inputData, "sub_user_name")?.Replace("'", "\\'"); var notes = RegexUtils.GetStringQuery(ref inputData, "notes")?.Replace("'", "\\'"); var status = RegexUtils.GetStringQuery(ref inputData, "status")?.Replace("'", "\\'"); var add_product_remaining = RegexUtils.GetStringQuery(ref inputData, "add_product_remaining").ParseToInt(); if (string.IsNullOrEmpty(user_name)) { return "{\"code\":500,\"msg\":\"没有用户名\"}"; } if (string.IsNullOrEmpty(shop_id)) { return "{\"code\":500,\"msg\":\"没有店铺信息\"}"; } DateTime addTime = DateTime.Now; string addTimeStr = addTime.ToString("yyyy-MM-dd HH:mm:ss"); string dbName = "kjd"; if (addTime.Year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (addTime.Year >= 2026) tableName += "_" + addTime.Year; string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = ""; if (add_product_remaining > 0) // add_product_remaining 为空或为0表示商品直传，不消耗次数 { sql = "select * from kjd.shop_add_prod_count where shop_id='" + shop_id + "';"; var dt = mySql.ExecuteDataTable(sql); if (!string.IsNullOrEmpty(mySql.Message)) { mySql.Close(); return "{\"code\":500,\"msg\":\"" + mySql.Message + "\"}"; } if (dt != null && dt.Rows.Count > 0) { add_product_remaining = dt.Rows[0]["add_product_remaining"].ParseToInt(); if (add_product_remaining <= 0) { mySql.Close(); return "{\"code\":501,\"msg\":\"本月商品认领限额已用完，请下个月再操作！\"}"; } } } sql = "INSERT INTO " + tableName + " (out_product_Id,shop_id,shop_account,user_name,sub_user_name,notes,status,add_time,mdy_time) VALUES" + " ('" + out_product_Id + "','" + shop_id + "','" + shop_account + "','" + user_name + "','" + sub_user_name + "','" + notes + "','" + status + "','" + addTimeStr + "','" + addTimeStr + "');"; if (add_product_remaining > 0) // add_product_remaining 为空或为0表示商品直传，不消耗次数 { add_product_remaining = add_product_remaining - 1; sql += "\r\n"; //sql += "UPDATE kjd.shop SET add_product_remaining=" + add_product_remaining + " where shop_id='" + shop_id + "';"; sql += "INSERT INTO kjd.shop_add_prod_count(shop_id, add_product_remaining) VALUES('" + shop_id + "'," + add_product_remaining + ")" + "ON DUPLICATE KEY UPDATE add_product_remaining=add_product_remaining-1"; } 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 MdyUserSelectProductStatus(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 select_db_id = RegexUtils.GetStringQuery(ref inputData, "db_id")?.Replace("'", "\\'"); var draft_id = RegexUtils.GetStringQuery(ref inputData, "draft_id")?.Replace("'", "\\'"); var up_spu_id = RegexUtils.GetStringQuery(ref inputData, "up_spu_id")?.Replace("'", "\\'"); var shop_id = RegexUtils.GetStringQuery(ref inputData, "shop_id")?.Replace("'", "\\'"); var status = RegexUtils.GetStringQuery(ref inputData, "status")?.Replace("'", "\\'"); var add_times = RegexUtils.GetStringQuery(ref inputData, "add_times")?.Replace("'", "\\'"); var select_add_time = RegexUtils.GetStringQuery(ref inputData, "select_add_time")?.Replace("'", "\\'").ParseToDateTimeNullable(); if (select_add_time == null) { return "{\"code\":500,\"msg\":\"当前软件版本不支持该操作，请升级软件。\"}"; } long l_draft_id = draft_id.ParseToLong(); long l_spu_map_table_id = l_draft_id % 128; long l_select_map_table_id = select_db_id.ParseToLong() % 64; string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = ""; // 使用事务一次提交多个sql操作 //sql += "set @@autocommit=0;\r\n"; sql += "START TRANSACTION;\r\n"; if (!string.IsNullOrEmpty(up_spu_id) && !string.IsNullOrEmpty(draft_id)) { sql += "INSERT into kjd_map.spu_map_" + l_spu_map_table_id + " (draft_id,from_spu_id,shop_id) VALUES(" + draft_id + "," + up_spu_id + ",'" + shop_id + "');\r\n"; if (!select_add_time.HasValue || select_add_time.Value.Year < 2026) { sql += "INSERT into kjd_map.product_third_select_map_" + l_select_map_table_id + " (product_id,product_select_db_id,shop_id) VALUES(" + draft_id + "," + select_db_id + ",'" + shop_id + "');\r\n"; } else { string select_type = "third-party"; sql += "INSERT INTO kjd_map_yearly.product_select_map_" + select_add_time.Value.Year + "(product_select_db_id,product_id,shop_id,select_type) VALUES" + "(" + select_db_id + ",'" + draft_id + "','" + shop_id + "','" + select_type + "');\r\n"; } } string dbName = "kjd"; if (select_add_time.HasValue && select_add_time.Value.Year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (select_add_time.HasValue && select_add_time.Value.Year >= 2026) tableName += "_" + select_add_time.Value.Year; sql += "update " + tableName + " set"; if (draft_id != null) sql += " draft_id='" + draft_id + "',"; if (status != null) sql += " status='" + status + "',"; if (status == "已上传") sql += " add_times=add_times+1,"; sql += " mdy_time='" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "',"; sql = sql.TrimEnd(','); sql += " WHERE id=" + select_db_id + ";\r\n"; var rst = mySql.ExecuteNonQuery(sql); string errMsg = mySql.Message; if (string.IsNullOrEmpty(errMsg)) sql = "COMMIT;"; else sql = "ROLLBACK;"; mySql.ExecuteNonQuery(sql); mySql.Close(); if (rst) { return "{\"code\":200,\"msg\":\"success\"}"; } else { return "{\"code\":500,\"msg\":\"" + errMsg + "\"}"; } } return "{\"code\":19999,\"msg\":\"输入为空\"}"; } public string GetUserSelectProductList(string inputData, bool isAdmin = false) { var timeCalc = DateTime.Now; 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("'", "\\'"); if (string.IsNullOrEmpty(user_name)) { return "{\"code\":500,\"msg\":\"没有用户名\"}"; } var shop_ids = RegexUtils.GetStringQuery(ref inputData, "shop_ids")?.Replace("'", "\\'"); var search_shop_id = RegexUtils.GetStringQuery(ref inputData, "search_shop_id")?.Replace("'", "\\'"); var search_shop_account = RegexUtils.GetStringQuery(ref inputData, "search_shop_account"); var search_spu = RegexUtils.GetStringQuery(ref inputData, "search_spu")?.Replace("'", "\\'"); var search_skc = RegexUtils.GetStringQuery(ref inputData, "search_skc")?.Replace("'", "\\'"); var search_cat = RegexUtils.GetStringQuery(ref inputData, "search_cat")?.Replace("'", "\\'"); var search_ext_code = RegexUtils.GetStringQuery(ref inputData, "search_ext_code")?.Replace("'", "\\'"); var search_prod_name = RegexUtils.GetStringQuery(ref inputData, "search_prod_name"); var search_notes = RegexUtils.GetStringQuery(ref inputData, "search_notes")?.Replace("'", "\\'"); var search_user_notes = RegexUtils.GetStringQuery(ref inputData, "search_user_notes")?.Replace("'", "\\'"); var search_db_ids = RegexUtils.GetStringQuery(ref inputData, "search_db_ids")?.Replace("'", "\\'"); var search_sub_sa_name = RegexUtils.GetStringQuery(ref inputData, "search_sub_sa_name")?.Replace("'", "\\'"); var status = RegexUtils.GetStringQuery(ref inputData, "status")?.Replace("'", "\\'"); var operate_sub_sa_name = RegexUtils.GetStringQuery(ref inputData, "operate_sub_sa_name")?.Replace("'", "\\'"); var search_year = RegexUtils.GetStringQuery(ref inputData, "search_year")?.Replace("'", "\\'").ParseToInt(); var search_end_time = RegexUtils.GetStringJson(ref inputData, "search_end_time")?.ParseToDateTimeNullable(); if (search_end_time == null || search_end_time.Value > DateTime.Now.Date.AddDays(1)) search_end_time = DateTime.Now.Date.AddDays(1); var search_start_time = RegexUtils.GetStringJson(ref inputData, "search_start_time")?.ParseToDateTimeNullable(); if (search_start_time == null || search_start_time.Value >= search_end_time.Value) search_start_time = search_end_time.Value.AddMonths(-6); int startTableId = Math.Max(2025, search_start_time.Value.Year); int endTableId = Math.Max(2025, search_end_time.Value.Year); var no_sub_sa = RegexUtils.GetStringQuery(ref inputData, "no_sub_sa")?.Replace("'", "\\'"); int page = RegexUtils.GetStringQuery(ref inputData, "page").ParseToInt(); int page_size = RegexUtils.GetStringQuery(ref inputData, "page_size").ParseToInt(50); string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = ""; if (search_year != null) { string dbName = "kjd"; if (search_year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (search_year >= 2026) tableName += "_" + search_year; sql += " SELECT count(s.id) FROM " + tableName + " s " + //"LEFT JOIN kjd.third_product p on s.out_product_id=p.id " + //"LEFT JOIN kjd.user u on s.operate_sub_sa_name=u.user_name " + "WHERE 1=1"; } else { sql = "select count(s.id) from ("; for (int year = search_start_time.Value.Year; year <= search_end_time.Value.Year; year++) { string dbName = "kjd"; if (year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (year >= 2026) tableName += "_" + year; if (year > search_start_time.Value.Year) sql += " UNION ALL"; sql += " SELECT * FROM " + tableName; } sql += ") s " + "LEFT JOIN kjd.third_product p on s.out_product_id=p.id " + "LEFT JOIN kjd.user u on s.operate_sub_sa_name=u.user_name " + "WHERE s.add_time BETWEEN '" + search_start_time.Value.ToString("yyyy-MM-dd") + "' AND '" + search_end_time.Value.ToString("yyyy-MM-dd") + "' "; } string where = ""; if (!isAdmin) //where += " and (s.user_name='" + user_name + "' or s.sub_user_name like '%" + user_name + "%')"; where += " and s.user_name='" + user_name + "'"; if (!string.IsNullOrEmpty(operate_sub_sa_name)) { where += " and s.operate_sub_sa_name = '" + operate_sub_sa_name + "'"; } if (no_sub_sa == "true") where += " and s.operate_sub_sa_name is null"; if (!string.IsNullOrEmpty(search_db_ids)) where += " and s.id in (" + search_db_ids + ")"; if (!string.IsNullOrEmpty(shop_ids)) where += " and s.shop_id in (" + shop_ids + ")"; if (!string.IsNullOrWhiteSpace(status)) where += " and s.status = '" + status + "'"; if (!string.IsNullOrWhiteSpace(search_shop_id)) where += " and s.shop_id like '" + search_shop_id + "%'"; if (!string.IsNullOrWhiteSpace(search_shop_account)) where += " and s.shop_account like @search_shop_account"; if (!string.IsNullOrWhiteSpace(search_notes)) { //核价成功 重复 核价成功（重复） if (search_notes == "无备注") where += " and s.notes = ''"; else if (search_notes == "重复") where += " and s.notes like '重复%' and s.notes not like '核价成功%' and s.notes not like '核价通过%'"; else if (search_notes == "核价成功") where += " and (s.notes like '核价成功%' or s.notes like '核价通过%') and s.notes not like '重复%'"; else if (search_notes == "核价成功（重复）") where += " and (s.notes like '核价成功%' or s.notes like '核价通过%') and s.notes like '重复%'"; else where += " and s.notes like '" + search_notes + "%'"; } if (!string.IsNullOrWhiteSpace(search_user_notes)) where += " and s.user_notes like '" + search_user_notes + "%'"; if (!string.IsNullOrWhiteSpace(search_spu)) where += " and p.spu_id like '" + search_spu + "%'"; if (!string.IsNullOrWhiteSpace(search_skc)) where += " and p.skc_id like '" + search_skc + "%'"; if (!string.IsNullOrWhiteSpace(search_cat)) where += " and p.cat_name like '" + search_cat + "%'"; if (!string.IsNullOrWhiteSpace(search_ext_code)) where += " and p.ext_code like '" + search_ext_code + "%'"; if (!string.IsNullOrWhiteSpace(search_prod_name)) where += " and p.product_name like @search_prod_name"; if (!string.IsNullOrEmpty(search_sub_sa_name)) { where += " and (s.operate_sub_sa_name like '" + search_sub_sa_name + "%'"; where += " or u.nick_name like '" + operate_sub_sa_name + "%')"; } sql += where; List paramLst = new List(); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@search_shop_account", Value = "" + search_shop_account + "%", }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@search_prod_name", Value = "%" + search_prod_name + "%", }); var count = mySql.ExecuteRowCount(sql, paramLst.ToArray()); DataTable dt; if (count == 0) { dt = new DataTable(); } else { //if (isDetail) //sql = "select * from kjd.third_product_select where 1=1"; //else if (search_year != null) { string dbName = "kjd"; if (search_year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (search_year >= 2026) tableName += "_" + search_year; //sql = "SELECT s.id,s.out_product_id,s.shop_id,s.shop_account,s.user_name," + // "s.sub_user_name,s.notes,s.user_notes,s.status,s.draft_id,s.add_times,s.add_time,s.mdy_time," + // "s.fission_product_name,s.operate_sub_sa_name,s.add_sub_sa_time," + // "p.spu_id,p.skc_id,p.cat_id,p.cat_name,p.change_cat_id,p.change_cat_name,p.ext_code,p.product_name,p.main_img," + // "u.nick_name as operate_sub_sa_nick " + // "FROM " + tableName + " s LEFT JOIN kjd.third_product p ON s.out_product_id=p.id " + // "LEFT JOIN kjd.user u ON u.user_name=s.operate_sub_sa_name " + // "WHERE 1=1"; //sql += where; // where子句 //sql += " order by s.add_time desc"; //sql += " limit " + Math.Max(page - 1, 0) * page_size + "," + page_size; //-------------------------------------------------------------------------------------------------------- sql = "SELECT s1.id,s1.out_product_id,s1.shop_id,s1.shop_account,s1.user_name," + "s1.sub_user_name,s1.notes,s1.user_notes,s1.status,s1.draft_id,s1.add_times,s1.add_time,s1.mdy_time," + "s1.fission_product_name,s1.operate_sub_sa_name,s1.add_sub_sa_time," + "s2.spu_id,s2.skc_id,s2.cat_id,s2.cat_name,s2.change_cat_id,s2.change_cat_name,s2.ext_code,s2.product_name,s2.main_img "; if (operate_sub_sa_name != null || 1 == 1) sql += ",s2.operate_sub_sa_nick"; sql += " FROM " + tableName + " s1"; // 子查询 sql += " JOIN (SELECT s.id," + "p.spu_id,p.skc_id,p.cat_id,p.cat_name,p.change_cat_id,p.change_cat_name,p.ext_code,p.product_name,p.main_img "; if (operate_sub_sa_name != null || 1 == 1) sql += ",u.nick_name as operate_sub_sa_nick "; sql += " FROM " + tableName + " s LEFT JOIN kjd.third_product p ON s.out_product_id=p.id "; if (operate_sub_sa_name != null || 1 == 1) sql += "LEFT JOIN kjd.user u ON u.user_name=s.operate_sub_sa_name "; sql += "WHERE 1=1"; sql += where; // where子句 sql += " order by s.add_time desc"; sql += " limit " + Math.Max(page - 1, 0) * page_size + "," + page_size; sql += ") as s2 ON s1.id = s2.id"; } else { sql = "SELECT s.id,s.out_product_id,s.shop_id,s.shop_account,s.user_name," + "s.sub_user_name,s.notes,s.user_notes,s.status,s.draft_id,s.add_times,s.add_time,s.mdy_time," + "s.fission_product_name,s.operate_sub_sa_name,s.add_sub_sa_time," + "p.spu_id,p.skc_id,p.cat_id,p.cat_name,p.change_cat_id,p.change_cat_name,p.ext_code,p.product_name,p.main_img," + "u.nick_name as operate_sub_sa_nick " + "FROM ("; for (int year = search_start_time.Value.Year; year <= search_end_time.Value.Year; year++) { string dbName = "kjd"; if (year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (year >= 2026) tableName += "_" + year; if (year > search_start_time.Value.Year) sql += " UNION ALL"; sql += " SELECT * FROM " + tableName; } sql += ") s LEFT JOIN kjd.third_product p ON s.out_product_id=p.id " + "LEFT JOIN kjd.user u ON u.user_name=s.operate_sub_sa_name " + "WHERE s.add_time BETWEEN '" + search_start_time.Value.ToString("yyyy-MM-dd") + "' AND '" + search_end_time.Value.ToString("yyyy-MM-dd") + "' "; sql += where; // where子句 sql += " order by s.add_time 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 productLst = new List(); foreach (DataRow row in dt.Rows) { ProductSelectResultParam prodSelect = new ProductSelectResultParam() { id = row["id"].ParseToLong(), out_product_Id = row["out_product_Id"].ParseToString(), shop_account = row["shop_account"].ParseToString(), shop_id = row["shop_id"].ParseToString(), status = row["status"].ParseToString(), sub_user_name = row["sub_user_name"].ParseToString(), user_name = row["user_name"].ParseToString(), cat_id = row["cat_id"].ParseToString(), cat_name = row["cat_name"].ParseToString(), change_cat_id = row["change_cat_id"].ParseToString(), change_cat_name = row["change_cat_name"].ParseToString(), product_name = row["product_name"].ParseToString(), main_img = row["main_img"].ParseToString(), ext_code = row["ext_code"].ParseToString(), add_time = Convert.ToDateTime(row["add_time"]), mdy_time = Convert.ToDateTime(row["mdy_time"]), notes = row["notes"].ParseToString(), draft_id = row["draft_id"].ParseToString(), add_times = row["add_times"].ParseToInt(), skc_id = row["skc_id"].ToString(), spu_id = row["spu_id"].ToString(), operate_sub_sa_name = row["operate_sub_sa_name"].ToString(), fission_product_name = row["fission_product_name"].ToString(), user_notes = row["user_notes"].ToString(), //product_json = row["product_json"].ToString(), //size_json = row["size_json"].ToString(), }; if (operate_sub_sa_name != null || 1 == 1) { prodSelect.operate_sub_sa_nick = row["operate_sub_sa_nick"].ToString(); } prodSelect.add_sub_sa_time = row["add_sub_sa_time"] as DateTime?; productLst.Add(prodSelect); } var data = JsonUtils.SerializeObjectToString(productLst); var seconds = (DateTime.Now - timeCalc).TotalSeconds.ToString("0.000"); return "{\"code\":200,\"msg\":\"success\",\"data\":" + data + ",\"count\":" + count + ",\"seconds\":" + seconds + "}"; } 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 DelSelectProd(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\":\"没有用户名\"}"; } var select_add_time = RegexUtils.GetStringQuery(ref inputData, "select_add_time")?.Replace("'", "\\'").ParseToDateTimeNullable(); if (select_add_time == null) { return "{\"code\":500,\"msg\":\"当前软件版本不支持该操作，请升级软件。\"}"; } string dbName = "kjd"; if (select_add_time != null && select_add_time.Value.Year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (select_add_time != null && select_add_time.Value.Year >= 2026) tableName += "_" + select_add_time.Value.Year; string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "delete from " + tableName + " 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 SetSelectProductSubSa(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("'", "\\'"); if (string.IsNullOrEmpty(user_name)) { return "{\"code\":50001,\"msg\":\"没有用户名\"}"; } var db_ids = RegexUtils.GetStringQuery(ref inputData, "db_id")?.Replace("'", "\\'"); var shop_ids = RegexUtils.GetStringQuery(ref inputData, "shop_id")?.Replace("'", "\\'"); var operate_sub_sa_name = RegexUtils.GetStringQuery(ref inputData, "operate_sub_sa_name")?.Replace("'", "\\'"); var status = RegexUtils.GetStringQuery(ref inputData, "status")?.Replace("'", "\\'"); var db_id_infos = RegexUtils.GetStringQuery(ref inputData, "db_id_infos")?.Replace("'", "\\'"); if (operate_sub_sa_name == null) { return "{\"code\":50002,\"msg\":\"未选择任何二级超管\"}"; } if (string.IsNullOrEmpty(db_ids) && string.IsNullOrEmpty(shop_ids) && string.IsNullOrEmpty(db_id_infos)) { return "{\"code\":50003,\"msg\":\"未选择任何待设置对象\"}"; } var select_add_time = RegexUtils.GetStringQuery(ref inputData, "select_add_time")?.Replace("'", "\\'").ParseToDateTimeNullable(); if (select_add_time == null && db_id_infos == null && db_ids == null) { return "{\"code\":500,\"msg\":\"当前软件版本不支持该操作，请升级软件。\"}"; } string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = ""; bool rst = false; if (!string.IsNullOrEmpty(db_ids)) { sql = "UPDATE kjd.third_product_select SET"; sql += " operate_sub_sa_name='" + operate_sub_sa_name + "',"; sql += " add_sub_sa_time='" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "'"; sql += " WHERE id IN (" + db_ids + ")"; if (!string.IsNullOrEmpty(status)) sql += " AND status='" + status + "';"; rst = mySql.ExecuteNonQuery(sql); if (!string.IsNullOrEmpty(mySql.Message)) { mySql.Close(); return "{\"code\":500,\"msg\":\"" + mySql.Message + "\"}"; } } else if (!string.IsNullOrEmpty(shop_ids)) { List yearLst = new List() { 2025 }; if (select_add_time != null) { yearLst.Clear(); yearLst.Add(select_add_time.Value.Year); yearLst.Add(select_add_time.Value.AddMonths(-6).Year); yearLst = yearLst.Distinct().ToList(); } foreach (int year in yearLst) { string dbName = "kjd"; if (year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (year >= 2026) tableName += "_" + year; sql = "UPDATE " + tableName + " SET"; sql += " operate_sub_sa_name='" + operate_sub_sa_name + "',"; sql += " add_sub_sa_time='" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "'"; sql += " WHERE shop_id in ('" + shop_ids.Replace(",", "','") + "')"; if (!string.IsNullOrEmpty(status)) sql += " AND status='" + status + "';"; rst = mySql.ExecuteNonQuery(sql); if (!string.IsNullOrEmpty(mySql.Message)) { mySql.Close(); return "{\"code\":500,\"msg\":\"" + mySql.Message + "\"}"; } } } else if (!string.IsNullOrEmpty(db_id_infos)) { try { JArray jArr = JArray.Parse(db_id_infos); foreach (JObject jObj in jArr) { var year = jObj["year"].ParseToInt(); var dbIds = jObj["db_ids"].ParseToString(); string dbName = "kjd"; if (year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (year >= 2026) tableName += "_" + year; sql = "UPDATE " + tableName + " SET"; sql += " operate_sub_sa_name='" + operate_sub_sa_name + "',"; sql += " add_sub_sa_time='" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "'"; sql += " WHERE id IN (" + dbIds + ")"; if (!string.IsNullOrEmpty(status)) sql += " AND status='" + status + "';"; rst = mySql.ExecuteNonQuery(sql); if (!string.IsNullOrEmpty(mySql.Message)) { mySql.Close(); return "{\"code\":500,\"msg\":\"" + mySql.Message + "\"}"; } } } catch (Exception ex) { mySql.Close(); return "{\"code\":50004,\"msg\":\"" + ex.Message + "\"}"; } } mySql.Close(); return "{\"code\":200,\"msg\":\"success\"}"; } return "{\"code\":19999,\"msg\":\"输入为空\"}"; } public string MdyProductSelectNotes(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 db_id = RegexUtils.GetStringQuery(ref inputData, "db_id"); string notes = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "notes")); string user_notes = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "user_notes")); string fission_product_name = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "fission_product_name")); if (string.IsNullOrEmpty(user_name)) { return "{\"code\":500,\"msg\":\"没有用户名\"}"; } var select_add_time = RegexUtils.GetStringQuery(ref inputData, "select_add_time")?.Replace("'", "\\'").ParseToDateTimeNullable(); if (select_add_time == null) { return "{\"code\":500,\"msg\":\"当前软件版本不支持该操作，请升级软件。\"}"; } string dbName = "kjd"; if (select_add_time != null && select_add_time.Value.Year >= 2026) dbName = "kjd_yearly"; string tableName = dbName + ".third_product_select"; if (select_add_time != null && select_add_time.Value.Year >= 2026) tableName += "_" + select_add_time.Value.Year; string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "update " + tableName + " set"; if (notes != null) sql += " notes=@notes,"; if (user_notes != null) sql += " user_notes=@user_notes,"; if (fission_product_name != null) sql += " fission_product_name=@fission_product_name,"; sql = sql.TrimEnd(','); sql += " where id=@id;"; List paramLst = new List(); paramLst.Add(new MySqlParameter() { DbType = DbType.Int64, ParameterName = "@id", Value = db_id, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@fission_product_name", Value = fission_product_name, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@user_notes", Value = user_notes, }); paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@notes", Value = notes, }); var rst = mySql.ExecuteNonQuery(sql, paramLst.ToArray()); mySql.Close(); if (rst) { return "{\"code\":200,\"msg\":\"success\"}"; } else { return "{\"code\":500,\"msg\":\"更新失败：" + mySql.Message + "\"}"; } } return "{\"code\":19999,\"msg\":\"输入为空\"}"; } public string GetSelectProdDbIdMapDraftIdList(string inputData, bool isDetail = false) { var timeCalc = DateTime.Now; 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 password = RegexUtils.GetStringQuery(ref inputData, "password")?.Replace("'", "\\'"); if (string.IsNullOrEmpty(user_name)) { return "{\"code\":50001,\"msg\":\"用户为空\"}"; } var select_db_id = RegexUtils.GetStringQuery(ref inputData, "select_db_id")?.Replace("'", "\\'"); if (string.IsNullOrEmpty(select_db_id)) { return "{\"code\":50002,\"msg\":\"未选择选品数据\"}"; } var select_add_time = RegexUtils.GetStringQuery(ref inputData, "select_add_time")?.Replace("'", "\\'").ParseToDateTimeNullable(); if (select_add_time == null) { return "{\"code\":500,\"msg\":\"当前软件版本不支持该操作，请升级软件。\"}"; } string dbName = "kjd_map"; if (select_add_time != null && select_add_time.Value.Year >= 2026) dbName = "kjd_map_yearly"; string tableName; if (select_add_time != null && select_add_time.Value.Year >= 2026) // 2026年以后的数据在新表 tableName = dbName + ".product_select_map_"; else tableName = dbName + ".product_third_select_map_"; if (select_add_time != null && select_add_time.Value.Year >= 2026) tableName += select_add_time.Value.Year; else { long l_select_map_table_id = select_db_id.ParseToLong() % 64; tableName += +l_select_map_table_id; } int page = RegexUtils.GetStringQuery(ref inputData, "page").ParseToInt(); int page_size = RegexUtils.GetStringQuery(ref inputData, "page_size").ParseToInt(50); string conn = "ConnKJD"; MysqlUtils mySql = new MysqlUtils(conn); string sql = "SELECT COUNT(id) FROM " + tableName + " WHERE 1=1"; string where = " AND product_select_db_id=" + select_db_id; if (select_add_time != null && select_add_time.Value.Year >= 2026) // 2026年以后的数据在新表 where += " AND select_type='third-party'"; sql += where; var count = mySql.ExecuteRowCount(sql); DataTable dt; if (count == 0) { dt = new DataTable(); } else { sql = "SELECT * FROM " + tableName + " WHERE 1=1"; //where子句 sql += where; sql += " ORDER BY add_time desc"; sql += " LIMIT " + Math.Max(page - 1, 0) * page_size + "," + page_size; dt = mySql.ExecuteDataTable(sql); } mySql.Close(); if (!string.IsNullOrEmpty(mySql.Message)) { return "{\"code\":500,\"msg\":\"" + mySql.Message + "\",\"data\":[],\"count\":" + 0 + "}"; } if (dt != null) { try { List dbIdMapProductIdLst = new List(); foreach (DataRow row in dt.Rows) { DBProdDbIdMapProductIdResultParam dbIdMapProductId = new DBProdDbIdMapProductIdResultParam { id = row["id"].ParseToLong(), product_select_db_id = row["product_select_db_id"].ParseToLong(), product_id = row["product_id"].ParseToLong(), shop_id = row["shop_id"].ParseToLong(), add_time = Convert.ToDateTime(row["add_time"]), }; dbIdMapProductIdLst.Add(dbIdMapProductId); } var data = JsonUtils.SerializeObjectToString(dbIdMapProductIdLst); var seconds = (DateTime.Now - timeCalc).TotalSeconds.ToString("0.000"); return "{\"code\":200,\"msg\":\"success\",\"data\":" + data + ",\"count\":" + count + ",\"seconds\":" + seconds + "}"; } catch (Exception ex) { return "{\"code\":500,\"msg\":\"" + ex.Message + "\",\"data\":[],\"count\":" + 0 + "}"; } } return "{\"code\":500,\"msg\":\"查询结果为空！\",\"data\":[],\"count\":" + 0 + "}"; } return "{\"code\":19999,\"msg\":\"输入为空\"}"; } } }