|
|
@@ -438,7 +438,7 @@ func SaveEsMethod() {
|
|
|
select {
|
|
|
case v := <-saveEsPool:
|
|
|
id := v["id"]
|
|
|
- ids := v["_id"]
|
|
|
+ //ids := v["_id"]
|
|
|
//如果优选，存在上次的优选ID，需要删除上次的ID索引
|
|
|
oid := util.ObjToString(v["old_preferid"])
|
|
|
delete(v, "old_preferid")
|
|
|
@@ -520,7 +520,7 @@ func SaveEsMethod() {
|
|
|
// 华为云新集群2，迁移原来阿里云数据
|
|
|
if config.Conf.DB.Es.Addr3 != "" {
|
|
|
v["id"] = id
|
|
|
- v["_id"] = ids
|
|
|
+ //v["_id"] = ids
|
|
|
delete(v, "old_preferid")
|
|
|
if oid != "" {
|
|
|
err := Es3.DeleteByID(config.Conf.DB.Es.IndexB, oid)
|
|
|
@@ -528,7 +528,10 @@ func SaveEsMethod() {
|
|
|
log.Info("SaveEsMethod", zap.String("上次优选ID删除失败", oid))
|
|
|
}
|
|
|
}
|
|
|
- Es3.Save(config.Conf.DB.Es.Indexb3, v)
|
|
|
+ err = Es3.SaveDocument(config.Conf.DB.Es.Indexb3, v)
|
|
|
+ if err != nil {
|
|
|
+ log.Error("SaveEsMethod,config.Conf.DB.Es.Addr3 保存bidding_temp数据到es；保存失败", zap.Error(err), zap.Any("id", id))
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
wcc