diff --git a/business/jxstore/cms/user2.go b/business/jxstore/cms/user2.go index 15b795bed..9be1c3c74 100644 --- a/business/jxstore/cms/user2.go +++ b/business/jxstore/cms/user2.go @@ -1142,5 +1142,15 @@ func CleanUserOrderSMSMark(ctx *jxcontext.Context) (err error) { } func RefreshUserMemberStatus(ctx *jxcontext.Context) (err error) { + var ( + db = dao.GetDB() + ) + userMembers, err := dao.GetUserMember(db, "", "", model.MemberTypeDiscountCard, -1) + for _, userMember := range userMembers { + if time.Now().Sub(userMember.EndAt) > 0 { + userMember.DeletedAt = time.Now() + dao.UpdateEntity(db, userMember, "DeletedAt") + } + } return err } diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 0962cee89..9c2cb8b85 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -268,6 +268,7 @@ func Init() { act.ChangeJxPriceByDiscountAct(jxcontext.AdminCtx) }, discountActJxList) ScheduleTimerFunc("RefreshUserMemberStatus", func() { + cms.RefreshUserMemberStatus(jxcontext.AdminCtx) }, updateActStatusTimeList) } ScheduleTimerFunc("AutoSaleStoreSku", func() { diff --git a/business/model/dao/dao_user.go b/business/model/dao/dao_user.go index 4cc4733eb..456262c72 100644 --- a/business/model/dao/dao_user.go +++ b/business/model/dao/dao_user.go @@ -278,7 +278,7 @@ func GetUserMember(db *DaoDB, userID, vendorOrderID string, memberType, isPay in sql += " AND member_type = ?" sqlParams = append(sqlParams, memberType) } - if isPay != 0 { + if isPay != -1 { sql += " AND is_pay = ?" sqlParams = append(sqlParams, isPay) }