Subversion Repositories SmartDukaan

package in.shop2020.web;

import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.TimeZone;
import java.util.logging.Logger;

import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

import com.google.appengine.api.datastore.DatastoreService;
import com.google.appengine.api.datastore.DatastoreServiceFactory;
import com.google.appengine.api.datastore.Entity;

public class AddDataLogServlet extends HttpServlet {
    private static final long serialVersionUID = -8236918415987438049L;
    private static Logger logger = Logger.getLogger(AddDataLogServlet.class.getName());
    
    private static final int BATCH_SIZE = 200;
    private List<Entity> entityList =  new ArrayList<Entity>(); // TO store entities in batches for performance
    
    public void doPost(HttpServletRequest req, HttpServletResponse resp) {
        Entity entity = new Entity("DataLog");
        entity.setProperty("logTime", new Date());
        
        setTime(req, entity);
        setEventType(req, entity);
        setSessionId(req, entity);
        setUserId(req, entity);
        setEmail(req, entity);
        setLogData(req, entity);
        
        entityList.add(entity);
        if(entityList.size() >= BATCH_SIZE) {
            logger.warning("Pushing events to datastore : " + entityList.size());
            synchronized(entityList) {
                DatastoreService ds = DatastoreServiceFactory.getDatastoreService();
                ds.put(entityList);
                entityList.clear();
            }
        }
    }
    
    public void doGet(HttpServletRequest req, HttpServletResponse resp) {
        doPost(req, resp);
    }

    private void setTime(HttpServletRequest req, Entity entity) {
        Date date = new Date(Long.valueOf(req.getParameter("time")));
        entity.setProperty("date", date);
        
        Calendar cal = Calendar.getInstance(TimeZone.getTimeZone("IST"));
        cal.setTime(date);
        cal.set(Calendar.HOUR_OF_DAY, 0);
        cal.set(Calendar.MINUTE, 0);  
        cal.set(Calendar.SECOND, 0);  
        cal.set(Calendar.MILLISECOND, 0);
        entity.setProperty("shortdate", cal.getTime());
    }
    
    private void setEventType(HttpServletRequest req, Entity entity) {
        entity.setProperty("eventType", req.getParameter("eventType"));
    }

    private void setSessionId(HttpServletRequest req, Entity entity) {
        entity.setProperty("sessionId", req.getParameter("sessionId"));
    }

    private void setUserId(HttpServletRequest req, Entity entity) {
        Integer userId = 0;
        try {
            userId = Integer.valueOf(req.getParameter("userId"));
        }
        catch (NumberFormatException e) {
        }
        entity.setProperty("userId", userId);
    }

    private void setEmail(HttpServletRequest req, Entity entity) {
        entity.setProperty("email", req.getParameter("email"));
    }
    
    private void setLogData(HttpServletRequest req, Entity entity) {
        try {
            String jsonLogData = req.getParameter("jsonLogData");
            if (jsonLogData == null) {
                return;
            }
            JSONObject logDataJson = new JSONObject(req.getParameter("jsonLogData"));
            for (String key : JSONObject.getNames(logDataJson)) {
                if (key.endsWith("_long_list")) {
                    JSONArray vals = logDataJson.getJSONArray(key);
                    List<Long> lVals = new ArrayList<Long>();
                    for (int i = 0; i<vals.length(); i++) {
                        lVals.add(vals.getLong(i));
                    }
                    entity.setProperty(key.replace("_long_list", ""), lVals);
                } else if (key.endsWith("_long")) {
                    entity.setProperty(key.replace("_long", ""), logDataJson.getLong(key));
                }
                else {
                    entity.setProperty(key, logDataJson.getString(key));
                }
            }
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void destroy() {
        logger.warning("Pushing events to datastore in destroy() : " + entityList.size());
        synchronized(entityList) {
            DatastoreService ds = DatastoreServiceFactory.getDatastoreService();
            ds.put(entityList);
            entityList.clear();
        }
        super.destroy();
    }
}