81 lines
2.8 KiB
Go
81 lines
2.8 KiB
Go
package public
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
|
|
//"github.com/Gleipnir-Technology/bob"
|
|
"github.com/Gleipnir-Technology/nidus-sync/db"
|
|
//"github.com/Gleipnir-Technology/nidus-sync/db/gen/nidus-sync/public/enum"
|
|
"github.com/Gleipnir-Technology/jet/postgres"
|
|
"github.com/Gleipnir-Technology/nidus-sync/db/gen/nidus-sync/public/model"
|
|
"github.com/Gleipnir-Technology/nidus-sync/db/gen/nidus-sync/public/table"
|
|
)
|
|
|
|
func AddressFromComplianceReportRequestID(ctx context.Context, txn db.Ex, public_id string) (model.Address, error) {
|
|
statement := table.Address.SELECT(
|
|
table.Address.AllColumns,
|
|
).FROM(
|
|
table.Address,
|
|
table.Site.INNER_JOIN(
|
|
table.Site,
|
|
table.Site.AddressID.EQ(table.Address.ID)),
|
|
table.Site.INNER_JOIN(
|
|
table.Lead,
|
|
table.Lead.SiteID.EQ(table.Site.ID)),
|
|
table.Lead.INNER_JOIN(
|
|
table.ComplianceReportRequest,
|
|
table.ComplianceReportRequest.LeadID.EQ(table.Lead.ID))).
|
|
WHERE(table.ComplianceReportRequest.PublicID.EQ(postgres.String(public_id)))
|
|
return db.ExecuteOne[model.Address](ctx, statement)
|
|
}
|
|
func AddressFromGID(ctx context.Context, txn db.Ex, gid string) (*model.Address, error) {
|
|
statement := table.Address.SELECT(
|
|
table.Address.AllColumns,
|
|
).FROM(table.Address).
|
|
WHERE(table.Address.Gid.EQ(postgres.String(gid)))
|
|
result, err := db.ExecuteOneTx[model.Address](ctx, txn, statement)
|
|
if err != nil {
|
|
if errors.Is(err, db.ErrNoRows) {
|
|
return nil, nil
|
|
}
|
|
return nil, fmt.Errorf("execute one: %w", err)
|
|
}
|
|
return &result, nil
|
|
}
|
|
func AddressFromID(ctx context.Context, txn db.Ex, comm_id int64) (model.Address, error) {
|
|
statement := table.Address.SELECT(
|
|
table.Address.AllColumns,
|
|
).FROM(table.Address).
|
|
WHERE(table.Address.ID.EQ(postgres.Int(comm_id)))
|
|
return db.ExecuteOne[model.Address](ctx, statement)
|
|
}
|
|
func AddressesFromIDs(ctx context.Context, txn db.Ex, address_ids []int64) ([]model.Address, error) {
|
|
if len(address_ids) == 0 {
|
|
return []model.Address{}, nil
|
|
}
|
|
sql_ids := make([]postgres.Expression, len(address_ids))
|
|
for i, address_id := range address_ids {
|
|
sql_ids[i] = postgres.Int(address_id)
|
|
}
|
|
statement := table.Address.SELECT(
|
|
table.Address.AllColumns,
|
|
).FROM(table.Address).
|
|
WHERE(table.Address.ID.IN(sql_ids...))
|
|
return db.ExecuteManyTx[model.Address](ctx, txn, statement)
|
|
}
|
|
func AddressInsert(ctx context.Context, txn db.Ex, a model.Address) (model.Address, error) {
|
|
statement := table.Address.
|
|
INSERT(table.Address.MutableColumns).
|
|
MODEL(a).
|
|
RETURNING(table.Address.AllColumns)
|
|
return db.ExecuteOneTx[model.Address](ctx, txn, statement)
|
|
}
|
|
func AddressInserts(ctx context.Context, txn db.Ex, addresses []model.Address) ([]model.Address, error) {
|
|
statement := table.Address.
|
|
INSERT(table.Address.MutableColumns).
|
|
MODELS(addresses).
|
|
RETURNING(table.Address.AllColumns)
|
|
return db.ExecuteManyTx[model.Address](ctx, txn, statement)
|
|
}
|