去掉cassandra

src/jfw/front/supsearch.go

@@ -540,7 +540,7 @@ func SaveUserSearchLog(request *http.Request, userid string, count int64, platfo
 		}
 		data["id"] = uc.DayShortTime()
 		data["tuid"] = gocql.TimeUUID()
-		if !public.Ca_Log.SaveCache("jy_search", data) {
+		if public.MQLOG.Save("jy_search", data) == "" {
 			data := map[string]interface{}{
 				"ip":         filter.GetIp(request),
 				"count":      count,

src/jfw/modules/app/src/app/front/swordfish.go

@@ -1010,7 +1010,7 @@ func SaveUserSearchLog(request *http.Request, userId string, count int64, platfo
 		}
 		data["id"] = uc.DayShortTime()
 		data["tuid"] = gocql.TimeUUID()
-		if !public.Ca_Log.SaveCache("jy_search", data) {
+		if public.MQLOG.Save("jy_search", data) == "" {
 			data := map[string]interface{}{
 				"ip":         filter.GetIp(request),
 				"count":      count,

src/jfw/modules/entsesearch/src/search/entsesearch.go

@@ -11,7 +11,6 @@ import (
 	"strings"
 	"time"
 	uc "ucbsutil"
-	ca "ucbsutil/cassandra"
 
 	"github.com/go-xweb/xweb"
 	"github.com/gocql/gocql"
@@ -163,7 +162,7 @@ func SaveUserSearchLog(request *http.Request, userid string, count int64, platfo
 		}
 		data["id"] = uc.DayShortTime()
 		data["tuid"] = gocql.TimeUUID()
-		if !ca.SaveCache("jy_search", data) {
+		if public.MQLOG.Save("jy_search", data) == "" {
 			data := map[string]interface{}{
 				"ip":         GetIp(request),
 				"count":      count,

src/jfw/public/db.go

@@ -8,40 +8,41 @@ import (
 	"qfw/util/jy"
 	"qfw/util/mysql"
 	"qfw/util/redis"
-	ca "ucbsutil/cassandra"
+	// ca "ucbsutil/cassandra"
 )
 
 var MQFW mg.MongodbSim
 var MQFWENT mg.MongodbSim
 var Mysql *mysql.Mysql
 var PushMysql *mysql.Mysql
-var Ca_Log = &ca.Cassandra{}
-var Ca_Push = &ca.Cassandra{}
+
+// var Ca_Log = &ca.Cassandra{}
+// var Ca_Push = &ca.Cassandra{}
 var MQLOG mg.MongodbSim
 
 func init() {
 	//初始化cassandra
-	cass, _ := Sysconfig["cassandra"].(map[string]interface{})
-	if cass != nil {
-		ca_log := cass["log"].(map[string]interface{})
-		Ca_Log.ViewCacheLen = true
-		Ca_Log.InitCassandra("jianyu",
-			util.IntAll(ca_log["size"]),
-			util.ObjArrToStringArr(ca_log["host"].([]interface{})),
-			map[string]int{
-				"port": util.IntAll(ca_log["port"]),
-			},
-		)
-		ca_push := cass["push"].(map[string]interface{})
-		Ca_Push.ViewCacheLen = true
-		Ca_Push.InitCassandra("jianyu",
-			util.IntAll(ca_push["size"]),
-			util.ObjArrToStringArr(ca_push["host"].([]interface{})),
-			map[string]int{
-				"port": util.IntAll(ca_push["port"]),
-			},
-		)
-	}
+	// cass, _ := Sysconfig["cassandra"].(map[string]interface{})
+	// if cass != nil {
+	// 	ca_log := cass["log"].(map[string]interface{})
+	// 	Ca_Log.ViewCacheLen = true
+	// 	Ca_Log.InitCassandra("jianyu",
+	// 		util.IntAll(ca_log["size"]),
+	// 		util.ObjArrToStringArr(ca_log["host"].([]interface{})),
+	// 		map[string]int{
+	// 			"port": util.IntAll(ca_log["port"]),
+	// 		},
+	// 	)
+	// 	ca_push := cass["push"].(map[string]interface{})
+	// 	Ca_Push.ViewCacheLen = true
+	// 	Ca_Push.InitCassandra("jianyu",
+	// 		util.IntAll(ca_push["size"]),
+	// 		util.ObjArrToStringArr(ca_push["host"].([]interface{})),
+	// 		map[string]int{
+	// 			"port": util.IntAll(ca_push["port"]),
+	// 		},
+	// 	)
+	// }
 	//初始化redis
 	redisConfig, _ := Sysconfig["redisaddrs"].(string)
 	if redisConfig != "" {