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:36:27 +08:00
parent deece80b16
commit f581387aa8
3 changed files with 140 additions and 143 deletions
Download Patch File Download Diff File Expand all files Collapse all files

138
business/jxstore/cms/store.go
View File

@@ -4219,3 +4219,141 @@ func UpdateVendorStoreBussinessStatus(ctx *jxcontext.Context, storeID, vendorID,
err = handler.UpdateStoreLineStatus(ctx, storeDetail.VendorOrgCode, storeID, storeDetail.VendorStoreID, status)
return err
}
func QueryPageStores2(db *dao.DaoDB, pageSize, offset int, keyword string, vendorStoreID string, vendorID, cityCode, districtCode int, tel string,
minShopScore float32, minRecentOrderNum, minSkuCount int, lng1, lat1, lng2, lat2 float64) (pagedInfo *model.PagedInfo, err error) {
sqlJD := `
SELECT name, 0 vendor_id, wmpoiid vendor_store_id, orgcode org_code, 1 vendor_status, address, phone tel1, pj shop_score, month_sales_tip recent_order_num,
bak_info city_name
FROM jingdong_showd
`
sqlEbai := `
`
sqlMT := `
`
sql := `
SELECT SQL_CALC_FOUND_ROWS
t1.*, t2.code city_code
FROM (
`
if vendorID == -1 {
sql += sqlJD
//+ ` UNION`
//sql += sqlEbai + ` UNION`
//sql += sqlMT
} else {
switch vendorID {
case model.VendorIDJD:
sql += sqlJD
case model.VendorIDMTWM:
sql += sqlMT
case model.VendorIDEBAI:
sql += sqlEbai
}
}
sql += `
)t1
LEFT JOIN place t2 ON t2.name = t1.city_name AND t2.level = 2
WHERE 1 = 1
`
sqlParams := []interface{}{}
if vendorStoreID != "" {
sql += " AND t1.vendor_store_id = ?"
sqlParams = append(sqlParams, vendorStoreID)
}
if vendorID != -1 {
sql += " AND t1.vendor_id = ?"
sqlParams = append(sqlParams, vendorID)
}
if cityCode != 0 {
sql += " AND t1.city_code = ?"
sqlParams = append(sqlParams, cityCode)
}
if districtCode != 0 {
sql += " AND t1.district_code = ?"
sqlParams = append(sqlParams, districtCode)
}
if tel != "" {
sql += " AND t1.tel1 = ?"
sqlParams = append(sqlParams, tel)
}
if minShopScore > 0 {
sql += " AND t1.shop_score >= ?"
sqlParams = append(sqlParams, minShopScore)
}
if minRecentOrderNum > 0 {
sql += " AND t1.recent_order_num >= ?"
sqlParams = append(sqlParams, minRecentOrderNum)
}
//if minSkuCount > 0 {
// sql += " AND t1.sku_count >= ?"
// sqlParams = append(sqlParams, minSkuCount)
//}
//if lng1 > 0 {
// sql += " AND t1.lng >= ? AND t1.lat >= ? AND t1.lng <= ? AND t1.lat <= ?"
// sqlParams = append(sqlParams, lng1, lat1, lng2, lat2)
//}
if keyword != "" {
keywordLike := "%" + keyword + "%"
sql += " AND (t1.name LIKE ? OR t1.tel1 LIKE ? OR t1.tel2 LIKE ? OR t1.org_code LIKE ? OR t1.address LIKE ? OR t2.name LIKE ? OR t3.name LIKE ? OR t1.licence_code LIKE ?"
sqlParams = append(sqlParams, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike)
sql += ")"
}
sql += `
ORDER BY t1.recent_order_num DESC
LIMIT ? OFFSET ?
`
pageSize = jxutils.FormalizePageSize(pageSize)
offset = jxutils.FormalizePageOffset(offset)
sqlParams = append(sqlParams, pageSize, offset)
var shopList []*dao.PageShopWithPlaceName
txDB, _ := dao.Begin(db)
defer func() {
if r := recover(); r != nil {
dao.Rollback(db, txDB)
panic(r)
}
}()
fmt.Println(sql)
fmt.Println(sqlParams)
if err = dao.GetRowsTx(txDB, &shopList, sql, sqlParams...); err == nil {
pagedInfo = &model.PagedInfo{
TotalCount: dao.GetLastTotalRowCount2(db, txDB),
//Data: shopList,
}
dao.Commit(db, txDB)
var newShopList []*dao.PageShopWithPlaceName
task := tasksch.NewParallelTask("", tasksch.NewParallelConfig().SetIsContinueWhenError(true), nil,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*dao.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 = []*dao.PageShopWithPlaceName{v}
}
} else {
retVal = []*dao.PageShopWithPlaceName{v}
}
retVal = []*dao.PageShopWithPlaceName{v}
} else {
retVal = []*dao.PageShopWithPlaceName{v}
}
return retVal, err
}, shopList)
tasksch.HandleTask(task, nil, true).Run()
result, _ := task.GetResult(0)
for _, v := range result {
newShopList = append(newShopList, v.(*dao.PageShopWithPlaceName))
}
pagedInfo.Data = newShopList
} else {
dao.Rollback(db, txDB)
}
return pagedInfo, err
}

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

