Souke/backend/controllers/ProductController.php

<?php

/**
 * Copyright distrib (2018)
 *
 * contact@opendistrib.net
 *
 * Ce logiciel est un programme informatique servant à aider les producteurs
 * à distribuer leur production en circuits courts.
 *
 * Ce logiciel est régi par la licence CeCILL soumise au droit français et
 * respectant les principes de diffusion des logiciels libres. Vous pouvez
 * utiliser, modifier et/ou redistribuer ce programme sous les conditions
 * de la licence CeCILL telle que diffusée par le CEA, le CNRS et l'INRIA
 * sur le site "http://www.cecill.info".
 *
 * En contrepartie de l'accessibilité au code source et des droits de copie,
 * de modification et de redistribution accordés par cette licence, il n'est
 * offert aux utilisateurs qu'une garantie limitée.  Pour les mêmes raisons,
 * seule une responsabilité restreinte pèse sur l'auteur du programme,  le
 * titulaire des droits patrimoniaux et les concédants successifs.
 *
 * A cet égard  l'attention de l'utilisateur est attirée sur les risques
 * associés au chargement,  à l'utilisation,  à la modification et/ou au
 * développement et à la reproduction du logiciel par l'utilisateur étant
 * donné sa spécificité de logiciel libre, qui peut le rendre complexe à
 * manipuler et qui le réserve donc à des développeurs et des professionnels
 * avertis possédant  des  connaissances  informatiques approfondies.  Les
 * utilisateurs sont donc invités à charger  et  tester  l'adéquation  du
 * logiciel à leurs besoins dans des conditions permettant d'assurer la
 * sécurité de leurs systèmes et ou de leurs données et, plus généralement,
 * à l'utiliser et l'exploiter dans les mêmes conditions de sécurité.
 *
 * Le fait que vous puissiez accéder à cet en-tête signifie que vous avez
 * pris connaissance de la licence CeCILL, et que vous en avez accepté les
 * termes.
 */

namespace backend\controllers;

use backend\forms\ProductPriceUploadForm;
use common\helpers\CSV;
use common\helpers\GlobalParam;
use common\logic\Distribution\ProductDistribution\Model\ProductDistribution;
use common\logic\PointSale\PointSale\Model\PointSale;
use common\logic\Product\Product\Model\Product;
use common\logic\Product\Product\Model\ProductSearch;
use common\logic\Product\ProductPointSale\Model\ProductPointSale;
use common\logic\Product\ProductPrice\Model\ProductPrice;
use common\logic\Product\ProductPrice\Model\ProductPriceSearch;
use common\logic\User\UserProducer\Model\UserProducer;
use Yii;
use yii\filters\AccessControl;
use yii\helpers\BaseFileHelper;
use yii\helpers\Html;
use yii\web\NotFoundHttpException;
use yii\filters\VerbFilter;
use common\helpers\Upload;
use yii\web\UploadedFile;

/**
 * ProduitController implements the CRUD actions for Produit model.
 */
class ProductController extends BackendController
{
    var $enableCsrfValidation = false;

    public function behaviors()
    {
        return [
            'verbs' => [
                'class' => VerbFilter::class,
                'actions' => [
                ],
            ],
            'access' => [
                'class' => AccessControl::class,
                'rules' => [
                    [
                        'allow' => true,
                        'roles' => ['@'],
                        'matchCallback' => function ($rule, $action) {
                            return $this->getUserManager()->hasAccessBackend();
                        }
                    ]
                ],
            ],
        ];
    }

    /**
     * Liste les modèles Produit.
     *
     * @return mixed
     */
    public function actionIndex()
    {
        $searchModel = new ProductSearch();
        $dataProvider = $searchModel->search(\Yii::$app->request->queryParams);

        return $this->render('index', [
            'searchModel' => $searchModel,
            'dataProvider' => $dataProvider,
        ]);
    }

