<?php

namespace app\operations\model\plus\groupbuy;

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

/**
 * 商家端团购商品模型
 */
class Product extends ProductModel
{
    // 定义全局的查询范围
    protected $globalScope = ['status'];
    public function scopeStatus($query)
    {
        $shop_supplier_ids = \app\operations\model\supplier\Supplier::getSupplierIdsByUser(session('jjjshop_operations')['user']);
        if (empty($shop_supplier_ids)){
            $query->where($query->getTable() . '.shop_supplier_id', -1);
        }else{
            $query->where($query->getTable() . '.shop_supplier_id', 'in', $shop_supplier_ids);
        }
    }
    /**
     * 获取团购商品列表
     */
    public function getList($param)
    {
        $filter = [];
        if (!empty($param['search'])) {
            $filter[] = ['p.product_name', 'like', '%' . trim($param['search']) . '%'];
        }
        
        if (!empty($param['groupbuy_active_id'])) {
            $filter[] = ['gp.groupbuy_active_id', '=', (int)$param['groupbuy_active_id']];
        }
        
        // 店铺ID筛选 - 明确指定表别名
        $filter[] = ['gp.shop_supplier_id', '=', $param['shop_supplier_id'] ?? 0];
        
        $order = ['gp.create_time' => 'desc'];
        if (!empty($param['order'])) {
            $order = [$param['order_field'] => $param['order']];
        }
        
        return $this->with(['product', 'groupbuySku', 'active'])
            ->alias('gp')
            ->join('product p', 'p.product_id = gp.product_id')
            ->where($filter)
            ->order($order)
            ->paginate([
                'list_rows' => $param['list_rows'] ?? 15,
                'query' => $param
            ]);
    }

    /**
     * 添加团购商品
     */
    public function add($data)
    {
        $this->startTrans();
        $data['app_id'] = $this->app_id;
        try {
            // 检查商品是否已存在该活动中
            $exist = $this->where([
                'product_id' => $data['product_id'],
                'groupbuy_active_id' => $data['groupbuy_active_id']
            ])->find();
            if ($exist) {
                $this->error = '该商品已在当前活动中';
                return false;
            }
            
            // 保存团购商品基本信息
            $result = $this->save($data);
            
            if ($result !== false) {
                // 处理团购SKU
                if (!empty($data['sku_list'])) {
                    $this->handleGroupbuySku($data['sku_list']);
                }
            }
            
            $this->commit();
            return $result !== false;
        } catch (\Exception $e) {
            $this->rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }

    /**
     * 批量添加团购商品
     */
    public function batchAdd($productsData)
    {
        $results = [];
        foreach ($productsData as $productData) {
            $results[] = $this->add($productData);
        }
        return array_filter($results); // 返回成功的数量
    }

    /**
     * 编辑团购商品
     */
    public function edit($data)
    {
        $this->startTrans();
        try {
            $result = $this->save($data);
            
            if ($result !== false && !empty($data['sku_list'])) {
                // 更新团购SKU
                $this->handleGroupbuySku($data['sku_list']);
            }
            
            $this->commit();
            return $result !== false;
        } catch (\Exception $e) {
            $this->rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }

    /**
     * 处理团购SKU数据
     */
    private function handleGroupbuySku($skuList)
    {
        $skuModel = new \app\operations\model\plus\groupbuy\ProductSku();
        
        // 先获取现有的SKU ID 列表
        $existingSkus = $skuModel->where('groupbuy_product_id', $this->groupbuy_product_id)->select();
        $existingSkuIds = [];
        foreach ($existingSkus as $existingSku) {
            $existingSkuIds[$existingSku['product_sku_id']] = $existingSku['groupbuy_product_sku_id'];
        }
        
        // 添加或更新团购SKU
        foreach ($skuList as $sku) {
            $sku['groupbuy_product_id'] = $this->groupbuy_product_id;
            $sku['app_id'] = $this->app_id;
            
            // 检查是否是现有SKU
            if (isset($existingSkuIds[$sku['product_sku_id']])) {
                // 更新现有SKU
                $skuModel->save($sku, ['groupbuy_product_sku_id' => $existingSkuIds[$sku['product_sku_id']]]);
            } else {
                // 创建新SKU
                $skuModel->create($sku);
            }
        }
    }

    /**
     * 删除团购商品
     */
    public function remove()
    {
        $this->startTrans();
        try {
            // 删除团购SKU
            $skuModel = new \app\operations\model\plus\groupbuy\ProductSku();
            $skuModel->where('groupbuy_product_id', $this->groupbuy_product_id)->delete();
            
            // 删除团购订单用户记录
            $billUserModel = new \app\operations\model\plus\groupbuy\BillUser();
            $billUserModel->where('groupbuy_product_id', $this->groupbuy_product_id)->delete();
            
            // 删除团购订单
            $billModel = new \app\operations\model\plus\groupbuy\Bill();
            $billModel->where('groupbuy_product_id', $this->groupbuy_product_id)->delete();
            
            // 最后删除团购商品
            $result = $this->delete();
            
            $this->commit();
            return $result !== false;
        } catch (\Exception $e) {
            $this->rollback();
            $this->error = $e->getMessage();
            return false;
        }
    }
}