51 lines
1008 B
Go
51 lines
1008 B
Go
package job
|
|
|
|
import (
|
|
"91jd-server/common"
|
|
"91jd-server/common/log"
|
|
shortvideo "91jd-server/skd/job/sqlcollapser/shordvideo"
|
|
"91jd-server/skd/job/sqlcollapser/user"
|
|
"91jd-server/skd/job/sqlcollapser/vid"
|
|
"sync"
|
|
)
|
|
|
|
var syncSqlcollaspeIsRuining = false
|
|
|
|
// start 定时任务 开启
|
|
func runSyncSqlcollaspe() {
|
|
//防止重入
|
|
if syncSqlcollaspeIsRuining {
|
|
return
|
|
}
|
|
syncSqlcollaspeIsRuining = true
|
|
defer func() {
|
|
syncSqlcollaspeIsRuining = false
|
|
}()
|
|
doSyncSqlcollasper() //做折叠业务
|
|
}
|
|
|
|
// 做折叠业务
|
|
func doSyncSqlcollasper() {
|
|
log.Info("SqlCollasper doSyncSqlcollasper start...")
|
|
defaultSyncDate, err := getDefaultSyncDate()
|
|
if err != nil {
|
|
log.Error("defaultStatDate invalid", log.E(err))
|
|
return
|
|
}
|
|
wg := sync.WaitGroup{}
|
|
wg.Add(3)
|
|
common.Go(func() {
|
|
defer wg.Done()
|
|
vid.RunSync(defaultSyncDate)
|
|
})
|
|
common.Go(func() {
|
|
defer wg.Done()
|
|
user.RunSync(defaultSyncDate)
|
|
})
|
|
common.Go(func() {
|
|
defer wg.Done()
|
|
shortvideo.RunSync(defaultSyncDate)
|
|
})
|
|
wg.Wait()
|
|
}
|