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 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 ) 108 return i, err 109} 110 111const getRequirement = `-- name: GetRequirement :one 112SELECT 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 id = $1 AND deleted_at IS NULL 113` 114 115func (q *Queries) GetRequirement(ctx context.Context, id uuid.UUID) (Requirement, error) { 116 row := q.db.QueryRow(ctx, getRequirement, id) 117 var i Requirement 118 err := row.Scan( 119 &i.ID, 120 &i.OrganizationID, 121 &i.OpportunityID, 122 &i.Title, 123 &i.CustomerAgency, 124 &i.RequiredLevel, 125 &i.RequiredPoly, 126 &i.RequiredYears, 127 &i.WorkLocation, 128 &i.RemoteAllowed, 129 &i.KeyPersonnel, 130 &i.CreatedAt, 131 &i.UpdatedAt, 132 &i.DeletedAt, 133 &i.LaborCategory, 134 &i.Quantity, 135 ) 136 return i, err 137} 138 139const listOpenRequirements = `-- name: ListOpenRequirements :many 140SELECT 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 FROM requirements r 141LEFT JOIN opportunities o 142 ON o.organization_id = r.organization_id AND o.id = r.opportunity_id 143WHERE r.deleted_at IS NULL 144 AND (o.id IS NULL OR o.status = 'open') 145ORDER BY r.created_at DESC, r.id DESC 146LIMIT $1 OFFSET $2 147` 148 149type ListOpenRequirementsParams struct { 150 Limit int32 `json:"limit"` 151 Offset int32 `json:"offset"` 152} 153 154// Only requirements whose opportunity is open, plus standalone requirements (NULL opportunity_id), 155// mirroring the Command Center predicate (o.id IS NULL OR o.status='open'). The LEFT JOIN selects r.* 156// so the row type stays Requirement. Used by the Opportunity Fit Engine, which scores only OPEN ones. 157func (q *Queries) ListOpenRequirements(ctx context.Context, arg ListOpenRequirementsParams) ([]Requirement, error) { 158 rows, err := q.db.Query(ctx, listOpenRequirements, arg.Limit, arg.Offset) 159 if err != nil { 160 return nil, err 161 } 162 defer rows.Close() 163 items := []Requirement{} 164 for rows.Next() { 165 var i Requirement 166 if err := rows.Scan( 167 &i.ID, 168 &i.OrganizationID, 169 &i.OpportunityID, 170 &i.Title, 171 &i.CustomerAgency, 172 &i.RequiredLevel, 173 &i.RequiredPoly, 174 &i.RequiredYears, 175 &i.WorkLocation, 176 &i.RemoteAllowed, 177 &i.KeyPersonnel, 178 &i.CreatedAt, 179 &i.UpdatedAt, 180 &i.DeletedAt, 181 &i.LaborCategory, 182 &i.Quantity, 183 ); err != nil { 184 return nil, err 185 } 186 items = append(items, i) 187 } 188 if err := rows.Err(); err != nil { 189 return nil, err 190 } 191 return items, nil 192} 193 194const listRequiredCertifications = `-- name: ListRequiredCertifications :many 195SELECT name FROM required_certifications WHERE requirement_id = $1 ORDER BY name 196` 197 198func (q *Queries) ListRequiredCertifications(ctx context.Context, requirementID uuid.UUID) ([]string, error) { 199 rows, err := q.db.Query(ctx, listRequiredCertifications, requirementID) 200 if err != nil { 201 return nil, err 202 } 203 defer rows.Close() 204 items := []string{} 205 for rows.Next() { 206 var name string 207 if err := rows.Scan(&name); err != nil { 208 return nil, err 209 } 210 items = append(items, name) 211 } 212 if err := rows.Err(); err != nil { 213 return nil, err 214 } 215 return items, nil 216} 217 218const listRequiredSkills = `-- name: ListRequiredSkills :many 219SELECT s.id, s.name, rs.mandatory 220FROM required_skills rs 221JOIN skills s ON s.id = rs.skill_id 222WHERE rs.requirement_id = $1 223ORDER BY s.name 224` 225 226type ListRequiredSkillsRow struct { 227 ID uuid.UUID `json:"id"` 228 Name string `json:"name"` 229 Mandatory bool `json:"mandatory"` 230} 231 232func (q *Queries) ListRequiredSkills(ctx context.Context, requirementID uuid.UUID) ([]ListRequiredSkillsRow, error) { 233 rows, err := q.db.Query(ctx, listRequiredSkills, requirementID) 234 if err != nil { 235 return nil, err 236 } 237 defer rows.Close() 238 items := []ListRequiredSkillsRow{} 239 for rows.Next() { 240 var i ListRequiredSkillsRow 241 if err := rows.Scan(&i.ID, &i.Name, &i.Mandatory); err != nil { 242 return nil, err 243 } 244 items = append(items, i) 245 } 246 if err := rows.Err(); err != nil { 247 return nil, err 248 } 249 return items, nil 250} 251 252const listRequirements = `-- name: ListRequirements :many 253SELECT 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 254WHERE deleted_at IS NULL 255ORDER BY created_at DESC, id DESC 256LIMIT $1 OFFSET $2 257` 258 259type ListRequirementsParams struct { 260 Limit int32 `json:"limit"` 261 Offset int32 `json:"offset"` 262} 263 264// id is a unique trailing sort key so the order is total: ties on created_at no longer leave the 265// LIMIT/OFFSET cut and the downstream Best Fit pick nondeterministic. 266func (q *Queries) ListRequirements(ctx context.Context, arg ListRequirementsParams) ([]Requirement, error) { 267 rows, err := q.db.Query(ctx, listRequirements, arg.Limit, arg.Offset) 268 if err != nil { 269 return nil, err 270 } 271 defer rows.Close() 272 items := []Requirement{} 273 for rows.Next() { 274 var i Requirement 275 if err := rows.Scan( 276 &i.ID, 277 &i.OrganizationID, 278 &i.OpportunityID, 279 &i.Title, 280 &i.CustomerAgency, 281 &i.RequiredLevel, 282 &i.RequiredPoly, 283 &i.RequiredYears, 284 &i.WorkLocation, 285 &i.RemoteAllowed, 286 &i.KeyPersonnel, 287 &i.CreatedAt, 288 &i.UpdatedAt, 289 &i.DeletedAt, 290 &i.LaborCategory, 291 &i.Quantity, 292 ); err != nil { 293 return nil, err 294 } 295 items = append(items, i) 296 } 297 if err := rows.Err(); err != nil { 298 return nil, err 299 } 300 return items, nil 301} 302