Mule DataWeave使用filter/map/groupBy实现销售报表接口问题排查

• 算子执行逻辑和优先级错误：代码未通过括号控制执行顺序，groupBy实际作用在map输出的每一条单独记录对象上，而非map返回的整个数组，完全没有实现数组分组的效果；且执行顺序错误，需求要求先筛选、再分组、最后做字段映射聚合，原代码是先映射单条记录再尝试分组，逻辑顺序颠倒。
• 分组维度不符合要求：仅按Country单字段分组，遗漏了需求要求的OrderPriority分组维度，无法实现双维度聚合。
• 字段值硬编码、计算逻辑错误：totalNumberofOrders直接写死为100，没有按分组统计实际订单数量；totalRevenue直接取单条记录的营收值，没有按分组对营收做求和汇总。
• 未处理CSV字段冗余空格问题：原始CSV中部分Country字段值末尾带多余空格（比如第一条记录的Antigua and Barbuda 末尾有空格），直接分组会把同国家的记录拆成不同分组。

严格按照要求使用filter、groupBy、map三个算子实现：

%dw 2.0
output application/json
---
// 1. filter算子：筛选匹配入参销售渠道的记录
payload filter (trim($.SalesChannel) == attributes.queryparam.salesChannel)
// 2. groupBy算子：按国家、订单优先级双维度分组
groupBy ((item) -> {
    country: trim(item.Country),
    orderPriority: item.OrderPriority
})
// 3. map算子：遍历分组结果做聚合计算，输出要求字段
map ((groupRecords, groupKey) -> {
    totalNumberofOrders: sizeOf(groupRecords),
    Country: groupKey.country,
    OrderPriority: groupKey.orderPriority,
    TotalRevenue: sum(groupRecords.TotalRevenue as Number)
})

• 筛选阶段对SalesChannel做trim处理，避免CSV字段前后空格导致渠道匹配失败
• 分组阶段使用复合对象作为分组键，同时支持国家、订单优先级两个维度的分组，对Country做trim处理避免空格导致分组错误
• 聚合映射阶段：
  • 用sizeOf统计每个分组的记录数，得到真实总订单数
  • 从分组键中提取国家、订单优先级字段，避免重复遍历
  • 把TotalRevenue转为数字类型后用sum求和，得到分组总营收

内容的提问来源于stack exchange，提问作者Aravind