<?php
/**
* Mirasvit
*
* This source file is subject to the Mirasvit Software License, which is available at https://mirasvit.com/license/.
* Do not edit or add to this file if you wish to upgrade the to newer versions in the future.
* If you wish to customize this module for your needs.
* Please refer to http://www.magentocommerce.com for more information.
*
* @category Mirasvit
* @package mirasvit/module-report
* @version 1.3.101
* @copyright Copyright (C) 2020 Mirasvit (https://mirasvit.com/)
*/



namespace Mirasvit\Report\Model\Export;

use Magento\Framework\App\Filesystem\DirectoryList;
use Magento\Framework\Filesystem;
use Mirasvit\ReportApi\Api\Processor\ResponseColumnInterface;
use Mirasvit\ReportApi\Api\Processor\ResponseItemInterface;
use Mirasvit\ReportApi\Api\ResponseInterface;

class ConvertToCsv
{
/**
* @var Filesystem\Directory\WriteInterface
*/
protected $directory;

/**
* ConvertToCsv constructor.
* @param Filesystem $filesystem
* @throws \Magento\Framework\Exception\FileSystemException
*/
public function __construct(
Filesystem $filesystem
) {
$this->directory = $filesystem->getDirectoryWrite(DirectoryList::VAR_DIR);
}

/**
* @param ResponseInterface $response
* @return array
* @throws \Magento\Framework\Exception\FileSystemException
*/
public function getCsvFile(ResponseInterface $response)
{
$name = hash('sha256', microtime());
$file = 'export/' . $name . '.csv';

$this->directory->create('export');
$stream = $this->directory->openFile($file, 'w+');
$stream->lock();

$header = [];
foreach ($response->getColumns() as $column) {
$header[] = $column->getLabel();
}
$stream->writeCsv($header);

foreach ($response->getItems() as $item) {
$this->writeItem($stream, $item, $response->getColumns());
}

$stream->writeCsv($response->getTotals()->getFormattedData());

$stream->unlock();
$stream->close();

return [
'type' => 'filename',
'value' => $file,
];
}

/**
* @param Filesystem\File\WriteInterface $stream
* @param ResponseItemInterface $item
* @param array $columns
* @throws \Magento\Framework\Exception\FileSystemException
*/
public function writeItem(Filesystem\File\WriteInterface $stream, ResponseItemInterface $item, array $columns)
{
$formattedData = $item->getFormattedData();

$data = [];
/** @var ResponseColumnInterface $column */
foreach ($columns as $column) {
$name = $column->getName();

if (isset($formattedData[$name])) {
$data[] = $formattedData[$name];
} else {
$data[] = '';
}
}

$stream->writeCsv($data);

foreach ($item->getItems() as $subItem) {
$this->writeItem($stream, $subItem, $columns);
}
}
}