<?php

namespace app\common\service\product\factory;

use app\common\enum\product\DeductStockTypeEnum;
use app\common\model\plus\advance\AdvanceSku as AdvanceProductSkuModel;
use app\common\model\plus\advance\Product as AdvanceProductModel;
use app\common\model\product\Product as ProductModel;
use app\common\model\product\ProductSku as ProductSkuModel;

/**
 * 商品来源-普通商品扩展类
 */
class AdvanceProductService extends ProductService
{
    /**
     * 更新商品库存 (针对下单减库存的商品)
     */
    public function updateAdvanceProductStock($productList)
    {
        foreach ($productList as $product) {
            // 下单减库存
            if ($product['deduct_stock_type'] == DeductStockTypeEnum::CREATE) {
                $sku = AdvanceProductSkuModel::detail($product['sku_source_id']);
                try{
                    // 主库存减少
                    (new AdvanceProductModel)->where('advance_product_id', '=', $sku['advance_product_id'])->dec('stock', $product['total_num'])->update();
                    // 下单减库存
                    (new AdvanceProductSkuModel)->where('advance_product_sku_id', '=', $sku['advance_product_sku_id'])->dec('advance_stock', $product['total_num'])->update();
                }catch (\Exception $e){
                    log_write('advance updateProductStock'. $e->getMessage());
                }
            }
        }
    }

    /**
     * 更新商品库存销量（订单付款后）
     */
    public function updateAdvanceStockSales($productList)
    {
        foreach ($productList as $product) {
            $sku = AdvanceProductSkuModel::detail($product['sku_source_id']);
            // 记录商品的销量
            (new AdvanceProductModel)->where('advance_product_id', '=', $sku['advance_product_id'])->inc('total_sales', $product['total_num'])->update();
            // 付款减库存
            if ($product['deduct_stock_type'] == DeductStockTypeEnum::PAYMENT) {
                try{
                    // 主库存减少
                    (new AdvanceProductModel)->where('advance_product_id', '=', $sku['advance_product_id'])->dec('stock', $product['total_num'])->update();
                    // 付款减库存
                    (new AdvanceProductSkuModel)->where('advance_product_sku_id', '=', $sku['advance_product_sku_id'])->dec('advance_stock', $product['total_num'])->update();
                }catch (\Exception $e){
                    log_write('advance updateStockSales'. $e->getMessage());
                }
            }
        }
        return true;
    }

    /**
     * 更新商品库存 (针对下单减库存的商品)
     */
    public function updateProductStock($productList)
    {
        $productData = [];
        $productSkuData = [];
        foreach ($productList as $product) {
            // 下单减库存
            if ($product['deduct_stock_type'] == DeductStockTypeEnum::CREATE) {
                // 总库存
                $productData[] = [
                    'data' => ['product_stock' => ['dec', $product['total_num']]],
                    'where' => [
                        'product_id' => $product['product_id'],
                    ],
                ];
                $productSkuData[] = [
                    'data' => ['stock_num' => ['dec', $product['total_num']]],
                    'where' => [
                        'product_id' => $product['product_id'],
                        'spec_sku_id' => $product['spec_sku_id'],
                    ],
                ];
            }
        }
        // 更新商品销量
        !empty($productData) && $this->updateProduct($productData);
        // 更新商品sku库存
        !empty($productSkuData) && $this->updateProductSku($productSkuData);
        return true;
    }

    /**
     * 更新商品库存销量（订单付款后）
     */
    public function updateStockSales($productList)
    {
        $productData = [];
        $productSkuData = [];
        foreach ($productList as $product) {
            // 记录商品的销量
            $product_data = [
                'data' => ['sales_actual' => ['inc', $product['total_num']]],
                'where' => [
                    'product_id' => $product['product_id']
                ],
            ];
            // 付款减库存
            if ($product['deduct_stock_type'] == DeductStockTypeEnum::PAYMENT) {
                //总库存
                $product_data['data']['product_stock'] = ['dec', $product['total_num']];
                //sku库存
                $productSkuData[] = [
                    'data' => ['stock_num' => ['dec', $product['total_num']]],
                    'where' => [
                        'product_id' => $product['product_id'],
                        'spec_sku_id' => $product['spec_sku_id'],
                    ],
                ];
            }
            $productData[] = $product_data;
        }
        // 更新商品销量
        !empty($productData) && $this->updateProduct($productData);
        // 更新商品sku库存
        !empty($productSkuData) && $this->updateProductSku($productSkuData);
        return true;
    }

    /**
     * 回退商品库存
     */
    public function backProductStock($productList, $isPayOrder = false)
    {
        $productData = [];
        $productSkuData = [];
        foreach ($productList as $product) {
            $product_item = [
                'where' => [
                    'product_id' => $product['product_id'],
                ],
                'data' => ['product_stock' => ['inc', $product['total_num']]],
            ];
            $sku_item = [
                'where' => [
                    'product_id' => $product['product_id'],
                    'spec_sku_id' => $product['spec_sku_id'],
                ],
                'data' => ['stock_num' => ['inc', $product['total_num']]],
            ];
            if ($isPayOrder == true) {
                // 付款订单全部库存
                $productData[] = $product_item;
                $productSkuData[] = $sku_item;
            } else {
                // 未付款订单，判断必须为下单减库存时才回退
                $product['deduct_stock_type'] == DeductStockTypeEnum::CREATE && $productData[] = $product_item;
                $product['deduct_stock_type'] == DeductStockTypeEnum::CREATE && $productSkuData[] = $sku_item;
            }

            $sku = AdvanceProductSkuModel::detail($product['sku_source_id']);
            // 回退主库存
            (new AdvanceProductModel)->where('advance_product_id', '=', $sku['advance_product_id'])->inc('stock', $product['total_num'])->update();
            // 回退sku库存
            (new AdvanceProductSkuModel)->where('advance_product_sku_id', '=', $sku['advance_product_sku_id'])->inc('advance_stock', $product['total_num'])->update();
        }
        // 更新商品库存
        !empty($productData) && $this->updateProduct($productData);
        // 更新商品sku库存
        !empty($productSkuData) && $this->updateProductSku($productSkuData);
        return true;
    }

    /**
     * 更新商品信息
     */
    private function updateProduct($data)
    {
        return (new ProductModel)->updateAll($data);
    }

    /**
     * 更新商品sku信息
     */
    private function updateProductSku($data)
    {
        return (new ProductSkuModel)->updateAll($data);
    }

}