|
|
@@ -472,157 +472,18 @@ class PaypalCycleNotify(View):
|
|
|
|
|
|
|
|
|
def do_test(self, request_dict, request, response):
|
|
|
- paypalrestsdk.configure(PAYPAL_CRD)
|
|
|
- billing_agreement = paypalrestsdk.BillingAgreement
|
|
|
- billing_agreement = billing_agreement.find("I-17SRPP7TS71U")
|
|
|
- print("Got Billing Agreement Details for Billing Agreement[%s]" % (
|
|
|
- billing_agreement.id))
|
|
|
- exit(billing_agreement)
|
|
|
- #normal_pay
|
|
|
- # json_str = '{"id":"WH-8SU832847J141682K-0FF265943E8692615","event_version":"1.0","create_time":"2022-01-10T06:31:49.863Z","resource_type":"sale","event_type":"PAYMENT.SALE.COMPLETED","summary":"Payment completed for $ 0.02 USD","resource":{"amount":{"total":"0.02","currency":"USD","details":{"subtotal":"0.02"}},"payment_mode":"INSTANT_TRANSFER","create_time":"2022-01-10T06:31:45Z","transaction_fee":{"currency":"USD","value":"0.02"},"parent_payment":"PAYID-MHN5E5Y1RH70069CT417990V","update_time":"2022-01-10T06:31:45Z","protection_eligibility_type":"ITEM_NOT_RECEIVED_ELIGIBLE,UNAUTHORIZED_PAYMENT_ELIGIBLE","application_context":{"related_qualifiers":[{"id":"0FJ93448LU7282046","type":"CART"}]},"protection_eligibility":"ELIGIBLE","links":[{"method":"GET","rel":"self","href":"https://api.sandbox.paypal.com/v1/payments/sale/6N498138TH641260G"},{"method":"POST","rel":"refund","href":"https://api.sandbox.paypal.com/v1/payments/sale/6N498138TH641260G/refund"},{"method":"GET","rel":"parent_payment","href":"https://api.sandbox.paypal.com/v1/payments/payment/PAYID-MHN5E5Y1RH70069CT417990V"}],"id":"6N498138TH641260G","state":"completed","invoice_number":""},"links":[{"href":"https://api.sandbox.paypal.com/v1/notifications/webhooks-events/WH-8SU832847J141682K-0FF265943E8692615","rel":"self","method":"GET"},{"href":"https://api.sandbox.paypal.com/v1/notifications/webhooks-events/WH-8SU832847J141682K-0FF265943E8692615/resend","rel":"resend","method":"POST"}]}'
|
|
|
- json_agreement_str = '{"id":"WH-9BE23393R5338163R-48P08088YL173821A","event_version":"1.0","create_time":"2022-01-10T10:27:42.925Z","resource_type":"sale","event_type":"PAYMENT.SALE.COMPLETED","summary":"Payment completed for $ 0.02 USD","resource":{"billing_agreement_id":"I-K8PCK2NJC6N6","amount":{"total":"0.02","currency":"USD","details":{"subtotal":"0.02"}},"payment_mode":"INSTANT_TRANSFER","update_time":"2022-01-10T10:27:19Z","create_time":"2022-01-10T10:27:19Z","protection_eligibility_type":"ITEM_NOT_RECEIVED_ELIGIBLE,UNAUTHORIZED_PAYMENT_ELIGIBLE","transaction_fee":{"currency":"USD","value":"0.02"},"protection_eligibility":"ELIGIBLE","links":[{"method":"GET","rel":"self","href":"https://api.sandbox.paypal.com/v1/payments/sale/4H259512Y67055105"},{"method":"POST","rel":"refund","href":"https://api.sandbox.paypal.com/v1/payments/sale/4H259512Y67055105/refund"}],"id":"4H259512Y67055105","state":"completed","invoice_number":""},"links":[{"href":"https://api.sandbox.paypal.com/v1/notifications/webhooks-events/WH-9BE23393R5338163R-48P08088YL173821A","rel":"self","method":"GET"},{"href":"https://api.sandbox.paypal.com/v1/notifications/webhooks-events/WH-9BE23393R5338163R-48P08088YL173821A/resend","rel":"resend","method":"POST"}]}'
|
|
|
- header = {'wsgi.file_wrapper': '<class gunicorn.http.wsgi.FileWrapper>', 'wsgi.version': '(1, 0)', 'HTTP_CONNECTION': 'close', 'wsgi.url_scheme': 'http', 'HTTP_PAYPAL_CERT_URL': 'https://api.sandbox.paypal.com/v1/notifications/certs/CERT-360caa42-fca2a594-7a8abba8', 'HTTP_PAYPAL_TRANSMISSION_ID': '022fbbc0-7139-11ec-afa1-0114a54fc1fc', 'SERVER_NAME': '0.0.0.0', 'HTTP_CORRELATION_ID': 'be4c80f0a6c05', 'REMOTE_ADDR': '127.0.0.1', 'HTTP_PAYPAL_TRANSMISSION_SIG': 'IM3Xwyjw5YUgBKPsgyjPdMAh6DSFTtqdwy8zbJBXBhFyB77B6mEqnRfhtEgwwBhag6HsStmKBGIScFhs5Nuraru7DbT4+7Tu5fNx3oQIHeHtR/FYZoQcv86bjZ9cq+Xo04HmhUfgBAsSetS+CuY5TsN60d1m8Hld1MTDjk1UuSbk8HA3dBLiMzWT7wUw3/SUau/C7TtLnWGmdJlkFne+b/5s0+HsuXn3wQQCDIHO0sBMBo72NdlyMlLIunSdoEJ61pKi2U1jQ6qqe/59IrY2q4ufx9D6JZ4bUB6z3NQZ+Gm7zrlKabT6HkVovLJbuBgRgRWWUoY02CuVXZ9w4AzVNQ==', 'REMOTE_PORT': '58060', 'HTTP_ACCEPT': '*/*', 'CONTENT_TYPE': 'application/json', 'HTTP_USER_AGENT': 'PayPal/AUHR-214.0-56015767', 'SCRIPT_NAME': '', 'HTTP_X_FORWARDED_FOR': '173.0.80.117', 'HTTP_HOST': 'test.zositechc.cn:443', 'wsgi.multiprocess': True, 'SERVER_PROTOCOL': 'HTTP/1.0', 'PATH_INFO': '/payCycle/paypalCycleNotify', 'SERVER_SOFTWARE': 'gunicorn/19.7.1', 'wsgi.input': '<gunicorn.http.body.Body object at 0x7fb966cddfd0>', 'REQUEST_METHOD': 'POST', 'wsgi.errors': '<gunicorn.http.wsgi.WSGIErrorsWrapper object at 0x7fb966cdda90>', 'CONTENT_LENGTH': '1226', 'wsgi.run_once': False, 'HTTP_X_B3_SPANID': 'e8ede80526720f95', 'HTTP_PAYPAL_AUTH_ALGO': 'SHA256withRSA', 'QUERY_STRING': '', 'HTTP_PAYPAL_TRANSMISSION_TIME': '2022-01-09T10:43:40Z', 'wsgi.multithread': False, 'HTTP_HTTP_X_FORWARDED_FOR': '173.0.80.117', 'HTTP_X_REAL_IP': '173.0.80.117', 'RAW_URI': '/payCycle/paypalCycleNotify', 'HTTP_PAYPAL_AUTH_VERSION': 'v2', 'gunicorn.socket': '<socket.socket fd=51, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=(127.0.0.1, 8082), raddr=(127.0.0.1, 58060)>', 'SERVER_PORT': '8082'}
|
|
|
-
|
|
|
-
|
|
|
+ logger = logging.getLogger('info')
|
|
|
+ logger.info('---into---webhook_notify-------')
|
|
|
+ logger.info('---request_dict-------')
|
|
|
+ logger.info(request_dict)
|
|
|
+ json_agreement_str = request.body.decode("utf-8")
|
|
|
json_obj = json.loads(json_agreement_str)
|
|
|
+ header = request.META
|
|
|
paypal_body = json_obj.get('resource')
|
|
|
- billing_agreement_id = paypal_body.get('billing_agreement_id')
|
|
|
- amount = paypal_body.get('amount')
|
|
|
- if not billing_agreement_id:
|
|
|
- return HttpResponse('success')
|
|
|
-
|
|
|
- nowTime = int(time.time())
|
|
|
- transmission_id = header.get('HTTP_PAYPAL_TRANSMISSION_ID',None)
|
|
|
- transmission_time = header.get('HTTP_PAYPAL_TRANSMISSION_TIME',None)
|
|
|
- webhook_id = '6TS30758D98835230'
|
|
|
- cert_url = header.get('HTTP_PAYPAL_CERT_URL',None)
|
|
|
- transmission_sig = header.get('HTTP_PAYPAL_TRANSMISSION_SIG',None)
|
|
|
- auth_algo = header.get('HTTP_PAYPAL_AUTH_ALGO',None)
|
|
|
- resource_type = json_obj.get('resource_type')
|
|
|
- # return HttpResponse(resource_type)
|
|
|
-
|
|
|
-
|
|
|
- transmission_id = 'f42509f0-71ff-11ec-a473-05e6d85b61e7'
|
|
|
- transmission_time = '2022-01-10T10:27:46Z'
|
|
|
- webhook_id = '3J888119TD851704M'
|
|
|
- cert_url = 'https://api.sandbox.paypal.com/v1/notifications/certs/CERT-360caa42-fca2a594-7a8abba8'
|
|
|
- transmission_sig = 'R6sBDhsoq5+FRQHWe+8tSeKJMlRDnt9F2SlWlWVVEfDu9mvQ0zKl74bwcN1zMbvH4o7fWVNbwkcPW70/t4O0YBsj9BcMwL8hDxcuWuHp20RBzaI2dlBpdPEke19wr/fhJKGZCDYuvptV2RJGCSePBn3gKs7hkY5ribELPDqHuajlgVxMmoXm/+CHrMmPo6gSGgTuEMzEn4/ENuj3uJoCkcYqsFx3tUHg6eakUvQ+vYAyflRx9hX7QXEQHp15PWLgGzHkm9zGmnX6YoG5keo5MbJEYh9LfHJjmHmHVErvOtHebJxfTEDZwGoqw+WHr3KqnP4L1gaUj7XIXsQzbiFTBg=='
|
|
|
- auth_algo = 'SHA256withRSA'
|
|
|
- resource_type = 'sale'
|
|
|
- self.get_plan_desc('P-4CG284532S612303METMEINY')
|
|
|
- if resource_type == 'sale' and paypal_body.get('state') == 'completed':
|
|
|
- # paypalrestsdk.configure(PAYPAL_CRD)
|
|
|
- # response = paypalrestsdk.WebhookEvent.verify(
|
|
|
- # transmission_id, transmission_time, webhook_id, json_agreement_str, cert_url, transmission_sig, auth_algo)
|
|
|
- response = True
|
|
|
- if response:
|
|
|
- try:
|
|
|
- agreement_id = paypal_body.get('billing_agreement_id')
|
|
|
- order_qs = Order_Model.objects.filter(agreement_id=agreement_id, status=1)
|
|
|
- if not order_qs:
|
|
|
- return HttpResponse('failss')
|
|
|
- order_list = order_qs.values("UID", "channel", "commodity_code", "rank", "isSelectDiscounts",
|
|
|
- "userID__userID","uid_bucket_id",
|
|
|
- "userID__username",'plan_id','addTime','desc','payType','currency','commodity_type')
|
|
|
- plan_id = order_list[0]['plan_id']
|
|
|
- # plan_cycle = self.get_plan_desc(plan_id)
|
|
|
- # 订阅续费订单(如果查到的本地订单已经付过了且包中的完成周期数`不是0, 则说明是续费订单, 本地可以新建一个订单标记是续费的)
|
|
|
- nowTime = int(time.time())
|
|
|
- if(order_list[0]['addTime']+600 > nowTime):
|
|
|
- return HttpResponse('success')
|
|
|
-
|
|
|
- userid = order_list[0]['userID__userID']
|
|
|
- username = order_list[0]['userID__username']
|
|
|
- UID = order_list[0]['UID']
|
|
|
- channel = order_list[0]['channel']
|
|
|
- rank = order_list[0]['rank']
|
|
|
- smqs = Store_Meal.objects.filter(id=rank). \
|
|
|
- values("day", "bucket_id", "bucket__storeDay", "expire")
|
|
|
- bucketId = smqs[0]['bucket_id']
|
|
|
- if not smqs.exists():
|
|
|
- return HttpResponse('fail')
|
|
|
- # ##
|
|
|
- ubqs = UID_Bucket.objects.filter(uid=UID).values("id", "bucket_id", "bucket__storeDay",
|
|
|
- "bucket__region",
|
|
|
- "endTime", "use_status")
|
|
|
- expire = smqs[0]['expire']
|
|
|
-
|
|
|
- # if order_list[0]['isSelectDiscounts'] == 1:
|
|
|
- # expire = smqs[0]['expire'] * 2
|
|
|
- # 是否有促销
|
|
|
- # nowTime = int(time.time())
|
|
|
- # promotion = PromotionRuleModel.objects.filter(status=1, startTime__lte=nowTime,
|
|
|
- # endTime__gte=nowTime).values('id', 'ruleConfig')
|
|
|
- # if promotion.exists():
|
|
|
- # promotion_rule_id = promotion[0]['id']
|
|
|
- # expire = expire * 2
|
|
|
- with transaction.atomic():
|
|
|
- if ubqs.exists():
|
|
|
- ubq = ubqs[0]
|
|
|
- if ubq['use_status'] == 1 and ubq['bucket_id'] == bucketId: # 套餐使用中并且相同套餐叠加过期时间
|
|
|
- endTime = CommonService.calcMonthLater(expire, ubq['endTime'])
|
|
|
- UID_Bucket.objects.filter(id=ubq['id']).update \
|
|
|
- (uid=UID, channel=channel, bucket_id=bucketId,
|
|
|
- endTime=endTime, updateTime=nowTime)
|
|
|
- else: # 已过期或者不相同的套餐加入未使用的关联套餐表
|
|
|
- has_unused = Unused_Uid_Meal.objects.filter(uid=UID, bucket_id=bucketId).values("id")
|
|
|
- # nums = 2 if order_list[0]['isSelectDiscounts'] == 1 else 1
|
|
|
- # if promotion.exists():
|
|
|
- nums = 1
|
|
|
- if has_unused.exists():
|
|
|
- Unused_Uid_Meal.objects.filter(id=has_unused[0]['id']).update(num=F('num') + nums)
|
|
|
- else:
|
|
|
- Unused_Uid_Meal.objects.create(uid=UID, channel=channel, addTime=nowTime, num=nums,
|
|
|
- expire=smqs[0]['expire'], bucket_id=bucketId)
|
|
|
- UID_Bucket.objects.filter(id=ubq['id']).update(has_unused=1)
|
|
|
- uid_bucket_id = ubq['id']
|
|
|
- else:
|
|
|
- endTime = CommonService.calcMonthLater(expire)
|
|
|
- ub_cqs = UID_Bucket.objects.create \
|
|
|
- (uid=UID, channel=channel, bucket_id=bucketId, endTime=endTime, addTime=nowTime,
|
|
|
- updateTime=nowTime, use_status=1)
|
|
|
- uid_bucket_id = ub_cqs.id
|
|
|
-
|
|
|
- dvq = Device_Info.objects.filter(UID=UID, vodPrimaryUserID='', vodPrimaryMaster='')
|
|
|
- if dvq.exists():
|
|
|
- dvq_set_update_dict = {
|
|
|
- 'vodPrimaryUserID': userid,
|
|
|
- 'vodPrimaryMaster': username
|
|
|
- }
|
|
|
- dvq.update(**dvq_set_update_dict)
|
|
|
-
|
|
|
- # uid_main_exist = UIDMainUser.objects.filter(UID=UID)
|
|
|
- # if not uid_main_exist.exists():
|
|
|
- # uid_main_dict = {
|
|
|
- # 'UID': UID,
|
|
|
- # 'user_id': userid
|
|
|
- # }
|
|
|
- # UIDMainUser.objects.create(**uid_main_dict)
|
|
|
- orderID = CommonService.createOrderID()
|
|
|
- Order_Model.objects.create(orderID=orderID, UID=UID, channel=channel, userID_id=userid,
|
|
|
- desc=order_list[0]['desc'], payType=order_list[0]['payType'], payTime=nowTime,
|
|
|
- price=amount.get('total'), currency=order_list[0]['currency'], addTime=nowTime, updTime=nowTime,
|
|
|
- pay_url='', isSelectDiscounts=0,
|
|
|
- commodity_code=order_list[0]['commodity_code'], commodity_type=order_list[0]['commodity_type'],
|
|
|
- rank_id=rank, paymentID='', coupon_id='',uid_bucket_id=uid_bucket_id,status=1,agreement_id=agreement_id,plan_id=order_list[0]['plan_id'])
|
|
|
- # 如果存在序列号,消息提示用序列号
|
|
|
- device_name = CommonService.query_serial_with_uid(uid=UID)
|
|
|
- datetime = time.strftime("%Y-%m-%d", time.localtime())
|
|
|
- sys_msg_text_list = ['温馨提示：尊敬的客户，您的' + device_name + '设备在' + datetime + '已成功续订云存套餐',
|
|
|
- 'Dear customer,you already subscribed the cloud storage package successfully for device ' + device_name + ' on ' + time.strftime(
|
|
|
- "%b %dth,%Y", time.localtime())]
|
|
|
-
|
|
|
- if order_list[0]['payType'] == 1:
|
|
|
- lang = 'en'
|
|
|
- else:
|
|
|
- lang = 'cn'
|
|
|
- CloudStorage.CloudStorageView.do_vod_msg_Notice(UID, channel, userid, lang,
|
|
|
- sys_msg_text_list, 'SMS_219738485')
|
|
|
- return HttpResponse('success')
|
|
|
- except Exception as e:
|
|
|
- print(e)
|
|
|
- return HttpResponse('fail')
|
|
|
- return HttpResponse('fail')
|
|
|
+ logger.info('-----paypal_body------')
|
|
|
+ logger.info(paypal_body)
|
|
|
+ logger.info('-----paypal_header------')
|
|
|
+ logger.info(header)
|
|
|
|
|
|
|
|
|
def get_plan_desc(self,plan_id):
|
lang