an>
|
123
|
+
|
|
|
124
|
+ # JSAPI--公众号支付、NATIVE--原生扫码支付、APP--app支付，统一下单接口trade_type的传参可参考这里
|
|
|
125
|
+ trade_type = 'JSAPI'
|
|
|
126
|
+
|
|
|
127
|
+ # 根据 trade_type 获取 wechat 配置
|
|
|
128
|
+ wxcfg = WECHAT.get(trade_type, {})
|
|
|
129
|
+ # WeChatPay 初始化
|
|
|
130
|
+ wxpay = WeChatPay(wxcfg.get('appID'), wxcfg.get('apiKey'), wxcfg.get('mchID'))
|
|
|
131
|
+
|
|
|
132
|
+ # 生成订单
|
|
|
133
|
+ order = RoomOrderInfo.objects.create(
|
|
|
134
|
+ user_id=user_id,
|
|
|
135
|
+ room_id=room_id,
|
|
|
136
|
+ anchor_id=anchor_id,
|
|
|
137
|
+ goods_id=goods_id,
|
|
|
138
|
+ share_openid=share_openid,
|
|
|
139
|
+ amount=amount,
|
|
|
140
|
+ total_fee=total_fee,
|
|
|
141
|
+ trade_type=trade_type,
|
|
|
142
|
+ name=name,
|
|
|
143
|
+ phone=phone,
|
|
|
144
|
+ address=address,
|
|
|
145
|
+ )
|
|
|
146
|
+
|
|
|
147
|
+ try:
|
|
|
148
|
+ prepay_data = wxpay.order.create(
|
|
|
149
|
+ body=body,
|
|
|
150
|
+ notify_url=settings.API_DOMAIN + 'live/pay/notify_url',
|
|
|
151
|
+ out_trade_no=order.order_id,
|
|
|
152
|
+ total_fee=total_fee,
|
|
|
153
|
+ trade_type=trade_type,
|
|
|
154
|
+ openid=user.openid, # 可选，用户在商户appid下的唯一标识。trade_type=JSAPI，此参数必传
|
|
|
155
|
+ )
|
|
|
156
|
+ except WeChatPayException as e:
|
|
|
157
|
+ order.unifiedorder_result = e.args
|
|
|
158
|
+ order.save()
|
|
|
159
|
+ return response(OrderStatusCode.UNIFIED_ORDER_FAIL)
|
|
|
160
|
+
|
|
|
161
|
+ prepay_id = prepay_data.get('prepay_id', '')
|
|
|
162
|
+ order.prepay_id = prepay_id
|
|
|
163
|
+ order.save()
|
|
|
164
|
+
|
|
|
165
|
+ wxpay_params = wxpay.jsapi.get_jsapi_params(prepay_id)
|
|
|
166
|
+
|
|
|
167
|
+
|
|
|
168
|
+ return response(200, 'Order Create Success', '订单创建成功', {
|
|
|
169
|
+ 'order_id': order.order_id,
|
|
|
170
|
+ 'prepay_id': prepay_id,
|
|
|
171
|
+ 'wxpay_params': wxpay_params,
|
|
|
172
|
+ })
|
|
|
173
|
+
|
|
|
174
|
+def live_order_cancel(request):
|
|
|
175
|
+ user_id = request.POST.get('user_id', '')
|
|
|
176
|
+ order_id = request.POST.get('order_id', '')
|
|
|
177
|
+ prepay_id = request.POST.get('prepay_id', '')
|
|
|
178
|
+
|
|
|
179
|
+ try:
|
|
|
180
|
+ order = RoomOrderInfo.objects.get(user_id=user_id, order_id=order_id, prepay_id=prepay_id)
|
|
|
181
|
+ except:
|
|
|
182
|
+ return response(400001, 'Order Not Found', description='直播间订单不存在')
|
|
|
183
|
+
|
|
|
184
|
+ if order.pay_status == RoomOrderInfo.FAIL:
|
|
|
185
|
+ return response(200, 'Order Cancel Success', '订单取消成功')
|
|
|
186
|
+
|
|
|
187
|
+ order.pay_status = RoomOrderInfo.FAIL
|
|
|
188
|
+ order.save()
|
|
|
189
|
+
|
|
|
190
|
+ try:
|
|
|
191
|
+ goods_info = RoomGoodsInfo.objects.get(room_id=order.room_id, goods_id=order.goods_id, anchor_id=order.anchor_id)
|
|
|
192
|
+ goods_info.inventory += order.amount
|
|
|
193
|
+ goods_info.save()
|
|
|
194
|
+ except:
|
|
|
195
|
+ return response(400001, 'Room Goods Not Found', description='直播间商品不存在')
|
|
|
196
|
+
|
|
|
197
|
+ return response(200, 'Order Cancel Success', '订单取消成功')
|
|
|
198
|
+
|
|
|
199
|
+def order_paid_success(order):
|
|
|
200
|
+ if order.pay_status == RoomOrderInfo.PAID:
|
|
|
201
|
+ return
|
|
|
202
|
+
|
|
|
203
|
+ order.pay_status = RoomOrderInfo.PAID
|
|
|
204
|
+ order.paid_at = tc.utc_datetime()
|
|
|
205
|
+ order.save()
|
|
|
206
|
+
|
|
|
207
|
+ try:
|
|
|
208
|
+ goods_info = RoomGoodsInfo.objects.get(room_id=order.room_id, goods_id=order.goods_id, anchor_id=order.anchor_id)
|
|
|
209
|
+ goods_info.sale_infos += [order.order_id]
|
|
|
210
|
+ goods_info.save()
|
|
|
211
|
+ except:
|
|
|
212
|
+ return
|
|
|
213
|
+
|
|
|
214
|
+def order_paid_fail(order):
|
|
|
215
|
+ if order.pay_status == RoomGoodsInfo.FAIL:
|
|
|
216
|
+ return
|
|
|
217
|
+
|
|
|
218
|
+ order.pay_status = RoomGoodsInfo.FAIL
|
|
|
219
|
+ order.save()
|
|
|
220
|
+
|
|
|
221
|
+ try:
|
|
|
222
|
+ goods_info = RoomGoodsInfo.objects.get(room_id=order.room_id, goods_id=order.goods_id, anchor_id=order.anchor_id)
|
|
|
223
|
+ goods_info.inventory += order.amount
|
|
|
224
|
+ goods_info.save()
|
|
|
225
|
+ except:
|
|
|
226
|
+ return
|
|
|
227
|
+
|
|
|
228
|
+@logit
|
|
|
229
|
+@transaction.atomic
|
|
|
230
|
+def notify_url_api(request):
|
|
|
231
|
+ """ 支付异步通知回调地址 """
|
|
|
232
|
+ notify_data, success = check_pay_notify(request.body, wx_configs=settings.WECHAT)
|
|
|
233
|
+ if not success:
|
|
|
234
|
+ return HttpResponse(WXPAY_NOTIFY_FAIL)
|
|
|
235
|
+
|
|
|
236
|
+ order = RoomOrderInfo.objects.select_for_update().get(order_id=notify_data.get('out_trade_no', ''), status=True)
|
|
|
237
|
+
|
|
|
238
|
+ order.notify_msg = request.body
|
|
|
239
|
+ order.transaction_id = notify_data.get('transaction_id', '')
|
|
|
240
|
+ order.save()
|
|
|
241
|
+
|
|
|
242
|
+ result_code = notify_data.get('result_code', '')
|
|
|
243
|
+ if result_code == 'SUCCESS':
|
|
|
244
|
+ live_views.order_paid_success(order)
|
|
|
245
|
+ else:
|
|
|
246
|
+ live_views.order_paid_fail(order)
|
|
|
247
|
+
|
|
|
248
|
+ return HttpResponse(WXPAY_NOTIFY_SUCCESS)
|
|
|
|
@@ -18,8 +18,11 @@ from account.models import UserInfo
|
|
18
|
18
|
from goods.models import GoodsInfo, PackGoodsInfo, PackGoodsSaleInfo, PackInfo
|
|
19
|
19
|
from kol.models import KOLInfo
|
|
20
|
20
|
from pay.models import OrderInfo
|
|
|
21
|
+from live.models import RoomOrderInfo
|
|
21
|
22
|
from utils.error.errno_utils import KOLStatusCode, OrderStatusCode, PackGoodsStatusCode, PackStatusCode, UserStatusCode
|
|
22
|
23
|
|
|
|
24
|
+from live import views as live_views
|
|
|
25
|
+
|
|
23
|
26
|
|
|
24
|
27
|
WECHAT = settings.WECHAT
|
|
25
|
28
|
|
|
|
|
@@ -215,19 +218,22 @@ def wx_notify_url_api(request):
|
|
215
|
218
|
if not success:
|
|
216
|
219
|
return HttpResponse(WXPAY_NOTIFY_FAIL)
|
|
217
|
220
|
|
|
|
221
|
+ #尖货接龙订单
|
|
218
|
222
|
try:
|
|
219
|
223
|
order = OrderInfo.objects.select_for_update().get(order_id=notify_data.get('out_trade_no', ''), status=True)
|
|
220
|
|
- except OrderInfo.DoesNotExist:
|
|
221
|
|
- return HttpResponse(WXPAY_NOTIFY_FAIL)
|
|
|
224
|
+ order.notify_msg = request.body
|
|
|
225
|
+ order.transaction_id = notify_data.get('transaction_id', '')
|
|
|
226
|
+ order.save()
|
|
222
|
227
|
|
|
223
|
|
- order.notify_msg = request.body
|
|
224
|
|
- order.transaction_id = notify_data.get('transaction_id', '')
|
|
225
|
|
- order.save()
|
|
|
228
|
+ result_code = notify_data.get('result_code', '')
|
|
|
229
|
+ if result_code == 'SUCCESS':
|
|
|
230
|
+ order_paid_success(order)
|
|
|
231
|
+ else:
|
|
|
232
|
+ order_paid_fail(order)
|
|
|
233
|
+
|
|
|
234
|
+ return HttpResponse(WXPAY_NOTIFY_SUCCESS)
|
|
|
235
|
+ except:
|
|
|
236
|
+ return HttpResponse(WXPAY_NOTIFY_FAIL)
|
|
226
|
237
|
|
|
227
|
|
- result_code = notify_data.get('result_code', '')
|
|
228
|
|
- if result_code == 'SUCCESS':
|
|
229
|
|
- order_paid_success(order)
|
|
230
|
|
- else:
|
|
231
|
|
- order_paid_fail(order)
|
|
232
|
238
|
|
|
233
|
239
|
return HttpResponse(WXPAY_NOTIFY_SUCCESS)
|