renzheng 7 anni fa
parent
commit
0a059bcae3

+ 35 - 4
jyservice/src/usermanager/access_token.go

@@ -2,6 +2,7 @@ package usermanager
 
 import (
 	"fmt"
+	"log"
 	"net/http"
 	"net/url"
 	"qfw/util"
@@ -23,14 +24,39 @@ const (
 //用户的accesstoken维护,每个用户分配一个 应用id=appid,用户密钥=key
 func GetAccessToken(w http.ResponseWriter, r *http.Request) {
 	defer util.Catch()
+	err := r.ParseForm()
+	if err != nil {
+		log.Println("parse1", err.Error())
+	}
+	err = r.ParseMultipartForm(20480)
+	if err != nil {
+		log.Println("parse2", err.Error())
+	}
 	d := JSON{}
 	appid := r.FormValue("appid")
 	key := r.FormValue("key")
+	if appid == "" {
+		appid = r.PostFormValue("appid")
+	}
+	if key == "" {
+		key = r.PostFormValue("key")
+	}
 	if appid != "" && key != "" {
-		res, b := Mgo.FindOneByField("user", &map[string]interface{}{
-			"appid": appid,
-			"key":   key,
-		}, `{"plan":1}`)
+		var res *map[string]interface{}
+		b := false
+		nt := 0
+		for nt < 4 {
+			res, b = Mgo.FindOneByField("user", &map[string]interface{}{
+				"appid": appid,
+				"key":   key,
+			}, `{"plan":1}`)
+			if b && res != nil && *res != nil {
+				break
+			} else {
+				nt++
+				time.Sleep(1 * time.Second)
+			}
+		}
 		if b && res != nil && *res != nil {
 			GetDataMapLock.Lock()
 			appidLock := GetDataMap[appid]
@@ -73,7 +99,12 @@ func GetAccessToken(w http.ResponseWriter, r *http.Request) {
 				d["code"] = CODE_E3
 				d["msg"] = MSG_E3
 			}
+		} else {
+			log.Println("查询用户信息为空", appid, key)
 		}
+
+	} else {
+		log.Println("参数获取为空", appid, key)
 	}
 	if len(d) == 0 {
 		d["code"] = CODE_E2

+ 1 - 0
jyservice/src/usermanager/usermanager.go

@@ -77,6 +77,7 @@ var lock sync.Mutex
 
 func addLog(req *http.Request) {
 	req.ParseForm()
+	req.ParseMultipartForm(10240)
 	m := url.Values{}
 	for k, v := range req.Form {
 		m[k] = v