Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import com.fasterxml.jackson.databind.ObjectMapper;

import com.razorpay.Utils;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.web.util.ResponseSender;

import com.spice.profitmandi.dao.entity.fofo.Customer;

import com.spice.profitmandi.dao.entity.fofo.FofoOrder;

import com.spice.profitmandi.dao.entity.fofo.UpsellRazorpayPaymentStatus;

import com.spice.profitmandi.dao.repository.cs.AgentRecordingRepository;

import com.spice.profitmandi.dao.repository.fofo.CustomerRepository;

import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;

import com.spice.profitmandi.dao.repository.fofo.UpsellRazorpayPaymentStatusRepository;

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

import com.spice.profitmandi.service.integrations.smartping.SmartPingService;

import com.spice.profitmandi.service.integrations.smartping.model.CallDetailModel;

import com.spice.profitmandi.service.integrations.smartping.model.PushCallLogModel;

import com.spice.profitmandi.web.util.MVCResponseSender;

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.HttpStatus;

import org.springframework.http.MediaType;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.ui.Model;

import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;

@Controller

@Transactional(rollbackFor = Throwable.class)

public class WebHookController {

    @Autowired

    MVCResponseSender mvcResponseSender;

    @Autowired

    private ResponseSender<?> responseSender;

    @Autowired

    private FofoOrderRepository fofoOrderRepository;

    @Autowired

    private CustomerRepository customerRepository;

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

    @Autowired

    SmartPingService smartPingService;

    @Autowired

    RecordingService recordingService;

    @Autowired

    AgentRecordingRepository agentRecordingRepository;

    /*

     * URL: POST /click2call/report-handler/recording-url

     * Content-Type: application/x-www-form-urlencoded

     * Third-party: Knowlarity

     */

    @RequestMapping(value = "/click2call/report-handler/recording-url", method = RequestMethod.POST, consumes = MediaType.APPLICATION_FORM_URLENCODED_VALUE)

    public ResponseEntity<?> click2callReportHandlerUpdateRecordingUrlPost(HttpServletRequest request, Model model, @ModelAttribute CallDetailModel callDetail) throws Exception {

        // Log raw parameters from Knowlarity before processing, so we can see exactly what they sent

        LOGGER.info("recording-url raw params from Knowlarity: {}", request.getParameterMap());

        try {

            LOGGER.info("update call detail (mapped): {}", callDetail);

            recordingService.updateAgentRecordingUrl(callDetail);

        } catch (Exception e) {

            LOGGER.error("Error processing recording-url webhook. Raw params: {}", request.getParameterMap(), e);

        }

        return responseSender.ok(true);

    }

    /**

     * Knowlarity Click2Call Webhook - Push Call Log.

     */

    @RequestMapping(value = "/click2call/push-call-log-handler/{srNumber}", method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)

    public ResponseEntity<?> click2callPushLogHandler(HttpServletRequest request, @RequestBody String rawBody, @PathVariable String srNumber) throws Exception {

        // Log raw JSON body from Knowlarity before processing, so we can see exactly what they sent

        LOGGER.info("push-call-log raw JSON from Knowlarity: {}", rawBody);

        try {

            ObjectMapper objectMapper = new ObjectMapper();

            PushCallLogModel pushCallLogModel = objectMapper.readValue(rawBody, PushCallLogModel.class);

            LOGGER.info("update call detail - push log (mapped): {}", pushCallLogModel);

            recordingService.updateAgentCallLog(pushCallLogModel);

        } catch (Exception e) {

            LOGGER.error("Error processing push-call-log webhook. Raw JSON: {}", rawBody, e);

        }

        return responseSender.ok("true");

    }

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

    private String razorpaySecret;

    @Autowired

    private UpsellRazorpayPaymentStatusRepository upsellRazorpayPaymentStatusRepository;

    @RequestMapping(value = "/upsellPayment/callback", method = RequestMethod.GET)

    public ResponseEntity<?> handleCallback(HttpServletRequest request) {

        try {

            // Retrieve the Razorpay parameters from the query string

            String paymentId = request.getParameter("razorpay_payment_id");

            String razorpaySignature = request.getParameter("razorpay_signature");

            String paymentLinkId = request.getParameter("razorpay_payment_link_id");

            String paymentLinkStatus = request.getParameter("razorpay_payment_link_status");

            String paymentLinkReferenceId = request.getParameter("razorpay_payment_link_reference_id");

            String orderId = request.getParameter("orderId");

            String insuranceAmount = request.getParameter("insuranceAmount");

            // Check for required parameters

            if (paymentId == null || razorpaySignature == null || orderId == null || insuranceAmount == null) {

                return ResponseEntity.status(HttpStatus.BAD_REQUEST).body("Missing required parameters");

            }

            JSONObject options = new JSONObject();

            options.put("payment_link_reference_id", paymentLinkReferenceId);

            options.put("razorpay_payment_id", paymentId);

            options.put("payment_link_status", paymentLinkStatus);

            options.put("payment_link_id", paymentLinkId);

            options.put("razorpay_signature", razorpaySignature);

            boolean status = Utils.verifyPaymentLink(options, razorpaySecret);

            LOGGER.info("status signature {}", status);

            if (!status) {

                return ResponseEntity.status(HttpStatus.BAD_REQUEST).body("Invalid signature");

            }

            FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(Integer.parseInt(orderId));

            Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());

            // Handle the payment status (you may need to add more logic depending on the status)

            updatePaymentStatus(paymentId, paymentLinkReferenceId, "captured", orderId, insuranceAmount);

            // Construct the HTML response

            String htmlResponse = "<html>" +

                    "<head>" +

                    "<style>" +

                    "  .container { background-color: #f0f0f0; padding: 20px; text-align: center; border-radius: 8px;max-width:600px;width:auto;margin:10px auto; }" +

                    "  .success-icon { color: green; font-size:30px; margin-right: 10px;border-radius: 50%;border: 2px solid;padding: 1px 7px; }" +

                    "  .message { font-size: 18px; margin-top: 10px; }" +

                    "</style>" +

                    "</head>" +

                    "<body>" +

                    "  <div class='container'>" +

                    "    <span class='success-icon'>&#10003;</span>" +

                    "    <div class='message'>" +

                    "      Hi " + customer.getFirstName() + ",<br>" +

                    "      Your payment of " + insuranceAmount + " was successfully completed.<br>" +

                    "      Your payment ID is: " + paymentId + "." +

                    "    </div>" +

                    "  </div>" +

                    "</body>" +

                    "</html>";

            return ResponseEntity.ok().contentType(MediaType.TEXT_HTML).body(htmlResponse);

        } catch (Exception e) {

            e.printStackTrace();

            return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body("Error processing callback");

        }

    }

    private void updatePaymentStatus(String paymentId, String paymentLinkReferenceId, String status, String orderId, String amount) throws ProfitMandiBusinessException {

        int id = Integer.parseInt(paymentLinkReferenceId.replaceFirst("^0+(?!$)", ""));

        UpsellRazorpayPaymentStatus upsellRazorpayPaymentStatus = upsellRazorpayPaymentStatusRepository.selectById(id);

        upsellRazorpayPaymentStatus.setPaymentId(paymentId);

        upsellRazorpayPaymentStatus.setReferenceId(paymentLinkReferenceId);

        upsellRazorpayPaymentStatus.setPaymentStatus(status);

        upsellRazorpayPaymentStatus.setPayment(Float.parseFloat(amount));

    }

}