我需要进行金额处理

lee_123

我需要进行金额处理

lee_1232

好的，请先提供数据的示例给我。并且告诉我怎么进行金额处理

lee_123

我的数据格式是这样的。

{
  "as_date": "2023-12-28 20:39:05",
  "as_id": 870174131,
  "buyer_apply_refund": "579.0",
  "buyer_receive_refund": "0.0",
  "confirm_date": "2024-01-01 10:51:13",
  "created": "2023-12-28 20:39:19",
  "currency": "",
  "free_amount": "0.0",
  "freight": "0",
  "good_status": "SELLER_RECEIVED",
  "items": [
    {
      "amount": "579",
      "as_id": 870174131,
      "asi_id": 870185928,
      "i_id": "T23WA37719",
      "name": "NORNS LADY/诺恩 秋冬新款大衣 T23WA37719 驼色 M",
      "outer_oi_id": "P718618651395344101_XHS-1UJO5VW57SAU",
      "pic": "http://qimg.xiaohongshu.com/arkgoods/1040g0o030s89g6f82g005p0o2fl4c9krngbegn0?itemId=656d2a401d547d0001c08fc5&imageView2/1/w/320/h/320/q/90.jpeg",
      "price": "579",
      "properties_value": "驼色 M(90-110斤)",
      "qty": 1,
      "r_qty": 1,
      "receive_date": "2024-01-01 10:51:13",
      "shop_amount": "579",
      "shop_sku_id": "df95c3c140a4a4b1e2c42587130954",
      "sku_id": "T23WA37719C6M",
      "sku_type": "normal",
      "type": "退货"
    }
  ],
  "l_id": "SF1678324944379",
  "labels": "ShopDown",
  "logistics_company": "顺丰速运",
  "modified": "2024-01-01 11:27:54",
  "node": "问题类型不存在",
  "o_id": 2631116,
  "order_label": "发货后售后",
  "order_status": "Sent",
  "order_type": "普通订单",
  "outer_as_id": "R9534410167144930",
  "payment": "0",
  "question_type": "多拍/拍错/不想要",
  "refund": "579",
  "refund_version": "0",
  "remark": "",
  "shop_buyer_id": "5b2be54d2720f8a01926f0960db956d9",
  "shop_freight": "0.0",
  "shop_id": "14793704",
  "shop_name": "Right Thirty R30服饰的店",
  "shop_status": "SUCCESS",
  "shop_type": "普通退货",
  "so_id": "P718618651395344101",
  "status": "Confirmed",
  "ts": "7417261917",
  "type": "普通退货",
  "urefund": "0.0",
  "warehouse": "浙江濮院分仓销退仓",
  "wh_id": 2,
  "wms_co_id": 12851795,
  "batchs": [
    {
      "amount": "579",
      "as_id": 870174131,
      "asi_id": 870185928,
      "i_id": "T23WA37719",
      "name": "NORNS LADY/诺恩 秋冬新款大衣 T23WA37719 驼色 M",
      "outer_oi_id": "P718618651395344101_XHS-1UJO5VW57SAU",
      "pic": "http://qimg.xiaohongshu.com/arkgoods/1040g0o030s89g6f82g005p0o2fl4c9krngbegn0?itemId=656d2a401d547d0001c08fc5&imageView2/1/w/320/h/320/q/90.jpeg",
      "price": "579",
      "properties_value": "驼色 M(90-110斤)",
      "qty": 1,
      "r_qty": 1,
      "receive_date": "2024-01-01 10:51:13",
      "shop_amount": "579",
      "shop_sku_id": "df95c3c140a4a4b1e2c42587130954",
      "sku_id": "T23WA37719C6M",
      "sku_type": "normal",
      "type": "退货"
    }
  ]
}

我的规则如下：
1：账户折扣金额:bill_dis_amount是否大于0，如果折扣金额大于0,就用折扣金额-运费，如果折扣金额小于0，就用折扣金额
2：得到商品分录行(material_entity)税费总额 = 每行的tax_price * 每行的qty，取浮点数
3：如果退款金额大于折扣金额，就行折扣金额，否则就取0
4：如果存在退费(urefund)，就减去运费
5：如果存在运费(freight)，就加上运费
6:如果税费总额-折扣总额不存在0.001的尾差。税费就用当前行税费。如果存在尾差则将第一个物料实体的tax_price字段设置为调整后的refund值，其他物料实体的tax_price字段设置为0

lee_1232

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

<?php

use Domain\Datahub\Instance\Storage\LogStorage;
use Adapter\Datahub\DataStrategyQueryAdapter;

class AfterTargetGenerate
{
    protected $params = [];

    protected $ids = [];

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

    public function run()
    {
        // 创建LogStorage对象
        $log = new LogStorage('04326edd-bdee-327f-baa3-390657cb23d2', '2e9ddc11-43eb-3125-8327-58d53b36bbdf');
        // 插入日志
        $log->insertOne(['text' => 'params', 'params' =>$this->params ]);
        //获取需要字段：
        $a1 = $this->params['bill_dis_amount'];
         //判断a1费用是否大于0
        if ($a1 > 0) {
             $a2 = $this->params['freight'];
             $this->params['bill_dis_amount'] = $a1 - $a2;
        }else{
              $this->params['bill_dis_amount'] = $a1;
        }
        // 插入处理后的日志
        //$log->insertOne(['text' => 'params after processing', 'params' => $this->params]);
          // 初始化总数为0
        $total = 0;

        // 遍历material_entity数组
        foreach ($this->params['material_entity'] as $entity) {
            // 将tax_price字段和qty字段转换为浮点数，然后相乘并加到总数上
            $total += floatval($entity['tax_price']) * floatval($entity['qty']);
        }

        // 假设a1和a2字段都存在于$this->params中
        $adjustedRefund = floatval($this->params['refund']) - (isset($this->params['bill_dis_amount']) ? floatval($this->params['bill_dis_amount']) : 0);
        $adjustedRefund -= isset($this->params['urefund']) ? floatval($this->params['urefund']) : 0 ;
        $adjustedRefund += isset($this->params['freight']) ? floatval($this->params['freight']) : 0 ;

        // 判断总数与调整后的refund值是否相等
        if (abs($total - $adjustedRefund) < 0.001) {
            // 如果相等，将每个物料实体的tax_price字段设置为原来的值
            foreach ($this->params['material_entity'] as &$entity) {
                $entity['tax_price'] = $entity['tax_price'];
            }
        } else {
            // 如果不相等，将第一个物料实体的tax_price字段设置为调整后的refund值，其他物料实体的tax_price字段设置为0
            $isFirst = true;
            foreach ($this->params['material_entity'] as &$entity) {
                if ($isFirst) {
                    $entity['tax_price'] = $adjustedRefund;
                    $this->params['bill_dis_amount']= 0 ;
                    $isFirst = false;
                } else {
                    $entity['tax_price'] = '0';
                }
            }
        }
        unset($this->params['freight']);
        unset($this->params['refund']);
        unset($this->params['urefund']);
    }
}