diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 70fc3ca65..99cc8c604 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -183,6 +183,7 @@ func Init() { defsch.FixedScheduler.ConfirmSelfTakeOrders(jxcontext.AdminCtx, []int{model.VendorIDJD}, time.Now().Add(-48*time.Hour), time.Now().Add(-30*time.Minute), true, true) }, 5*time.Second, 10*time.Minute) + //20分钟一次,两个统计 ScheduleTimerFuncByInterval(func() { report.RefreshStoreManageState(jxcontext.AdminCtx) }, 5*time.Second, 20*time.Minute) @@ -190,6 +191,7 @@ func Init() { ScheduleTimerFuncByInterval(func() { curDate := utils.Time2Date(time.Now()) orderman.FixedOrderManager.AmendMissingOrders(jxcontext.AdminCtx, []int{model.VendorIDJD, model.VendorIDMTWM, model.VendorIDEBAI}, 0, curDate, curDate, true, true) + }, 5*time.Second, 10*time.Minute) ScheduleTimerFunc("auto enable remote store", func() { diff --git a/business/jxstore/report/report.go b/business/jxstore/report/report.go index e5f01a52f..81657baa3 100644 --- a/business/jxstore/report/report.go +++ b/business/jxstore/report/report.go @@ -630,3 +630,14 @@ func CalculateCoverArea(coordinate []string, vendorID int) (area float64) { sum = utils.Str2Float64(fmt.Sprintf("%.2f", sum)) return sum } + +func RefreshJDMembers(ctx *jxcontext.Context) (err error) { + //var ( + // db = dao.GetDB() + //) + //if configs, err := dao.QueryConfigs(dao.GetDB(), "jdStorePageCookie", model.ConfigTypeCookie, ""); err == nil { + // api.JdAPI.SetJdCookie(configs[0].Value) + //} + //api.JdAPI.QueryMemberTransListByCondition(1, 10) + return err +} diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 3c23b477d..eab4a8fe4 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1910,10 +1910,10 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { //京东会员数据 var ( db = dao.GetDB() - pageSize = 50 + pageSize = 20 pages []int ) - for page := 3079; page >= 1; page-- { + for page := 7697; page >= 1; page-- { pages = append(pages, page) } task := tasksch.NewParallelTask2("京东会员", tasksch.NewParallelConfig().SetIsContinueWhenError(true).SetParallelCount(1), ctx,