MarketingController.php 2.9 KB

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