redis.go 946 B

123456789101112131415161718192021222324252627282930313233343536373839
  1. package archive
  2. import (
  3. "context"
  4. "go-common/library/cache/redis"
  5. "go-common/library/log"
  6. )
  7. const (
  8. _lockingVideo = "videoup_admin_locking_video"
  9. )
  10. // IsLockingVideo 是否正在自动锁定视频
  11. func (d *Dao) IsLockingVideo(c context.Context) (locking bool, err error) {
  12. conn := d.redis.Get(c)
  13. defer conn.Close()
  14. if locking, err = redis.Bool(conn.Do("EXISTS", _lockingVideo)); err != nil {
  15. log.Error("conn.Do(EXISTS,%s) error(%v)", _lockingVideo, err)
  16. }
  17. return
  18. }
  19. // LockingVideo 设置是否正在自动锁定视频
  20. func (d *Dao) LockingVideo(c context.Context, v int8) (err error) {
  21. var conn = d.redis.Get(c)
  22. defer conn.Close()
  23. if v == 1 {
  24. if _, err = conn.Do("SET", _lockingVideo, v); err != nil {
  25. log.Error("conn.Do(SET, %s,%d) error(%v)", _lockingVideo, v, err)
  26. }
  27. } else {
  28. if _, err = conn.Do("DEL", _lockingVideo); err != nil {
  29. log.Error("conn.Do(SET, %s) error(%v)", _lockingVideo, err)
  30. }
  31. }
  32. return
  33. }