会员刷新

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
 }

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() {

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)
 	}