xg

src/front/mark.go

@@ -12,6 +12,7 @@ import (
 
 // DataMark 数据标注
 func (f *Front) DataMark() {
+	qu.Debug("-----------------")
 	defer qu.Catch()
 	success := false
 	msg := ""
@@ -20,9 +21,11 @@ func (f *Front) DataMark() {
 	obj := []map[string]interface{}{}
 	infoId := f.GetString("s_infoid")
 	userTaskId := f.GetString("s_usertaskid")
+	qu.Debug(userTaskId)
 	data := f.GetString("data")
 	err := json.Unmarshal([]byte(data), &obj)
 	if err != nil {
+		qu.Debug("Json Unmarshal Error")
 		f.ServeJson(map[string]interface{}{"success": success, "msg": "解析数据失败"})
 		return
 	}
@@ -85,12 +88,14 @@ func (f *Front) DataMark() {
 		allTagFields[k] = nil
 	}
 	qu.Debug("allTagFields===", allTagFields)
+	qu.Debug("0000000")
 	userTask, _ := util.Mgo.FindById(util.TASKCOLLNAME, userTaskId, map[string]interface{}{"s_personid": 1, "s_personname": 1, "s_projectname": 1, "s_sourceinfo": 1})
 	if userTask == nil || len(*userTask) == 0 {
 		f.ServeJson(map[string]interface{}{"success": success, "msg": "查询用户任务失败"})
 		return
 	}
-	sourceInfo := qu.ObjToString((*userTask)["s_sourceinfo"])                                                     //数据源表
+	sourceInfo := qu.ObjToString((*userTask)["s_sourceinfo"]) //数据源表
+	qu.Debug("11111111111")
 	dataInfo, _ := util.Mgo.FindById(sourceInfo, infoId, map[string]interface{}{"v_baseinfo": 1, "v_taginfo": 1}) //查询标注保存前的原始信息
 	tagInfo, _ := (*dataInfo)["v_taginfo"].(map[string]interface{})
 	baseInfo, _ := (*dataInfo)["v_baseinfo"].(map[string]interface{})
@@ -108,6 +113,7 @@ func (f *Front) DataMark() {
 			}
 		}
 	}
+	qu.Debug("2222222222222")
 	if len(tagSet) > 0 {
 		//1、更新数据源信息
 		setResult := map[string]interface{}{ //更新字段集
@@ -132,11 +138,15 @@ func (f *Front) DataMark() {
 			set["$unset"] = baseUnsetResult
 		}
 		qu.Debug("set---", set)
+		qu.Debug("3333333")
 		success = util.Mgo.UpdateById(sourceInfo, infoId, set)
+		qu.Debug("444444")
 		//2、更新marked表
 		tmp, _ := util.Mgo.FindById(sourceInfo, infoId, map[string]interface{}{"v_baseinfo": 1, "v_taginfo": 1, "i_ckdata": 1})
+
 		delete((*tmp), "_id")
 		(*tmp)["updatetime"] = time.Now().Unix()
+		qu.Debug("5555555555555")
 		b := util.Mgo.Update(util.AllToColl, map[string]interface{}{"_id": mongodb.StringTOBsonId(infoId)}, map[string]interface{}{"$set": tmp}, true, false)
 		qu.Debug("Update Marked：", b)
 	}