1         with transaction.atomic():
 2             try:
 3                 if is_key:
 4                     act = Activity.objects.select_for_update().get(key=key_or_id)
 5                 else:
 6                     act = Activity.objects.select_for_update().get(id=key_or_id)
 7                 ticket = Ticket.objects.select_for_update().get(student_id=self.user.student_id, activity_id=act.id)
 8                 reply_text = {
 9                     'Title': self.get_message('ticket_title', act_name=act.name),
10                     'Description': self.get_message('ticket_description', act_description=act.description),
11                     'Url': self.url_ticket(ticket.unique_id)
12                 }
13                 is_reply_text = False
14             except Activity.DoesNotExist:
15                 reply_text = "活动不存在"
16             except Ticket.DoesNotExist:
17                 if act.book_start > timezone.now():
18                     reply_text = "抢票尚未开始"
19                 elif act.book_end < timezone.now():
20                     reply_text = "抢票已经结束"
21                 elif act.remain_tickets <= 0:
22                     reply_text = "对不起，票已经被抢光啦"
23                 else:
24                     act.remain_tickets -= 1
25                     act.save()
26                     t = Ticket(student_id=self.user.student_id,
27                                activity_id=act.id,
28                                unique_id=gen_unique_id(self.user.student_id, act.id),
29                                status=Ticket.STATUS_VALID)
30                     t.save()
31                     reply_text = "抢票成功,请稍后查看抢票结果"
32                     is_success = True
33         if is_success:
34             task_update_activity_in_cache.delay(act.id)

 1 @task
 2 def task_update_activity_in_cache(id):
 4     acts = Activity.objects.filter(id=id)
 5     print(acts[0].remain_tickets)
 6     print(timezone.now())
 7     if not acts:
 8         return
 9     if acts.count() > 1:
10         raise DbError("duplicated id")
11     activity = acts[0]
12     cache.set(querykey_of_act('id', activity.id), activity)
13     cache.set(querykey_of_act('key', activity.key), activity)