|
|
|
@@ -14,15 +14,14 @@ import ( |
|
|
|
) |
|
|
|
|
|
|
|
var ( |
|
|
|
timer *cron.Cron |
|
|
|
jobs = map[string]func(*xorm.Engine){} |
|
|
|
baseEntryId cron.EntryID |
|
|
|
entryIds []cron.EntryID |
|
|
|
taskCfgList *[]model.SysCfg |
|
|
|
ch = make(chan int, 30) |
|
|
|
workerNum = 15 // 智盟跟单并发数量 |
|
|
|
otherCh = make(chan int, 30) |
|
|
|
otherWorkerNum = 18 // 淘宝, 苏宁, 考拉并发量 |
|
|
|
timer *cron.Cron |
|
|
|
jobs = map[string]func(*xorm.Engine){} |
|
|
|
baseEntryId cron.EntryID |
|
|
|
entryIds []cron.EntryID |
|
|
|
taskCfgList *[]model.SysCfg |
|
|
|
ch = make(chan int, 30) |
|
|
|
workerNum = 15 // 智盟跟单并发数量 |
|
|
|
otherCh = make(chan int, 30) |
|
|
|
) |
|
|
|
|
|
|
|
func Init() { |
|
|
|
|
