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

修复上货检测是错误Bug

Browse Source
This commit is contained in:
chfei committed 2026-10-30 18:44:39 +08:00
1 parent d1ddb96ce0
commit 0381dafd65
2 files changed
+5 -5
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

TEMUKJD/WXForms/ProductForms/WXDBProdUploadForm.cs
+1 -1
View File
@@ -1723,7 +1723,7 @@ namespace TemuKJD.WXForms.ProductForms
if (!long.TryParse(dbProd.spu_id, out var goodsId) || goodsId <= 0)
throw new Exception("商品ID无效");
var statuses = CloudGoodsService.GetViolationStatus(new List<long> { goodsId }).GetAwaiter().GetResult();
var statuses = CloudGoodsService.GetViolationStatus(new List<long> { goodsId });
var status = statuses.FirstOrDefault(item => item.GoodsId == goodsId);
if (status == null)
throw new Exception("未返回当前商品的违规状态");
Work/Services/CloudGoodsService.cs
+4 -4
View File
@@ -230,7 +230,7 @@ namespace Work.Services
for (var offset = 0; offset < goodsIds.Count; offset += 50)
{
var batch = goodsIds.Skip(offset).Take(50).ToList();
var statuses = await GetViolationStatus(batch).ConfigureAwait(false);
var statuses = GetViolationStatus(batch);
var violations = new HashSet<long>(statuses.Where(item => item != null && item.IsViolation && batch.Contains(item.GoodsId))
.Select(item => item.GoodsId));
var productIds = mappings.Where(item => violations.Contains(item.Value)).Select(item => item.Key).ToList();
@@ -301,7 +301,7 @@ namespace Work.Services
throw new ArgumentException("违规商品列表不能包含空项。", nameof(items));
}
var html = await GetHtml.PostJsonAsync(ServerUrl + "/api/CloudGoods/ReportViolations", items);
var html = await GetHtml.PostJsonAsync(ServerUrl + "/api/CloudGoods/ReportViolations", items, timeOut: 5);
var ret = JsonConvert.DeserializeObject<Result<List<ReportGoodsViolationResult>>>(html);
if (ret == null)
{
@@ -317,14 +317,14 @@ namespace Work.Services
/// <summary>
/// 批量查询商品违规状态。
/// </summary>
public static async Task<List<GoodsViolationStatus>> GetViolationStatus(List<long> goodsIds)
public static List<GoodsViolationStatus> GetViolationStatus(List<long> goodsIds)
{
if (goodsIds == null)
{
throw new ArgumentNullException(nameof(goodsIds));
}
var html = await GetHtml.PostJsonAsync(ServerUrl + "/api/CloudGoods/GetViolationStatus", goodsIds);
var html = GetHtml.PostJson(ServerUrl + "/api/CloudGoods/GetViolationStatus", goodsIds, timeOut: 5);
var ret = JsonConvert.DeserializeObject<Result<List<GoodsViolationStatus>>>(html);
if (ret == null)
{