This commit is contained in:
parent
b42b1144b6
commit
9d2895bd94
1 changed files with 0 additions and 44 deletions
|
|
@ -3,12 +3,7 @@ package platform
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
"github.com/Gleipnir-Technology/bob"
|
|
||||||
"github.com/Gleipnir-Technology/bob/dialect/psql"
|
|
||||||
"github.com/Gleipnir-Technology/bob/dialect/psql/dialect"
|
|
||||||
"github.com/Gleipnir-Technology/bob/dialect/psql/sm"
|
|
||||||
"source.gleipnir.technology/Gleipnir/nidus-sync/db"
|
"source.gleipnir.technology/Gleipnir/nidus-sync/db"
|
||||||
"source.gleipnir.technology/Gleipnir/nidus-sync/db/models"
|
|
||||||
querypublic "source.gleipnir.technology/Gleipnir/nidus-sync/db/query/public"
|
querypublic "source.gleipnir.technology/Gleipnir/nidus-sync/db/query/public"
|
||||||
"source.gleipnir.technology/Gleipnir/nidus-sync/platform/types"
|
"source.gleipnir.technology/Gleipnir/nidus-sync/platform/types"
|
||||||
)
|
)
|
||||||
|
|
@ -19,42 +14,3 @@ func MailerByID(ctx context.Context, user User, id int32) (*types.Mailer, error)
|
||||||
func MailerList(ctx context.Context, user User, limit int) ([]types.Mailer, error) {
|
func MailerList(ctx context.Context, user User, limit int) ([]types.Mailer, error) {
|
||||||
return querypublic.MailersFromOrganizationID(ctx, db.PGInstance.PGXPool, int64(user.Organization.ID), int64(limit))
|
return querypublic.MailersFromOrganizationID(ctx, db.PGInstance.PGXPool, int64(user.Organization.ID), int64(limit))
|
||||||
}
|
}
|
||||||
func mailerQuery() bob.BaseQuery[*dialect.SelectQuery] {
|
|
||||||
return psql.Select(
|
|
||||||
sm.Columns(
|
|
||||||
models.Addresses.Columns.Country.As("address.country"),
|
|
||||||
models.Addresses.Columns.Locality.As("address.locality"),
|
|
||||||
//sm.From(psql.F("COALESCE", psql.Raw("address.location_latitude"), 0)).As("address.location.latitude"),
|
|
||||||
//sm.From(psql.F("COALESCE", psql.Raw("address.location_longitude"), 0)).As("address.location.longitude"),
|
|
||||||
"COALESCE(address.location_latitude, 0) AS \"address.location.latitude\"",
|
|
||||||
"COALESCE(address.location_longitude, 0) AS \"address.location.longitude\"",
|
|
||||||
models.Addresses.Columns.Number.As("address.number_"),
|
|
||||||
models.Addresses.Columns.PostalCode.As("address.postal_code"),
|
|
||||||
models.Addresses.Columns.Region.As("address.region"),
|
|
||||||
models.Addresses.Columns.Street.As("address.street"),
|
|
||||||
models.Addresses.Columns.Unit.As("address.unit"),
|
|
||||||
models.ComplianceReportRequests.Columns.Created.As("created"),
|
|
||||||
models.ComplianceReportRequests.Columns.PublicID.As("compliance_report_request_id"),
|
|
||||||
models.Sites.Columns.ID.As("site_id"),
|
|
||||||
models.Sites.Columns.OwnerName.As("recipient"),
|
|
||||||
"'created' AS \"status\"",
|
|
||||||
),
|
|
||||||
sm.From(models.ComplianceReportRequestMailers.Name()),
|
|
||||||
sm.InnerJoin(models.ComplianceReportRequests.Name()).OnEQ(
|
|
||||||
models.ComplianceReportRequestMailers.Columns.ComplianceReportRequestID,
|
|
||||||
models.ComplianceReportRequests.Columns.ID,
|
|
||||||
),
|
|
||||||
sm.InnerJoin(models.Leads.Name()).OnEQ(
|
|
||||||
models.ComplianceReportRequests.Columns.LeadID,
|
|
||||||
models.Leads.Columns.ID,
|
|
||||||
),
|
|
||||||
sm.InnerJoin(models.Sites.Name()).OnEQ(
|
|
||||||
models.Leads.Columns.SiteID,
|
|
||||||
models.Sites.Columns.ID,
|
|
||||||
),
|
|
||||||
sm.InnerJoin(models.Addresses.Name()).OnEQ(
|
|
||||||
models.Sites.Columns.AddressID,
|
|
||||||
models.Addresses.Columns.ID,
|
|
||||||
),
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue