<?php

namespace app\operations\model\plus\seckill;

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

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

    private function addProduct($seckill_activity_id, $product, $isUpdate = false)
    {
        //添加商品
        $stock = array_sum(array_column($product['spec_list'], 'seckill_stock'));
        $arr = [
            'product_id' => $product['product_id'],
            'seckill_activity_id' => $seckill_activity_id,
            'app_id' => self::$app_id,
            'stock' => $stock,
            'limit_num' => $product['limit_num'],
            'sort' => $product['sort'],
            'sales_initial' => $product['sales_initial'],
            'is_delete' => $product['is_delete'],
        ];
        if($isUpdate){
            $model = static::detail($product['seckill_product_id'])?:new self();
        }else{
            $model = new self();
        }
        $model->save($arr);
        //商品规格
        $sku_model = new SeckillSku();
        $save_data = [];
        $not_in_sku_id = [];
        foreach ($product['spec_list'] as $sku) {
            $sku_data = [
                'seckill_product_id' => $model['seckill_product_id'],
                'product_id' => $product['product_id'],
                'product_sku_id' => $sku['product_sku_id'],
                'seckill_price' => $sku['seckill_price'],
                'product_price' => $sku['product_price'],
                'seckill_stock' => $sku['seckill_stock'],
                'product_attr' => isset($sku['product_attr'])?$sku['product_attr']:'',
                'seckill_activity_id' => $seckill_activity_id,
                'app_id' => self::$app_id,
            ];
            if($sku['seckill_product_sku_id'] > 0){
                $detail = $sku_model->find($sku['seckill_product_sku_id']);
                if($detail){
                    $detail->save($sku_data);
                    array_push($not_in_sku_id, $sku['seckill_product_sku_id']);
                }
            }else{
                $save_data[] = $sku_data;
            }
        }
        //删除规格
        count($not_in_sku_id) > 0 && $sku_model->where('seckill_product_id', '=', $model['seckill_product_id'])
            ->whereNotIn('seckill_product_sku_id', $not_in_sku_id)
            ->delete();
        //新增规格
        count($save_data) > 0 && $sku_model->saveAll($save_data);
    }

    /**
     * 修改
     */
    public function edit($seckill_activity_id, $product_list)
    {
        //添加活动
        foreach ($product_list as $product){
            $this->addProduct($seckill_activity_id, $product, true);
        }
    }
    //审核商品状态
    public function editProduct($data)
    {
        $where['seckill_product_id'] = $data['seckill_product_id'];
        return self::update($data, $where);
    }
    public function del($seckill_product_id)
    {
        $this->startTrans();
        try {
            self::destroy($seckill_product_id);
            $model = new SeckillSku();
            $model->delAll($seckill_product_id);
            // 事务提交
            $this->commit();
            return true;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }


    public function getActivityList($seckill_activity_arr, $param)
    {
        $param = json_decode($param['param'], true);

        $model = $this;
        if (isset($param['search']) && !empty($param['search'])) {
            $model = $model->where('product.product_name', 'like', '%' . trim($param['search']) . '%');
        }
        $str = implode(',', $seckill_activity_arr);
        $res = $model->with(['product.image.file', 'seckillSku', 'active.file'])
            ->alias('kill')->join('product', 'product.product_id = kill.product_id')
            ->where('kill.seckill_activity_id', 'in', $str)
            ->paginate($param);
        if (!empty($res)) {
            $res = $res->toArray();
            foreach ($res['data'] as $key => $val) {
                $arr = array_column($res['data'][$key]['seckillSku'], 'seckill_price');
                if (count($arr) == 1) {
                    $res['data'][$key]['seckill_price'] = '￥' . current($arr);
                } else {
                    sort($arr);
                    $res['data'][$key]['seckill_price'] = '￥' . current($arr) . ' - ￥' . end($arr);
                }

            }
        }
        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;
    }
}