1

src/udpfileserver/main.go

@@ -232,7 +232,7 @@ func save(mid interface{}, qmap, fileinfo map[string]interface{}) {
 		log.Println(mid, "rpc返回数据为空:", string(reply))
 		return
 	}
-	log.Println(mid, string(reply))
+	//log.Println(mid, string(reply))
 	rdata := make(map[string]interface{})
 	if err := json.Unmarshal(reply, &rdata); err != nil {
 		mongodbutil.Mgo.UpdateById(MgoC, mid, bson.M{
@@ -251,7 +251,6 @@ func save(mid interface{}, qmap, fileinfo map[string]interface{}) {
 		if !mongodbutil.Mgo.UpdateById(MgoC, mid, bson.M{
 			"$set": bson.M{
 				MgoFileFiled: qmap[MgoFileFiled],
-				"updatefileErr":0,
 			},
 		}) {
 			mongodbutil.Mgo.UpdateById(MgoC, mid, bson.M{
@@ -260,6 +259,10 @@ func save(mid interface{}, qmap, fileinfo map[string]interface{}) {
 				},})
 			log.Println(mid, "mongo更新数据失败")
 		} else {
+			mongodbutil.Mgo.UpdateById(MgoC, mid, bson.M{
+				"$set": bson.M{
+					"updatefileErr": 0,
+				},})
 			log.Println(mid, "mongo更新数据成功")
 		}
 	} else {