strprfcrm/app/Http/Controllers/OrderController.php

<?php

namespace App\Http\Controllers;

use App\Http\Requests\CreteTtnRequest;
use App\Http\Requests\ExportScheduleRequest;
use App\Http\Requests\Order\StoreOrderRequest;
use App\Jobs\ExportOneOrderJob;
use App\Jobs\ExportOrdersJob;
use App\Jobs\ExportScheduleJob;
use App\Jobs\GenerateFilesPack;
use App\Jobs\GenerateHandoverPack;
use App\Jobs\GenerateInstallationPack;
use App\Jobs\GenerateTtnPack;
use App\Jobs\NotifyManagerChangeStatusJob;
use App\Jobs\NotifyManagerNewOrderJob;
use App\Models\Dictionary\Area;
use App\Models\Dictionary\District;
use App\Models\File;
use App\Models\MafOrder;
use App\Models\ObjectType;
use App\Models\Order;
use App\Models\OrderStatus;
use App\Models\OrderView;
use App\Models\ProductSKU;
use App\Models\Role;
use App\Models\Schedule;
use App\Models\Ttn;
use App\Models\User;
use App\Services\FileService;
use Illuminate\Http\RedirectResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Storage;
use Symfony\Component\HttpFoundation\StreamedResponse;
use ZipArchive;

class OrderController extends Controller
{
    protected array $data = [
        'active'    => 'orders',
        'title'     => 'Заказы',
        'id'        => 'orders',
        'header'    => [
            'id'                        => 'ID',
            'name'                      => 'Название',
            'user_name'                 => 'Менеджер',
            'district_name'             => 'Округ',
            'area_name'                 => 'Район',
            'object_address'            => 'Адрес объекта',
            'object_type_name'          => 'Тип объекта',
            'comment'                   => 'Комментарий',
            'installation_date'         => 'Дата выхода на монтаж',
            'ready_date'                => 'Дата готовности площадки',
            'brigadier_name'            => 'Бригадир',
            'order_status_name'         => 'Статус',
            'tg_group_name'             => 'Имя группы в ТГ',
            'tg_group_link'             => 'Ссылка на группу в ТГ',
            'products_with_count'       => 'МАФы',
            'ready_to_mount'            => 'Все МАФы на складе',
        ],
        'searchFields' => [
            'name',
            'user_name',
            'district_name',
            'area_name',
            'object_type_name',
            'comment',
            'object_address',
            'installation_date',
            'tg_group_name',
            'tg_group_link',
        ],
    ];

    public function __construct()
    {
        $this->data['districts'] = District::query()->get()->pluck('name', 'id');
        $this->data['areas'] = Area::query()->get()->pluck('name', 'id');
        $this->data['objectTypes'] = ObjectType::query()->get()->pluck('name', 'id');
        $this->data['orderStatuses'] =OrderStatus::query()->get()->pluck('name', 'id');
        $this->data['brigadiers'] = User::query()->where('role', Role::BRIGADIER)->get()->pluck('name', 'id');
        $this->data['users'] = User::query()->whereIn('role', [Role::MANAGER, Role::ADMIN])->get()->pluck('name', 'id');
    }


    /**
     * Display a listing of the resource.
     */
    public function index(Request $request)
    {
        session(['gp_orders' => $request->all()]);
        $model = new OrderView;
        // fill filters
        $this->createFilters($model, 'user_name', 'district_name', 'area_name', 'object_type_name', 'brigadier_name', 'order_status_name', 'ready_to_mount');
        $this->createDateFilters($model, 'installation_date', 'ready_date');
        $this->data['ranges'] = [];

        $q = $model::query();

        $this->acceptFilters($q, $request);
        $this->acceptSearch($q, $request);
        $this->setSortAndOrderBy($model, $request);

        if(hasRole('brigadier')) {
            $q->where('brigadier_id', auth()->id());
        }

        $q->orderBy($this->data['sortBy'], $this->data['orderBy']);
        $this->data['orders'] = $q->paginate(session('per_page', config('pagination.per_page')))->withQueryString();

        foreach ($this->data['orders'] as $order) {
            Order::where('id', $order->id)->first()?->recalculateReadyToMount();
        }

        $this->data['statuses'] = OrderStatus::query()->get()->pluck('name', 'id');

        return view('orders.index', $this->data);
    }

