관리-도구

편집 파일: SendingServerController.php

<?php

namespace App\Http\Controllers\Admin;

use App\Http\Requests\SendingServer\StoreCustomServer;
use App\Http\Requests\SendingServer\StoreSendingServerRequest;
use App\Models\CustomSendingServer;
use App\Models\SendingServer;
use App\Repositories\Contracts\SendingServerRepository;
use Generator;
use Illuminate\Auth\Access\AuthorizationException;
use Illuminate\Contracts\Foundation\Application as ApplicationAlias;
use Illuminate\Contracts\View\Factory;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\RedirectResponse;
use Illuminate\Http\Request;
use Illuminate\View\View;
use JetBrains\PhpStorm\NoReturn;
use OpenSpout\Common\Exception\InvalidArgumentException;
use OpenSpout\Common\Exception\IOException;
use OpenSpout\Common\Exception\UnsupportedTypeException;
use OpenSpout\Writer\Exception\WriterNotOpenedException;
use Rap2hpoutre\FastExcel\FastExcel;
use Symfony\Component\HttpFoundation\BinaryFileResponse;

class SendingServerController extends AdminBaseController
{
    protected SendingServerRepository $sendingServers;

/**
     * SendingServerController constructor.
     *
     * @param  SendingServerRepository  $sendingServers
     */

public function __construct(SendingServerRepository $sendingServers)
    {
        $this->sendingServers = $sendingServers;
    }

/**
     * @return ApplicationAlias|Factory|View
     * @throws AuthorizationException
     */

public function index(): Factory|View|ApplicationAlias
    {

$this->authorize('view sending_servers');

$breadcrumbs = [
                [
                        'link' => url(config('app.admin_path')."/dashboard"),
                        'name' => __('locale.menu.Dashboard'),
                ],
                [
                        'link' => url(config('app.admin_path')."/dashboard"),
                        'name' => __('locale.menu.Sending'),
                ],
                ['name' => __('locale.menu.Sending Servers')],
        ];

return view('admin.SendingServer.index', compact('breadcrumbs'));
    }

/**
     * @param  Request  $request
     *
     * @return void
     * @throws AuthorizationException
     */
    #[NoReturn] public function search(Request $request): void
    {

$this->authorize('view sending_servers');

$columns = [
                0 => 'responsive_id',
                1 => 'uid',
                2 => 'uid',
                3 => 'name',
                4 => 'type',
                5 => 'quota_value',
                6 => 'status',
                7 => 'action',
        ];

$totalData = SendingServer::count();

$totalFiltered = $totalData;

$limit = $request->input('length');
        $start = $request->input('start');
        $order = $columns[$request->input('order.0.column')];
        $dir   = $request->input('order.0.dir');

if (empty($request->input('search.value'))) {
            $sending_servers = SendingServer::limit($limit)
                                            ->offset($start)
                                            ->orderBy($order, $dir)
                                            ->get();
        } else {
            $search = $request->input('search.value');

$sending_servers = SendingServer::whereLike(['uid', 'name', 'type'], $search)
                                            ->limit($limit)
                                            ->orderBy($order, $dir)
                                            ->get();

$totalFiltered = SendingServer::whereLike(['uid', 'name', 'type'], $search)
                                          ->count();
        }

$data = [];
        if ( ! empty($sending_servers)) {
            foreach ($sending_servers as $sending_server) {
                $show = route('admin.sending-servers.show', $sending_server->uid);

if ($sending_server->status === true) {
                    $status = 'checked';
                } else {
                    $status = '';
                }

$color = match ($sending_server->type) {
                    'smpp'     => 'secondary',
                    'viber'    => 'primary',
                    'otp'      => 'warning',
                    'whatsapp' => 'info',
                    default    => 'success'
                };

if ($sending_server->settings == 'Whatsender') {
                    $nestedData['devices'] = route('admin.sending-servers.devices', $sending_server->uid);
                }
                $nestedData['settings'] = $sending_server->settings;

$nestedData['responsive_id'] = '';
                $nestedData['uid']           = $sending_server->uid;
                $nestedData['name']          = $sending_server->name;
                $nestedData['type']          = "<span class='badge text-uppercase bg-$color'>$sending_server->type</span>";
                $nestedData['quota_value']   = "<div> <p class='text-capitalize'>"
                        .__('locale.sending_servers.sending_limit')
                        ." <span class='text-danger'>$sending_server->quota_value </span> "
                        .__('locale.sending_servers.per')
                        ." <span class='text-info'> $sending_server->quota_base $sending_server->quota_unit</span></p>  </div>";

$nestedData['status'] = "<div class='form-check form-switch form-check-primary'>
                <input type='checkbox' class='form-check-input get_status' id='status_$sending_server->uid' data-id='$sending_server->uid' name='status' $status>
                <label class='form-check-label' for='status_$sending_server->uid'>
                  <span class='switch-icon-left'><i data-feather='check'></i> </span>
                  <span class='switch-icon-right'><i data-feather='x'></i> </span>
                </label>
              </div>";

$nestedData['edit'] = $show;
                $data[]             = $nestedData;

}
        }

$json_data = [
                "draw"            => intval($request->input('draw')),
                "recordsTotal"    => $totalData,
                "recordsFiltered" => $totalFiltered,
                "data"            => $data,
        ];

echo json_encode($json_data);
        exit();

}

/**
     * Get all sending servers
     *
     * @return ApplicationAlias|Factory|View
     *
     * @throws AuthorizationException
     */

public function select(): Factory|View|ApplicationAlias
    {

$this->authorize('create sending_servers');

$breadcrumbs = [
                [
                        'link' => url(config('app.admin_path')."/dashboard"),
                        'name' => __('locale.menu.Dashboard'),
                ],
                [
                        'link' => url(config('app.admin_path')."/sending-servers"),
                        'name' => __('locale.menu.Sending Servers'),
                ],
                [
                        'name' => __('locale.sending_servers.select_sending_server'),
                ],
        ];

$sending_servers = $this->sendingServers->allSendingServer();

return view('admin.SendingServer.list', compact('breadcrumbs', 'sending_servers'));
    }

/**
     * Create New Server
     *
     * @param $type
     *
     * @return ApplicationAlias|Factory|View
     *
     * @throws AuthorizationException
     */

protected function create($type): Factory|View|ApplicationAlias
    {

$this->authorize('create sending_servers');

$breadcrumbs = [
                [
                        'link' => url(config('app.admin_path')."/dashboard"),
                        'name' => __('locale.menu.Dashboard'),
                ],
                [
                        'link' => url(config('app.admin_path')."/sending-servers"),
                        'name' => __('locale.menu.Sending Servers'),
                ],
                [
                        'link' => url(config('app.admin_path')."/sending-servers/select"),
                        'name' => __('locale.sending_servers.select_sending_server'),
                ],
        ];

if ($type == 'custom') {

$breadcrumbs[] = [
                    'name' => __('locale.sending_servers.create_own_server'),
            ];

return view('admin.SendingServer.create_custom', compact('breadcrumbs'));
        }

$server = $this->sendingServers->allSendingServer()[$type];

$breadcrumbs[] = ['name' => $server['name']];

return view('admin.SendingServer.create', compact('server', 'breadcrumbs'));

}

/**
     * Store Sending Server
     *
     * @param  StoreSendingServerRequest  $request
     *
     * @return RedirectResponse
     *
     * @throws AuthorizationException
     */
    public function store(StoreSendingServerRequest $request): RedirectResponse
    {

if (config('app.stage') == 'demo') {
            return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => 'Sorry! This option is not available in demo mode',
            ]);
        }

