package etimer

import (
	"container/list"
	"time"
)

func (u *ExtendTimerMgr) StartMillSecGoroutine() {
	u.wg.Add(1)
	defer func() {
		u.wg.Done()
	}()

	runTimer := time.NewTimer(time.Millisecond * 10)
	defer func() {
		runTimer.Stop()
	}()

	select {
	case <-runTimer.C:
		{
			curMillSecond := getMillSecond()
			if curMillSecond < u.lastMillSec {
				ELog.Error("[ExtendTimerMgr] Time Rollback")
				return
			}
			delta := curMillSecond - u.lastMillSec
			var next *list.Element
			for e := u.millSecTimerList.Front(); e != nil; {
				next = e.Next()
				extendTimer := e.Value.(*ExtendTimer)
				if extendTimer.state != TimerRunningState {
					u.millSecTimerList.Remove(e)
					e = next
					continue
				}

				if extendTimer.delay > uint64(delta) {
					extendTimer.delay -= uint64(delta)
				} else {
					u.triggerQueue <- extendTimer
					u.millSecTimerList.Remove(e)
					e = next
				}
				e = next
			}
		}
	case <-u.ctxWithCancel.Done():
		return
	}
}

func (u *ExtendTimerMgr) StartMinGoroutine() {
	u.wg.Add(1)
	defer func() {
		u.wg.Done()
	}()

	runTimer := time.NewTimer(time.Minute * 10)
	defer func() {
		runTimer.Stop()
	}()

	tenMin := uint64(1000 * 60 * 10)
	select {
	case <-runTimer.C:
		{
			var next *list.Element
			for e := u.minTimerList.Front(); e != nil; {
				next = e.Next()
				extendTimer := e.Value.(*ExtendTimer)
				if extendTimer.state != TimerRunningState {
					u.minTimerList.Remove(e)
					e = next
					continue
				}
				extendTimer.delay -= tenMin
				if extendTimer.delay < tenMin {
					u.millSecTimerList.PushBack(extendTimer)
				}
				e = next
			}
		}
	case <-u.ctxWithCancel.Done():
		return
	}
}

func (u *ExtendTimerMgr) StartHourGoroutine() {
	u.wg.Add(1)
	defer func() {
		u.wg.Done()
	}()

	runTimer := time.NewTimer(time.Minute * 10)
	defer func() {
		runTimer.Stop()
	}()

	tenMin := uint64(1000 * 60 * 10)
	select {
	case <-runTimer.C:
		{
			var next *list.Element
			for e := u.minTimerList.Front(); e != nil; {
				next = e.Next()
				extendTimer := e.Value.(*ExtendTimer)
				if extendTimer.state != TimerRunningState {
					u.minTimerList.Remove(e)
					e = next
					continue
				}
				extendTimer.delay -= tenMin
				if extendTimer.delay < tenMin {
					u.millSecTimerList.PushBack(extendTimer)
				}
				e = next
			}
		}
	case <-u.ctxWithCancel.Done():
		return
	}
}