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

1// Code generated by sqlc. DO NOT EDIT. 2// versions: 3// sqlc v1.31.1 4// source: opportunity_records.sql 5 6package dbgen 7 8import ( 9 "context" 10 "time" 11 12 "github.com/google/uuid" 13 "github.com/jackc/pgx/v5/pgtype" 14 "github.com/shopspring/decimal" 15) 16 17const getOpportunityRecord = `-- name: GetOpportunityRecord :one 18SELECT id, source_name, source_record_id, dedupe_key, record_kind, title, agency, sub_agency, naics, psc, pop_city, pop_state, pop_country, pop_zip, set_aside, set_aside_code, contract_vehicle, estimated_value, value_source, incumbent_name, incumbent_uei, posted_date, response_deadline, award_date, estimated_award_date, pop_start_date, pop_end_date, ui_link, is_planning, raw_object_key, raw_sha256, fetched_at, synced_at FROM opportunity_records WHERE id = $1 19` 20 21func (q *Queries) GetOpportunityRecord(ctx context.Context, id uuid.UUID) (OpportunityRecord, error) { 22 row := q.db.QueryRow(ctx, getOpportunityRecord, id) 23 var i OpportunityRecord 24 err := row.Scan( 25 &i.ID, 26 &i.SourceName, 27 &i.SourceRecordID, 28 &i.DedupeKey, 29 &i.RecordKind, 30 &i.Title, 31 &i.Agency, 32 &i.SubAgency, 33 &i.Naics, 34 &i.Psc, 35 &i.PopCity, 36 &i.PopState, 37 &i.PopCountry, 38 &i.PopZip, 39 &i.SetAside, 40 &i.SetAsideCode, 41 &i.ContractVehicle, 42 &i.EstimatedValue, 43 &i.ValueSource, 44 &i.IncumbentName, 45 &i.IncumbentUei, 46 &i.PostedDate, 47 &i.ResponseDeadline, 48 &i.AwardDate, 49 &i.EstimatedAwardDate, 50 &i.PopStartDate, 51 &i.PopEndDate, 52 &i.UiLink, 53 &i.IsPlanning, 54 &i.RawObjectKey, 55 &i.RawSha256, 56 &i.FetchedAt, 57 &i.SyncedAt, 58 ) 59 return i, err 60} 61 62const listOpportunityRecords = `-- name: ListOpportunityRecords :many 63SELECT id, source_name, source_record_id, dedupe_key, record_kind, title, agency, sub_agency, naics, psc, pop_city, pop_state, pop_country, pop_zip, set_aside, set_aside_code, contract_vehicle, estimated_value, value_source, incumbent_name, incumbent_uei, posted_date, response_deadline, award_date, estimated_award_date, pop_start_date, pop_end_date, ui_link, is_planning, raw_object_key, raw_sha256, fetched_at, synced_at FROM opportunity_records 64WHERE ($1::text[] IS NULL OR record_kind = ANY($1::text[])) 65 AND ($2::text[] IS NULL OR naics = ANY($2::text[])) 66 AND ($3::text[] IS NULL OR upper(agency) = ANY($3::text[])) 67 AND ($4::text[] IS NULL OR upper(pop_state) = ANY($4::text[])) 68ORDER BY (response_deadline IS NULL OR response_deadline < now()), response_deadline ASC, posted_date DESC NULLS LAST, id 69LIMIT $5::int 70` 71 72type ListOpportunityRecordsParams struct { 73 Kinds []string `json:"kinds"` 74 Naics []string `json:"naics"` 75 Agencies []string `json:"agencies"` 76 States []string `json:"states"` 77 Lim int32 `json:"lim"` 78} 79 80// Optional filters (NULL array = no filter). Soonest closing first, then most recently posted, then id 81// as a unique tiebreaker so the order is deterministic. Text equality filters compare upper() on both 82// sides; the service upper cases the params so casing drift cannot silently zero out results. 83func (q *Queries) ListOpportunityRecords(ctx context.Context, arg ListOpportunityRecordsParams) ([]OpportunityRecord, error) { 84 rows, err := q.db.Query(ctx, listOpportunityRecords, 85 arg.Kinds, 86 arg.Naics, 87 arg.Agencies, 88 arg.States, 89 arg.Lim, 90 ) 91 if err != nil { 92 return nil, err 93 } 94 defer rows.Close() 95 items := []OpportunityRecord{} 96 for rows.Next() { 97 var i OpportunityRecord 98 if err := rows.Scan( 99 &i.ID, 100 &i.SourceName, 101 &i.SourceRecordID, 102 &i.DedupeKey, 103 &i.RecordKind, 104 &i.Title, 105 &i.Agency, 106 &i.SubAgency, 107 &i.Naics, 108 &i.Psc, 109 &i.PopCity, 110 &i.PopState, 111 &i.PopCountry, 112 &i.PopZip, 113 &i.SetAside, 114 &i.SetAsideCode, 115 &i.ContractVehicle, 116 &i.EstimatedValue, 117 &i.ValueSource, 118 &i.IncumbentName, 119 &i.IncumbentUei, 120 &i.PostedDate, 121 &i.ResponseDeadline, 122 &i.AwardDate, 123 &i.EstimatedAwardDate, 124 &i.PopStartDate, 125 &i.PopEndDate, 126 &i.UiLink, 127 &i.IsPlanning, 128 &i.RawObjectKey, 129 &i.RawSha256, 130 &i.FetchedAt, 131 &i.SyncedAt, 132 ); err != nil { 133 return nil, err 134 } 135 items = append(items, i) 136 } 137 if err := rows.Err(); err != nil { 138 return nil, err 139 } 140 return items, nil 141} 142 143const opportunityRecordMeta = `-- name: OpportunityRecordMeta :one 144SELECT COUNT(*)::bigint AS total, MAX(synced_at) AS last_synced FROM opportunity_records 145` 146 147type OpportunityRecordMetaRow struct { 148 Total int64 `json:"total"` 149 LastSynced interface{} `json:"last_synced"` 150} 151 152func (q *Queries) OpportunityRecordMeta(ctx context.Context) (OpportunityRecordMetaRow, error) { 153 row := q.db.QueryRow(ctx, opportunityRecordMeta) 154 var i OpportunityRecordMetaRow 155 err := row.Scan(&i.Total, &i.LastSynced) 156 return i, err 157} 158 159const upsertOpportunityRecord = `-- name: UpsertOpportunityRecord :exec 160 161INSERT INTO opportunity_records ( 162 source_name, source_record_id, dedupe_key, record_kind, title, agency, sub_agency, 163 naics, psc, pop_city, pop_state, pop_country, pop_zip, set_aside, set_aside_code, 164 contract_vehicle, estimated_value, value_source, incumbent_name, incumbent_uei, 165 posted_date, response_deadline, award_date, estimated_award_date, pop_start_date, pop_end_date, 166 ui_link, is_planning, raw_object_key, raw_sha256, fetched_at, synced_at 167) VALUES ( 168 $1, $2, $3, $4, $5, $6, $7, 169 $8, $9, $10, $11, $12, $13, $14, $15, 170 $16, $17, $18, $19, $20, 171 $21, $22, $23, $24, $25, $26, 172 $27, $28, $29, $30, $31, now() 173) 174ON CONFLICT (source_name, source_record_id) DO UPDATE SET 175 dedupe_key = EXCLUDED.dedupe_key, 176 record_kind = EXCLUDED.record_kind, 177 title = EXCLUDED.title, 178 agency = EXCLUDED.agency, 179 sub_agency = EXCLUDED.sub_agency, 180 naics = EXCLUDED.naics, 181 psc = EXCLUDED.psc, 182 pop_city = EXCLUDED.pop_city, 183 pop_state = EXCLUDED.pop_state, 184 pop_country = EXCLUDED.pop_country, 185 pop_zip = EXCLUDED.pop_zip, 186 set_aside = EXCLUDED.set_aside, 187 set_aside_code = EXCLUDED.set_aside_code, 188 contract_vehicle = EXCLUDED.contract_vehicle, 189 estimated_value = EXCLUDED.estimated_value, 190 value_source = EXCLUDED.value_source, 191 incumbent_name = EXCLUDED.incumbent_name, 192 incumbent_uei = EXCLUDED.incumbent_uei, 193 posted_date = EXCLUDED.posted_date, 194 response_deadline = EXCLUDED.response_deadline, 195 award_date = EXCLUDED.award_date, 196 estimated_award_date = EXCLUDED.estimated_award_date, 197 pop_start_date = EXCLUDED.pop_start_date, 198 pop_end_date = EXCLUDED.pop_end_date, 199 ui_link = EXCLUDED.ui_link, 200 is_planning = EXCLUDED.is_planning, 201 raw_object_key = EXCLUDED.raw_object_key, 202 raw_sha256 = EXCLUDED.raw_sha256, 203 fetched_at = EXCLUDED.fetched_at, 204 synced_at = now() 205` 206 207type UpsertOpportunityRecordParams struct { 208 SourceName string `json:"source_name"` 209 SourceRecordID string `json:"source_record_id"` 210 DedupeKey string `json:"dedupe_key"` 211 RecordKind string `json:"record_kind"` 212 Title string `json:"title"` 213 Agency string `json:"agency"` 214 SubAgency string `json:"sub_agency"` 215 Naics string `json:"naics"` 216 Psc string `json:"psc"` 217 PopCity string `json:"pop_city"` 218 PopState string `json:"pop_state"` 219 PopCountry string `json:"pop_country"` 220 PopZip string `json:"pop_zip"` 221 SetAside string `json:"set_aside"` 222 SetAsideCode string `json:"set_aside_code"` 223 ContractVehicle string `json:"contract_vehicle"` 224 EstimatedValue *decimal.Decimal `json:"estimated_value"` 225 ValueSource string `json:"value_source"` 226 IncumbentName string `json:"incumbent_name"` 227 IncumbentUei string `json:"incumbent_uei"` 228 PostedDate pgtype.Date `json:"posted_date"` 229 ResponseDeadline *time.Time `json:"response_deadline"` 230 AwardDate pgtype.Date `json:"award_date"` 231 EstimatedAwardDate pgtype.Date `json:"estimated_award_date"` 232 PopStartDate pgtype.Date `json:"pop_start_date"` 233 PopEndDate pgtype.Date `json:"pop_end_date"` 234 UiLink string `json:"ui_link"` 235 IsPlanning bool `json:"is_planning"` 236 RawObjectKey string `json:"raw_object_key"` 237 RawSha256 string `json:"raw_sha256"` 238 FetchedAt time.Time `json:"fetched_at"` 239} 240 241// Opportunity Intelligence unified records. Global public catalog (no organization_id, outside RLS): 242// reads run straight off the pool, writes come from cmd/opp-sync as the migrator role. 243func (q *Queries) UpsertOpportunityRecord(ctx context.Context, arg UpsertOpportunityRecordParams) error { 244 _, err := q.db.Exec(ctx, upsertOpportunityRecord, 245 arg.SourceName, 246 arg.SourceRecordID, 247 arg.DedupeKey, 248 arg.RecordKind, 249 arg.Title, 250 arg.Agency, 251 arg.SubAgency, 252 arg.Naics, 253 arg.Psc, 254 arg.PopCity, 255 arg.PopState, 256 arg.PopCountry, 257 arg.PopZip, 258 arg.SetAside, 259 arg.SetAsideCode, 260 arg.ContractVehicle, 261 arg.EstimatedValue, 262 arg.ValueSource, 263 arg.IncumbentName, 264 arg.IncumbentUei, 265 arg.PostedDate, 266 arg.ResponseDeadline, 267 arg.AwardDate, 268 arg.EstimatedAwardDate, 269 arg.PopStartDate, 270 arg.PopEndDate, 271 arg.UiLink, 272 arg.IsPlanning, 273 arg.RawObjectKey, 274 arg.RawSha256, 275 arg.FetchedAt, 276 ) 277 return err 278} 279