$this->authorize('create sending_servers');

$this->sendingServers->store($request->input());

return redirect()->route('admin.sending-servers.index')->with([
                'status'  => 'success',
                'message' => __('locale.sending_servers.sending_server_successfully_added'),
        ]);
    }

/**
     * Show existing sending server
     *
     * @param  SendingServer  $server
     *
     * @return ApplicationAlias|Factory|RedirectResponse|View
     * @throws AuthorizationException
     */

public function show(SendingServer $server): Factory|View|RedirectResponse|ApplicationAlias
    {
        $this->authorize('edit sending_servers');

$server = $server->toArray();
        if ( ! is_array($server)) {
            return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => __('locale.sending_servers.sending_server_not_found'),
            ]);
        }

if ($server['custom']) {

$custom_info = CustomSendingServer::where('server_id', $server['id'])->first();

if ($custom_info) {
                $breadcrumbs[] = [
                        'name' => __('locale.sending_servers.create_own_server'),
                ];

$data = $custom_info->toArray();

return view('admin.SendingServer.edit_custom', compact('server', 'data', 'breadcrumbs'));
            }

return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => __('locale.sending_servers.sending_server_not_found'),
            ]);
        }

$breadcrumbs[] = ['name' => $server['name']];

return view('admin.SendingServer.create', compact('server', 'breadcrumbs'));
    }

/**
     * Update existing sending server
     *
     * @param  SendingServer  $sendingServer
     * @param  StoreSendingServerRequest  $request
     *
     * @return RedirectResponse
     * @throws AuthorizationException
     */

