Subversion Repositories SmartDukaan

package in.shop2020.utils;

import in.shop2020.datalogger.EventType;

import in.shop2020.datalogger.SocialEventType;

import in.shop2020.datalogger.event.Event;

import in.shop2020.datalogger.socialevent.SocialEvent;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.UnsupportedEncodingException;

import java.net.MalformedURLException;

import java.net.URL;

import java.net.URLConnection;

import java.net.URLEncoder;

import java.util.Date;

import java.util.ResourceBundle;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import org.apache.commons.lang.StringUtils;

import org.apache.log4j.Logger;

import org.json.JSONObject;

public class DataLogger {

    /**

     * If it fails to log the data to google app engine, we log the event locally to data.log using log4j.

     */

    private static Logger log = Logger.getLogger(DataLogger.class);

    /**

     * RootLogger to be used internal logging of this class.

     */

    private static Logger rootLogger = Logger.getRootLogger();

    /**

     * Logger to post data to google app engine.

     */

    private static ExecutorService asyncDataLogger = Executors.newSingleThreadExecutor();

    private static ExecutorService asyncSocialDataLogger = Executors.newSingleThreadExecutor();

    private static ResourceBundle properties = ResourceBundle.getBundle(DataLogger.class.getName());

    private static String googleAppUrl = properties.getString("googleappurl");

    public static void logData(final EventType eType, final String sessionId, final long userId, final String email, final String... logData) {

        final String strToWrite = StringUtils.join(logData, ", ");

        final Long time = (new Date()).getTime();

        asyncDataLogger.execute(new Runnable() {

            @Override

            public void run() {

                Event event = Event.createEvent(eType, sessionId, userId, email, logData);

                JSONObject logDataInJson = event.getLogDataInJson();

                try {

                    // Construct data

                    String data = URLEncoder.encode("time", "UTF-8") + "=" + URLEncoder.encode(time.toString(), "UTF-8");

                    data += "&" + URLEncoder.encode("eventType", "UTF-8") + "=" + URLEncoder.encode(eType.name(), "UTF-8");

                    data += "&" + URLEncoder.encode("sessionId", "UTF-8") + "=" + URLEncoder.encode(sessionId, "UTF-8");

                    data += "&" + URLEncoder.encode("userId", "UTF-8") + "=" + URLEncoder.encode(Long.toString(userId), "UTF-8");

                    data += "&" + URLEncoder.encode("email", "UTF-8") + "=" + URLEncoder.encode(email, "UTF-8");

                    if (logDataInJson != null) {

                        data += "&" + URLEncoder.encode("jsonLogData", "UTF-8")

                                + "=" + URLEncoder.encode(logDataInJson.toString(), "UTF-8");

                    }

                    // Send data

                    URL url = new URL("http://" + googleAppUrl + "/add-data-log");

                    URLConnection conn = url.openConnection();

                    conn.setDoOutput(true);

                    OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream());

                    wr.write(data);

                    wr.close();

                    conn.getInputStream().close();

                } catch (UnsupportedEncodingException e) {

                    rootLogger.error("Unsupported Encoding Exception: " + eType.name() + " " + sessionId + " " + userId + " " + email);

                    log.error(eType.name() + ", " + sessionId + ", " + Long.toString(userId) + ", " + email + ", " + strToWrite);

				} catch (MalformedURLException e) {

					rootLogger.error("Malformed URL Exception: " + eType.name() + " " + sessionId + " " + userId + " " + email);

                    log.error(eType.name() + ", " + sessionId + ", " + Long.toString(userId) + ", " + email + ", " + strToWrite);

				} catch (IOException e) {

					rootLogger.error("IO Exception: " + eType.name() + " " + sessionId + " " + userId + " " + email);

                    log.error(eType.name() + ", " + sessionId + ", " + Long.toString(userId) + ", " + email + ", " + strToWrite);

				}

            }

        });

    }

    public static void logSocialData(final SocialEventType eType, final String userId, final String... logData) {

        final String strToWrite = StringUtils.join(logData, ", ");

        final Long time = (new Date()).getTime();

        asyncSocialDataLogger.execute(new Runnable() {

            @Override

            public void run() {

                log.info(eType.name() + ", " + userId + ", " + strToWrite);

                SocialEvent event = SocialEvent.createEvent(eType, userId, logData);

                JSONObject logDataInJson = event.getLogDataInJson();

                try {

                    String data = URLEncoder.encode("time", "UTF-8") + "=" + URLEncoder.encode(time.toString(), "UTF-8");

                    data += "&" + URLEncoder.encode("eventType", "UTF-8") + "=" + URLEncoder.encode(eType.name(), "UTF-8");

                    data += "&" + URLEncoder.encode("userId", "UTF-8") + "=" + URLEncoder.encode(userId, "UTF-8");

                    if (logDataInJson != null) {

                        data += "&" + URLEncoder.encode("jsonLogData", "UTF-8") + "=" + URLEncoder.encode(logDataInJson.toString(), "UTF-8");

                    }

                    // Send data

                    URL url = new URL("http://" + googleAppUrl + "/add-social-data-log");

                    URLConnection conn = url.openConnection();

                    conn.setDoOutput(true);

                    OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream());

                    wr.write(data);

                    wr.close();

                    BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));

                    while (in.readLine() != null);

                    in.close();

                } catch (Exception e) {

                    Logger.getRootLogger().warn(e);

                }

            }

        });

    }

    public static void main(String[] args) {

        DataLogger.logData(EventType.NEW_SESSION, "FDTWSYTW", 12, "vmalik@gmail.com", "Test");

    }

}