diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 1f0240953..f4fdcaff7 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1908,60 +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() - goods []*model.GoodsOrder + db = dao.GetDB() + pageSize = 20 + pages []int ) - sql := ` - SELECT * FROM goods_order WHERE vendor_id = 0 and consignee_mobile2 = '' and order_created_at > '2021-04-13' and vendor_org_code = '320406' - ` - dao.GetRows(db, &goods, sql, nil) - for _, v := range goods { - mobile, _ := api.JdAPI.GetRealMobile4Order(v.VendorOrderID, v.VendorStoreID) - if v.ConsigneeMobile2 == "" { - v.ConsigneeMobile2 = mobile - dao.UpdateEntity(db, v, "ConsigneeMobile2") - } + 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() + // goods []*model.GoodsOrder + //) + //sql := ` + // SELECT * FROM goods_order WHERE vendor_id = 0 and consignee_mobile2 = '' and order_created_at > '2021-04-13' and vendor_org_code = '320406' + //` + //dao.GetRows(db, &goods, sql, nil) + //for _, v := range goods { + // mobile, _ := api.JdAPI.GetRealMobile4Order(v.VendorOrderID, v.VendorStoreID) + // if v.ConsigneeMobile2 == "" { + // v.ConsigneeMobile2 = mobile + // dao.UpdateEntity(db, v, "ConsigneeMobile2") + // } + //} return err }