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

1// Code generated by sqlc. DO NOT EDIT. 2// versions: 3// sqlc v1.31.1 4// source: requirements.sql 5 6package dbgen 7 8import ( 9 "context" 10 11 "github.com/google/uuid" 12) 13 14const addRequiredCertification = `-- name: AddRequiredCertification :exec 15INSERT INTO required_certifications (organization_id, requirement_id, name) 16VALUES ($1,$2,$3) 17ON CONFLICT (requirement_id, name) DO NOTHING 18` 19 20type AddRequiredCertificationParams struct { 21 OrganizationID uuid.UUID `json:"organization_id"` 22 RequirementID uuid.UUID `json:"requirement_id"` 23 Name string `json:"name"` 24} 25 26func (q *Queries) AddRequiredCertification(ctx context.Context, arg AddRequiredCertificationParams) error { 27 _, err := q.db.Exec(ctx, addRequiredCertification, arg.OrganizationID, arg.RequirementID, arg.Name) 28 return err 29} 30 31const addRequiredSkill = `-- name: AddRequiredSkill :exec 32INSERT INTO required_skills (organization_id, requirement_id, skill_id, mandatory) 33VALUES ($1,$2,$3,$4) 34ON CONFLICT (requirement_id, skill_id) DO UPDATE SET mandatory = EXCLUDED.mandatory 35` 36 37type AddRequiredSkillParams struct { 38 OrganizationID uuid.UUID `json:"organization_id"` 39 RequirementID uuid.UUID `json:"requirement_id"` 40 SkillID uuid.UUID `json:"skill_id"` 41 Mandatory bool `json:"mandatory"` 42} 43 44func (q *Queries) AddRequiredSkill(ctx context.Context, arg AddRequiredSkillParams) error { 45 _, err := q.db.Exec(ctx, addRequiredSkill, 46 arg.OrganizationID, 47 arg.RequirementID, 48 arg.SkillID, 49 arg.Mandatory, 50 ) 51 return err 52} 53 54const createRequirement = `-- name: CreateRequirement :one 55INSERT INTO requirements ( 56 organization_id, opportunity_id, title, customer_agency, 57 required_level, required_poly, required_years, 58 work_location, remote_allowed, key_personnel 59) VALUES ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10) 60RETURNING 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 61` 62 63type CreateRequirementParams struct { 64 OrganizationID uuid.UUID `json:"organization_id"` 65 OpportunityID *uuid.UUID `json:"opportunity_id"` 66 Title string `json:"title"` 67 CustomerAgency *string `json:"customer_agency"` 68 RequiredLevel string `json:"required_level"` 69 RequiredPoly string `json:"required_poly"` 70 RequiredYears int32 `json:"required_years"` 71 WorkLocation *string `json:"work_location"` 72 RemoteAllowed bool `json:"remote_allowed"` 73 KeyPersonnel bool `json:"key_personnel"` 74} 75 76func (q *Queries) CreateRequirement(ctx context.Context, arg CreateRequirementParams) (Requirement, error) { 77 row := q.db.QueryRow(ctx, createRequirement, 78 arg.OrganizationID, 79 arg.OpportunityID, 80 arg.Title, 81 arg.CustomerAgency, 82 arg.RequiredLevel, 83 arg.RequiredPoly, 84 arg.RequiredYears, 85 arg.WorkLocation, 86 arg.RemoteAllowed, 87 arg.KeyPersonnel, 88 ) 89 var i Requirement 90 err := row.Scan( 91 &i.ID, 92 &i.OrganizationID, 93 &i.OpportunityID, 94 &i.Title, 95 &i.CustomerAgency, 96 &i.RequiredLevel, 97 &i.RequiredPoly, 98 &i.RequiredYears, 99 &i.WorkLocation, 100 &i.RemoteAllowed, 101 &i.KeyPersonnel, 102 &i.CreatedAt, 103 &i.UpdatedAt, 104 &i.DeletedAt, 105 &i.LaborCategory, 106 &i.Quantity, 107 &i.RequiredCompartments, 108 ) 109 return i, err 110} 111 112const getRequirement = `-- name: GetRequirement :one 113SELECT 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 id = $1 AND deleted_at IS NULL 114` 115 116func (q *Queries) GetRequirement(ctx context.Context, id uuid.UUID) (Requirement, error) { 117 row := q.db.QueryRow(ctx, getRequirement, id) 118 var i Requirement 119 err := row.Scan( 120 &i.ID, 121 &i.OrganizationID, 122 &i.OpportunityID, 123 &i.Title, 124 &i.CustomerAgency, 125 &i.RequiredLevel, 126 &i.RequiredPoly, 127 &i.RequiredYears, 128 &i.WorkLocation, 129 &i.RemoteAllowed, 130 &i.KeyPersonnel, 131 &i.CreatedAt, 132 &i.UpdatedAt, 133 &i.DeletedAt, 134 &i.LaborCategory, 135 &i.Quantity, 136 &i.RequiredCompartments, 137 ) 138 return i, err 139} 140 141const listOpenRequirements = `-- name: ListOpenRequirements :many 142SELECT r.id, r.organization_id, r.opportunity_id, r.title, r.customer_agency, r.required_level, r.required_poly, r.required_years, r.work_location, r.remote_allowed, r.key_personnel, r.created_at, r.updated_at, r.deleted_at, r.labor_category, r.quantity, r.required_compartments FROM requirements r 143LEFT JOIN opportunities o 144 ON o.organization_id = r.organization_id AND o.id = r.opportunity_id 145WHERE r.deleted_at IS NULL 146 AND (o.id IS NULL OR o.status = 'open') 147ORDER BY r.created_at DESC, r.id DESC 148LIMIT $1 OFFSET $2 149` 150 151type ListOpenRequirementsParams struct { 152 Limit int32 `json:"limit"` 153 Offset int32 `json:"offset"` 154} 155 156// Only requirements whose opportunity is open, plus standalone requirements (NULL opportunity_id), 157// mirroring the Command Center predicate (o.id IS NULL OR o.status='open'). The LEFT JOIN selects r.* 158// so the row type stays Requirement. Used by the Opportunity Fit Engine, which scores only OPEN ones. 159func (q *Queries) ListOpenRequirements(ctx context.Context, arg ListOpenRequirementsParams) ([]Requirement, error) { 160 rows, err := q.db.Query(ctx, listOpenRequirements, arg.Limit, arg.Offset) 161 if err != nil { 162 return nil, err 163 } 164 defer rows.Close() 165 items := []Requirement{} 166 for rows.Next() { 167 var i Requirement 168 if err := rows.Scan( 169 &i.ID, 170 &i.OrganizationID, 171 &i.OpportunityID, 172 &i.Title, 173 &i.CustomerAgency, 174 &i.RequiredLevel, 175 &i.RequiredPoly, 176 &i.RequiredYears, 177 &i.WorkLocation, 178 &i.RemoteAllowed, 179 &i.KeyPersonnel, 180 &i.CreatedAt, 181 &i.UpdatedAt, 182 &i.DeletedAt, 183 &i.LaborCategory, 184 &i.Quantity, 185 &i.RequiredCompartments, 186 ); err != nil { 187 return nil, err 188 } 189 items = append(items, i) 190 } 191 if err := rows.Err(); err != nil { 192 return nil, err 193 } 194 return items, nil 195} 196 197const listRequiredCertifications = `-- name: ListRequiredCertifications :many 198SELECT name FROM required_certifications WHERE requirement_id = $1 ORDER BY name 199` 200 201func (q *Queries) ListRequiredCertifications(ctx context.Context, requirementID uuid.UUID) ([]string, error) { 202 rows, err := q.db.Query(ctx, listRequiredCertifications, requirementID) 203 if err != nil { 204 return nil, err 205 } 206 defer rows.Close() 207 items := []string{} 208 for rows.Next() { 209 var name string 210 if err := rows.Scan(&name); err != nil { 211 return nil, err 212 } 213 items = append(items, name) 214 } 215 if err := rows.Err(); err != nil { 216 return nil, err 217 } 218 return items, nil 219} 220 221const listRequiredSkills = `-- name: ListRequiredSkills :many 222SELECT s.id, s.name, rs.mandatory 223FROM required_skills rs 224JOIN skills s ON s.id = rs.skill_id 225WHERE rs.requirement_id = $1 226ORDER BY s.name 227` 228 229type ListRequiredSkillsRow struct { 230 ID uuid.UUID `json:"id"` 231 Name string `json:"name"` 232 Mandatory bool `json:"mandatory"` 233} 234 235func (q *Queries) ListRequiredSkills(ctx context.Context, requirementID uuid.UUID) ([]ListRequiredSkillsRow, error) { 236 rows, err := q.db.Query(ctx, listRequiredSkills, requirementID) 237 if err != nil { 238 return nil, err 239 } 240 defer rows.Close() 241 items := []ListRequiredSkillsRow{} 242 for rows.Next() { 243 var i ListRequiredSkillsRow 244 if err := rows.Scan(&i.ID, &i.Name, &i.Mandatory); err != nil { 245 return nil, err 246 } 247 items = append(items, i) 248 } 249 if err := rows.Err(); err != nil { 250 return nil, err 251 } 252 return items, nil 253} 254 255const listRequirements = `-- name: ListRequirements :many 256SELECT 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 257WHERE deleted_at IS NULL 258ORDER BY created_at DESC, id DESC 259LIMIT $1 OFFSET $2 260` 261 262type ListRequirementsParams struct { 263 Limit int32 `json:"limit"` 264 Offset int32 `json:"offset"` 265} 266 267// id is a unique trailing sort key so the order is total: ties on created_at no longer leave the 268// LIMIT/OFFSET cut and the downstream Best Fit pick nondeterministic. 269func (q *Queries) ListRequirements(ctx context.Context, arg ListRequirementsParams) ([]Requirement, error) { 270 rows, err := q.db.Query(ctx, listRequirements, arg.Limit, arg.Offset) 271 if err != nil { 272 return nil, err 273 } 274 defer rows.Close() 275 items := []Requirement{} 276 for rows.Next() { 277 var i Requirement 278 if err := rows.Scan( 279 &i.ID, 280 &i.OrganizationID, 281 &i.OpportunityID, 282 &i.Title, 283 &i.CustomerAgency, 284 &i.RequiredLevel, 285 &i.RequiredPoly, 286 &i.RequiredYears, 287 &i.WorkLocation, 288 &i.RemoteAllowed, 289 &i.KeyPersonnel, 290 &i.CreatedAt, 291 &i.UpdatedAt, 292 &i.DeletedAt, 293 &i.LaborCategory, 294 &i.Quantity, 295 &i.RequiredCompartments, 296 ); err != nil { 297 return nil, err 298 } 299 items = append(items, i) 300 } 301 if err := rows.Err(); err != nil { 302 return nil, err 303 } 304 return items, nil 305} 306