新增酒鬼酒生肖卡合成接口

datacenter/urls.py

@@ -126,6 +126,7 @@ urlpatterns = [
     url(r'^sales/promotioncode/share_json/$', sal_views.promotionCode_share_json),
     url(r'^sales/promotioncode/compose/$', sal_views.promotionCode_compose),
     url(r'^sales/promotioncode/compose_json/$', sal_views.promotionCode_compose_json),
+    url(r'^sales/promotioncode/compose_json_jg/$', sal_views.promotionCode_compose_json_jg),
     url(r'^sales/promotioncode/redeem/$', sal_views.promotionCode_redeem),
     url(r'^sales/promotioncode/redeem_json/$', sal_views.promotionCode_redeem_json),
     url(r'^sales/promotioncode/super_prize_redeem_json/$', sal_views.promotionCode_super_prize_redeem_json),

sales/views.py

@@ -3348,7 +3348,7 @@ def promotionCode_getUserData(request):
            f"(select name from sales_award where id=(select award_id from sales_activityawards where id=a.award_id)), " \
            f"tm, activity_id " \
            f"from sales_consumerwinner a " \
-           f"where activity_id in (18, 55, 98) and consumer_id={user.id} and tm_redeemed is null"
+           f"where activity_id in (18, 55, 98, 104) and consumer_id={user.id} and tm_redeemed is null"
     cur.execute(sql2)
     t = cur.fetchall()
 
@@ -3367,7 +3367,7 @@ def promotionCode_getUserData(request):
            f"(select name from sales_award where id=(select award_id from sales_activityawards where id=a.award_id)), " \
            f"tm, tm_redeemed, activity_id " \
            f"from sales_consumerwinner a " \
-           f"where activity_id in (18, 55, 98) and consumer_id={user.id} and tm_redeemed is not null"
+           f"where activity_id in (18, 55, 98, 104) and consumer_id={user.id} and tm_redeemed is not null"
     cur.execute(sql3)
     d = cur.fetchall()
 
@@ -4064,7 +4064,7 @@ def promotionCode_compose_json(request):
 
 
 @csrf_exempt
-def promotionCode_compose_json_v2(request):
+def promotionCode_compose_json_jg(request):
     """
     {plan}
      0: 馥郁奖,
@@ -4090,9 +4090,9 @@ def promotionCode_compose_json_v2(request):
 
     if company_id == 1:
         plan = int(plan)
-        if activity == 104 and plan == 0:
+        if plan == 0:
             card_consume_list = []
-            activityAward = 425
+            activityAward = 426
             qty=1
             ids = []
             for key, value in cardsUse.items():
@@ -4101,7 +4101,6 @@ def promotionCode_compose_json_v2(request):
                 rs = cur.fetchall()
                 for r in rs:
                     ids.append([r[0],r[1]])
-
             if len(ids) == 3:
                 for r in ids:
                     # 修改code的状态
@@ -4123,8 +4122,68 @@ def promotionCode_compose_json_v2(request):
                 c.save()
                 return JsonResponse({'card_consumed': card_consume_list, 'plan': plan})
             else:
-                JsonResponse({'msg': 'not enough'})
-            
+                return JsonResponse({'msg': 'not enough'})
+        elif plan == 1:
+            card_consume_list = []
+            sql0 = f"select item, count(*) from sales_promotioncode where uid_id={user.id} and status in (1,2) and activity_id='{activity}' group by item"
+            cur.execute(sql0)
+            r = cur.fetchall()
+            list = []
+            listArray = [0, 0, 0, 0, 0, 0]
+            cardsUseArray = cardsUse.split(',')
+            for i, v in enumerate(cardsUseArray):
+                cardsUseArray[i] = int(v)
+            for i in r:
+                list.append({
+                    i[0]: i[1]
+                })
+                listArray[i[0] - 1] = i[1]
+
+            qty = 1
+            limit = 6
+            activityAward = 425
+
+            cardsUseSum = 0
+            for i in cardsUseArray:
+                cardsUseSum += i
+            if cardsUseSum != limit:
+                return JsonResponse({'e': 'limit not match', 'code': '16-1'})
+
+            sufficientCards = True
+            for i, v in enumerate(listArray):
+                if cardsUseArray[i] > listArray[i]:
+                    sufficientCards = False
+                    break
+            if sufficientCards == False:
+                return JsonResponse({'e': 'insufficient cards', 'code': '15-1'})
+            else:
+                for j, jv in enumerate(cardsUseArray):
+                    if jv == 0:
+                        continue
+                    sql = f"select id, item from sales_promotioncode where activity_id={activity} and uid_id={user.id} and status in (1,2) and item={j + 1} limit {jv}"
+                    cur.execute(sql)
+                    rs = cur.fetchall()
+                    for r in rs:
+                        # 修改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=104,
+                    award_id=activityAward,
+                    qty=qty
+                )
+                c.save()
+                return JsonResponse({'card_consumed': card_consume_list, 'plan': plan})
+        
+
     return JsonResponse({'msg': 'ok'})