public function update(SendingServer $sendingServer, StoreSendingServerRequest $request): RedirectResponse
    {

$this->authorize('edit sending_servers');

$this->sendingServers->update($sendingServer, $request->input());

return redirect()->route('admin.sending-servers.index')->with([
                'status'  => 'success',
                'message' => __('locale.sending_servers.sending_server_successfully_updated'),
        ]);
    }

/**
     * Add Customer Server
     *
     * @param  StoreCustomServer  $request
     *
     * @return RedirectResponse
     * @throws AuthorizationException
     */

public function addCustomServer(StoreCustomServer $request): RedirectResponse
    {
        if (config('app.stage') == 'demo') {
            return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => 'Sorry! This option is not available in demo mode',
            ]);
        }

$this->authorize('create sending_servers');

$this->sendingServers->storeCustom($request->input());

/**
     * Update existing sending server
     *
     * @param  SendingServer  $sendingServer
     * @param  StoreCustomServer  $request
     *
     * @return RedirectResponse
     * @throws AuthorizationException
     */

public function updateCustomServer(SendingServer $sendingServer, StoreCustomServer $request): RedirectResponse
    {
        if (config('app.stage') == 'demo') {
            return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => 'Sorry! This option is not available in demo mode',
            ]);
        }

$this->authorize('edit sending_servers');

$this->sendingServers->updateCustom($sendingServer, $request->input());

/**
     * change sending server status
     *
     * @param  SendingServer  $server
     *
     * @return JsonResponse
     * @throws AuthorizationException
     */

public function activeToggle(SendingServer $server): JsonResponse
    {

if (config('app.stage') == 'demo') {

return response()->json([
                    'status'  => 'error',
                    'message' => 'Sorry! This option is not available in demo mode',
            ]);
        }

$this->authorize('edit sending_servers');

$server->update(['status' => ! $server->status]);

return response()->json([
                'status'  => 'success',
                'message' => __('locale.sending_servers.sending_server_successfully_change'),
        ]);

}

/**
     * Delete sending server
     *
     * @param  SendingServer  $sendingServer
     *
     * @return JsonResponse
     * @throws AuthorizationException
     */
    public function destroy(SendingServer $sendingServer): JsonResponse
    {

if (config('app.stage') == 'demo') {

return response()->json([
                    'status'  => 'error',
                    'message' => 'Sorry! This option is not available in demo mode',
            ]);
        }

$this->authorize('delete sending_servers');

$this->sendingServers->destroy($sendingServer);

return response()->json([
                'status'  => 'success',
                'message' => __('locale.sending_servers.sending_server_successfully_deleted'),
        ]);

}

/**
     * Bulk Action with Enable, Disable and Delete
     *
     * @param  Request  $request
     *
     * @return JsonResponse
     * @throws AuthorizationException
     */

public function batchAction(Request $request): JsonResponse
    {

if (config('app.stage') == 'demo') {

return response()->json([
                    'status'  => 'error',
                    'message' => 'Sorry! This option is not available in demo mode',
            ]);
        }

$action = $request->get('action');
        $ids    = $request->get('ids');

switch ($action) {
            case 'destroy':
                $this->authorize('delete sending_servers');

$this->sendingServers->batchDestroy($ids);

return response()->json([
                        'status'  => 'success',
                        'message' => __('locale.sending_servers.sending_servers_deleted'),
                ]);

case 'enable':
                $this->authorize('edit sending_servers');

$this->sendingServers->batchActive($ids);

return response()->json([
                        'status'  => 'success',
                        'message' => __('locale.sending_servers.sending_servers_enabled'),
                ]);

case 'disable':

$this->authorize('edit sending_servers');

$this->sendingServers->batchDisable($ids);

return response()->json([
                        'status'  => 'success',
                        'message' => __('locale.sending_servers.sending_servers_disabled'),
                ]);
        }

return response()->json([
                'status'  => 'error',
                'message' => __('locale.exceptions.invalid_action'),
        ]);

}

/**
     *
     * @return Generator
     */

public function sendingServerGenerator(): Generator
    {
        foreach (SendingServer::cursor() as $sendingServer) {
            yield $sendingServer;
        }
    }

/**
     * @return RedirectResponse|BinaryFileResponse
     * @throws AuthorizationException
     */
    public function export(): BinaryFileResponse|RedirectResponse
    {
        if (config('app.stage') == 'demo') {
            return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => 'Sorry! This option is not available in demo mode',
            ]);
        }

$this->authorize('view sending_servers');

try {
            $file_name = (new FastExcel($this->sendingServerGenerator()))->export(storage_path('SendingServers_'.time().'.xlsx'));

return response()->download($file_name);

} catch (IOException|InvalidArgumentException|UnsupportedTypeException|WriterNotOpenedException $e) {
            return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => $e->getMessage(),
            ]);
        }
    }

/*
    |--------------------------------------------------------------------------
    | For WhatSender Only
    |--------------------------------------------------------------------------
    |
    | This Controller only contains whatsender info
    |
    */

/**
     * Show existing device details
     *
     * @param  SendingServer  $server
     *
     * @return ApplicationAlias|Factory|RedirectResponse|View
     * @throws AuthorizationException
     */

public function devices(SendingServer $server)
    {
        $this->authorize('edit sending_servers');

$breadcrumbs[] = ['name' => $server['name']];

$ch = curl_init();

curl_setopt_array($ch, [
                CURLOPT_URL            => "https://api.whatsender.io/v1/devices/".$server['device_id'],
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_ENCODING       => "",
                CURLOPT_MAXREDIRS      => 10,
                CURLOPT_TIMEOUT        => 30,
                CURLOPT_HTTP_VERSION   => CURL_HTTP_VERSION_1_1,
                CURLOPT_CUSTOMREQUEST  => "GET",
                CURLOPT_HTTPHEADER     => [
                        "Token: ".$server['api_token'],
                ],
        ]);

$response = curl_exec($ch);
        $err      = curl_error($ch);

curl_close($ch);

if ($err) {
            return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => $err,
            ]);
        }

$device = json_decode($response, true);

if (is_array($device) && array_key_exists('status', $device)) {
            if ($device['status'] == 'operative') {
                return view('admin.SendingServer.device_details', compact('server', 'breadcrumbs', 'device'));
            }

return redirect()->route('admin.sending-servers.index')->with([
                    'status'  => 'error',
                    'message' => $device['message'],
            ]);
        }

return redirect()->route('admin.sending-servers.index')->with([
                'status'  => 'error',
                'message' => 'Device not found',
        ]);

}

/**
     * reboot session
     *
     * @param  SendingServer  $server
     *
     * @return JsonResponse
     */
    public function reboot(SendingServer $server): JsonResponse
    {

$ch = curl_init();

curl_setopt_array($ch, [
                CURLOPT_URL            => "https://api.whatsender.io/v1/devices/".$server['device_id']."/reboot",
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_ENCODING       => "",
                CURLOPT_MAXREDIRS      => 10,
                CURLOPT_TIMEOUT        => 30,
                CURLOPT_HTTP_VERSION   => CURL_HTTP_VERSION_1_1,
                CURLOPT_CUSTOMREQUEST  => "POST",
                CURLOPT_POSTFIELDS     => json_encode(['wait' => true]),
                CURLOPT_HTTPHEADER     => [
                        "Content-Type: application/json",
                        "Token: ".$server['api_token'],
                ],
        ]);

$response = curl_exec($ch);
        $err      = curl_error($ch);

curl_close($ch);

if ($err) {
            return response()->json([
                    'status'  => 'success',
                    'message' => $err,
            ]);
        }

$reboot = json_decode($response, true);

if (is_array($reboot) && array_key_exists('status', $reboot)) {
            if ($reboot['status'] == 'operative') {
                return response()->json([
                        'status'  => 'success',
                        'message' => 'Session was successfully rebooted',
                ]);
            }

return response()->json([
                    'status'  => 'error',
                    'message' => $reboot['message'],
            ]);
        }

return response()->json([
                'status'  => 'error',
                'message' => 'Device info not found',
        ]);
    }

/**
     * reset sessions
     *
     * @param  SendingServer  $server
     *
     * @return JsonResponse
     */
    public function reset(SendingServer $server): JsonResponse
    {
        $ch = curl_init();

curl_setopt_array($ch, [
                CURLOPT_URL            => "https://api.whatsender.io/v1/devices/".$server['device_id']."/reset",
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_ENCODING       => "",
                CURLOPT_MAXREDIRS      => 10,
                CURLOPT_TIMEOUT        => 30,
                CURLOPT_HTTP_VERSION   => CURL_HTTP_VERSION_1_1,
                CURLOPT_CUSTOMREQUEST  => "POST",
                CURLOPT_POSTFIELDS     => json_encode([
                        'wait'       => 'false',
                        'emptyQueue' => 'true',
                ]),
                CURLOPT_HTTPHEADER     => [
                        "Content-Type: application/json",
                        "Token: ".$server['api_token'],
                ],
        ]);

$response = curl_exec($ch);
        $err      = curl_error($ch);

curl_close($ch);

if ($err) {
            return response()->json([
                    'status'  => 'success',
                    'message' => $err,
            ]);
        }

$reboot = json_decode($response, true);

return response()->json([
                    'status'  => 'error',
                    'message' => $reboot['message'],
            ]);
        }

