适配风险合规下消费者投诉2.0相关接口

Author: minibear2021

README.md

@@ -7,7 +7,7 @@
 
 微信支付接口V3版python库。
 
-欢迎微信支付开发者扫码进QQ群讨论：
+欢迎微信支付开发者扫码进QQ群(群号：973102221)讨论：
 
 ![image](qq.png)
 
@@ -54,6 +54,10 @@
 
     分账 已适配
 
+### 风险合规
+
+    消费者投诉2.0 已适配
+
 #### 其他能力
 
     图片上传 已适配
@@ -270,6 +274,11 @@ def combine_close():
 def sign():
     print(wxpay.sign(['wx888','1414561699','5K8264ILTKCH16CQ2502S....','prepay_id=wx201410272009395522657....']))
 
+# 解密部分接口返回的信息中的加密字段
+# https://pay.weixin.qq.com/wiki/doc/apiv3/wechatpay/wechatpay4_3.shtml
+def decrypt():
+    print(wxpay.decrypt(ciphtext='Qe41VhP/sGdNeTHMQGlxCWiUyHu6XNO9GCYln2Luv4HhwJzZBfcL12sB+PgZcS5NhePBog30NgJ1xRaK+gbGDKwpg=='))
+
 # 验证并解密回调消息，把回调接口收到的headers和body传入
 # 这里以flask框架为例，其他web框架如果遇到InvalidSignature，请确认传入的body和收到的一致，没有做额外的预处理
 def decrypt_callback(headers=request.headers, body=request.data):
@@ -483,6 +492,80 @@ def profitsharing_bill():
     )
     print('code: %s, message: %s' % (code, message))
 
