lf 前后端分离 (6) 支付

  1 import datetime
  2 
  3 from django.core.exceptions import ObjectDoesNotExist
  4 
  5 from rest_framework.views import APIView
  6 from rest_framework.response import Response
  7 
  8 from app01.utils.auth import LoginAuth
  9 from app01.utils.response import BaseResponse
 10 from app01.utils.exception import CommonException
 11 from app01.utils.pay import AliPay
 12 from app01.models import *
 13 
 14 
 15 class PaymentView(APIView):
 16     ‘‘‘
 17        模拟请求数据格式：
 18 
 19          {
 20          is_beli:true,
 21          course_list=[
 22                      {  course_id:1
 23                       default_price_policy_id:1,
 24                       coupon_record_id:2
 25                       },
 26                      { course_id:2
 27                       default_price_policy_id:4,
 28                       coupon_record_id:6
 29                       }
 30                   ],
 31           global_coupon_id:3,
 32           pay_money:298
 33 
 34           }
 35 
 36 
 37         状态码：
 38             1000:  成功
 39             1001:  课程不存在
 40             1002:  价格策略不合法
 41             1003:  加入购物车失败
 42             1004:  获取购物车失败
 43             1005:  贝里数有问题
 44             1006:  优惠券异常
 45             1007:  优惠券未达到最低消费
 46             1008:  支付总价格异常
 47 
 48        ‘‘‘
 49     authentication_classes = [LoginAuth]
 50 
 51 
 52     def get_alipay(self):
 53         # 沙箱环境地址：https://openhome.alipay.com/platform/appDaily.htm?tab=info
 54         app_id = "2016091100486897"
 55         # POST请求，用于最后的检测
 56         notify_url = "http://47.94.172.250:8804/page2/"
 57         # notify_url = "http://www.wupeiqi.com:8804/page2/"
 58         # GET请求，用于页面的跳转展示
 59         return_url = "http://47.94.172.250:8804/page2/"
 60         # return_url = "http://www.wupeiqi.com:8804/page2/"
 61         merchant_private_key_path = "keys/app_private_2048.txt"
 62         alipay_public_key_path = "keys/alipay_public_2048.txt"
 63 
 64         alipay = AliPay(
 65             appid=app_id,
 66             app_notify_url=notify_url,
 67             return_url=return_url,
 68             app_private_key_path=merchant_private_key_path,
 69             alipay_public_key_path=alipay_public_key_path,  # 支付宝的公钥，验证支付宝回传消息使用，不是你自己的公钥
 70             debug=True,  # 默认False,
 71         )
 72         return alipay
 73 
 74     def cal_coupon_price(self, price, coupon_record_obj):
 75         coupon_type = coupon_record_obj.coupon.coupon_type
 76         money_equivalent_value = coupon_record_obj.coupon.money_equivalent_value
 77         off_percent = coupon_record_obj.coupon.off_percent
 78         minimum_consume = coupon_record_obj.coupon.minimum_consume
 79         rebate_price = 0
 80         if coupon_type == 0:  # 立减券
 81             rebate_price = price - money_equivalent_value
 82             if rebate_price <= 0:
 83                 rebate_price = 0
 84         elif coupon_type == 1:  # 满减券
 85             if minimum_consume > price:
 86                 raise CommonException(1007, "优惠券未达到最低消费")
 87             else:
 88                 rebate_price = price - money_equivalent_value
 89         elif coupon_type == 2:
 90             rebate_price = price * off_percent / 100
 91 
 92         return rebate_price
 93 
 94     def post(self, request):
 95         print(request.data)
 96         response = BaseResponse()
 97         #         1.获取数据
 98 
 99         user_id = request.user.pk