return response()->json([
                'status'  => 'error',
                'message' => 'Device info not found',
        ]);
    }

/**
     * scan qr code
     *
     * @param  SendingServer  $server
     *
     * @return JsonResponse
     */
    public function scan(SendingServer $server): JsonResponse
    {

$ch = curl_init();

curl_setopt_array($ch, [
                CURLOPT_URL            => "https://api.whatsender.io/v1/devices/".$server['device_id']."/scan",
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_ENCODING       => "",
                CURLOPT_MAXREDIRS      => 10,
                CURLOPT_TIMEOUT        => 30,
                CURLOPT_HTTP_VERSION   => CURL_HTTP_VERSION_1_1,
                CURLOPT_CUSTOMREQUEST  => "GET",
                CURLOPT_HTTPHEADER     => [
                        "Token: ".$server['api_token'],
                ],
        ]);

$response = curl_exec($ch);
        $err      = curl_error($ch);

curl_close($ch);

if ($err) {
            return response()->json([
                    'status'  => 'success',
                    'message' => $err,
            ]);
        }

$data = json_decode($response);

if (json_last_error() != JSON_ERROR_NONE) {
            return response()->json([
                    'status' => 'success',
                    'image'  => $response,
            ]);
        }

return response()->json([
                'status'  => 'error',
                'message' => $data->message,
        ]);

}

/**
     * start new session
     *
     * @param  SendingServer  $server
     *
     * @return JsonResponse
     */
    public function start(SendingServer $server): JsonResponse
    {

$ch = curl_init();

curl_setopt_array($ch, [
                CURLOPT_URL            => "https://api.whatsender.io/v1/devices/".$server['device_id']."/start",
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_ENCODING       => "",
                CURLOPT_MAXREDIRS      => 10,
                CURLOPT_TIMEOUT        => 30,
                CURLOPT_HTTP_VERSION   => CURL_HTTP_VERSION_1_1,
                CURLOPT_CUSTOMREQUEST  => "POST",
                CURLOPT_POSTFIELDS     => json_encode([
                        'wait' => 'true',
                ]),
                CURLOPT_HTTPHEADER     => [
                        "Content-Type: application/json",
                        "Token: ".$server['api_token'],
                ],
        ]);

$response = curl_exec($ch);
        $err      = curl_error($ch);

curl_close($ch);

if ($err) {
            return response()->json([
                    'status'  => 'error',
                    'message' => $err,
            ]);
        }

$start = json_decode($response, true);

if (is_array($start) && array_key_exists('status', $start)) {
            if ($start['status'] == 'operative') {
                return response()->json([
                        'status'  => 'success',
                        'message' => 'Session was successfully started',
                ]);
            }

return response()->json([
                    'status'  => 'error',
                    'message' => $start['message'],
            ]);
        }

return response()->json([
                'status'  => 'error',
                'message' => 'Device info not found',
        ]);
    }

/**
     * sync the sessions
     *
     * @param  SendingServer  $server
     *
     * @return JsonResponse
     */
    public function sync(SendingServer $server): JsonResponse
    {

$ch = curl_init();

curl_setopt_array($ch, [
                CURLOPT_URL            => "https://api.whatsender.io/v1/devices/".$server['device_id']."/sync",
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_ENCODING       => "",
                CURLOPT_MAXREDIRS      => 10,
                CURLOPT_TIMEOUT        => 30,
                CURLOPT_HTTP_VERSION   => CURL_HTTP_VERSION_1_1,
                CURLOPT_CUSTOMREQUEST  => "GET",
                CURLOPT_HTTPHEADER     => [
                        "Token: ".$server['api_token'],
                ],
        ]);

$response = curl_exec($ch);
        $err      = curl_error($ch);

curl_close($ch);

if ($err) {
            return response()->json([
                    'status'  => 'success',
                    'message' => $err,
            ]);
        }

$sync = json_decode($response, true);

if (is_array($sync) && array_key_exists('status', $sync)) {
            return response()->json([
                    'status'  => 'success',
                    'message' => 'Device synchronized. Current session status: <b>'.ucfirst($sync['status'])."</b>",
            ]);
        }

return response()->json([
                'status'  => 'error',
                'message' => 'Device info not found',
        ]);
    }

}

Edulab LMS