This commit is contained in:
suyl
2021-05-11 16:39:14 +08:00
parent f581387aa8
commit 1f8bf71865

View File

@@ -4325,7 +4325,7 @@ func QueryPageStores2(db *dao.DaoDB, pageSize, offset int, keyword string, vendo
}
dao.Commit(db, txDB)
var newShopList []*dao.PageShopWithPlaceName
task := tasksch.NewParallelTask("", tasksch.NewParallelConfig().SetIsContinueWhenError(true), nil,
task := tasksch.NewParallelTask("", tasksch.NewParallelConfig().SetIsContinueWhenError(true), jxcontext.AdminCtx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*dao.PageShopWithPlaceName)
if v.Address != "" && v.CityName != "" {