我需要处理项目关联

lee_123

我需要处理关联项目的数据

lee_1232

这个场景使用使用AfterSourceInvoke 队列调用后插件进行执行。
在为你编写加工厂脚本之前，请先提供原始的响应数据给我。

lee_123

我的数据格式是这样的。


{
  "bill_source": "ISV",
  "bill_date": "2024-03-03 09:39:02",
  "bill_no": "CK2024030337",
  "customer_number": "001",
  "operation_key": "audit",
  "custom_field": {
    "custom_field__4__2obgp309axx5_number": "xm00001",
    "custom_field__1__3trygs3uh415": "240302-173119979082432"
  },
  "material_entity": [
    {
      "material_number": "6920118552236",
      "stock_number": "009",
      "qty": "1.0000",
      "unit_id": "1484260736698951680",
      "tax_price": "59.900000",
      "cess": "13"
    }
  ]
}

lee_1232

在为你编写加工厂脚本之前，请先回答我如下的问题：
1、当前方案中，使用哪个字段去关联另外一个联查方案？
2、另外一个联查方案的ID是什么？以及另外一个方案中部门编码字段是什么？
3、是否复制一个全新的字段出来？

lee_123

使用”custom_field42obgp309axx5_number“这个字段去联查。
联查的方案ID是 84218b22-74df-3c24-bb3b-d7afdd663b5c，部门编码字段是 content.FNumber
我要复制一个全新的字段”custom_field42obgp309axx5_number“出来。

lee_1232

我已经帮你写好了这个加工厂，将该加工厂代码新增到方案的事件 AfterTargetGenerate 即可。

<?php
use Domain\Datahub\Instance\Storage\DataStorage;
use Domain\Datahub\Instance\Storage\LogStorage;
class AfterTargetGenerate
{
    protected $params = [];
    protected $ids = [];

    public function __construct(&$params, $ids)
    {
        $this->params = &$params;
        $this->ids = $ids;
    }

    public function run()
    {
        // $log = new LogStorage('b555edbf-0c37-30c1-a84d-31bf9f7322b2', 'c2547c01-d26b-3910-908b-1420e7f0971d');
        // $log->insertOne(['text' => 'this is params', 'params' => $this->params]);
        if(isset($this->params['custom_field__4__2obgp309axx5_number']) && $this->params['custom_field__4__2obgp309axx5_number'] != ''){
            $strategyId = '84218b22-74df-3c24-bb3b-d7afdd663b5c';
            $storage = new DataStorage('b555edbf-0c37-30c1-a84d-31bf9f7322b2',$strategyId);
            $where = ['content.number'=> ['$eq' => $this->params['custom_field__4__2obgp309axx5_number']]];
            $query = $storage->find($where);
            if ($query) {
                # code...
                // $log->insertOne(['text' => 'this is params', 'params' => $query]);
                $this->params['custom_field__4__2obgp309axx5_number'] = $query[0]['content']['id'];
            }
        }
    }
}