Function sendRssUpdateMsg

plugin/rsshub/main.go:145–164

sendRssUpdateMsg 发送Rss更新消息

(ctx *zero.Ctx, groupToFeedsMap map[int64][]*domain.RssClientView)

// sendRssUpdateMsg 发送Rss更新消息
func sendRssUpdateMsg(ctx *zero.Ctx, groupToFeedsMap map[int64][]*domain.RssClientView) {
	for groupID, views := range groupToFeedsMap {
		logrus.Infof("RssHub插件在群 %d 触发推送检查", groupID)
		for _, view := range views {
			if view == nil || len(view.Contents) == 0 {
				continue
			}
			msg, err := newRssDetailsMsg(ctx, view)
			if len(msg) == 0 || err != nil {
				ctx.SendPrivateMessage(zero.BotConfig.SuperUsers[0], message.Text(rssHubPushErrMsg, err))
				continue
			}
			logrus.Infof("RssHub插件在群 %d 开始推送 %s", groupID, view.Source.Title)
			ctx.SendGroupMessage(groupID, message.Text(fmt.Sprintf("%s\n该RssHub频道下有更新了哦~", view.Source.Title)))
			if res := ctx.SendGroupForwardMessage(groupID, msg); !res.Exists() {
				ctx.SendPrivateMessage(zero.BotConfig.SuperUsers[0], message.Text(rssHubPushErrMsg))
			}
		}
	}
}