fjffk简单的咖啡店科开发2方法2 环滁皆山也。其西南诸峰，林壑尤美，望之蔚然而深秀者，琅琊也。山行六七里，渐闻水声潺潺，而泻出于两峰之间者，酿泉也 ??????????????????????????????? ??????????????/????????????????? ............/................... .........................../... ??????????????????????????????? >>>>>>>>>>>>>/>>>>>>>>>>>>>>>>> ÿØÿà JFIF    ÿÛ „  ( %!1!%)+//.383,7(-.+  -%%-////---/-.+/--+------/------/--0+--/-/-----.-----ÿÀ  ¥2" ÿÄ     ÿÄ J    ! 1AQ"aq2‘#BR‚¡ÁÑ3br’¢±Âð$CSƒ²á4c“%DsÓñÿÄ   ÿÄ *  !1AQa‘"2q3±ð#b¡ÿÚ   ? ¼QxJQaÍuò¸Zö Úü8,ÐÚú "SSn<rçù–´âE—^ªBÖ9À\†¸ÔÁT­ÃÛ5 ëd´³Í#Ý;Þ38œî ¶H£M:wÎ3…³…âpÔF&‚FK¸9„â4àGEõªfÿ ‘ñ(ßw­pŽF|È¥ù®häðÍѶ¹‘[ÒinÙW¶ùñY˜Q{›K"išÒ[Ú8žë\F¹@-?v"ÔU”,ìöžkÿ {I‡£šÍ?e ríV ?> ......................................... ............................................................................. <<<<<<<<<<<<<<<<<<<<<<<<<<<<<< >>>>>>>>>>>>>/>>>>>>>>>>>>>>>>>> <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<< <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<< >>>>>>>>>>>>>>>>>>>>>>>>>>>>>> dsdfhome/nectalco/public_html/app/Services/PaymentGateways/RazorpayService.php000064400000053704152667070630023141 0ustar00with(['message' => __('Please enable Razorpay'), 'type' => 'error']); } Plan::query() ->where('currency', 'INR') ->where('type', '!=', 'prepaid') ->where('active', 1) ->each(fn ($plan) => self::saveProduct($plan)); return null; } catch (Exception $ex) { Log::error(self::$GATEWAY_CODE . '-> saveAllProducts(): ' . $ex->getMessage()); return back()->with(['message' => $ex->getMessage(), 'type' => 'error']); } } public static function getPlansPriceIdsForMigration(): null { return null; } public static function getUsersCustomerIdsForMigration(Subscriptions $subscription): null { return null; } public static function saveProduct($plan): bool|\Illuminate\Http\RedirectResponse { try { $gateway = self::geteway(); if (! $gateway) { return back()->with(['message' => __('Please enable Razorpay'), 'type' => 'error']); } $api = self::client(); DB::beginTransaction(); $data = $api->plan->create( self::planPayload($plan) ); GatewayProducts::updateOrCreate( ['plan_id' => $plan->id, 'gateway_code' => self::$GATEWAY_CODE], ['plan_name' => $plan->name, 'product_id' => $data['id'], 'price_id' => $data['item']['id'], 'payload' => $data->toArray()] ); DB::commit(); return true; } catch (Exception $ex) { DB::rollBack(); Log::error(self::$GATEWAY_CODE . "-> saveProduct():\n" . $ex->getMessage()); return back()->with(['message' => $ex->getMessage(), 'type' => 'error']); } } public static function client(): Api { $gateway = self::geteway(); $apiKey = $gateway->getAttribute('mode') === 'sandbox' ? $gateway->getAttribute('sandbox_client_id') : $gateway->getAttribute('live_client_id'); $secret = $gateway->getAttribute('mode') === 'sandbox' ? $gateway->getAttribute('sandbox_client_secret') : $gateway->getAttribute('live_client_secret'); return new Api($apiKey, $secret); } public static function geteway(): Model|Builder|null { if (self::$gateway) { return self::$gateway; } self::$gateway = Gateways::where('code', self::$GATEWAY_CODE)->first(); return self::$gateway; } public static function objectToArray($request) { if (is_object($request)) { if (property_exists($request, 'id')) { $request = json_decode(json_encode($request), true); } } return $request; } public static function gatewayDefinitionArray(): array { return [ 'code' => 'razorpay', 'title' => 'Razorpay', 'link' => 'https://razorpay.com/', 'active' => 0, 'available' => 1, 'img' => '/assets/img/payments/razorpay.svg', 'whiteLogo' => 0, 'mode' => 1, 'sandbox_client_id' => 1, 'sandbox_client_secret' => 1, 'sandbox_app_id' => 0, 'live_client_id' => 1, 'live_client_secret' => 1, 'live_app_id' => 0, 'currency' => 0, 'currency_locale' => 0, 'notify_url' => 0, 'base_url' => 0, 'sandbox_url' => 0, 'locale' => 0, 'validate_ssl' => 0, 'webhook_secret' => 0, 'logger' => 0, 'tax' => 1, // Option in settings 'bank_account_details' => 0, 'bank_account_other' => 0, ]; } public static function subscribe($plan): View { $order_id = 'ORDER-' . strtoupper(Str::random(13)); $newDiscountedPrice = $plan->price; $coupon = checkCouponInRequest(); if ($coupon) { $newDiscountedPrice = $plan->price - ($plan->price * ($coupon->discount / 100)); if ($newDiscountedPrice != floor($newDiscountedPrice)) { $newDiscountedPrice = number_format($newDiscountedPrice, 2); } } return view('panel.user.finance.subscription.' . self::$GATEWAY_CODE, compact('plan', 'newDiscountedPrice', 'order_id', 'coupon')); } public static function subscribeCheckout(Request $request, $referral = null) { $planID = $request->input('planID', null); $plan = Plan::query() ->where('id', $planID) ->first(); $gateway = self::geteway(); if ($gateway == null) { return back()->with(['message' => __('Please enable coingate'), 'type' => 'error']); } $gatewayProduct = GatewayProducts::query() ->where('plan_id', $plan->getAttribute('id')) ->where('gateway_code', self::$GATEWAY_CODE) ->first(); if (! $gatewayProduct) { return back()->with(['message' => __('Gateway product not found'), 'type' => 'error']); } $planId = $gatewayProduct->getAttribute('product_id'); try { $api = self::client(); $data = $api->subscription->create([ 'plan_id' => $planId, 'total_count' => 6, 'quantity' => 1, 'customer_notify' => 0, ]); Subscriptions::query() ->create([ 'user_id' => auth()->id(), 'name' => $plan->id, 'stripe_id' => $data['id'], 'stripe_status' => 'WAITING', 'stripe_price' => null, 'quantity' => 1, 'trial_ends_at' => null, 'tax_rate' => 0, 'tax_value' => 0, 'coupon' => null, 'total_amount' => $plan->price, 'plan_id' => $plan->id, 'paid_with' => self::$GATEWAY_CODE, ]); $order = UserOrder::query() ->create([ 'order_id' => $data['id'], 'plan_id' => $plan->id, 'user_id' => auth()->id(), 'payment_type' => self::$GATEWAY_CODE, 'price' => $plan->price, 'affiliate_earnings' => 0, 'status' => 'WAITING', 'country' => $user->country ?? 'Unknown', 'tax_rate' => 0, 'type' => 'subscription', 'tax_value' => 0, 'payload' => $data->toArray(), ]); \App\Models\Usage::getSingle()->updateSalesCount($plan->price); $short_link = $data['short_url']; return redirect($short_link); } catch (Exception $exception) { Log::error(self::$GATEWAY_CODE . '-> subscribe(): ' . $exception->getMessage()); return back()->with(['message' => Str::before($exception->getMessage(), ':'), 'type' => 'error']); } } public static function prepaidCheckout(Request $request, $referral = null) { $planID = $request->input('planID', null); $orderID = $request->input('orderID', null); $plan = Plan::query()->where('id', $planID)->first(); $user = Auth::user(); $gateway = self::geteway(); if ($gateway === null) { return back()->with(['message' => __('Please enable coingate'), 'type' => 'error']); } $api = self::client(); try { $order = UserOrder::query() ->create([ 'order_id' => $orderID, 'plan_id' => $plan->id, 'user_id' => $user->id, 'payment_type' => self::$GATEWAY_CODE, 'price' => $plan->price, 'affiliate_earnings' => 0, 'status' => 'WAITING', 'country' => $user->country ?? 'Unknown', 'tax_rate' => 0, 'tax_value' => 0, 'type' => 'token-pack', 'payload' => [], ]); $paymentLink = $api->paymentLink->create([ 'amount' => $plan->price * 100, 'currency' => 'INR', 'accept_partial' => true, 'reference_id' => $orderID, 'description' => 'For XYZ purpose', 'customer' => [ 'name' => auth()->user()->name, 'email' => auth()->user()->email, ], 'notify' => ['sms' => false, 'email' => true], 'reminder_enable' => true, 'callback_url' => Helper::setting('site_url') . '/webhooks/razorpay', 'callback_method' => 'get', ]); // 9876543XXX $order->update([ 'order_id' => $paymentLink['id'], // 'id' => 'pl_1J2f3g4h5I6j7k8l9', 'payload' => $paymentLink->toArray(), ]); \App\Models\Usage::getSingle()->updateSalesCount($plan->price); return redirect()->to($paymentLink['short_url']); } catch (Exception $exception) { Log::error(self::$GATEWAY_CODE . '-> prepaidCheckout(): ' . $exception->getMessage()); return back()->with(['message' => Str::before($exception->getMessage(), ':'), 'type' => 'error']); } } public static function prepaid($plan) { $order_id = 'ORDER-' . strtoupper(Str::random(13)); return view('panel.user.finance.prepaid.' . self::$GATEWAY_CODE, compact('plan', 'order_id')); } public static function subscribeCancel(?User $internalUser = null) { $user = Auth::user() ?: $internalUser; $userId = $user->getAttribute('id'); // Get current active subscription $activeSub = getCurrentActiveSubscription($userId); if (! $activeSub) { return; } /** * @var Plan $plan */ $plan = Plan::query() ->where('id', $activeSub->getAttribute('plan_id')) ->first(); $api = self::client(); $data = $api->subscription->fetch($activeSub->getAttribute('stripe_id'))->cancel([]); if ($data) { $status = data_get($data, 'status'); if ($status === 'cancelled') { $activeSub->stripe_status = $status; $activeSub->ends_at = Carbon::now(); $activeSub->save(); self::creditDecreaseCancelPlan($user, $plan); CreateActivity::for($user, 'Cancelled', 'Subscription plan'); return back()->with(['message' => __('Your subscription is cancelled succesfully.'), 'type' => 'success']); } } return back()->with(['message' => __('Could not find active subscription. Nothing changed!'), 'type' => 'error']); } public static function cancelSubscribedPlan($subscription, $planId) { $api = self::client(); $user = Auth::user(); $check = $subscription instanceof Subscriptions; if (! $check) { $subscription = Subscriptions::where('id', $subscription)->first(); } if ($subscription === null) { return back()->with(['message' => __('Subscription not found'), 'type' => 'error']); } try { $data = $api->subscription->fetch($subscription->getAttribute('stripe_id'))->cancel([]); $subscription->update([ 'stripe_status' => 'canceled', ]); } catch (Exception $ex) { Log::error(self::$GATEWAY_CODE . '-> cancelSubscribedPlan(): ' . $ex->getMessage()); return back()->with(['message' => $ex->getMessage(), 'type' => 'error']); } } public static function checkIfTrial(): bool { return true; } public static function getSubscriptionRenewDate() { $user = Auth::user() ?: User::query()->first(); $subscription = getCurrentActiveSubscription($user->getAttribute('id')); $next_delivery_date = null; if ($subscription) { $id = $subscription->getAttribute('stripe_id'); $request = self::client()->subscription->fetch($id); $next_delivery_date = data_get($request, 'charge_at'); } if ($next_delivery_date) { return date('F jS, Y', $next_delivery_date); } return false; } public static function getSubscriptionStatus($incomingUserId = null) { $user = null; if ($incomingUserId) { $user = User::query()->where('id', $incomingUserId)->first(); } if (Auth::check() && $incomingUserId == null) { $user = Auth::user(); } if (! $user) { return false; } $subscription = getCurrentActiveSubscription($user->getAttribute('id')); if ($subscription) { $id = $subscription->getAttribute('stripe_id'); try { $request = self::client()->subscription->fetch($id); $status = data_get($request, 'status'); if ((string) $status === 'active') { return true; } else { if ($subscription->getAttribute('created_at') < Carbon::now()->subHours(2)) { $subscription->update([ 'stripe_status' => 'cancelled', 'ends_at' => Carbon::now(), ]); } return false; } } catch (Exception $th) { if ($subscription->getAttribute('created_at') < Carbon::now()->subHours(2)) { $subscription->update([ 'stripe_status' => 'cancelled', 'ends_at' => Carbon::now(), ]); } return false; } } return false; } public static function getSubscriptionDaysLeft() { $user = null; if (Auth::check()) { $user = Auth::user(); } if (! $user) { return; } $subscription = getCurrentActiveSubscription($user->getAttribute('id')); if ($subscription) { $id = $subscription->getAttribute('stripe_id'); try { $request = self::client()->subscription->fetch($id); $next_delivery_date = data_get($request, 'charge_at'); if ($next_delivery_date) { $date = date('Y-m-d H:i:s', $next_delivery_date); $next_delivery_date = Carbon::parse($date); return $next_delivery_date->diffInDays(Carbon::now()); } } catch (Exception $th) { return false; } } } public static function handleWebhook(Request $request) { $data = $request->all(); $event = data_get($data, 'event'); $entity = data_get($data, 'payload.subscription.entity'); if ($entity && ($event === 'subscription.activated' || $event === 'subscription.updated')) { $subscription = Subscriptions::query() ->where('stripe_id', data_get($entity, 'id')) ->first(); if ($subscription) { $subscription->update(['stripe_status' => data_get($entity, 'status')]); if (data_get($entity, 'status') === 'active') { /** * @var User $user */ $user = User::query()->where('id', $subscription->getAttribute('user_id'))->first(); /** * @var Plan $plan */ $plan = Plan::query()->where('id', $subscription->getAttribute('plan_id'))->first(); self::creditIncreaseSubscribePlan($user, $plan); } } } $razorpay_payment_link_id = data_get($data, 'razorpay_payment_link_id'); $razorpay_payment_link_status = data_get($data, 'razorpay_payment_link_status'); $razorpay_payment_link_reference_id = data_get($data, 'razorpay_payment_link_reference_id'); if ($razorpay_payment_link_id && $razorpay_payment_link_status && $razorpay_payment_link_reference_id) { $order = UserOrder::query() ->where('order_id', $razorpay_payment_link_id) ->where('type', 'token-pack') ->where('status', 'WAITING') ->first(); $api = self::client(); $data = $api->paymentLink->fetch($order->order_id); $status = $razorpay_payment_link_status; if ($status === 'paid') { /** * @var User $user */ $user = User::query()->where('id', $order->getAttribute('user_id'))->first(); /** * @var Plan $plan */ $plan = Plan::query()->where('id', $order->getAttribute('plan_id'))->first(); $order->update(['status' => 'PAID']); self::creditIncreaseSubscribePlan($user, $plan); return redirect('dashboard/user')->with(['message' => __('Payment successful'), 'type' => 'success']); } return redirect('dashboard/user')->with(['message' => __('Payment unsuccessful'), 'type' => 'error']); } return response()->json(['success' => true]); } public static function checkPayments(): void { $date = now()->subHours(2); $orders = UserOrder::query() ->where('payment_type', self::$GATEWAY_CODE) ->where('status', 'WAITING') ->where('created_at', '>', $date) ->get(); foreach ($orders as $order) { $payments = $order->payload; /** * @var User $user */ $user = User::query()->where('id', $order->getAttribute('user_id'))->first(); /** * @var Plan $plan */ $plan = Plan::query()->where('id', $order->getAttribute('plan_id'))->first(); $last = Arr::last($payments); try { if ($order->type === 'token-pack') { $api = self::client(); $data = $api->paymentLink->fetch($order->order_id); $status = data_get($data, 'status'); if ($status === 'paid') { $order->update(['status' => 'PAID']); self::creditIncreaseSubscribePlan($user, $plan); } } else { $request = self::client()->subscription->fetch($order->order_id); $subscription = Subscriptions::query() ->where('stripe_id', $order->order_id) ->first(); $status = data_get($request, 'status'); if ($subscription) { $subscription->stripe_status = $status; $subscription->save(); if ($status === 'active') { self::creditIncreaseSubscribePlan($user, $plan); } } } } catch (Exception $th) { } } } public static function planPayload(Plan $plan): array { return [ 'period' => $plan->getAttribute('frequency'), 'interval' => 1, 'item' => [ 'name' => $plan->getAttribute('name'), 'description' => $plan->getAttribute('name'), 'amount' => (int) $plan->getAttribute('price') * 100, 'currency' => 'INR', ], 'notes' => [], ]; } }