    /**
     * Crée un Product.
     */
    public function actionCreate()
    {
        $productManager = $this->getProductManager();
        $distributionManager = $this->getDistributionManager();

        $model = $productManager->instanciateProduct();

        $model->active = 1;
        $model->id_producer = GlobalParam::getCurrentProducerId();
        $model->monday = 1;
        $model->tuesday = 1;
        $model->wednesday = 1;
        $model->thursday = 1;
        $model->friday = 1;
        $model->saturday = 1;
        $model->sunday = 1;
        $model->available_on_points_sale = 1;

        if ($model->load(\Yii::$app->request->post()) && $productManager->saveCreate($model)) {

            $lastProductOrder = Product::find()->where('id_producer = :id_producer')->params([':id_producer' => GlobalParam::getCurrentProducerId()])->orderBy('order DESC')->one();
            if ($lastProductOrder) {
                $model->order = ++$lastProductOrder->order;
            }

            Upload::uploadFile($model, 'photo');
            $productManager->saveUpdate($model);

            $this->processAvailabilityPointsSale($model);
            $distributionManager->addProductIncomingDistributions($model);

            $this->setFlash('success', 'Produit <strong>' . Html::encode($model->name) . '</strong> ajouté');

            return $this->redirect(['index']);
        } else {
            return $this->render('create', [
                'model' => $model,
            ]);
        }
    }

    /**
     * Modifie un Product.
     */
    public function actionUpdate($id)
    {
        $productManager = $this->getProductManager();
        $distributionManager = $this->getDistributionManager();

        $request = Yii::$app->request;
        $model = $this->findModel($id);

        foreach ($model->productPointSale as $productPointSale) {
            $model->pointsSale[] = $productPointSale->id_point_sale;
        }

        $photoFilenameOld = $model->photo;

        if ($model->load(\Yii::$app->request->post()) && $productManager->saveUpdate($model)) {

            Upload::uploadFile($model, 'photo', $photoFilenameOld);

            $deletePhoto = $request->post('delete_photo', 0);
            if ($deletePhoto) {
                $model->photo = '';
                $model->save();
            }

            $this->processAvailabilityPointsSale($model);

            if ($model->apply_distributions) {
                $distributionManager->addProductIncomingDistributions($model);
            }

            $this->setFlash('success', 'Produit <strong>' . Html::encode($model->name) . '</strong> modifié');
            return $this->redirect(['index']);
        }

        return $this->render('update/update', [
            'model' => $model,
            'action' => 'update',
        ]);
    }

    /**
     * Traite les accès restreints d'un point de vente.
     */
    public function processAvailabilityPointsSale($product)
    {
        $pointSaleManager = $this->getPointSaleManager();
        $productPointSaleManager = $this->getProductPointSaleManager();

        ProductPointSale::deleteAll(['id_product' => $product->id]);

        if (is_array($product->pointsSale) && count($product->pointsSale)) {
            foreach ($product->pointsSale as $key => $idPointSale) {
                $pointSale = $pointSaleManager->findOnePointSaleById($idPointSale);
                if ($pointSale) {
                    $productPointSaleManager->createProductPointSale(
                        $product,
                        $pointSale,
                        ($product->available_on_points_sale) ? false : true
                    );
                }
            }
        }
    }

    public function actionPricesList(int $id)
    {
        $model = $this->findModel($id);

        $searchModel = new ProductPriceSearch();
        $searchModel->id_product = $id;

        $dataProvider = $searchModel->search(array_merge(\Yii::$app->request->queryParams, [
            'id_product' => $id
        ]));

        $userProducerWithProductPercent = UserProducer::searchAll([], [
            'join_with' => ['user'],
            'conditions' => 'user_producer.product_price_percent != 0',
        ]);

        $pointSaleWithProductPercent = PointSale::searchAll([], [
            'conditions' => 'point_sale.product_price_percent != 0'
        ]);

        return $this->render('update/prices/list', [
            'model' => $model,
            'action' => 'prices-list',
            'searchModel' => $searchModel,
            'dataProvider' => $dataProvider,
            'userProducerWithProductPercent' => $userProducerWithProductPercent,
            'pointSaleWithProductPercent' => $pointSaleWithProductPercent,
        ]);
    }

    public function actionPricesCreate($idProduct)
    {
        $model = new ProductPrice();
        $model->id_product = $idProduct;
        $modelProduct = $this->findModel($idProduct);

        if ($model->load(\Yii::$app->request->post())) {

            $conditionsProductPriceExist = [
                'id_product' => $idProduct,
                'id_user' => $model->id_user ?? null,
                'id_user_group' => $model->id_user_group ?? null,
                'id_point_sale' => $model->id_point_sale ?? null,
                'from_quantity' => $model->from_quantity ?? null,
            ];

            $productPriceExist = ProductPrice::findOne($conditionsProductPriceExist);

            if ($productPriceExist) {
                $productPriceExist->delete();
                $this->setFlash('warning', 'Un prix existait déjà pour cet utilisateur / point de vente, il a été supprimé.');
            }

            if ($model->save()) {
                $this->setFlash('success', 'Le prix a bien été ajouté.');
                return $this->redirect(['product/prices-list', 'id' => $idProduct]);
            }
        }

        return $this->render('update/prices/create', [
            'model' => $model,
            'modelProduct' => $modelProduct,
        ]);
    }

