liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ebai store

Browse Source
This commit is contained in:
suyl
2021-07-30 15:16:42 +08:00
parent eacb7e0ccb
commit 143a0f38dc
1 changed files with 88 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -4335,11 +4335,33 @@ type MtPage struct {
BrandName string `json:"brand_name"`
}
type EbaiPage struct {
LibraryName string `json:"library_name"`
EleID string `orm:"column(ele_id)" json:"ele_id"`
MonthSales string `json:"month_sales"`
FirstOpenTime string `json:"first_open_time"`
Wid string `json:"wid"`
ShopScore string `json:"shop_score"`
StoreID string `orm:"column(store_id)" json:"store_id"`
Phone string `json:"phone"`
Classif string `json:"classif"`
ClassifyParameter string `json:"classify_parameter"`
Address string `json:"address"`
Settime string `json:"settime"`
Remark string `json:"remark"`
State int `json:"state"`
Lat string `json:"lat"`
Lng string `json:"lng"`
DistrictName string `json:"district_name"`
BrandName string `json:"brand_name"`
}
func RefreshPageStore() {
var (
db = dao.GetDB()
jds []*JdPage
mts []*MtPage
db = dao.GetDB()
jds []*JdPage
mts []*MtPage
ebais []*EbaiPage
)
//刷京东门店表的坐标和区名
sql := `
@@ -4413,6 +4435,43 @@ func RefreshPageStore() {
}
}
}
//刷饿百门店表的坐标和区名
sqlebai := `
SELECT * FROM elm_showd WHERE (lng IS NULL AND lat IS NULL) OR (lng = 0 AND lat = 0) OR (lng = '' AND lat = '')
`
dao.GetRows(db, &ebais, sqlebai, nil)
for _, v := range ebais {
if (v.Lat == "" && v.Lng == "") || (v.Lat == "0" && v.Lng == "0") {
if v.Address != "" {
if v.Remark != "" {
result, _ := api.AutonaviAPI.GetCoordinateFromAddressAll(v.Address, v.Remark)
lng, lat, dis := utils.Float64ToStr(result.Lng), utils.Float64ToStr(result.Lat), result.AdName
if lng == "" || lat == "" {
result1, _ := api.AutonaviAPI.GetCoordinateFromAddressAll(v.Address, "")
lng, lat, dis = utils.Float64ToStr(result1.Lng), utils.Float64ToStr(result1.Lat), result1.AdName
}
sql := `
UPDATE elm_showd SET lng = ?, lat = ?, district_name = ? WHERE store_id = ?
`
sqlparams := []interface{}{
lng, lat, dis, v.StoreID,
}
dao.ExecuteSQL(db, sql, sqlparams)
} else {
result1, _ := api.AutonaviAPI.GetCoordinateFromAddressAll(v.Address, "")
lng, lat, dis := utils.Float64ToStr(result1.Lng), utils.Float64ToStr(result1.Lat), result1.AdName
sql := `
UPDATE elm_showd SET lng = ?, lat = ?, district_name = ? WHERE store_id = ?
`
sqlparams := []interface{}{
lng, lat, dis, v.StoreID,
}
dao.ExecuteSQL(db, sql, sqlparams)
}
}
}
}
////商品表合并
//sql3 := ` TRUNCATE page_sku`
//dao.ExecuteSQL(db, sql3)
@@ -4459,6 +4518,7 @@ func RefreshPageStore() {
splitStr2 = []string{
"-", "（", "(", "•", " ", "【",
}
ebai2 []*EbaiPage
)
trySplitBrand := func(splitStr []string, name string) (brandName string) {
for _, v := range splitStr {
@@ -4500,6 +4560,21 @@ func RefreshPageStore() {
dao.ExecuteSQL(db, sql, sqlparams)
}
}
sqle := `
SELECT * FROM meituan_showd WHERE brand_name = '' OR brand_name IS NULL OR brand_name = '无' OR brand_name = '0'
`
dao.GetRows(db, &ebai2, sqle)
if len(ebai2) > 0 {
for _, v := range ebai2 {
sql := `
UPDATE elm_showd SET brand_name = ? WHERE store_id = ?
`
sqlparams := []interface{}{
trySplitBrand(splitStr2, v.LibraryName), v.StoreID,
}
dao.ExecuteSQL(db, sql, sqlparams)
}
}
sql9 := ` TRUNCATE page_brand`
dao.ExecuteSQL(db, sql9)
sql10 := `
@@ -4514,6 +4589,11 @@ func RefreshPageStore() {
SELECT DISTINCT a.brand_name
FROM meituan_showd a
)
UNION
(
SELECT DISTINCT a.brand_name
FROM elm_showd a
)
)t1
`
dao.ExecuteSQL(db, sql10)
@@ -4528,7 +4608,9 @@ func QueryPageStores2(db *dao.DaoDB, pageSize, offset int, keyword, vendorStoreI
FROM jingdong_showd
`
sqlEbai := `
SELECT library_name name, 3 vendor_id, store_id vendor_store_id, '' org_code, 1 vendor_status, address, phone tel1, shop_score, month_sales recent_order_num,
remark city_name, 0 sku_count, lat, lng, district_name, brand_name, classify_parameter category, first_open_time shipping_time
FROM elm_showd
`
sqlMT := `
SELECT name, 1 vendor_id, wmpoiid vendor_store_id, '' org_code, 1 vendor_status, address, phone tel1, pj shop_score, REPLACE(REPLACE(month_sales_tip,'月售',''),'+','') recent_order_num,
@@ -4542,8 +4624,8 @@ func QueryPageStores2(db *dao.DaoDB, pageSize, offset int, keyword, vendorStoreI
`
if vendorID == -1 {
sql += sqlJD + ` UNION`
sql += sqlMT
//sql += sqlEbai + ` UNION`
sql += sqlMT + `UNION`
sql += sqlEbai
} else {
switch vendorID {
case model.VendorIDJD: