SY90SUN012-modification in logic & added cc part

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

webitm-sys/ibase/webitm/ejb/sys/DownloadCSVBatchBean.java

@@ -46,6 +46,7 @@ public class DownloadCSVBatchBean  implements Schedule
 			
 		String tranId = null;
 		String custCode = null;
+		String siteCode = null;
 		String emailAddr = null;
 		String uniformCode = null;
 		String dt = null;
@@ -141,7 +142,7 @@ public class DownloadCSVBatchBean  implements Schedule
 												
 						//start - select all the undownloaded invoice, if found, 
 						//then download for each.
-						sql =" SELECT IV.INVOICE_ID TRAN_ID, IV.CUST_CODE CUST_CODE, "
+						sql =" SELECT IV.INVOICE_ID TRAN_ID, IV.CUST_CODE CUST_CODE, IV.SITE_CODE SITE_CODE,"
 							+"		CU.EMAIL_ADDR EMAIL_ADDR, CU.UNIFORM_CODE UNIFORM_CODE, "
 							+"		TO_CHAR( IV.TRAN_DATE, 'DDMM' ) DT, IV.TRAN_DATE TRAN_DATE, "
 							+"		SC.INV_TRF_TYPE INV_TRF_TYPE, SC.INV_TRF_CYCLE INV_TRF_CYCLE "
@@ -176,6 +177,7 @@ public class DownloadCSVBatchBean  implements Schedule
 							retString =  null;
 							tranId = rs.getString( "TRAN_ID" );
 							custCode = rs.getString( "CUST_CODE" );
+							siteCode = rs.getString( "SITE_CODE" );
 							emailAddr = rs.getString( "EMAIL_ADDR" );
 							uniformCode = rs.getString( "UNIFORM_CODE" );
 							dt = rs.getString( "DT" );
@@ -239,35 +241,42 @@ public class DownloadCSVBatchBean  implements Schedule
 							
 							if(trfCycle != null && trfCycle.equalsIgnoreCase( "O" ))
 							{
-								pstmtSeq = conn.prepareStatement( " SELECT IV.INV_EXP_DATE "
-								+" FROM INVOICE IV, SITE_CUSTOMER SC "
-								+" WHERE IV.CUST_CODE__BIL = SC.CUST_CODE "
-								+" AND IV.SITE_CODE = SC.SITE_CODE AND IV.INV_EXP_DATE IS NOT NULL "
-								+" AND IV.TRAN_DATE BETWEEN  ? AND ? ");
-								
+								if("S".equalsIgnoreCase(trfType))
+								{
+									pstmtSeq = conn.prepareStatement( " SELECT IV.DOWNLOAD_FLAG "
+									+" FROM INVOICE IV, SITE_CUSTOMER SC "
+									+" WHERE IV.CUST_CODE__BIL = SC.CUST_CODE "
+									+" AND IV.SITE_CODE = SC.SITE_CODE "
+									+" AND IV.TRAN_DATE BETWEEN  ? AND ? "
+									+" AND IV.SITE_CODE = ? "
+									+" AND IV.CUST_CODE = ? " 
+									+" AND IV.DOWNLOAD_FLAG = 'Y' " );
+								}
+								else
+								{
+									pstmtSeq = conn.prepareStatement( " SELECT IV.INV_EXP_DATE "
+									+" FROM INVOICE IV, SITE_CUSTOMER SC "
+									+" WHERE IV.CUST_CODE__BIL = SC.CUST_CODE "
+									+" AND IV.SITE_CODE = SC.SITE_CODE AND IV.INV_EXP_DATE IS NOT NULL "
+									+" AND IV.TRAN_DATE BETWEEN  ? AND ? "
+									+"  AND IV.SITE_CODE = ? "
+									+" AND IV.CUST_CODE = ? " );
+								}
 								pstmtSeq.setTimestamp(1, fromDate);
 								pstmtSeq.setTimestamp(2, toDate);
+								pstmtSeq.setString(3, siteCode);
+								pstmtSeq.setString(4, custCode);
+								
 								rsSeq = pstmtSeq.executeQuery();
 								if( rsSeq.next() )
 								{
-									pstmtSeq2 = conn.prepareStatement( "UPDATE INVOICE SET "
-									+" DOWNLOAD_FLAG = 'Y' WHERE INVOICE_ID = ? " );
-									
-									pstmtSeq2.setString( 1, tranId );
-									int rowCnt = pstmtSeq2.executeUpdate();
-									if(rowCnt >= 1){
-										conn.commit();
-									}
-									else{
-										conn.rollback();
-									}
-									pstmtSeq2.close();
-									pstmtSeq2 = null;
+									updateFlag(tranId, conn);
+									System.out.println("Inside S & O already downloaded ");
 								}
 								else
 								{	
-									download(tranFileMip, downloadLoc);								
-									
+									download(tranFileMip, downloadLoc);
+																		
 									if(trfType != null && (trfType.equalsIgnoreCase( "B" ) || 
 									trfType.equalsIgnoreCase( "E" )))
 									{
@@ -281,6 +290,11 @@ public class DownloadCSVBatchBean  implements Schedule
 											deleteFile(filePath);
 										}
 									}
+									else if("S".equalsIgnoreCase(trfType))
+									{
+										updateFlag(tranId, conn);
+										System.out.println("Inside S & O ");
+									}
 								}
 								rsSeq.close();
 								rsSeq = null;
