|
|
@@ -4,9 +4,11 @@
|
|
|
import time
|
|
|
|
|
|
import itunesiap
|
|
|
+from django.db.models import Q
|
|
|
from django.views import View
|
|
|
|
|
|
-from Model.models import Order_Model, Store_Meal
|
|
|
+from Model.models import Order_Model, Store_Meal, Device_Info, UID_Bucket
|
|
|
+from Object.RedisObject import RedisObject
|
|
|
from Service.CommonService import CommonService
|
|
|
|
|
|
|
|
|
@@ -44,7 +46,27 @@ class InAppPurchaseView(View):
|
|
|
uid = request_dict.get('uid', None)
|
|
|
lang = request_dict.get('lang', 'en')
|
|
|
channel = request_dict.get('channel', None)
|
|
|
+
|
|
|
+ # redis加锁，防止订单重复
|
|
|
+ redis_obj = RedisObject()
|
|
|
+ redis_key = uid + 'in_app_purchase'
|
|
|
+ is_lock = redis_obj.CONN.setnx(redis_key, 1)
|
|
|
+ redis_obj.CONN.expire(redis_key, 60)
|
|
|
+ if not is_lock:
|
|
|
+ return response.json(5)
|
|
|
+
|
|
|
try:
|
|
|
+ device_info_qs = Device_Info.objects.filter(userID_id=user_id, UID=uid, isShare=False, isExist=1).values(
|
|
|
+ 'vodPrimaryUserID',
|
|
|
+ 'vodPrimaryMaster')
|
|
|
+ if not device_info_qs.exists():
|
|
|
+ return response.json(12)
|
|
|
+
|
|
|
+ device_info_qs = Device_Info.objects.filter(Q(UID=uid), ~Q(vodPrimaryUserID='')).values('vodPrimaryUserID')
|
|
|
+ if device_info_qs.exists():
|
|
|
+ if device_info_qs[0]['vodPrimaryUserID'] != user_id:
|
|
|
+ return response.json(10033)
|
|
|
+
|
|
|
order_id = CommonService.createOrderID()
|
|
|
verify_response = itunesiap.verify(receipt, env=itunesiap.env.sandbox)
|
|
|
print(verify_response.receipt.in_app[0]['product_id']) # response.receipt.last_in_app.product_id
|
|
|
@@ -53,6 +75,10 @@ class InAppPurchaseView(View):
|
|
|
pay_type = 4
|
|
|
now_time = int(time.time())
|
|
|
|
|
|
+ # 查询设备是否已开过云存
|
|
|
+ uid_bucket_qs = UID_Bucket.objects.filter(uid=uid).\
|
|
|
+ values('id', 'bucket_id', 'bucket__region', 'endTime', 'use_status')
|
|
|
+
|
|
|
store_qs = Store_Meal.objects.filter(
|
|
|
product_id=product_id, lang__lang=lang, is_show=0).\
|
|
|
values(
|
|
|
@@ -80,8 +106,10 @@ class InAppPurchaseView(View):
|
|
|
orderID=order_id, UID=uid, channel=channel, userID_id=user_id, desc=content, payType=pay_type,
|
|
|
payTime=now_time, price=price, currency=currency, addTime=now_time, updTime=now_time,
|
|
|
order_type=order_type, commodity_code=commodity_code, commodity_type=commodity_type, rank_id=rank_id,
|
|
|
- ai_rank_id=1, store_meal_name=store_meal_name)
|
|
|
+ ai_rank_id=1, status=1, store_meal_name=store_meal_name)
|
|
|
+ redis_obj.del_data(redis_key)
|
|
|
return response.json(0)
|
|
|
except Exception as e:
|
|
|
+ redis_obj.del_data(redis_key)
|
|
|
return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
|
|
