|
@@ -53,7 +53,7 @@ from Model.models import (
|
|
|
UID_Bucket,
|
|
|
UIDCompanySerialModel,
|
|
|
VodBucketModel, PaypalWebHookEvent, TimeZoneInfo, CountryLanguageModel, UidSetModel, UidPushModel,
|
|
|
- ExperienceContextModel,
|
|
|
+ ExperienceContextModel, Unused_Uid_Meal,
|
|
|
)
|
|
|
from Object.AliPayObject import AliPayObject
|
|
|
from Object.AWS.AmazonS3Util import AmazonS3Util
|
|
@@ -207,6 +207,8 @@ class testView(View):
|
|
|
return self.get_domain_name(response)
|
|
|
elif operation == 'base64EncodeOrDecode':
|
|
|
return self.base64EncodeOrDecode(request_dict, response)
|
|
|
+ elif operation == 'handlingDuplicateOrders':
|
|
|
+ return self.handlingDuplicateOrders(request_dict, response)
|
|
|
else:
|
|
|
return response.json(414)
|
|
|
|
|
@@ -1605,3 +1607,22 @@ class testView(View):
|
|
|
else:
|
|
|
result = CommonService.decode_data(data)
|
|
|
return response.json(0, result)
|
|
|
+
|
|
|
+ @staticmethod
|
|
|
+ def handlingDuplicateOrders(request_dict, response):
|
|
|
+ try:
|
|
|
+ order_id_list = []
|
|
|
+ uid_list = []
|
|
|
+ for uid in uid_list:
|
|
|
+ order_qs = Order_Model.objects.filter(UID=uid, addTime__gt=1748102400).values('orderID')
|
|
|
+ order_id = order_qs[0]['orderID']
|
|
|
+ order_id_list.append(order_id)
|
|
|
+ # 如果没有未使用订单,更新vod_uid_bucket的has_unused
|
|
|
+ # unused_count = Unused_Uid_Meal.objects.filter(uid=uid).count()
|
|
|
+ # if unused_count < 2:
|
|
|
+ # UID_Bucket.objects.filter(uid=uid).update(has_unused=0)
|
|
|
+ # 删除订单,unused_uid_Meal未使用订单
|
|
|
+ print(order_id_list)
|
|
|
+ return response.json(0)
|
|
|
+ except Exception as e:
|
|
|
+ return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|