改回mongo日志

jyservice/src/usermanager/usermanager.go

@@ -8,8 +8,8 @@ import (
 	"strings"
 	"sync"
 	"time"
-	uc "ucbsutil"
-	ca "ucbsutil/cassandra"
+	//uc "ucbsutil"
+	//ca "ucbsutil/cassandra"
 	. "utils"
 
 	"github.com/gorilla/mux"
@@ -56,15 +56,15 @@ func Middleware(next http.Handler) http.Handler {
 //定时保存日志
 func SaveLogTask() {
 	lock.Lock()
-	/*if len(arr) >= 1 {
+	if len(arr) >= 1 {
 		tmp := arr
 		arr = make([]map[string]interface{}, 0)
 		go func() {
 			log.Debug("timer..save..visit..log", len(tmp))
 			Mgo.SaveBulk("logs", tmp...)
 		}()
-	}*/
-	if len(arr) >= 1 {
+	}
+	/*if len(arr) >= 1 {
 		tmp := arr
 		arr = make([]map[string]interface{}, 0)
 		go func() {
@@ -73,7 +73,7 @@ func SaveLogTask() {
 				log.Println("timer..save..log", len(tmp))
 			}
 		}()
-	}
+	}*/
 	lock.Unlock()
 	time.AfterFunc(2*time.Minute, SaveLogTask)
 }
@@ -104,9 +104,9 @@ func addLog(req *http.Request) {
 	md, _ := json.Marshal(m)
 	str := string(md)
 	logs := map[string]interface{}{
-		"id":        uc.DayShortTime(),
+		//"id":        uc.DayShortTime(),
 		"date":      timeNow,
-		"ip":        req.Proto,
+		"ip":        GetIp(req),
 		"refer":     ref,
 		"year":      timeNow.Year(),
 		"month":     timeNow.Month(),
@@ -121,20 +121,21 @@ func addLog(req *http.Request) {
 	lock.Lock()
 	arr = append(arr, logs)
 	if len(arr) >= nc || s_url == "/sl" {
-		/*tmp := arr
+		tmp := arr
 		arr = make([]map[string]interface{}, 0)
 		go func() {
 			log.Println("save..visit..log", len(tmp))
 			Mgo.SaveBulk("logs", tmp...)
-		}()*/
-		tmp := arr
-		arr = make([]map[string]interface{}, 0)
-		go func() {
-			success := ca.SaveBatch("jy_qyfw", tmp)
-			if success {
-				log.Println("save..visit..log", len(tmp))
-			}
 		}()
+		/*
+			tmp := arr
+			arr = make([]map[string]interface{}, 0)
+			go func() {
+				success := ca.SaveBatch("jy_qyfw", tmp)
+				if success {
+					log.Println("save..visit..log", len(tmp))
+				}
+			}()*/
 	}
 	lock.Unlock()
 }