(interval int64)
| 8 | ) |
| 9 | |
| 10 | func CleanExpireHistoryMsgs(interval int64) error { |
| 11 | parseDuration, _ := time.ParseDuration(fmt.Sprintf("-%dh", interval*24)) |
| 12 | expireTime := time.Now().Add(parseDuration) |
| 13 | roomIds := new_db.GetAllRoomIds() |
| 14 | for _, roomId := range roomIds { |
| 15 | ok := new_db.DeleteExpireEventsByRoomId(roomId, expireTime) |
| 16 | if !ok { |
| 17 | return errors.New("err when cleaning room:" + roomId) |
| 18 | } |
| 19 | } |
| 20 | return nil |
| 21 | } |