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-27 11:48:21 +08:00
parent 8e57df5a8d
commit 35d5a5cdc6
1 changed files with 39 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

79
business/jxstore/report/report.go
View File

@@ -662,46 +662,45 @@ func RefreshJDMembers(ctx *jxcontext.Context) (err error) {
for ; page > 0; page-- { for ; page > 0; page-- {
pages = append(pages, page) pages = append(pages, page)
} }
fmt.Println("RefreshJDMembers map 111111111111111111111111111111111", memberMap) task := tasksch.NewParallelTask2("RefreshJDMembers", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
//task := tasksch.NewParallelTask2("RefreshJDMembers", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) { pageNo := batchItemList[0].(int)
// pageNo := batchItemList[0].(int) pageResult2, err := api.JdAPI.QueryMemberTransListByCondition("", "", pageNo, pageSize)
// pageResult2, err := api.JdAPI.QueryMemberTransListByCondition("", "", pageNo, pageSize) if pageResult2 != nil {
// if pageResult2 != nil { for _, v := range pageResult2.Rows {
// for _, v := range pageResult2.Rows { if utils.Str2Time(v.Endtimestr+" 23:59:59").Sub(time.Now()) >= 0 && v.Dealstatus == 0 {
// if utils.Str2Time(v.Endtimestr+" 23:59:59").Sub(time.Now()) >= 0 && v.Dealstatus == 0 { if memberMap[v.Merchantcardno] != nil { //库里有这个人的会员信息了
// if memberMap[v.Merchantcardno] != nil { //库里有这个人的会员信息了 if utils.Time2Str(memberMap[v.Merchantcardno].EndAt) != v.Endtimestr+" 23:59:59" { //可能这个人续费了，续存了
// if utils.Time2Str(memberMap[v.Merchantcardno].EndAt) != v.Endtimestr+" 23:59:59" { //可能这个人续费了，续存了 memberMap[v.Merchantcardno].EndAt = utils.Str2Time(v.Endtimestr + " 23:59:59")
// memberMap[v.Merchantcardno].EndAt = utils.Str2Time(v.Endtimestr + " 23:59:59") memberMap[v.Merchantcardno].DeletedAt = utils.DefaultTimeValue
// memberMap[v.Merchantcardno].DeletedAt = utils.DefaultTimeValue dao.UpdateEntity(db, memberMap[v.Merchantcardno], "EndAt", "DeletedAt")
// dao.UpdateEntity(db, memberMap[v.Merchantcardno], "EndAt", "DeletedAt") }
// } } else {
// } else { userMember := &model.UserMember{
// userMember := &model.UserMember{ VendorOrderID: v.Orderid,
// VendorOrderID: v.Orderid, VendorID: model.VendorIDJD,
// VendorID: model.VendorIDJD, Mobile: v.Merchantcardno,
// Mobile: v.Merchantcardno, MemberType: 1,
// MemberType: 1, EndAt: utils.Str2Time(v.Endtimestr + " 23:59:59"),
// EndAt: utils.Str2Time(v.Endtimestr + " 23:59:59"), }
// } dao.WrapAddIDCULDEntity(userMember, "jxadmin")
// dao.WrapAddIDCULDEntity(userMember, "jxadmin") if v.Createtime != "" {
// if v.Createtime != "" { userMember.CreatedAt = utils.Str2Time(v.Createtime)
// userMember.CreatedAt = utils.Str2Time(v.Createtime) } else {
// } else { userMember.CreatedAt = utils.Str2Time(v.Cardcreatetime)
// userMember.CreatedAt = utils.Str2Time(v.Cardcreatetime) }
// } if userMember.EndAt.Sub(time.Now()) <= 0 {
// if userMember.EndAt.Sub(time.Now()) <= 0 { userMember.DeletedAt = time.Now()
// userMember.DeletedAt = time.Now() }
// } dao.CreateEntity(db, userMember)
// dao.CreateEntity(db, userMember) }
// } }
// } }
// } }
// } return retVal, successCount, err
// return retVal, successCount, err }, pages)
// }, pages) tasksch.HandleTask(task, nil, true).Run()
//tasksch.HandleTask(task, nil, true).Run() task.GetID()
//task.GetID()
return err return err
} }