diff --git a/controller/pddCatId.go b/controller/pddCatId.go deleted file mode 100644 index 62a7db5..0000000 --- a/controller/pddCatId.go +++ /dev/null @@ -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() -//} diff --git a/es/es_search.go b/es/es_search.go index cfc7421..0995910 100644 --- a/es/es_search.go +++ b/es/es_search.go @@ -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(