|
@@ -1023,22 +1023,20 @@ func (f *Front) GroupImportData() {
|
|
|
|
|
|
func (f *Front) StatsTasData() {
|
|
func (f *Front) StatsTasData() {
|
|
tid := f.GetString("tid")
|
|
tid := f.GetString("tid")
|
|
- sourceinfo := f.GetString("s_sourceinfo")
|
|
|
|
if f.Method() == "POST" {
|
|
if f.Method() == "POST" {
|
|
stype := f.GetString("stype")
|
|
stype := f.GetString("stype")
|
|
sctype := f.GetString("sctype")
|
|
sctype := f.GetString("sctype")
|
|
- n1, n2, n3 := countFuc(stype, sourceinfo, tid, sctype)
|
|
|
|
|
|
+ n1, n2, n3 := countFuc(stype, tid, sctype)
|
|
f.ServeJson(map[string]interface{}{"success": true, "data": bson.M{"num": n1, "pCount": n2, "cCount": n3}})
|
|
f.ServeJson(map[string]interface{}{"success": true, "data": bson.M{"num": n1, "pCount": n2, "cCount": n3}})
|
|
} else {
|
|
} else {
|
|
f.T["taskid"] = tid
|
|
f.T["taskid"] = tid
|
|
- f.T["s_sourceinfo"] = sourceinfo
|
|
|
|
if f.GetString("stype") == "user" {
|
|
if f.GetString("stype") == "user" {
|
|
f.T["user"] = "user"
|
|
f.T["user"] = "user"
|
|
- isTagNum := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_usertaskid": tid, "b_istag": true}) //已标注数量
|
|
|
|
- allNum := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_usertaskid": tid}) //数据总量
|
|
|
|
- effNum1 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_usertaskid": tid, "v_baseinfo.is_efficient": "是"}) // 有效数据 是
|
|
|
|
- effNum2 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_usertaskid": tid, "v_baseinfo.is_efficient": "否"}) // 有效数据 否
|
|
|
|
- effNum3 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_usertaskid": tid, "v_baseinfo.is_efficient": nil}) // 有效数据 空
|
|
|
|
|
|
+ isTagNum := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_usertaskid": tid, "b_istag": true}) //已标注数量
|
|
|
|
+ allNum := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_usertaskid": tid}) //数据总量
|
|
|
|
+ effNum1 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_usertaskid": tid, "v_baseinfo.is_efficient": "是"}) // 有效数据 是
|
|
|
|
+ effNum2 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_usertaskid": tid, "v_baseinfo.is_efficient": "否"}) // 有效数据 否
|
|
|
|
+ effNum3 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_usertaskid": tid, "v_baseinfo.is_efficient": nil}) // 有效数据 空
|
|
qu.Debug("数据总量:", allNum, "已标注量:", isTagNum)
|
|
qu.Debug("数据总量:", allNum, "已标注量:", isTagNum)
|
|
f.T["allNum"] = allNum
|
|
f.T["allNum"] = allNum
|
|
f.T["isTagNum"] = isTagNum
|
|
f.T["isTagNum"] = isTagNum
|
|
@@ -1048,11 +1046,11 @@ func (f *Front) StatsTasData() {
|
|
} else if f.GetString("stype") == "group" {
|
|
} else if f.GetString("stype") == "group" {
|
|
f.T["group"] = "group"
|
|
f.T["group"] = "group"
|
|
//统计数据量
|
|
//统计数据量
|
|
- isTagNum := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "b_istag": true}) //已标注数量
|
|
|
|
- allNum := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid}) //数据总量``
|
|
|
|
- effNum1 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": "是"}) // 有效数据 是
|
|
|
|
- effNum2 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": "否"}) // 有效数据 否
|
|
|
|
- effNum3 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": nil}) // 有效数据 空
|
|
|
|
|
|
+ isTagNum := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid, "b_istag": true}) //已标注数量
|
|
|
|
+ allNum := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid}) //数据总量``
|
|
|
|
+ effNum1 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": "是"}) // 有效数据 是
|
|
|
|
+ effNum2 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": "否"}) // 有效数据 否
|
|
|
|
+ effNum3 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": nil}) // 有效数据 空
|
|
qu.Debug("数据总量:", allNum, "已标注量:", isTagNum)
|
|
qu.Debug("数据总量:", allNum, "已标注量:", isTagNum)
|
|
f.T["allNum"] = allNum
|
|
f.T["allNum"] = allNum
|
|
f.T["isTagNum"] = isTagNum
|
|
f.T["isTagNum"] = isTagNum
|
|
@@ -1062,11 +1060,11 @@ func (f *Front) StatsTasData() {
|
|
} else {
|
|
} else {
|
|
f.T["project"] = "project"
|
|
f.T["project"] = "project"
|
|
//统计数据量
|
|
//统计数据量
|
|
- isTagNum := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "b_istag": true}) //已标注数量
|
|
|
|
- allNum := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid}) //数据总量
|
|
|
|
- effNum1 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": "是"}) // 有效数据 是
|
|
|
|
- effNum2 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": "否"}) // 有效数据 否
|
|
|
|
- effNum3 := util.Mgo.Count(sourceinfo, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": nil}) // 有效数据 空
|
|
|
|
|
|
+ isTagNum := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid, "b_istag": true}) //已标注数量
|
|
|
|
+ allNum := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid}) //数据总量
|
|
|
|
+ effNum1 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": "是"}) // 有效数据 是
|
|
|
|
+ effNum2 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": "否"}) // 有效数据 否
|
|
|
|
+ effNum3 := util.Mgo.Count(util.DATACOLLNAME, map[string]interface{}{"s_grouptaskid": tid, "v_baseinfo.is_efficient": nil}) // 有效数据 空
|
|
qu.Debug("数据总量:", allNum, "已标注量:", isTagNum)
|
|
qu.Debug("数据总量:", allNum, "已标注量:", isTagNum)
|
|
f.T["allNum"] = allNum
|
|
f.T["allNum"] = allNum
|
|
f.T["isTagNum"] = isTagNum
|
|
f.T["isTagNum"] = isTagNum
|
|
@@ -1078,7 +1076,7 @@ func (f *Front) StatsTasData() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
-func countFuc(stype, coll, tid, sctype string) (int, int, int) {
|
|
|
|
|
|
+func countFuc(stype, tid, sctype string) (int, int, int) {
|
|
field := "" //
|
|
field := "" //
|
|
q := make(map[string]interface{})
|
|
q := make(map[string]interface{})
|
|
f := make(map[string]interface{})
|
|
f := make(map[string]interface{})
|
|
@@ -1104,7 +1102,7 @@ func countFuc(stype, coll, tid, sctype string) (int, int, int) {
|
|
defer util.Mgo.DestoryMongoConn(sess)
|
|
defer util.Mgo.DestoryMongoConn(sess)
|
|
|
|
|
|
qu.Debug(q)
|
|
qu.Debug(q)
|
|
- query := sess.DB(util.Mgo.DbName).C(coll).Find(q).Select(f).Iter()
|
|
|
|
|
|
+ query := sess.DB(util.Mgo.DbName).C(util.DATACOLLNAME).Find(q).Select(f).Iter()
|
|
count := 0
|
|
count := 0
|
|
size, pCount, cCount := 0, 0, 0 //标讯数量, 标的物/多包/意向 累加数量,有效数量
|
|
size, pCount, cCount := 0, 0, 0 //标讯数量, 标的物/多包/意向 累加数量,有效数量
|
|
for tmp := make(map[string]interface{}); query.Next(tmp); count++ {
|
|
for tmp := make(map[string]interface{}); query.Next(tmp); count++ {
|