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 15:36:22 +08:00
parent 03dd2c45d0
commit 1f3de84373
1 changed files with 31 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1827,53 +1827,49 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// }) // })
// } // }
var ( var (
db = dao.GetDB() db = dao.GetDB()
idLists2 [][]int64
) )
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")
things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"}) things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"})
for i := 0; i < len(things); i += 50 { // for i := 0; i < len(things); i += 50 {
// var idList []*jdapi.SkuIdEntity // // var idList []*jdapi.SkuIdEntity
var idList2 []int64 // var idList2 []int64
j := i + 50 // j := i + 50
if j > len(things)-1 { // if j > len(things)-1 {
j = len(things) - 1 // j = len(things) - 1
} // }
for _, v := range things[i:j] { // for _, v := range things[i:j] {
if v.VendorThingID != "" { // if v.VendorThingID != "" {
// idList = append(idList, &jdapi.SkuIdEntity{ // // idList = append(idList, &jdapi.SkuIdEntity{
// OutSkuId: utils.Int64ToStr(v.ThingID), // // OutSkuId: utils.Int64ToStr(v.ThingID),
// }) // // })
idList2 = append(idList2, utils.Str2Int64(v.VendorThingID)) // idList2 = append(idList2, utils.Str2Int64(v.VendorThingID))
} // }
} // }
// idLists = append(idLists, idList) // // idLists = append(idLists, idList)
idLists2 = append(idLists2, idList2) // idLists2 = append(idLists2, idList2)
} // }
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)
for _, v := range idLists2 { task2 := tasksch.NewParallelTask("uuuuu2", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
if v != nil && storeMap != nil { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, v) thing := batchItemList[0].(*model.ThingMap)
var idLists []*jdapi.SkuIdEntity priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, []int64{utils.Str2Int64(thing.VendorThingID)})
for _, vv := range priceInfo { for _, vv := range priceInfo {
if vv.VipPrice != 0 { if vv.VipPrice != 0 {
thingMap := &model.ThingMap{} err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), []*jdapi.SkuIdEntity{
sql := ` &jdapi.SkuIdEntity{
SELECT * FROM thing_map WHERE thing_type = 3 AND deletad_at = '1970-01-01 00:00:00' AND vendor_org_code = 320406 AND vendor_id = 0 AND vendor_thing_id = ? OutSkuId: utils.Int64ToStr(thing.ThingID),
` },
sqlParams := []interface{}{vv.SkuID}
dao.GetRow(db, &thingMap, sql, sqlParams)
idLists = append(idLists, &jdapi.SkuIdEntity{
OutSkuId: utils.Int64ToStr(thingMap.ThingID),
}) })
} }
} }
err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), idLists) return retVal, err
} }, things)
} tasksch.HandleTask(task2, nil, true).Run()
_, err = task2.GetResult(0)
return retVal, err return retVal, err
}, storeMaps) }, storeMaps)
tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()