WebSVN – SmartDukaan – Diff – //trunk/ContentStore/src/main/java/in/shop2020/util/ContentGenerationUtility.java

 import in.shop2020.ui.util.SpecialPageJSONConvertor;
 import in.shop2020.utils.GmailUtils;
 import java.io.File;
 import java.io.IOException;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.LinkedHashMap;
 public class ContentGenerationUtility {
     private static final String   UPDATE_TYPE_CATALOG         = "CATALOG";
     private static final String   UPDATE_TYPE_CONTENT         = "CONTENT";
-    private static final String   COMMAND_LINE                = "java ContentGenerationUtility.class -t { ALL | INCREMENTAL | ONE } -u { CONTENT | CATALOG } -e {EntityId} ";
+    private static final String   COMMAND_LINE                = "java ContentGenerationUtility.class -t { ALL | INCREMENTAL | ONE } -s { yyyy-MM-dd-HH-mm-ss } -u { CONTENT | CATALOG } -e {EntityId} ";
     private static Log            log                         = LogFactory
                                                                       .getLog(ContentGenerationUtility.class);
     // Commandline options
     private static final String   GENERATION_TYPE_ALL         = "ALL";
     private static final String   GENERATION_TYPE_ONE         = "ONE";
     private static final String   UPDATE_TYPE_OPTION          = "u";
     private static final String   GENERATION_TYPE_OPTION      = "t";
     private static final String   ENTITY_ID_OPTION            = "e";
+    private static final String   TIMESTAMP_OPTION            = "s";
     // Default values of cmdline options
     private static String         UPDATE_TYPE                 = UPDATE_TYPE_CONTENT;
     private static String         GENERATION_TYPE             = GENERATION_TYPE_INCREMENTAL;
     private static String         ENTITY_ID                   = "ALL";
+    private Date 				  timeStamp			  		  = null;
     private CommandLine           cmd                         = null;
     private Map<Long, List<Item>> entityIdItemMap             = new LinkedHashMap<Long, List<Item>>();
     private Long                  lastGenerationTime          = 0l;
     private Map<Long, Entity>     entities;
+    private Map<Long, Entity>     dbg_entities;
     private List<Item>            items;
     private List<Source>          sources;
     private CatalogClient         csc;
     private Client                client;
         options.addOption(GENERATION_TYPE_OPTION, true, "Generation type");
         options.addOption(UPDATE_TYPE_OPTION, true, "Default is : "
                 + UPDATE_TYPE);
         options.addOption(ENTITY_ID_OPTION, true, "all entities " + ENTITY_ID
                 + " by default");
+        options.addOption(TIMESTAMP_OPTION, true, "Manual timestamp");
+    }
     public ContentGenerationUtility() throws Exception {
         csc = new CatalogClient();
         client = csc.getClient();
                 .hasOption(UPDATE_TYPE_OPTION))) {
             HelpFormatter formatter = new HelpFormatter();
             formatter.printHelp(COMMAND_LINE, options);
             System.exit(1);
+        }
         GENERATION_TYPE = cmd.getOptionValue(GENERATION_TYPE_OPTION);
         UPDATE_TYPE = cmd.getOptionValue(UPDATE_TYPE_OPTION);
         // Look for optional args.
         if (GENERATION_TYPE.equals(GENERATION_TYPE_ONE)) {
             if (cmd.hasOption(ENTITY_ID_OPTION)) {
                 HelpFormatter formatter = new HelpFormatter();
                 formatter.printHelp(COMMAND_LINE, options);
                 System.exit(1);
+            }
+        }
+        if (GENERATION_TYPE_INCREMENTAL.equals(GENERATION_TYPE))
+        	if (cmd.hasOption(TIMESTAMP_OPTION)) {
+        		SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd-HH-mm-ss");
+        		try {
+        		    timeStamp = df.parse(cmd.getOptionValue(TIMESTAMP_OPTION));
+        		} catch(Exception e) {
+        			HelpFormatter formatter = new HelpFormatter();
+                    formatter.printHelp(COMMAND_LINE, options);
+                    System.exit(1);
+        		}
+        	}
+    }
     /**
      * Call method based on arguments
+     *
             } catch (Exception e) {
                 log.error("Error updating prices", e);
+            }
+        }
-        GmailUtils gm = new GmailUtils();
+//        GmailUtils gm = new GmailUtils();
-        String[] sendTo = { "chandranshu.s@shop2020.in",
+//        String[] sendTo = { "chandranshu.s@shop2020.in",
-                "rajveer.singh@shop2020.in", "mandeep.dhir@shop2020.in" };
+//                "rajveer.singh@shop2020.in", "mandeep.dhir@shop2020.in" };
+//
-        try {
+//        try {
-            gm.sendSSLMessage(sendTo, "Content Generation Successful ? : "
+//            gm.sendSSLMessage(sendTo, "Content Generation Successful ? : "
-                    + isSuccess, "Content generation completed at time : "
+//                    + isSuccess, "Content generation completed at time : "
-                    + Calendar.getInstance().getTime().toString(),
+//                    + Calendar.getInstance().getTime().toString(),
-                    "build@shop2020.in", "shop2020", logfile);
+//                    "build@shop2020.in", "shop2020", logfile);
-        } catch (MessagingException e) {
+//        } catch (MessagingException e) {
-            log.error("Could not send status mail", e);
+//            log.error("Could not send status mail", e);
-        }
+//        }
+    }
     public boolean cleanDir(File dir, boolean deleteSelf) {
         if (dir.isDirectory()) {
             String[] children = dir.list();
         if (GENERATION_TYPE.equals(GENERATION_TYPE_ALL)) {
             entities = CreationUtils.getEntities();
             lastGenerationTime = new Long(0);
         } else if (GENERATION_TYPE.equals(GENERATION_TYPE_ONE)) {
             entities = new HashMap<Long, Entity>();
+            dbg_entities = CreationUtils.getEntities();
             entities.put(Long.parseLong(ENTITY_ID),
                     CreationUtils.getEntity(Long.parseLong(ENTITY_ID)));
             lastGenerationTime = new Long(0);
         } else {
-            entities = CreationUtils.getEntities();
+        	entities = CreationUtils.getEntities();
+            //  When we read lastGenerationTime from database
+            //  then only we should mark the
+            //	current time as newLastGenerationTime
+            if(timeStamp == null) {
-            newLastGenerationTime = new Date().getTime();
+            	newLastGenerationTime = new Date().getTime();
-            lastGenerationTime = CreationUtils.getLastContentGenerationTime();
+            	lastGenerationTime = CreationUtils.getLastContentGenerationTime();
+            } else {
+            	lastGenerationTime = timeStamp.getTime();
+            }
             log.info("lastGenerationTime: " + lastGenerationTime);
             if (lastGenerationTime == null) {
                 lastGenerationTime = new Long(0);
+            }
         }
         // Filter invalid entities here
         List<Entity> validEntities = new ArrayList<Entity>();
         for (long entityID : entities.keySet()) {
             if (isValidEntity(entities.get(entityID))) {

Subversion Repositories SmartDukaan

(root)//trunk/ContentStore/src/main/java/in/shop2020/util/ContentGenerationUtility.java – Rev 4058 → 4098