aa

business/jxstore/tempop/tempop.go

@@ -1908,44 +1908,60 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// 	}
 	// }
 	//京东会员数据
+	//var (
+	//	db       = dao.GetDB()
+	//	pageSize = 20
+	//	pages    []int
+	//)
+	//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 {
+	//			userMembers, _ := dao.GetUserMember(db, "", "", v.Merchantcardno, model.VendorIDJD, 0, -1)
+	//			if len(userMembers) == 0 {
+	//				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")
+	//				if v.Createtime != "" {
+	//					userMember.CreatedAt = utils.Str2Time(v.Createtime)
+	//				} else {
+	//					userMember.CreatedAt = utils.Str2Time(v.Cardcreatetime)
+	//				}
+	//				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()
+	//刷新京东真实订单号
 	var (
 		db    = dao.GetDB()
-		pageSize = 20
+		goods []*model.GoodsOrder
-		pages    []int
 	)
-	for page := 1; page < 5; page++ {
+	sql := `
-		pages = append(pages, page)
+		SELECT * FROM goods_order WHERE vendor_id = 0 and consignee_mobile2 = '' and order_created_at > '2021-04-13' and vendor_org_code = '320406'
-	}
+	`
-	task := tasksch.NewParallelTask2("京东会员", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
+	dao.GetRows(db, goods, sql, nil)
-		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {
+	for _, v := range goods {
-			page := batchItemList[0].(int)
+		mobile, _ := api.JdAPI.GetRealMobile4Order(v.VendorOrderID, v.VendorStoreID)
-			results, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize)
+		if v.ConsigneeMobile2 == "" {
-			for _, v := range results {
+			v.ConsigneeMobile2 = mobile
-				userMembers, _ := dao.GetUserMember(db, "", "", v.Merchantcardno, model.VendorIDJD, 0, -1)
+			dao.UpdateEntity(db, v, "ConsigneeMobile2")
-				if len(userMembers) == 0 {
-					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")
-					if v.Createtime != "" {
-						userMember.CreatedAt = utils.Str2Time(v.Createtime)
-					} else {
-						userMember.CreatedAt = utils.Str2Time(v.Cardcreatetime)
-					}
-					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
 }