You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
246 lines
6.3 KiB
246 lines
6.3 KiB
package archive |
|
|
|
import ( |
|
"sync" |
|
"time" |
|
) |
|
|
|
const ( |
|
//StateOpen state open |
|
StateOpen = 0 |
|
//StateOrange 橙色通过 |
|
StateOrange = 1 |
|
|
|
//StateForbidWait 待审 |
|
StateForbidWait = -1 |
|
//StateForbidRecicle 打回 |
|
StateForbidRecicle = -2 |
|
//StateForbidPolice 网警锁定 |
|
StateForbidPolice = -3 |
|
//StateForbidLock 锁定 |
|
StateForbidLock = -4 |
|
//StateForbidFixed 修复待审 |
|
StateForbidFixed = -6 |
|
//StateForbidLater 暂缓待审 |
|
StateForbidLater = -7 |
|
//StateForbidXcodeFail 转码失败 |
|
StateForbidXcodeFail = -16 |
|
//StateForbidSubmit 创建提交 |
|
StateForbidSubmit = -30 |
|
//StateForbidUserDelay 定时 |
|
StateForbidUserDelay = -40 |
|
//StateForbidUpDelete 删除 |
|
StateForbidUpDelete = -100 |
|
//RoundBegin 开始流转 |
|
RoundBegin = 0 |
|
//RoundAuditSecond 二审：选定分区的多P稿件 及 PGC/活动的单P多P稿件 |
|
RoundAuditSecond = 10 |
|
//RoundAuditThird 三审：选定分区/PGC/活动 的单P多P稿件 |
|
RoundAuditThird = 20 |
|
//RoundReviewFirst 分区回查：粉丝小于配置阈值 如 5000 且 指定分区 |
|
RoundReviewFirst = 30 |
|
//RoundReviewFirstWaitTrigger 点击/粉丝 等待触发中间状态，7天内达到阈值进列表，未达到自动变99 |
|
RoundReviewFirstWaitTrigger = 31 |
|
//RoundReviewSecond 社区回查：粉丝大于配置阈值 如 5000 或 优质高危up |
|
RoundReviewSecond = 40 |
|
//RoundTriggerFans 粉丝回查：粉丝量达到配置阈值 |
|
RoundTriggerFans = 80 |
|
//RoundTriggerClick 点击回查：点击量达到配置阈值 |
|
RoundTriggerClick = 90 |
|
//RoundEnd 流转结束 |
|
RoundEnd = 99 |
|
//AccessDefault access |
|
AccessDefault = int16(0) |
|
//AccessMember 会员可见 |
|
AccessMember = int16(10000) |
|
//CopyrightUnknow copyright |
|
CopyrightUnknow = 0 |
|
//CopyrightOriginal 原创 |
|
CopyrightOriginal = 1 |
|
//CopyrightCopy 转载 |
|
CopyrightCopy = 2 |
|
|
|
//AttrYes attribute yes |
|
AttrYes = int32(1) |
|
//AttrNo attribute no |
|
AttrNo = int32(0) |
|
//AttrBitNoRank 禁止排序 |
|
AttrBitNoRank = uint(0) |
|
//AttrBitNoDynamic 禁止动态 |
|
AttrBitNoDynamic = uint(1) |
|
//AttrBitNoWeb 禁止web |
|
AttrBitNoWeb = uint(2) |
|
//AttrBitNoMobile 禁止手机端 |
|
AttrBitNoMobile = uint(3) |
|
//AttrBitNoSearch 禁止搜索 |
|
AttrBitNoSearch = uint(4) |
|
//AttrBitOverseaLock 禁止海外 |
|
AttrBitOverseaLock = uint(5) |
|
//AttrBitNoRecommend 禁止推荐 |
|
AttrBitNoRecommend = uint(6) |
|
// AttrBitHideCoins = uint(7) |
|
|
|
//AttrBitHasHD5 是否高清 |
|
AttrBitHasHD5 = uint(8) |
|
// AttrBitVisitorDm = uint(9) |
|
|
|
//AttrBitAllowBp 允许承包 |
|
AttrBitAllowBp = uint(10) |
|
//AttrBitIsBangumi 番剧 |
|
AttrBitIsBangumi = uint(11) |
|
//AttrBitIsPOrder 是否私单 |
|
AttrBitIsPOrder = uint(12) |
|
|
|
//AttrBitHideClick 点击 |
|
AttrBitHideClick = uint(13) |
|
//AttrBitAllowTag 允许操作tag |
|
AttrBitAllowTag = uint(14) |
|
// AttrBitIsFromArcApi = uint(15) |
|
|
|
//AttrBitJumpURL 跳转 |
|
AttrBitJumpURL = uint(16) |
|
//AttrBitIsMovie is movie |
|
AttrBitIsMovie = uint(17) |
|
//AttrBitBadgepay 付费 |
|
AttrBitBadgepay = uint(18) |
|
|
|
//ReplyDefault 默认评论状态 |
|
ReplyDefault = int64(-1) |
|
//ReplyOn 开评论 |
|
ReplyOn = int64(0) |
|
//ReplyOff 关评论 |
|
ReplyOff = int64(1) |
|
|
|
//LogBusJob 稿件后台任务日志bus |
|
LogBusJob = 211 |
|
//LogTypeReply 稿件后台任务type评论 |
|
LogTypeReply = 1 |
|
) |
|
|
|
//ReplyState 评论开关状态 |
|
var ReplyState = []int64{ |
|
ReplyDefault, |
|
ReplyOn, |
|
ReplyOff, |
|
} |
|
|
|
//ReplyDesc 评论状态描述 |
|
var ReplyDesc = map[int64]string{ |
|
ReplyDefault: "未知状态", |
|
ReplyOn: "开", |
|
ReplyOff: "关", |
|
} |
|
|
|
//UpInfo up info |
|
type UpInfo struct { |
|
Nw *Archive |
|
Old *Archive |
|
} |
|
|
|
// Oper is archive operate model. |
|
type Oper struct { |
|
ID int64 `json:"id"` |
|
AID int64 `json:"aid"` |
|
UID int64 `json:"uid"` |
|
TypeID int16 `json:"typeid"` |
|
State int `json:"state"` |
|
Content string `json:"-"` |
|
Round int8 `json:"round"` |
|
Attribute int32 `json:"attribute"` |
|
LastID int64 `json:"last_id"` |
|
Remark string `json:"-"` |
|
CTime time.Time `json:"ctime"` |
|
MTime time.Time `json:"mtime"` |
|
} |
|
|
|
// ArcMoveTypeCache archive move typeid count |
|
type ArcMoveTypeCache struct { |
|
Data map[int8]map[int16]map[string]int |
|
sync.Mutex |
|
} |
|
|
|
// ArcRoundFlowCache archive round flow record |
|
type ArcRoundFlowCache struct { |
|
Data map[int8]map[int64]map[string]int |
|
sync.Mutex |
|
} |
|
|
|
//Archive archive |
|
type Archive struct { |
|
ID int64 `json:"id"` |
|
AID int64 `json:"aid"` //result库binlog={id:0,aid:xxx} |
|
Mid int64 `json:"mid"` |
|
TypeID int16 `json:"typeid"` |
|
HumanRank int `json:"humanrank"` |
|
Duration int `json:"duration"` |
|
Desc string `json:"desc"` |
|
Title string `json:"title"` |
|
Cover string `json:"cover"` |
|
Content string `json:"content"` |
|
Tag string `json:"tag"` |
|
Attribute int32 `json:"attribute"` |
|
Copyright int8 `json:"copyright"` |
|
AreaLimit int8 `json:"arealimit"` |
|
State int `json:"state"` |
|
Author string `json:"author"` |
|
Access int `json:"access"` |
|
Forward int `json:"forward"` |
|
PubTime string `json:"pubtime"` |
|
Reason string `json:"reject_reason"` |
|
Round int8 `json:"round"` |
|
CTime string `json:"ctime"` |
|
MTime string `json:"mtime"` |
|
PTime string `json:"ptime"` |
|
} |
|
|
|
//IsSyncState can archive sync |
|
func (a *Archive) IsSyncState() bool { |
|
if a.State >= 0 || a.State == StateForbidUserDelay || a.State == StateForbidUpDelete || a.State == StateForbidRecicle || a.State == StateForbidPolice || |
|
a.State == StateForbidLock { |
|
return true |
|
} |
|
return false |
|
} |
|
|
|
//ArgStat arg state |
|
type ArgStat struct { |
|
Aid int64 |
|
Field int |
|
Value int |
|
RealIP string |
|
} |
|
|
|
// AttrVal get attribute value. |
|
func (a *Archive) AttrVal(bit uint) int32 { |
|
return (a.Attribute >> bit) & int32(1) |
|
} |
|
|
|
//NormalState normal state |
|
func NormalState(state int) bool { |
|
return state == StateOpen || state == StateOrange |
|
} |
|
|
|
//Type archive_type |
|
type Type struct { |
|
ID int16 `json:"id"` |
|
PID int16 `json:"pid"` |
|
Name string `json:"name"` |
|
} |
|
|
|
// StateMean the mean for archive state |
|
var StateMean = map[int]string{ |
|
StateOpen: "开放浏览", |
|
StateOrange: "橙色通过", |
|
// forbid state |
|
StateForbidWait: "待审", |
|
StateForbidRecicle: "打回", |
|
StateForbidPolice: "网警锁定", |
|
StateForbidLock: "锁定稿件", |
|
StateForbidFixed: "修复待审", |
|
StateForbidLater: "暂缓审核", |
|
//StateForbidAdminDelay: "延迟发布", |
|
StateForbidXcodeFail: "转码失败", |
|
StateForbidSubmit: "创建提交", |
|
StateForbidUserDelay: "用户定时发布", |
|
StateForbidUpDelete: "UP主删除", |
|
}
|
|
|