From deece80b1634c7d8dcfba1d44f1bce5d7b3f4a88 Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Tue, 11 May 2021 16:26:59 +0800
Subject: [PATCH] aa

---
 business/model/dao/page_store.go | 40 ++++++++++++++++++++------------
 1 file changed, 25 insertions(+), 15 deletions(-)

diff --git a/business/model/dao/page_store.go b/business/model/dao/page_store.go
index accbe3a6a..177a79d8e 100644
--- a/business/model/dao/page_store.go
+++ b/business/model/dao/page_store.go
@@ -3,6 +3,8 @@ package dao
 import (
 	"fmt"
 	"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/globals/api"
 )
@@ -207,25 +209,33 @@ func QueryPageStores2(db *DaoDB, pageSize, offset int, keyword string, vendorSto
 		}
 		Commit(db, txDB)
 		var newShopList []*PageShopWithPlaceName
-		for _, v := range shopList {
-			if v.Address != "" && v.CityName != "" {
-				result, _ := api.AutonaviAPI.GetCoordinateFromAddressByPageAll(v.Address, v.CityCode)
-				lng, lat := result.Lng, result.Lat
-				v.DistrictName = result.AdName
-				v.Lng, v.Lat = lng, lat
-				if lng1 > 0 {
-					if !(lng >= lng1 && lat >= lat1 && lng <= lng2 && lat <= lat2) {
-						newShopList = append(newShopList, v)
+		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 != "" {
+					result, _ := api.AutonaviAPI.GetCoordinateFromAddressByPageAll(v.Address, v.CityCode)
+					lng, lat := result.Lng, result.Lat
+					v.DistrictName = result.AdName
+					v.Lng, v.Lat = lng, lat
+					if lng1 > 0 {
+						if !(lng >= lng1 && lat >= lat1 && lng <= lng2 && lat <= lat2) {
+							retVal = []*PageShopWithPlaceName{v}
+						}
+					} else {
+						retVal = []*PageShopWithPlaceName{v}
 					}
+					retVal = []*PageShopWithPlaceName{v}
 				} else {
-					newShopList = append(newShopList, v)
+					retVal = []*PageShopWithPlaceName{v}
 				}
-				newShopList = append(newShopList, v)
-			} else {
-				newShopList = append(newShopList, 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 {
 		Rollback(db, txDB)
 	}