修改测试

common/src/qfw/util/mongodb/mongodbutil_test.go

@@ -204,7 +204,6 @@ func Test_Credit(t *testing.T) {
 	log.Println(ObjToArr(`{"_id":-1,"name":1}`), []string{"-_id", "name"})
 
 }
-
 func Test_name(t *testing.T) {
 	InitMongodbPool(1, "192.168.3.18:27080", "spider")
 	sess := GetMgoConn()
@@ -218,3 +217,61 @@ func Test_name(t *testing.T) {
 		tmp = make(map[string]interface{})
 	}
 }
+
+func Test_CMD(t *testing.T) {
+	InitMongodbPool(1, "192.168.3.18:27080", "qfw")
+	sess := GetMgoConn()
+	defer DestoryMongoConn(sess)
+	result := make(map[string]interface{})
+	sess.DB("qfw").Run(D{{"eval",
+	 `function (){ var db2=connect("spider");var d=db2.entinv.findOne(); return d; }`}}, &result)
+	log.Println(result)
+
+}
+
+
+func Test_Rule(t *testing.T) {
+	InitMongodbPool(1, "192.168.3.18:27080", "qfw")
+	m:=map[string]interface{}{
+		"s_name":"变更公告",
+		"s_rule":[]string{
+			"(中标公告|成交公告|成交公示|中标公示|中标结果|结果公告|结果公示)3",
+			"(废标公示|采购废标|流标公告|流标公示|招标失败公告|质疑答复|质疑回复|招标结果|评标结果)4",
+		},
+		"i_order":1,
+		"l_date":time.Now().Unix(),
+		"s_user":"rr",
+		"i_status":1,
+		"l_lasttime":time.Now().Unix(),
+	}
+	Save("rc_rule",&m)
+}
+
+func Test_task(t *testing.T) {
+	InitMongodbPool(1, "192.168.3.18:27080", "qfw")
+	m:=map[string]interface{}{
+		"s_name":"变更公告",
+		"a_class":[]int{0,1},
+		"i_rate":5,
+		"l_date":time.Now().Unix(),
+		"s_user":"rr",
+		"i_status":1,
+		"l_lasttime":time.Now().Unix(),
+	}
+	Save("rc_task",&m)
+}
+
+func Test_class(t *testing.T) {
+	InitMongodbPool(1, "192.168.3.18:27080", "qfw")
+	m:=map[string]interface{}{
+		"s_name":"招标一级分类识别",
+		"a_rule":[]int{0,1},
+		"s_fields":"title,content",
+		"s_savefield":"cc",
+		"l_date":time.Now().Unix(),
+		"s_user":"rr",
+		"i_status":1,
+		"l_lasttime":time.Now().Unix(),
+	}
+	Save("rc_class",&m)
+}