@@ -291,7 +305,7 @@ public class DownloadCSVBatchBean  implements Schedule
 							else if(trfCycle != null && trfCycle.equalsIgnoreCase( "A" ))
 							{							
 								download(tranFileMip, downloadLoc);
-						
+								
 								if(trfType != null && (trfType.equalsIgnoreCase( "B" ) || 
 								trfType.equalsIgnoreCase( "E" )))
 								{
@@ -304,7 +318,12 @@ public class DownloadCSVBatchBean  implements Schedule
 											deleteFile(filePath);
 									}
 								}
-														
+								else if("S".equalsIgnoreCase(trfType))
+								{
+									updateFlag(tranId, conn);
+									System.out.println("Inside S & A ");
+									
+								}						
 							}
 							//Changed by Sachin [update the Download_flag and INV_EXP_DATE after 
 							//each invoice files downloading]
@@ -359,6 +378,33 @@ public class DownloadCSVBatchBean  implements Schedule
 		}
 	}
 	
+	public void updateFlag(String tranId, Connection conn)throws RemoteException, ITMException
+	{
+		java.sql.PreparedStatement pstmtSeq2 = null;
+		try
+		{
+			pstmtSeq2 = conn.prepareStatement( "UPDATE INVOICE SET "
+			+" DOWNLOAD_FLAG = 'Y' WHERE INVOICE_ID = ? " );
+
+			pstmtSeq2.setString( 1, tranId );
+			int rowCnt = pstmtSeq2.executeUpdate();
+			if(rowCnt >= 1){
+				conn.commit();
+			}
+			else{
+				conn.rollback();
+			}
+			pstmtSeq2.close();
+			pstmtSeq2 = null;
+		}
+		catch (Exception e) 
+		{
+			System.out.println("Unable to updateFlag (" + e.getMessage() + ")");
+		}
+	}
+	
+	
+	
 	public void deleteFile( String filePath)throws RemoteException, ITMException
 	{
 		try 
@@ -398,7 +444,7 @@ public class DownloadCSVBatchBean  implements Schedule
 		String templDnld = null;
 		String csvData = null;
 		TranXmlData client = null;
-		java.sql.PreparedStatement pstmtSeq2 = null;
+
 		
 		ibase.webitm.utility.XML2CSVCustomConverter csvConverter = null;
 		csvConverter = new ibase.webitm.utility.XML2CSVCustomConverter();	
@@ -428,24 +474,12 @@ public class DownloadCSVBatchBean  implements Schedule
 				FileWriter fw = new FileWriter( downloadLoc + File.separator + dnldFileName + ".csv" );
 
 				fw.write( csvData );
-
 				fw.close();
 				fw = null;
-				pstmtSeq2 = conn.prepareStatement( "UPDATE INVOICE SET "
-				+" DOWNLOAD_FLAG = 'Y' WHERE INVOICE_ID = ? " );
-				
-				pstmtSeq2.setString( 1, tranId );
-				int rowCnt = pstmtSeq2.executeUpdate();
-				if(rowCnt >= 1){
-					conn.commit();
-				}
-				else{
-					conn.rollback();
-				}
-				pstmtSeq2.close();
-				pstmtSeq2 = null;
 				conn.close();
 				conn = null;
+				
+				System.out.println("Inside download ");
 			}
 			catch( Exception ex )
 			{
@@ -461,17 +495,19 @@ public class DownloadCSVBatchBean  implements Schedule
 		String retString = "";
 		String to = "";
 		String from = "";
+		String cc = "";
 		boolean debug = false;
 		String subject = "",text = "";
 		String xmlDataFilePath = "";
-
+		java.sql.PreparedStatement pstmtSeq2 = null;
+		java.sql.ResultSet rsSeq = null; 
 		
 		try 
 		{
 			Properties props = System.getProperties();
 			props.put("mail.smtp.host", CommonConstants.SMTPHOST);		  
 			Authenticator auth = null;
-			
+			 
 			Session session= Session.getDefaultInstance(props,auth);
 			session.setDebug(debug);
 			MimeMessage msg = new MimeMessage(session);
@@ -479,6 +515,20 @@ public class DownloadCSVBatchBean  implements Schedule
 			MimeBodyPart mbp2 = new MimeBodyPart();
 			Multipart mp = new MimeMultipart();
 			
+			pstmtSeq2 = conn.prepareStatement( "SELECT VAR_VALUE FROM DISPARM "
+			+" WHERE VAR_NAME = 'MAIL_CC' " );
+
+			rsSeq = pstmtSeq2.executeQuery();
+			if( rsSeq.next() )
+			{
+				cc = rsSeq.getString( "VAR_VALUE" );
+				System.out.println("cc =="+ cc);
+			}
+			rsSeq.close();
+			rsSeq = null;
+			pstmtSeq2.close();
+			pstmtSeq2 = null;
+			
 			from = CommonConstants.MAILFROM;
 			to = (String)hMap.get("TO_ADDR");
 			
@@ -487,6 +537,7 @@ public class DownloadCSVBatchBean  implements Schedule
 			xmlDataFilePath = (String)hMap.get("FILEPATH");
 			
 			InternetAddress[] address = {new InternetAddress(to)};
+			
 			mbp1.setText(text);				
 			mp.addBodyPart(mbp1);
 			
@@ -506,6 +557,10 @@ public class DownloadCSVBatchBean  implements Schedule
 			mp.addBodyPart(mbp2);
 			
 			msg.setRecipients(Message.RecipientType.TO, address);
+			if(cc != null && cc.trim().length() > 0){
+				InternetAddress[] ccAddress = {new InternetAddress(cc)};
+				msg.setRecipients(Message.RecipientType.CC, ccAddress);
+			}
 			msg.setSubject(subject);						
 			msg.setFrom(new InternetAddress(from));	
 			msg.setContent(mp);