diff --git a/core/service.go b/core/service.go index b125ac4..f11e1e9 100644 --- a/core/service.go +++ b/core/service.go @@ -850,7 +850,7 @@ func (sh *serviceDescription) delacc(w http.ResponseWriter, r *http.Request) { return } - accids, err := sh.mongoClient.FindAll(CollectionAccount, bson.M{ + linkidMap, err := sh.mongoClient.FindAll(CollectionAccount, bson.M{ "accid": authInfo.Accid, }, options.Find().SetProjection(bson.M{ "_id": 1, @@ -861,12 +861,12 @@ func (sh *serviceDescription) delacc(w http.ResponseWriter, r *http.Request) { return } - var addIdFilter primitive.A - for _, accid := range accids { - addIdFilter = append(addIdFilter, accid["_id"].(primitive.ObjectID)) + var linkidAry primitive.A + for _, linkid := range linkidMap { + linkidAry = append(linkidAry, linkid["_id"].(primitive.ObjectID)) } - delfilter := primitive.M{"_id": bson.M{"$in": addIdFilter}} + delfilter := primitive.M{"_id": bson.M{"$in": linkidAry}} var delop primitive.M if !cancel { curtime := primitive.NewDateTimeFromTime(time.Now().UTC()) @@ -874,6 +874,7 @@ func (sh *serviceDescription) delacc(w http.ResponseWriter, r *http.Request) { "$set": primitive.M{"_ts": curtime}, } } else { + delfilter["platform"] = sType delop = primitive.M{ "$unset": primitive.M{"_ts": true}, } @@ -892,7 +893,7 @@ func (sh *serviceDescription) delacc(w http.ResponseWriter, r *http.Request) { return } - logger.Println("delacc success :", accids) + logger.Println("delacc success :", linkidMap) } func (sh *serviceDescription) serveHTTP(w http.ResponseWriter, r *http.Request) {