    /**
     * Show the form for creating a new resource.
     */
    public function create(Request $request)
    {
        $this->data['previous_url'] = $this->resolvePreviousUrl(
            $request,
            'previous_url_orders',
            route('order.index', session('gp_orders'))
        );
        return view('orders.edit', $this->data);
    }

    /**
     * Store a newly created resource in storage.
     */
    public function store(StoreOrderRequest $request)
    {
        $data = $request->validated();

        $products = $request->validated('products');
        $quantities = $request->validated('quantity');

        unset($data['products']);

        if(isset($data['id'])) {
            $order = Order::query()->where('id', $data['id'])->first();
            $status = $order->order_status_id;
            $order->update($data);
            $order->refresh();
            if($order->order_status_id != $status) {
                NotifyManagerChangeStatusJob::dispatch($order);
            }
        } else {
            $data['order_status_id'] = Order::STATUS_NEW;
            $order = Order::query()->create($data);
            $tg_group_name = '/' . $order->district->shortname
                . ' ' . $order->object_address
                . ' (' . $order->area->name . ')'
                . ' - ' . $order->user->name;
            $order->update(['tg_group_name' => $tg_group_name]);
            NotifyManagerNewOrderJob::dispatch($order);
        }

        // меняем список товаров заказа только если статус новый
        if($products && $quantities && ($order->order_status_id == 1)) {
            // remove from products_sku
            ProductSKU::query()->where('order_id', $order->id)->delete();
            foreach ($products as $key => $product) {
                for($i = 0; $i < $quantities[$key]; $i++) {
                    ProductSKU::query()->create([
                        'order_id' => $order->id,
                        'product_id' => $product,
                        'status' => 'требуется'
                    ]);
                }
            }
        }

        $order->refresh();
        $order->autoChangeStatus();

        return redirect()->route('order.show', ['order' => $order, 'previous_url' => $request->get('previous_url')]);
    }

    /**
     * Display the specified resource.
     */
    public function show(Request $request, int $order)
    {
        $this->data['order'] = Order::query()->withoutGlobalScopes()->find($order);
        $this->data['previous_url'] = $this->resolvePreviousUrl(
            $request,
            'previous_url_orders',
            route('order.index', session('gp_orders'))
        );
        return view('orders.show', $this->data);
    }

    /**
     * Show the form for editing the specified resource.
     */
    public function edit(Request $request, Order $order)
    {
        $this->data['order'] = $order;
        $this->data['previous_url'] = $this->resolvePreviousUrl(
            $request,
            'previous_url_orders',
            route('order.index', session('gp_orders'))
        );
        return view('orders.edit', $this->data);
    }

    /**
     * Привязка товаров к заказу
     * @param Order $order
     * @return RedirectResponse
     */
    public function getMafToOrder(Order $order)
    {
        foreach ($order->products_sku as $product_sku) {
            // dont connect maf to order if already connected
            if($product_sku->maf_order) {
                continue;
            }

            $mafOrder = MafOrder::query()
                ->where('product_id', $product_sku->product_id)
                ->where('in_stock', '>' , 0)
                ->orderBy('created_at')
                ->first();
            $product_sku->update(['maf_order_id' => $mafOrder->id, 'status' => 'отгружен']);
            $mafOrder->decrement('in_stock');
            unset($mafOrder, $product_sku);
        }
        $order->autoChangeStatus();
        return redirect()->route('order.show', $order);
    }

    /**
     * @param Order $order
     * @return RedirectResponse
     */
    public function destroy(Order $order)
    {
        Order::query()->where('id', $order->id)->delete();
        ProductSKU::query()->where('order_id', $order->id)->delete();
        return redirect()->route('order.index', session('gp_orders'));
    }

    public function revertMaf(Order $order)
    {
        foreach ($order->products_sku as $maf) {
            MafOrder::query()->where('id', $maf->maf_order_id)->increment('in_stock');
            $maf->update(['maf_order_id' => null, 'status' => 'требуется']);
        }

        return redirect()->route('order.show', $order);
    }

