Janady13/missionmatch / internal/modules/commandcenter/service.go

1package commandcenter 2 3import ( 4 "context" 5 "errors" 6 "fmt" 7 "time" 8 9 "github.com/jackc/pgx/v5" 10 "github.com/shopspring/decimal" 11 12 "github.com/missionworkforce/missionmatch/internal/modules/matching/engine" 13 "github.com/missionworkforce/missionmatch/internal/platform/tenant" 14) 15 16// ErrNoDatabase is returned when no pool is configured. 17var ErrNoDatabase = errors.New("commandcenter: no database configured") 18 19var hundred = decimal.NewFromInt(100) 20 21// WCC composite weights (DISTINCT from the engine's per-candidate weights). Sum == 1.00 (tested). 22var weights = map[string]decimal.Decimal{ 23 "clearance_coverage": decimal.RequireFromString("0.30"), 24 "skill_coverage": decimal.RequireFromString("0.25"), 25 "labor_category_coverage": decimal.RequireFromString("0.20"), 26 "proposal_readiness": decimal.RequireFromString("0.15"), 27 "availability_coverage": decimal.RequireFromString("0.10"), 28} 29var driverOrder = []struct{ key, label string }{ 30 {"clearance_coverage", "Clearance Coverage"}, 31 {"skill_coverage", "Skill Coverage"}, 32 {"labor_category_coverage", "Labor Category Coverage"}, 33 {"proposal_readiness", "Proposal Readiness"}, 34 {"availability_coverage", "Availability Coverage"}, 35} 36 37var levelLabels = map[string]string{ 38 "unknown": "Unknown", "none": "None", "confidential": "Confidential", 39 "secret": "Secret", "top_secret": "Top Secret", "ts_sci": "TS/SCI", 40} 41 42// Service computes the Workforce Command Center view. 43type Service struct { 44 db *tenant.DB 45 clock func() time.Time 46} 47 48func NewService(db *tenant.DB) *Service { return &Service{db: db, clock: time.Now} } 49 50func levelLabel(code string) string { 51 if l, ok := levelLabels[code]; ok { 52 return l 53 } 54 return code 55} 56 57func pct(num, den int64) decimal.Decimal { 58 if den <= 0 { 59 return decimal.Zero 60 } 61 return decimal.NewFromInt(num).Div(decimal.NewFromInt(den)).Mul(hundred).Round(2) 62} 63 64func driverState(p decimal.Decimal) string { 65 switch { 66 case p.GreaterThanOrEqual(engine.BandGreenMin): 67 return "ready" 68 case p.GreaterThanOrEqual(engine.BandYellowMin): 69 return "partial" 70 default: 71 return "gap" 72 } 73} 74 75func colorFor(p decimal.Decimal) string { 76 switch driverState(p) { 77 case "ready": 78 return "green" 79 case "partial": 80 return "yellow" 81 default: 82 return "red" 83 } 84} 85 86// CommandCenter computes the full dashboard for the caller's org as-of the given date. 87func (s *Service) CommandCenter(ctx context.Context, asOf time.Time) (View, error) { 88 if s.db == nil { 89 return View{}, ErrNoDatabase 90 } 91 asOfStr := asOf.Format("2006-01-02") 92 v := View{AsOf: asOfStr, GeneratedAt: asOf.UTC().Format(time.RFC3339), Meta: Meta{Notes: []string{}}} 93 if org, ok := tenant.OrgFromContext(ctx); ok { 94 v.OrganizationID = org 95 } 96 97 err := s.db.RunInTenantTx(ctx, func(ctx context.Context, tx pgx.Tx) error { 98 if err := buildTemps(ctx, tx, asOfStr); err != nil { 99 return err 100 } 101 102 // ---- opportunity metadata (RLS-scoped) ---- 103 oppMeta := map[string]oppInfo{} 104 rows, err := tx.Query(ctx, `SELECT id::text, name, COALESCE(customer_agency,''), COALESCE(solicitation_number,''), COALESCE(to_char(due_date,'YYYY-MM-DD'),''), value, value_source FROM opportunities WHERE status='open'`) 105 if err != nil { 106 return fmt.Errorf("opp map: %w", err) 107 } 108 for rows.Next() { 109 var id, name, cust, sol, due, src string 110 var val *decimal.Decimal 111 if err := rows.Scan(&id, &name, &cust, &sol, &due, &val, &src); err != nil { 112 rows.Close() 113 return err 114 } 115 oppMeta[id] = oppInfo{name: name, customer: cust, solicitation: sol, dueDate: due, value: val, valueSource: src} 116 } 117 rows.Close() 118 if err := rows.Err(); err != nil { 119 return err 120 } 121 122 // ---- assignment-based panels (each available candidate consumed at most once) ---- 123 assigned, qualified, reqs, _, err := fetchAssignment(ctx, tx) 124 if err != nil { 125 return err 126 } 127 opps, highRisk := opportunitiesFromAssignment(reqs, assigned, oppMeta) 128 v.ActiveOpportunities = opps 129 gaps, suggestReq, totalGaps := gapsFromAssignment(reqs, assigned, oppMeta) 130 v.StaffingGaps = gaps 131 v.LaborCategoryCoverage = lcatCoverageFromAssignment(reqs, assigned) 132 var proposalPct decimal.Decimal 133 v.ProposalReadiness, proposalPct = proposalFromAssignment(reqs, assigned, qualified, oppMeta) 134 135 // ---- drivers (clearance/skill/lcat coverage + availability via SQL; proposal from assignment) ---- 136 drivers, availReqCov, err := s.drivers(ctx, tx) 137 if err != nil { 138 return err 139 } 140 drivers["proposal_readiness"] = proposalPct 141 142 var totalCleared, availableAll, availCleared int64 143 if err := tx.QueryRow(ctx, 144 `SELECT count(*) FILTER (WHERE effective AND lvl>=2), count(*) FILTER (WHERE available), 145 count(*) FILTER (WHERE available AND effective AND lvl>=2) FROM cc_cand`). 146 Scan(&totalCleared, &availableAll, &availCleared); err != nil { 147 return fmt.Errorf("banner cand: %w", err) 148 } 149 // Proposal-ready = green slate members on slates tied to an OPEN (or standalone) opportunity, 150 // excluding closed-opportunity slates [review EN-2]. 151 var proposalReady, activeReqs int64 152 if err := tx.QueryRow(ctx, 153 `SELECT count(DISTINCT sm.candidate_id) 154 FROM slate_members sm 155 JOIN slates s ON s.id = sm.slate_id 156 JOIN requirements r ON r.id = s.requirement_id 157 LEFT JOIN opportunities o ON o.id = r.opportunity_id 158 WHERE sm.band='green' AND (o.id IS NULL OR o.status='open')`).Scan(&proposalReady); err != nil { 159 return fmt.Errorf("proposal ready: %w", err) 160 } 161 if err := tx.QueryRow(ctx, `SELECT count(*) FROM cc_active_req`).Scan(&activeReqs); err != nil { 162 return fmt.Errorf("active reqs: %w", err) 163 } 164 165 // ---- clearance intelligence ---- 166 if v.ClearanceIntelligence, err = s.clearance(ctx, tx, asOfStr); err != nil { 167 return err 168 } 169 // ---- win impact ---- 170 if v.WinImpact, err = s.winImpact(ctx, tx); err != nil { 171 return err 172 } 173 // ---- heat map ---- 174 if v.HeatMap, err = s.heatMap(ctx, tx); err != nil { 175 return err 176 } 177 // ---- action center badge counts ---- 178 var openNoSlate, reqsUnscreened int64 179 if err := tx.QueryRow(ctx, 180 `SELECT count(*) FROM opportunities o WHERE o.status='open' 181 AND NOT EXISTS (SELECT 1 FROM slates s WHERE s.requirement_id IN (SELECT id FROM requirements r WHERE r.opportunity_id=o.id))`). 182 Scan(&openNoSlate); err != nil { 183 return fmt.Errorf("open no slate: %w", err) 184 } 185 if err := tx.QueryRow(ctx, 186 `SELECT count(*) FROM cc_active_req ar WHERE NOT EXISTS (SELECT 1 FROM slates s WHERE s.requirement_id=ar.id)`). 187 Scan(&reqsUnscreened); err != nil { 188 return fmt.Errorf("reqs unscreened: %w", err) 189 } 190 191 // ---- assemble mission readiness ---- 192 score := decimal.Zero 193 drvViews := make([]Driver, 0, len(driverOrder)) 194 for _, d := range driverOrder { 195 p := drivers[d.key] 196 score = score.Add(p.Mul(weights[d.key])) 197 drvViews = append(drvViews, Driver{ 198 Key: d.key, Label: d.label, Pct: p.StringFixed(2), State: driverState(p), 199 Weight: weights[d.key].String(), 200 }) 201 } 202 score = score.Round(2) 203 band, status := readinessBand(score, totalCleared == 0 && activeReqs == 0) 204 v.MissionReadiness = MissionReadiness{ 205 Score: score.StringFixed(2), Band: band, Status: status, Drivers: drvViews, 206 AvailabilityReqCoverage: availReqCov.StringFixed(2), Flags: []string{}, 207 } 208 209 v.Banner = Banner{ 210 TotalClearedWorkforce: int(totalCleared), AvailableCandidates: int(availableAll), 211 ProposalReadyCandidates: int(proposalReady), ActiveRequirements: int(activeReqs), 212 StaffingGaps: int(totalGaps), HighRiskOpportunities: highRisk, 213 } 214 215 v.ActionCenter = buildActionCenter(suggestReq, opps, int(openNoSlate), int(reqsUnscreened)) 216 v.Meta.Empty = totalCleared == 0 && activeReqs == 0 && availableAll == 0 217 return nil 218 }) 219 if err != nil { 220 return View{}, err 221 } 222 223 v.AIRecommendations = buildRecommendations(v) 224 if v.AIRecommendations == nil { 225 v.AIRecommendations = []Recommendation{} 226 } 227 return v, nil 228} 229 230type oppInfo struct { 231 name string 232 customer string 233 solicitation string 234 dueDate string 235 value *decimal.Decimal 236 valueSource string // representative, operator, sam, usaspending (W2 Revenue at Risk provenance) 237} 238 239// isRealValueSource reports whether an opportunity value came from a cached federal source (SAM or 240// USASpending). A representative or operator entered dollar is not a real federal figure, so it can 241// never clear the representative label on Revenue at Risk. 242func isRealValueSource(s string) bool { return s == "sam" || s == "usaspending" } 243 244func readinessBand(score decimal.Decimal, empty bool) (band, status string) { 245 if empty { 246 return "red", "No Data" 247 } 248 switch { 249 case score.GreaterThanOrEqual(engine.BandGreenMin): 250 return "green", "Mission Ready" 251 case score.GreaterThanOrEqual(engine.BandYellowMin): 252 return "yellow", "Watch" 253 default: 254 return "red", "At Risk" 255 } 256} 257