From 3f778267f3c18dd67ce1874f06a3c3215f43daa3 Mon Sep 17 00:00:00 2001 From: shenjiachi Date: Mon, 16 Dec 2024 16:42:38 +0800 Subject: [PATCH] update --- consume/egg_record_active_consume.go | 4 ++-- consume/im_egg_energy_send_red_package_consume.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/consume/egg_record_active_consume.go b/consume/egg_record_active_consume.go index 1b662f4..4fe6eae 100644 --- a/consume/egg_record_active_consume.go +++ b/consume/egg_record_active_consume.go @@ -83,7 +83,7 @@ func handleEggRecordActiveDataConsume(msgData []byte) error { // 3.添加团队活跃次数 if userRelate != nil { parentUid := userRelate.ParentUid - parentEsId := fmt.Sprintf("%d%d-%d", year, week, parentUid) + parentEsId := fmt.Sprintf("%d%d_%d", year, week, parentUid) // 增加团队活跃次数记录 script := elastic.NewScript("ctx._source.team_activity_nums += params.inc").Param("inc", 1) _, err = es.EsClient.Update(). @@ -97,7 +97,7 @@ func handleEggRecordActiveDataConsume(msgData []byte) error { } // 4.更新签到次数 - esId := fmt.Sprintf("%d%d-%d", year, week, msg.Uid) + esId := fmt.Sprintf("%d%d_%d", year, week, msg.Uid) script := elastic.NewScript(` ctx._source.sign_in_nums += params.signInInc; `).Param("signInInc", 1) diff --git a/consume/im_egg_energy_send_red_package_consume.go b/consume/im_egg_energy_send_red_package_consume.go index 32c05ad..64014ed 100644 --- a/consume/im_egg_energy_send_red_package_consume.go +++ b/consume/im_egg_energy_send_red_package_consume.go @@ -69,7 +69,7 @@ func handleIMEggEnergySendRedPackageConsume(msgData []byte) error { yearStr := utils2.IntToStr(year) weekStr := utils2.IntToStr(week) index := es2.GetAppointIndexFromAlias(yearStr, weekStr) - id := fmt.Sprintf("%d%d-%d", year, week, msg.Uid) + id := fmt.Sprintf("%d%d_%d", year, week, msg.Uid) // 3.新增发红包次数 script := elastic.NewScript("ctx._source.send_red_package_nums += params.inc").Param("inc", 1) _, err = es.EsClient.Update().