酒鬼酒兑奖v2

sales/views.py

@@ -4063,6 +4063,71 @@ def promotionCode_compose_json(request):
     return JsonResponse({'msg': 'ok'})
 
 
+@csrf_exempt
+def promotionCode_compose_json_v2(request):
+    """
+    {plan}
+     0: 馥郁奖,
+     1: 三香奖,
+    """
+
+    req_json = json.loads(request.body)
+
+    consumer_id = req_json['uid']
+    activity = req_json['activity']
+    company_id = 1
+    plan = req_json['plan']
+    cardsUse = req_json['cardsUse']
+
+    tm = datetime.datetime.now()
+
+    try:
+        user = ConsumerAccount.objects.get(id=consumer_id)
+    except Exception as e:
+        return JsonResponse({'e': 'invalid consumer_id.'})
+
+    cur = connection.cursor()
+
+    if company_id == 1:
+        plan = int(plan)
+        if activity == 104 and plan == 0:
+            card_consume_list = []
+            activityAward = 425
+            qty=1
+            ids = []
+            for key, value in cardsUse.items():
+                sql = f"select id, item from sales_promotioncode where activity_id={key} and uid_id={user.id} and status in (1,2) and item={value[0]} limit 1"
+                cur.execute(sql)
+                rs = cur.fetchall()
+                for r in rs:
+                    ids.append([r[0],r[1]])
+
+            if len(ids) == 3:
+                for r in ids:
+                    # 修改code的状态
+                    pc = PromotionCode.objects.get(id=r[0])
+                    pc.status = 3
+                    pc.save()
+                        # 写消耗的记录
+                    p = PromotionCodeStatusRecord(code=pc, operation=3, uid=user, tm=tm)
+                    p.save()
+                    card_consume_list.append({'id': r[0], 'item': r[1]})
+                # 写 ConsumerWinner
+                c = ConsumerWinner(
+                        company_id=company_id,
+                        consumer_id=user.id,
+                        activity_id=activity,
+                        award_id=activityAward,
+                        qty=qty
+                    )
+                c.save()
+                return JsonResponse({'card_consumed': card_consume_list, 'plan': plan})
+            else:
+                JsonResponse({'msg': 'not enough'})
+            
+    return JsonResponse({'msg': 'ok'})
+
+
 @csrf_exempt
 def promotionCode_redeem(request):
     consumer_id = request.POST.get('uid', '')