100         global_coupon_id = request.data.get("global_coupon_id")
101         pay_money = request.data.get("pay_money")
102         course_list = request.data.get("course_list")
103         is_beli = request.data.get("is_beli")
104         now = datetime.datetime.now()
105 
106         try:
107             # 2 校验数据
108             # 2.2 校验课程
109 
110             course_price_list = []
111             for course_dict in course_list:
112                 # 2.2.1 校验课程id
113                 course_id = course_dict.get("course_id")
114                 course_obj = Course.objects.get(pk=course_id)
115                 # 2.2.2 价格策略id
116                 if course_dict.get("default_price_policy_id") not in [obj.pk for obj in course_obj.price_policy.all()]:
117                     raise CommonException(1002, "价格策略异常")
118                 # 2.2.3 课程优惠券id
119                 price_policy_obj = PricePolicy.objects.get(pk=course_dict.get("default_price_policy_id"))
120                 course_dict["original_price"] = price_policy_obj.price
121                 course_dict["valid_period_display"] = price_policy_obj.get_valid_period_display()
122                 course_dict["valid_period"] = price_policy_obj.valid_period
123                 coupon_record_id = course_dict.get("coupon_record_id")
124                 if coupon_record_id:
125                     coupon_record_list = CouponRecord.objects.filter(account=request.user,
126                                                                      status=0,
127                                                                      coupon__valid_begin_date__lte=now,
128                                                                      coupon__valid_end_date__gte=now,
129                                                                      coupon__content_type_id=9,
130                                                                      coupon__object_id=course_id
131                                                                      )
132                     print("coupon_record_id", coupon_record_id)
133                     print([obj.pk for obj in coupon_record_list])
134                     # 默认获取没有选择的优惠券和筛选后优劵
135                     if coupon_record_id not in [obj.pk for obj in coupon_record_list]:
136                         raise CommonException(1006, "课程优惠劵异常")
137                     # 计算循环课程的课程优惠券优惠后的价格
138                     coupon_record_obj = CouponRecord.objects.get(pk=coupon_record_id)
139                     rebate_price = self.cal_coupon_price(price_policy_obj.price, coupon_record_obj)
140                     course_price_list.append(rebate_price)
141                     course_dict["rebate_price"] = rebate_price
142                 else:
143                     course_price_list.append(price_policy_obj.price)
144 
145             #             2.3 校验通用优惠券id
146             global_coupon_record_list = CouponRecord.objects.filter(account=request.user,
147                                                                     status=0,
148                                                                     coupon__valid_begin_date__lte=now,
149                                                                     coupon__valid_end_date__gte=now,
150                                                                     coupon__content_type_id=9,
151                                                                     coupon__object_id=None
152                                                                     )
153             print("global_coupon_record_list", global_coupon_record_list)
154 
155 
156 
157             if global_coupon_id:
158                 if global_coupon_id not in [obj.pk for obj in global_coupon_record_list]:
159                     raise CommonException("通用优惠券异常", 1006)
160                 global_coupon_record_obj = CouponRecord.objects.get(pk=global_coupon_id)
161                 final_price = self.cal_coupon_price(sum(course_price_list), global_coupon_record_obj)
162             else:
163                 final_price = sum(course_price_list)
164             #     2.4 计算实际支付价格与money 校验
165             if is_beli:
166                 final_price = final_price - request.user.beli / 10
167                 if final_price < 0:
168                     final_price = 0
169                 print(final_price)
170 
171             if final_price != float(pay_money):
172                 raise CommonException("支付总价格异常！", 1008)
173 
174         #     4.调用alipay 接口
175             alipay = self.get_alipay()
176             query_params = alipay.direct_pay(
177                 subject="路飞学成",
178                 out_trade_no="x345" + str(datetime.datetime.now()),
179                 total_amount=pay_money,
180             )
181             pay_url = "https://openapi.alipaydev.com/gateway.do?{}".format(query_params)
182             response.data = {
183                 "url": pay_url
184             }
185 
186 
187 
188         except ObjectDoesNotExist as e:
189             response.code = 1001
190             response.msg = "课程不存在！"
191         except CommonException as e:
192             response.code = e.code
193             response.msg = e.msg
194         # except Exception as e:
195         #     response.code = 500
196         #     response.msg = str(e)
197 
198         return Response(response.dict)