package job

import (
	"91porn-server/common"
	"91porn-server/common/log"
	shortvideo "91porn-server/skd/job/sqlcollapser/shordvideo"
	"91porn-server/skd/job/sqlcollapser/user"
	"91porn-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()
}