task

Documentation

Index

• Constants
• Variables
• type AssignConfig
• type ConfigItem
• type JumpList
  • func NewJumpList() *JumpList
  • func (jl *JumpList) List() []int
  • func (jl *JumpList) POP() (item *WeightLog)
  • func (jl *JumpList) PUSH(item *WeightLog)
  • func (jl *JumpList) Reset()
• type Task
• type WeightConfig
• type WeightLog
• type WeightParams
• type WeightValueConf

Constants

const (
	// PoolForFirst 一审
	PoolForFirst = int8(0)
	// PoolForSecond 二审
	PoolForSecond = int8(1)
	// SubjectForNormal 普通任务
	SubjectForNormal = int8(0)
	// SubjectForTask 指派任务
	SubjectForTask = int8(1)
	// StateForTaskDefault 初始化状态（未认领）
	StateForTaskDefault = int8(0)
	// StateForTaskWork 已认领，未处理
	StateForTaskWork = int8(1)
	// StateForTaskDelay 延迟审核
	StateForTaskDelay = int8(3)
	// StateForTaskUserDeleted 被释放
	StateForTaskUserDeleted = int8(6)
)

const (
	// UpperSuperWhite 优质>10w粉
	UpperSuperWhite = int8(1)
	// UpperSuperBlack 高危>10w粉
	UpperSuperBlack = int8(2)
	// UpperWhite 优质
	UpperWhite = int8(3)
	// UpperBigWhite 优质>1w粉
	UpperBigWhite = int8(4)
	// UpperBigNormal 普通>1w粉
	UpperBigNormal = int8(5)
	// UpperSuperNormal 普通>10w粉
	UpperSuperNormal = int8(6)
	// UpperBlack 高危
	UpperBlack = int8(7)
	// WConfMid 按照mid配置权重
	WConfMid = int8(0)
	// WConfTaskID 按照taskid配置权重
	WConfTaskID = int8(1)
	// WConfType 按照分区配置权重
	WConfType = int8(2)
	// WConfUpFrom 按照投稿来源配置权重
	WConfUpFrom = int8(3)

	//UpperTypeWhite 优质
	UpperTypeWhite int8 = 1
	//UpperTypeBlack 高危
	UpperTypeBlack int8 = 2
	//UpperTypePGC 生产组
	UpperTypePGC int8 = 3
	//UpperTypeUGCX don't know
	UpperTypeUGCX int8 = 3
	//UpperTypePolitices 时政
	UpperTypePolitices int8 = 5
	//UpperTypeEnterprise 企业
	UpperTypeEnterprise int8 = 7
	//UpperTypeSigned 签约
	UpperTypeSigned int8 = 15
)

Variables

var (
	// TaskCountTH 插队任务阈值
	TaskCountTH = 2000
	// SuperUpperTH 粉丝数阈值
	SuperUpperTH = int64(100000)
	// BigUpperTH 粉丝数阈值
	BigUpperTH = int64(10000)
	// WLVConf 各个权重等级具体的配置数值
	WLVConf = &WeightValueConf{
		MaxWeight:  int64(200000),
		MinWeight:  int64(-510),
		SubRelease: int64(18),

		Slv1: int64(8),
		Slv2: int64(10),
		Slv3: int64(12),
		Slv4: int64(15),
		Slv5: int64(18),
		Slv6: int64(6),
		Slv7: int64(0),

		Nlv1:   int64(3),
		Nlv2:   int64(6),
		Nlv3:   int64(9),
		Nlv4:   int64(12),
		Nlv5:   int64(0),
		Nsum9:  int64(0),
		Nsum15: int64(6),
		Nsum27: int64(30),
		Nsum45: int64(84),

		Tlv1:   int64(3),
		Tlv2:   int64(9),
		Tlv3:   int64(21),
		Tlv4:   int64(0),
		Tsum2h: int64(120),
		Tsum1h: int64(300),
	}
)

Types

type AssignConfig

type AssignConfig struct {
	ID          int64
	Pool        int8
	MinDuration int64
	MaxDuration int64
	MIDs        map[int64]struct{}
	TIDs        map[int16]struct{}
	UIDs        []int64
	AdminID     int64
	State       int8
	STime       time.Time
	ETime       time.Time
	Index       int
}

AssignConfig 指派配置

type ConfigItem

