Subversion Repositories SmartDukaan

import org.json.JSONArray;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.HttpURLConnection;

import java.net.URL;

    private boolean sendWhatsAppMessageByMeta(WhatsappMessageType whatsappMessageType, String message, String title, String mobile, String mediaUrl, String fileName) throws Exception {

        mobile = this.optInUsersByMobiles(mobile);

        String token = "###############";

        String phoneNumberId = "000000000000000000";

        String url = "https://graph.facebook.com/v22.0/" + phoneNumberId + "/messages";

        HttpURLConnection conn = (HttpURLConnection) new URL(url).openConnection();

        conn.setRequestMethod("POST");

        conn.setRequestProperty("Authorization", "Bearer " + token);

        conn.setRequestProperty("Content-Type", "application/json");

        conn.setDoOutput(true);

        // Construct the payload

        JSONObject payload = new JSONObject();

        payload.put("messaging_product", "whatsapp");

        payload.put("to", "918529003611");

        if (mediaUrl != null) {

            JSONObject image = new JSONObject();

            image.put("link", mediaUrl);

            if (fileName != null) image.put("caption", message);

            payload.put("type", "image");

            payload.put("image", image);

        } else {

            payload.put("type", "template");

            JSONObject template = new JSONObject();

            template.put("name", "bid_live");

            JSONObject language = new JSONObject();

            language.put("code", "en_US");

            template.put("language", language);

            JSONArray components = new JSONArray();

            JSONObject body = new JSONObject();

            body.put("type", "body");

            JSONArray parameters = new JSONArray();

            parameters.put(new JSONObject().put("type", "text").put("text", "*Oppo Reno 10 Pro 5G (12GB 256GB) Silvery Grey* at 54.55% Off"));

            parameters.put(new JSONObject().put("type", "text").put("text", "44000.0"));

            parameters.put(new JSONObject().put("type", "text").put("text", "20000.0"));

            parameters.put(new JSONObject().put("type", "text").put("text", "05/05/2025 06:00PM"));

            body.put("parameters", parameters);

            components.put(body);

            template.put("components", components);

            payload.put("template", template);

        }

        LOGGER.info("Final WhatsApp payload: \n{}", payload.toString(2));

        try (OutputStream os = conn.getOutputStream()) {

            os.write(payload.toString().getBytes(StandardCharsets.UTF_8));

        }

        int status = conn.getResponseCode();

        String response = new BufferedReader(new InputStreamReader(status >= 400 ? conn.getErrorStream() : conn.getInputStream())).lines().collect(Collectors.joining("\n"));

        LOGGER.info("WhatsApp API response: {}", response);

        if (status != 200 && status != 201) {

            LOGGER.error("Failed to send WhatsApp message. Status: {}, Response: {}", status, response);

            return false;

        }

        JSONObject jsonResponse = new JSONObject(response);

        JSONArray messages = jsonResponse.optJSONArray("messages");

        String externalId = null;

        if (messages != null && messages.length() > 0) {

            externalId = messages.getJSONObject(0).optString("id");

            WhatsappMessage whatsappMessage = new WhatsappMessage();

            whatsappMessage.setCreatedTimestamp(LocalDateTime.now());

            whatsappMessage.setExternalId(externalId);

            whatsappMessage.setDestAddr(mobile);

            whatsappMessageRepository.persist(whatsappMessage);

        }

        return externalId != null;

    }

    private String optInUsersByMobiles(String mobiles) throws Exception {

        List<String> savedMobiles = new ArrayList<>();

        if (mobiles == null || mobiles.isEmpty()) return String.join(",",savedMobiles);

        String[] mobileNumbers = mobiles.split(",");

        for (String mobile : mobileNumbers) {

            mobile = mobile.trim();

            if (mobile.isEmpty()) continue;

            Optin optin = optinRepository.selectByMobile(mobile);

            if (optin == null) {

                this.optIn(mobile);

                optin = new Optin();

                optin.setCreated(LocalDateTime.now());

                optin.setMobile(mobile);

                optinRepository.persist(optin);

            }

            savedMobiles.add("91"+mobile);

        }

        return String.join(",",savedMobiles);

    }