04 · Kỹ thuật

Phân tích BA cho dev

Đặc tả kỹ thuật để hiện thực bộ rule: mô hình dữ liệu, thuật toán kèm pseudocode, API và edge case. Trang Rule điều phối là nguồn chân lý nghiệp vụ; trang này tập trung cách hiện thực.

Mô hình dữ liệu

Các thực thể cốt lõi. Kiểu dữ liệu mang tính gợi ý, đội dev điều chỉnh theo stack thực tế.

Employee (Nhân viên)

Service & Step

Skill & Assignment

Thuật toán điều phối

Phân loại đầu vào

function dispatch(service):
  if service.urgency == 'urgent':
      return dispatchUrgent(service)
  if service.type == 'branch_opening':
      return dispatchBranchProject(service)
  return dispatchRegular(service)   // việc lẻ

Việc lẻ — gom cụm

function buildCluster(emp, service, startSeq):
  cluster = []; total = 0
  for step in service.steps[startSeq:]:
      if step.skill_id not in emp.skills: break   // thiếu KN
      if total + step.std_minutes > session_cap: break // trần buổi
      cluster.add(step); total += step.std_minutes
  return cluster, total

Việc lẻ — chọn người

function dispatchRegular(service):
  startSeq = firstUnassignedStep(service)
  skill = service.steps[startSeq].skill_id
  // B1: lọc cứng
  cands = employees.filter(e =>
      skill in e.skills
      AND service.branch.area in e.areas
      AND e.status == 'available'
      AND remainingSessionTime(e) > 0)

  if cands.isEmpty():            // B4 van an toàn
      cands = anyAvailableWithSkill(skill, service.branch.area)
      flag = 'auto_out_of_band'
  else:
      flag = 'auto_in_band'

  // B2-B3: chấm điểm (band qua w4, KHÔNG phải bộ lọc)
  minPay = min(e.monthly_service_pay for e in allActive)
  for e in cands:
      cluster, mins = buildCluster(e, service, startSeq)
      payGap = e.monthly_service_pay - minPay
      e.score = w1*e.performance_score
              + w2*len(e.skills)
              - w3*currentLoadHours(e)
              + w4*max(0, band_limit - payGap)/100000
              + clusterBonus(cluster)
  winner = argmax(cands, by=score)
  return createAssignment(winner, cluster, flag)

Việc khẩn & dự án

function dispatchUrgent(service):
  target = pick(employeesOnSite(service.branch), by=nearest)
  // KHÔNG cắt cụm; giao thêm, cho vượt trần buổi
  a = createAssignment(target, service, flag='urgent',
                       allowOverCap=true, maxMinutes=urgent_handle)
  if spikeDetected() OR overdue(service): escalateAddPeople(service)
  return a

function dispatchBranchProject(service):
  for s in uniqueSkillSteps(service):
      pinAssign(soleOwner(s.skill), s)   // ràng buộc cứng
  crew = []
  while not covers(crew.skills, remainingSkills(service)):
      crew.add(roundRobinNext(eligiblePool(service.area)))
  return assignCrew(crew, service)

Gợi ý API / sự kiện

Edge case