From 613adf9aa5d70d4f26e770a5569d155d291fd702 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Mon, 20 Jan 2020 17:46:17 +0800
Subject: [PATCH] =?UTF-8?q?=E7=88=86=E5=93=81=E9=A2=84=E8=AD=A6=E6=AD=A3?=
 =?UTF-8?q?=E5=BC=8F=EF=BC=8C=E6=AF=8F=E5=A4=A9=E6=97=A9=E4=B8=8A8?=
 =?UTF-8?q?=E7=82=B9=E5=8D=8A=E8=B7=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/cms/store_sku.go | 2 --
 business/jxstore/misc/misc.go     | 8 +++++++-
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go
index bc55062a3..fbd26f22a 100644
--- a/business/jxstore/cms/store_sku.go
+++ b/business/jxstore/cms/store_sku.go
@@ -3357,7 +3357,6 @@ func SendSeckillSkusCountMsg(ctx *jxcontext.Context, vendorIDs []int, isAsync, i
 	)
 	db := dao.GetDB()
 	storeList, err := dao.GetStoresMapList(db, vendorIDs, nil, model.StoreStatusOpened, model.StoreIsSyncAll, "")
-	// storeList, err := dao.GetStoreList(db, nil, nil, []int{model.StoreStatusOpened, model.StoreStatusClosed, model.StoreStatusHaveRest}, nil, "")
 	pTask := tasksch.NewParallelTask("SendSeckillSkusCountMsg", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			store := batchItemList[0].(*model.StoreMap)
@@ -3423,7 +3422,6 @@ func SendSeckillSkusCountMsg(ctx *jxcontext.Context, vendorIDs []int, isAsync, i
 			}
 			if type1 < type1Count || type2 < type2Count {
 				storeDetail, _ := dao.GetStoreDetail(db, store.StoreID, store.VendorID)
-				fmt.Println(type1, type2, storeDetail)
 				var (
 					operatorName  string
 					operatorPhone string
diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go
index b3f9a987d..a35780744 100644
--- a/business/jxstore/misc/misc.go
+++ b/business/jxstore/misc/misc.go
@@ -88,6 +88,9 @@ var (
 	updateActStatusTimeList = []string{
 		"00:01:00",
 	}
+	sendSecKillWarnList = []string{
+		"8:30:00",
+	}
 
 	autoSaleStoreSkuTimeList = []string{
 		cms.AutoSaleAtStr,
@@ -159,8 +162,11 @@ func Init() {
 			cms.AutoFocusStoreSkusForTopSkus(jxcontext.AdminCtx, true, true)
 		}, createStorePriceTimeList)
 		ScheduleTimerFunc("GetCheckVendorCookie", func() {
-			event.GetCheckVendorCookie(jxcontext.AdminCtx, []int{0, 1, 3, 102}, true)
+			event.GetCheckVendorCookie(jxcontext.AdminCtx, []int{model.VendorIDEBAI, model.VendorIDJD, model.VendorIDMTWM, model.VendorIDMTPS}, true)
 		}, checkCookieList)
+		ScheduleTimerFunc("SendSeckillSkusCountMsg", func() {
+			cms.SendSeckillSkusCountMsg(jxcontext.AdminCtx, []int{model.VendorIDEBAI, model.VendorIDJD, model.VendorIDMTWM}, false, true)
+		}, sendSecKillWarnList)
 		ScheduleTimerFunc("每日报警心跳", func() {
 			globals.SugarLogger.Warnf("每日报警心跳，这不是报警。启动时间：%s", cms.GetServiceInfo(jxcontext.AdminCtx)["startupTime"])
 		}, dailyHeartbeat)