    public function actionPricesUpdate($id)
    {
        $model = $this->findModelProductPrice($id);
        $modelProduct = $this->findModel($model->id_product);

        if ($model->load(\Yii::$app->request->post()) && $model->save()) {
            $this->setFlash('success', 'Prix modifié');
            return $this->redirect(['product/prices-list', 'id' => $model->id_product]);
        }

        return $this->render('update/prices/update', [
            'model' => $model,
            'modelProduct' => $modelProduct,
            'action' => 'prices-update',
        ]);
    }

    public function actionPricesDelete($id)
    {
        $productPrice = $this->findModelProductPrice($id);
        $productPrice->delete();
        $this->setFlash('success', 'Prix supprimé');
        return $this->redirect(['product/prices-list', 'id' => $productPrice->id_product]);
    }

    /**
     * Supprime un Product.
     */
    public function actionDelete(int $id, bool $confirm = false)
    {
        $product = $this->findModel($id);

        if ($confirm) {
            $product->delete();
            ProductDistribution::deleteAll(['id_product' => $id]);

            $this->setFlash('success', 'Produit <strong>' . Html::encode($product->name) . '</strong> supprimé');
        } else {
            $this->setFlash('info', 'Souhaitez-vous vraiment supprimer le produit <strong>' . Html::encode($product->name) . '</strong> ? '
                . Html::a('Oui', ['product/delete', 'id' => $id, 'confirm' => 1], ['class' => 'btn btn-default']) . ' ' . Html::a('Non', ['product/index'], ['class' => 'btn btn-default']));
        }

        return $this->redirect(['index']);
    }

    /**
     * Modifie l'ordre des produits.
     */
    public function actionOrder()
    {
        $array = Yii::$app->request->post('array');
        $orderArray = json_decode(stripslashes($array));

        foreach ($orderArray as $id => $order) {
            $product = $this->findModel($id);
            $product->order = $order;
            $product->save();
        }
    }

    public function actionAjaxToggleActive($id, $active)
    {
        \Yii::$app->response->format = \yii\web\Response::FORMAT_JSON;

        $distributionManager = $this->getDistributionManager();

        $product = $this->findModel($id);
        $product->active = (int) $active;
        $product->save();

        $distributionManager->addProductIncomingDistributions($product);

        return ['success', 'id' => $id, 'active' => $active];
    }

