diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 18fbdc014..1ff5e08eb 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -169,6 +169,7 @@ func Init() { ScheduleTimerFuncByInterval(func() { RefreshRealMobile(jxcontext.AdminCtx, model.VendorIDEBAI, time.Now().Add(-24*time.Hour), utils.DefaultTimeValue, false, true) + report.RefreshStoreManageState(jxcontext.AdminCtx, nil, []int{model.VendorIDJD}) }, 5*time.Second, 1*time.Hour) ScheduleTimerFuncByInterval(func() { @@ -176,7 +177,7 @@ func Init() { }, 5*time.Second, 10*time.Minute) ScheduleTimerFuncByInterval(func() { - report.RefreshStoreManageState(jxcontext.AdminCtx, nil) + report.RefreshStoreManageState(jxcontext.AdminCtx, nil, []int{model.VendorIDMTWM, model.VendorIDEBAI}) }, 5*time.Second, 20*time.Minute) ScheduleTimerFuncByInterval(func() { diff --git a/business/jxstore/report/report.go b/business/jxstore/report/report.go index 5db86bdf8..1ed69f4b8 100644 --- a/business/jxstore/report/report.go +++ b/business/jxstore/report/report.go @@ -379,10 +379,10 @@ func GetManageState(ctx *jxcontext.Context, cityCodes []int, vendorID int) (getM return getManageStateResult, err } -func RefreshStoreManageState(ctx *jxcontext.Context, storeIDs []int) { +func RefreshStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorIDs []int) { var ( - db = dao.GetDB() - vendorIDs = []int{model.VendorIDJD, model.VendorIDMTWM, model.VendorIDEBAI} + db = dao.GetDB() + //vendorIDs = []int{model.VendorIDJD, model.VendorIDMTWM, model.VendorIDEBAI} messageFlag = time.Now().Hour() == 10 && time.Now().Minute() > 0 && time.Now().Minute() < 12 ) task := tasksch.NewParallelTask("RefreshStoreManageState", tasksch.NewParallelConfig().SetParallelCount(3).SetIsContinueWhenError(true), ctx,