+# 查询投诉单列表
+def complant_list_query():
+    code, message = wxpay.complant_list_query(
+        begin_date='2019-01-01'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+# 查询投诉单详情
+def complant_detail_query():
+    code, message = wxpay.complant_detail_query(
+        complaint_id='200201820200101080076610000'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+# 查询投诉协商历史
+def complant_history_query():
+    code, message = wxpay.complant_history_query(
+        complaint_id='200201820200101080076610000'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+# 创建投诉通知回调地址
+def complant_notification_create():
+    code, message = wxpay.complant_notification_create(
+        url='https://www.xxx.com/notify'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+# 查询投诉通知回调地址
+def complant_notification_query():
+    code, message = wxpay.complant_notification_query()
+    print('code: %s, message: %s' % (code, message))
+
+# 更新投诉通知回调地址
+def complant_notification_update():
+    code, message = wxpay.complant_notification_update(
+        url='https://www.xxx.com/notify'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+# 删除投诉通知回调地址
+def complant_notification_delete():
+    code, message = wxpay.complant_notification_delete()
+    print('code: %s, message: %s' % (code, message))
+
+# 提交投诉回复
+def complant_response():
+    code, message = wxpay.complant_response(
+        complaint_id='200201820200101080076610000',
+        response_content='已与用户沟通解决'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+# 反馈投诉处理完成
+def complant_complete():
+    code, message = wxpay.complant_complete(
+        complaint_id='200201820200101080076610000'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+# 商户上传投诉反馈图片
+def complant_image_upload():
+    code, message = wxpay.complant_image_upload(
+        filepath='./media/demo.png'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+# 下载客户投诉图片
+def complant_image_download():
+    code, message = wxpay.complant_image_download(
+        media_url='https://api.mch.weixin.qq.com/v3/merchant-service/images/xxxxx'
+    )
+    print('code: %s, message: %s' % (code, message))
+
 ```
 
 ## 回调验证失败处理

examples.py

@@ -107,6 +107,10 @@ def sign():
     print(wxpay.sign(['wx888', '1414561699', '5K8264ILTKCH16CQ2502S....', 'prepay_id=wx201410272009395522657....']))
 
 
+def decrypt():
+    print(wxpay.decrypt(ciphtext='Qe41VhP/sGdNeTHMQGlxCWiUyHu6XNO9GCYln2Luv4HhwJzZBfcL12sB+PgZcS5NhePBog30NgJ1xRaK+gbGDKwpg=='))
+
+
 def decrypt_callback(headers, body):
     print(wxpay.decrypt_callback(headers, body))
 
@@ -319,6 +323,80 @@ def profitsharing_bill():
     print('code: %s, message: %s' % (code, message))
 
 
+def complant_list_query():
+    code, message = wxpay.complant_list_query(
+        begin_date='2019-01-01'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_detail_query():
+    code, message = wxpay.complant_detail_query(
+        complaint_id='200201820200101080076610000'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_history_query():
+    code, message = wxpay.complant_history_query(
+        complaint_id='200201820200101080076610000'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_notification_create():
+    code, message = wxpay.complant_notification_create(
+        url='https://www.xxx.com/notify'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_notification_query():
+    code, message = wxpay.complant_notification_query()
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_notification_update():
+    code, message = wxpay.complant_notification_update(
+        url='https://www.xxx.com/notify'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_notification_delete():
+    code, message = wxpay.complant_notification_delete()
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_response():
+    code, message = wxpay.complant_response(
+        complaint_id='200201820200101080076610000',
+        response_content='已与用户沟通解决'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_complete():
+    code, message = wxpay.complant_complete(
+        complaint_id='200201820200101080076610000'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_image_upload():
+    code, message = wxpay.complant_image_upload(
+        filepath='./media/demo.png'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
+def complant_image_download():
+    code, message = wxpay.complant_image_download(
+        media_url='https://api.mch.weixin.qq.com/v3/merchant-service/images/xxxxx'
+    )
+    print('code: %s, message: %s' % (code, message))
+
+
 if __name__ == '__main__':
     pay()
     query()
@@ -332,6 +410,7 @@ def profitsharing_bill():
     combine_query()
     combine_close()
     sign()
+    decrypt()
     points_notify()
     user_authorization()
     guides_register()
@@ -354,4 +433,15 @@ def profitsharing_bill():
     profitsharing_add_receiver()
     profitsharing_delete_receiver()
     profitsharing_bill()
+    complant_list_query()
+    complant_detail_query()
+    complant_history_query()
+    complant_notification_create()
+    complant_notification_query()
+    complant_notification_update()
+    complant_notification_delete()
+    complant_response()
+    complant_complete()
+    complant_image_upload()
+    complant_image_download()
     pass

setup.py

@@ -6,7 +6,7 @@
 
 setup(
     name="wechatpayv3",
-    version="1.0.11",
+    version="1.0.12",
     author="minibear",
     description="微信支付接口V3版python库(python sdk for wechatpay v3)",
     long_description=long_description,
@@ -17,7 +17,7 @@
     packages=["wechatpayv3"],
     classifiers=[
         "Development Status :: 5 - Production/Stable",
-        "Topic :: Software Development :: Build Tools",
+        "Topic :: Office/Business :: Financial",
         "License :: OSI Approved :: BSD License",
         "Programming Language :: Python :: 3",
         "Programming Language :: Python :: 3.4",

wechatpayv3/__init__.py

@@ -49,13 +49,34 @@ def decrypt_callback(self, headers, body):
         """
         return self._core.decrypt_callback(headers, body)
 
+    def decrypt(self, ciphtext):
+        """解密微信支付平台返回的信息中的敏感字段
+        :param ciphtext: 加密后的敏感字段，示例值：'Qe41VhP/sGdNeTHMQGlxCWiUyHu6XNO9GCYln2Luv4HhwJzZBfcL12sB+PgZcS5NhePBog30NgJ1xRaK+gbGDKwpg=='
+        """
+        return self._core.decrypt(ciphtext)
+
+
     from .businesscircle import points_notify, user_authorization
+    from .complaint import (complant_complete, complant_detail_query,
+                            complant_history_query, complant_image_download,
+                            complant_image_upload, complant_list_query,
+                            complant_notification_create,
+                            complant_notification_delete,
+                            complant_notification_query,
+                            complant_notification_update, complant_response)
     from .marketing import marketing_image_upload
     from .media import image_upload, video_upload
-    from .parking import parking_enter, parking_order, parking_order_query, parking_service_find
-    from .profitsharing import (profitsharing_add_receiver, profitsharing_amount_query, profitsharing_bill,
-                                profitsharing_delete_receiver, profitsharing_order, profitsharing_order_query,
-                                profitsharing_return, profitsharing_return_query, profitsharing_unfreeze)
-    from .smartguide import guides_assign, guides_query, guides_register, guides_update
-    from .transaction import (close, combine_close, combine_pay, combine_query, download_bill,
-                              fundflow_bill, pay, query, query_refund, refund, trade_bill)
+    from .parking import (parking_enter, parking_order, parking_order_query,
+                          parking_service_find)
+    from .profitsharing import (profitsharing_add_receiver,
+                                profitsharing_amount_query, profitsharing_bill,
+                                profitsharing_delete_receiver,
+                                profitsharing_order, profitsharing_order_query,
+                                profitsharing_return,
+                                profitsharing_return_query,
+                                profitsharing_unfreeze)
+    from .smartguide import (guides_assign, guides_query, guides_register,
+                             guides_update)
+    from .transaction import (close, combine_close, combine_pay, combine_query,
+                              download_bill, fundflow_bill, pay, query,
+                              query_refund, refund, trade_bill)