diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 1bce22d9f..3f6a50f8f 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -6,6 +6,7 @@ import ( "time" "git.rosy.net.cn/baseapi/utils" + "git.rosy.net.cn/jx-callback/business/jxstore/cms" "git.rosy.net.cn/jx-callback/business/jxutils" "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" "git.rosy.net.cn/jx-callback/business/jxutils/tasksch" @@ -78,3 +79,24 @@ func RefreshRealMobile(ctx *jxcontext.Context, vendorID int, fromTime, toTime ti } return hint, err } + +func StartDailyWork() { + if globals.ReallyCallPlatformAPI { + now := time.Now() + runTime := time.Date(now.Year(), now.Month(), now.Day(), 0, 25, 0, 0, time.Local) // 凌晨00:25点开始执行 + waitDuration := runTime.Sub(now) + if waitDuration < 5*time.Second { + waitDuration += 24 * time.Hour + } + globals.SugarLogger.Debugf("dailyWork waitDuration:%d minutes", waitDuration/time.Minute) + utils.AfterFuncWithRecover(waitDuration, func() { + doDailyWork() + StartDailyWork() + }) + } +} + +func doDailyWork() { + globals.SugarLogger.Debug("doDailyWork") + cms.CurVendorSync.FullSyncStoresSkus(jxcontext.AdminCtx, dao.GetDB(), []int{model.VendorIDJD}, nil, true, true) +} diff --git a/main.go b/main.go index 7208b1aff..ada89dd47 100644 --- a/main.go +++ b/main.go @@ -49,6 +49,7 @@ func Init() { if globals.IsProductEnv() { misc.StartRefreshEbaiRealMobile() ebai.CurPurchaseHandler.StartRefreshComment() + misc.StartDailyWork() } }