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-11 16:26:59 +08:00
parent 20718f4e9d
commit deece80b16
1 changed files with 25 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
business/model/dao/page_store.go
View File

@@ -3,6 +3,8 @@ package dao
import ( import (
"fmt" "fmt"
"git.rosy.net.cn/jx-callback/business/jxutils" "git.rosy.net.cn/jx-callback/business/jxutils"
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/globals/api" "git.rosy.net.cn/jx-callback/globals/api"
) )
@@ -207,7 +209,9 @@ func QueryPageStores2(db *DaoDB, pageSize, offset int, keyword string, vendorSto
} }
Commit(db, txDB) Commit(db, txDB)
var newShopList []*PageShopWithPlaceName var newShopList []*PageShopWithPlaceName
for _, v := range shopList { task := tasksch.NewParallelTask("刷新商品前缀水印图", tasksch.NewParallelConfig().SetIsContinueWhenError(true), jxcontext.AdminCtx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*PageShopWithPlaceName)
if v.Address != "" && v.CityName != "" { if v.Address != "" && v.CityName != "" {
result, _ := api.AutonaviAPI.GetCoordinateFromAddressByPageAll(v.Address, v.CityCode) result, _ := api.AutonaviAPI.GetCoordinateFromAddressByPageAll(v.Address, v.CityCode)
lng, lat := result.Lng, result.Lat lng, lat := result.Lng, result.Lat
@@ -215,17 +219,23 @@ func QueryPageStores2(db *DaoDB, pageSize, offset int, keyword string, vendorSto
v.Lng, v.Lat = lng, lat v.Lng, v.Lat = lng, lat
if lng1 > 0 { if lng1 > 0 {
if !(lng >= lng1 && lat >= lat1 && lng <= lng2 && lat <= lat2) { if !(lng >= lng1 && lat >= lat1 && lng <= lng2 && lat <= lat2) {
newShopList = append(newShopList, v) retVal = []*PageShopWithPlaceName{v}
} }
} else { } else {
newShopList = append(newShopList, v) retVal = []*PageShopWithPlaceName{v}
} }
newShopList = append(newShopList, v) retVal = []*PageShopWithPlaceName{v}
} else { } else {
newShopList = append(newShopList, v) retVal = []*PageShopWithPlaceName{v}
} }
return retVal, err
}, shopList)
tasksch.HandleTask(task, nil, true).Run()
result, _ := task.GetResult(0)
for _, v := range result {
newShopList = append(newShopList, v.(*PageShopWithPlaceName))
} }
pagedInfo.Data = shopList pagedInfo.Data = newShopList
} else { } else {
Rollback(db, txDB) Rollback(db, txDB)
} }