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).