|
|
@@ -102,7 +102,7 @@ func handleEggCanalViolateNumsConsume(msg []byte) error { |
|
|
|
|
|
|
|
// 2.3 更新违规记录 |
|
|
|
updateMap := make(map[string]interface{}) |
|
|
|
updateMap["violate_nums"] = res[0]["total"] |
|
|
|
updateMap["violate_nums"] = utils2.StrToInt(res[0]["total"]) |
|
|
|
updateDocRet, err := es.UpdateDoc(index, id, updateMap) |
|
|
|
if err != nil { |
|
|
|
if strings.Contains(err.Error(), "elastic: Error 404 (Not Found)") { |
|
|
|