git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@209438 ce508802-f39f-4f6c-b175-0d175dae99d5

webitm-dashboard/ibase/dashboard/common/hibernate/dao/CourseDAO.java

@@ -827,6 +827,7 @@ public class CourseDAO
 			updCourseData.put("courseStatus", "C");
 			updateCourseAttend(courseCode, updCourseData.toString());
             sendEmail(courseCode, tranDB);
+            sendCertificate(courseCode, tranDB);
 		} 
 		catch (HibernateException e) 
 		{
@@ -1245,4 +1246,122 @@ public class CourseDAO
 		}
 		return bodyTextData;	
 	}
+	
+	private String sendCertificate( String courseCode , String transDB) throws Exception 
+	{
+		String retString = "Success";
+		EMail email = new EMail();
+		String to = "";
+		String cc = "";
+		String bcc = "";
+		String sub = "";
+		String body = "";
+		String emailId = "";
+		String copyToEmailId = "";
+		
+		Connection userConn = null;
+		java.sql.PreparedStatement pstmt = null;
+		ResultSet rs = null;
+
+		try
+		{
+			JSONObject courseObj = getCourse(courseCode).toJson();
+			BaseLogger.log("3",null,null,"Sending email for "+courseObj+" course.");
+			
+			if(courseObj == null)
+			{
+				return "Send Certificate Fail.";
+			}
+			else {
+				String imgUrl=CommonConstants.TOMCAT_HOME +"/ibase/images/logo_servgyan.png";
+				courseObj.put("imgUrl", imgUrl);
+			}
+			
+			ConnDriver connDriver = new ConnDriver();
+			//conn = connDriver.getConnectDB("Driver");
+			userConn = connDriver.getConnectDB( transDB );
+			String userSql = "SELECT SEND_TO,COPY_TO,BLIND_COPY,SUBJECT,BODY_TEXT FROM MAIL_FORMAT WHERE FORMAT_CODE = ? ";
+
+			pstmt = userConn.prepareStatement(userSql);
+			pstmt.setString(1, "COURSE_CERTIFICATE");
+			rs = pstmt.executeQuery();
+			if(rs.next())
+			{
+				to = rs.getString("SEND_TO");
+				cc = rs.getString("COPY_TO");
+				bcc = rs.getString("BLIND_COPY");
+				sub = rs.getString("SUBJECT");
+				body = rs.getString("BODY_TEXT");
+			}
+
+			pstmt.close();
+			rs.close();
+			userConn.close();
+
+			if( "user_id__attend".equalsIgnoreCase( to ))
+			{
+				emailId = this.userInfo.getEmailIdOff();
+				courseObj.put("userName", this.userInfo.getUserName());
+			}
+			else
+			{
+				emailId = to;
+			}
+			if( "user_id__admin".equalsIgnoreCase( cc ))
+			{
+				String chgUser = courseObj.optString("chgUser");
+				copyToEmailId = checkNull(getAdminEmailID(chgUser, transDB));
+			}
+			else
+			{
+				copyToEmailId = cc;
+			}
+
+			
+			BaseLogger.log("3",null,null,"transDB:"+transDB);
+			StringBuilder mailXmlData = new StringBuilder("<root>");
+			mailXmlData.append("<TO_ADD><![CDATA["+emailId+"]]></TO_ADD>");
+			if(cc != null && cc.trim().length() > 0)
+			{
+				mailXmlData.append("<CC_ADD><![CDATA["+copyToEmailId+"]]></CC_ADD>");
+			}
+			if(cc != null && cc.trim().length() > 0)
+			{
+				mailXmlData.append("<BCC_ADD><![CDATA["+bcc+"]]></BCC_ADD>");
+			}
+			mailXmlData.append("<SUBJECT><![CDATA["+sub+"]]></SUBJECT>");
+			mailXmlData.append("<MESSAGE><![CDATA["+getFormatedEmailBody(body, courseObj )+"]]></MESSAGE>");
+			mailXmlData.append("<MESSAGE_TYPE><![CDATA[text/html]]></MESSAGE_TYPE>");
+			mailXmlData.append("<EMAIL_TYPE><![CDATA[page]]></EMAIL_TYPE>");
+			mailXmlData.append("</root>");
+			String result = email.sendMail(mailXmlData.toString(), null);
+			BaseLogger.log("3",null,null,"Send Email :mailXmlData:" + mailXmlData);
+			BaseLogger.log("3",null,null, result);
+			
+		}
+		catch ( Exception e )
+		{
+			throw new Exception(e) ;
+		}
+		finally
+		{
+			if (pstmt != null )
+			{
+				try 
+				{
+					if(userConn != null)
+						userConn.close();
+					if(pstmt != null)
+						pstmt.close();
+					if(rs != null)
+						rs.close();
+				} catch (SQLException e) {
+
+				}
+
+			}
+		}
+		return retString;
+	}
+
 }

webitm-dashboard/ibase/dashboard/common/hibernate/dao/UserHistoryDAO.java

@@ -16,7 +16,7 @@ import java.util.concurrent.TimeUnit;
 
 import javax.rmi.CORBA.UtilDelegate;
 
-import org.apache.poi.util.SystemOutLogger;
+//import org.apache.poi.util.SystemOutLogger;
 import org.json.JSONArray;
 import org.json.JSONException;
 import org.json.JSONObject;