From 4ae02a5eb2e3a6839bbdb3024bab13a75f3c7b90 Mon Sep 17 00:00:00 2001
From: gazebo <gazeboxu@gmail.com>
Date: Wed, 22 May 2019 14:20:42 +0800
Subject: [PATCH] =?UTF-8?q?-=20=E6=B7=BB=E5=8A=A0dailyWork=E6=94=AF?=
 =?UTF-8?q?=E6=8C=81=EF=BC=8C=E5=BD=93=E5=89=8D=E8=AE=A2=E6=98=AF=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E4=BA=AC=E4=B8=9C=E9=97=A8=E5=BA=97=E4=BB=B7=E6=A0=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/misc/misc.go | 22 ++++++++++++++++++++++
 main.go                       |  1 +
 2 files changed, 23 insertions(+)

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()
 	}
 }