@@ -1,12 +1,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"
)
type PageShopWithPlaceName struct {
@@ -103,141 +99,3 @@ func QueryPageStores(db *DaoDB, pageSize, offset int, keyword string, vendorStor
}
return pagedInfo, err
}
func QueryPageStores2(db *DaoDB, pageSize, offset int, keyword string, vendorStoreID string, vendorID, cityCode, districtCode int, tel string,
minShopScore float32, minRecentOrderNum, minSkuCount int, lng1, lat1, lng2, lat2 float64) (pagedInfo *model.PagedInfo, err error) {
sqlJD := `
SELECT name, 0 vendor_id, wmpoiid vendor_store_id, orgcode org_code, 1 vendor_status, address, phone tel1, pj shop_score, month_sales_tip recent_order_num,
bak_info city_name
FROM jingdong_showd
`
sqlEbai := `
`
sqlMT := `
`
sql := `
SELECT SQL_CALC_FOUND_ROWS
t1.*, t2.code city_code
FROM (
`
if vendorID == -1 {
sql += sqlJD
//+ ` UNION`
//sql += sqlEbai + ` UNION`
//sql += sqlMT
} else {
switch vendorID {
case model.VendorIDJD:
sql += sqlJD
case model.VendorIDMTWM:
sql += sqlMT
case model.VendorIDEBAI:
sql += sqlEbai
}
}
sql += `
)t1
LEFT JOIN place t2 ON t2.name = t1.city_name AND t2.level = 2
WHERE 1 = 1
`
sqlParams := []interface{}{}
if vendorStoreID != "" {
sql += " AND t1.vendor_store_id = ?"
sqlParams = append(sqlParams, vendorStoreID)
}
if vendorID != -1 {
sql += " AND t1.vendor_id = ?"
sqlParams = append(sqlParams, vendorID)
}
if cityCode != 0 {
sql += " AND t1.city_code = ?"
sqlParams = append(sqlParams, cityCode)
}
if districtCode != 0 {
sql += " AND t1.district_code = ?"
sqlParams = append(sqlParams, districtCode)
}
if tel != "" {
sql += " AND t1.tel1 = ?"
sqlParams = append(sqlParams, tel)
}
if minShopScore > 0 {
sql += " AND t1.shop_score >= ?"
sqlParams = append(sqlParams, minShopScore)
}
if minRecentOrderNum > 0 {
sql += " AND t1.recent_order_num >= ?"
sqlParams = append(sqlParams, minRecentOrderNum)
}
//if minSkuCount > 0 {
// sql += " AND t1.sku_count >= ?"
// sqlParams = append(sqlParams, minSkuCount)
//}
//if lng1 > 0 {
// sql += " AND t1.lng >= ? AND t1.lat >= ? AND t1.lng <= ? AND t1.lat <= ?"
// sqlParams = append(sqlParams, lng1, lat1, lng2, lat2)
//}
if keyword != "" {
keywordLike := "%" + keyword + "%"
sql += " AND (t1.name LIKE ? OR t1.tel1 LIKE ? OR t1.tel2 LIKE ? OR t1.org_code LIKE ? OR t1.address LIKE ? OR t2.name LIKE ? OR t3.name LIKE ? OR t1.licence_code LIKE ?"
sqlParams = append(sqlParams, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike)
sql += ")"
}
sql += `
ORDER BY t1.recent_order_num DESC
LIMIT ? OFFSET ?
`
pageSize = jxutils.FormalizePageSize(pageSize)
offset = jxutils.FormalizePageOffset(offset)
sqlParams = append(sqlParams, pageSize, offset)
var shopList []*PageShopWithPlaceName
txDB, _ := Begin(db)
defer func() {
if r := recover(); r != nil {
Rollback(db, txDB)
panic(r)
}
}()
fmt.Println(sql)
fmt.Println(sqlParams)
if err = GetRowsTx(txDB, &shopList, sql, sqlParams...); err == nil {
pagedInfo = &model.PagedInfo{
TotalCount: GetLastTotalRowCount2(db, txDB),
//Data: shopList,
}
Commit(db, txDB)
var newShopList []*PageShopWithPlaceName
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 {
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 = newShopList
} else {
Rollback(db, txDB)
}
return pagedInfo, err
}

3
controllers/net_spider.go
View File

@@ -2,6 +2,7 @@ package controllers
import (
"fmt"
"git.rosy.net.cn/jx-callback/business/jxstore/cms"
"sort"
"git.rosy.net.cn/baseapi/utils"
@@ -82,7 +83,7 @@ func (c *NetSpiderController) QueryPageStores() {
offset = 0
pageSize = model.UnlimitedPageSize
}
pagedInfo, err := dao.QueryPageStores2(dao.GetDB(), pageSize, offset, params.Keyword, params.VendorStoreID, params.VendorID,
pagedInfo, err := cms.QueryPageStores2(dao.GetDB(), pageSize, offset, params.Keyword, params.VendorStoreID, params.VendorID,
params.CityCode, params.DistrictCode, params.Tel, float32(params.MinShopScore), params.MinRecentOrderNum, params.MinSkuCount,
lng1, lat1, lng2, lat2)
if err == nil {