<?php

namespace app\queue\redis\slow;

use Webman\RedisQueue\Consumer;
use support\spark\model\govern\Schedule;
use support\spark\model\basicdata\Materialcommon;

/**
 * 部位计划导入消费者
 */
class UsedpartScheduleImport implements Consumer
{
    // 要消费的队列名
    public $queue = 'usedpart-schedule-import';

    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    /**
     * 消费函数 - 处理并更新给定的材料数据
     * 
     * @param array $param 包含数据和组织ID的参数数组
     *      $param['data'] 为材料数据数组，每个元素包含材料的相关信息
     *      $param['orgId'] 为组织ID
     * @return void 无返回值
     */
    public function consume($param)
    {
        // 提取参数中的数据和组织ID
        $data = $param["data"];
        $orgId = $param['orgId'];

        // 获取材料数据中的唯一材料编号，并查询相关的材料信息
        $materialNums = array_values(array_unique(array_column($data, 'material_num')));
        $materials = Materialcommon::whereIn('material_num', $materialNums)->get(['material_num', 'material_unit', 'material_model'])
            ->keyBy('material_num');

        // 遍历数据数组，为每个材料添加规格和单位信息，并更新或插入到计划数据表中
        foreach ($data as $item) {
            // 检查材料是否存在，如果存在，则添加规格和单位信息
            if (isset($materials[$item['material_num']])) {
                $material = $materials[$item['material_num']];

                $item['spec'] = $material->material_model;
                $item['unit'] = $material->material_unit;
            }
            // 准备计划数据
            $scheduleData = [
                'org_id' => $orgId,
                'usedpart_wbs' => $item['usedpart_wbs'],
                'material_name' => $item['material_name'],
                'material_num' => $item['material_num'],
            ];

            // 更新或插入计划数据
            Schedule::updateOrInsert($scheduleData, $item);
        }
    }
}