记录删除数据，并标记

src/service/repair_rule.go

@@ -76,10 +76,10 @@ func (jy *RepairRule) RepairDelete() {
 		//新增mongo记录
 		count := JYMgo.Count(JyRecord,bson.M{"_id": qu.StringTOBsonId(id)})
 		if count<=0 {
-			log.Println("删除-无记录-新增源数据")
+			log.Println("删除-无记录-新增源数据:",id)
 			(*souredata)["is_exist_type"] = "0"
 			(*souredata)["is_exist_coll"] = coll
-			JYMgo.Update(JyRecord, "", bson.M{"$set": souredata}, true, true)
+			JYMgo.SaveByOriID(JyRecord,souredata)
 		}else {
 			log.Println("删除-有记录-更新数据：",id)
 			set := bson.M{
@@ -135,10 +135,10 @@ func (jy *RepairRule) RepairSave() {
 			if count<=0 {
 				(*souredata)["is_exist_type"] = "1"
 				(*souredata)["is_exist_coll"] = coll
-				log.Println("更新，无数据，记录源数据")
-				JYMgo.Update(JyRecord, "", bson.M{"$set": souredata}, true, true)
+				log.Println("更新，无数据，记录源数据:",id)
+				JYMgo.SaveByOriID(JyRecord,souredata)
 			}else {
-				log.Println("更新，有数据，已记录")
+				log.Println("更新，有数据，已记录:",id)
 			}
 			jy.ServeJson(map[string]interface{}{
 				"rep": rep,