Subversion Repositories SmartDukaan

package com.smartdukaan.cron.services.razorpayx;

import com.spice.profitmandi.common.web.client.RestClient;

import com.spice.profitmandi.service.integrations.kommuno.RecordingService;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.json.JSONObject;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.http.HttpHeaders;

import org.springframework.stereotype.Component;

import java.nio.charset.StandardCharsets;

import java.util.Base64;

import java.util.HashMap;

import java.util.Map;

@Component

public class RazorpayXClient {

    private static final Logger LOGGER = LogManager.getLogger(RazorpayXClient.class);

    @Value("${razorpay.x.account.keyId}")

    private String API_KEY;

    @Value("${razorpay.x.account.keySecret}")

    private String API_SECRET;

    @Value("${razorpay.api.url}")

    private String BASE_URL;

    @Value("${razorpay.x.account.number}")

    private String RAZORPAYX_ACCOUNT;

    @Autowired

    private RestClient restClient; // same utility you used for Knowlarity

    public String createPayoutRaw(String fundAccountId, Double amount, String idempotencyKey, String currency) throws Exception {

        JSONObject payload = new JSONObject();

        payload.put("account_number", RAZORPAYX_ACCOUNT);

        payload.put("fund_account_id", fundAccountId);

        payload.put("amount", (int) (amount * 100));

        payload.put("currency", currency);

        payload.put("mode", "IMPS");

        payload.put("purpose", "payout");

        payload.put("queue_if_low_balance", true);

        try {

            Map<String, String> headers = getAuthHeaders();

            headers.put("X-Payout-Idempotency", idempotencyKey);

            LOGGER.info("Sending RazorpayX payout request: {}", payload);

            String url = BASE_URL + "/payouts";

            return restClient.post(url, payload.toString(), headers);

        } catch (Exception e) {

            LOGGER.error("Failed to create payout", e);

            throw e;

        }

    }

    public JSONObject fetchPayoutStatus(String payoutId) throws Exception {

        String url = BASE_URL + "/payouts/" + payoutId;

        String response = restClient.get(url,null, getAuthHeaders());

        return new JSONObject(response);

    }

    private Map<String, String> getAuthHeaders() {

        Map<String, String> headers = new HashMap<>();

        headers.put("Content-Type", "application/json");

        String auth = API_KEY + ":" + API_SECRET;

        String encodedAuth = Base64.getEncoder()

                .encodeToString(auth.getBytes(StandardCharsets.UTF_8));

        headers.put("Authorization", "Basic " + encodedAuth);

        return headers;

    }

}