package queue

import (
	"gitee.com/h79/goutils/common/timer"
	"reflect"
)

var PriorityItemType = reflect.TypeOf((*IPriorityItem)(nil)).Elem()

type IPriorityItem interface {
	GValue() interface{}
	PValue() int64
}

type PriorityItem struct {
	Value    interface{}
	Priority int64
}

func (it *PriorityItem) GValue() interface{} {
	return it.Value
}

func (it *PriorityItem) PValue() int64 {
	return it.Priority
}

func ConvertPriorityItem(elem interface{}) IPriorityItem {
	if p, ok := elem.(*PriorityItem); ok {
		return p
	}
	if it, ok := elem.(PriorityItem); ok {
		return &it
	}
	val := reflect.ValueOf(elem)
	if val.CanInterface() && val.Type().Implements(PriorityItemType) {
		fm := val.Interface().(IPriorityItem)
		return fm
	}
	return &PriorityItem{Value: elem, Priority: timer.NowNano()}
}