MonitorBotController.php 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112
  1. <?php
  2. namespace App\Http\Controllers\Admin\Monitor;
  3. use Illuminate\Http\Request;
  4. use App\Services\AipHttpClient;
  5. use App\Http\Controllers\Controller;
  6. use Illuminate\Support\Facades\DB;
  7. use App\Models\Telegram\TelegramBot;
  8. use App\Models\Monitor\MonitorBot;
  9. class MonitorBotController extends Controller
  10. {
  11. public $MonitorWalletStatus = ['开启','关闭'];
  12. public function index(Request $request)
  13. {
  14. $MonitorWalletStatus = $this->MonitorWalletStatus;
  15. $botData = TelegramBot::pluck('bot_username','rid');
  16. return view('admin.monitor.bot.index',compact("MonitorWalletStatus","botData"));
  17. }
  18. //列表
  19. public function getData(Request $request)
  20. {
  21. $model = MonitorBot::from('monitor_bot as a')
  22. ->leftJoin('telegram_bot as b','a.bot_rid','b.rid')
  23. ->where(function($query) use ($request){
  24. if ($request->monitor_wallet != '') {
  25. $query->where('a.monitor_wallet', 'like' ,"%" . $request->monitor_wallet ."%");
  26. }
  27. });
  28. $count = $model->count();
  29. $limit = $request->limit ?? 15;
  30. $offset = $request->page ? ($request->page - 1) * $limit : 0;
  31. $data = $model->limit($limit)->offset($offset)->select('a.*','b.bot_token','b.bot_firstname','b.bot_username')->orderBy('a.rid','desc')->get();
  32. return ['code' => '0', 'data' => $data, 'count' => $count];
  33. }
  34. //添加
  35. public function add(Request $request)
  36. {
  37. $data = MonitorBot::where('bot_rid', $request->bot_rid)->first();
  38. if(!empty($data)){
  39. return $this->responseData(400, '机器人监控已存在');
  40. }
  41. $res = MonitorBot::create([
  42. 'bot_rid' => $request->bot_rid,
  43. 'price_usdt_5' => $request->price_usdt_5 ?? 0,
  44. 'price_usdt_10' => $request->price_usdt_10 ?? 0,
  45. 'price_usdt_20' => $request->price_usdt_20 ?? 0,
  46. 'price_usdt_50' => $request->price_usdt_50 ?? 0,
  47. 'price_usdt_100' => $request->price_usdt_100 ?? 0,
  48. 'price_usdt_200' => $request->price_usdt_200 ?? 0,
  49. 'comments' => $request->comments ?? '',
  50. 'create_time' => nowDate()
  51. ]);
  52. return $res ? $this->responseData(200, '添加成功') : $this->responseData(400, '添加失败');
  53. }
  54. //删除
  55. public function delete(Request $request)
  56. {
  57. $res = MonitorBot::where('rid', $request->rid)->delete();
  58. return $res ? $this->responseData(200, '删除成功') : $this->responseData(400, '删除失败');
  59. }
  60. //编辑
  61. public function update(Request $request)
  62. {
  63. DB::beginTransaction();
  64. try {
  65. $data = MonitorBot::where('rid', $request->rid)->first();
  66. $data->bot_rid = $request->bot_rid;
  67. $data->price_usdt_5 = $request->price_usdt_5 ?? 0;
  68. $data->price_usdt_10 = $request->price_usdt_10 ?? 0;
  69. $data->price_usdt_20 = $request->price_usdt_20 ?? 0;
  70. $data->price_usdt_50 = $request->price_usdt_50 ?? 0;
  71. $data->price_usdt_100 = $request->price_usdt_100 ?? 0;
  72. $data->price_usdt_200 = $request->price_usdt_200 ?? 0;
  73. $data->comments = $request->comments ?? '';
  74. $data->update_time = nowDate();
  75. $data->save();
  76. DB::commit();
  77. return $this->responseData(200, '更新成功');
  78. } catch (\Exception $e) {
  79. DB::rollBack();
  80. return $this->responseData(400, '更新失败'.$e->getMessage());
  81. }
  82. }
  83. //编辑状态
  84. public function change_status(Request $request)
  85. {
  86. DB::beginTransaction();
  87. try {
  88. $data = MonitorBot::where('rid', $request->rid)->first();
  89. $data->status = $request->status == 1 ? 0 : 1;
  90. $data->save();
  91. DB::commit();
  92. return $this->responseData(200, '更新成功');
  93. } catch (\Exception $e) {
  94. DB::rollBack();
  95. return $this->responseData(400, '更新失败'.$e->getMessage());
  96. }
  97. }
  98. }