liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

heihei

Browse Source
This commit is contained in:
苏尹岚
2020-11-11 19:06:27 +08:00
parent 0e1067ad96
commit 5a3e88fd25
1 changed files with 75 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files

140
business/jxstore/tempop/tempop.go
View File

@@ -1710,61 +1710,63 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// cms.UpdateStoreSkus(ctx, 0, storeDetail.ID, skuBindInfos, true, true)
// }
var (
// jdStoreIDs = []string{
// "11734848",
// "11734850",
// "11734854",
// "11734862",
// "11734868",
// "11734873",
// "11734874",
// "11734886",
// "11748353",
// "11890095",
// "11800399",
// "11738114",
// "11857499",
// "11873440",
// "11883071",
// "11734852",
// "11886763",
// "11874614",
// "11734884",
// "11926674",
// "11929173",
// "11894144",
// "11734861",
// "11951611",
// "11800403",
// "11913597",
// "11980746",
// "11981675",
// "12011812",
// "12007545",
// "11734846",
// "12005417",
// "12005640",
// "12005682",
// "12006134",
// "11982352",
// "12007250",
// "12007560",
// "11982427",
// "12008087",
// "12035806",
// "12008160",
// "12008395",
// "12009345",
// "11940019",
// "12010237",
// "12010654",
// "12011111",
// "12006857",
// "11734851",
// "12030632",
// "12050456",
// }
jdStoreIDs = []string{
"11734848",
"11734850",
"11734854",
"11734862",
"11734868",
"11734873",
"11734874",
"11734886",
"11748353",
"11890095",
"11800399",
"11738114",
"11857499",
"11873440",
"11883071",
"11734852",
"11886763",
"11874614",
"11734884",
"11926674",
"11929173",
"11894144",
"11734861",
"11951611",
"11800403",
"11913597",
"11980746",
"11981675",
"12011812",
"12007545",
"11734846",
"12005417",
"12005640",
"12005682",
"12006134",
"11982352",
"12007250",
"12007560",
"11982427",
"12008087",
"12035806",
"12008160",
"12008395",
"12009345",
"11940019",
"12010237",
"12010654",
"12011111",
"12006857",
"11734851",
"12030632",
"12050456",
}
jdStoreIDxipu = "11890095"
skuMap = make(map[string]*partner.StoreSkuInfo)
priceList []*pa
)
StoreSkuFullList2BareFilter := func(storeSkuFull []*partner.SkuNameInfo) (bareStoreSkuList []*partner.StoreSkuInfo) {
for _, v := range storeSkuFull {
@@ -1781,18 +1783,26 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
allSkuNameInfoList, err := multiHandler.GetSkus(ctx, "320406", 0, "")
skuInfos := StoreSkuFullList2BareFilter(allSkuNameInfoList)
outStoreSkuList, err := handler.GetStoreSkusBareInfo(ctx, "320406", nil, 0, jdStoreIDxipu, skuInfos)
fmt.Println(utils.Format4Output(outStoreSkuList, false))
// task := tasksch.NewParallelTask("初始化京东", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// jdStoreID := batchItemList[0].(string)
// outStoreSkuList2, err := handler.GetStoreSkusBareInfo(ctx, "320406", nil, 0, jdStoreID, skuInfos)
// for _, v := range outStoreSkuList {
for _, v := range outStoreSkuList {
skuMap[v.VendorSkuID] = v
}
task := tasksch.NewParallelTask("初始化京东", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
jdStoreID := batchItemList[0].(string)
outStoreSkuList2, err := handler.GetStoreSkusBareInfo(ctx, "320406", nil, 0, jdStoreID, skuInfos)
for _, v := range outStoreSkuList2 {
if skuMap[v.VendorSkuID] != nil {
continue
}
if skuMap[v.VendorSkuID].VendorPrice != v.VendorPrice {
v.VendorPrice = skuMap[v.VendorSkuID].VendorPrice
// }
// return retVal, err
// }, jdStoreIDs)
// tasksch.HandleTask(task, nil, true).Run()
// task.GetID()
}
}
return retVal, err
}, jdStoreIDs)
tasksch.HandleTask(task, nil, true).Run()
task.GetID()
return err
}