Janady13/missionmatch / internal/platform/database/dbgen/opportunities.sql.go

1// Code generated by sqlc. DO NOT EDIT. 2// versions: 3// sqlc v1.31.1 4// source: opportunities.sql 5 6package dbgen 7 8import ( 9 "context" 10 11 "github.com/google/uuid" 12 "github.com/jackc/pgx/v5/pgtype" 13) 14 15const createOpportunity = `-- name: CreateOpportunity :one 16INSERT INTO opportunities (organization_id, name, solicitation_number, customer_agency, due_date, status) 17VALUES ($1,$2,$3,$4,$5,$6) 18RETURNING id, organization_id, name, solicitation_number, customer_agency, due_date, status, created_at, updated_at, value, value_source, federal_ref 19` 20 21type CreateOpportunityParams struct { 22 OrganizationID uuid.UUID `json:"organization_id"` 23 Name string `json:"name"` 24 SolicitationNumber *string `json:"solicitation_number"` 25 CustomerAgency *string `json:"customer_agency"` 26 DueDate pgtype.Date `json:"due_date"` 27 Status string `json:"status"` 28} 29 30func (q *Queries) CreateOpportunity(ctx context.Context, arg CreateOpportunityParams) (Opportunity, error) { 31 row := q.db.QueryRow(ctx, createOpportunity, 32 arg.OrganizationID, 33 arg.Name, 34 arg.SolicitationNumber, 35 arg.CustomerAgency, 36 arg.DueDate, 37 arg.Status, 38 ) 39 var i Opportunity 40 err := row.Scan( 41 &i.ID, 42 &i.OrganizationID, 43 &i.Name, 44 &i.SolicitationNumber, 45 &i.CustomerAgency, 46 &i.DueDate, 47 &i.Status, 48 &i.CreatedAt, 49 &i.UpdatedAt, 50 &i.Value, 51 &i.ValueSource, 52 &i.FederalRef, 53 ) 54 return i, err 55} 56 57const getOpportunity = `-- name: GetOpportunity :one 58SELECT id, organization_id, name, solicitation_number, customer_agency, due_date, status, created_at, updated_at, value, value_source, federal_ref FROM opportunities WHERE id = $1 59` 60 61func (q *Queries) GetOpportunity(ctx context.Context, id uuid.UUID) (Opportunity, error) { 62 row := q.db.QueryRow(ctx, getOpportunity, id) 63 var i Opportunity 64 err := row.Scan( 65 &i.ID, 66 &i.OrganizationID, 67 &i.Name, 68 &i.SolicitationNumber, 69 &i.CustomerAgency, 70 &i.DueDate, 71 &i.Status, 72 &i.CreatedAt, 73 &i.UpdatedAt, 74 &i.Value, 75 &i.ValueSource, 76 &i.FederalRef, 77 ) 78 return i, err 79} 80 81const listOpportunities = `-- name: ListOpportunities :many 82SELECT id, organization_id, name, solicitation_number, customer_agency, due_date, status, created_at, updated_at, value, value_source, federal_ref FROM opportunities ORDER BY created_at DESC, id DESC LIMIT $1 OFFSET $2 83` 84 85type ListOpportunitiesParams struct { 86 Limit int32 `json:"limit"` 87 Offset int32 `json:"offset"` 88} 89 90func (q *Queries) ListOpportunities(ctx context.Context, arg ListOpportunitiesParams) ([]Opportunity, error) { 91 rows, err := q.db.Query(ctx, listOpportunities, arg.Limit, arg.Offset) 92 if err != nil { 93 return nil, err 94 } 95 defer rows.Close() 96 items := []Opportunity{} 97 for rows.Next() { 98 var i Opportunity 99 if err := rows.Scan( 100 &i.ID, 101 &i.OrganizationID, 102 &i.Name, 103 &i.SolicitationNumber, 104 &i.CustomerAgency, 105 &i.DueDate, 106 &i.Status, 107 &i.CreatedAt, 108 &i.UpdatedAt, 109 &i.Value, 110 &i.ValueSource, 111 &i.FederalRef, 112 ); err != nil { 113 return nil, err 114 } 115 items = append(items, i) 116 } 117 if err := rows.Err(); err != nil { 118 return nil, err 119 } 120 return items, nil 121} 122 123const listRequirementsForOpportunity = `-- name: ListRequirementsForOpportunity :many 124SELECT id, organization_id, opportunity_id, title, customer_agency, required_level, required_poly, required_years, work_location, remote_allowed, key_personnel, created_at, updated_at, deleted_at, labor_category, quantity FROM requirements WHERE opportunity_id = $1 AND deleted_at IS NULL ORDER BY created_at DESC, id DESC 125` 126 127func (q *Queries) ListRequirementsForOpportunity(ctx context.Context, opportunityID *uuid.UUID) ([]Requirement, error) { 128 rows, err := q.db.Query(ctx, listRequirementsForOpportunity, opportunityID) 129 if err != nil { 130 return nil, err 131 } 132 defer rows.Close() 133 items := []Requirement{} 134 for rows.Next() { 135 var i Requirement 136 if err := rows.Scan( 137 &i.ID, 138 &i.OrganizationID, 139 &i.OpportunityID, 140 &i.Title, 141 &i.CustomerAgency, 142 &i.RequiredLevel, 143 &i.RequiredPoly, 144 &i.RequiredYears, 145 &i.WorkLocation, 146 &i.RemoteAllowed, 147 &i.KeyPersonnel, 148 &i.CreatedAt, 149 &i.UpdatedAt, 150 &i.DeletedAt, 151 &i.LaborCategory, 152 &i.Quantity, 153 ); err != nil { 154 return nil, err 155 } 156 items = append(items, i) 157 } 158 if err := rows.Err(); err != nil { 159 return nil, err 160 } 161 return items, nil 162} 163 164const proposalReadiness = `-- name: ProposalReadiness :many 165SELECT sm.band, sm.decision, COUNT(*) AS n 166FROM requirements r 167JOIN slates s ON s.requirement_id = r.id 168JOIN slate_members sm ON sm.slate_id = s.id 169WHERE r.opportunity_id = $1 170GROUP BY sm.band, sm.decision 171ORDER BY sm.band, sm.decision 172` 173 174type ProposalReadinessRow struct { 175 Band string `json:"band"` 176 Decision string `json:"decision"` 177 N int64 `json:"n"` 178} 179 180// Band/decision rollup across every slate member under one opportunity's requirements, the source 181// for GET /proposal-readiness [review COMPL-2]. RLS scopes all three tables to the caller's org. 182func (q *Queries) ProposalReadiness(ctx context.Context, opportunityID *uuid.UUID) ([]ProposalReadinessRow, error) { 183 rows, err := q.db.Query(ctx, proposalReadiness, opportunityID) 184 if err != nil { 185 return nil, err 186 } 187 defer rows.Close() 188 items := []ProposalReadinessRow{} 189 for rows.Next() { 190 var i ProposalReadinessRow 191 if err := rows.Scan(&i.Band, &i.Decision, &i.N); err != nil { 192 return nil, err 193 } 194 items = append(items, i) 195 } 196 if err := rows.Err(); err != nil { 197 return nil, err 198 } 199 return items, nil 200} 201