Subversion Repositories SmartDukaan

package com.smartdukaan.cron.monitored;

import java.io.IOException;

import java.util.HashMap;

import java.util.Map;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

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

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

import org.springframework.stereotype.Component;

import com.spice.profitmandi.common.enumuration.SchemeType;

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

import com.spice.profitmandi.common.model.RechargeCredential;

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

import com.spice.profitmandi.dao.repository.catalog.ItemRepository;

import com.spice.profitmandi.service.recharge.RechargeService;

import com.spice.profitmandi.service.recharge.provider.ThinkWalnutDigitalRechargeProviderService;

@Component

/**

 * Reads the two prepaid balances -- SMS credits and the ThinkWalnut recharge wallet --

 * and pushes them into {@link BalanceGauges}.

 *

 * ⚠ NOTHING CALLS THIS. There is no @Scheduled method and no other caller anywhere in

 * the codebase, which is why both gauges read -1 ("not read yet") on every scrape. The

 * micrometer bridge works; the trigger was never written. Either give it a @Scheduled

 * entry in ScheduledSkeleton or delete this and its gauges -- do not leave it half-wired.

 *

 * Formerly NagiosMonitorTasks: the Nagios server and every NRPE daemon are gone, so the

 * name described a transport that no longer exists.

 */

public class BalanceMonitorTasks {

	private static final Logger log = LogManager.getLogger(BalanceMonitorTasks.class);

	@Value("${think.walnut.digital.recharge.transaction.mobile.url}")

	private String thinkWalnutDigitalRechargeTransactionMobileUrl;

	@Value("${think.walnut.digital.recharge.transaction.dth.url}")

	private String thinkWalnutDigitalRechargeTransactionDthUrl;

	@Value("${think.walnut.digital.recharge.enquiry.url}")

	private String thinkWalnutDigitalRechargeEnquiryUrl;

	@Value("${think.walnut.digital.recharge.balance.url}")

	private String thinkWalnutDigitalRechargeBalanceUrl;

	@Value("${think.walnut.digital.recharge.username}")

	private String thinkWalnutDigitalRechargeUserName;

	@Value("${think.walnut.digital.recharge.password}")

	private String thinkWalnutDigitalRechargePassword;

	@Value("${think.walnut.digital.recharge.auth.key}")

	private String thinkWalnutDigitalRechargeAuthKey;

	@Autowired

	private ThinkWalnutDigitalRechargeProviderService thinkWalnutDigitalRechargeProviderService;

	@Autowired

	private RestClient restClient;

	@Autowired

	ItemRepository itemRepository;

	@Autowired

	private RechargeService rechargeService;

	@Autowired

	private BalanceGauges balanceGauges;

	public void reportSmsCount() throws Throwable {

		String htmlpage;

		int currentSmsCount = 0;

		String uri = "/MessagingGateway/GetSMSBalance";

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

		params.put("Username", "srlsaholic");

		params.put("Password", "sr18mar");

		String response = restClient.post(SchemeType.HTTP, "103.15.179.45", 8085, uri, params, new HashMap<>());

		// System.out.println("response Html"+response);

		if (response.length() > 0) {

			htmlpage = response.substring(response.indexOf("=")+1);

			 System.out.println(htmlpage);

			currentSmsCount = Integer.parseInt(htmlpage.trim());

			log.info("Got successfully parsed {}", currentSmsCount);

			balanceGauges.setSmsBalance(currentSmsCount);

		}

	}

	public void currentThinkWalnutBalace() throws ProfitMandiBusinessException, IOException {

		RechargeCredential thinkWalnutDigitalRechargeCredential = new RechargeCredential();

		thinkWalnutDigitalRechargeCredential.setRechargeUrl(thinkWalnutDigitalRechargeBalanceUrl);

		thinkWalnutDigitalRechargeCredential.setRechargeUserName(thinkWalnutDigitalRechargeUserName);

		thinkWalnutDigitalRechargeCredential.setRechargePassword(thinkWalnutDigitalRechargePassword);

		thinkWalnutDigitalRechargeCredential.setRechargeAuthKey(thinkWalnutDigitalRechargeAuthKey);

		float thinkWalnutBalance = thinkWalnutDigitalRechargeProviderService

				.doCheckBalanceRequest(thinkWalnutDigitalRechargeCredential);

		log.info("ThinkWalnut Balance {}", thinkWalnutBalance);

		balanceGauges.setRechargeWalletBalance(thinkWalnutBalance);

	}

}