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-06-08 11:19:31 +08:00
parent cf8a9d9504
commit e1a26c1444
1 changed files with 67 additions and 63 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1840,58 +1840,62 @@ 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}, nil, 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}, []int{34322, 24206, 24207}, []string{"320406"}) things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []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[v.ThingID] = v.VendorThingID
// } }
}
task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
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)
// result1, _ :=
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
for _, vv := range priceInfo {
if vv.VipPrice != 0 {
list = append(list, &jdapi.SkuIdEntity{
OutSkuId: thingIDmap[vv.SkuID],
})
// result = []bool{true}
// return result, 0, err
}
}
if len(list) > 0 {
err = api.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
}
return result, 0, err
}, ctx, task, storeSkus, 50, true)
// for _, v := range result1 {
// if v.(bool) {
// retVal = []int{storeMap.StoreID}
// return retVal, err
// }
// }
return retVal, err
}, storeMaps)
tasksch.HandleTask(task, nil, true).Run()
_, err = task.GetResult(0)
//for _, v := range result2 {
// result3 = append(result3, v.(int))
//} //}
// //fmt.Println("result3", result3)
//task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// storeMap := batchItemList[0].(*model.StoreMap)
// // result1, _ :=
// FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) {
// api := jd.GetAPI("320406")
// priceInfo, _ := api.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
// var list []*jdapi.SkuIdEntity
// for _, vv := range priceInfo {
// if vv.VipPrice != 0 {
// list = append(list, &jdapi.SkuIdEntity{
// OutSkuId: thingIDmap[vv.SkuID],
// })
// // result = []bool{true}
// // return result, 0, err
// }
// }
// if len(list) > 0 {
// err = api.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
// }
// return result, 0, err
// }, ctx, task, vendorThingIDs, 50, true)
// // for _, v := range result1 {
// // if v.(bool) {
// // retVal = []int{storeMap.StoreID}
// // return retVal, err
// // }
// // }
// return retVal, err
// }, storeMaps)
//tasksch.HandleTask(task, nil, true).Run()
//_, err = task.GetResult(0)
// for _, v := range result2 {
// result3 = append(result3, v.(int))
// }
// fmt.Println("result3", result3)
//京东账号更新 //京东账号更新
// var ( // var (
// db = dao.GetDB() // db = dao.GetDB()
@@ -1923,16 +1927,16 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// dao.UpdateEntity(db, v, "ConsigneeMobile2") // dao.UpdateEntity(db, v, "ConsigneeMobile2")
// } // }
//} //}
order, _ := partner.CurOrderManager.LoadOrder("2113480902000652", model.VendorIDJD) //order, _ := partner.CurOrderManager.LoadOrder("2113480902000652", model.VendorIDJD)
handler := partner.GetPurchaseOrderHandlerFromVendorID(model.VendorIDJD) //handler := partner.GetPurchaseOrderHandlerFromVendorID(model.VendorIDJD)
order2, _ := handler.GetOrder(order.VendorOrgCode, order.VendorOrderID, "") //order2, _ := handler.GetOrder(order.VendorOrgCode, order.VendorOrderID, "")
if len(order.Skus) == 0 { //if len(order.Skus) == 0 {
if len(order2.Skus) > 0 { // if len(order2.Skus) > 0 {
for _, v := range order2.Skus { // for _, v := range order2.Skus {
dao.CreateEntity(dao.GetDB(), v) // dao.CreateEntity(dao.GetDB(), v)
} // }
} // }
} //}
return err return err
} }
@@ -1955,12 +1959,12 @@ func FreeBatchInfo2(name string, handler func(tasksch.ITask, []*jdapi.SkuIdEntit
return resultList, err return resultList, err
} }
func FreeBatchInfo(name string, handler func(tasksch.ITask, []int64) (interface{}, int, error), ctx *jxcontext.Context, parentTask tasksch.ITask, storeSkuList []int64, batchSize int, isContinueWhenError bool) (resultList []interface{}, err error) { func FreeBatchInfo(name string, handler func(tasksch.ITask, []*model.StoreSkuBind) (interface{}, int, error), ctx *jxcontext.Context, parentTask tasksch.ITask, storeSkuList []*model.StoreSkuBind, batchSize int, isContinueWhenError bool) (resultList []interface{}, err error) {
task := tasksch.NewParallelTask2(fmt.Sprintf("FreeBatchInfo:%s", name), tasksch.NewParallelConfig().SetParallelCount(1).SetBatchSize(batchSize).SetIsContinueWhenError(isContinueWhenError), ctx, task := tasksch.NewParallelTask2(fmt.Sprintf("FreeBatchInfo:%s", name), tasksch.NewParallelConfig().SetParallelCount(1).SetBatchSize(batchSize).SetIsContinueWhenError(isContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {
batchStoreSkuList := make([]int64, len(batchItemList)) batchStoreSkuList := make([]*model.StoreSkuBind, len(batchItemList))
for k, v := range batchItemList { for k, v := range batchItemList {
batchStoreSkuList[k] = v.(int64) batchStoreSkuList[k] = v.(*model.StoreSkuBind)
} }
retVal, successCount, err = handler(task, batchStoreSkuList) retVal, successCount, err = handler(task, batchStoreSkuList)
if err != nil { if err != nil {