/
mongo.go
68 lines (59 loc) · 2.06 KB
/
mongo.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
package ProfileBackend
import (
"context"
pkb "github.com/FarhanRizkiM/pasetobackend"
"github.com/aiteung/atdb"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/mongo"
)
func InsertDataParkiran(MongoConn *mongo.Database, colname string, emp Parkiran) (InsertedID interface{}) {
req := new(Parkiran)
req.ParkiranId = emp.ParkiranId
req.Nama = emp.Nama
req.NPM = emp.NPM
req.Jurusan = emp.Jurusan
req.NamaKendaraan = emp.NamaKendaraan
req.NomorKendaraan = emp.NomorKendaraan
req.JenisKendaraan = emp.JenisKendaraan
req.Akun = emp.Akun
return pkb.InsertOneDoc(MongoConn, colname, req)
}
func GetAllParkiranData(Mongoconn *mongo.Database, colname string) []Parkiran {
data := atdb.GetAllDoc[[]Parkiran](Mongoconn, colname)
return data
}
func DeleteUser(Mongoconn *mongo.Database, colname, username string) (deleted interface{}, err error) {
filter := bson.M{"username": username}
data := atdb.DeleteOneDoc(Mongoconn, colname, filter)
return data, err
}
func UpdateParkiran(Mongoconn *mongo.Database, ctx context.Context, emp Parkiran) (UpdateId interface{}, err error) {
filter := bson.D{{"parkiranid", emp.ParkiranId}}
res, err := Mongoconn.Collection("parkiran").ReplaceOne(ctx, filter, emp)
if err != nil {
return nil, err
}
return res, nil
}
func UpdatePassword(mongoconn *mongo.Database, user pkb.User) (Updatedid interface{}) {
filter := bson.D{{"username", user.Username}}
pass, _ := pkb.HashPass(user.Password)
update := bson.D{{"$Set", bson.D{
{"password", pass},
}}}
res, err := mongoconn.Collection("user").UpdateOne(context.Background(), filter, update)
if err != nil {
return "gagal update data"
}
return res
}
func DeleteParkiranData(mongoconn *mongo.Database, colname, PakId string) (deletedid interface{}, err error) {
filter := bson.M{"parkiranid": PakId}
data := atdb.DeleteOneDoc(mongoconn, colname, filter)
return data, err
}
func GetOneParkiranData(mongoconn *mongo.Database, colname, Pakid string) (dest Parkiran) {
filter := bson.M{"parkiranid": Pakid}
dest = atdb.GetOneDoc[Parkiran](mongoconn, colname, filter)
return
}