    /**
     * Import des prix produits via un fichier CSV.
     *
     * @return mixed
     */
    public function actionPriceImport()
    {
        $productManager = $this->getProductManager();
        $productPriceManager = $this->getProductPriceManager();
        $userGroupManager = $this->getUserGroupManager();
        $pointSaleManager = $this->getPointSaleManager();
        $userManager = $this->getUserManager();

        $model = new ProductPriceUploadForm();

        if (Yii::$app->request->isPost) {
            $model->file = UploadedFile::getInstance($model, 'file');

            if ($model->file && $model->validate()) {
                $productPriceCsvArray = array_map(function($data) { return str_getcsv($data,";");}, file($model->file->tempName));

                if(!$productPriceCsvArray || count($productPriceCsvArray[0]) != 6) {
                    $this->setFlash('error', "Format de fichier invalide. Veuillez vérifier que le séparateur de champs de votre fichier est bien \";\".");
                }
                else {
                    unset($productPriceCsvArray[0]);
                    $countUpdate = 0;
                    $countCreate = 0;
                    $cptLine = 1;
                    $dataNotFound = false;
                    $dataNotFoundArray = [];

                    foreach ($productPriceCsvArray as $productPriceCsv) {
                        $cptLine ++;
                        if (count($productPriceCsv) != 6) {
                            $dataNotFound = true;
                            continue;
                        }

                        $productName = $productPriceCsv[0];
                        $userArray = explode('#', $productPriceCsv[1]);
                        $userGroupName = $productPriceCsv[2];
                        $pointSaleName = $productPriceCsv[3];
                        $quantityFrom = (float)$productPriceCsv[4];
                        $price = (float)$productPriceCsv[5];

                        $product = $productName ? $productManager->findOneProductByName($productName) : null;
                        $user = (count($userArray) > 1) ? $userManager->findOneUserById((int)$userArray[1]) : null;
                        $userGroup = $userGroupName ? $userGroupManager->findOneUserGroupByName($userGroupName) : null;
                        $pointSale = $pointSaleName ? $pointSaleManager->findOnePointSaleByName($pointSaleName) : null;

                        if (($productName && !$product)
                            || (count($userArray) > 1 && !$user)
                            || ($userGroupName && !$userGroup)
                            || ($pointSaleName && !$pointSale)) {

                            $dataNotFound = true;
                            $dataNotFoundArray[] = $cptLine;
                            continue;
                        }

                        if ($product) {
                            // prix de base
                            if (!$user && !$userGroup && !$pointSale && !$quantityFrom) {
                                $product->price = $price;
                                $productManager->saveUpdate($product);
                                $countUpdate++;
                            } // prix spécifique
                            else {
                                $productPrice = $productPriceManager->findOneProductPriceBy($product, $user, $userGroup, $pointSale, $quantityFrom);
                                if ($productPrice) {
                                    $productPrice->price = $price;
                                    $productPriceManager->saveUpdate($productPrice);
                                    $countUpdate++;
                                }
                                // Création automatique du prix spécifique
                                else {
                                    $productPrice = $productPriceManager->instanciateProductPrice($product, $price, $user, $userGroup, $pointSale, $quantityFrom);
                                    $productPriceManager->saveCreate($productPrice);
                                    $countCreate ++;
                                }
                            }
                        }
                    }

                    if ($dataNotFound) {
                        $strLinesDataNotFound = '('.implode(', ', $dataNotFoundArray).')';
                        $this->addFlash('error', "Attention, certaines lignes ".$strLinesDataNotFound." du fichier n'ont pas été prises en compte. Veuillez réessayer en repartant du fichier d'export.<br />Contacter l'administrateur du site si le problème persiste.");
                    }

                    if ($countUpdate) {
                        $this->addFlash('success', $countUpdate . ' prix produits mis à jour.');
                    }

                    if($countCreate) {
                        $this->addFlash('success', $countCreate . ' prix produits créés.');
                    }
                }
            }
        }

        return $this->render('price_import', [
            'model' => $model
        ]);
    }

    /**
     * Export des prix produits au format CSV.
     *
     * @return mixed
     */
    public function actionPriceExport()
    {
        $productManager = $this->getProductManager();
        $productPriceManager = $this->getProductPriceManager();
        $userManager = $this->getUserManager();

        $data = [];

        $data[] = [
            "Produit",
            "Utilisateur",
            "Groupe d'utilisateur",
            "Point de vente",
            "À partir de la quantité",
            "Prix HT"
        ];

        $productArray = $productManager->findProducts();
        foreach($productArray as $product) {

            // prix produit
            $data[] = [
                $product->name,
                '',
                '',
                '',
                '',
                $product->price
            ];

            // prix spécifiques
            foreach($product->productPrice as $productPrice) {
                $productPrice = $productPriceManager->findOneProductPriceById($productPrice->id);

                if($productPrice->user || $productPrice->userGroup || $productPrice->pointSale || $productPrice->from_quantity) {
                    $data[] = [
                        $product->name,
                        $productPrice->user ? str_replace('#', '', $userManager->getUsername($productPrice->user)).' #'.$productPrice->user->id : '',
                        $productPrice->userGroup ? $productPrice->userGroup->name : '',
                        $productPrice->pointSale ? $productPrice->pointSale->name : '',
                            $productPrice->from_quantity ?? '',
                        $productPrice->price
                    ];
                }
            }
        }

        CSV::downloadSendHeaders('prix_produits.csv');
        echo CSV::array2csv($data);
        die();
    }

    /**
     * Recherche un produit en fonction de son ID.
     */
    protected function findModel(int $id)
    {
        $productManager = $this->getProductManager();

        if (($product = $productManager->findOneProductById($id)) !== null) {
            return $product;
        } else {
            throw new NotFoundHttpException('The requested page does not exist.');
        }
    }

    protected function findModelProductPrice($id)
    {
        $productPriceManager = $this->getProductPriceManager();
        if (($productPrice = $productPriceManager->findOneProductPriceById($id)) !== null) {
            return $productPrice;
        } else {
            throw new NotFoundHttpException('The requested page does not exist.');
        }
    }
}