DaShangDao/daShangDao_centerBook
8
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

redis连接对象

Browse Source 
db4(2) -> db1
This commit is contained in:
97694731 2026-03-14 12:00:00 +08:00
parent fe34007bd8
commit 6dd5815666
2 changed files with 8 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
controller/pddCatId.go
View File

@ -1,58 +0,0 @@
package controller
//import (
// "centerBook/util/esClient"
// "centerBook/util/pdd"
// "centerBook/util/redisClient"
// "context"
// "log"
//)
//
//// 推测pddCatId类目
//func getPddCatId() {
//
// ctx := context.Background()
// // 为两个数据库创建命名客户端
// redisClient.AddClient("db4", "36.212.20.113", "j8nZ4jra2E", 4)
// redisClient.AddClient("db14", "36.212.20.113", "j8nZ4jra2E", 14)
//
// // 从 db4 获取数据示例
// db4Client, err := redisClient.GetClientByName("db4")
// if err == nil {
// // 示例：获取键为 "key1" 的值
// val, err := db4Client.Get(ctx, "1995373681100910593").Result()
// if err == nil {
// log.Println(val)
// }
// }
//
// bookName := ""
//
// instance, err := pdd.GetPddInstance()
// if err != nil {
// return
// }
// instance.PddGoodsOuterCatMappingGet("", "15543", "书籍/杂志/报纸", "书籍 "+bookName)
//
// // 从 db14 获取数据示例
// db14Client, err := redisClient.GetClientByName("db14")
// if err == nil {
// // 示例：获取键为 "key2" 的值
// val, err := db14Client.Get(ctx, "key2").Result()
// if err == nil {
// // 处理获取到的值
// }
// }
//
//}
//
//// connectES 连接到 Elasticsearch
//func connectES(addresses []string, username, password string) (*esClient.ESClient, error) {
// return esClient.NewESClient(addresses, username, password)
//}
//
//// connectRedis 连接到 Redis
//func connectRedis(addr, password string, db int) {
// redisClient.InitRedis(addr, password, db)
// redisClient.GetClient()
//}

14
es/es_search.go
View File

@ -2054,11 +2054,11 @@ func (svc *ESSearchService) SearchBooksHandler(c *gin.Context) {
ctx := context.Background()
db4Client, err := redisClient.GetClientByName("db4")
db4Client, err := redisClient.GetClientByName("db1")
if err == nil {
val, err := db4Client.Get(ctx, isbn).Result()
if err == nil && val != "" {
log.Printf("[SearchBooksHandler] 从 Redis db4 查询到数据: %s", isbn)
log.Printf("[SearchBooksHandler] 从 Redis db1 查询到数据: %s", isbn)
var esBook ESBook
if err := json.Unmarshal([]byte(val), &esBook); err == nil {
responseList := []ESBookResponse{esBook.ConvertToResponse()}
@ -2102,15 +2102,15 @@ func (svc *ESSearchService) SearchBookByISBNHandler(c *gin.Context) {
ctx := context.Background()
db4Client, err := redisClient.GetClientByName("db4")
db4Client, err := redisClient.GetClientByName("db1")
fmt.Println(db4Client)
if err != nil {
log.Printf("[SearchBookByISBNHandler] 获取 Redis db4 客户端失败: %v", err)
log.Printf("[SearchBookByISBNHandler] 获取 Redis db1 客户端失败: %v", err)
} else {
val, err := db4Client.Get(ctx, isbn).Result()
if err == nil && val != "" {
log.Printf("[SearchBookByISBNHandler] 从 Redis db4 查询到数据: %s", isbn)
log.Printf("[SearchBookByISBNHandler] 从 Redis db1 查询到数据: %s", isbn)
var esBook ESBook
if err := json.Unmarshal([]byte(val), &esBook); err == nil {
responseData := esBook.ConvertToResponse()
@ -2122,7 +2122,7 @@ func (svc *ESSearchService) SearchBookByISBNHandler(c *gin.Context) {
log.Printf("[SearchBookByISBNHandler] Redis 数据解析失败: %v", err)
}
} else {
log.Printf("[SearchBookByISBNHandler] Redis db4 中未找到 ISBN: %s", isbn)
log.Printf("[SearchBookByISBNHandler] Redis db1 中未找到 ISBN: %s", isbn)
}
}
@ -2497,6 +2497,8 @@ func (svc *ESSearchService) UpdateBookSuitByISBNHandler(c *gin.Context) {
},
}
fmt.Println(body)
payload, _ := json.Marshal(body)
res, err := svc.ES.Client.UpdateByQuery(