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 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 ) 52 return i, err 53} 54 55const getOpportunity = `-- name: GetOpportunity :one 56SELECT id, organization_id, name, solicitation_number, customer_agency, due_date, status, created_at, updated_at, value FROM opportunities WHERE id = $1 57` 58 59func (q *Queries) GetOpportunity(ctx context.Context, id uuid.UUID) (Opportunity, error) { 60 row := q.db.QueryRow(ctx, getOpportunity, id) 61 var i Opportunity 62 err := row.Scan( 63 &i.ID, 64 &i.OrganizationID, 65 &i.Name, 66 &i.SolicitationNumber, 67 &i.CustomerAgency, 68 &i.DueDate, 69 &i.Status, 70 &i.CreatedAt, 71 &i.UpdatedAt, 72 &i.Value, 73 ) 74 return i, err 75} 76 77const listOpportunities = `-- name: ListOpportunities :many 78SELECT id, organization_id, name, solicitation_number, customer_agency, due_date, status, created_at, updated_at, value FROM opportunities ORDER BY created_at DESC LIMIT $1 OFFSET $2 79` 80 81type ListOpportunitiesParams struct { 82 Limit int32 `json:"limit"` 83 Offset int32 `json:"offset"` 84} 85 86func (q *Queries) ListOpportunities(ctx context.Context, arg ListOpportunitiesParams) ([]Opportunity, error) { 87 rows, err := q.db.Query(ctx, listOpportunities, arg.Limit, arg.Offset) 88 if err != nil { 89 return nil, err 90 } 91 defer rows.Close() 92 items := []Opportunity{} 93 for rows.Next() { 94 var i Opportunity 95 if err := rows.Scan( 96 &i.ID, 97 &i.OrganizationID, 98 &i.Name, 99 &i.SolicitationNumber, 100 &i.CustomerAgency, 101 &i.DueDate, 102 &i.Status, 103 &i.CreatedAt, 104 &i.UpdatedAt, 105 &i.Value, 106 ); err != nil { 107 return nil, err 108 } 109 items = append(items, i) 110 } 111 if err := rows.Err(); err != nil { 112 return nil, err 113 } 114 return items, nil 115} 116 117const listRequirementsForOpportunity = `-- name: ListRequirementsForOpportunity :many 118SELECT 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 119` 120 121func (q *Queries) ListRequirementsForOpportunity(ctx context.Context, opportunityID *uuid.UUID) ([]Requirement, error) { 122 rows, err := q.db.Query(ctx, listRequirementsForOpportunity, opportunityID) 123 if err != nil { 124 return nil, err 125 } 126 defer rows.Close() 127 items := []Requirement{} 128 for rows.Next() { 129 var i Requirement 130 if err := rows.Scan( 131 &i.ID, 132 &i.OrganizationID, 133 &i.OpportunityID, 134 &i.Title, 135 &i.CustomerAgency, 136 &i.RequiredLevel, 137 &i.RequiredPoly, 138 &i.RequiredYears, 139 &i.WorkLocation, 140 &i.RemoteAllowed, 141 &i.KeyPersonnel, 142 &i.CreatedAt, 143 &i.UpdatedAt, 144 &i.DeletedAt, 145 &i.LaborCategory, 146 &i.Quantity, 147 ); err != nil { 148 return nil, err 149 } 150 items = append(items, i) 151 } 152 if err := rows.Err(); err != nil { 153 return nil, err 154 } 155 return items, nil 156} 157 158const proposalReadiness = `-- name: ProposalReadiness :many 159SELECT sm.band, sm.decision, COUNT(*) AS n 160FROM requirements r 161JOIN slates s ON s.requirement_id = r.id 162JOIN slate_members sm ON sm.slate_id = s.id 163WHERE r.opportunity_id = $1 164GROUP BY sm.band, sm.decision 165ORDER BY sm.band, sm.decision 166` 167 168type ProposalReadinessRow struct { 169 Band string `json:"band"` 170 Decision string `json:"decision"` 171 N int64 `json:"n"` 172} 173 174// Band/decision rollup across every slate member under one opportunity's requirements — the source 175// for GET /proposal-readiness [review COMPL-2]. RLS scopes all three tables to the caller's org. 176func (q *Queries) ProposalReadiness(ctx context.Context, opportunityID *uuid.UUID) ([]ProposalReadinessRow, error) { 177 rows, err := q.db.Query(ctx, proposalReadiness, opportunityID) 178 if err != nil { 179 return nil, err 180 } 181 defer rows.Close() 182 items := []ProposalReadinessRow{} 183 for rows.Next() { 184 var i ProposalReadinessRow 185 if err := rows.Scan(&i.Band, &i.Decision, &i.N); err != nil { 186 return nil, err 187 } 188 items = append(items, i) 189 } 190 if err := rows.Err(); err != nil { 191 return nil, err 192 } 193 return items, nil 194} 195