自定义数据加工厂，源平台队列插入前 BeforeSourceJobInsert 示例

<?php

class BeforeSourceJobInsert
{

    protected $response;

    protected $adapter;

    /**
     * 构造函数
     *
     * @param array $response          引用传递,调用接口返回的原始响应数组
     * @param Adapter:class $adapter   适配器类
     */
    public function __construct(&$response, $adapter)
    {
        $this->response = &$response;
        $this->adapter = $adapter;
    }

    /**
     * 工厂事件执行函数
     *
     * @return void
     */
    public function run()
    {
        // 如果旺店通响应code大于0,则响应失败,不对数据进行加工 
        if ($this->response['code'] > 0) {
            return;
        }
        // 开始遍历 stockout_list 单据数组 
        foreach ($this->response['stockout_list'] as &$item) {
            // 如果单据中的 post_fee 运费字段大于0 
            if (floatval($item['post_fee'])  > 0) {
                // 向details_list单据体数组追加一行分录,分录定义了五个基本对象 规格码\数量\单价\仓库\备注
                $item['details_list'][] = [
                    'spec_code' => '2222',
                    'goods_count' => 1,
                    'price' => floatval($item['post_fee']),
                    'warehouse_no' => '440001',
                    'remark' => '运费333'
                ];
            }
        }
    }
}