mgolog

db/db.go

@@ -15,7 +15,7 @@ import (
 )
 
 var (
-	Mgo_Log      *mongodb.MongodbSim
+	MgoLog       *mongodb.MongodbSim
 	Mgo          *mongodb.MongodbSim
 	Mysql        *mysql.Mysql
 	Tidb         *mysql.Mysql
@@ -50,7 +50,7 @@ func init() {
 
 	var mgologConf MgoConf
 	if err := gcfg.Instance().MustGet(gctx.New(), "databases.mogLog").Scan(&mgologConf); err == nil {
-		Mgo_Log = &mongodb.MongodbSim{
+		MgoLog = &mongodb.MongodbSim{
 			MongodbAddr: mgologConf.Address,
 			Size:        mgologConf.Size,
 			DbName:      mgologConf.DbName,
@@ -58,7 +58,7 @@ func init() {
 			UserName:    mgologConf.UserName,
 			Password:    mgologConf.Password,
 		}
-		Mgo_Log.InitPool()
+		MgoLog.InitPool()
 		log.Printf("初始化 mongodb log 完成 %+v\n", mgologConf)
 	}
 	var mgoConf MgoConf

main.go

@@ -48,7 +48,7 @@ func main() {
 	go task.SelectOrderTask()
 
 	c := config.NsqLogConfig
-	util.NsqLog = util.NewSaveLog(c.Name, c.CollName, c.MgoSaveCacheSize, c.SPSize, c.BulkSize, c.TimeAfter, c.Timeout, *db.Mgo_Log)
+	util.NsqLog = util.NewSaveLog(c.Name, c.CollName, c.MgoSaveCacheSize, c.SPSize, c.BulkSize, c.TimeAfter, c.Timeout, *db.MgoLog)
 	go util.NsqLog.SaveMgo()
 	mux1 := http.NewServeMux()
 	xweb.RunBase(gcfg.Instance().MustGet(gctx.New(), "webport", "").String(), mux1)

services/filter/logfilter.go

@@ -1,9 +1,11 @@
-/**
+/*
+*
 日志过滤器
 记录网站所有访问和请求
 2015-7-2
 任政
-**/
+*
+*/
 package filter
 
 import (
@@ -18,19 +20,19 @@ import (
 	"app.yhyue.com/moapp/jybase/go-xweb/httpsession"
 )
 
-//日志过滤器
+// 日志过滤器
 type logfilter struct {
 	App *xweb.App
 }
 
-//继承过滤器方法
+// 继承过滤器方法
 func (l *logfilter) Do(w http.ResponseWriter, req *http.Request) bool {
 	session := l.App.SessionManager.Session(req, w)
 	go addLog(l, session, req)
 	return true
 }
 
-//用线程处理，增加日志
+// 用线程处理，增加日志
 func addLog(l *logfilter, session *httpsession.Session, req *http.Request) {
 	timeNow := time.Now()
 	md, _ := json.Marshal(req.Form)
@@ -52,10 +54,10 @@ func addLog(l *logfilter, session *httpsession.Session, req *http.Request) {
 		logs["userid"] = session.Get("userId")
 		logs["nickname"] = session.Get("s_nickname")
 	}
-	db.Mgo_Log.Save("jymessage_logs", logs)
+	db.MgoLog.Save("jymessage_logs", logs)
 }
 
-//获取请求ip
+// 获取请求ip
 func GetIp(req *http.Request) string {
 	if req == nil {
 		return ""