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:
suyl
2021-05-17 09:33:56 +08:00
parent 0bc820b3e5
commit a5b28a9f66
1 changed files with 48 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1841,54 +1841,54 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// tasksch.HandleTask(task, nil, true).Run() // tasksch.HandleTask(task, nil, true).Run()
// task.GetID() // task.GetID()
//删京东会员价 //删京东会员价
//var ( var (
// db = dao.GetDB() db = dao.GetDB()
// vendorThingIDs []int64 vendorThingIDs []int64
// // result3 []int // result3 []int
//) )
//storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, []int{103197, 666774}, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406") storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, 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}, []int{34322, 24206, 24207}, []string{"320406"})
//thingIDmap := make(map[int64]string) thingIDmap := make(map[int64]string)
//
//for _, v := range things { for _, v := range things {
// if v.VendorThingID != "" { if v.VendorThingID != "" {
// vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID)) vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID))
// thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID) thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID)
// } }
//} }
//
//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)
// // result1, _ := // result1, _ :=
// FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) { FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) {
// api := jd.GetAPI("320406") api := jd.GetAPI("320406")
// priceInfo, _ := api.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList) priceInfo, _ := api.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
// var list []*jdapi.SkuIdEntity var list []*jdapi.SkuIdEntity
// for _, vv := range priceInfo { for _, vv := range priceInfo {
// if vv.VipPrice != 0 { if vv.VipPrice != 0 {
// list = append(list, &jdapi.SkuIdEntity{ list = append(list, &jdapi.SkuIdEntity{
// OutSkuId: thingIDmap[vv.SkuID], OutSkuId: thingIDmap[vv.SkuID],
// }) })
// // result = []bool{true} // result = []bool{true}
// // return result, 0, err // return result, 0, err
// } }
// } }
// if len(list) > 0 { if len(list) > 0 {
// err = api.DelVipPrice(utils.Int2Str(storeMap.StoreID), list) err = api.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
// } }
// return result, 0, err return result, 0, err
// }, ctx, task, vendorThingIDs, 50, true) }, ctx, task, vendorThingIDs, 50, true)
// // for _, v := range result1 { // for _, v := range result1 {
// // if v.(bool) { // if v.(bool) {
// // retVal = []int{storeMap.StoreID} // retVal = []int{storeMap.StoreID}
// // return retVal, err // return retVal, err
// // } // }
// // } // }
// return retVal, err return retVal, err
// }, storeMaps) }, storeMaps)
//tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()
//_, err = task.GetResult(0) _, err = task.GetResult(0)
// for _, v := range result2 { // for _, v := range result2 {
// result3 = append(result3, v.(int)) // result3 = append(result3, v.(int))
// } // }