目标队列后处理工厂实现指南

轻易云数据集成平台提供强大的数据处理能力，以下代码示例展示了如何在目标队列生成后执行自定义数据处理逻辑。该加工厂类实现了对物料实体数据的实时计算和字段处理功能。

<?php
/**
 * AfterTargetGenerate 目标队列后处理工厂
 * 在轻易云数据集成流程中，对已生成的目标队列数据进行二次加工
 */
class AfterTargetGenerate
{
    /**
     * @var array 目标队列请求参数（引用传递）
     * 包含所有需要处理的业务数据实体
     */
    protected $params = [];

    /**
     * @var array 关联的原始数据ID集合
     * 采用MongoDB ObjectId格式标识数据来源
     */
    protected $ids = [];

    /**
     * 构造函数
     * @param array &$params 目标队列参数引用
     * @param array $ids 关联数据ID集合
     */
    public function __construct(&$params, $ids)
    {
        $this->params = &$params;
        $this->ids = $ids;
    }

    /**
     * 执行数据处理逻辑
     * 对物料实体中的税价进行折扣计算，并移除临时折扣字段
     */
    public function run()
    {
        foreach ($this->params['material_entity'] as &$item) {
            $item['tax_price'] = round($item['tax_price'] * $item['discount2'], 2);
            unset($item['discount2']);
        }
    }
}

关键功能说明：

1. 引用传参机制：通过构造函数接收参数引用，确保原始数据能被直接修改
2. 批量数据处理：遍历处理物料实体数组中的每个元素
3. 实时计算：对税价字段应用折扣率并保留两位小数
4. 字段清理：计算完成后自动移除临时折扣字段

集成部署方式：

将该加工厂类代码添加到轻易云数据集成方案的AfterTargetGenerate事件中，平台将在目标队列生成后自动触发执行。这种设计模式完美体现了轻易云数据集成平台的扩展性和灵活性，支持企业根据实际业务需求定制数据处理流程。

通过此类后处理工厂，企业可以轻松实现：

• 复杂价格计算逻辑
• 数据标准化处理
• 临时字段清理
• 业务规则校验等高级功能

轻易云数据集成平台的开放式架构确保各类数据处理需求都能通过类似的工厂模式得到完美解决。