diff --git a/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs b/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs index fdc82f2..a1f7f68 100644 --- a/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs +++ b/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs @@ -12,7 +12,6 @@ using SDKAdapter.OperationPlatform.Models; using SDKAdapter.PurchasePlatform.Client; using SDKAdapter.PurchasePlatform.Models; using System.Data; -using System.Net.Http.Headers; using Yitter.IdGenerator; namespace BBWYB.Server.Business @@ -1004,8 +1003,38 @@ namespace BBWYB.Server.Business } public void SuncPurchaserName() - { - + { + List<IUpdate<Purchaser>> updatePurchaserList = new List<IUpdate<Purchaser>>(); + var dbPurchaserList = fsql.Select<Purchaser>().ToList(); + + var pspList = fsql.Select<PurchaseSchemeProduct>() + .GroupBy(psp2 => psp2.PurchaserId) + .WithTempQuery(g => new { MaxId = g.Max(g.Value.Id), PurchaserId = g.Key }) + .From<PurchaseSchemeProduct>() + .InnerJoin((psp2, psp1) => psp2.MaxId == psp1.Id) + .ToList((psp2, psp1) => psp1); + foreach (var psp in pspList) + { + var data = purchaseSchemeBusiness.GetPurchaseSkuBasicInfo(new PurchaseSkuBasicInfoRequest() + { + FirstApiMode = Enums.PurchaseProductAPIMode.Spider, + PriceMode = Enums.PurchaseOrderMode.批发, + Platform = Enums.Platform.阿里巴巴, + PurchaseProductId = psp.PurchaseProductId, + }); + if (data == null) + continue; + var dbPurchaser = dbPurchaserList.FirstOrDefault(p => p.Id == data.Purchaser.Id); + if (dbPurchaser == null) + continue; + if (dbPurchaser.Name != data.Purchaser.Name || + dbPurchaser.Id2 != data.Purchaser.Id2 || + dbPurchaser.MemberId != data.Purchaser.MemberId || + dbPurchaser.Tag != data.Purchaser.Tag) + { + + } + } } } }