update
This commit is contained in:
parent
623a1f97c4
commit
74ef2407e7
@ -120,13 +120,14 @@ async def issue_coupon(
|
|||||||
db.add(issue_record)
|
db.add(issue_record)
|
||||||
|
|
||||||
# 批量创建用户优惠券
|
# 批量创建用户优惠券
|
||||||
manager = CouponManager(coupon)
|
user_coupons = []
|
||||||
user_coupons = []
|
|
||||||
|
|
||||||
for _ in range(user_coupon.count):
|
for _ in range(user_coupon.count):
|
||||||
user_coupon_obj = manager.add_coupon(
|
user_coupon_obj = UserCouponDB(
|
||||||
user_id=user_coupon.user_id,
|
user_id=user_coupon.user_id,
|
||||||
coupon_id=coupon.id,
|
coupon_id=coupon.id,
|
||||||
|
coupon_name=coupon.name,
|
||||||
|
coupon_amount=coupon.amount,
|
||||||
|
coupon_type=coupon.coupon_type,
|
||||||
expire_time=user_coupon.expire_time
|
expire_time=user_coupon.expire_time
|
||||||
)
|
)
|
||||||
db.add(user_coupon_obj)
|
db.add(user_coupon_obj)
|
||||||
|
|||||||
@ -205,13 +205,17 @@ async def receive_coupons(
|
|||||||
today = datetime.now().date()
|
today = datetime.now().date()
|
||||||
#过期时间:15 天
|
#过期时间:15 天
|
||||||
expire_time = datetime.combine(today, datetime.max.time()) + timedelta(days=config['days'])
|
expire_time = datetime.combine(today, datetime.max.time()) + timedelta(days=config['days'])
|
||||||
manager = CouponManager(db)
|
count=config['count']
|
||||||
manager.add_coupon(
|
for _ in range(count):
|
||||||
user_id=current_user.userid,
|
user_coupon = UserCouponDB(
|
||||||
coupon_id=coupon.id,
|
user_id=current_user.userid,
|
||||||
expire_time= expire_time,
|
coupon_id=coupon_id,
|
||||||
count=config['count']
|
coupon_name=coupon.name,
|
||||||
)
|
coupon_amount=coupon.amount,
|
||||||
|
coupon_type=coupon.coupon_type,
|
||||||
|
expire_time=expire_time,
|
||||||
|
)
|
||||||
|
db.add(user_coupon)
|
||||||
|
|
||||||
# 检查是否领取过优惠券
|
# 检查是否领取过优惠券
|
||||||
receive_record = db.query(CouponReceiveRecordDB).filter(
|
receive_record = db.query(CouponReceiveRecordDB).filter(
|
||||||
|
|||||||
@ -27,17 +27,21 @@ class CouponManager:
|
|||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
UserCouponDB: 创建的用户优惠券对象
|
UserCouponDB: 创建的用户优惠券对象
|
||||||
|
|
||||||
|
Raises:
|
||||||
|
ValueError: 当优惠券对象不存在时抛出
|
||||||
"""
|
"""
|
||||||
# 使用传入的优惠券对象
|
# 检查优惠券对象是否存在
|
||||||
coupon = self.coupon
|
if not self.coupon:
|
||||||
|
raise ValueError("优惠券对象不存在")
|
||||||
|
|
||||||
# 发放优惠券
|
# 发放优惠券
|
||||||
user_coupon = UserCouponDB(
|
user_coupon = UserCouponDB(
|
||||||
user_id=user_id,
|
user_id=user_id,
|
||||||
coupon_id=coupon_id,
|
coupon_id=coupon_id,
|
||||||
coupon_name=coupon.name,
|
coupon_name=self.coupon.name,
|
||||||
coupon_amount=coupon.amount,
|
coupon_amount=self.coupon.amount,
|
||||||
coupon_type=coupon.coupon_type,
|
coupon_type=self.coupon.coupon_type,
|
||||||
expire_time=expire_time,
|
expire_time=expire_time,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
BIN
jobs.sqlite
BIN
jobs.sqlite
Binary file not shown.
Loading…
Reference in New Issue
Block a user