From 28a90b135cadc7f40b1cdddb43cc71c7b3bbe62e Mon Sep 17 00:00:00 2001 From: wule Date: Sat, 31 Oct 2026 16:46:48 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=BC=E5=A4=9A=E5=A4=9A=E6=98=A0=E5=B0=84?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E7=9B=B8=E5=85=B3=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- KJD_WebService/BLL/BXX/BXXProductManage.cs | 87 ++++++++++++++++++++-- KJD_WebService/BLL/KJD/ToolManage.cs | 4 +- 2 files changed, 83 insertions(+), 8 deletions(-) diff --git a/KJD_WebService/BLL/BXX/BXXProductManage.cs b/KJD_WebService/BLL/BXX/BXXProductManage.cs index c669ed3..bdd21fe 100644 --- a/KJD_WebService/BLL/BXX/BXXProductManage.cs +++ b/KJD_WebService/BLL/BXX/BXXProductManage.cs @@ -1,6 +1,7 @@ using KJD_Web.BLL.WXXD; using KJD_Web.Model; using KJD_Web.Model.ShopModel; +using KJD_Web.Upload.Prod; using KJD_Web.Utils; using MySql.Data.MySqlClient; using NaiBa.Util.Extension; @@ -3913,8 +3914,9 @@ namespace KJD_Web.BLL.BXX return "{\"code\":500,\"msg\":\"缺少上家编号\"}"; } var index = RegexUtils.GetStringQuery(ref inputData, "index").ParseToNullableLong(); - if (index == null) - index = Math.Abs(up_spu_id.GetHashCode()) % 128; + index = Convert.ToInt32(EncrypUtil.GetMd5(up_spu_id).Substring(EncrypUtil.GetMd5(up_spu_id).Length - 4), 16) % 128; + //if (index == null) + // index = Math.Abs(up_spu_id.GetHashCode()) % 128; var up_goods_name = HtmlUtils.UrlDecodeUtf8(RegexUtils.GetStringQuery(ref inputData, "up_goods_name")); if (string.IsNullOrEmpty(up_goods_name)) { @@ -3949,7 +3951,7 @@ namespace KJD_Web.BLL.BXX string conn = System.Configuration.ConfigurationManager.ConnectionStrings["ConnKJD"].ConnectionString; MysqlUtils mySql = new MysqlUtils(conn); - string sql = "insert into bxx_relation.out_prod_relation_" + index.ParseToString().PadLeft(4, '0') + + string sql = "insert into bxx_relation.out_prod_relation_t" + index.ParseToString().PadLeft(4, '0') + " (up_spu_id,up_goods_name,from_site,goods_id,shop_id,price_min,price_max) " + " values ('" + up_spu_id + "',@up_goods_name,'" + from_site + "','" + goods_id + "'," + shop_id + "," + price_min + "," + price_max + ");"; @@ -3984,16 +3986,89 @@ namespace KJD_Web.BLL.BXX return "{\"code\":500,\"msg\":\"缺少来源商品编号\"}"; } var index = RegexUtils.GetStringQuery(ref inputData, "index").ParseToNullableLong(); - if (index == null) - index = Math.Abs(up_spu_id.GetHashCode()) % 128; + index = Convert.ToInt32(EncrypUtil.GetMd5(up_spu_id).Substring(EncrypUtil.GetMd5(up_spu_id).Length - 4), 16) % 128; + //if (index == null) + // index = Math.Abs(up_spu_id.GetHashCode()) % 128; + + + + string conn = System.Configuration.ConfigurationManager.ConnectionStrings["ConnKJD"].ConnectionString; MysqlUtils mySql = new MysqlUtils(conn); - string sql = "select * from bxx_relation.out_prod_relation_" + index.ParseToString().PadLeft(4, '0') + + string sql = "select * from bxx_relation.out_prod_relation_t" + index.ParseToString().PadLeft(4, '0') + " where up_spu_id='" + up_spu_id + "' limit 20;"; var dt = mySql.ExecuteDataTable(sql); + mySql.Close(); + + //int uniqCount = 0; //95 个重复的（可能中间少记录一个） + //var totalCount = 0; //30224 //30320 + //for (int i = 0; i < 128; i++) + //{ + // sql = ""; + // mySql = new MysqlUtils(conn); + + // //sql = @"drop table if exists bxx_relation.out_prod_relation_t" + i.ParseToString().PadLeft(4, '0') + ";\r\n"; + // //sql += @"CREATE TABLE bxx_relation.out_prod_relation_t" + i.ParseToString().PadLeft(4, '0') + @" ( + // // `id` int NOT NULL AUTO_INCREMENT, + // // `up_spu_id` varchar(50) NOT NULL COMMENT '源商品id信息，此字段为分表依据', + // // `up_goods_name` varchar(255) NOT NULL COMMENT '源商品标题', + // // `from_site` varchar(10) NOT NULL COMMENT '商品来源平台如pdd,tb,1688,vd(微店)等', + // // `goods_id` varchar(50) NOT NULL COMMENT '映射商品id信息', + // // `shop_id` varchar(50) NOT NULL COMMENT '上传到的店铺id', + // // `price_min` int NOT NULL COMMENT '最低价，单位分', + // // `price_max` int NOT NULL COMMENT '最高价，单位分', + // // `add_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP, + // // PRIMARY KEY(`id`), + // // UNIQUE KEY `index_up_spu_id` (`up_spu_id`) USING BTREE, + // // KEY `index_add_time` (`add_time`) USING BTREE, + // // KEY `index_shop_id` (`shop_id`) USING BTREE, + // // KEY `index_price_min` (`price_min`) USING BTREE, + // // KEY `index_price_max` (`price_max`) USING BTREE + // // ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '记录拼多多关联数据信息'"; + // //var rst = mySql.ExecuteNonQuery(sql); + + // sql = "select * from bxx_relation.out_prod_relation_" + i.ParseToString().PadLeft(4, '0'); + // dt = mySql.ExecuteDataTable(sql); + // totalCount += dt.Rows.Count; + + // //sql = "select count(*) from bxx_relation.out_prod_relation_" + i.ParseToString().PadLeft(4, '0'); + // //totalCount += mySql.ExecuteFirstInt(sql); + // foreach (DataRow row in dt.Rows) + // { + // var indexCount = dt.Rows.IndexOf(row); + // JObject jObj = new JObject(); + // //jObj["id"] = row["id"].ParseToInt(); + // var up_spu_id1 = row["up_spu_id"].ToString(); + // var up_goods_name = row["up_goods_name"].ToString(); + // var from_site = row["from_site"].ToString(); + // var goods_id = row["goods_id"].ToString(); + // var shop_id = row["shop_id"].ToString(); + // var price_min = row["price_min"].ParseToInt(); + // var price_max = row["price_max"].ParseToInt(); + // var add_time = row["add_time"].ParseToString().ParseToDateTime(); + + + // index = Convert.ToInt32(EncrypUtil.GetMd5(up_spu_id1).Substring(EncrypUtil.GetMd5(up_spu_id1).Length - 4), 16) % 128; + + // sql = "insert into bxx_relation.out_prod_relation_t" + index.ParseToString().PadLeft(4, '0') + + // " (up_spu_id,up_goods_name,from_site,goods_id,shop_id,price_min,price_max,add_time) " + + // " values ('" + up_spu_id1 + "',@up_goods_name,'" + from_site + "','" + + // goods_id + "'," + shop_id + "," + price_min + "," + price_max + ",'" + add_time.ToString("yyyy-MM-dd HH:mm:ss") + "');"; + // List paramLst = new List(); + // paramLst.Add(new MySqlParameter() { DbType = DbType.String, ParameterName = "@up_goods_name", Value = up_goods_name, }); + // var rs = mySql.ExecuteAffectedRows(sql, paramLst.ToArray()); + // if (rs != 1) + // { + // uniqCount++; + // } + // } + + // mySql.Close(); + //} + if (mySql.Message.IsNullOrEmpty()) { JArray jArr = new JArray(); diff --git a/KJD_WebService/BLL/KJD/ToolManage.cs b/KJD_WebService/BLL/KJD/ToolManage.cs index 8954bf5..d1d3244 100644 --- a/KJD_WebService/BLL/KJD/ToolManage.cs +++ b/KJD_WebService/BLL/KJD/ToolManage.cs @@ -38,8 +38,8 @@ namespace KJD_Web.BLL //string sql = ""; //for (int i = 0; i < 128; i++) //{ - // sql = @"drop table if exists bxx_relation.out_prod_relation_" + i.ParseToString().PadLeft(4, '0') + ";\r\n"; - // sql += @"CREATE TABLE bxx_relation.out_prod_relation_" + i.ParseToString().PadLeft(4, '0') + @" ( + // sql = @"drop table if exists bxx_relation.out_prod_relation_" + i.ParseToString().PadLeft(6, '0') + ";\r\n"; + // sql += @"CREATE TABLE bxx_relation.out_prod_relation_" + i.ParseToString().PadLeft(6, '0') + @" ( // `id` int NOT NULL AUTO_INCREMENT, // `up_spu_id` varchar(50) NOT NULL COMMENT '源商品id信息，此字段为分表依据', // `up_goods_name` varchar(255) NOT NULL COMMENT '源商品标题',