ソースを参照

wip:删除索引信息

wangshan 8 ヶ月 前
コミット
bfbc2c5363
2 ファイル変更9 行追加4 行削除
  1. 1 1
      jy_member/go.mod
  2. 8 3
      jy_publishing/tool/task.go

+ 1 - 1
jy_member/go.mod

@@ -5,7 +5,7 @@ go 1.14
 require (
 	github.com/golang/protobuf v1.4.3
 	github.com/olivere/elastic/v7 v7.0.32
-	google.golang.org/grpc v1.33.2
+	google.golang.org/grpc v1.6.4
 	google.golang.org/protobuf v1.25.0
 	jygit.jydev.jianyu360.cn/BP/servicerd v0.0.0-20230621085048-b7e09df0c982
 	jygit.jydev.jianyu360.cn/data_processing/common_utils v0.0.0-20230627091444-ee2add33ba67

+ 8 - 3
jy_publishing/tool/task.go

@@ -431,18 +431,23 @@ func DelMethod(mold int, res string) {
 	switch mold {
 	case 8:
 		Index = "bidding_yg" //直采-采购信息
-		var ok bool
+		var (
+			ok bool
+			id string
+		)
 		data := Es.Get(Index, `{"query": {"bool": {"must": [{"terms": {"source_id": ["`+res+`"]}}]}},"from": 0,"size": 1}`)
 		if data != nil && len(*data) > 0 {
 			one := (*data)[0]
-			id := util.ObjToString(one["_id"])
+			id = util.ObjToString(one["id"])
 			if id != "" {
 				ok = Es.DelById(Index, id)
 			} else {
 				ok = Es.DelById(Index, res)
 			}
 		}
-		log.Println(ok, "用户删除发布信息后 删除索引信息失败:", data, "----", res)
+		if !ok {
+			log.Println(id, "用户删除发布信息后 删除索引信息失败:", data, "----", res)
+		}
 	default:
 		Es.DelById(Index, res)
 	}