chfei/KJD
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微信数据导入 新格式兼容v4

Browse Source
This commit is contained in:
chfei committed 2026-10-12 20:51:31 +08:00
1 parent 423fb3d4f3
commit 7a7cd82eea
2 files changed
+352 -116
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

TEMUKJD/BLL/ImportConverters/ConverterWXToPddV4.cs
+351 -115
View File
@@ -11,23 +11,27 @@ using System.Linq;
namespace TemuKJD.BLL.ImportConverters
{
/// <summary>
/// 微信转拼多多数据源 V4版本
/// 针对微信商品详情API（/channels/ec/product/get）返回的完整数据结构
/// 微信转拼多多数据源 V4版本（兼容增强版）
/// 针对微信商品详情API（/channels/ec/product/get）返回的 detail.product 结构
///
/// 数据结构特点：
/// - 顶层为 { detail: { product: { product_key, info, product_skus, ... } } }
/// - info 节点包含商品基本信息、主图、详情图、参数、SKU列表等
/// - product_skus 节点包含完整的SKU信息（含库存、价格、规格）
/// - product_sale_attrs 节点包含销售属性（颜色、尺码）
/// - extra_service 节点包含售后服务信息
/// - qualification_list 节点包含资质信息
/// 兼容的数据样例：
/// - 10000031453165（女装针织衫，含视频、资质、完整size_chart）
/// - 10000182390569（不锈钢调味球，无视频、无资质列表、简化size_chart）
///
/// 兼容策略：
/// 1. 所有可选字段使用安全访问，缺失时回退
/// 2. 属性解析优先 param_v2，回退 categorys
/// 3. 规格解析优先 value_v2，回退 value
/// 4. SKU价格优先 sale_price，回退 sku_list.sku_info.price
/// 5. SKU库存优先 product_skus，回退 spu_total_stock 均分
/// </summary>
internal class ConverterWXToPddV4 : GoodsConverterBase
{
private JObject _jsonRoot;
private JObject _productNode; // detail.product
private JObject _infoNode; // detail.product.info
private JArray _skuList; // detail.product.info.product_skus
private JArray _skuList; // detail.product.info.sku_list.sku_info（价格兜底）
private JArray _productSkus; // detail.product.product_skus（完整SKU）
private JArray _saleAttrs; // detail.product.info.product_sale_attrs
public override string ConverterName => "微信转拼多多数据源 V4";
@@ -41,36 +45,41 @@ namespace TemuKJD.BLL.ImportConverters
_jsonRoot = JsonConvert.DeserializeObject<JObject>(RawData);
if (_jsonRoot == null) return false;
// 1. 检查是否为详情API格式（detail.product 结构）
// 1. 检查 detail.product 结构
var detail = _jsonRoot.SelectToken("$.detail") as JObject;
if (detail == null) return false;
var product = detail.SelectToken("$.product") as JObject;
if (product == null) return false;
// 2. 检查 product_key 是否存在
// 2. 检查 product_key.product_id
var productKey = product.SelectToken("$.product_key") as JObject;
if (productKey == null) return false;
var productId = productKey.SelectToken("$.product_id")?.ToString();
if (string.IsNullOrEmpty(productId)) return false;
// 3. 检查 info 节点是否存在
// 3. 检查 info 节点
var info = product.SelectToken("$.info") as JObject;
if (info == null) return false;
// 4. 检查是否有标题
// 4. 检查标题
var title = info.SelectToken("$.title")?.ToString();
if (string.IsNullOrEmpty(title)) return false;
// 5. 检查是否有SKU列表
var skus = product.SelectToken("$.product_skus") as JArray;
if (skus == null || skus.Count == 0) return false;
// 5. 检查SKU（兼容两种：product_skus 优先，sku_list.sku_info 兜底）
var productSkus = product.SelectToken("$.product_skus") as JArray;
var skuList = info.SelectToken("$.sku_list.sku_info") as JArray;
if ((productSkus == null || productSkus.Count == 0) &&
(skuList == null || skuList.Count == 0))
return false;
// 缓存节点
_productNode = product;
_infoNode = info;
_skuList = skus;
_productSkus = productSkus;
_skuList = skuList;
_saleAttrs = info.SelectToken("$.product_sale_attrs") as JArray;
return true;
@@ -88,14 +97,12 @@ namespace TemuKJD.BLL.ImportConverters
Platform = Platform,
GoodsId = ParseGoodsId()
};
product.ListingTime = GetListingTime();
// ========== 1. 商品基本信息 ==========
product.Title = GetStringValue(_infoNode, "title");
product.Description = GetStringValue(_infoNode, "short_title");
if (string.IsNullOrEmpty(product.Description))
{
product.Description = GetStringValue(_infoNode, "ai_gen_short_title");
}
// ========== 2. 品牌信息 ==========
product.BrandId = GetLongValue(_infoNode, "brand_id");
@@ -130,20 +137,21 @@ namespace TemuKJD.BLL.ImportConverters
#region 核心字段解析
/// <summary>
/// 解析商品ID
/// 解析商品ID（兼容 out_product_id 存在与否）
/// </summary>
private long ParseGoodsId()
{
// 优先 product_id（所有情况都存在）
var productId = _productNode.SelectToken("$.product_key.product_id")?.ToString();
if (long.TryParse(productId, out var result))
return result;
// 回退到文件路径
// 回退文件路径
return Path.GetFileNameWithoutExtension(FilePath).ParseToLong();
}
/// <summary>
/// 获取类目ID（取最细分类目）
/// 获取类目ID（兼容 category 数组，取最细分类目）
/// </summary>
private int GetCategoryId()
{
@@ -151,7 +159,6 @@ namespace TemuKJD.BLL.ImportConverters
if (category == null || category.Count == 0)
return 0;
// 取最后一个类目（最细分类目）
var lastCat = category.Last as JObject;
return lastCat?["cat_id"]?.Value<int>() ?? 0;
}
@@ -183,7 +190,7 @@ namespace TemuKJD.BLL.ImportConverters
{
var result = new List<string>();
// 优先使用 head_img 数组
// 优先 head_img
var headImg = _infoNode["head_img"] as JArray;
if (headImg != null && headImg.Count > 0)
{
@@ -196,7 +203,7 @@ namespace TemuKJD.BLL.ImportConverters
return result;
}
// 回退到 head_img_infos
// 回退 head_img_infos
var headImgInfos = _infoNode["head_img_infos"] as JArray;
if (headImgInfos != null)
{
@@ -236,7 +243,10 @@ namespace TemuKJD.BLL.ImportConverters
}
/// <summary>
/// 获取商品属性列表（从 param 节点解析）
/// 获取商品属性列表（从 info.param 解析）
/// 兼容两种结构：
/// - 10000031453165：categorys[0].name = key, categorys[1].name = value
/// - 10000182390569：categorys[0].name = key, categorys[1].name = value（相同）
/// </summary>
private List<Property> GetProperties()
{
@@ -256,7 +266,6 @@ namespace TemuKJD.BLL.ImportConverters
if (!string.IsNullOrEmpty(key) && !string.IsNullOrEmpty(value))
{
// 去重
if (!result.Any(p => p.Key == key))
{
result.Add(new Property
@@ -272,7 +281,7 @@ namespace TemuKJD.BLL.ImportConverters
}
/// <summary>
/// 获取视频URL列表
/// 获取视频URL列表（兼容无视频的情况）
/// </summary>
private List<string> GetVideoUrls()
{
@@ -290,18 +299,6 @@ namespace TemuKJD.BLL.ImportConverters
return result;
}
private DateTime? GetListingTime()
{
string time = _infoNode["listing_time"].ToString();
if (time != null)
{
if (int.TryParse(time, out int v))
{
return NaiBa.Util.Helper.DateTimeHelper.IntStampToDateTime(v);
}
}
return null;
}
#endregion
@@ -309,87 +306,324 @@ namespace TemuKJD.BLL.ImportConverters
/// <summary>
/// 获取SKU和规格信息
/// 兼容两种数据：
/// - product_skus：包含 sku_key.sku_id、sale_param、sale_price、stock_info
/// - sku_list.sku_info：包含 sku_id、price、estimate_price（无规格、无库存）
/// </summary>
private Tuple<List<SkuItem>, List<SpecItem>> GetSkusAndSpecs()
private Tuple<List<SkuItem> , List<SpecItem>> GetSkusAndSpecs()
{
var skuList = new List<SkuItem>();
var specList = new List<SpecItem>();
if (_skuList == null || _skuList.Count == 0)
return new Tuple<List<SkuItem>, List<SpecItem>>(skuList, specList);
// 构建 sku_list.sku_info 的价格字典（作为兜底）
var priceFallbackDict = BuildPriceFallbackDict();
// 收集所有规格
var specDict = new Dictionary<string, HashSet<string>>();
// 构建 product_sale_attrs 的规格字典（作为兜底）
var attrFallbackDict = BuildAttrFallbackDict();
// 优先处理 product_skus（完整信息）
if (_productSkus != null && _productSkus.Count > 0)
{
foreach (var sku in _productSkus)
{
var skuObj = sku as JObject;
if (skuObj == null) continue;
var skuItem = ParseProductSku(skuObj, priceFallbackDict, attrFallbackDict);
if (skuItem != null)
skuList.Add(skuItem);
}
}
// 回退到 sku_list.sku_info（仅价格）
else if (_skuList != null && _skuList.Count > 0)
{
foreach (var sku in _skuList)
{
var skuObj = sku as JObject;
if (skuObj == null) continue;
var skuItem = ParseSkuInfoOnly(skuObj, attrFallbackDict);
if (skuItem != null)
skuList.Add(skuItem);
}
}
// 构建规格列表（优先 product_sale_attrs）
BuildSpecList(specList, skuList);
return new Tuple<List<SkuItem>, List<SpecItem>>(skuList, specList);
}
/// <summary>
/// 构建 sku_list.sku_info 的价格兜底字典
/// </summary>
private Dictionary<string, decimal> BuildPriceFallbackDict()
{
var dict = new Dictionary<string, decimal>();
if (_skuList == null) return dict;
foreach (var sku in _skuList)
{
var skuObj = sku as JObject;
if (skuObj == null) continue;
// 获取 SKU 基本信息
var skuKey = skuObj["sku_key"] as JObject;
var skuInfo = skuObj["product_sku_info"] as JObject;
if (skuKey == null || skuInfo == null) continue;
var skuId = skuObj["sku_id"]?.Value<string>();
if (string.IsNullOrEmpty(skuId)) continue;
var skuId = skuKey["sku_id"]?.Value<string>() ?? string.Empty;
var outSkuId = skuKey["out_sku_id"]?.Value<string>() ?? string.Empty;
// 优先 estimate_price（优惠后），回退 price
var estimatePrice = skuObj["estimate_price"]?.Value<decimal>() ?? 0;
var price = skuObj["price"]?.Value<decimal>() ?? 0;
var actualPrice = estimatePrice > 0 ? estimatePrice : price;
// 解析销售属性
var saleParams = skuInfo["sale_param"] as JArray;
var specValues = new List<string>();
dict[skuId] = actualPrice;
}
if (saleParams != null)
return dict;
}
/// <summary>
/// 构建 product_sale_attrs 的规格兜底字典（skuId -> spec文本）
/// 兼容两种结构：
/// - 10000031453165：items[].value_v2, items[].sku_ids[]
/// - 10000182390569：items[].value, items[].sku_ids[]
/// </summary>
private Dictionary<string, string> BuildAttrFallbackDict()
{
var dict = new Dictionary<string, string>();
if (_saleAttrs == null) return dict;
foreach (var attr in _saleAttrs)
{
var key = attr["key"]?.Value<string>() ?? string.Empty;
var items = attr["items"] as JArray;
if (items == null) continue;
foreach (var item in items)
{
foreach (var param in saleParams)
{
var paramV2 = param["param_v2"] as JObject;
if (paramV2 == null) continue;
// 兼容 value_v2 和 value
var value = item["value_v2"]?.Value<string>();
if (string.IsNullOrEmpty(value))
value = item["value"]?.Value<string>();
if (string.IsNullOrEmpty(value)) continue;
var skuIds = item["sku_ids"] as JArray;
if (skuIds == null) continue;
var specText = $"{key}:{value}";
foreach (var skuId in skuIds)
{
var id = skuId?.Value<string>();
if (!string.IsNullOrEmpty(id))
dict[id] = specText;
}
}
}
return dict;
}
/// <summary>
/// 解析 product_skus 中的单个SKU
/// </summary>
private SkuItem ParseProductSku(
JObject skuObj,
Dictionary<string, decimal> priceFallbackDict,
Dictionary<string, string> attrFallbackDict)
{
var skuKey = skuObj["sku_key"] as JObject;
var skuInfo = skuObj["product_sku_info"] as JObject;
if (skuKey == null || skuInfo == null) return null;
var skuId = skuKey["sku_id"]?.Value<string>() ?? string.Empty;
var outSkuId = skuKey["out_sku_id"]?.Value<string>() ?? string.Empty;
if (string.IsNullOrEmpty(skuId)) return null;
// 解析规格
var specText = ParseSkuSpec(skuInfo, skuId, attrFallbackDict);
// 解析价格
var salePrice = skuInfo["sale_price"]?.Value<decimal>() ?? 0;
if (salePrice <= 0 && priceFallbackDict.TryGetValue(skuId, out var fallbackPrice))
salePrice = fallbackPrice;
// 解析库存
var stockNum = ParseStockNum(skuInfo);
// 缩略图
var thumbImg = skuInfo["thumb_img"]?.Value<string>() ?? string.Empty;
return new SkuItem
{
SkuId = !string.IsNullOrEmpty(outSkuId) ? outSkuId : skuId,
Spec = specText,
Price = salePrice / 100, // 分转元
OriginalPrice = salePrice.ToString(),
Stock = stockNum,
SpecImage = thumbImg
};
}
/// <summary>
/// 解析 sku_list.sku_info 中的单个SKU（仅价格）
/// </summary>
private SkuItem ParseSkuInfoOnly(
JObject skuObj,
Dictionary<string, string> attrFallbackDict)
{
var skuId = skuObj["sku_id"]?.Value<string>() ?? string.Empty;
if (string.IsNullOrEmpty(skuId)) return null;
// 规格从 attrFallbackDict 获取
var specText = attrFallbackDict.TryGetValue(skuId, out var spec) ? spec : string.Empty;
// 价格
var estimatePrice = skuObj["estimate_price"]?.Value<decimal>() ?? 0;
var price = skuObj["price"]?.Value<decimal>() ?? 0;
var actualPrice = estimatePrice > 0 ? estimatePrice : price;
return new SkuItem
{
SkuId = skuId,
Spec = specText,
Price = actualPrice / 100,
OriginalPrice = actualPrice.ToString(),
Stock = 0,
SpecImage = string.Empty
};
}
/// <summary>
/// 解析SKU规格
/// 兼容两种结构：
/// - 10000031453165：sale_param[].param_v2.attr_name / attr_value_name
/// - 10000182390569：sale_param[].categorys[0].name / categorys[1].name
/// </summary>
private string ParseSkuSpec(
JObject skuInfo,
string skuId,
Dictionary<string, string> attrFallbackDict)
{
var specValues = new List<string>();
var saleParams = skuInfo["sale_param"] as JArray;
if (saleParams != null)
{
foreach (var param in saleParams)
{
// 优先 param_v2
var paramV2 = param["param_v2"] as JObject;
if (paramV2 != null)
{
var attrName = paramV2["attr_name"]?.Value<string>() ?? string.Empty;
var attrValue = paramV2["attr_value_name"]?.Value<string>() ?? string.Empty;
if (!string.IsNullOrEmpty(attrName) && !string.IsNullOrEmpty(attrValue))
{
specValues.Add($"{attrName}:{attrValue}");
continue;
}
}
// 收集规格
if (!specDict.ContainsKey(attrName))
specDict[attrName] = new HashSet<string>();
specDict[attrName].Add(attrValue);
// 回退 categorys
var categorys = param["categorys"] as JArray;
if (categorys != null && categorys.Count >= 2)
{
var attrName = categorys[0]?["name"]?.Value<string>() ?? string.Empty;
var attrValue = categorys[1]?["name"]?.Value<string>() ?? string.Empty;
if (!string.IsNullOrEmpty(attrName) && !string.IsNullOrEmpty(attrValue))
{
specValues.Add($"{attrName}:{attrValue}");
}
}
}
// 价格（单位：分）
var salePrice = skuInfo["sale_price"]?.Value<decimal>() ?? 0;
// 库存
var stockInfo = skuInfo["stock_info"] as JObject;
var stockNum = 0;
if (stockInfo != null)
{
var stockStr = stockInfo["stock_num"]?.Value<string>();
if (!string.IsNullOrEmpty(stockStr))
{
int.TryParse(stockStr, out stockNum);
}
}
// 缩略图
var thumbImg = skuInfo["thumb_img"]?.Value<string>() ?? string.Empty;
skuList.Add(new SkuItem
{
SkuId = !string.IsNullOrEmpty(outSkuId) ? outSkuId : skuId,
Spec = string.Join(";", specValues),
Price = salePrice / 100, // 分转元
OriginalPrice = salePrice.ToString(),
Stock = stockNum,
SpecImage = thumbImg
});
}
// 构建规格列表
// 如果无法从 sale_param 解析，从 attrFallbackDict 兜底
if (specValues.Count == 0 && attrFallbackDict.TryGetValue(skuId, out var fallbackSpec))
{
specValues.Add(fallbackSpec);
}
return string.Join(";", specValues);
}
/// <summary>
/// 解析库存（兼容字符串/数字格式）
/// </summary>
private int ParseStockNum(JObject skuInfo)
{
var stockInfo = skuInfo["stock_info"] as JObject;
if (stockInfo == null) return 0;
var stockToken = stockInfo["stock_num"];
if (stockToken == null) return 0;
if (stockToken.Type == JTokenType.String)
{
return int.TryParse(stockToken.Value<string>(), out var result) ? result : 0;
}
return stockToken.Value<int>();
}
/// <summary>
/// 构建规格列表
/// 优先从 product_sale_attrs 构建，回退从SKU的spec文本解析
/// </summary>
private void BuildSpecList(List<SpecItem> specList, List<SkuItem> skus)
{
var specDict = new Dictionary<string, HashSet<string>>();
// 优先从 product_sale_attrs 构建
if (_saleAttrs != null && _saleAttrs.Count > 0)
{
foreach (var attr in _saleAttrs)
{
var key = attr["key"]?.Value<string>() ?? string.Empty;
var items = attr["items"] as JArray;
if (items == null) continue;
foreach (var item in items)
{
// 兼容 value_v2 和 value
var value = item["value_v2"]?.Value<string>();
if (string.IsNullOrEmpty(value))
value = item["value"]?.Value<string>();
if (string.IsNullOrEmpty(value)) continue;
if (!specDict.ContainsKey(key))
specDict[key] = new HashSet<string>();
specDict[key].Add(value);
}
}
}
// 如果 product_sale_attrs 不存在，从SKU的spec文本解析
if (specDict.Count == 0 && skus.Count > 0)
{
foreach (var sku in skus)
{
if (string.IsNullOrEmpty(sku.Spec)) continue;
foreach (var part in sku.Spec.Split(new[] { ';' }, StringSplitOptions.RemoveEmptyEntries))
{
var kv = part.Split(':');
if (kv.Length == 2)
{
var key = kv[0].Trim();
var value = kv[1].Trim();
if (!specDict.ContainsKey(key))
specDict[key] = new HashSet<string>();
specDict[key].Add(value);
}
}
}
}
// 构建 SpecItem 列表
foreach (var spec in specDict)
{
foreach (var value in spec.Value)
@@ -403,8 +637,6 @@ namespace TemuKJD.BLL.ImportConverters
});
}
}
return new Tuple<List<SkuItem>, List<SpecItem>>(skuList, specList);
}
/// <summary>
@@ -412,33 +644,37 @@ namespace TemuKJD.BLL.ImportConverters
/// </summary>
private decimal GetMinPrice()
{
if (_skuList == null || _skuList.Count == 0)
return 0;
var minPrice = decimal.MaxValue;
foreach (var sku in _skuList)
// 优先从 product_skus 获取
if (_productSkus != null && _productSkus.Count > 0)
{
var skuObj = sku as JObject;
if (skuObj == null) continue;
var minPrice = decimal.MaxValue;
foreach (var sku in _productSkus)
{
var skuObj = sku as JObject;
if (skuObj == null) continue;
var skuInfo = skuObj["product_sku_info"] as JObject;
if (skuInfo == null) continue;
var skuInfo = skuObj["product_sku_info"] as JObject;
if (skuInfo == null) continue;
var price = skuInfo["sale_price"]?.Value<decimal>() ?? 0;
if (price > 0 && price < minPrice)
minPrice = price;
var price = skuInfo["sale_price"]?.Value<decimal>() ?? 0;
if (price > 0 && price < minPrice)
minPrice = price;
}
if (minPrice > 0 && minPrice != decimal.MaxValue)
return minPrice / 100;
}
// 回退到 sku_list.min_price
if (minPrice == decimal.MaxValue)
// 回退 sku_list.min_price
var skuListInfo = _infoNode["sku_list"] as JObject;
if (skuListInfo != null)
{
var skuListInfo = _infoNode["sku_list"] as JObject;
var minPriceToken = skuListInfo?["min_price"]?.Value<decimal>() ?? 0;
return minPriceToken / 100;
var minPriceToken = skuListInfo["min_price"]?.Value<decimal>() ?? 0;
if (minPriceToken > 0)
return minPriceToken / 100;
}
return minPrice > 0 ? minPrice / 100 : 0;
return 0;
}
#endregion
test/KJD.Test/UnitTest1.cs
+1 -1
View File
@@ -143,7 +143,7 @@ namespace KJD.Test
[Test]
public void TestWXToPDDV4()
{
string filePath = @"C:\Users\chaih\Documents\xwechat_files\hongfei357_a567\msg\file\2026-10\10000033063024.json";
string filePath = @"C:\Users\chaih\Documents\xwechat_files\hongfei357_a567\msg\attach\cde4474908f6a5f2da5f7c82f4a8c5d0\2026-10\Rec\e65980801fd61508\F\0\10000182390569(1).txt";
var frontProdInfo = ConverterToPddFactory.Convert(filePath);
var isMatch = frontProdInfo != null;
Console.WriteLine(frontProdInfo.Skus.Count);