catalog/controller/api/product.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php
// catalog/controller/api/product.php
class ControllerApiProduct extends Controller {
    private $error = array();
    protected $null_array = array();
    protected $use_table_seo_url = false;
    protected $posted_categories = '';

    protected function validateData($data) {

        if (!isset($data['names']) || !$data['names']) {
            $this->error['names'] = sprintf($this->language->get('error_required'), 'Names');
        }

        if ($this->error && !isset($this->error['warning'])) {
            $this->error['warning'] = $this->language->get('error_warning');
        }
        return $this->error;
    }

    public function delproduct(){
        $json = array();
        $check = $this->check->checkToken();
        if (!$check) {
            $json['code'] = 401;
            $json['error']['warning'] = $this->language->get('error_permission');
        } else {
            $product_id  = (int)$_REQUEST['product_id'];
            // load model
            $this->load->model('catalog/product');
            $this->model_catalog_product->deleteProduct($product_id);
            $this->cache->deleteLike('index_');
            $json['success']['msg'] = 'delete success';
            $json['code'] = 200;
        }
    }
    //分配库存 $product['sku'],$product['product_id'],$product['act']默认是更新库存
    public function update_stock(){
        $this->load->language('api/product');
        $json = array();
        $check = $this->check->checkToken();

        if (!$check) {
            $json['code'] = 401;
            $json['error']['warning'] = $this->language->get('error_permission');
        } else {
            if (($this->request->server['REQUEST_METHOD'] == 'POST')) {
                //接post body json
                $products = json_decode(file_get_contents("php://input"),true);
                if(!$products) {
                    $this->error['required'] = sprintf($this->language->get('error_required'), '');
                }
                foreach ($products as $k=>$product){
                $action = isset($product['act'])?$product['act']:'update';
                if (!isset($product['product_id']) && !isset($product['skuid'])) {
                    $this->error['required'] = sprintf($this->language->get('error_required'), 'Product_id or Sku_id');
                }
                if (!isset($product['quantity']) || !$product['quantity'] || (int)$product['quantity'] <= 0) {
                    $this->error['required'] = sprintf($this->language->get('error_required'), 'Quantity');
                }