BfhlQualifierApplication.java

package com.exam.bfhl;

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;

import java.util.HashMap;
import java.util.Map;

@SpringBootApplication
public class BfhlQualifierApplication implements CommandLineRunner {

    public static void main(String[] args) {
        SpringApplication.run(BfhlQualifierApplication.class, args);
    }

    @Override
    public void run(String... args) {
        System.out.println("Starting application and executing webhook task...");
        RestTemplate restTemplate = new RestTemplate();

        String generateWebhookUrl = "https://bfhldevapigw.healthrx.co.in/hiring/generateWebhook/JAVA";
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);

        Map<String, String> requestBody = new HashMap<>();
        requestBody.put("name", "John Doe");
        requestBody.put("regNo", "REG12347");
        requestBody.put("email", "john@example.com");

        HttpEntity<Map<String, String>> request = new HttpEntity<>(requestBody, headers);

        try {
            ResponseEntity<Map> response = restTemplate.postForEntity(generateWebhookUrl, request, Map.class);
            System.out.println("Generate Webhook Response: " + response.getBody());

            if (response.getBody() != null) {
                String webhook = (String) response.getBody().get("webhook");
                String accessToken = (String) response.getBody().get("accessToken");

                if (webhook == null) {
                    webhook = "https://bfhldevapigw.healthrx.co.in/hiring/testWebhook/JAVA"; // Fallback
                }

                String sqlQuery = "SELECT p.AMOUNT AS SALARY, CONCAT(e.FIRST_NAME, ' ', e.LAST_NAME) AS NAME, TIMESTAMPDIFF(YEAR, e.DOB, CURDATE()) AS AGE, d.DEPARTMENT_NAME FROM PAYMENTS p JOIN EMPLOYEE e ON p.EMP_ID = e.EMP_ID JOIN DEPARTMENT d ON e.DEPARTMENT = d.DEPARTMENT_ID WHERE DAY(p.PAYMENT_TIME) != 1 ORDER BY p.AMOUNT DESC LIMIT 1;";

                HttpHeaders submitHeaders = new HttpHeaders();
                submitHeaders.setContentType(MediaType.APPLICATION_JSON);
                submitHeaders.set("Authorization", accessToken);

                Map<String, String> submitBody = new HashMap<>();
                submitBody.put("finalQuery", sqlQuery);

                HttpEntity<Map<String, String>> submitRequest = new HttpEntity<>(submitBody, submitHeaders);

                System.out.println("Submitting to: " + webhook);
                ResponseEntity<String> submitResponse = restTemplate.postForEntity(webhook, submitRequest, String.class);
                System.out.println("Submit Response: " + submitResponse.getBody());
            }

        } catch (Exception e) {
            System.err.println("API execution failed: " + e.getMessage());
        }
    }
}