    public function moveMaf(Request $request)
    {
        $data = $request->validate([
            'new_order_id' => 'required',
            'ids' => 'required|json',
        ]);

        $ids = json_decode($data['ids'], true);
        $updated = [];
        foreach ($ids as $mafId) {
            $maf = ProductSKU::query()
                ->where('id', $mafId)
                ->first();
            if($maf) {
                $comment = $maf->comment . "\n" . date('Y-m-d H:i') . ' Перенесено с площадки: ' . $maf->order->common_name;
                $maf->update(['order_id' => $data['new_order_id'], 'comment' => $comment]);
                $updated[] = $maf;
            }
        }
        return response()->json(['success' => true]);
    }

    public function search(Request $request): array
    {
        $ret = [];
        $s = $request->get('s');
        $searchFields = $this->data['searchFields'];
        $result = Order::query();
        if($s) {
            $result->where(function ($query) use ($searchFields, $s) {
                foreach ($searchFields as $searchField) {
                    $query->orWhere($searchField, 'LIKE', '%' . $s . '%');
                }
            });
        }

        $result->orderBy('object_address');
        foreach ($result->get() as $p) {
            $ret[$p->id] = $p->common_name;
        }
        return $ret;
    }

    public function uploadPhoto(Request $request, Order $order, FileService $fileService)
    {
        $data = $request->validate([
            'photo.*' => 'mimes:jpeg,jpg,png',
        ]);
        $f = [];
        foreach ($data['photo'] as $photo) {
            $f[] = $fileService->saveUploadedFile( 'orders/' . $order->id . '/photo', $photo);
        }
        $order->photos()->syncWithoutDetaching($f);

        return redirect()->route('order.show', $order);
    }

    public function deletePhoto(Order $order, File $file, FileService $fileService)
    {
        $order->photos()->detach($file);
        Storage::disk('public')->delete($file->path);
        $file->delete();
        return redirect()->route('order.show', $order);
    }

    public function deleteAllPhotos(Order $order)
    {
        $files = $order->photos;
        $order->photos()->detach();
        foreach ($files as $file) {
            Storage::disk('public')->delete($file->path);
            $file->delete();
        }
        return redirect()->route('order.show', $order);
    }

    public function uploadDocument(Request $request, Order $order, FileService $fileService)
    {
        $data = $request->validate([
            'document.*'    => 'file',
        ]);
        $f = [];
        $i = 0;
        foreach ($data['document'] as $document) {
            if($i++ >= 5) break;
            $f[] = $fileService->saveUploadedFile( 'orders/' . $order->id . '/document', $document);
        }
        $order->documents()->syncWithoutDetaching($f);

        return redirect()->route('order.show', $order);
    }

    public function deleteDocument(Order $order, File $file)
    {
        $order->documents()->detach($file);
        Storage::disk('public')->delete($file->path);
        $file->delete();
        return redirect()->route('order.show', $order);
    }

    public function deleteAllDocuments(Order $order)
    {
        $files = $order->documents;
        $order->documents()->detach();
        foreach ($files as $file) {
            Storage::disk('public')->delete($file->path);
            $file->delete();
        }
        return redirect()->route('order.show', $order);
    }

    public function uploadStatement(Request $request, Order $order, FileService $fileService)
    {
        $data = $request->validate([
            'statement.*'   => 'file',
        ]);
        $f = [];
        $i = 0;
        foreach ($data['statement'] as $statement) {
            if($i++ >= 5) break;
            $f[] = $fileService->saveUploadedFile( 'orders/' . $order->id . '/statement', $statement);
        }
        $order->statements()->syncWithoutDetaching($f);

        return redirect()->route('order.show', $order);
    }

    public function deleteStatement(Order $order, File $file)
    {
        $order->statements()->detach($file);
        Storage::disk('public')->delete($file->path);
        $file->delete();
        return redirect()->route('order.show', $order);
    }

    public function deleteAllStatements(Order $order)
    {
        $files = $order->statements;
        $order->statements()->detach();
        foreach ($files as $file) {
            Storage::disk('public')->delete($file->path);
            $file->delete();
        }
        return redirect()->route('order.show', $order);
    }

