主次用户2

Controller/CloudStorage.py

@@ -848,17 +848,26 @@ class CloudStorageView(View):
 
         print("进来了,阿里支付成功回调")
         response = ResponseObject()
-        # data = request.POST.dict()
-        # asy = threading.Thread(target=ModelService.add_log,
-        #                        args=(CommonService.get_ip_address(request),data['out_trade_no'], '进来了,阿里支付成功回调'))
-        # asy.start()
-        # signature = data["sign"]
-        # data.pop('sign')
-        # orderID = data['out_trade_no']
-        orderID = 20201223083053707657
+        data = request.POST.dict()
+        asy = threading.Thread(target=ModelService.add_log,
+                               args=(CommonService.get_ip_address(request), data['out_trade_no'], '进来了,阿里支付成功回调'))
+        asy.start()
+        signature = data["sign"]
+        data.pop('sign')
+        orderID = data['out_trade_no']
+
         order_qs = Order_Model.objects.filter(orderID=orderID, status=0)
+        print(order_qs)
 
-        if True:
+        if not order_qs.exists():
+            return response.json(404)
+        print(json.dumps(data))
+        print(signature)
+        # verify
+        aliPayObj = AliPayObject()
+        alipay = aliPayObj.conf()
+        success = alipay.verify(data, signature)
+        if success and data["trade_status"] in ("TRADE_SUCCESS", "TRADE_FINISHED"):
             print("trade succeed")
             order_qs = Order_Model.objects.filter(orderID=orderID)
             nowTime = int(time.time())