1 files changed, 91 insertions, 0 deletions
diff --git a/ecomp-sdk/epsdk-analytics/src/main/java/org/openecomp/portalsdk/analytics/util/Scheduler.java b/ecomp-sdk/epsdk-analytics/src/main/java/org/openecomp/portalsdk/analytics/util/Scheduler.java
new file mode 100644
index 00000000..0dc6da17
--- /dev/null
+++ b/ecomp-sdk/epsdk-analytics/src/main/java/org/openecomp/portalsdk/analytics/util/Scheduler.java
@@ -0,0 +1,91 @@
+/*-
+ * ================================================================================
+ * eCOMP Portal SDK
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ================================================================================
+ */
+package org.openecomp.portalsdk.analytics.util;
+
+import java.sql.SQLException;
+import java.util.*;
+
+import org.openecomp.portalsdk.analytics.error.ReportSQLException;
+import org.openecomp.portalsdk.analytics.scheduler.SendNotifications;
+import org.openecomp.portalsdk.analytics.system.*;
+import org.openecomp.portalsdk.analytics.util.*;
+
+public class Scheduler extends TimerTask {
+	private Timer timer = new Timer(true);
+
+	private int timeInterval = 0;
+
+	public Scheduler(int timeInterval) {
+		super();
+
+		this.timeInterval = timeInterval;
+		start();
+	} // Scheduler
+
+	public void start() {
+		if (timeInterval > 0)
+			timer.schedule(this, 0, timeInterval * 1000);
+	}
+
+	public void stop() {
+		timer.cancel();
+	}
+
+	public void run() {
+		
+		SendNotifications sendNotifications = null;
+		
+		try {
+			Log.write("[Scheduler.run " + (new java.util.Date()).toString()
+					+ "] Sending notifications...", 4);
+            //System.out.println("SMTP Server " + AppUtils.getSMTPServer()); 
+            //System.out.println("System Name " + Globals.getSystemName());
+            //System.out.println("DefaultEmailSender " + AppUtils.getDefaultEmailSender());
+            //System.out.println("DirectAccessURL " + AppUtils.getDirectAccessURL());
+	        //System.out.println("timeInterval " + timeInterval);
+			/*	        
+	        DbUtils.executeCall(
+	        		"BEGIN cr_raptor.send_notifications(" +
+	        		"'" + AppUtils.getSMTPServer() + "', " + 
+	        		"'" + AppUtils.getDefaultEmailSender() + "', " + 
+	        		"'" + Globals.getSystemName() + "', " + 
+	        		"'" + AppUtils.getDirectAccessURL() + "', " + 
+	        		timeInterval + 
+	        		"); END;", false);
+	        */
+			sendNotifications = new SendNotifications();
+			sendNotifications.send_notification(AppUtils.getSMTPServer(), AppUtils.getSMTPServer(), Globals.getSystemName() ,
+					AppUtils.getDirectAccessURL(), timeInterval);
+	        
+		} catch (Exception e) {
+			Log.write("[SYSTEM ERROR Scheduler.run] Exception: " + e.getMessage());
+			//e.printStackTrace();
+		}
+		finally {
+			
+			try {
+				sendNotifications.deInit();
+			} catch (SQLException e) {
+				Log.write("[SYSTEM ERROR Scheduler.run] Could not close connection: " + e.getMessage());
+			}
+		}
+	} // run
+
+} // Scheduler