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 17:21:08 +08:00
parent fdfc3ab5d1
commit b7852f2f65
1 changed files with 36 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1827,10 +1827,9 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// }) // })
// } // }
var ( var (
db = dao.GetDB() db = dao.GetDB()
// vendorThingIDs []int64 vendorThingIDs []int64
) )
var lists []*jdapi.SkuIdEntity
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")
// for _, v := range storeMaps { // for _, v := range storeMaps {
// storesSkus, _ := dao.GetStoresSkusInfo(db, []int{v.StoreID}, nil) // storesSkus, _ := dao.GetStoresSkusInfo(db, []int{v.StoreID}, nil)
@@ -1841,52 +1840,53 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// } // }
// } // }
things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []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 != "" {
lists = append(lists, &jdapi.SkuIdEntity{ // lists = append(lists, &jdapi.SkuIdEntity{
OutSkuId: utils.Int64ToStr(v.ThingID), // OutSkuId: utils.Int64ToStr(v.ThingID),
}) // })
// 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)
// resultList, _ := FreeBatchInfo("uuuuu", 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) {
// priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList) priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
// for _, vv := range priceInfo { for _, vv := range priceInfo {
// // if vv.VipPrice != 0 { if vv.VipPrice != 0 {
// // err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), []*jdapi.SkuIdEntity{ fmt.Println("vipPrice", vv.SkuID)
// // &jdapi.SkuIdEntity{ err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), []*jdapi.SkuIdEntity{
// // OutSkuId: thingIDmap[vv.SkuID], &jdapi.SkuIdEntity{
// // }, OutSkuId: thingIDmap[vv.SkuID],
// // }) },
// result = []int64{vv.SkuID} })
// // } // result = []int64{vv.SkuID}
// } }
// return result, 0, err }
// }, ctx, task, vendorThingIDs, 40, true) return result, 0, err
}, ctx, task, vendorThingIDs, 50, true)
// for _, v := range resultList { // for _, v := range resultList {
// var thingmaps []*model.ThingMap // var thingmaps []*model.ThingMap
// sql := ` // sql := `
// SELECT * FROM thing_map WHERE vendor_thing_id = ? AND vendor_org_code = ? AND deleted_at = ? // SELECT * FROM thing_map WHERE vendor_thing_id = ? AND vendor_org_code = ? AND deleted_at = ?
// ` // `
// sqlParams := []interface{}{v, 320406, utils.DefaultTimeValue} // sqlParams := []interface{}{v, 320406, utils.DefaultTimeValue}
// err = dao.GetRows(db, &thingmaps, sql, sqlParams) // err = dao.GetRows(db, &thingmaps, sql, sqlParams)
// for _, vv := range thingmaps { // for _, vv := range thingmaps {
// lists = append(lists, &jdapi.SkuIdEntity{ // lists = append(lists, &jdapi.SkuIdEntity{
// OutSkuId: thingIDmap[v.(int64)], // OutSkuId: thingIDmap[v.(int64)],
// }) // })
// }
// } // }
// } // FreeBatchInfo2("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*jdapi.SkuIdEntity) (result interface{}, successCount int, err error) {
FreeBatchInfo2("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*jdapi.SkuIdEntity) (result interface{}, successCount int, err error) { // err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), batchedStoreSkuList)
err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), batchedStoreSkuList) // return result, 0, err
return result, 0, err // }, ctx, task, lists, 50, true)
}, ctx, task, lists, 50, true)
return retVal, err return retVal, err
}, storeMaps) }, storeMaps)
tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()