aa

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()