222

.idea/.gitignore

 
 # Default ignored files
-/workspace.xml
\ No newline at end of file
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
\ No newline at end of file

app/api/engine.py

@@ -43,11 +43,11 @@ tamp_pay_engine = create_engine(
         charset="utf8")
 )
 
-# redis = redis.StrictRedis(
-#     host=config[env]['redis']['host'],
-#     port=config[env]['redis']['port'],
-#     db=config[env]['redis']['db']
-# )
+redis = redis.StrictRedis(
+    host=config[env]['redis']['host'],
+    port=config[env]['redis']['port'],
+    db=config[env]['redis']['db']
+)
 
 logging.basicConfig(level=logging.INFO,
                     filename=work_dir + config[env]['log']['filename'],

app/config/config.yaml

@@ -7,7 +7,7 @@ dev:
     user: root
     password: mysql
   redis:
-    host: localhost
+    host: redis
     port: 6379
     db: 0
   log:

app/controller/errorhandler.py

@@ -11,7 +11,7 @@ import time
 import requests
 from flask import jsonify, make_response, request
 
-from app.api.engine import config, env
+from app.api.engine import config, env, redis
 from app.config.errors import Errors
 from app.api.engine import logging
 
@@ -70,14 +70,17 @@ def add_errorhandler(app):
             pass
         else:
             try:
-                requests.adapters.DEFAULT_RETRIES = 5  # 增加重连次数
-                s = requests.session()
-                s.keep_alive = False
-                res = s.get(url+'?tampToken='+token, timeout=2)
-                resp = res.json()
-                if resp['statusCode'] != "0000":
+                # requests.adapters.DEFAULT_RETRIES = 5  # 增加重连次数
+                # s = requests.session()
+                # s.keep_alive = False
+                # res = s.get(url+'?tampToken='+token, timeout=2)
+                # resp = res.json()
+                # if resp['statusCode'] != "0000":
+                # request.user_id = resp['attributes']
+                user_id = redis.get('s:sid:['+token+']')
+                if not user_id:
                     raise CustomFlaskErr(Errors.TOKEN_INVALID)
-                request.user_id = resp['attributes']
+                request.user_id = user_id
             except:
                 logging.error('token鉴权失败', token)
         request.return_success = {'statusCode': "0000", 'message': 'ok'}