|
|
@@ -87,7 +87,7 @@ func handleEggCanalPersonAddActivityValueConsume(msg []byte) error { |
|
|
|
} |
|
|
|
|
|
|
|
// 3. 增加个人活跃积分 |
|
|
|
script := elastic.NewScript("ctx._source.person_add_activity_value += params.inc").Param("inc", item.Amount) |
|
|
|
script := elastic.NewScript("ctx._source.person_add_activity_value += params.inc").Param("inc", utils2.StrToInt(item.Amount)) |
|
|
|
_, err = es.EsClient.Update(). |
|
|
|
Index(index). |
|
|
|
Id(id). |
|
|
|