DashboardService.php 60 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474
  1. <?php
  2. namespace App\Services;
  3. use App\Enums\ApprovalStatusEnum;
  4. use App\Enums\GenderEnum;
  5. use App\Enums\ServicePackageStatusEnum;
  6. use App\Enums\UserTypeEnum;
  7. use App\Models\Address;
  8. use App\Models\Client;
  9. use App\Models\ClientFavoriteProvider;
  10. use App\Models\ClientPaymentMethod;
  11. use App\Models\Notification;
  12. use App\Models\Provider;
  13. use App\Models\ProviderSpeciality;
  14. use App\Models\Review;
  15. use App\Models\Schedule;
  16. use App\Models\ScheduleProposal;
  17. use App\Models\ServicePackage;
  18. use App\Rules\ScheduleBusinessRules;
  19. use Illuminate\Auth\Access\AuthorizationException;
  20. use Illuminate\Support\Collection;
  21. use Illuminate\Support\Facades\Auth;
  22. use Illuminate\Support\Facades\DB;
  23. use Illuminate\Support\Facades\Storage;
  24. class DashboardService
  25. {
  26. private const NEARBY_RADIUS_KM = 20.0;
  27. public function __construct(
  28. private readonly CustomScheduleService $customScheduleService,
  29. private readonly ZipCodeCoordinatesService $zipCodeCoordinatesService,
  30. ) {}
  31. public function dadosDashboardCliente(): array
  32. {
  33. $user = Auth::user();
  34. if ($user->type !== UserTypeEnum::CLIENT) {
  35. throw new AuthorizationException(__('messages.only_clients_allowed'));
  36. }
  37. $cliente = Client::with('profileMedia')->where('user_id', $user->id)->first();
  38. $headerBar = [
  39. 'rating' => $cliente->average_rating,
  40. 'total_services' => $cliente->total_services,
  41. 'total_ratings' => Review::where('reviews.origin', 'provider')
  42. ->leftJoin('schedules', 'schedules.id', '=', 'reviews.schedule_id')
  43. ->where('schedules.client_id', $cliente->id)
  44. ->count(),
  45. ];
  46. $address = Address::where('source', 'client')
  47. ->where('source_id', $cliente->id)
  48. ->with(['city', 'state'])
  49. ->select('id', 'source', 'source_id', 'address', 'number', 'district', 'nickname', 'address_type', 'city_id', 'state_id', 'is_primary')
  50. ->orderByDesc('is_primary')
  51. ->orderByDesc('id')
  52. ->first();
  53. $summaryInfos = [
  54. 'name' => $user->name,
  55. 'address' => $address,
  56. 'profile_photo' => $cliente->profileMedia?->path
  57. ? Storage::temporaryUrl($cliente->profileMedia->path, now()->addMinutes(60))
  58. : null,
  59. 'pending_services' => Schedule::where('client_id', $cliente->id)
  60. ->whereIn('status', ['pending', 'paid', 'accepted'])
  61. ->whereDate('date', '>=', now()->toDateString())
  62. ->count(),
  63. ];
  64. $nextSchedules = Schedule::with([
  65. 'address:district,address,source_id,source,id,address_type',
  66. ])
  67. ->where('schedules.client_id', $cliente->id)
  68. ->where('schedules.status', 'paid')
  69. ->whereDate('schedules.date', '>', now()->toDateString())
  70. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  71. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  72. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  73. ->select(
  74. 'schedules.id',
  75. 'schedules.provider_id',
  76. 'provider_user.name as provider_name',
  77. 'providers.gender',
  78. 'schedules.date',
  79. 'schedules.start_time',
  80. 'schedules.end_time',
  81. 'schedules.total_amount',
  82. 'schedules.period_type',
  83. 'schedules.schedule_type',
  84. 'schedules.address_id',
  85. 'custom_schedules.address_type as custom_address_type',
  86. DB::raw("
  87. (
  88. SELECT spi.service_package_id
  89. FROM service_package_items spi
  90. WHERE spi.schedule_id = schedules.id
  91. LIMIT 1
  92. ) AS service_package_id
  93. "),
  94. DB::raw("
  95. (
  96. SELECT COUNT(*)
  97. FROM service_package_items spi_count
  98. JOIN schedules s_count ON s_count.id = spi_count.schedule_id
  99. AND s_count.status NOT IN ('cancelled', 'rejected')
  100. AND s_count.schedule_type = 'default'
  101. WHERE spi_count.service_package_id = (
  102. SELECT spi.service_package_id
  103. FROM service_package_items spi
  104. WHERE spi.schedule_id = schedules.id
  105. LIMIT 1
  106. )
  107. ) AS service_package_items_count
  108. "),
  109. )
  110. ->orderBy('schedules.date', 'asc')
  111. ->limit(5)
  112. ->get();
  113. $nextSchedules->each(function ($item) {
  114. $item->gender_label = GenderEnum::labelFor($item->gender);
  115. });
  116. $latestPerProvider = Schedule::where('client_id', $cliente->id)
  117. ->where('status', 'finished')
  118. ->select('provider_id', DB::raw('MAX(id) as max_id'))
  119. ->groupBy('provider_id');
  120. $lastDoneSchedules = Schedule::joinSub($latestPerProvider, 'latest', function ($join) {
  121. $join->on('schedules.id', '=', 'latest.max_id');
  122. })
  123. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  124. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  125. ->leftJoinSub(
  126. Address::preferredForProvider(),
  127. 'provider_address',
  128. fn($join) =>
  129. $join->on('provider_address.source_id', '=', 'providers.id')
  130. ->where('provider_address.rn', 1)
  131. )
  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. )
  139. ->orderBy('schedules.date', 'desc')
  140. ->limit(5)
  141. ->get();
  142. $lastDoneSchedules->each(function ($item) {
  143. $item->gender_label = GenderEnum::labelFor($item->gender);
  144. });
  145. $favoriteProviders = ClientFavoriteProvider::where('client_favorite_providers.client_id', $cliente->id)
  146. ->leftJoin('providers', 'providers.id', '=', 'client_favorite_providers.provider_id')
  147. ->whereExists(Provider::hasActivePrimaryBankAccount())
  148. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  149. ->leftJoinSub(
  150. Address::preferredForProvider(),
  151. 'provider_address',
  152. fn($join) =>
  153. $join->on('provider_address.source_id', '=', 'providers.id')
  154. ->where('provider_address.rn', 1)
  155. )
  156. ->select(
  157. 'providers.id as provider_id',
  158. 'provider_user.name as provider_name',
  159. 'providers.gender',
  160. 'providers.average_rating',
  161. 'provider_address.district as provider_district',
  162. )
  163. ->orderBy('client_favorite_providers.created_at', 'desc')
  164. ->limit(5)
  165. ->get();
  166. $favoriteProviders->each(function ($item) {
  167. $item->gender_label = GenderEnum::labelFor($item->gender);
  168. });
  169. $blockedProviderIds = ScheduleBusinessRules::getBlockedProviderIdsForClient($cliente->id);
  170. $providersWithWorkingDays = ScheduleBusinessRules::getProviderIdsWithWorkingDays();
  171. $clientPrimaryAddress = Address::where('source', 'client')
  172. ->where('source_id', $cliente->id)
  173. ->orderByDesc('is_primary')
  174. ->orderByDesc('id')
  175. ->first();
  176. $providersCloseCityId = $clientPrimaryAddress?->city_id;
  177. $providersCloseLatitude = $clientPrimaryAddress?->latitude !== null ? (float) $clientPrimaryAddress->latitude : null;
  178. $providersCloseLongitude = $clientPrimaryAddress?->longitude !== null ? (float) $clientPrimaryAddress->longitude : null;
  179. $hasLocation = $providersCloseLatitude !== null && $providersCloseLongitude !== null;
  180. $providersCloseDistanceSelect = $this->distanceSelect(
  181. $providersCloseLatitude,
  182. $providersCloseLongitude,
  183. );
  184. $providerAddressLatestSubquery = DB::raw("
  185. (
  186. SELECT DISTINCT ON (source_id)
  187. *
  188. FROM addresses
  189. WHERE
  190. source = 'provider'
  191. AND deleted_at IS NULL
  192. ORDER BY
  193. source_id,
  194. (latitude IS NOT NULL AND longitude IS NOT NULL) DESC,
  195. is_primary DESC,
  196. id DESC
  197. ) AS provider_address
  198. ");
  199. $providersClose = $hasLocation
  200. ? Provider::leftJoin(
  201. 'users as provider_user',
  202. 'provider_user.id',
  203. '=',
  204. 'providers.user_id'
  205. )
  206. ->visibleToCustomers()
  207. ->leftJoin(
  208. $providerAddressLatestSubquery,
  209. 'provider_address.source_id',
  210. '=',
  211. 'providers.id'
  212. )
  213. ->whereNotNull('provider_address.id')
  214. ->where(function ($query) use ($providersCloseCityId, $providersCloseLatitude, $providersCloseLongitude) {
  215. if ($providersCloseCityId !== null) {
  216. $query->orWhere('provider_address.city_id', $providersCloseCityId);
  217. }
  218. if ($providersCloseLatitude !== null && $providersCloseLongitude !== null) {
  219. $query->orWhereRaw(
  220. DistanceService::withinRadiusSqlCondition(
  221. (float) $providersCloseLatitude,
  222. (float) $providersCloseLongitude,
  223. self::NEARBY_RADIUS_KM,
  224. )
  225. );
  226. }
  227. })
  228. ->whereNotIn('providers.id', $blockedProviderIds)
  229. ->whereIn('providers.id', $providersWithWorkingDays)
  230. ->whereNull('providers.deleted_at')
  231. ->select(
  232. 'providers.id as provider_id',
  233. 'provider_user.name as provider_name',
  234. 'providers.gender',
  235. 'provider_address.id as address_id',
  236. 'provider_address.zip_code as provider_zip_code',
  237. 'provider_address.district',
  238. 'provider_address.latitude as provider_latitude',
  239. 'provider_address.longitude as provider_longitude',
  240. 'providers.average_rating',
  241. 'providers.total_services',
  242. 'providers.daily_price_8h',
  243. 'providers.daily_price_6h',
  244. 'providers.daily_price_4h',
  245. 'providers.daily_price_2h',
  246. DB::raw("
  247. (
  248. SELECT COUNT(*)
  249. FROM reviews
  250. LEFT JOIN schedules
  251. ON schedules.id = reviews.schedule_id
  252. WHERE reviews.origin = 'provider'
  253. AND schedules.provider_id = providers.id
  254. ) AS total_reviews
  255. "),
  256. $providersCloseDistanceSelect,
  257. )
  258. ->orderByRaw('distance_km ASC NULLS LAST')
  259. ->get()
  260. : collect();
  261. if ($hasLocation) {
  262. $this->zipCodeCoordinatesService->preload(
  263. $providersClose->whereNull('distance_km')->pluck('provider_zip_code')
  264. );
  265. $providersClose->each(function ($item) use ($clientPrimaryAddress) {
  266. $item->gender_label = GenderEnum::labelFor($item->gender);
  267. if ($item->distance_km === null) {
  268. $item->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  269. $clientPrimaryAddress?->latitude !== null ? (float) $clientPrimaryAddress->latitude : null,
  270. $clientPrimaryAddress?->longitude !== null ? (float) $clientPrimaryAddress->longitude : null,
  271. $clientPrimaryAddress?->zip_code,
  272. $item->provider_latitude !== null ? (float) $item->provider_latitude : null,
  273. $item->provider_longitude !== null ? (float) $item->provider_longitude : null,
  274. $item->provider_zip_code,
  275. );
  276. }
  277. $item->specialities = ProviderSpeciality::query()
  278. ->join('specialities', 'specialities.id', '=', 'provider_specialities.speciality_id')
  279. ->where('provider_specialities.provider_id', $item->provider_id)
  280. ->where('specialities.active', true)
  281. ->orderBy('specialities.description')
  282. ->get([
  283. 'specialities.id',
  284. 'specialities.description',
  285. ]);
  286. $item->age = Provider::query()
  287. ->where('id', $item->provider_id)
  288. ->value(DB::raw("DATE_PART('year', AGE(birth_date))"));
  289. unset($item->provider_zip_code);
  290. $item->daily_price_8h_base = $item->daily_price_8h;
  291. $item->daily_price_6h_base = $item->daily_price_6h;
  292. $item->daily_price_4h_base = $item->daily_price_4h;
  293. $item->daily_price_2h_base = $item->daily_price_2h;
  294. $item->daily_price_8h = $this->applyCreditCardFee($item->daily_price_8h);
  295. $item->daily_price_6h = $this->applyCreditCardFee($item->daily_price_6h);
  296. $item->daily_price_4h = $this->applyCreditCardFee($item->daily_price_4h);
  297. $item->daily_price_2h = $this->applyCreditCardFee($item->daily_price_2h);
  298. });
  299. $providersClose = $providersClose
  300. ->sortBy(fn($provider) => $provider->distance_km ?? PHP_FLOAT_MAX)
  301. ->values();
  302. }
  303. $pendingSchedules = Schedule::with([
  304. 'address:district,address,number,source_id,source,id,address_type',
  305. ])
  306. ->where('schedules.client_id', $cliente->id)
  307. ->whereIn('schedules.status', ['pending', 'accepted'])
  308. ->where('schedules.schedule_type', 'default')
  309. ->whereDate('schedules.date', '>=', now()->toDateString())
  310. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  311. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  312. ->select(
  313. 'schedules.id',
  314. 'schedules.provider_id',
  315. 'provider_user.name as provider_name',
  316. 'providers.gender',
  317. 'schedules.date',
  318. 'schedules.address_id',
  319. 'schedules.status',
  320. 'schedules.total_amount',
  321. 'schedules.start_time',
  322. 'schedules.end_time',
  323. DB::raw("
  324. CASE
  325. WHEN (NOW() - schedules.created_at) < INTERVAL '1 hour' THEN
  326. CONCAT(
  327. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 60),
  328. 'min'
  329. )
  330. WHEN (NOW() - schedules.created_at) < INTERVAL '1 day' THEN
  331. CONCAT(
  332. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 3600),
  333. 'h'
  334. )
  335. ELSE
  336. CONCAT(
  337. ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 86400),
  338. 'd'
  339. )
  340. END AS time_since_request
  341. "),
  342. DB::raw("
  343. (
  344. SELECT spi.service_package_id
  345. FROM service_package_items spi
  346. WHERE spi.schedule_id = schedules.id
  347. LIMIT 1
  348. ) AS service_package_id
  349. "),
  350. DB::raw("
  351. (
  352. SELECT COUNT(*)
  353. FROM service_package_items spi_count
  354. JOIN schedules s_count ON s_count.id = spi_count.schedule_id
  355. AND s_count.status NOT IN ('cancelled', 'rejected')
  356. AND s_count.schedule_type = 'default'
  357. WHERE spi_count.service_package_id = (
  358. SELECT spi.service_package_id
  359. FROM service_package_items spi
  360. WHERE spi.schedule_id = schedules.id
  361. LIMIT 1
  362. )
  363. ) AS service_package_items_count
  364. "),
  365. )
  366. ->orderBy('schedules.date', 'asc')
  367. ->get();
  368. $pendingSchedules->each(function ($item) {
  369. $item->gender_label = GenderEnum::labelFor($item->gender);
  370. });
  371. $this->attachPackageItems($pendingSchedules);
  372. $proposalsDistanceSelect = DistanceService::sqlExpression(
  373. $providersCloseLatitude,
  374. $providersCloseLongitude,
  375. );
  376. $schedulesProposals = ScheduleProposal::query()
  377. ->leftJoin(
  378. 'schedules',
  379. 'schedule_proposals.schedule_id',
  380. '=',
  381. 'schedules.id'
  382. )
  383. ->leftJoin(
  384. 'providers',
  385. 'schedule_proposals.provider_id',
  386. '=',
  387. 'providers.id'
  388. )
  389. ->whereExists(Provider::hasActivePrimaryBankAccount())
  390. ->leftJoin('users', 'providers.user_id', '=', 'users.id')
  391. ->leftJoin(
  392. DB::raw("
  393. (
  394. SELECT DISTINCT ON (source_id)
  395. *
  396. FROM addresses
  397. WHERE source = 'provider'
  398. AND deleted_at IS NULL
  399. ORDER BY source_id, is_primary DESC
  400. ) AS provider_address
  401. "),
  402. 'provider_address.source_id',
  403. '=',
  404. 'providers.id'
  405. )
  406. ->leftJoin(
  407. 'addresses as schedule_address',
  408. 'schedule_address.id',
  409. '=',
  410. 'schedules.address_id'
  411. )
  412. ->where('schedules.client_id', $cliente->id)
  413. ->where('schedules.schedule_type', 'custom')
  414. ->where('schedules.status', 'pending')
  415. ->whereNull('schedules.deleted_at')
  416. ->whereDate('schedules.date', '>=', now()->toDateString())
  417. ->orderBy('schedule_proposals.created_at', 'desc')
  418. ->select([
  419. 'schedule_proposals.id',
  420. DB::raw("
  421. DATE_PART('year', AGE(providers.birth_date)) AS idade
  422. "),
  423. 'providers.id as provider_id',
  424. 'providers.gender',
  425. 'schedules.id as schedule_id',
  426. 'schedules.date',
  427. 'schedules.start_time',
  428. 'schedules.end_time',
  429. 'schedules.period_type',
  430. 'schedules.total_amount',
  431. 'providers.daily_price_8h',
  432. 'providers.average_rating',
  433. 'providers.total_services',
  434. 'users.name as provider_name',
  435. 'provider_address.latitude as provider_latitude',
  436. 'provider_address.longitude as provider_longitude',
  437. 'provider_address.zip_code as provider_zip_code',
  438. 'schedule_address.address as address',
  439. 'schedule_address.number as address_number',
  440. 'schedule_address.district as address_district',
  441. 'schedule_address.address_type as address_type',
  442. $proposalsDistanceSelect,
  443. ])
  444. ->get();
  445. $this->zipCodeCoordinatesService->preload(
  446. $schedulesProposals->whereNull('distance_km')->pluck('provider_zip_code')
  447. );
  448. $custom_schedules_with_no_proposals = Schedule::with('address:district,address,number,source_id,source,id')
  449. ->where('client_id', $cliente->id)
  450. ->where('schedule_type', 'custom')
  451. ->where('status', 'pending')
  452. ->whereDate('date', '>=', now()->toDateString())
  453. ->doesntHave('proposals')
  454. ->get();
  455. $schedulesProposals->each(function ($item) use ($clientPrimaryAddress) {
  456. $item->gender_label = GenderEnum::labelFor($item->gender);
  457. $item->address = [
  458. 'address' => $item->address,
  459. 'number' => $item->address_number,
  460. 'district' => $item->address_district,
  461. 'address_type' => $item->address_type,
  462. ];
  463. unset($item->address_number, $item->address_district);
  464. if ($item->distance_km === null) {
  465. $item->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  466. $clientPrimaryAddress?->latitude !== null ? (float) $clientPrimaryAddress->latitude : null,
  467. $clientPrimaryAddress?->longitude !== null ? (float) $clientPrimaryAddress->longitude : null,
  468. $clientPrimaryAddress?->zip_code,
  469. $item->provider_latitude !== null ? (float) $item->provider_latitude : null,
  470. $item->provider_longitude !== null ? (float) $item->provider_longitude : null,
  471. $item->provider_zip_code,
  472. );
  473. }
  474. unset(
  475. $item->provider_latitude,
  476. $item->provider_longitude,
  477. $item->provider_zip_code,
  478. );
  479. });
  480. $todaySchedules = Schedule::with([
  481. 'address:district,address,number,source_id,source,id,address_type',
  482. ])
  483. ->where('schedules.client_id', $cliente->id)
  484. ->whereIn('schedules.status', ['paid', 'started', 'finished'])
  485. ->whereDate('schedules.date', now()->toDateString())
  486. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  487. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  488. ->select(
  489. 'schedules.id',
  490. 'schedules.provider_id',
  491. 'provider_user.name as provider_name',
  492. 'providers.gender',
  493. 'schedules.date',
  494. 'schedules.start_time',
  495. 'schedules.end_time',
  496. 'schedules.total_amount',
  497. 'schedules.period_type',
  498. 'schedules.schedule_type',
  499. 'schedules.address_id',
  500. 'schedules.status',
  501. 'schedules.code_verified',
  502. 'schedules.code',
  503. DB::raw("
  504. (
  505. SELECT spi.service_package_id
  506. FROM service_package_items spi
  507. WHERE spi.schedule_id = schedules.id
  508. LIMIT 1
  509. ) AS service_package_id
  510. "),
  511. DB::raw("
  512. (
  513. SELECT COUNT(*)
  514. FROM service_package_items spi_count
  515. JOIN schedules s_count ON s_count.id = spi_count.schedule_id
  516. AND s_count.status NOT IN ('cancelled', 'rejected')
  517. AND s_count.schedule_type = 'default'
  518. WHERE spi_count.service_package_id = (
  519. SELECT spi.service_package_id
  520. FROM service_package_items spi
  521. WHERE spi.schedule_id = schedules.id
  522. LIMIT 1
  523. )
  524. ) AS service_package_items_count
  525. "),
  526. DB::raw("
  527. EXISTS (
  528. SELECT 1
  529. FROM reviews
  530. WHERE reviews.schedule_id = schedules.id
  531. AND reviews.origin = 'client'
  532. AND reviews.origin_id = {$cliente->id}
  533. AND reviews.deleted_at IS NULL
  534. ) AS client_reviewed
  535. "),
  536. )
  537. ->orderBy('schedules.start_time', 'asc')
  538. ->get()
  539. ->map(function ($item) {
  540. $item->gender_label = GenderEnum::labelFor($item->gender);
  541. return $item;
  542. });
  543. $providerCollections = collect([
  544. $nextSchedules,
  545. $lastDoneSchedules,
  546. $favoriteProviders,
  547. $providersClose,
  548. $pendingSchedules,
  549. $schedulesProposals,
  550. $todaySchedules,
  551. ]);
  552. $providerPhotoUrls = $this->providerPhotoUrls(
  553. $providerCollections->flatMap(
  554. fn(Collection $items) => $items->pluck('provider_id'),
  555. ),
  556. );
  557. $providerCollections->each(function (Collection $items) use ($providerPhotoUrls) {
  558. $items->each(function ($item) use ($providerPhotoUrls) {
  559. $item->provider_photo = $providerPhotoUrls->get($item->provider_id);
  560. });
  561. });
  562. $notifications = Notification::where('user_id', $user->id)
  563. ->orderBy('read', 'asc')
  564. ->orderBy('created_at', 'desc')
  565. ->limit(10)
  566. ->get()
  567. ->map(function ($notification) {
  568. return [
  569. 'id' => $notification->id,
  570. 'title' => $notification->title,
  571. 'description' => $notification->description,
  572. 'time' => $notification->created_at->diffForHumans(),
  573. 'read' => $notification->read,
  574. 'avatar' => '/icons/avatar.svg',
  575. ];
  576. });
  577. $hasPaymentMethods = ClientPaymentMethod::where('client_id', $cliente->id)->exists();
  578. $pendingServicePackages = ServicePackage::query()
  579. ->where('client_id', $cliente->id)
  580. ->where('status', ServicePackageStatusEnum::OPEN->value)
  581. ->whereHas('items.schedule', fn($q) => $q->where('status', 'accepted'))
  582. ->whereDoesntHave('items.schedule', fn($q) => $q->where('status', 'pending'))
  583. ->with(['items.schedule' => function ($query) {
  584. $query->with(['provider.user', 'address']);
  585. }])
  586. ->with('provider.user')
  587. ->get();
  588. return [
  589. 'headerBar' => $headerBar,
  590. 'summaryInfos' => $summaryInfos,
  591. 'pendingSchedules' => $pendingSchedules,
  592. 'nextSchedules' => $nextSchedules,
  593. 'lastDoneSchedules' => $lastDoneSchedules,
  594. 'favoriteProviders' => $favoriteProviders,
  595. 'providersClose' => $providersClose,
  596. 'todaySchedules' => $todaySchedules,
  597. 'schedulesProposals' => $schedulesProposals,
  598. 'customSchedulesNoProposals' => $custom_schedules_with_no_proposals,
  599. 'notifications' => $notifications,
  600. 'has_payment_methods' => $hasPaymentMethods,
  601. 'has_location' => $hasLocation,
  602. 'pendingServicePackages' => $pendingServicePackages,
  603. ];
  604. }
  605. public function dadosPedidosCliente(): array
  606. {
  607. $user = Auth::user();
  608. if ($user->type !== UserTypeEnum::CLIENT) {
  609. throw new AuthorizationException(__('messages.only_clients_allowed'));
  610. }
  611. $cliente = Client::where('user_id', $user->id)->firstOrFail();
  612. $clientPrimaryAddress = Address::where('source', 'client')
  613. ->where('source_id', $cliente->id)
  614. ->orderByDesc('is_primary')
  615. ->orderByDesc('id')
  616. ->first();
  617. $proposalsDistanceSelect = DistanceService::sqlExpression(
  618. $clientPrimaryAddress?->latitude !== null ? (float) $clientPrimaryAddress->latitude : null,
  619. $clientPrimaryAddress?->longitude !== null ? (float) $clientPrimaryAddress->longitude : null,
  620. );
  621. $schedulesProposals = ScheduleProposal::query()
  622. ->leftJoin(
  623. 'schedules',
  624. 'schedule_proposals.schedule_id',
  625. '=',
  626. 'schedules.id'
  627. )
  628. ->leftJoin(
  629. 'providers',
  630. 'schedule_proposals.provider_id',
  631. '=',
  632. 'providers.id'
  633. )
  634. ->whereExists(Provider::hasActivePrimaryBankAccount())
  635. ->leftJoin('users', 'providers.user_id', '=', 'users.id')
  636. ->leftJoin(
  637. DB::raw("
  638. (
  639. SELECT DISTINCT ON (source_id)
  640. *
  641. FROM addresses
  642. WHERE source = 'provider'
  643. AND deleted_at IS NULL
  644. ORDER BY source_id, is_primary DESC
  645. ) AS provider_address
  646. "),
  647. 'provider_address.source_id',
  648. '=',
  649. 'providers.id'
  650. )
  651. ->leftJoin(
  652. 'addresses as schedule_address',
  653. 'schedule_address.id',
  654. '=',
  655. 'schedules.address_id'
  656. )
  657. ->where('schedules.client_id', $cliente->id)
  658. ->where('schedules.schedule_type', 'custom')
  659. ->where('schedules.status', 'pending')
  660. ->whereNull('schedules.deleted_at')
  661. ->whereDate('schedules.date', '>=', now()->toDateString())
  662. ->orderBy('schedule_proposals.created_at', 'desc')
  663. ->select([
  664. 'schedule_proposals.id',
  665. DB::raw("
  666. DATE_PART('year', AGE(providers.birth_date)) AS idade
  667. "),
  668. 'providers.id as provider_id',
  669. 'providers.gender',
  670. 'schedules.id as schedule_id',
  671. 'schedules.date',
  672. 'schedules.start_time',
  673. 'schedules.end_time',
  674. 'schedules.period_type',
  675. 'schedules.total_amount',
  676. 'providers.daily_price_8h',
  677. 'providers.average_rating',
  678. 'providers.total_services',
  679. 'users.name as provider_name',
  680. 'provider_address.latitude as provider_latitude',
  681. 'provider_address.longitude as provider_longitude',
  682. 'provider_address.zip_code as provider_zip_code',
  683. 'schedule_address.address as address',
  684. 'schedule_address.number as address_number',
  685. 'schedule_address.district as address_district',
  686. 'schedule_address.address_type as address_type',
  687. $proposalsDistanceSelect,
  688. ])
  689. ->get();
  690. $this->zipCodeCoordinatesService->preload(
  691. $schedulesProposals->whereNull('distance_km')->pluck('provider_zip_code')
  692. );
  693. $customSchedulesNoProposals = Schedule::with('address:district,address,number,source_id,source,id')
  694. ->where('client_id', $cliente->id)
  695. ->where('schedule_type', 'custom')
  696. ->where('status', 'pending')
  697. ->whereDate('date', '>=', now()->toDateString())
  698. ->doesntHave('proposals')
  699. ->get();
  700. $schedulesProposals->each(function ($item) use ($clientPrimaryAddress) {
  701. $item->gender_label = GenderEnum::labelFor($item->gender);
  702. $item->address = [
  703. 'address' => $item->address,
  704. 'number' => $item->address_number,
  705. 'district' => $item->address_district,
  706. 'address_type' => $item->address_type,
  707. ];
  708. unset($item->address_number, $item->address_district);
  709. if ($item->distance_km === null) {
  710. $item->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  711. $clientPrimaryAddress?->latitude !== null ? (float) $clientPrimaryAddress->latitude : null,
  712. $clientPrimaryAddress?->longitude !== null ? (float) $clientPrimaryAddress->longitude : null,
  713. $clientPrimaryAddress?->zip_code,
  714. $item->provider_latitude !== null ? (float) $item->provider_latitude : null,
  715. $item->provider_longitude !== null ? (float) $item->provider_longitude : null,
  716. $item->provider_zip_code,
  717. );
  718. }
  719. unset(
  720. $item->provider_latitude,
  721. $item->provider_longitude,
  722. $item->provider_zip_code,
  723. );
  724. });
  725. $packageItemCounts = DB::table('service_package_items as spi_count')
  726. ->join('schedules as s_count', function ($join) {
  727. $join->on('s_count.id', '=', 'spi_count.schedule_id')
  728. ->whereNotIn('s_count.status', ['cancelled', 'rejected'])
  729. ->where('s_count.schedule_type', 'default');
  730. })
  731. ->groupBy('spi_count.service_package_id')
  732. ->select('spi_count.service_package_id', DB::raw('COUNT(*) AS items_count'));
  733. $pendingSchedules = Schedule::query()
  734. ->where('schedules.client_id', $cliente->id)
  735. ->where('schedules.schedule_type', 'default')
  736. ->where('schedules.status', 'pending')
  737. ->whereDate('schedules.date', '>=', now()->toDateString())
  738. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  739. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  740. ->leftJoin('addresses as schedule_address', 'schedule_address.id', '=', 'schedules.address_id')
  741. ->leftJoin('service_package_items as spi', 'spi.schedule_id', '=', 'schedules.id')
  742. ->leftJoinSub(
  743. $packageItemCounts,
  744. 'package_counts',
  745. 'package_counts.service_package_id',
  746. '=',
  747. 'spi.service_package_id',
  748. )
  749. ->orderBy('schedules.date', 'asc')
  750. ->select([
  751. 'schedules.id',
  752. 'schedules.provider_id',
  753. 'schedules.date',
  754. 'schedules.start_time',
  755. 'schedules.end_time',
  756. 'schedules.status',
  757. 'provider_user.name as provider_name',
  758. 'spi.service_package_id',
  759. DB::raw('COALESCE(package_counts.items_count, 1) AS service_package_items_count'),
  760. DB::raw("
  761. CASE
  762. WHEN (NOW() - schedules.created_at) < INTERVAL '1 hour' THEN
  763. CONCAT(ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 60), 'min')
  764. WHEN (NOW() - schedules.created_at) < INTERVAL '1 day' THEN
  765. CONCAT(ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 3600), 'h')
  766. ELSE
  767. CONCAT(ROUND(EXTRACT(EPOCH FROM (NOW() - schedules.created_at)) / 86400), 'd')
  768. END AS time_since_request
  769. "),
  770. 'schedule_address.address as address_address',
  771. 'schedule_address.number as address_number',
  772. 'schedule_address.district as address_district',
  773. ])
  774. ->get()
  775. ->unique(fn ($schedule) => $schedule->service_package_id
  776. ? 'package-'.$schedule->service_package_id
  777. : 'schedule-'.$schedule->id)
  778. ->values();
  779. $this->attachPackageItems($pendingSchedules);
  780. $pendingSchedules->each(function ($schedule) {
  781. $schedule->address = [
  782. 'address' => $schedule->address_address,
  783. 'number' => $schedule->address_number,
  784. 'district' => $schedule->address_district,
  785. ];
  786. unset(
  787. $schedule->address_address,
  788. $schedule->address_number,
  789. $schedule->address_district,
  790. );
  791. });
  792. $pendingServicePackages = ServicePackage::query()
  793. ->where('client_id', $cliente->id)
  794. ->where('status', ServicePackageStatusEnum::OPEN->value)
  795. ->whereHas('items.schedule', fn ($query) => $query->where('status', 'accepted'))
  796. ->whereDoesntHave('items.schedule', fn ($query) => $query->where('status', 'pending'))
  797. ->with([
  798. 'provider:id,user_id',
  799. 'provider.user:id,name',
  800. 'items:id,service_package_id,schedule_id',
  801. 'items.schedule' => fn ($query) => $query
  802. ->select('id', 'date', 'start_time', 'end_time', 'status', 'total_amount', 'address_id')
  803. ->with('address:id,address,number,district'),
  804. ])
  805. ->get();
  806. $providerPhotoUrls = $this->providerPhotoUrls(
  807. $schedulesProposals->pluck('provider_id')
  808. ->merge($pendingSchedules->pluck('provider_id'))
  809. ->merge($pendingServicePackages->pluck('provider_id')),
  810. );
  811. collect([$schedulesProposals, $pendingSchedules])->each(
  812. fn (Collection $items) => $items->each(function ($item) use ($providerPhotoUrls) {
  813. $item->provider_photo = $providerPhotoUrls->get($item->provider_id);
  814. }),
  815. );
  816. $pendingServicePackages = $pendingServicePackages->map(
  817. function (ServicePackage $package) use ($providerPhotoUrls) {
  818. $schedules = $package->items
  819. ->pluck('schedule')
  820. ->filter()
  821. ->values();
  822. $activeSchedules = $schedules->reject(
  823. fn ($schedule) => in_array($schedule->status, ['cancelled', 'rejected'], true),
  824. );
  825. return [
  826. 'id' => $package->id,
  827. 'provider_id' => $package->provider_id,
  828. 'provider_name' => $package->provider?->user?->name,
  829. 'provider_photo' => $providerPhotoUrls->get($package->provider_id),
  830. 'total_amount' => (float) $activeSchedules->sum(
  831. fn ($schedule) => (float) $schedule->total_amount,
  832. ),
  833. 'service_package_items_count' => $activeSchedules->count(),
  834. 'schedules' => $schedules->map(fn ($schedule) => [
  835. 'id' => $schedule->id,
  836. 'status' => $schedule->status,
  837. 'date' => $schedule->date?->format('Y-m-d'),
  838. 'start_time' => $schedule->start_time,
  839. 'end_time' => $schedule->end_time,
  840. 'total_amount' => (float) $schedule->total_amount,
  841. 'address' => [
  842. 'address' => $schedule->address?->address,
  843. 'number' => $schedule->address?->number,
  844. 'district' => $schedule->address?->district,
  845. ],
  846. ])->values(),
  847. ];
  848. },
  849. );
  850. return [
  851. 'schedulesProposals' => $schedulesProposals,
  852. 'customSchedulesNoProposals' => $customSchedulesNoProposals,
  853. 'pendingSchedules' => $pendingSchedules,
  854. 'pendingServicePackages' => $pendingServicePackages,
  855. ];
  856. }
  857. public function dadosDashboardPrestador(): array
  858. {
  859. $user = Auth::user();
  860. if ($user->type !== UserTypeEnum::PROVIDER) {
  861. throw new AuthorizationException(__('messages.only_providers_allowed'));
  862. }
  863. $provider = Provider::with('profileMedia')->where('user_id', $user->id)->first();
  864. $headerBar = [
  865. 'rating' => $provider->average_rating,
  866. 'total_ratings' => Review::where('reviews.origin', 'client')->leftJoin('schedules', 'schedules.id', '=', 'reviews.schedule_id')->where('schedules.provider_id', $provider->id)->count(),
  867. 'total_services' => $provider->total_services,
  868. ];
  869. $address = Address::where('source', 'provider')->where('source_id', $provider->id)->with(['city', 'state'])->first();
  870. $summaryInfos = [
  871. 'name' => $user->name,
  872. 'address' => $address,
  873. 'pending_services' => Schedule::where('provider_id', $provider->id)->where('status', 'pending')->count(),
  874. 'profile_photo' => $provider->profileMedia?->path
  875. ? Storage::temporaryUrl($provider->profileMedia->path, now()->addMinutes(60))
  876. : null,
  877. ];
  878. if ($provider->approval_status === ApprovalStatusEnum::PENDING) {
  879. return [
  880. 'headerBar' => $headerBar,
  881. 'summaryInfos' => $summaryInfos,
  882. 'priceSuggested' => null,
  883. 'todayServices' => [],
  884. 'solicitations' => [],
  885. 'nextSchedules' => [],
  886. 'opportunities' => [],
  887. 'notifications' => [],
  888. 'pendingConfirmation' => [],
  889. ];
  890. }
  891. $providerCityId = $address?->city_id;
  892. $priceSuggestedAvg = Provider::query()
  893. ->where('providers.user_id', '!=', $user->id)
  894. ->whereNotNull('providers.daily_price_8h')
  895. ->whereExists(function ($query) use ($providerCityId) {
  896. $query->select(DB::raw(1))
  897. ->from('addresses')
  898. ->whereColumn('addresses.source_id', 'providers.id')
  899. ->where('addresses.source', 'provider')
  900. ->whereNull('addresses.deleted_at')
  901. ->where('addresses.city_id', $providerCityId);
  902. })
  903. ->avg('providers.daily_price_8h');
  904. $priceActual = $provider->daily_price_8h;
  905. $priceSuggested = [
  906. 'average_price' => $priceSuggestedAvg,
  907. 'your_price' => $priceActual,
  908. ];
  909. $solicitations = Schedule::with([
  910. 'address:district,source_id,source,id,zip_code,latitude,longitude',
  911. 'customSchedule.specialities',
  912. ])
  913. ->where('schedules.provider_id', $provider->id)
  914. ->where('schedules.status', 'pending')
  915. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  916. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  917. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  918. ->select(
  919. 'schedules.id',
  920. 'schedules.client_id',
  921. 'client_user.name as client_name',
  922. 'clients.average_rating',
  923. 'schedules.date',
  924. DB::raw("
  925. TO_CHAR(schedules.date, 'DD/MM/YYYY') AS formatted_date
  926. "),
  927. 'schedules.start_time',
  928. 'schedules.end_time',
  929. 'schedules.total_amount',
  930. 'schedules.period_type',
  931. 'schedules.schedule_type',
  932. 'schedules.address_id',
  933. 'schedules.status',
  934. 'custom_schedules.offers_meal',
  935. DB::raw("
  936. CASE
  937. WHEN (NOW() - schedules.created_at) < INTERVAL '1 day' THEN
  938. CONCAT(
  939. ROUND(
  940. EXTRACT(
  941. EPOCH FROM (NOW() - schedules.created_at)
  942. ) / 3600
  943. ),
  944. ' hours ago'
  945. )
  946. ELSE
  947. CONCAT(
  948. ROUND(
  949. EXTRACT(
  950. EPOCH FROM (NOW() - schedules.created_at)
  951. ) / 86400
  952. ),
  953. ' days ago'
  954. )
  955. END AS time_since_request
  956. "),
  957. DB::raw("
  958. (
  959. SELECT service_package_items.service_package_id
  960. FROM service_package_items
  961. WHERE service_package_items.schedule_id = schedules.id
  962. LIMIT 1
  963. ) AS service_package_id
  964. "),
  965. )
  966. ->orderBy('schedules.date', 'asc')
  967. ->get()
  968. ->append('specialities')
  969. ->makeHidden('customSchedule');
  970. $solicitations->each(function ($solicitation) use ($address) {
  971. $solicitation->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  972. $address?->latitude !== null ? (float) $address->latitude : null,
  973. $address?->longitude !== null ? (float) $address->longitude : null,
  974. $address?->zip_code,
  975. $solicitation->address?->latitude !== null ? (float) $solicitation->address->latitude : null,
  976. $solicitation->address?->longitude !== null ? (float) $solicitation->address->longitude : null,
  977. $solicitation->address?->zip_code,
  978. );
  979. });
  980. $todayServices = Schedule::with([
  981. 'address:district,address,number,source_id,source,id',
  982. ])
  983. ->where('schedules.provider_id', $provider->id)
  984. ->whereIn('schedules.status', ['paid', 'started', 'finished'])
  985. ->whereDate('schedules.date', now()->toDateString())
  986. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  987. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  988. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  989. ->select(
  990. 'schedules.id',
  991. 'schedules.client_id',
  992. 'client_user.name as client_name',
  993. 'schedules.date',
  994. 'schedules.start_time',
  995. 'schedules.end_time',
  996. 'schedules.total_amount',
  997. 'schedules.period_type',
  998. 'schedules.address_id',
  999. 'schedules.schedule_type',
  1000. 'schedules.status',
  1001. 'schedules.code_verified',
  1002. 'schedules.code',
  1003. 'custom_schedules.offers_meal',
  1004. DB::raw("
  1005. EXISTS (
  1006. SELECT 1
  1007. FROM reviews
  1008. WHERE reviews.schedule_id = schedules.id
  1009. AND reviews.origin = 'provider'
  1010. AND reviews.origin_id = {$provider->id}
  1011. AND reviews.deleted_at IS NULL
  1012. ) AS provider_reviewed
  1013. "),
  1014. DB::raw("
  1015. (
  1016. SELECT service_package_items.service_package_id
  1017. FROM service_package_items
  1018. WHERE service_package_items.schedule_id = schedules.id
  1019. LIMIT 1
  1020. ) AS service_package_id
  1021. "),
  1022. )
  1023. ->orderBy('schedules.start_time', 'asc')
  1024. ->get();
  1025. $pendingConfirmation = Schedule::with([
  1026. 'address' => fn ($query) => $query->withTrashed()->select([
  1027. 'district', 'address', 'number', 'source_id', 'source', 'id', 'zip_code', 'latitude', 'longitude',
  1028. ]),
  1029. ])
  1030. ->where('schedules.provider_id', $provider->id)
  1031. ->where('schedules.status', 'accepted')
  1032. ->whereDate('schedules.date', '>=', now()->toDateString())
  1033. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  1034. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  1035. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  1036. ->select(
  1037. 'schedules.id',
  1038. 'schedules.client_id',
  1039. 'client_user.name as client_name',
  1040. 'schedules.date',
  1041. 'schedules.start_time',
  1042. 'schedules.end_time',
  1043. 'schedules.total_amount',
  1044. 'schedules.period_type',
  1045. 'schedules.address_id',
  1046. 'schedules.schedule_type',
  1047. 'schedules.status',
  1048. 'custom_schedules.offers_meal',
  1049. DB::raw("
  1050. (
  1051. SELECT service_package_items.service_package_id
  1052. FROM service_package_items
  1053. WHERE service_package_items.schedule_id = schedules.id
  1054. LIMIT 1
  1055. ) AS service_package_id
  1056. "),
  1057. )
  1058. ->orderBy('schedules.date', 'asc')
  1059. ->get();
  1060. $pendingConfirmation->each(function ($schedule) use ($address) {
  1061. $schedule->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  1062. $address?->latitude !== null ? (float) $address->latitude : null,
  1063. $address?->longitude !== null ? (float) $address->longitude : null,
  1064. $address?->zip_code,
  1065. $schedule->address?->latitude !== null ? (float) $schedule->address->latitude : null,
  1066. $schedule->address?->longitude !== null ? (float) $schedule->address->longitude : null,
  1067. $schedule->address?->zip_code,
  1068. );
  1069. });
  1070. $nextSchedules = Schedule::with([
  1071. 'address' => fn ($query) => $query->withTrashed()->select([
  1072. 'district', 'address', 'number', 'source_id', 'source', 'id', 'zip_code', 'latitude', 'longitude',
  1073. ]),
  1074. ])
  1075. ->where('schedules.provider_id', $provider->id)
  1076. ->where('schedules.status', 'paid')
  1077. ->whereDate('schedules.date', '>', now()->toDateString())
  1078. ->leftJoin('clients', 'clients.id', '=', 'schedules.client_id')
  1079. ->leftJoin('users as client_user', 'client_user.id', '=', 'clients.user_id')
  1080. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  1081. ->select(
  1082. 'schedules.id',
  1083. 'schedules.client_id',
  1084. 'client_user.name as client_name',
  1085. 'schedules.date',
  1086. 'schedules.start_time',
  1087. 'schedules.end_time',
  1088. 'schedules.total_amount',
  1089. 'schedules.period_type',
  1090. 'schedules.address_id',
  1091. 'schedules.schedule_type',
  1092. 'schedules.status',
  1093. 'custom_schedules.offers_meal',
  1094. DB::raw("
  1095. (
  1096. SELECT service_package_items.service_package_id
  1097. FROM service_package_items
  1098. WHERE service_package_items.schedule_id = schedules.id
  1099. LIMIT 1
  1100. ) AS service_package_id
  1101. "),
  1102. )
  1103. ->orderBy('schedules.date', 'asc')
  1104. ->get();
  1105. $nextSchedules->each(function ($schedule) use ($address) {
  1106. $schedule->distance_km = $this->zipCodeCoordinatesService->calculateDistance(
  1107. $address?->latitude !== null ? (float) $address->latitude : null,
  1108. $address?->longitude !== null ? (float) $address->longitude : null,
  1109. $address?->zip_code,
  1110. $schedule->address?->latitude !== null ? (float) $schedule->address->latitude : null,
  1111. $schedule->address?->longitude !== null ? (float) $schedule->address->longitude : null,
  1112. $schedule->address?->zip_code,
  1113. );
  1114. });
  1115. $clientCollections = collect([
  1116. $solicitations,
  1117. $todayServices,
  1118. $pendingConfirmation,
  1119. $nextSchedules
  1120. ]);
  1121. $clientPhotoUrls = $this->clientPhotoUrls(
  1122. $clientCollections->flatMap(
  1123. fn(Collection $items) => $items->pluck('client_id'),
  1124. ),
  1125. );
  1126. $clientCollections->each(function (Collection $items) use ($clientPhotoUrls) {
  1127. $items->each(function ($item) use ($clientPhotoUrls) {
  1128. $item->customer_photo = $clientPhotoUrls->get($item->client_id);
  1129. });
  1130. });
  1131. $notifications = Notification::where('user_id', $user->id)
  1132. ->orderBy('read', 'asc')
  1133. ->orderBy('created_at', 'desc')
  1134. ->limit(10)
  1135. ->get()
  1136. ->map(function ($notification) {
  1137. return [
  1138. 'id' => $notification->id,
  1139. 'title' => $notification->title,
  1140. 'description' => $notification->description,
  1141. 'time' => $notification->created_at->diffForHumans(),
  1142. 'read' => $notification->read,
  1143. 'avatar' => '/icons/avatar.svg',
  1144. ];
  1145. });
  1146. $opportunities = $this->customScheduleService->getAvailableOpportunities($provider->id);
  1147. $opportunities->each(function ($o) {
  1148. $o->customer_photo = $o->client?->profileMedia?->path
  1149. ? Storage::temporaryUrl($o->client->profileMedia->path, now()->addMinutes(60))
  1150. : null;
  1151. });
  1152. return [
  1153. 'headerBar' => $headerBar,
  1154. 'summaryInfos' => $summaryInfos,
  1155. 'priceSuggested' => $priceSuggested,
  1156. 'solicitations' => $solicitations,
  1157. 'todayServices' => $todayServices,
  1158. 'pendingConfirmation' => $pendingConfirmation,
  1159. 'nextSchedules' => $nextSchedules,
  1160. 'opportunities' => $opportunities,
  1161. 'notifications' => $notifications,
  1162. ];
  1163. }
  1164. public function getScheduleClienteDetails(int $scheduleId): array
  1165. {
  1166. $user = Auth::user();
  1167. $cliente = Client::where('user_id', $user->id)->firstOrFail();
  1168. $schedule = Schedule::with('customSchedule.specialities')
  1169. ->where('schedules.id', $scheduleId)
  1170. ->where('schedules.client_id', $cliente->id)
  1171. ->leftJoin('providers', 'providers.id', '=', 'schedules.provider_id')
  1172. ->leftJoin('users as provider_user', 'provider_user.id', '=', 'providers.user_id')
  1173. ->leftJoin('custom_schedules', 'custom_schedules.schedule_id', '=', 'schedules.id')
  1174. ->select(
  1175. 'schedules.id',
  1176. 'schedules.provider_id',
  1177. 'schedules.schedule_type',
  1178. 'provider_user.name as provider_name',
  1179. 'providers.birth_date as provider_birth_date',
  1180. 'providers.gender',
  1181. 'custom_schedules.offers_meal',
  1182. 'custom_schedules.min_price',
  1183. 'custom_schedules.max_price',
  1184. )
  1185. ->firstOrFail();
  1186. $providerPhoto = $this->providerPhotoUrls([$schedule->provider_id])
  1187. ->get($schedule->provider_id);
  1188. return [
  1189. 'schedule_type' => $schedule->schedule_type,
  1190. 'provider_name' => $schedule->provider_name,
  1191. 'provider_birth_date' => $schedule->provider_birth_date,
  1192. 'gender' => $schedule->gender,
  1193. 'gender_label' => GenderEnum::labelFor($schedule->gender),
  1194. 'offers_meal' => $schedule->offers_meal,
  1195. 'specialities' => $schedule->specialities,
  1196. 'min_price' => $schedule->min_price,
  1197. 'max_price' => $schedule->max_price,
  1198. 'provider_photo' => $providerPhoto,
  1199. ];
  1200. }
  1201. private function attachPackageItems(Collection $schedules): void
  1202. {
  1203. $packageIds = $schedules->pluck('service_package_id')->filter()->unique();
  1204. $standaloneIds = $schedules->whereNull('service_package_id')->pluck('id')->filter()->unique();
  1205. if ($packageIds->isEmpty() && $standaloneIds->isEmpty()) {
  1206. $schedules->each(fn ($schedule) => $schedule->package_items = collect());
  1207. return;
  1208. }
  1209. $rows = Schedule::query()
  1210. ->leftJoin('service_package_items as spi', 'spi.schedule_id', '=', 'schedules.id')
  1211. ->where(function ($query) use ($packageIds, $standaloneIds) {
  1212. if ($packageIds->isNotEmpty()) {
  1213. $query->orWhereIn('spi.service_package_id', $packageIds);
  1214. }
  1215. if ($standaloneIds->isNotEmpty()) {
  1216. $query->orWhereIn('schedules.id', $standaloneIds);
  1217. }
  1218. })
  1219. ->whereNotIn('schedules.status', ['cancelled', 'rejected'])
  1220. ->orderBy('schedules.date', 'asc')
  1221. ->orderBy('schedules.start_time', 'asc')
  1222. ->select([
  1223. 'schedules.id',
  1224. 'schedules.date',
  1225. 'schedules.start_time',
  1226. 'schedules.end_time',
  1227. 'schedules.total_amount',
  1228. 'schedules.offers_meal',
  1229. 'schedules.status',
  1230. 'spi.service_package_id',
  1231. ])
  1232. ->get();
  1233. $byPackage = $rows->whereNotNull('service_package_id')->groupBy('service_package_id');
  1234. $byId = $rows->keyBy('id');
  1235. $schedules->each(function ($schedule) use ($byPackage, $byId) {
  1236. if ($schedule->service_package_id) {
  1237. $schedule->package_items = $byPackage
  1238. ->get($schedule->service_package_id, collect())
  1239. ->values();
  1240. return;
  1241. }
  1242. $own = $byId->get($schedule->id);
  1243. $schedule->package_items = $own ? collect([$own]) : collect();
  1244. });
  1245. }
  1246. private function providerPhotoUrls(iterable $providerIds): Collection
  1247. {
  1248. return Provider::query()
  1249. ->select('id', 'profile_media_id')
  1250. ->with('profileMedia')
  1251. ->whereIn('id', collect($providerIds)->filter()->unique())
  1252. ->get()
  1253. ->mapWithKeys(function (Provider $provider) {
  1254. $path = $provider->profileMedia?->path;
  1255. return [
  1256. $provider->id => $path ? Storage::temporaryUrl($path, now()->addMinutes(60)) : null,
  1257. ];
  1258. });
  1259. }
  1260. // Gera URLs apenas para fotos verificadas ou visíveis ao próprio cliente.
  1261. private function clientPhotoUrls(iterable $clientIds): Collection
  1262. {
  1263. return Client::query()
  1264. ->select('id', 'profile_media_id')
  1265. ->with('profileMedia')
  1266. ->whereIn('id', collect($clientIds)->filter()->unique())
  1267. ->get()
  1268. ->mapWithKeys(function (Client $client) {
  1269. $path = $client->profileMedia?->path;
  1270. return [
  1271. $client->id => $path ? Storage::temporaryUrl($path, now()->addMinutes(60)) : null,
  1272. ];
  1273. });
  1274. }
  1275. //
  1276. private function applyCreditCardFee(?float $price): ?float
  1277. {
  1278. if ($price === null) {
  1279. return null;
  1280. }
  1281. $rate = $this->platformCreditCardFeeRate();
  1282. return round($price * (1 + $rate), 2);
  1283. }
  1284. private function platformCreditCardFeeRate(): float
  1285. {
  1286. $rate = config('services.pagarme.platform_credit_card_fee_rate', 0.16);
  1287. if (is_string($rate)) {
  1288. $rate = str_replace(',', '.', trim($rate));
  1289. }
  1290. $rate = (float) $rate;
  1291. return $rate > 1 ? $rate / 100 : $rate;
  1292. }
  1293. //
  1294. private function distanceSelect(?float $clientLatitude, ?float $clientLongitude): \Illuminate\Contracts\Database\Query\Expression
  1295. {
  1296. return DistanceService::sqlExpression($clientLatitude, $clientLongitude);
  1297. }
  1298. }