MarketingController.php 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Http\Controllers\Controller;
  4. use App\Models\Marketing;
  5. use DB;
  6. use Exception;
  7. use Http;
  8. use Illuminate\Http\JsonResponse;
  9. use Illuminate\Http\Request;
  10. use Log;
  11. use Response;
  12. use RuntimeException;
  13. /**
  14. * 促销控制器.
  15. *
  16. * Class MarketingController
  17. */
  18. class MarketingController extends Controller
  19. {
  20. // 邮件群发消息列表
  21. public function emailList(Request $request)
  22. {
  23. $status = $request->input('status');
  24. $query = Marketing::whereType(1);
  25. if (isset($status)) {
  26. $query->whereStatus($status);
  27. }
  28. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  29. return view('admin.marketing.emailList', $view);
  30. }
  31. // 消息通道群发列表
  32. public function pushList(Request $request)
  33. {
  34. $status = $request->input('status');
  35. $query = Marketing::whereType(2);
  36. if (isset($status)) {
  37. $query->whereStatus($status);
  38. }
  39. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  40. return view('admin.marketing.pushList', $view);
  41. }
  42. // 添加推送消息
  43. public function addPushMarketing(Request $request): ?JsonResponse
  44. {
  45. $title = $request->input('title');
  46. $content = $request->input('content');
  47. if (! sysConfig('is_push_bear')) {
  48. return Response::json(['status' => 'fail', 'message' => '推送失败:请先启用并配置PushBear']);
  49. }
  50. try {
  51. DB::beginTransaction();
  52. $response = Http::timeout(15)->get('https://pushbear.ftqq.com/sub', [
  53. 'sendkey' => sysConfig('push_bear_send_key'),
  54. 'text' => $title,
  55. 'desp' => $content,
  56. ]);
  57. $message = $response->json();
  58. if (! $message || ! $message['code'] === 0 || $response->failed()) { // 失败
  59. $this->addMarketing(2, $title, $content, -1, $message['message']);
  60. throw new RuntimeException($message['message']);
  61. }
  62. $this->addMarketing(2, $title, $content, 1);
  63. DB::commit();
  64. return Response::json(['status' => 'success', 'message' => '推送成功']);
  65. } catch (Exception $e) {
  66. Log::error('PushBear消息推送失败:'.$e->getMessage());
  67. DB::rollBack();
  68. return Response::json(['status' => 'fail', 'message' => '推送失败:'.$e->getMessage()]);
  69. }
  70. }
  71. private function addMarketing($type = 1, $title = '', $content = '', $status = 1, $error = '', $receiver = ''): bool
  72. {
  73. $marketing = new Marketing();
  74. $marketing->type = $type;
  75. $marketing->receiver = $receiver;
  76. $marketing->title = $title;
  77. $marketing->content = $content;
  78. $marketing->error = $error;
  79. $marketing->status = $status;
  80. return $marketing->save();
  81. }
  82. }