DashboardService.php 45 KB

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