From 04ee23549ee5355000a90a182524e53638dd9cab Mon Sep 17 00:00:00 2001 From: shenjiachi Date: Wed, 4 Dec 2024 17:55:56 +0800 Subject: [PATCH] update --- rule/egg_energy/md/mq_im.go | 7 ++++++- svc/svc_es.go | 10 +++++++++- 2 files changed, 15 insertions(+), 2 deletions(-) diff --git a/rule/egg_energy/md/mq_im.go b/rule/egg_energy/md/mq_im.go index c9b16b1..de06bf5 100644 --- a/rule/egg_energy/md/mq_im.go +++ b/rule/egg_energy/md/mq_im.go @@ -3,7 +3,8 @@ package md const IMEggEnergyExchange = "im.egg.energy" const ( - IMEggEnergyRoutKeyForBatchSendMessageData = "batch_send_message_data" // 批量发送信息 + IMEggEnergyRoutKeyForBatchSendMessageData = "batch_send_message_data" // 批量发送信息 + IMEggEnergyRoutKeyForDelFriendCircleCommentData = "del_friend_circle_comment_data" // 删除朋友圈评论 ) type IMEggEnergyStructForBatchSendMessageData struct { @@ -13,3 +14,7 @@ type IMEggEnergyStructForBatchSendMessageData struct { ReceiveIMId int64 `json:"receive_id"` // 接受者IM id Content string `json:"content"` // 消息内容 } + +type IMEggEnergyStructForDelFriendCircleCommentData struct { + CommentIndexId string `json:"comment_index_id"` // 文章索引 +} diff --git a/svc/svc_es.go b/svc/svc_es.go index 7f2296c..d3cd09e 100644 --- a/svc/svc_es.go +++ b/svc/svc_es.go @@ -14,8 +14,16 @@ func GetEggFriendCircleCommentEsIndexId(userId int64, circleId string) string { return circleId + "_" + strconv.FormatInt(userId, 10) + "_" + egg_system_rules.Int64ToStr(time.Now().Unix()) } +func GetEggFriendCircleLikeEsIndex(userId int64) string { + return md.EggFriendCircleLikeEsIndex + GetUserIdSuffix(userId) +} +func GetEggFriendCircleLikeEsIndexId(userId int64, circleId string) string { + return circleId + "_" + strconv.FormatInt(userId, 10) +} + func GetUserIdSuffix(userId int64) string { numberStr := strconv.FormatInt(userId, 10) // 将数字转换为字符串 lastChar := numberStr[len(numberStr)-1] // 获取最后一个字符 - return strconv.Itoa(int(lastChar)) + //return strconv.Itoa(int(lastChar)) // 将 byte 类型的值隐式转换为 int + return string(lastChar) }