neiyou_user_web/app/Http/Controllers/Admin/MarketingController.php

<?php

namespace App\Http\Controllers\Admin;

use App\Http\Controllers\Controller;
use App\Models\Marketing;
use DB;
use Exception;
use GuzzleHttp\Client;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Log;
use Response;
use RuntimeException;

/**
 * 促销控制器
 *
 * Class MarketingController
 *
 * @package App\Http\Controllers\Controller
 */
class MarketingController extends Controller
{

    // 邮件群发消息列表
    public function emailList(Request $request)
    {
        $status = $request->input('status');

        $query = Marketing::whereType(1);

        if (isset($status)) {
            $query->whereStatus($status);
        }

        $view['list'] = $query->paginate(15)->appends($request->except('page'));

        return view('admin.marketing.emailList', $view);
    }

    // 消息通道群发列表
    public function pushList(Request $request)
    {
        $status = $request->input('status');

        $query = Marketing::whereType(2);

        if (isset($status)) {
            $query->whereStatus($status);
        }

        $view['list'] = $query->paginate(15)->appends($request->except('page'));

        return view('admin.marketing.pushList', $view);
    }

    // 添加推送消息
    public function addPushMarketing(Request $request): ?JsonResponse
    {
        $title   = $request->input('title');
        $content = $request->input('content');

        if ( ! sysConfig('is_push_bear')) {
            return Response::json(
                ['status' => 'fail', 'message' => '推送失败：请先启用并配置PushBear']
            );
        }

        try {
            DB::beginTransaction();

            $response = (new Client())->get(
                'https://pushbear.ftqq.com/sub',
                [
                    'query' => [
                        'sendkey' => sysConfig('push_bear_send_key'),
                        'text'    => $title,
                        'desp'    => $content,
                    ],
                ]
            );

            $result = json_decode($response->getBody(), true);
            if ($result->code) { // 失败
                $this->addMarketing(2, $title, $content, -1, $result->message);

                throw new RuntimeException($result->message);
            }

            $this->addMarketing(2, $title, $content, 1);

            DB::commit();

            return Response::json(['status' => 'success', 'message' => '推送成功']);
        } catch (Exception $e) {
            Log::error('PushBear消息推送失败：' . $e->getMessage());

            DB::rollBack();

            return Response::json(
                ['status' => 'fail', 'message' => '推送失败：' . $e->getMessage()]
            );
        }
    }

    private function addMarketing(
        $type = 1,
        $title = '',
        $content = '',
        $status = 1,
        $error = '',
        $receiver = ''
    ): bool {
        $marketing           = new Marketing();
        $marketing->type     = $type;
        $marketing->receiver = $receiver;
        $marketing->title    = $title;
        $marketing->content  = $content;
        $marketing->error    = $error;
        $marketing->status   = $status;

        return $marketing->save();
    }

}