aa

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

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
+}

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,