From bfcc54c4894900aaca21d2808040ec139397e275 Mon Sep 17 00:00:00 2001 From: shenjiachi Date: Fri, 13 Dec 2024 16:28:18 +0800 Subject: [PATCH] fix update person add activity value --- consume/egg_canal_person_add_activity_value_consume.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consume/egg_canal_person_add_activity_value_consume.go b/consume/egg_canal_person_add_activity_value_consume.go index 14ee4b8..bc97bf6 100644 --- a/consume/egg_canal_person_add_activity_value_consume.go +++ b/consume/egg_canal_person_add_activity_value_consume.go @@ -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).