liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-05-13 18:14:30 +08:00
parent 38d0f56e8e
commit 861bffc87b
1 changed files with 51 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

102
business/jxstore/tempop/tempop.go
View File

@@ -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 ( var (
db = dao.GetDB() db = dao.GetDB()
goods []*model.GoodsOrder pageSize = 20
pages []int
) )
sql := ` for page := 1; page < 5; page++ {
SELECT * FROM goods_order WHERE vendor_id = 0 and consignee_mobile2 = '' and order_created_at > '2021-04-13' and vendor_org_code = '320406' pages = append(pages, page)
`
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")
}
} }
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 return err
} }