aa

business/jxstore/tempop/tempop.go

@@ -1908,13 +1908,37 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// 	}
 	// }
 	//京东会员数据
-	//var (
+	var (
-	//	db       = dao.GetDB()
+		db       = dao.GetDB()
-	//	pageSize = 50
+		pageSize = 50
-	//)
+		pages    []int
-	//for page := 1; page < 3080; page++ {
+	)
-	//	result, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize)
+	for page := 1; page < 5; page++ {
-	//}
+		pages = append(pages, page)
+	}
+	task := tasksch.NewParallelTask2("京东会员", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {
+			page := batchItemList[0].(int)
+			results, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize)
+			for _, v := range results {
+				userMember := &model.UserMember{
+					VendorOrderID: v.Orderid,
+					VendorID:      model.VendorIDJD,
+					Mobile:        v.Merchantcardno,
+					MemberType:    1,
+					EndAt:         utils.Str2Time(v.Endtimestr + " 23:59:59"),
+				}
+				dao.WrapAddIDCULDEntity(userMember, "jxadmin")
+				userMember.CreatedAt = utils.Str2Time(v.Createtime)
+				if userMember.EndAt.Sub(time.Now()) <= 0 {
+					userMember.DeletedAt = time.Now()
+				}
+				dao.CreateEntity(db, userMember)
+			}
+			return retVal, successCount, err
+		}, pages)
+	tasksch.HandleTask(task, nil, false).Run()
+	task.GetID()
 	return err
 }