浏览代码

更新订单交易时间

peng 1 年之前
父节点
当前提交
d501cf5462
共有 3 个文件被更改,包括 12 次插入5 次删除
  1. 5 2
      AdminController/ServeManagementController.py
  2. 1 1
      Controller/Cron/CronTaskController.py
  3. 6 2
      Controller/TestApi.py

+ 5 - 2
AdminController/ServeManagementController.py

@@ -857,12 +857,15 @@ class serveManagement(View):
         if not abnormal_order.exists():
             return response.json(173)
         try:
-            trade_no = abnormal_order.values('trade_no')[0]['trade_no']
+            abnormal_order_qs = abnormal_order.values('trade_no', 'pay_time')
+            trade_no = abnormal_order_qs[0]['trade_no']
+            pay_time = abnormal_order_qs[0]['pay_time']
             order_qs = Order_Model.objects.filter(trade_no=trade_no)
             if order_qs.exists():
+                order_qs.update(payTime=pay_time)
                 abnormal_order.update(status=1)
                 return response.json(0)
-            params = {'trade_no': trade_no}
+            params = {'trade_no': trade_no, 'pay_time': pay_time}
             eur_response = requests.get('https://www.zositeche.com/testApi/checkOrderExist', params=params)
             if eur_response.status_code == 200:
                 result = eur_response.json()

+ 1 - 1
Controller/Cron/CronTaskController.py

@@ -1242,7 +1242,7 @@ class CronComparedDataView(View):
                 params = {'trade_no': trade_no}
                 response = requests.get('https://www.zositeche.com/testApi/checkOrderExist', params=params)
                 if response.status_code != 200:
-                    # 如果响应失败,记录记录在数据库
+                    # 如果响应失败,记录在数据库
                     AbnormalOrder.objects.create(**order_dict)
                     continue
                 result = response.json()

+ 6 - 2
Controller/TestApi.py

@@ -170,7 +170,7 @@ class testView(View):
             return self.getSerialNumberInfo(request_dict, response)
         elif operation == 'get-serial-details':  # 序列号信息查询
             return self.get_serial_details(request_dict, response, request)
-        elif operation == 'checkOrderExist':  # 转换时间戳
+        elif operation == 'checkOrderExist':  # 检查paypal订单是否存在
             return self.checkOrderExist(request_dict, response)
         else:
             return 123
@@ -1041,9 +1041,13 @@ class testView(View):
     @staticmethod
     def checkOrderExist(request_dict, response):
         trade_no = request_dict.get('trade_no', None)
+        pay_time = request_dict.get('pay_time', None)
         try:
             order_qs = Order_Model.objects.filter(trade_no=trade_no)
-            is_exist = 1 if order_qs.exists() else 0
+            is_exist = 0
+            if order_qs.exists():
+                is_exist = 1
+                order_qs.update(payTime=pay_time)
             return response.json(0, {'is_exist': is_exist})
         except Exception as e:
             return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))