    public function generateInstallationPack(Order $order)
    {
        $errors = [];
        if(!in_array($order->order_status_id, [Order::STATUS_READY_TO_MOUNT, Order::STATUS_IN_MOUNT]))
            $errors[] = 'Статус должен быть "Готов к монтажу" или "В монтаже"!';
        $errors = array_merge($errors, $order->isAllMafConnected());
        if($errors) {
            return redirect()->route('order.show', $order)->with(['danger' => $errors]);
        }

        GenerateInstallationPack::dispatch($order, auth()->user()->id);
        return redirect()->route('order.show', $order)->with(['success' => 'Задача генерации документов создана!']);
    }

    public function generateHandoverPack(Order $order)
    {
        if($errors = $order->canCreateHandover()) {
            return redirect()->route('order.show', $order)->with(['danger' => $errors]);
        }
        GenerateHandoverPack::dispatch($order, auth()->user()->id);
        return redirect()->route('order.show', $order)->with(['success' => 'Задача генерации документов создана!']);
    }

    public function generatePhotosPack(Order $order)
    {
        GenerateFilesPack::dispatch($order, $order->photos, auth()->user()->id, 'Фото');
        return redirect()->back()->with(['success' => 'Задача архивации создана!']);
    }

    public function createTtn(CreteTtnRequest $request)
    {
        $ttn = Ttn::query()->create([
            'year' => date('Y'),
            'ttn_number'    => Ttn::getTtnNumber() + 1,
            'ttn_number_suffix' => 'И',
            'order_number'  => $request->order_number,
            'order_date'    => $request->order_date,
            'order_sum'     => $request->order_sum,
            'skus'          => json_encode($request->skus),
        ]);
        GenerateTtnPack::dispatch($ttn, auth()->user()->id);
        return redirect()->back()->with(['success' => 'Задача формирования ТН создана!']);
    }

    public function export(Request $request)
    {

        $schedules = Order::query()
            ->get();

        ExportOrdersJob::dispatch($schedules, $request->user()->id);
        return redirect()->route('order.index')
            ->with(['success' => 'Задача выгрузки создана!']);

    }
    public function exportOne(Order $order, Request $request)
    {

        ExportOneOrderJob::dispatch($order, $request->user()->id);
        return redirect()->route('order.show', $order->id)
            ->with(['success' => 'Задача выгрузки создана!']);

    }

    public function downloadTechDocs(Order $order): StreamedResponse
    {
        $techDocsPath = base_path('tech-docs');
        $articles = $order->products_sku
            ->pluck('product.article')
            ->unique()
            ->filter()
            ->values();

        if ($articles->isEmpty()) {
            abort(404, 'Нет МАФов на площадке');
        }

        $archiveName = 'Тех.документация - ' . fileName($order->object_address) . '.zip';

        return response()->streamDownload(function () use ($techDocsPath, $articles) {
            $zip = new ZipArchive();
            $tempFile = tempnam(storage_path('app/temp/'), 'tech_docs_');
            $zip->open($tempFile, ZipArchive::CREATE | ZipArchive::OVERWRITE);

            $filesAdded = 0;
            foreach ($articles as $article) {
                $articlePath = $techDocsPath . '/' . $article;
                if (!is_dir($articlePath)) {
                    continue;
                }

                $files = new \RecursiveIteratorIterator(
                    new \RecursiveDirectoryIterator($articlePath, \RecursiveDirectoryIterator::SKIP_DOTS),
                    \RecursiveIteratorIterator::LEAVES_ONLY
                );

                foreach ($files as $file) {
                    if ($file->isFile()) {
                        $relativePath = $article . '/' . $file->getFilename();
                        $zip->addFile($file->getRealPath(), $relativePath);
                        $filesAdded++;
                    }
                }
            }

            if(!$filesAdded) {
                $zip->addFromString('readme.txt', 'Нет документации для этих МАФ!');
            }

            $zip->close();

            readfile($tempFile);
            unlink($tempFile);

        }, $archiveName, [
            'Content-Type' => 'application/zip',
        ]);
    }

}