DashboardService.php 43 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053
  1. <?php
  2. namespace App\Services;
  3. use App\Enums\UserTypeEnum;
  4. use App\Models\Address;
  5. use App\Models\Client;
  6. use App\Models\ClientFavoriteProvider;
  7. use App\Models\ClientPaymentMethod;
  8. use App\Models\Notification;
  9. use App\Models\Provider;
  10. use App\Models\ProviderSpeciality;
  11. use App\Models\Review;
  12. use App\Models\Schedule;
  13. use App\Models\ScheduleProposal;
  14. use App\Models\Speciality;
  15. use App\Rules\ScheduleBusinessRules;
  16. use Illuminate\Auth\Access\AuthorizationException;
  17. use Illuminate\Support\Facades\Auth;
  18. use Illuminate\Support\Facades\DB;
  19. use Illuminate\Support\Facades\Log;
  20. use Illuminate\Support\Facades\Storage;
  21. class DashboardService
  22. {
  23. public function __construct(
  24. private readonly CustomScheduleService $customScheduleService,
  25. private readonly ZipCodeCoordinatesService $zipCodeCoordinatesService,
  26. ) {}
  27. public function dadosDashboardCliente(): array
  28. {
  29. $user = Auth::user();
  30. if ($user->type !== UserTypeEnum::CLIENT) {
  31. throw new AuthorizationException('Apenas clientes podem acessar este recurso.');
  32. }
  33. $cliente = Client::with('profileMedia')->where('user_id', $user->id)->first();
  34. $headerBar = [
  35. 'rating' => $cliente->average_rating,
  36. 'total_services' => $cliente->total_services,
  37. 'total_ratings' => Review::where('reviews.origin', 'provider')
  38. ->leftJoin('schedules', 'schedules.id', '=', 'reviews.schedule_id')
  39. ->where('schedules.client_id', $cliente->id)
  40. ->count(),
  41. ];
  42. $address = Address::where('source', 'client')
  43. ->where('source_id', $cliente->id)
  44. ->with(['city', 'state'])
  45. ->select('id', 'source', 'source_id', 'address', 'number', 'district', 'nickname', 'address_type', 'city_id', 'state_id', 'is_primary')
  46. ->first();
  47. $summaryInfos = [
  48. 'name' => $user->name,
  49. 'address' => $address,
  50. 'profile_photo' => $cliente->profileMedia?->path
  51. ? Storage::temporaryUrl($cliente->profileMedia->path, now()->addMinutes(60))
  52. : null,
  53. 'pending_services' => Schedule::where('client_id', $cliente->id)
  54. ->whereIn('status', ['pending', 'paid', 'accepted'])
  55. ->whereDate('date', '>=', now()->toDateString())
  56. ->count(),
  57. ];
  58. $nextSchedules = Schedule::with([
  59. 'address:district,address,source_id,source,id,address_type',
  60. ])
  61. ->where('schedules.client_id', $cliente->id)
  62. ->whereIn('schedules.status', ['accepted', 'paid'])
  63. ->whereDate('schedules.date', '>=', now()->toDateString())
  64. ->where('schedules.date', '>=', now()->toDateString())
  65. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  66. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  67. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  68. ->leftJoin('media as provider_media', 'provider_media.id', '=', 'providers.profile_media_id')
  69. ->select(
  70. 'schedules.id',
  71. 'schedules.provider_id',
  72. 'provider_user.name as provider_name',
  73. 'schedules.date',
  74. 'schedules.start_time',
  75. 'schedules.end_time',
  76. 'schedules.total_amount',
  77. 'schedules.period_type',
  78. 'schedules.schedule_type',
  79. 'schedules.address_id',
  80. 'custom_schedules.address_type as custom_address_type',
  81. 'provider_media.path as provider_photo_path',
  82. DB::raw("
  83. (
  84. SELECT ci.cart_id
  85. FROM cart_items ci
  86. WHERE ci.schedule_id = schedules.id
  87. LIMIT 1
  88. ) AS cart_id
  89. "),
  90. DB::raw("
  91. (
  92. SELECT COUNT(*)
  93. FROM cart_items ci_count
  94. WHERE ci_count.cart_id = (
  95. SELECT ci.cart_id
  96. FROM cart_items ci
  97. WHERE ci.schedule_id = schedules.id
  98. LIMIT 1
  99. )
  100. ) AS cart_items_count
  101. "),
  102. )
  103. ->orderBy('schedules.date', 'asc')
  104. ->limit(5)
  105. ->get();
  106. $nextSchedules->each(function ($item) {
  107. $item->provider_photo = $item->provider_photo_path
  108. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  109. : null;
  110. unset($item->provider_photo_path);
  111. });
  112. $latestPerProvider = Schedule::where('client_id', $cliente->id)
  113. ->where('status', 'finished')
  114. ->select('provider_id', DB::raw('MAX(id) as max_id'))
  115. ->groupBy('provider_id');
  116. $lastDoneSchedules = Schedule::joinSub($latestPerProvider, 'latest', function ($join) {
  117. $join->on('schedules.id', '=', 'latest.max_id');
  118. })
  119. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  120. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  121. ->leftJoinSub(
  122. Address::preferredForProvider(),
  123. 'provider_address',
  124. fn($join) =>
  125. $join->on('provider_address.source_id', '=', 'providers.id')
  126. ->where('provider_address.rn', 1)
  127. )
  128. ->leftJoin('media as provider_media', 'provider_media.id', '=', 'providers.profile_media_id')
  129. ->select(
  130. 'schedules.id',
  131. 'schedules.provider_id',
  132. 'provider_user.name as provider_name',
  133. 'provider_address.district as provider_district',
  134. 'provider_media.path as provider_photo_path',
  135. )
  136. ->orderBy('schedules.date', 'desc')
  137. ->limit(5)
  138. ->get();
  139. $lastDoneSchedules->each(function ($item) {
  140. $item->provider_photo = $item->provider_photo_path
  141. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  142. : null;
  143. unset($item->provider_photo_path);
  144. });
  145. $favoriteProviders = ClientFavoriteProvider::where('client_favorite_providers.client_id', $cliente->id)
  146. ->leftJoin('providers', 'providers.id', '=', 'client_favorite_providers.provider_id')
  147. ->whereNotNull('providers.recipient_default_bank_account')
  148. ->whereRaw("providers.recipient_default_bank_account::text <> '{}'")
  149. ->whereRaw("providers.recipient_default_bank_account::text <> '[]'")
  150. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  151. ->leftJoinSub(
  152. Address::preferredForProvider(),
  153. 'provider_address',
  154. fn($join) =>
  155. $join->on('provider_address.source_id', '=', 'providers.id')
  156. ->where('provider_address.rn', 1)
  157. )
  158. ->leftJoin('media as provider_media', 'provider_media.id', '=', 'providers.profile_media_id')
  159. ->select(
  160. 'providers.id as provider_id',
  161. 'provider_user.name as provider_name',
  162. 'providers.average_rating',
  163. 'provider_address.district as provider_district',
  164. 'provider_media.path as provider_photo_path',
  165. )
  166. ->orderBy('client_favorite_providers.created_at', 'desc')
  167. ->limit(5)
  168. ->get();
  169. $favoriteProviders->each(function ($item) {
  170. $item->provider_photo = $item->provider_photo_path
  171. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  172. : null;
  173. unset($item->provider_photo_path);
  174. });
  175. $blockedProviderIds = ScheduleBusinessRules::getBlockedProviderIdsForClient($cliente->id);
  176. $providersWithWorkingDays = ScheduleBusinessRules::getProviderIdsWithWorkingDays();
  177. $clientPrimaryAddress = Address::where('source', 'client')
  178. ->where('source_id', $cliente->id)
  179. ->orderByDesc('is_primary')
  180. ->orderByDesc('id')
  181. ->first();
  182. $clientDistanceAddress = $this->addressForDistance($cliente->id, $clientPrimaryAddress);
  183. $clientCoordinates = $this->zipCodeCoordinatesService->resolve(
  184. $clientDistanceAddress?->latitude !== null ? (float) $clientDistanceAddress->latitude : null,
  185. $clientDistanceAddress?->longitude !== null ? (float) $clientDistanceAddress->longitude : null,
  186. $clientDistanceAddress?->zip_code,
  187. );
  188. $providersCloseDistanceSelect = $this->distanceSelect(
  189. $clientCoordinates['latitude'] ?? null,
  190. $clientCoordinates['longitude'] ?? null,
  191. );
  192. $providerAddressLatestSubquery = DB::raw("
  193. (
  194. SELECT DISTINCT ON (source_id)
  195. *
  196. FROM addresses
  197. WHERE source = 'provider'
  198. AND deleted_at IS NULL
  199. ORDER BY
  200. source_id,
  201. (latitude IS NOT NULL AND longitude IS NOT NULL) DESC,
  202. is_primary DESC,
  203. id DESC
  204. ) AS provider_address
  205. ");
  206. $providersCloseDebugQuery = Provider::leftJoin(
  207. 'users as provider_user',
  208. 'provider_user.id',
  209. '=',
  210. 'providers.user_id'
  211. )
  212. ->visibleToCustomers()
  213. ->leftJoin(
  214. $providerAddressLatestSubquery,
  215. 'provider_address.source_id',
  216. '=',
  217. 'providers.id'
  218. )
  219. ->whereNull('providers.deleted_at');
  220. Log::info('Dashboard providersClose context', [
  221. 'client_id' => $cliente->id,
  222. 'user_id' => $user->id,
  223. 'client_primary_address_id' => $clientPrimaryAddress?->id,
  224. 'client_primary_address_city_id' => $clientPrimaryAddress?->city_id,
  225. 'client_primary_address_state_id' => $clientPrimaryAddress?->state_id,
  226. 'client_distance_address_id' => $clientDistanceAddress?->id,
  227. 'client_distance_zip_code' => $clientDistanceAddress?->zip_code,
  228. 'client_coordinates' => $clientCoordinates,
  229. 'blocked_provider_ids_count' => $blockedProviderIds->count(),
  230. 'providers_working_days_count' => $providersWithWorkingDays->count(),
  231. ]);
  232. Log::info('Dashboard providersClose filter counts', [
  233. 'visible_with_bank' => (clone $providersCloseDebugQuery)
  234. ->distinct('providers.id')
  235. ->count('providers.id'),
  236. 'with_provider_address' => (clone $providersCloseDebugQuery)
  237. ->whereNotNull('provider_address.id')
  238. ->distinct('providers.id')
  239. ->count('providers.id'),
  240. 'after_city_filter' => (clone $providersCloseDebugQuery)
  241. ->whereNotNull('provider_address.id')
  242. ->when(
  243. $clientPrimaryAddress?->city_id,
  244. fn ($query, int $cityId) => $query->where('provider_address.city_id', $cityId)
  245. )
  246. ->distinct('providers.id')
  247. ->count('providers.id'),
  248. 'after_block_filter' => (clone $providersCloseDebugQuery)
  249. ->whereNotNull('provider_address.id')
  250. ->when(
  251. $clientPrimaryAddress?->city_id,
  252. fn ($query, int $cityId) => $query->where('provider_address.city_id', $cityId)
  253. )
  254. ->whereNotIn('providers.id', $blockedProviderIds)
  255. ->distinct('providers.id')
  256. ->count('providers.id'),
  257. 'after_working_days_filter' => (clone $providersCloseDebugQuery)
  258. ->whereNotNull('provider_address.id')
  259. ->when(
  260. $clientPrimaryAddress?->city_id,
  261. fn ($query, int $cityId) => $query->where('provider_address.city_id', $cityId)
  262. )
  263. ->whereNotIn('providers.id', $blockedProviderIds)
  264. ->whereIn('providers.id', $providersWithWorkingDays)
  265. ->distinct('providers.id')
  266. ->count('providers.id'),
  267. ]);
  268. $providersClose = Provider::leftJoin(
  269. 'users as provider_user',
  270. 'provider_user.id',
  271. '=',
  272. 'providers.user_id'
  273. )
  274. ->visibleToCustomers()
  275. ->leftJoin(
  276. $providerAddressLatestSubquery,
  277. 'provider_address.source_id',
  278. '=',
  279. 'providers.id'
  280. )
  281. ->leftJoin(
  282. 'media as provider_media',
  283. 'provider_media.id',
  284. '=',
  285. 'providers.profile_media_id'
  286. )
  287. ->whereNotNull('provider_address.id')
  288. ->when(
  289. $clientPrimaryAddress?->city_id,
  290. fn ($query, int $cityId) => $query->where('provider_address.city_id', $cityId)
  291. )
  292. ->whereNotIn('providers.id', $blockedProviderIds)
  293. ->whereIn('providers.id', $providersWithWorkingDays)
  294. ->whereNull('providers.deleted_at')
  295. ->select(
  296. 'providers.id as provider_id',
  297. 'provider_user.name as provider_name',
  298. 'provider_address.id as address_id',
  299. 'provider_address.zip_code as provider_zip_code',
  300. 'provider_address.district',
  301. 'provider_address.latitude as provider_latitude',
  302. 'provider_address.longitude as provider_longitude',
  303. 'providers.average_rating',
  304. 'providers.total_services',
  305. 'providers.daily_price_8h',
  306. 'providers.daily_price_6h',
  307. 'providers.daily_price_4h',
  308. 'providers.daily_price_2h',
  309. DB::raw("
  310. (
  311. SELECT COUNT(*)
  312. FROM reviews
  313. LEFT JOIN schedules
  314. ON schedules.id = reviews.schedule_id
  315. WHERE reviews.origin = 'provider'
  316. AND schedules.provider_id = providers.id
  317. ) AS total_reviews
  318. "),
  319. $providersCloseDistanceSelect,
  320. 'provider_media.path as provider_photo_path',
  321. )
  322. ->orderByRaw('distance_km ASC NULLS LAST')
  323. ->get();
  324. Log::info('Dashboard providersClose query result', [
  325. 'count' => $providersClose->count(),
  326. 'provider_ids_sample' => $providersClose->pluck('provider_id')->take(20)->values()->all(),
  327. 'null_distance_count' => $providersClose->whereNull('distance_km')->count(),
  328. 'provider_city_filter' => $clientPrimaryAddress?->city_id,
  329. ]);
  330. if ($providersClose->whereNull('distance_km')->isEmpty()) {
  331. Log::info('Dashboard providersClose zip fallback skipped', [
  332. 'reason' => 'all_distances_calculated_by_sql',
  333. 'count' => $providersClose->count(),
  334. ]);
  335. }
  336. $this->zipCodeCoordinatesService->preload(
  337. $providersClose->whereNull('distance_km')->pluck('provider_zip_code')
  338. );
  339. $providersClose->each(function ($item) use ($clientDistanceAddress) {
  340. if ($item->distance_km === null) {
  341. $item->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  342. $clientDistanceAddress?->latitude !== null ? (float) $clientDistanceAddress->latitude : null,
  343. $clientDistanceAddress?->longitude !== null ? (float) $clientDistanceAddress->longitude : null,
  344. $clientDistanceAddress?->zip_code,
  345. $item->provider_latitude !== null ? (float) $item->provider_latitude : null,
  346. $item->provider_longitude !== null ? (float) $item->provider_longitude : null,
  347. $item->provider_zip_code,
  348. );
  349. }
  350. $item->provider_photo = $item->provider_photo_path
  351. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  352. : null;
  353. unset($item->provider_photo_path, $item->provider_zip_code);
  354. $item->daily_price_8h_base = $item->daily_price_8h;
  355. $item->daily_price_6h_base = $item->daily_price_6h;
  356. $item->daily_price_4h_base = $item->daily_price_4h;
  357. $item->daily_price_2h_base = $item->daily_price_2h;
  358. $item->daily_price_8h = $this->applyCreditCardFee($item->daily_price_8h);
  359. $item->daily_price_6h = $this->applyCreditCardFee($item->daily_price_6h);
  360. $item->daily_price_4h = $this->applyCreditCardFee($item->daily_price_4h);
  361. $item->daily_price_2h = $this->applyCreditCardFee($item->daily_price_2h);
  362. });
  363. $providersClose = $providersClose
  364. ->sortBy(fn ($provider) => $provider->distance_km ?? PHP_FLOAT_MAX)
  365. ->values();
  366. Log::info('Dashboard providersClose final result', [
  367. 'count' => $providersClose->count(),
  368. 'items_sample' => $providersClose->take(5)->map(fn ($provider) => [
  369. 'provider_id' => $provider->provider_id,
  370. 'provider_name' => $provider->provider_name,
  371. 'district' => $provider->district,
  372. 'distance_km' => $provider->distance_km,
  373. ])->values()->all(),
  374. ]);
  375. $pendingSchedules = Schedule::with([
  376. 'address:district,address,number,source_id,source,id,address_type',
  377. ])
  378. ->where('schedules.client_id', $cliente->id)
  379. ->whereIn('schedules.status', ['pending', 'accepted'])
  380. ->where('schedules.schedule_type', 'default')
  381. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  382. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  383. ->leftJoin('media as provider_media', 'provider_media.id', '=', 'providers.profile_media_id')
  384. ->select(
  385. 'schedules.id',
  386. 'schedules.provider_id',
  387. 'provider_user.name as provider_name',
  388. 'schedules.date',
  389. 'schedules.address_id',
  390. 'schedules.status',
  391. 'schedules.total_amount',
  392. 'schedules.start_time',
  393. 'schedules.end_time',
  394. DB::raw("
  395. CASE
  396. WHEN (NOW() - schedules.created_at) < INTERVAL '1 hour' THEN
  397. CONCAT(
  398. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 60),
  399. 'min'
  400. )
  401. WHEN (NOW() - schedules.created_at) < INTERVAL '1 day' THEN
  402. CONCAT(
  403. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 3600),
  404. 'h'
  405. )
  406. ELSE
  407. CONCAT(
  408. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 86400),
  409. 'd'
  410. )
  411. END AS time_since_request
  412. "),
  413. 'provider_media.path as provider_photo_path',
  414. DB::raw("
  415. (
  416. SELECT ci.cart_id
  417. FROM cart_items ci
  418. WHERE ci.schedule_id = schedules.id
  419. LIMIT 1
  420. ) AS cart_id
  421. "),
  422. DB::raw("
  423. (
  424. SELECT COUNT(*)
  425. FROM cart_items ci_count
  426. WHERE ci_count.cart_id = (
  427. SELECT ci.cart_id
  428. FROM cart_items ci
  429. WHERE ci.schedule_id = schedules.id
  430. LIMIT 1
  431. )
  432. ) AS cart_items_count
  433. "),
  434. )
  435. ->orderBy('schedules.date', 'asc')
  436. ->get();
  437. $pendingSchedules->each(function ($item) {
  438. $item->provider_photo = $item->provider_photo_path
  439. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  440. : null;
  441. unset($item->provider_photo_path);
  442. });
  443. $proposalsDistanceSelect = DistanceService::sqlExpression(
  444. $clientCoordinates['latitude'] ?? null,
  445. $clientCoordinates['longitude'] ?? null,
  446. );
  447. $schedulesProposals = ScheduleProposal::query()
  448. ->leftJoin(
  449. 'schedules',
  450. 'schedule_proposals.schedule_id',
  451. '=',
  452. 'schedules.id'
  453. )
  454. ->leftJoin(
  455. 'providers',
  456. 'schedule_proposals.provider_id',
  457. '=',
  458. 'providers.id'
  459. )
  460. ->whereNotNull('providers.recipient_default_bank_account')
  461. ->whereRaw("providers.recipient_default_bank_account::text <> '{}'")
  462. ->whereRaw("providers.recipient_default_bank_account::text <> '[]'")
  463. ->leftJoin('users', 'providers.user_id', '=', 'users.id')
  464. ->leftJoin(
  465. DB::raw("
  466. (
  467. SELECT DISTINCT ON (source_id)
  468. *
  469. FROM addresses
  470. WHERE source = 'provider'
  471. AND deleted_at IS NULL
  472. ORDER BY source_id, is_primary DESC
  473. ) AS provider_address
  474. "),
  475. 'provider_address.source_id',
  476. '=',
  477. 'providers.id'
  478. )
  479. ->leftJoin(
  480. 'media as provider_media',
  481. 'provider_media.id',
  482. '=',
  483. 'providers.profile_media_id'
  484. )
  485. ->where('schedules.client_id', $cliente->id)
  486. ->where('schedules.schedule_type', 'custom')
  487. ->where('schedules.status', 'pending')
  488. ->whereNull('schedules.deleted_at')
  489. ->whereDate('schedules.date', '>=', now()->toDateString())
  490. ->orderBy('schedule_proposals.created_at', 'desc')
  491. ->select([
  492. 'schedule_proposals.id',
  493. DB::raw("
  494. DATE_PART('year', AGE(providers.birth_date)) AS idade
  495. "),
  496. 'providers.id as provider_id',
  497. 'schedules.id as schedule_id',
  498. 'schedules.date',
  499. 'schedules.start_time',
  500. 'schedules.end_time',
  501. 'schedules.period_type',
  502. 'schedules.total_amount',
  503. 'providers.daily_price_8h',
  504. 'providers.average_rating',
  505. 'providers.total_services',
  506. 'users.name as provider_name',
  507. 'provider_address.latitude as provider_latitude',
  508. 'provider_address.longitude as provider_longitude',
  509. 'provider_address.zip_code as provider_zip_code',
  510. $proposalsDistanceSelect,
  511. 'provider_media.path as provider_photo_path',
  512. ])
  513. ->get();
  514. $this->zipCodeCoordinatesService->preload(
  515. $schedulesProposals->whereNull('distance_km')->pluck('provider_zip_code')
  516. );
  517. $custom_schedules_with_no_proposals = Schedule::where('client_id', $cliente->id)
  518. ->where('schedule_type', 'custom')
  519. ->where('status', 'pending')
  520. ->whereDate('date', '>=', now()->toDateString())
  521. ->doesntHave('proposals')
  522. ->get();
  523. $schedulesProposals->each(function ($item) use ($clientDistanceAddress) {
  524. if ($item->distance_km === null) {
  525. $item->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  526. $clientDistanceAddress?->latitude !== null ? (float) $clientDistanceAddress->latitude : null,
  527. $clientDistanceAddress?->longitude !== null ? (float) $clientDistanceAddress->longitude : null,
  528. $clientDistanceAddress?->zip_code,
  529. $item->provider_latitude !== null ? (float) $item->provider_latitude : null,
  530. $item->provider_longitude !== null ? (float) $item->provider_longitude : null,
  531. $item->provider_zip_code,
  532. );
  533. }
  534. $item->provider_photo = $item->provider_photo_path
  535. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  536. : null;
  537. unset(
  538. $item->provider_photo_path,
  539. $item->provider_latitude,
  540. $item->provider_longitude,
  541. $item->provider_zip_code,
  542. );
  543. });
  544. $todaySchedules = Schedule::with([
  545. 'address:district,address,number,source_id,source,id,address_type',
  546. ])
  547. ->where('schedules.client_id', $cliente->id)
  548. ->whereIn('schedules.status', ['accepted', 'paid', 'started', 'finished'])
  549. ->whereDate('schedules.date', now()->toDateString())
  550. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  551. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  552. ->leftJoin('media', 'media.id', '=', 'providers.profile_media_id')
  553. ->select(
  554. 'schedules.id',
  555. 'schedules.provider_id',
  556. 'provider_user.name as provider_name',
  557. 'schedules.date',
  558. 'schedules.start_time',
  559. 'schedules.end_time',
  560. 'schedules.total_amount',
  561. 'schedules.period_type',
  562. 'schedules.schedule_type',
  563. 'schedules.address_id',
  564. 'schedules.status',
  565. 'schedules.code_verified',
  566. 'schedules.code',
  567. 'media.path as provider_photo',
  568. DB::raw("
  569. (
  570. SELECT ci.cart_id
  571. FROM cart_items ci
  572. WHERE ci.schedule_id = schedules.id
  573. LIMIT 1
  574. ) AS cart_id
  575. "),
  576. DB::raw("
  577. (
  578. SELECT COUNT(*)
  579. FROM cart_items ci_count
  580. WHERE ci_count.cart_id = (
  581. SELECT ci.cart_id
  582. FROM cart_items ci
  583. WHERE ci.schedule_id = schedules.id
  584. LIMIT 1
  585. )
  586. ) AS cart_items_count
  587. "),
  588. DB::raw("
  589. EXISTS (
  590. SELECT 1
  591. FROM reviews
  592. WHERE reviews.schedule_id = schedules.id
  593. AND reviews.origin = 'client'
  594. AND reviews.origin_id = {$cliente->id}
  595. AND reviews.deleted_at IS NULL
  596. ) AS client_reviewed
  597. "),
  598. )
  599. ->orderBy('schedules.start_time', 'asc')
  600. ->get()
  601. ->map(function ($item) {
  602. $item->provider_photo = $item->provider_photo
  603. ? Storage::temporaryUrl(
  604. $item->provider_photo,
  605. now()->addMinutes(60)
  606. )
  607. : null;
  608. return $item;
  609. });
  610. $notifications = Notification::where('user_id', $user->id)
  611. ->orderBy('read', 'asc')
  612. ->orderBy('created_at', 'desc')
  613. ->limit(10)
  614. ->get()
  615. ->map(function ($notification) {
  616. return [
  617. 'id' => $notification->id,
  618. 'title' => $notification->title,
  619. 'description' => $notification->description,
  620. 'time' => $notification->created_at->diffForHumans(),
  621. 'read' => $notification->read,
  622. 'avatar' => '/icons/avatar.svg',
  623. ];
  624. });
  625. $hasPaymentMethods = ClientPaymentMethod::where('client_id', $cliente->id)->exists();
  626. return [
  627. 'headerBar' => $headerBar,
  628. 'summaryInfos' => $summaryInfos,
  629. 'pendingSchedules' => $pendingSchedules,
  630. 'nextSchedules' => $nextSchedules,
  631. 'lastDoneSchedules' => $lastDoneSchedules,
  632. 'favoriteProviders' => $favoriteProviders,
  633. 'providersClose' => $providersClose,
  634. 'todaySchedules' => $todaySchedules,
  635. 'schedulesProposals' => $schedulesProposals,
  636. 'customSchedulesNoProposals' => $custom_schedules_with_no_proposals,
  637. 'notifications' => $notifications,
  638. 'has_payment_methods' => $hasPaymentMethods,
  639. ];
  640. }
  641. public function dadosDashboardPrestador(): array
  642. {
  643. $user = Auth::user();
  644. if ($user->type !== UserTypeEnum::PROVIDER) {
  645. throw new AuthorizationException('Apenas prestadores podem acessar este recurso.');
  646. }
  647. $provider = Provider::with('profileMedia')->where('user_id', $user->id)->first();
  648. $headerBar = [
  649. 'rating' => $provider->average_rating,
  650. 'total_ratings' => Review::where('reviews.origin', 'client')->leftJoin('schedules', 'schedules.id', '=', 'reviews.schedule_id')->where('schedules.provider_id', $provider->id)->count(),
  651. 'total_services' => $provider->total_services,
  652. ];
  653. $address = Address::where('source', 'provider')->where('source_id', $provider->id)->with(['city', 'state'])->first();
  654. $summaryInfos = [
  655. 'name' => $user->name,
  656. 'address' => $address,
  657. 'pending_services' => Schedule::where('provider_id', $provider->id)->where('status', 'pending')->count(),
  658. 'profile_photo' => $provider->profileMedia?->path
  659. ? Storage::temporaryUrl($provider->profileMedia->path, now()->addMinutes(60))
  660. : null,
  661. ];
  662. $priceSuggestedAvg = Provider::where('user_id', '!=', $user->id)
  663. ->whereNotNull('daily_price_8h')
  664. ->pluck('daily_price_8h')
  665. ->avg();
  666. $priceActual = $provider->daily_price_8h;
  667. $priceSuggested = [
  668. 'average_price' => $priceSuggestedAvg,
  669. 'your_price' => $priceActual,
  670. ];
  671. $solicitations = Schedule::with([
  672. 'address:district,source_id,source,id,zip_code,latitude,longitude',
  673. ])
  674. ->where('schedules.provider_id', $provider->id)
  675. ->where('schedules.status', 'pending')
  676. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  677. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  678. ->leftJoin('media as client_media', 'client_media.id', '=', 'clients.profile_media_id')
  679. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  680. ->select(
  681. 'schedules.id',
  682. 'client_user.name as client_name',
  683. 'clients.average_rating',
  684. 'schedules.date',
  685. DB::raw("
  686. TO_CHAR(schedules.date, 'DD/MM/YYYY') AS formatted_date
  687. "),
  688. 'schedules.start_time',
  689. 'schedules.end_time',
  690. 'schedules.total_amount',
  691. 'schedules.period_type',
  692. 'schedules.schedule_type',
  693. 'schedules.address_id',
  694. 'schedules.status',
  695. 'custom_schedules.offers_meal',
  696. 'client_media.path as customer_photo_path',
  697. DB::raw("
  698. CASE
  699. WHEN (NOW() - schedules.created_at) < INTERVAL '1 day' THEN
  700. CONCAT(
  701. ROUND(
  702. EXTRACT(
  703. EPOCH FROM (NOW() - schedules.created_at)
  704. ) / 3600
  705. ),
  706. ' hours ago'
  707. )
  708. ELSE
  709. CONCAT(
  710. ROUND(
  711. EXTRACT(
  712. EPOCH FROM (NOW() - schedules.created_at)
  713. ) / 86400
  714. ),
  715. ' days ago'
  716. )
  717. END AS time_since_request
  718. "),
  719. )
  720. ->orderBy('schedules.date', 'asc')
  721. ->get();
  722. $solicitations->each(function ($solicitation) use ($address) {
  723. $solicitation->customer_photo = $solicitation->customer_photo_path
  724. ? Storage::temporaryUrl($solicitation->customer_photo_path, now()->addMinutes(60))
  725. : null;
  726. unset($solicitation->customer_photo_path);
  727. $solicitation->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  728. $address?->latitude !== null ? (float) $address->latitude : null,
  729. $address?->longitude !== null ? (float) $address->longitude : null,
  730. $address?->zip_code,
  731. $solicitation->address?->latitude !== null ? (float) $solicitation->address->latitude : null,
  732. $solicitation->address?->longitude !== null ? (float) $solicitation->address->longitude : null,
  733. $solicitation->address?->zip_code,
  734. );
  735. });
  736. $todayServices = Schedule::with([
  737. 'address:district,address,number,source_id,source,id',
  738. ])
  739. ->where('schedules.provider_id', $provider->id)
  740. ->whereIn('schedules.status', ['accepted', 'paid', 'started', 'finished'])
  741. ->whereDate('schedules.date', now()->toDateString())
  742. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  743. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  744. ->leftJoin('media as client_media', 'client_media.id', '=', 'clients.profile_media_id')
  745. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  746. ->select(
  747. 'schedules.id',
  748. 'schedules.client_id',
  749. 'client_user.name as client_name',
  750. 'schedules.date',
  751. 'schedules.start_time',
  752. 'schedules.end_time',
  753. 'schedules.total_amount',
  754. 'schedules.period_type',
  755. 'schedules.address_id',
  756. 'schedules.schedule_type',
  757. 'schedules.status',
  758. 'schedules.code_verified',
  759. 'schedules.code',
  760. 'custom_schedules.offers_meal',
  761. 'client_media.path as customer_photo_path',
  762. DB::raw("
  763. EXISTS (
  764. SELECT 1
  765. FROM reviews
  766. WHERE reviews.schedule_id = schedules.id
  767. AND reviews.origin = 'provider'
  768. AND reviews.origin_id = {$provider->id}
  769. AND reviews.deleted_at IS NULL
  770. ) AS provider_reviewed
  771. "),
  772. )
  773. ->orderBy('schedules.start_time', 'asc')
  774. ->get();
  775. $todayServices->each(function ($s) {
  776. $s->customer_photo = $s->customer_photo_path
  777. ? Storage::temporaryUrl($s->customer_photo_path, now()->addMinutes(60))
  778. : null;
  779. unset($s->customer_photo_path);
  780. });
  781. $nextSchedules = Schedule::with('address:district,address,number,source_id,source,id,zip_code,latitude,longitude')
  782. ->where('schedules.provider_id', $provider->id)
  783. ->whereIn('schedules.status', ['accepted', 'paid'])
  784. ->whereDate('schedules.date', '>=', now()->toDateString())
  785. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  786. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  787. ->leftJoin('media as client_media', 'client_media.id', '=', 'clients.profile_media_id')
  788. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  789. ->select(
  790. 'schedules.id',
  791. 'client_user.name as client_name',
  792. 'schedules.date',
  793. 'schedules.start_time',
  794. 'schedules.end_time',
  795. 'schedules.total_amount',
  796. 'schedules.period_type',
  797. 'schedules.address_id',
  798. 'schedules.schedule_type',
  799. 'schedules.status',
  800. 'custom_schedules.offers_meal',
  801. 'client_media.path as customer_photo_path',
  802. )
  803. ->orderBy('schedules.date', 'asc')
  804. ->get();
  805. $nextSchedules->each(function ($schedule) use ($address) {
  806. $schedule->customer_photo = $schedule->customer_photo_path
  807. ? Storage::temporaryUrl($schedule->customer_photo_path, now()->addMinutes(60))
  808. : null;
  809. unset($schedule->customer_photo_path);
  810. $schedule->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  811. $address?->latitude !== null ? (float) $address->latitude : null,
  812. $address?->longitude !== null ? (float) $address->longitude : null,
  813. $address?->zip_code,
  814. $schedule->address?->latitude !== null ? (float) $schedule->address->latitude : null,
  815. $schedule->address?->longitude !== null ? (float) $schedule->address->longitude : null,
  816. $schedule->address?->zip_code,
  817. );
  818. });
  819. $notifications = Notification::where('user_id', $user->id)
  820. ->orderBy('read', 'asc')
  821. ->orderBy('created_at', 'desc')
  822. ->limit(10)
  823. ->get()
  824. ->map(function ($notification) {
  825. return [
  826. 'id' => $notification->id,
  827. 'title' => $notification->title,
  828. 'description' => $notification->description,
  829. 'time' => $notification->created_at->diffForHumans(),
  830. 'read' => $notification->read,
  831. 'avatar' => '/icons/avatar.svg',
  832. ];
  833. });
  834. $opportunities = $this->customScheduleService->getAvailableOpportunities($provider->id);
  835. $opportunities->each(function ($o) {
  836. $o->customer_photo = $o->client?->profileMedia?->path
  837. ? Storage::temporaryUrl($o->client->profileMedia->path, now()->addMinutes(60))
  838. : null;
  839. });
  840. return [
  841. 'headerBar' => $headerBar,
  842. 'summaryInfos' => $summaryInfos,
  843. 'priceSuggested' => $priceSuggested,
  844. 'solicitations' => $solicitations,
  845. 'todayServices' => $todayServices,
  846. 'nextSchedules' => $nextSchedules,
  847. 'opportunities' => $opportunities,
  848. 'notifications' => $notifications,
  849. ];
  850. }
  851. public function getScheduleClienteDetails(int $scheduleId): array
  852. {
  853. $user = Auth::user();
  854. $cliente = Client::where('user_id', $user->id)->firstOrFail();
  855. $schedule = Schedule::where('schedules.id', $scheduleId)
  856. ->where('schedules.client_id', $cliente->id)
  857. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  858. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  859. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  860. ->leftJoin('media', 'media.id', '=', 'providers.profile_media_id')
  861. ->select(
  862. 'schedules.provider_id',
  863. 'provider_user.name as provider_name',
  864. 'providers.birth_date as provider_birth_date',
  865. 'media.path as provider_photo',
  866. 'custom_schedules.offers_meal',
  867. )
  868. ->firstOrFail();
  869. $allSpecialities = Speciality::where('active', true)
  870. ->select('id', 'description')
  871. ->orderBy('description')
  872. ->get();
  873. $providerSpecialityIds = ProviderSpeciality::where('provider_id', $schedule->provider_id)
  874. ->pluck('speciality_id')
  875. ->all();
  876. $specialities = $allSpecialities->map(fn($sp) => [
  877. 'id' => $sp->id,
  878. 'description' => $sp->description,
  879. 'has_speciality' => in_array($sp->id, $providerSpecialityIds),
  880. ])->values();
  881. return [
  882. 'provider_name' => $schedule->provider_name,
  883. 'provider_birth_date' => $schedule->provider_birth_date,
  884. 'offers_meal' => $schedule->offers_meal,
  885. 'specialities' => $specialities,
  886. 'provider_photo' => $schedule->provider_photo
  887. ? Storage::temporaryUrl($schedule->provider_photo, now()->addMinutes(60))
  888. : null,
  889. ];
  890. }
  891. //
  892. private function applyCreditCardFee(?float $price): ?float
  893. {
  894. if ($price === null) {
  895. return null;
  896. }
  897. $rate = $this->platformCreditCardFeeRate();
  898. return round($price * (1 + $rate), 2);
  899. }
  900. private function platformCreditCardFeeRate(): float
  901. {
  902. $rate = config('services.pagarme.platform_credit_card_fee_rate', 0.16);
  903. if (is_string($rate)) {
  904. $rate = str_replace(',', '.', trim($rate));
  905. }
  906. $rate = (float) $rate;
  907. return $rate > 1 ? $rate / 100 : $rate;
  908. }
  909. private function addressForDistance(int $clientId, ?Address $primaryAddress): ?Address
  910. {
  911. if ($primaryAddress?->latitude !== null && $primaryAddress?->longitude !== null) {
  912. return $primaryAddress;
  913. }
  914. return Address::where('source', 'client')
  915. ->where('source_id', $clientId)
  916. ->whereNotNull('latitude')
  917. ->whereNotNull('longitude')
  918. ->orderByDesc('is_primary')
  919. ->orderByDesc('id')
  920. ->first() ?? $primaryAddress;
  921. }
  922. private function distanceSelect(?float $clientLatitude, ?float $clientLongitude): \Illuminate\Contracts\Database\Query\Expression
  923. {
  924. return DistanceService::sqlExpression($clientLatitude, $clientLongitude);
  925. }
  926. }