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-14 11:17:42 +08:00
parent 6e485be7bb
commit a353963998
1 changed files with 23 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1911,43 +1911,34 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
var ( var (
db = dao.GetDB() db = dao.GetDB()
pageSize = 20 pageSize = 20
pages []int
) )
for page := 7697; page >= 1; page-- { for page := 7697; page >= 1; page-- {
pages = append(pages, page) results, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize)
} for _, v := range results {
task := tasksch.NewParallelTask2("京东会员", tasksch.NewParallelConfig().SetIsContinueWhenError(true).SetParallelCount(1), ctx, if utils.Str2Time(v.Endtimestr+" 23:59:59").Sub(time.Now()) >= 0 {
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) { userMembers, _ := dao.GetUserMember(db, "", "", v.Merchantcardno, model.VendorIDJD, 0, -1)
page := batchItemList[0].(int) if len(userMembers) == 0 {
results, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize) userMember := &model.UserMember{
for _, v := range results { VendorOrderID: v.Orderid,
if utils.Str2Time(v.Endtimestr+" 23:59:59").Sub(time.Now()) >= 0 { VendorID: model.VendorIDJD,
userMembers, _ := dao.GetUserMember(db, "", "", v.Merchantcardno, model.VendorIDJD, 0, -1) Mobile: v.Merchantcardno,
if len(userMembers) == 0 { MemberType: 1,
userMember := &model.UserMember{ EndAt: utils.Str2Time(v.Endtimestr + " 23:59:59"),
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)
} }
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, true).Run()
task.GetID()
//刷新京东真实订单号 //刷新京东真实订单号
//var ( //var (
// db = dao.GetDB() // db = dao.GetDB()