diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index 5b42013c9..33a71d1cb 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -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: