diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index bcecbf4cb..617420745 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1857,31 +1857,33 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { storeMap := batchItemList[0].(*model.StoreMap) storeSkus, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, nil) - FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*model.StoreSkuBind) (result interface{}, successCount int, err error) { + result, _ := FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*model.StoreSkuBind) (result interface{}, successCount int, err error) { api := jd.GetAPI("320406") var ids []int64 for _, v := range batchedStoreSkuList { ids = append(ids, utils.Str2Int64(thingIDmap[int64(v.SkuID)])) } priceInfo, _ := api.GetStationInfoList(storeMap.VendorStoreID, ids) - var list []*jdapi.SkuIdEntity + //var list []*jdapi.SkuIdEntity for _, vv := range priceInfo { if vv.VipPrice != 0 { - list = append(list, &jdapi.SkuIdEntity{ - OutSkuId: utils.Int2Str(thingIDmap2[utils.Int64ToStr(vv.SkuID)]), - }) - + //list = append(list, &jdapi.SkuIdEntity{ + // OutSkuId: utils.Int2Str(thingIDmap2[utils.Int64ToStr(vv.SkuID)]), + //}) + result = []interface{}{vv.StationNo} } } - if len(list) > 0 { - err = api.DelVipPrice(utils.Int2Str(storeMap.StoreID), list) - } + //if len(list) > 0 { + // err = api.DelVipPrice(utils.Int2Str(storeMap.StoreID), list) + //} return result, 0, err }, ctx, task, storeSkus, 50, true) + retVal = []interface{}{result} return retVal, err }, storeMaps) tasksch.HandleTask(task, nil, true).Run() - _, err = task.GetResult(0) + result, err := task.GetResult(0) + fmt.Println("fuck vip", utils.Format4Output(result, true)) //京东账号更新 // var ( // db = dao.GetDB()