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();
    }
}