diff --git a/handler/rss/job.go b/handler/rss/job.go index b626a81..4513349 100644 --- a/handler/rss/job.go +++ b/handler/rss/job.go @@ -60,24 +60,28 @@ func CheckNewRss() { } //比较最新的rss数据与订阅信息中的last_item_hash,若有更新则向对应群发送消息,并更新订阅信息中的last_item_hash log.Println("localHash:", group.LastItemHash, "remoteHash:", items[0].Hash) - if items[0].Hash != group.LastItemHash { - db.Model(&group).Update("last_item_hash", items[0].Hash) - action.ActionManager.SendMsg(&model.Reply{ - FromMsg: model.Message{ - GroupInfo: model.GroupInfo{ - GroupId: int64(group.GroupID), - IsGroupMsg: true, - }, - }, - ReplyMsg: []qq_message.QQMessage{ - &qq_message.TextMessage{ - Type: qq_message.TypeText, - Data: qq_message.TextMessageData{ - Text: fmt.Sprintf("您订阅的%s发布了新的文章: %s\n%s", title, items[0].Title, items[0].Link), + db.Model(&group).Update("last_item_hash", items[0].Hash) + for _, item := range items { + if item.Hash != group.LastItemHash { + action.ActionManager.SendMsg(&model.Reply{ + FromMsg: model.Message{ + GroupInfo: model.GroupInfo{ + GroupId: int64(group.GroupID), + IsGroupMsg: true, }, }, - }, - }) + ReplyMsg: []qq_message.QQMessage{ + &qq_message.TextMessage{ + Type: qq_message.TypeText, + Data: qq_message.TextMessageData{ + Text: fmt.Sprintf("您订阅的%s发布了新的文章: %s\n%s", title, items[0].Title, items[0].Link), + }, + }, + }, + }) + } else { + break + } } } }