推广接口

app/model/curriculum_order.py

@@ -62,3 +62,4 @@ class OrderFlow(Base, BaseModel):
     deletetag = Column(String(3), default="0", comment='删除标识')
     unionid = Column(String(64), comment='微信unionid')
     transaction_serial_no = Column(String(64), comment='交易流水号')
+    register_phone = Column(String(20), comment='授权手机号')

app/service/order_service.py

@@ -33,6 +33,8 @@ import requests
 
 course_price_api = "http://s-nginx/course/res/money/price"
 
+course_rollback_api = "http://s-nginx/course/fatools/pay/course/rollback"
+
 class TopUpOrderService:
     """"""
     def __init__(self):
@@ -268,7 +270,8 @@ class CurriculumOrderService:
                 }
                 amount = requests.post(course_price_api, 
                                     headers = headers,
-                                    json = data)
+                                    json = data,
+                                    timeout = 5)
                 try:
                     amount = amount.json()
                     '''
@@ -423,6 +426,23 @@ def consumeSucessAction(order_no, transaction_id):
             'complete_time': datetime.datetime.now()
         })
 
+        if curriculum_order.ab_type == '300':
+            data = {"resId": curriculum_order.ab_proid],
+                    "userId": curriculum_order.user_id,
+                    "phone": curriculum_order.register_phone}
+            headers = {
+                "Content-Type": "application/json",
+                "env": "ios"
+            }
+            try:
+                requests.post(course_rollback_api, 
+                                headers = headers,
+                                json = data,
+                                timeout = 5)
+            except:
+                print("用户提升级别接口失败")
+
+
 
 def getAccountBalance(user_id):
     """查询探普币余额"""