DashboardService.php 44 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061
  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(__('messages.only_clients_allowed'));
  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 spi.service_package_id
  85. FROM service_package_items spi
  86. WHERE spi.schedule_id = schedules.id
  87. LIMIT 1
  88. ) AS service_package_id
  89. "),
  90. DB::raw("
  91. (
  92. SELECT COUNT(*)
  93. FROM service_package_items spi_count
  94. WHERE spi_count.service_package_id = (
  95. SELECT spi.service_package_id
  96. FROM service_package_items spi
  97. WHERE spi.schedule_id = schedules.id
  98. LIMIT 1
  99. )
  100. ) AS service_package_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. data_get($clientCoordinates, 'latitude'),
  190. data_get($clientCoordinates, 'longitude'),
  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('Contexto de prestadores próximos no dashboard', [
  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('Contagem dos filtros de prestadores próximos no dashboard', [
  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('Resultado da consulta de prestadores próximos no dashboard', [
  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. 'items_sample' => $providersClose->take(5)->map(fn ($provider) => [
  330. 'provider_id' => $provider->provider_id,
  331. 'provider_name' => $provider->provider_name,
  332. 'provider_zip_code' => $provider->provider_zip_code,
  333. 'provider_latitude' => $provider->provider_latitude,
  334. 'provider_longitude' => $provider->provider_longitude,
  335. 'distance_km' => $provider->distance_km,
  336. ])->values()->all(),
  337. ]);
  338. if ($providersClose->whereNull('distance_km')->isEmpty()) {
  339. Log::info('Fallback por CEP de prestadores próximos ignorado no dashboard', [
  340. 'reason' => 'all_distances_calculated_by_sql',
  341. 'count' => $providersClose->count(),
  342. ]);
  343. }
  344. $this->zipCodeCoordinatesService->preload(
  345. $providersClose->whereNull('distance_km')->pluck('provider_zip_code')
  346. );
  347. $providersClose->each(function ($item) use ($clientDistanceAddress) {
  348. if ($item->distance_km === null) {
  349. $item->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  350. $clientDistanceAddress?->latitude !== null ? (float) $clientDistanceAddress->latitude : null,
  351. $clientDistanceAddress?->longitude !== null ? (float) $clientDistanceAddress->longitude : null,
  352. $clientDistanceAddress?->zip_code,
  353. $item->provider_latitude !== null ? (float) $item->provider_latitude : null,
  354. $item->provider_longitude !== null ? (float) $item->provider_longitude : null,
  355. $item->provider_zip_code,
  356. );
  357. }
  358. $item->provider_photo = $item->provider_photo_path
  359. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  360. : null;
  361. unset($item->provider_photo_path, $item->provider_zip_code);
  362. $item->daily_price_8h_base = $item->daily_price_8h;
  363. $item->daily_price_6h_base = $item->daily_price_6h;
  364. $item->daily_price_4h_base = $item->daily_price_4h;
  365. $item->daily_price_2h_base = $item->daily_price_2h;
  366. $item->daily_price_8h = $this->applyCreditCardFee($item->daily_price_8h);
  367. $item->daily_price_6h = $this->applyCreditCardFee($item->daily_price_6h);
  368. $item->daily_price_4h = $this->applyCreditCardFee($item->daily_price_4h);
  369. $item->daily_price_2h = $this->applyCreditCardFee($item->daily_price_2h);
  370. });
  371. $providersClose = $providersClose
  372. ->sortBy(fn ($provider) => $provider->distance_km ?? PHP_FLOAT_MAX)
  373. ->values();
  374. Log::info('Resultado final de prestadores próximos no dashboard', [
  375. 'count' => $providersClose->count(),
  376. 'items_sample' => $providersClose->take(5)->map(fn ($provider) => [
  377. 'provider_id' => $provider->provider_id,
  378. 'provider_name' => $provider->provider_name,
  379. 'district' => $provider->district,
  380. 'distance_km' => $provider->distance_km,
  381. ])->values()->all(),
  382. ]);
  383. $pendingSchedules = Schedule::with([
  384. 'address:district,address,number,source_id,source,id,address_type',
  385. ])
  386. ->where('schedules.client_id', $cliente->id)
  387. ->whereIn('schedules.status', ['pending', 'accepted'])
  388. ->where('schedules.schedule_type', 'default')
  389. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  390. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  391. ->leftJoin('media as provider_media', 'provider_media.id', '=', 'providers.profile_media_id')
  392. ->select(
  393. 'schedules.id',
  394. 'schedules.provider_id',
  395. 'provider_user.name as provider_name',
  396. 'schedules.date',
  397. 'schedules.address_id',
  398. 'schedules.status',
  399. 'schedules.total_amount',
  400. 'schedules.start_time',
  401. 'schedules.end_time',
  402. DB::raw("
  403. CASE
  404. WHEN (NOW() - schedules.created_at) < INTERVAL '1 hour' THEN
  405. CONCAT(
  406. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 60),
  407. 'min'
  408. )
  409. WHEN (NOW() - schedules.created_at) < INTERVAL '1 day' THEN
  410. CONCAT(
  411. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 3600),
  412. 'h'
  413. )
  414. ELSE
  415. CONCAT(
  416. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 86400),
  417. 'd'
  418. )
  419. END AS time_since_request
  420. "),
  421. 'provider_media.path as provider_photo_path',
  422. DB::raw("
  423. (
  424. SELECT spi.service_package_id
  425. FROM service_package_items spi
  426. WHERE spi.schedule_id = schedules.id
  427. LIMIT 1
  428. ) AS service_package_id
  429. "),
  430. DB::raw("
  431. (
  432. SELECT COUNT(*)
  433. FROM service_package_items spi_count
  434. WHERE spi_count.service_package_id = (
  435. SELECT spi.service_package_id
  436. FROM service_package_items spi
  437. WHERE spi.schedule_id = schedules.id
  438. LIMIT 1
  439. )
  440. ) AS service_package_items_count
  441. "),
  442. )
  443. ->orderBy('schedules.date', 'asc')
  444. ->get();
  445. $pendingSchedules->each(function ($item) {
  446. $item->provider_photo = $item->provider_photo_path
  447. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  448. : null;
  449. unset($item->provider_photo_path);
  450. });
  451. $proposalsDistanceSelect = DistanceService::sqlExpression(
  452. data_get($clientCoordinates, 'latitude'),
  453. data_get($clientCoordinates, 'longitude'),
  454. );
  455. $schedulesProposals = ScheduleProposal::query()
  456. ->leftJoin(
  457. 'schedules',
  458. 'schedule_proposals.schedule_id',
  459. '=',
  460. 'schedules.id'
  461. )
  462. ->leftJoin(
  463. 'providers',
  464. 'schedule_proposals.provider_id',
  465. '=',
  466. 'providers.id'
  467. )
  468. ->whereNotNull('providers.recipient_default_bank_account')
  469. ->whereRaw("providers.recipient_default_bank_account::text <> '{}'")
  470. ->whereRaw("providers.recipient_default_bank_account::text <> '[]'")
  471. ->leftJoin('users', 'providers.user_id', '=', 'users.id')
  472. ->leftJoin(
  473. DB::raw("
  474. (
  475. SELECT DISTINCT ON (source_id)
  476. *
  477. FROM addresses
  478. WHERE source = 'provider'
  479. AND deleted_at IS NULL
  480. ORDER BY source_id, is_primary DESC
  481. ) AS provider_address
  482. "),
  483. 'provider_address.source_id',
  484. '=',
  485. 'providers.id'
  486. )
  487. ->leftJoin(
  488. 'media as provider_media',
  489. 'provider_media.id',
  490. '=',
  491. 'providers.profile_media_id'
  492. )
  493. ->where('schedules.client_id', $cliente->id)
  494. ->where('schedules.schedule_type', 'custom')
  495. ->where('schedules.status', 'pending')
  496. ->whereNull('schedules.deleted_at')
  497. ->whereDate('schedules.date', '>=', now()->toDateString())
  498. ->orderBy('schedule_proposals.created_at', 'desc')
  499. ->select([
  500. 'schedule_proposals.id',
  501. DB::raw("
  502. DATE_PART('year', AGE(providers.birth_date)) AS idade
  503. "),
  504. 'providers.id as provider_id',
  505. 'schedules.id as schedule_id',
  506. 'schedules.date',
  507. 'schedules.start_time',
  508. 'schedules.end_time',
  509. 'schedules.period_type',
  510. 'schedules.total_amount',
  511. 'providers.daily_price_8h',
  512. 'providers.average_rating',
  513. 'providers.total_services',
  514. 'users.name as provider_name',
  515. 'provider_address.latitude as provider_latitude',
  516. 'provider_address.longitude as provider_longitude',
  517. 'provider_address.zip_code as provider_zip_code',
  518. $proposalsDistanceSelect,
  519. 'provider_media.path as provider_photo_path',
  520. ])
  521. ->get();
  522. $this->zipCodeCoordinatesService->preload(
  523. $schedulesProposals->whereNull('distance_km')->pluck('provider_zip_code')
  524. );
  525. $custom_schedules_with_no_proposals = Schedule::where('client_id', $cliente->id)
  526. ->where('schedule_type', 'custom')
  527. ->where('status', 'pending')
  528. ->whereDate('date', '>=', now()->toDateString())
  529. ->doesntHave('proposals')
  530. ->get();
  531. $schedulesProposals->each(function ($item) use ($clientDistanceAddress) {
  532. if ($item->distance_km === null) {
  533. $item->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  534. $clientDistanceAddress?->latitude !== null ? (float) $clientDistanceAddress->latitude : null,
  535. $clientDistanceAddress?->longitude !== null ? (float) $clientDistanceAddress->longitude : null,
  536. $clientDistanceAddress?->zip_code,
  537. $item->provider_latitude !== null ? (float) $item->provider_latitude : null,
  538. $item->provider_longitude !== null ? (float) $item->provider_longitude : null,
  539. $item->provider_zip_code,
  540. );
  541. }
  542. $item->provider_photo = $item->provider_photo_path
  543. ? Storage::temporaryUrl($item->provider_photo_path, now()->addMinutes(60))
  544. : null;
  545. unset(
  546. $item->provider_photo_path,
  547. $item->provider_latitude,
  548. $item->provider_longitude,
  549. $item->provider_zip_code,
  550. );
  551. });
  552. $todaySchedules = Schedule::with([
  553. 'address:district,address,number,source_id,source,id,address_type',
  554. ])
  555. ->where('schedules.client_id', $cliente->id)
  556. ->whereIn('schedules.status', ['accepted', 'paid', 'started', 'finished'])
  557. ->whereDate('schedules.date', now()->toDateString())
  558. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  559. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  560. ->leftJoin('media', 'media.id', '=', 'providers.profile_media_id')
  561. ->select(
  562. 'schedules.id',
  563. 'schedules.provider_id',
  564. 'provider_user.name as provider_name',
  565. 'schedules.date',
  566. 'schedules.start_time',
  567. 'schedules.end_time',
  568. 'schedules.total_amount',
  569. 'schedules.period_type',
  570. 'schedules.schedule_type',
  571. 'schedules.address_id',
  572. 'schedules.status',
  573. 'schedules.code_verified',
  574. 'schedules.code',
  575. 'media.path as provider_photo',
  576. DB::raw("
  577. (
  578. SELECT spi.service_package_id
  579. FROM service_package_items spi
  580. WHERE spi.schedule_id = schedules.id
  581. LIMIT 1
  582. ) AS service_package_id
  583. "),
  584. DB::raw("
  585. (
  586. SELECT COUNT(*)
  587. FROM service_package_items spi_count
  588. WHERE spi_count.service_package_id = (
  589. SELECT spi.service_package_id
  590. FROM service_package_items spi
  591. WHERE spi.schedule_id = schedules.id
  592. LIMIT 1
  593. )
  594. ) AS service_package_items_count
  595. "),
  596. DB::raw("
  597. EXISTS (
  598. SELECT 1
  599. FROM reviews
  600. WHERE reviews.schedule_id = schedules.id
  601. AND reviews.origin = 'client'
  602. AND reviews.origin_id = {$cliente->id}
  603. AND reviews.deleted_at IS NULL
  604. ) AS client_reviewed
  605. "),
  606. )
  607. ->orderBy('schedules.start_time', 'asc')
  608. ->get()
  609. ->map(function ($item) {
  610. $item->provider_photo = $item->provider_photo
  611. ? Storage::temporaryUrl(
  612. $item->provider_photo,
  613. now()->addMinutes(60)
  614. )
  615. : null;
  616. return $item;
  617. });
  618. $notifications = Notification::where('user_id', $user->id)
  619. ->orderBy('read', 'asc')
  620. ->orderBy('created_at', 'desc')
  621. ->limit(10)
  622. ->get()
  623. ->map(function ($notification) {
  624. return [
  625. 'id' => $notification->id,
  626. 'title' => $notification->title,
  627. 'description' => $notification->description,
  628. 'time' => $notification->created_at->diffForHumans(),
  629. 'read' => $notification->read,
  630. 'avatar' => '/icons/avatar.svg',
  631. ];
  632. });
  633. $hasPaymentMethods = ClientPaymentMethod::where('client_id', $cliente->id)->exists();
  634. return [
  635. 'headerBar' => $headerBar,
  636. 'summaryInfos' => $summaryInfos,
  637. 'pendingSchedules' => $pendingSchedules,
  638. 'nextSchedules' => $nextSchedules,
  639. 'lastDoneSchedules' => $lastDoneSchedules,
  640. 'favoriteProviders' => $favoriteProviders,
  641. 'providersClose' => $providersClose,
  642. 'todaySchedules' => $todaySchedules,
  643. 'schedulesProposals' => $schedulesProposals,
  644. 'customSchedulesNoProposals' => $custom_schedules_with_no_proposals,
  645. 'notifications' => $notifications,
  646. 'has_payment_methods' => $hasPaymentMethods,
  647. ];
  648. }
  649. public function dadosDashboardPrestador(): array
  650. {
  651. $user = Auth::user();
  652. if ($user->type !== UserTypeEnum::PROVIDER) {
  653. throw new AuthorizationException(__('messages.only_providers_allowed'));
  654. }
  655. $provider = Provider::with('profileMedia')->where('user_id', $user->id)->first();
  656. $headerBar = [
  657. 'rating' => $provider->average_rating,
  658. 'total_ratings' => Review::where('reviews.origin', 'client')->leftJoin('schedules', 'schedules.id', '=', 'reviews.schedule_id')->where('schedules.provider_id', $provider->id)->count(),
  659. 'total_services' => $provider->total_services,
  660. ];
  661. $address = Address::where('source', 'provider')->where('source_id', $provider->id)->with(['city', 'state'])->first();
  662. $summaryInfos = [
  663. 'name' => $user->name,
  664. 'address' => $address,
  665. 'pending_services' => Schedule::where('provider_id', $provider->id)->where('status', 'pending')->count(),
  666. 'profile_photo' => $provider->profileMedia?->path
  667. ? Storage::temporaryUrl($provider->profileMedia->path, now()->addMinutes(60))
  668. : null,
  669. ];
  670. $priceSuggestedAvg = Provider::where('user_id', '!=', $user->id)
  671. ->whereNotNull('daily_price_8h')
  672. ->pluck('daily_price_8h')
  673. ->avg();
  674. $priceActual = $provider->daily_price_8h;
  675. $priceSuggested = [
  676. 'average_price' => $priceSuggestedAvg,
  677. 'your_price' => $priceActual,
  678. ];
  679. $solicitations = Schedule::with([
  680. 'address:district,source_id,source,id,zip_code,latitude,longitude',
  681. ])
  682. ->where('schedules.provider_id', $provider->id)
  683. ->where('schedules.status', 'pending')
  684. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  685. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  686. ->leftJoin('media as client_media', 'client_media.id', '=', 'clients.profile_media_id')
  687. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  688. ->select(
  689. 'schedules.id',
  690. 'client_user.name as client_name',
  691. 'clients.average_rating',
  692. 'schedules.date',
  693. DB::raw("
  694. TO_CHAR(schedules.date, 'DD/MM/YYYY') AS formatted_date
  695. "),
  696. 'schedules.start_time',
  697. 'schedules.end_time',
  698. 'schedules.total_amount',
  699. 'schedules.period_type',
  700. 'schedules.schedule_type',
  701. 'schedules.address_id',
  702. 'schedules.status',
  703. 'custom_schedules.offers_meal',
  704. 'client_media.path as customer_photo_path',
  705. DB::raw("
  706. CASE
  707. WHEN (NOW() - schedules.created_at) < INTERVAL '1 day' THEN
  708. CONCAT(
  709. ROUND(
  710. EXTRACT(
  711. EPOCH FROM (NOW() - schedules.created_at)
  712. ) / 3600
  713. ),
  714. ' hours ago'
  715. )
  716. ELSE
  717. CONCAT(
  718. ROUND(
  719. EXTRACT(
  720. EPOCH FROM (NOW() - schedules.created_at)
  721. ) / 86400
  722. ),
  723. ' days ago'
  724. )
  725. END AS time_since_request
  726. "),
  727. )
  728. ->orderBy('schedules.date', 'asc')
  729. ->get();
  730. $solicitations->each(function ($solicitation) use ($address) {
  731. $solicitation->customer_photo = $solicitation->customer_photo_path
  732. ? Storage::temporaryUrl($solicitation->customer_photo_path, now()->addMinutes(60))
  733. : null;
  734. unset($solicitation->customer_photo_path);
  735. $solicitation->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  736. $address?->latitude !== null ? (float) $address->latitude : null,
  737. $address?->longitude !== null ? (float) $address->longitude : null,
  738. $address?->zip_code,
  739. $solicitation->address?->latitude !== null ? (float) $solicitation->address->latitude : null,
  740. $solicitation->address?->longitude !== null ? (float) $solicitation->address->longitude : null,
  741. $solicitation->address?->zip_code,
  742. );
  743. });
  744. $todayServices = Schedule::with([
  745. 'address:district,address,number,source_id,source,id',
  746. ])
  747. ->where('schedules.provider_id', $provider->id)
  748. ->whereIn('schedules.status', ['accepted', 'paid', 'started', 'finished'])
  749. ->whereDate('schedules.date', now()->toDateString())
  750. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  751. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  752. ->leftJoin('media as client_media', 'client_media.id', '=', 'clients.profile_media_id')
  753. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  754. ->select(
  755. 'schedules.id',
  756. 'schedules.client_id',
  757. 'client_user.name as client_name',
  758. 'schedules.date',
  759. 'schedules.start_time',
  760. 'schedules.end_time',
  761. 'schedules.total_amount',
  762. 'schedules.period_type',
  763. 'schedules.address_id',
  764. 'schedules.schedule_type',
  765. 'schedules.status',
  766. 'schedules.code_verified',
  767. 'schedules.code',
  768. 'custom_schedules.offers_meal',
  769. 'client_media.path as customer_photo_path',
  770. DB::raw("
  771. EXISTS (
  772. SELECT 1
  773. FROM reviews
  774. WHERE reviews.schedule_id = schedules.id
  775. AND reviews.origin = 'provider'
  776. AND reviews.origin_id = {$provider->id}
  777. AND reviews.deleted_at IS NULL
  778. ) AS provider_reviewed
  779. "),
  780. )
  781. ->orderBy('schedules.start_time', 'asc')
  782. ->get();
  783. $todayServices->each(function ($s) {
  784. $s->customer_photo = $s->customer_photo_path
  785. ? Storage::temporaryUrl($s->customer_photo_path, now()->addMinutes(60))
  786. : null;
  787. unset($s->customer_photo_path);
  788. });
  789. $nextSchedules = Schedule::with('address:district,address,number,source_id,source,id,zip_code,latitude,longitude')
  790. ->where('schedules.provider_id', $provider->id)
  791. ->whereIn('schedules.status', ['accepted', 'paid'])
  792. ->whereDate('schedules.date', '>=', now()->toDateString())
  793. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  794. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  795. ->leftJoin('media as client_media', 'client_media.id', '=', 'clients.profile_media_id')
  796. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  797. ->select(
  798. 'schedules.id',
  799. 'client_user.name as client_name',
  800. 'schedules.date',
  801. 'schedules.start_time',
  802. 'schedules.end_time',
  803. 'schedules.total_amount',
  804. 'schedules.period_type',
  805. 'schedules.address_id',
  806. 'schedules.schedule_type',
  807. 'schedules.status',
  808. 'custom_schedules.offers_meal',
  809. 'client_media.path as customer_photo_path',
  810. )
  811. ->orderBy('schedules.date', 'asc')
  812. ->get();
  813. $nextSchedules->each(function ($schedule) use ($address) {
  814. $schedule->customer_photo = $schedule->customer_photo_path
  815. ? Storage::temporaryUrl($schedule->customer_photo_path, now()->addMinutes(60))
  816. : null;
  817. unset($schedule->customer_photo_path);
  818. $schedule->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  819. $address?->latitude !== null ? (float) $address->latitude : null,
  820. $address?->longitude !== null ? (float) $address->longitude : null,
  821. $address?->zip_code,
  822. $schedule->address?->latitude !== null ? (float) $schedule->address->latitude : null,
  823. $schedule->address?->longitude !== null ? (float) $schedule->address->longitude : null,
  824. $schedule->address?->zip_code,
  825. );
  826. });
  827. $notifications = Notification::where('user_id', $user->id)
  828. ->orderBy('read', 'asc')
  829. ->orderBy('created_at', 'desc')
  830. ->limit(10)
  831. ->get()
  832. ->map(function ($notification) {
  833. return [
  834. 'id' => $notification->id,
  835. 'title' => $notification->title,
  836. 'description' => $notification->description,
  837. 'time' => $notification->created_at->diffForHumans(),
  838. 'read' => $notification->read,
  839. 'avatar' => '/icons/avatar.svg',
  840. ];
  841. });
  842. $opportunities = $this->customScheduleService->getAvailableOpportunities($provider->id);
  843. $opportunities->each(function ($o) {
  844. $o->customer_photo = $o->client?->profileMedia?->path
  845. ? Storage::temporaryUrl($o->client->profileMedia->path, now()->addMinutes(60))
  846. : null;
  847. });
  848. return [
  849. 'headerBar' => $headerBar,
  850. 'summaryInfos' => $summaryInfos,
  851. 'priceSuggested' => $priceSuggested,
  852. 'solicitations' => $solicitations,
  853. 'todayServices' => $todayServices,
  854. 'nextSchedules' => $nextSchedules,
  855. 'opportunities' => $opportunities,
  856. 'notifications' => $notifications,
  857. ];
  858. }
  859. public function getScheduleClienteDetails(int $scheduleId): array
  860. {
  861. $user = Auth::user();
  862. $cliente = Client::where('user_id', $user->id)->firstOrFail();
  863. $schedule = Schedule::where('schedules.id', $scheduleId)
  864. ->where('schedules.client_id', $cliente->id)
  865. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  866. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  867. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  868. ->leftJoin('media', 'media.id', '=', 'providers.profile_media_id')
  869. ->select(
  870. 'schedules.provider_id',
  871. 'provider_user.name as provider_name',
  872. 'providers.birth_date as provider_birth_date',
  873. 'media.path as provider_photo',
  874. 'custom_schedules.offers_meal',
  875. )
  876. ->firstOrFail();
  877. $allSpecialities = Speciality::where('active', true)
  878. ->select('id', 'description')
  879. ->orderBy('description')
  880. ->get();
  881. $providerSpecialityIds = ProviderSpeciality::where('provider_id', $schedule->provider_id)
  882. ->pluck('speciality_id')
  883. ->all();
  884. $specialities = $allSpecialities->map(fn($sp) => [
  885. 'id' => $sp->id,
  886. 'description' => $sp->description,
  887. 'has_speciality' => in_array($sp->id, $providerSpecialityIds),
  888. ])->values();
  889. return [
  890. 'provider_name' => $schedule->provider_name,
  891. 'provider_birth_date' => $schedule->provider_birth_date,
  892. 'offers_meal' => $schedule->offers_meal,
  893. 'specialities' => $specialities,
  894. 'provider_photo' => $schedule->provider_photo
  895. ? Storage::temporaryUrl($schedule->provider_photo, now()->addMinutes(60))
  896. : null,
  897. ];
  898. }
  899. //
  900. private function applyCreditCardFee(?float $price): ?float
  901. {
  902. if ($price === null) {
  903. return null;
  904. }
  905. $rate = $this->platformCreditCardFeeRate();
  906. return round($price * (1 + $rate), 2);
  907. }
  908. private function platformCreditCardFeeRate(): float
  909. {
  910. $rate = config('services.pagarme.platform_credit_card_fee_rate', 0.16);
  911. if (is_string($rate)) {
  912. $rate = str_replace(',', '.', trim($rate));
  913. }
  914. $rate = (float) $rate;
  915. return $rate > 1 ? $rate / 100 : $rate;
  916. }
  917. private function addressForDistance(int $clientId, ?Address $primaryAddress): ?Address
  918. {
  919. if ($primaryAddress?->latitude !== null && $primaryAddress?->longitude !== null) {
  920. return $primaryAddress;
  921. }
  922. return Address::where('source', 'client')
  923. ->where('source_id', $clientId)
  924. ->whereNotNull('latitude')
  925. ->whereNotNull('longitude')
  926. ->orderByDesc('is_primary')
  927. ->orderByDesc('id')
  928. ->first() ?? $primaryAddress;
  929. }
  930. private function distanceSelect(?float $clientLatitude, ?float $clientLongitude): \Illuminate\Contracts\Database\Query\Expression
  931. {
  932. return DistanceService::sqlExpression($clientLatitude, $clientLongitude);
  933. }
  934. }