MarketingController.php 2.6 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 GuzzleHttp\Client;
  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. * @package App\Http\Controllers\Controller
  19. */
  20. class MarketingController extends Controller {
  21. // 邮件群发消息列表
  22. public function emailList(Request $request) {
  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. $status = $request->input('status');
  34. $query = Marketing::whereType(2);
  35. if(isset($status)){
  36. $query->whereStatus($status);
  37. }
  38. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  39. return view('admin.marketing.pushList', $view);
  40. }
  41. // 添加推送消息
  42. public function addPushMarketing(Request $request): ?JsonResponse {
  43. $title = $request->input('title');
  44. $content = $request->input('content');
  45. if(!sysConfig('is_push_bear')){
  46. return Response::json(['status' => 'fail', 'message' => '推送失败:请先启用并配置PushBear']);
  47. }
  48. try{
  49. DB::beginTransaction();
  50. $response = (new Client())->get('https://pushbear.ftqq.com/sub', [
  51. 'query' => [
  52. 'sendkey' => sysConfig('push_bear_send_key'),
  53. 'text' => $title,
  54. 'desp' => $content
  55. ]
  56. ]);
  57. $result = json_decode($response->getBody(), true);
  58. if($result->code){ // 失败
  59. $this->addMarketing(2, $title, $content, -1, $result->message);
  60. throw new RuntimeException($result->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 = ''
  72. ): bool {
  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. }