aa

2021-05-11 11:08:06 +08:00
parent 1dd5b592a8
commit 26940b3a12
3 changed files with 119 additions and 3 deletions
--- a/business/model/dao/page_store.go
+++ b/business/model/dao/page_store.go
@@ -99,3 +99,113 @@ 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, set 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.name city_name, t3.name district_name
+				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.
+	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)
+		}
+	}()
+	if err = GetRowsTx(txDB, &shopList, sql, sqlParams...); err == nil {
+		pagedInfo = &model.PagedInfo{
+			TotalCount: GetLastTotalRowCount2(db, txDB),
+			Data:       shopList,
+		}
+		Commit(db, txDB)
+	} else {
+		Rollback(db, txDB)
+	}
+	return pagedInfo, err
+}