<?php

namespace app\operations\model\plus\assemble;

use app\common\model\plus\assemble\Product as ProductModel;

/**
 * 拼团商品模型
 */
class Product extends ProductModel
{
    /**
     * 获取秒杀商品列表
     */
    public static function getList($assemble_activity_id)
    {
        return (new static())->with(['product', 'assembleSku'])
            ->where('assemble_activity_id', '=', $assemble_activity_id)
            ->order(['sort' => 'asc', 'create_time' => 'asc'])
            ->select();
    }
     /**
     * 获取砍价商品列表
     */
    public static function getAllList($data)
    {   
        $model = new self();
        if(isset($data['assemble_activity_id'])&&$data['assemble_activity_id']){
            $model = $model->where('assemble_activity_id', '=', $data['assemble_activity_id']);
        }
       return $model->with(['product', 'assembleSku','supplier'])
            ->where('status', '=', $data['status'])
           ->where('is_delete','=', 0)
            ->order(['sort' => 'asc', 'create_time' => 'asc'])
            ->paginate($data);
    }
    /**
     * 新增
     */
    public function add($assemble_activity_id, $product_list)
    {
        //添加活动
        foreach ($product_list as $product){
            $this->addProduct($assemble_activity_id, $product);
        }
    }

    public function addProduct($assemble_activity_id, $product, $isUpdate = false)
    {
        //添加商品
        $stock = array_sum(array_column($product['spec_list'], 'assemble_stock'));
        $arr = [
            'product_id' => $product['product_id'],
            'limit_num' => $product['limit_num'],
            'stock' => $stock,
            'assemble_activity_id' => $assemble_activity_id,
            'assemble_num' => $product['assemble_num'],
            'sort' => $product['sort'],
            'sales_initial' => $product['sales_initial'],
            'is_delete' => $product['is_delete'],
            'app_id' => self::$app_id,
        ];
        if($isUpdate){
            $model = static::detail($product['assemble_product_id'])?:new self();
        }else{
            $model = new self();
        }
        $model->save($arr);
        //商品规格
        $sku_model = new AssembleSku();
        $save_data = [];
        $not_in_sku_id = [];
        foreach ($product['spec_list'] as $sku) {
            $sku_data = [
                'assemble_product_id' => $model['assemble_product_id'],
                'product_id' => $product['product_id'],
                'product_sku_id' => $sku['product_sku_id'],
                'assemble_price' => $sku['assemble_price'],
                'product_price' => $sku['product_price'],
                'assemble_stock' => $sku['assemble_stock'],
                'product_attr' => isset($sku['product_attr'])?$sku['product_attr']:'',
                'assemble_activity_id' => $assemble_activity_id,
                'app_id' => self::$app_id,
            ];
            if($sku['assemble_product_sku_id'] > 0){
                $detail = $sku_model->find($sku['assemble_product_sku_id']);
                if($detail){
                    $detail->save($sku_data);
                    array_push($not_in_sku_id, $sku['assemble_product_sku_id']);
                }
            }else{
                $save_data[] = $sku_data;
            }
        }

        //删除规格
        count($not_in_sku_id) > 0 && $sku_model->where('assemble_product_id', '=', $model['assemble_product_id'])
            ->whereNotIn('assemble_product_sku_id', $not_in_sku_id)
            ->delete();
        //新增规格
        count($save_data) > 0 && $sku_model->saveAll($save_data);
    }


    /**
     * 修改
     */
    public function edit($assemble_activity_id, $product_list)
    {
        //添加活动
        foreach ($product_list as $product){
            $this->addProduct($assemble_activity_id, $product, true);
        }
    }
    //审核商品状态
    public function editProduct($data)
    {

        $where['assemble_product_id'] = $data['assemble_product_id'];
        return self::update($data, $where);
    }

    public function del($assemble_product_id)
    {
        $this->startTrans();
        try {
            self::destroy($assemble_product_id);
            $model = new AssembleSku();
            $model->delAll($assemble_product_id);
            // 事务提交
            $this->commit();
            return true;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }

    /**
     *获取指定活动商品
     */
    public function getProductList($assemble_activity_id, $param = [])
    {
        $model = $this;
        $res = $model->with(['product.image.file', 'assembleSku', 'active.file'])
            ->where('assemble_activity_id', '=', $assemble_activity_id)
            ->paginate($param);
        if (!empty($res)) {
            $res = $res->toArray();
            foreach ($res['data'] as $key => $val) {
                $arr = array_column($res['data'][$key]['assembleSku'], 'assemble_price');
                if (count($arr) == 1) {
                    $res['data'][$key]['assemble_price'] = '￥' . current($arr);
                } else {
                    sort($arr);
                    $res['data'][$key]['assemble_price'] = '￥' . current($arr) . ' - ￥' . end($arr);
                }

            }
        }
        return $res;
    }

    public function getAssembleDetail($assemble_product_id)
    {
        $res = $this->with(['product.image.file', 'assembleSku.productSku.image'])
            ->where('assemble_product_id', '=', $assemble_product_id)->find();
        if (!empty($res)) {
            $arr = array_column($res->toArray()['assembleSku'], 'assemble_price');
            foreach ($res['assembleSku'] as $key => $val) {
                $res['assembleSku'][$key]['price'] = $res['assembleSku'][$key]['productSku']['product_price'];
            }
            $arr1 = array_column($res->toArray()['assembleSku'], 'price');
            sort($arr);
            sort($arr1);
            $res['assemble_price'] = '￥' . current($arr);
            $res['line_price'] = '￥' . current($arr1);
            if (count($arr) > 1) {
                $res['assemble_price'] = '￥' . current($arr) . ' - ￥' . end($arr);
                $res['line_price'] = '￥' . current($arr1) . ' - ￥' . end($arr1);
            }
        }
        return $res;
    }

    /**
     * 商品删除
     */
    public function setDelete()
    {
        return $this->save([
            'is_delete' => 1
        ]);
    }

    /**
     * 获取待审核数量
     */
    public static function getApplyCount()
    {
        return (new static())->where('status', '=', 0)
            ->where('is_delete', '=', 0)
            ->count();
    }

    /**
     * 上下架
     */
    public function setState($data)
    {
        return $this->save($data) !== false;
    }
}