type ConfigItem struct {
	ID     int64            `json:"id"`
	Radio  int8             `json:"radio"`
	CID    int64            `json:"cid"` // config id 四种配置通用
	Uname  string           `json:"user,omitempty"`
	Rule   int8             `json:"rule"`
	Weight int64            `json:"weight"`
	Mtime  utils.FormatTime `json:"mtime"`
	Desc   string           `json:"desc,omitempty"`
	Bt     utils.FormatTime `json:"et"`
	Et     utils.FormatTime `json:"bt"`
}

ConfigItem task weight config item

type JumpList

type JumpList struct {
	// contains filtered or unexported fields
}

JumpList 插队同步的任务

func NewJumpList

func NewJumpList() *JumpList

NewJumpList New JumpList

func (*JumpList) List

func (jl *JumpList) List() []int

List 待更新权重的任务

func (*JumpList) POP

func (jl *JumpList) POP() (item *WeightLog)

POP 读取

func (*JumpList) PUSH

func (jl *JumpList) PUSH(item *WeightLog)

PUSH 添加

func (*JumpList) Reset

func (jl *JumpList) Reset()

Reset 重置

type Task

type Task struct {
	Pool         int8
	Subject      int8
	AdminID      int64
	Aid          int64
	Cid          int64
	UID          int64
	State        int8
	ConfigID     int64
	ConfigState  int8
	ConfigWeight int64
	UPSpecial    int8
	CFtime       utils.FormatTime
	Ptime        utils.FormatTime
}

Task 审核任务

type WeightConfig

type WeightConfig struct {
	ID       int64
	Mid      int64
	TaskID   int64
	Rule     int8
	Weight   int64
	Ctime    time.Time
	Mtime    time.Time
	UserName string
	Desc     string
}

WeightConfig task_weight_config记录结构

type WeightLog

type WeightLog struct {
	TaskID  int64            `json:"taskid"`
	Mid     int64            `json:"mid"`     //用户id
	Weight  int64            `json:"weight"`  //任务权重总和
	CWeight int64            `json:"cweight"` //配置权重
	NWeight int64            `json:"nweight"` //普通任务
	SWeight int64            `json:"sweight"` //特殊任务
	TWeight int64            `json:"tweight"` //定时任务
	Uptime  utils.FormatTime `json:"uptime"`  //更新时间
	CfItems []*ConfigItem    `json:"cfitems,omitempty"`
}

WeightLog 权重变更记录

type WeightParams

type WeightParams struct {
	TaskID    int64            `json:"taskid"`
	Weight    int64            `json:"weight"` //权重总值
	State     int8             `json:"state"`  //任务状态
	Mid       int64            `json:"mid"`
	Special   int8             `json:"special"` //特殊任务
	Ctime     utils.FormatTime `json:"ctime"`   //任务生成时间
	Ptime     utils.FormatTime `json:"ptime"`   //定时发布时间
	CfItems   []*ConfigItem    `json:"cfitems,omitempty"`
	Fans      int64            `json:"fans"`     //粉丝数
	AccFailed bool             `json:"accfaild"` //账号查询是否失败

	UpGroups []int8 `json:"ugs"`    //分组
	UpFrom   int8   `json:"upfrom"` //来源
	TypeID   int16  `json:"typeid"` //分区
}

WeightParams 审核任务权重的相关参数

type WeightValueConf

type WeightValueConf struct {
	MaxWeight  int64 `json:"maxweight"`
	SubRelease int64 `json:"subrelease"`
	MinWeight  int64 `json:"minweight"`
	Slv1       int64 `json:"slv1"`
	Slv2       int64 `json:"slv2"`
	Slv3       int64 `json:"slv3"`
	Slv4       int64 `json:"slv4"`
	Slv5       int64 `json:"slv5"`
	Slv6       int64 `json:"slv6"`
	Slv7       int64 `json:"slv7"`
	Nlv1       int64 `json:"nlv1"`
	Nlv2       int64 `json:"nlv2"`
	Nlv3       int64 `json:"nlv3"`
	Nlv4       int64 `json:"nlv4"`
	Nlv5       int64 `json:"nlv5"`
	Nsum9      int64 `json:"-"`
	Nsum15     int64 `json:"-"`
	Nsum27     int64 `json:"-"`
	Nsum45     int64 `json:"-"`
	Tlv1       int64 `json:"tlv1"`
	Tlv2       int64 `json:"tlv2"`
	Tlv3       int64 `json:"tlv3"`
	Tlv4       int64 `json:"tlv4"`
	Tsum2h     int64 `json:"-"`
	Tsum1h     int64 `json:"-"`
}

WeightValueConf 可配置的权重