Merge branch 'dev2.0' of http://192.168.3.207:8080/data_processing/data_validation into dev2.0

* 'dev2.0' of http://192.168.3.207:8080/data_processing/data_validation:
  xg
  xg

src/front/project.go

@@ -188,19 +188,16 @@ func (f *Front) ProjectQualityAssessment() {
 	//质量评估
 	projectid := f.GetString("pid") //项目id
 	qu.Debug("Project Id：", projectid)
-	project, _ := util.Mgo.FindById(util.PROJECTCOLLNAME, projectid, map[string]interface{}{"b_isassessment": 1, "s_sourceinfo": 1})
+	project, _ := util.Mgo.FindById(util.PROJECTCOLLNAME, projectid, map[string]interface{}{"b_isassessment": 1, "s_sourceinfo": 1, "v_fields": 1})
 	if project != nil && len(*project) > 0 {
 		if isAssessment, ok := (*project)["b_isassessment"].(bool); ok && !isAssessment {
-			if fields, ok := (*project)["v_fields"].([]interface{}); ok && len(fields) > 0 {
+			if fields, ok := (*project)["v_fields"].(map[string]interface{}); ok && len(fields) > 0 {
 				var fieldsArr []string
-				for _, fieldsTmp := range fields {
-					fieldsMap := fieldsTmp.(map[string]interface{})
-					for f, _ := range fieldsMap {
-						fieldsArr = append(fieldsArr, f)
-					}
+				for f, _ := range fields {
+					fieldsArr = append(fieldsArr, f)
 				}
 				sourceinfo := qu.ObjToString((*project)["s_sourceinfo"])
-				success := QuaFieldScore(fieldsArr, sourceinfo) //调用数据质量评估接口
+				success = QuaFieldScore(fieldsArr, sourceinfo) //调用数据质量评估接口
 				if success {
 					//点击清洗更新项目状态为进行中
 					b := util.Mgo.UpdateById(util.PROJECTCOLLNAME, projectid, map[string]interface{}{"$set": map[string]interface{}{"b_isassessment": true, "s_status": "进行中", "i_starttime": time.Now().Unix()}})