Subversion Repositories SmartDukaan

package in.shop2020.datalogger;

import in.shop2020.datalogger.event.Event;

import java.io.BufferedReader;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import org.apache.commons.lang.StringUtils;

public class DataLogParser {

    private static String dataFile = "/var/log/website/data.log";

    private static Map<String, List<Event>> logDataMap;

    private static Map<Long, String> orderSessionMap;

    private static Map<Long, Set<String>> userSessionMap;

    private static void parseFile(String dataFile) {

        // TODO Auto-generated method stub

        logDataMap = new HashMap<String, List<Event>>();

        orderSessionMap = new HashMap<Long, String>();

        userSessionMap = new HashMap<Long, Set<String>>();

        File f = new File(dataFile);

        if(!f.exists()) {

            System.out.println(dataFile + " - does not exist");

        }

        FileInputStream fis = null;

        try {

            fis = new FileInputStream(f);

            BufferedReader br = new BufferedReader(new InputStreamReader(fis));

            String line;

            while((line = br.readLine()) != null){

                String[] logFields = StringUtils.split(line, ",");

                Event event = Event.createEvent(logFields);

                String sessionId = event.getSessionId();

                if (!logDataMap.containsKey(sessionId)) {

                    List<Event> logEvents = new ArrayList<Event>();

                    logEvents.add(event);

                    logDataMap.put(sessionId, logEvents);

                }

                else {

                    logDataMap.get(sessionId).add(event);

                }

                String eventName = event.getEventType().name();

                if(eventName.equals(EventType.ORDER_CREATION.name())) {

                    Long orderId = Long.parseLong(logFields[5].trim());

                    if (!orderSessionMap.containsKey(orderId)) {

                        orderSessionMap.put(orderId, sessionId);

                    }

                }

                try {

                    Long userId = event.getUserId();

                    if (!userSessionMap.containsKey(userId)) {

                        Set<String> userSessions = new HashSet<String>();

                        userSessions.add(sessionId);

                        userSessionMap.put(userId, userSessions);

                    }

                    else {

                        userSessionMap.get(userId).add(sessionId);

                    }

                } catch (NumberFormatException e) {

                    // e.printStackTrace();

                }

            }

        } catch (IOException e) {

            e.printStackTrace();

        }

        finally {

            if(fis != null) {

                try {

                    fis.close();

                } catch (IOException e) {

                    e.printStackTrace();

                }

            }

        }

    }

    private static void printHistoryEventsForOrder(long i) {

        String session = orderSessionMap.get(i);

        List<Event> events = logDataMap.get(session);

        for (Event event : events) {

            System.out.println(event);

        }

    }

    public static void main(String[] args) {

        parseFile(dataFile);

        /*

        for (Map.Entry<String, List<String>> entry : logDataMap.entrySet()) {

            List<String> logs = entry.getValue();

            for (String log : logs) {

                System.out.println(entry.getKey() + " : " + log);

            }

        }

        for (Map.Entry<Long, Set<String>> entry : userSessionMap.entrySet()) {

            Set<String> sessions = entry.getValue();

            for (String session : sessions) {

                System.out.println(entry.getKey() + " : " + session);

            }

        }

        for (Map.Entry<Long, String> entry : orderSessionMap.entrySet()) {

            System.out.println(entry.getKey() + " : " + entry.getValue());

        }

        */

        System.out.println(orderSessionMap.size());

        System.out.println(userSessionMap.size());

        System.out.println(logDataMap.size());

        printHistoryEventsForOrder(500);

    }

}