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

aa

Browse Source
This commit is contained in:
苏尹岚
2021-02-08 14:33:50 +08:00
parent 3bf0a49837
commit d115bf7faf
1 changed files with 17 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1831,7 +1831,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
idLists [][]*jdapi.SkuIdEntity idLists [][]*jdapi.SkuIdEntity
k = 1 k = 1
) )
// storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, []int{667281}, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406") storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, []int{667281}, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406")
things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"}) things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"})
for i := 0; i < len(things); i += 50 { for i := 0; i < len(things); i += 50 {
var idList []*jdapi.SkuIdEntity var idList []*jdapi.SkuIdEntity
@@ -1851,20 +1851,22 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
break break
} }
} }
fmt.Println(utils.Format4Output(idLists, false)) // fmt.Println(utils.Format4Output(idLists, false))
// task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// storeMap := batchItemList[0].(*model.StoreMap) storeMap := batchItemList[0].(*model.StoreMap)
// for _, v := range idLists { for _, v := range idLists {
// err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), v, "suyl") if v != nil {
// if strings.Contains(err.Error(), "没有会员价") { err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), v, "suyl")
// err = nil if strings.Contains(err.Error(), "没有会员价") {
// } err = nil
// } }
// return retVal, err }
// }, storeMaps) }
// tasksch.HandleTask(task, nil, true).Run() return retVal, err
// _, err = task.GetResult(0) }, storeMaps)
tasksch.HandleTask(task, nil, true).Run()
_, err = task.GetResult(0)
return err return err
} }