<flow name="forecast-demand-publish">
  <scheduler>
    <scheduling-strategy>
      <fixed-frequency frequency="86400000"/>
    </scheduling-strategy>
  </scheduler>

  <!-- Pull approved forecast lines from SF -->
  <salesforce:query
    config-ref="SF_Mfg_Cloud">
    <salesforce:salesforce-query>
      SELECT Id, Year_Month__c, Qty__c,
             Unit_Price__c, Phase__c,
             Forecast_Scenario__r.Confidence__c,
             Part__r.SKU__c
      FROM Forecast_Schedule_Line__c
      WHERE Status__c = 'Approved'
    </salesforce:salesforce-query>
  </salesforce:query>

  <ee:transform>
    <!-- DataWeave below -->
  </ee:transform>

  <http:request
    config-ref="ERP_Demand_API"
    method="POST"
    path="/demand/import"/>
</flow>

%dw 2.0
output application/json
// Preserve month-level granularity
// Do NOT smooth · do NOT average
---
{
  source: "salesforce-forecast",
  publishedAt: now(),
  lines: payload map ((line, i) -> {
    sku: line.Part__r.SKU__c,
    yearMonth: line.Year_Month__c,
    qty: line.Qty__c as Number,
    unitPrice: line.Unit_Price__c as Number,
    revenue: (line.Qty__c as Number)
            * (line.Unit_Price__c as Number),
    phase: line.Phase__c,
    confidence: (line.Forecast_Scenario__r
                .Confidence__c as Number) / 100,
    weightedRevenue: (line.Qty__c as Number)
                   * (line.Unit_Price__c as Number)
                   * ((line.Forecast_Scenario__r
                      .Confidence__c as Number) / 100),
    canonicalKey: line.Id
  })
}