|
@@ -191,16 +191,13 @@ func (f *Front) ProjectQualityAssessment() {
|
|
|
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()}})
|