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, required_compartments 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 &i.RequiredCompartments, 154 ); err != nil { 155 return nil, err 156 } 157 items = append(items, i) 158 } 159 if err := rows.Err(); err != nil { 160 return nil, err 161 } 162 return items, nil 163} 164 165const proposalReadiness = `-- name: ProposalReadiness :many 166SELECT sm.band, sm.decision, COUNT(*) AS n 167FROM requirements r 168JOIN slates s ON s.requirement_id = r.id 169JOIN slate_members sm ON sm.slate_id = s.id 170WHERE r.opportunity_id = $1 171GROUP BY sm.band, sm.decision 172ORDER BY sm.band, sm.decision 173` 174 175type ProposalReadinessRow struct { 176 Band string `json:"band"` 177 Decision string `json:"decision"` 178 N int64 `json:"n"` 179} 180 181// Band/decision rollup across every slate member under one opportunity's requirements, the source 182// for GET /proposal-readiness [review COMPL-2]. RLS scopes all three tables to the caller's org. 183func (q *Queries) ProposalReadiness(ctx context.Context, opportunityID *uuid.UUID) ([]ProposalReadinessRow, error) { 184 rows, err := q.db.Query(ctx, proposalReadiness, opportunityID) 185 if err != nil { 186 return nil, err 187 } 188 defer rows.Close() 189 items := []ProposalReadinessRow{} 190 for rows.Next() { 191 var i ProposalReadinessRow 192 if err := rows.Scan(&i.Band, &i.Decision, &i.N); err != nil { 193 return nil, err 194 } 195 items = append(items, i) 196 } 197 if err := rows.Err(); err != nil { 198 return nil, err 199 } 200 return items, nil 201} 202