Skip to content

I
ibase-webitm-ejb-sc
Commit fdd0228e authored by Ketan Patil's avatar Ketan Patil
Browse files
Options

Replace SFAMonthlyReport.java

parent 3ddb8003
Hide whitespace changes
Inline Side-by-side
Showing with 829 additions and 531 deletions
ibase/webitm/ejb/sc/SFAMonthlyReport.java
View file @ fdd0228e
/* */ package ibase.webitm.ejb.sc; package ibase.webitm.ejb.sc;
/* */ /**
/* */ import ibase.scheduler.utility.interfaces.Schedule; * Author :- Amit Shrivastava
/* */ import ibase.system.config.ConnDriver; * Component :- SFAMonthlyReport.java
/* */ import ibase.utility.CommonConstants; * Req Id:- [F16GSUN003]
/* */ import ibase.utility.E12GenericUtility; * Date [27/feb/20]
/* */ import ibase.utility.UserInfoBean; * */
/* */ import ibase.webitm.ejb.DBAccessEJB;
/* */ import ibase.webitm.ejb.ITMDBAccessEJB; import ibase.scheduler.utility.interfaces.Schedule;
import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.DBAccessEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.dis.DistCommon; import ibase.webitm.ejb.dis.DistCommon;
/* */ import ibase.webitm.utility.ITMException;
/* */ import java.io.File;
/* */ import java.io.FileNotFoundException;
/* */ import java.io.FileWriter;
/* */ import java.io.IOException;
/* */ import java.io.PrintStream;
/* */ import java.io.PrintWriter;
/* */ import java.sql.Connection;
/* */ import java.sql.PreparedStatement;
/* */ import java.sql.ResultSet;
/* */ import java.sql.ResultSetMetaData;
/* */ import java.sql.SQLException;
/* */ import java.sql.Statement;
/* */ import java.sql.Timestamp;
/* */ import java.text.SimpleDateFormat;
/* */ import java.util.ArrayList;
/* */ import java.util.Calendar;
/* */ import java.util.Date;
/* */ import java.util.HashMap;
/* */
/* */ public class SFAMonthlyReport
/* */ implements Schedule
/* */ {
/* 43 */ String userInfoXml = "";
/* */
/* 49 */ E12GenericUtility genericUtility = new E12GenericUtility();
/* 50 */ ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
/* */
/* */ public String schedule(HashMap arg0)
/* */ throws Exception
/* */ {
/* 55 */ return null;
/* */ }
/* */
/* */ public String schedule(String scheduleParamXML)
/* */ throws Exception
/* */ {
/* 61 */ ConnDriver connDriver = new ConnDriver();
/* 62 */ Connection conn = null;
/* 63 */ PreparedStatement pstmt = null; PreparedStatement pstmt1 = null;
/* 64 */ ResultSet rs = null;
/* */
/* 67 */ int fileNameCount = 0; String sqlExpr = ""; String sqlExpr1 = ""; String sqlExpr2 = ""; String sqlExpr3 = ""; String sqlExpr4 = ""; String sqlExpr5 = ""; String sqlExpr6 = ""; String objtNames = ""; String compSql = "";
/* 68 */ String siteCodeStrSale = "";
/* */ try
/* */ {
/* 71 */ System.out.println("Before userInfoXml:::[" + this.userInfoXml + "]" + "Before scheduleParamXML>> " + scheduleParamXML);
/* 72 */ this.userInfoXml = scheduleParamXML;
/* 73 */ System.out.println("userInfoXml:::[" + this.userInfoXml + "]" + "scheduleParamXML>> " + scheduleParamXML);
/* 74 */ UserInfoBean userInfo = new UserInfoBean(this.userInfoXml);
/* 75 */ System.out.println("userInfo > Amit > " + userInfo);
/* 76 */ String transDB = userInfo.getTransDB();
/* 77 */ System.out.println("get TransDB connection in updateStatus : " + transDB);
/* 78 */ if ((transDB != null) && (transDB.trim().length() > 0))
/* */ {
/* 80 */ conn = connDriver.getConnectDB(transDB);
/* */ }
/* */ else
/* */ {
/* 84 */ conn = connDriver.getConnectDB("DriverITM");
/* */ }
/* */
/* 102 */ System.out.println("@V@ In schedule method");
/* */
/* 106 */ System.out.println("@V@ In schedule method");
/* */
/* 112 */ String fldValue = ""; String fldValue1 = ""; String fldValue2 = "";
/* */
/* 117 */ ArrayList al = new ArrayList();
/* 118 */ ArrayList bl = new ArrayList();
/* */
/* 120 */ String query = "SELECT count(*) FROM GENCODES where FLD_NAME='SFARP' and MOD_NAME='SFAREPORT' ";
/* */
/* 122 */ pstmt = conn.prepareStatement(query);
/* 123 */ rs = pstmt.executeQuery();
/* 124 */ int FCounter = 0;
/* 125 */ if (rs.next())
/* */ {
/* 127 */ fileNameCount = rs.getInt(1);
/* */ }
/* 129 */ rs.close();
/* 130 */ pstmt.close();
/* */
/* 132 */ System.out.println("@V@ Count is =>[" + fileNameCount + "]<=Getting files @V@");
/* */
/* 134 */ String[] fileNames = new String[fileNameCount];
/* */
/* 136 */ query = "SELECT fld_value, descr FROM GENCODES where FLD_NAME='SFARP' and MOD_NAME='SFAREPORT' order by to_number(fld_value)";
/* 137 */ pstmt = conn.prepareStatement(query);
/* 138 */ rs = pstmt.executeQuery();
/* */
/* 140 */ while (rs.next())
/* */ {
/* 142 */ fileNameCount = rs.getInt(1);
/* 143 */ fileNames[FCounter] = rs.getString(2);
/* 144 */ System.out.println("@V@ File no [" + FCounter + "] = [" + fileNames[FCounter] + "]");
/* 145 */ FCounter++;
/* */ }
/* 147 */ fileNameCount = fileNames.length;
/* 148 */ System.out.println("@V@ Final Count of Files:- [" + fileNameCount + "]");
/* 149 */ System.out.println("@V@ Final Name of Files:- [" + fileNames[1] + "]");
/* 150 */ pstmt.close();
/* 151 */ rs.close();
/* */
/* 173 */ for (int i = 1; i <= fileNameCount; i++)
/* */ {
/* 178 */ String sql = "select sql_expr,sql_input,sql_expr1,sql_expr2,sql_expr3,sql_expr4,sql_expr5,sql_expr6 from TAX_BAL_GRP_DET where BAL_GROUP='SFARP' and to_number(LINE_NO)=" + i +
/* 179 */ " order by to_number(line_no)";
/* 180 */ pstmt = conn.prepareStatement(sql);
/* */
/* 182 */ rs = pstmt.executeQuery();
/* 183 */ if (!rs.next()) {
/* */ continue;
/* */ }
/* 186 */ sqlExpr = checkNull(rs.getString("sql_expr"));
/* 187 */ sqlExpr1 = checkNull(rs.getString("sql_expr1"));
/* 188 */ sqlExpr2 = checkNull(rs.getString("sql_expr2"));
/* 189 */ sqlExpr3 = checkNull(rs.getString("sql_expr3"));
/* 190 */ sqlExpr4 = checkNull(rs.getString("sql_expr4"));
/* 191 */ sqlExpr5 = checkNull(rs.getString("sql_expr5"));
/* 192 */ sqlExpr6 = checkNull(rs.getString("sql_expr6"));
/* 193 */ objtNames = checkNull(rs.getString("sql_input"));
/* */
/* 195 */ compSql = sqlExpr + " " + sqlExpr1 + " " + sqlExpr2 + " " + sqlExpr3 + " " + sqlExpr4 + " " + sqlExpr5 + " " +
/* 196 */ sqlExpr6;
/* 197 */ System.out.println("Combine SQL::::" + compSql);
/* */
/* 199 */ System.out.println("inside execute dynamically Sql ");
/* */
/* 201 */ processQuery(compSql, fileNames[(i - 1)], conn);
/* */ }
/* */
/* */ }
/* */ catch (Exception ee)
/* */ {
/* 208 */ System.out.println("@ Amit>> Error in [SFADailyReport.java]=>" + ee);
/* 209 */ ee.printStackTrace();
/* */ }
/* */ finally
/* */ {
/* 214 */ if ((conn != null) && (rs != null) && (pstmt1 != null))
/* */ {
/* 216 */ conn.close();
/* 217 */ rs.close();
/* 218 */ pstmt.close();
/* */ }
/* */ }
/* */
/* 222 */ return "";
/* */ }
/* */
/* */ String changeType(Object obj)
/* */ {
/* 450 */ String retString = null;
/* 451 */ String dataType = obj.getClass().getSimpleName();
/* 452 */ System.out.println("@V@ obj Format: " + dataType);
/* 453 */ if (obj.getClass().getSimpleName() == "Date")
/* */ {
/* 455 */ // GenericUtility genericUtility = new GenericUtility();
/* */ try
/* */ {
/* 459 */ String dispalyDateFormat = genericUtility.getDispDateFormat();
/* 460 */ SimpleDateFormat sdf = new SimpleDateFormat(dispalyDateFormat);
/* 461 */ retString = sdf.format(obj);
/* */ }
/* */ catch (ITMException e)
/* */ {
/* 466 */ e.printStackTrace();
/* */ }
/* */ catch (Exception e)
/* */ {
/* 471 */ e.printStackTrace();
/* */ }
/* */ }
/* */ else
/* */ {
/* 476 */ retString = obj.toString();
/* */ }
/* 478 */ return retString;
/* */ }
/* */
/* */ public String schedulePriority(String arg0)
/* */ throws Exception
/* */ {
/* 484 */ return null;
/* */ }
/* */
/* */ private String checkNull(String input)
/* */ {
/* 489 */ if (input == null) {
/* 490 */ input = "";
/* */ }
/* 492 */ return input.trim();
/* */ }
/* */
/* */ public void printLogFile(String title, String msg, String fileName, Connection conn)
/* */ {
/* 498 */ String logFile = "";
/* 499 */ String logDir = "";
/* 500 */ File logFileDir = null;
/* 501 */ FileWriter fileWriter = null;
/* 502 */ String currTime = null;
/* 503 */ Calendar calendar = Calendar.getInstance();
/* 504 */ String filePath = "";
/* 505 */ E12GenericUtility genericUtility = new E12GenericUtility();
/* */ try
/* */ {
/* 508 */ SFAMonthlyReport sfa = new SFAMonthlyReport();
/* 509 */ String logFileName = "";
/* */
/* 511 */ SimpleDateFormat sdf1 = new SimpleDateFormat(genericUtility.getDBDateFormat());
/* 512 */ currTime = sdf1.format(new Timestamp(System.currentTimeMillis())).toString();
/* 513 */ currTime = currTime.replaceAll("-", "");
/* 514 */ calendar.setTime(new Timestamp(System.currentTimeMillis()));
/* 515 */ fileName = fileName + currTime + calendar.get(10) + calendar.get(12);
/* */
/* 517 */ logFileName = fileName;
/* 518 */ DistCommon disCom = new DistCommon();
/* 519 */ filePath = sfa.getDisparamsServerLog("999999", "MONTHREPORT_LOG", conn);
/* 520 */ System.out.println(" Sfa logFileName >> " + filePath);
/* */
/* 522 */ logDir = filePath;
/* 523 */ System.out.println("logDir >> " + logDir);
/* 524 */ logFileDir = new File(logDir);
/* */
/* 526 */ if (!logFileDir.exists())
/* */ {
/* 528 */ logFileDir.mkdirs();
/* */ }
/* */
/* 531 */ logFile = logDir + File.separator + logFileName + ".log";
/* */
/* 533 */ SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd HH:mm");
/* 534 */ Date now = new Date();
/* 535 */ String strDate = sdfDate.format(now);
/* */
/* 537 */ fileWriter = new FileWriter(logFile, true);
/* */
/* 539 */ fileWriter.write("\r\n");
/* 540 */ fileWriter.write(strDate + " " + "INFO" + " " + "[" + title + "] : " + msg);
/* */ }
/* */ catch (Exception ex)
/* */ {
/* 544 */ ex.printStackTrace();
/* */ try
/* */ {
/* 552 */ if (fileWriter != null)
/* */ {
/* 554 */ fileWriter.flush();
/* 555 */ fileWriter.close();
/* */ }
/* */ }
/* */ catch (Exception e)
/* */ {
/* 560 */ e.printStackTrace();
/* */ }
/* */ }
/* */ finally
/* */ {
/* */ try
/* */ {
/* 552 */ if (fileWriter != null)
/* */ {
/* 554 */ fileWriter.flush();
/* 555 */ fileWriter.close();
/* */ }
/* */ }
/* */ catch (Exception e)
/* */ {
/* 560 */ e.printStackTrace();
/* */ }
/* */ }
/* */ }
/* */
/* */ public String getUserInfo(String xtraParams)
/* */ throws ITMException
/* */ {
/* 569 */ StringBuffer userInfoStr = new StringBuffer();
/* 570 */ String userId = "";
/* 571 */ String loginEmpCode = "";
/* 572 */ String loginSiteCode = "";
/* 573 */ String entityCode = "";
/* 574 */ String profileId = "";
/* 575 */ String userType = "";
/* 576 */ String charEnc = "";
/* 577 */ String chgTerm = "";
/* 578 */ String transDb = "";
/* 579 */ String sql = "";
/* */
/* 581 */ PreparedStatement pstmt = null;
/* 582 */ ResultSet rs = null;
/* 583 */ Connection conn = null;
/* */ try
/* */ {
/* 586 */ //GenericUtility genericUtility = GenericUtility.getInstance();
/* 587 */ userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
/* 588 */ loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
/* 589 */ loginSiteCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
/* 590 */ entityCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "entityCode");
/* 591 */ profileId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "profileId");
/* 592 */ userType = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "userType");
/* */
/* 594 */ charEnc = CommonConstants.ENCODING;
/* 595 */ System.out.println("charEnc......" + charEnc);
/* */
/* 597 */ chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chgTerm");
/* 598 */ UserInfoBean userInfo = new UserInfoBean();
/* 599 */ DBAccessEJB dbAccessEJB = new DBAccessEJB();
/* 600 */ userInfo = dbAccessEJB.createUserInfo(userId);
/* 601 */ transDb = userInfo.getTransDB();
/* 602 */ System.out.println("transDb::::@@@ " + transDb);
/* */
/* 604 */ userInfoStr.append("<UserInfo>");
/* 605 */ userInfoStr.append("<loginCode>").append("<![CDATA[" + userId + "]]>").append("</loginCode>\r\n");
/* 606 */ userInfoStr.append("<empCode>").append("<![CDATA[" + loginEmpCode + "]]>").append("</empCode>\r\n");
/* 607 */ userInfoStr.append("<siteCode>").append("<![CDATA[" + loginSiteCode + "]]>").append("</siteCode>\r\n");
/* 608 */ userInfoStr.append("<entityCode>").append("<![CDATA[" + entityCode + "]]>").append("</entityCode>\r\n");
/* 609 */ userInfoStr.append("<profileId>").append("<![CDATA[" + profileId + "]]>").append("</profileId>\r\n");
/* 610 */ userInfoStr.append("<userType>").append("<![CDATA[" + userType + "]]>").append("</userType>\r\n");
/* 611 */ userInfoStr.append("<charEnc>").append("<![CDATA[" + charEnc + "]]>").append("</charEnc>\r\n");
/* 612 */ userInfoStr.append("<remoteHost>").append("<![CDATA[" + chgTerm + "]]>").append("</remoteHost>\r\n");
/* 613 */ userInfoStr.append("<transDB>").append("<![CDATA[" + transDb + "]]>").append("</transDB>\r\n");
/* */
/* 615 */ userInfoStr.append("</UserInfo>");
/* */ }
/* */ catch (Exception e)
/* */ {
/* 619 */ throw new ITMException(e);
/* */ }
/* 621 */ return userInfoStr.toString();
/* */ }
/* */
/* */ public String getDisparamsServerLog(String prdCode, String varName, Connection conn)
/* */ {
/* 655 */ String retVal = null;
/* 656 */ String sql = null;
/* 657 */ ResultSet rs = null;
/* 658 */ Statement stmt = null;
/* */ try {
/* 660 */ System.out
/* 661 */ .println("Finding the variable value from Disparam for parameters[" +
/* 662 */ prdCode + "," + varName + "]");
/* 663 */ stmt = conn.createStatement();
/* 664 */ sql = "SELECT VAR_VALUE FROM DISPARM WHERE PRD_CODE ='" + prdCode +
/* 665 */ "' AND VAR_NAME ='" + varName + "'";
/* 666 */ rs = stmt.executeQuery(sql);
/* 667 */ if (rs.next())
/* 668 */ retVal = rs.getString(1) == null ? " " : rs.getString(1);
/* */ else {
/* 670 */ retVal = "NULLFOUND";
/* */ }
/* 672 */ rs.close();
/* 673 */ stmt.close();
/* 674 */ rs = null;
/* 675 */ stmt = null;
/* */ } catch (Exception e) {
/* 677 */ e.printStackTrace();
/* */ }
/* 679 */ return retVal;
/* */ }
/* */
/* */ public void processQuery(String query1, String fileName, Connection conn)
/* */ {
/* 685 */ PreparedStatement pstmt = null;
/* 686 */ PrintWriter pw = null;
/* */
/* 688 */ PreparedStatement pstmt1 = null;
/* 689 */ String currTime = null;
/* 690 */ SimpleDateFormat sdf1 = null;
/* */ try
/* */ {
/* */ try
/* */ {
/* 695 */ sdf1 = new SimpleDateFormat(this.genericUtility.getDBDateFormat());
/* */ }
/* */ catch (ITMException e) {
/* 698 */ e.printStackTrace();
/* */ }
/* */ catch (Exception e) {
/* 701 */ e.printStackTrace();
/* */ }
/* */
/* 704 */ System.out.println("@V@ Before Query1 Executed");
/* 705 */ System.out.println("@V@ query1:- [" + query1 + "]");
/* 706 */ System.out.println("@V@ fileName:- [" + fileName + "]");
/* */
/* 711 */ currTime = sdf1.format(new Timestamp(System.currentTimeMillis())).toString();
/* 712 */ currTime = currTime.replaceAll("-", "");
/* 713 */ String logFileName = "SFA_Monthely_Report_" + currTime + "_";
/* 714 */ pstmt = conn.prepareStatement(query1);
/* */
/* 718 */ ResultSet rs = pstmt.executeQuery();
/* 719 */ System.out.println("@V@ Query Executed");
/* 720 */ System.out.println("rs row==>" + rs.getRow());
/* 721 */ System.out.println("@V@ Query Executed");
/* */
/* 726 */ fileName = fileName + "_" + new SimpleDateFormat("ddMMyyyyhhmm").format(new Date());
/* 727 */ DistCommon disCom = new DistCommon();
/* 728 */ String jbossHome = disCom.getDisparams("999999", "MONTHLY_REPORT_", conn);
/* 729 */ System.out.println("jbossHome File Path >> " + jbossHome);
/* 730 */ File filDir = new File(jbossHome);
/* 731 */ if (!filDir.exists())
/* */ {
/* 733 */ System.out.println("@V@ Folder not found In IF");
/* 734 */ filDir.mkdir();
/* */ }
/* */ else
/* */ {
/* 738 */ System.out.println("@V@ Folder found In ELSE");
/* */ }
/* */
/* 742 */ pw = new PrintWriter(jbossHome + File.separator + fileName + ".csv");
/* 743 */ ResultSetMetaData rsmd = rs.getMetaData();
/* 744 */ int columnsNumber = rsmd.getColumnCount();
/* 745 */ System.out.println("@V@ ColumnCount: " + columnsNumber);
/* */
/* 747 */ String sql = "select var_value from finparm where var_name='SSCDAILY_SEP'";
/* 748 */ pstmt1 = conn.prepareStatement(sql);
/* 749 */ ResultSet rs2 = pstmt1.executeQuery();
/* 750 */ String seperator = ",";
/* 751 */ if (rs2.next())
/* */ {
/* 753 */ seperator = rs2.getString("var_value");
/* */ }
/* */
/* 757 */ StringBuilder sb1 = new StringBuilder();
/* 758 */ for (int i = 1; i <= columnsNumber; i++)
/* */ {
/* 760 */ sb1.append("\t" + rsmd.getColumnName(i) + seperator.trim() + "\t");
/* */ }
/* */
/* 763 */ pw.println(sb1.substring(0, sb1.length() - 1));
/* */
/* 766 */ while (rs.next())
/* */ {
/* 769 */ StringBuilder sb = new StringBuilder();
/* 770 */ for (int i = 1; i <= columnsNumber; i++)
/* */ {
/* 773 */ String str = rs.getString(i);
/* */
/* 777 */ str = str.replaceAll("\n", " ");
/* 778 */ str = str.replaceAll("\r", " ");
/* 779 */ str = str.replaceAll("\t", " ");
/* */
/* 781 */ sb.append(str.trim() + seperator.trim());
/* */ }
/* */
/* 784 */ System.out.println("@V@ StringBuider: " + sb);
/* */
/* 786 */ pw.println(sb.substring(0, sb.length() - 1));
/* */ }
/* 788 */ System.out.println("@V@ File Generated");
/* 789 */ pw.flush();
/* 790 */ pw.close();
/* 791 */ SFACSVToExcelConverter csv = new SFACSVToExcelConverter();
/* 792 */ System.out.println("@V@ file name before EXCEL conversion :- [" + fileName + "]");
/* */
/* 794 */ csv.convertMonthlyReport(fileName, seperator.trim(), logFileName, conn);
/* */
/* 797 */ printLogFile("STDOUT", "File Not Generated Because Division Not Found For :: <" + fileName + ">", logFileName, conn);
/* */ }
/* */ catch (SQLException e)
/* */ {
/* 802 */ e.printStackTrace();
/* */ try
/* */ {
/* 818 */ pw.flush();
/* 819 */ pw.close();
/* 820 */ pstmt.close();
/* */ }
/* */ catch (SQLException e1)
/* */ {
/* 825 */ e1.printStackTrace();
/* */ }
/* */ }
/* */ catch (FileNotFoundException e)
/* */ {
/* 807 */ e.printStackTrace();
/* */ try
/* */ {
/* 818 */ pw.flush();
/* 819 */ pw.close();
/* 820 */ pstmt.close();
/* */ }
/* */ catch (SQLException e1)
/* */ {
/* 825 */ e1.printStackTrace();
/* */ }
/* */ }
/* */ catch (IOException e)
/* */ {
/* 812 */ e.printStackTrace();
/* */ try
/* */ {
/* 818 */ pw.flush();
/* 819 */ pw.close();
/* 820 */ pstmt.close();
/* */ }
/* */ catch (SQLException e1)
/* */ {
/* 825 */ e1.printStackTrace();
/* */ }
/* */ }
/* */ finally
/* */ {
/* */ try
/* */ {
/* 818 */ pw.flush();
/* 819 */ pw.close();
/* 820 */ pstmt.close();
/* */ }
/* */ catch (SQLException e)
/* */ {
/* 825 */ e.printStackTrace();
/* */ }
/* */ }
/* */ }
/* */ }
/* Location: C:\Users\pravin.nevage\Desktop\ibase3-webitm-sc2-0-1-5.jar import ibase.webitm.utility.ITMException;
* Qualified Name: ibase.webitm.ejb.sc.SFAMonthlyReport
* JD-Core Version: 0.6.0 import java.io.File;
*/ import java.io.FileNotFoundException;
\ No newline at end of file import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import com.itextpdf.text.log.SysoCounter;
import ibase.utility.UserInfoBean;
public class SFAMonthlyReport implements Schedule
{
String userInfoXml = "";
/* public static void main(String[] args) {
// TODO Auto-generated method stub
}*/
E12GenericUtility genericUtility = new E12GenericUtility();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
@Override
public String schedule(HashMap arg0) throws Exception
{
// TODO Auto-generated method stub
return null;
}
@Override
public String schedule(String scheduleParamXML) throws Exception
{
ConnDriver connDriver = new ConnDriver();
Connection conn = null;
PreparedStatement pstmt = null,pstmt1=null;
ResultSet rs=null;
int fileNameCount = 0;String sqlExpr = "", sqlExpr1 = "", sqlExpr2 = "", sqlExpr3 = "", sqlExpr4 = "", sqlExpr5 = "", sqlExpr6 = "",objtNames="",compSql="";
String siteCodeStrSale="";
try
{
System.out.println("Before userInfoXml:::[" + this.userInfoXml + "]"+"Before scheduleParamXML>> "+scheduleParamXML);
this.userInfoXml = scheduleParamXML;
System.out.println("userInfoXml:::[" + this.userInfoXml + "]"+"scheduleParamXML>> "+scheduleParamXML);
UserInfoBean userInfo = new UserInfoBean(this.userInfoXml);
System.out.println("userInfo > Amit > " +userInfo);
String transDB = userInfo.getTransDB();
System.out.println("get TransDB connection in updateStatus : " + transDB);
if ((transDB != null) && (transDB.trim().length() > 0))
{
conn = connDriver.getConnectDB(transDB);
}
else
{
conn = connDriver.getConnectDB("DriverITM");
}
/*String loginCode=getValueFromXTRAPARAMS(xtraparams);
UserInfoBean userInfo = new UserInfoBean();
DBAccessEJB dbAccessEJB = new DBAccessEJB();
userInfo = dbAccessEJB.createUserInfo(loginCode);
transDb = userInfo.getTransDB();*/
/*System.out.println("transDb::::@@@ " + scheduleParamXML);
if ((scheduleParamXML != null) && (scheduleParamXML.trim().length() > 0))
{
conn = connDriver.getConnectDB(scheduleParamXML);
}
else
{
conn = connDriver.getConnectDB("DriverITM");
}*/
System.out.println("@V@ In schedule method");
// conn = connDriver.getConnectDB("DriverITM");
// System.out.println("@V@ In schedule method");
String query ;
System.out.println("@V@ In schedule method");
String fldValue="",fldValue1="",fldValue2="";
/*[START] SANKET GIRME [19-Apr-2016]
* To get the dynamically file names and count of the files.
* */
ArrayList<String> al =new ArrayList<String>();
ArrayList<String> bl =new ArrayList<String>();
query = "SELECT count(*) FROM GENCODES where FLD_NAME='SFARP' and MOD_NAME='SFAREPORT' ";
//query = "SELECT fld_value,descr FROM GENCODES where FLD_NAME='SFARS' and MOD_NAME='W_D_GIFT_DISTRIBUTION_DATA_NEW' ";
pstmt = conn.prepareStatement(query);
rs = pstmt.executeQuery();
int FCounter = 0;
if(rs.next())
{
fileNameCount = rs.getInt(1);
}
rs.close();
pstmt.close();
System.out.println("@V@ Count is =>["+fileNameCount+"]<=Getting files @V@");
String[] fileNames = new String[fileNameCount] ;
query = "SELECT fld_value, descr FROM GENCODES where FLD_NAME='SFARP' and MOD_NAME='SFAREPORT' order by to_number(fld_value)";// change SSCGRP -> SSCGRP1
pstmt = conn.prepareStatement(query);
rs = pstmt.executeQuery();
while(rs.next())
{
fileNameCount = rs.getInt(1);
fileNames[FCounter] = rs.getString(2); ;
System.out.println("@V@ File no ["+FCounter+"] = ["+fileNames[FCounter]+"]");
FCounter++;
}
fileNameCount = fileNames.length;
System.out.println("@V@ Final Count of Files:- ["+fileNameCount+"]");
System.out.println("@V@ Final Name of Files:- ["+fileNames[1]+"]");
pstmt.close();
rs.close();
//String[] fileNames = new String[fileNameCount] ;
// query = "SELECT fld_value, descr FROM GENCODES where FLD_NAME='SSC' and MOD_NAME='SSCGRP' order by to_number(fld_value) ";// change SSCGRP -> SSCGRP1
/*query = "SELECT fld_value, descr FROM GENCODES where FLD_NAME='SFA' and MOD_NAME='SFAGRP1'";// change SSCGRP -> SSCGRP1
pstmt = conn.prepareStatement(query);
rs = pstmt.executeQuery();
while(rs.next())
{
fileNameCount = rs.getInt(1);
fileNames[FCounter] = rs.getString(2); ;
System.out.println("@V@ File no ["+FCounter+"] = ["+fileNames[FCounter]+"]");
FCounter++;
}
System.out.println("@V@ Final Count of Files:- ["+fileNameCount+"]");
System.out.println("@V@ Final Name of Files:- ["+fileNames[1]+"]");
pstmt.close();
rs.close();*/
for(int i=1;i<=fileNameCount;i++)
{
/*String sql = "select line_no,sql_expr,sql_input,sql_expr1,sql_expr2,sql_expr3,sql_expr4,"
+ " sql_expr5,sql_expr6 from tax_bal_grp_det where bal_group=? ";*/
String sql = "select sql_expr,sql_input,sql_expr1,sql_expr2,sql_expr3,sql_expr4,sql_expr5,sql_expr6 from TAX_BAL_GRP_DET where BAL_GROUP='SFARP' and to_number(LINE_NO)="+i+"" + // change SSCRP -> SSCRP1
" order by to_number(line_no)";
pstmt = conn.prepareStatement(sql);
//pstmt.setString(1, "SFARP");
rs = pstmt.executeQuery();
if (rs.next())
{
sqlExpr = checkNull(rs.getString("sql_expr"));
sqlExpr1 = checkNull(rs.getString("sql_expr1"));
sqlExpr2 = checkNull(rs.getString("sql_expr2"));
sqlExpr3 = checkNull(rs.getString("sql_expr3"));
sqlExpr4 = checkNull(rs.getString("sql_expr4"));
sqlExpr5 = checkNull(rs.getString("sql_expr5"));
sqlExpr6 = checkNull(rs.getString("sql_expr6"));
objtNames = checkNull(rs.getString("sql_input"));
compSql = sqlExpr + " " + sqlExpr1 + " " + sqlExpr2 + " " + sqlExpr3 + " " + sqlExpr4 + " " + sqlExpr5 + " "
+ sqlExpr6;
System.out.println("Combine SQL::::" + compSql);
System.out.println("inside execute dynamically Sql ");
//processQuery(compSql,bl.get(i),al.get(i),conn);
processQuery(compSql,fileNames[i-1],conn);
}
}
}
catch(Exception ee)
{
System.out.println("@ Amit>> Error in [SFADailyReport.java]=>"+ee);
ee.printStackTrace();
}
finally
{
if(conn !=null && rs != null && pstmt1 !=null)
{
conn.close();
rs.close();
pstmt.close();
}
}
return "";
}
/*public void processQuery1(String query1,String fileName,String list,Connection conn)
{
PreparedStatement pstmt = null;
PrintWriter pw = null ;
PreparedStatement pstmt1 = null;
PreparedStatement pstmt2 = null;
try
{
String currTime = null;
SimpleDateFormat sdf1=null;
try {
sdf1 = new SimpleDateFormat(this.genericUtility.getDBDateFormat());
} catch (ITMException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
currTime = sdf1.format(new Timestamp(System.currentTimeMillis())).toString();
currTime = currTime.replaceAll("-", "");
String logFileName = "SFA_Monthely_Report_" + currTime+"_";
System.out.println("@V@ Before Query1 Executed");
System.out.println("@V@ query1:- ["+query1+"]");
System.out.println("@Amit >> value of division:- ["+list+"]");
System.out.println("@V@ fileName:- ["+fileName+"]");
if(query2!=null)
query1 = query1+" "+query2;
int counter=0;
System.out.println("Inside The Division Loop");
pstmt = conn.prepareStatement(query1);
if(list!=null && list.length()>0)
{
pstmt.setString(1,list.trim());
ResultSet rs = pstmt.executeQuery();
System.out.println("@V@ Query Executed");
System.out.println("rs row==>"+rs.getRow());
if (rs.next() )
{
if(row > 0){
//Added for Get the path name from gencodes [start]
sql="SELECT FLD_NAME,MOD_NAME,FLD_VALUE,DESCR,SH_DESCR,UDF_STR1,UDF_STR2,UDF_STR3 FROM GENCODES WHERE ACTIVE='Y' AND FLD_NAME= ? ";
pstmt2=conn.prepareStatement(sql);
pstmt2.setString(1, "COMM_SITE_LIST");
rs2=pstmt2.executeQuery();
int count=0,commListNotFound=0;
count=rs2.getRow();
System.out.println("count"+count);
System.out.println("rs size"+rs2.getRow());
while(rs2.next())
{
commListNotFound++;
fieldName=rs2.getString("FLD_NAME");
System.out.println("@ Shri fieldName>> "+fieldName);
}
if(commListNotFound == 0)
{
printLogFile("STDOUT", "Data Is Not found from Disparm Sql For TOTAL Sale For Site Code :: <" + siteCode,logFileName, conn);
}
pstmt1.close();
pstmt1=null;
rs1.close();
rs1=null;
//Added for Get the path name from gencodes [End]
fileName = fileName+"_"+(new SimpleDateFormat("ddMMyyyyhhmm").format(new Date()));
DistCommon disCom = new DistCommon();
String jbossHome= disCom.getDisparams("999999", "MONTHLY_REPORT_", conn);
System.out.println("jbossHome File Path >> "+ jbossHome);
//String jbossHome = CommonConstants.JBOSSHOME;
System.out.println("jbossHome>> " +jbossHome);
File filDir=new File(jbossHome+"/"+"SFAMonthlyReport");
File filDir=new File(jbossHome);
if(!filDir.exists())
{
System.out.println("@V@ Folder not found In IF");
filDir.mkdir();
}
else
{
System.out.println("@V@ Folder found In ELSE");
}
pw = new PrintWriter(jbossHome + File.separator
+ "SFAMonthlyReport"+ File.separator + fileName +".csv");
pw = new PrintWriter(jbossHome + File.separator + fileName +".csv");
pw = new PrintWriter(jbossHome + File.separator
+ "SFAMonthlyReport"+ File.separator + fileName +".csv");// vallabh change folder name.
System.out.println("pw >> " +pw.toString());
rs.getMetaData().getColumnCount();
ResultSetMetaData rsmd = rs.getMetaData();
int columnsNumber = rsmd.getColumnCount();
System.out.println("@V@ ColumnCount: " + columnsNumber);
String sql = "select var_value from finparm where var_name='SSCDAILY_SEP'";
pstmt1 = conn.prepareStatement(sql);
ResultSet rs2 = pstmt1.executeQuery();
String seperator = ",";
if(rs2.next())
{
seperator = rs2.getString("var_value");
}
StringBuilder sb1 = new StringBuilder();
for (int i = 1; i <= columnsNumber; i++)
{
System.out.println("Inside the columnsNumber loop ");
sb1.append(" "+rsmd.getColumnName(i) + ""+seperator.trim()+" ");
// sb1.append(""+rsmd.getColumnName(i) + ""+seperator.trim()+" ");
}
pw.println(sb1.substring(0, sb1.length() - 1));
System.out.println("rs row==>"+rs.getRow());
if (rs.next() )
{
System.out.println("Inside the rs");
} else{
System.out.println("Inside the close rs");
}
while (rs.next())
{
System.out.println("Inside the while");
StringBuilder sb = new StringBuilder();
for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++)
{
for (int i = 1; i <= columnsNumber; i++)
{
Object obj = rs.getObject(i);
String str = "" + rs.getString(i);
System.out.println("str>> "+str);
if(obj!=null)
str = changeType(obj);
//System.out.println("Data: " + str);
str = str.replaceAll("\n", " ");
str = str.replaceAll("\r", " ");
str = str.replaceAll("\t", " ");
//sb.append(" "+str.trim() + ""+seperator.trim()+"");
sb.append(str.trim()+seperator.trim());
}
//String csvLine = sb.toString();
System.out.println("@V@ StringBuider: "+sb);
// print to csv file after removing the trailing ',' character
pw.println(sb.substring(0, sb.length() - 1));
}
for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++)
{
System.out.println("Inside the columnsNumber loop ");
sb1.append(" "+rs.getMetaData().getColumnName(i) + ""+seperator.trim()+" ");
// sb1.append(""+rsmd.getColumnName(i) + ""+seperator.trim()+" ");
}
pw.println(sb1.substring(0, sb1.length() - 1));
System.out.println("@V@ File Generated");
pw.flush();
pw.close();
SFACSVToExcelConverter csv = new SFACSVToExcelConverter();
System.out.println("@V@ file name before EXCEL conversion :- ["+fileName+"]");
csv.convertMonthlyReport(fileName,seperator.trim(),conn);
printLogFile("STDOUT", "File Has Been Generated For Division :: <" +list+">",logFileName, conn);
//csv.convertCsvToXls(fileName,seperator.trim());
}else{
printLogFile("STDOUT", "File Not Generated Because Division Data Not Found For :: <" +list+">",logFileName, conn);
}
} else{
System.out.println("no data");
printLogFile("STDOUT", "File Not Generated Because Division Data Is Not Found For division :: <" +list+">",logFileName, conn);
}
}
else{
printLogFile("STDOUT", "File Not Generated Because Division Not Found For :: <" +list+">",logFileName, conn);
}
}
catch (SQLException e)
{
e.printStackTrace();
}
catch (FileNotFoundException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
catch (IOException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
finally
{
try
{
if(pw!=null && pstmt!=null)
{
pw.flush();
pw.close();
pstmt.close();
}
}
catch (SQLException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}*/
String changeType(Object obj)
{
String retString = null;
String dataType = obj.getClass().getSimpleName();
System.out.println("@V@ obj Format: "+dataType);
if((obj.getClass().getSimpleName())=="Date")
{
E12GenericUtility genericUtility= new E12GenericUtility();
String dispalyDateFormat;
try
{
dispalyDateFormat = genericUtility.getDispDateFormat();
SimpleDateFormat sdf = new SimpleDateFormat(dispalyDateFormat);
retString = sdf.format(obj);
}
catch (ITMException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
catch (Exception e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
else
{
retString = obj.toString();
}
return retString;
}
@Override
public String schedulePriority(String arg0) throws Exception
{
// TODO Auto-generated method stub
return null;
}
private String checkNull(String input) {
if (input == null) {
input = "";
}
return input.trim();
}
public void printLogFile(String title, String msg, String fileName,Connection conn)
{
String logFile = "";
String logDir = "";
File logFileDir = null;
FileWriter fileWriter = null;
String currTime = null;
Calendar calendar = Calendar.getInstance();
String filePath = "";
E12GenericUtility genericUtility = new E12GenericUtility();
try
{
SFAMonthlyReport sfa =new SFAMonthlyReport();
String logFileName = "";
//SimpleDateFormat sdf = new SimpleDateFormat("dd-MM-yyyy");
SimpleDateFormat sdf1 = new SimpleDateFormat(genericUtility.getDBDateFormat());
currTime = sdf1.format(new Timestamp(System.currentTimeMillis())).toString();
currTime = currTime.replaceAll("-","");
calendar.setTime(new java.sql.Timestamp(System.currentTimeMillis()));
fileName = fileName+currTime+calendar.get(Calendar.HOUR)+""+calendar.get(Calendar.MINUTE);
logFileName = fileName;
DistCommon disCom = new DistCommon();
filePath= sfa.getDisparamsServerLog("999999", "MONTHREPORT_LOG", conn);
System.out.println(" Sfa logFileName >> "+ filePath);
/*logDir = CommonConstants.JBOSSHOME + File.separator + "AMDPO" + File.separator + "Stock Transfer Scheduler-To-Track-Exceptions";*/
logDir= filePath;
System.out.println("logDir >> "+logDir);
logFileDir = new File(logDir);
if (!logFileDir.exists())
{
logFileDir.mkdirs();
}
logFile = logDir + File.separator + logFileName + ".log";
//SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd HH:mm");
java.util.Date now = new java.util.Date();
String strDate = sdfDate.format(now);
fileWriter = new FileWriter(logFile, true);
fileWriter.write("\r\n");
fileWriter.write(strDate + " " + "INFO" + " " + "["+ title +"] : " + msg);
}
catch (Exception ex)
{
ex.printStackTrace();
//printLog("STDERR", ex, "");
//printLog("STDOUT","Inside Exception [getLog]>>" + ex.toString(),fileName);
}
finally
{
try
{
if (fileWriter != null)
{
fileWriter.flush();
fileWriter.close();
}
}
catch (Exception e)
{
e.printStackTrace();
//printLog("STDERR", e,fileName);
}
}
}
public String getUserInfo(String xtraParams) throws ITMException
{
StringBuffer userInfoStr = new StringBuffer();
String userId = "";
String loginEmpCode = "";
String loginSiteCode = "";
String entityCode = "";
String profileId = "";
String userType = "";
String charEnc = "";
String chgTerm = "";
String transDb = "";
String sql = "";
PreparedStatement pstmt = null;
ResultSet rs = null;
Connection conn = null;
try
{
E12GenericUtility genericUtility= new E12GenericUtility();
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
loginSiteCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
entityCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "entityCode");
profileId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "profileId");
userType = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "userType");
charEnc = CommonConstants.ENCODING;
System.out.println("charEnc......" + charEnc);
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chgTerm");
UserInfoBean userInfo = new UserInfoBean();
DBAccessEJB dbAccessEJB = new DBAccessEJB();
userInfo = dbAccessEJB.createUserInfo(userId);
transDb = userInfo.getTransDB();
System.out.println("transDb::::@@@ " + transDb);
userInfoStr.append("<UserInfo>");
userInfoStr.append("<loginCode>").append("<![CDATA[" + userId + "]]>").append("</loginCode>\r\n");
userInfoStr.append("<empCode>").append("<![CDATA[" + loginEmpCode + "]]>").append("</empCode>\r\n");
userInfoStr.append("<siteCode>").append("<![CDATA[" + loginSiteCode + "]]>").append("</siteCode>\r\n");
userInfoStr.append("<entityCode>").append("<![CDATA[" + entityCode + "]]>").append("</entityCode>\r\n");
userInfoStr.append("<profileId>").append("<![CDATA[" + profileId + "]]>").append("</profileId>\r\n");
userInfoStr.append("<userType>").append("<![CDATA[" + userType + "]]>").append("</userType>\r\n");
userInfoStr.append("<charEnc>").append("<![CDATA[" + charEnc + "]]>").append("</charEnc>\r\n");
userInfoStr.append("<remoteHost>").append("<![CDATA[" + chgTerm + "]]>").append("</remoteHost>\r\n");
userInfoStr.append("<transDB>").append("<![CDATA[" + transDb + "]]>").append("</transDB>\r\n");
userInfoStr.append("</UserInfo>");
}
catch (Exception e)
{
throw new ITMException(e);
}
return userInfoStr.toString();
}
/*public String getDisparams(String prdCode, String varName, Connection conn) {
String retVal = null;
String sql = null;
ResultSet rs = null;
Statement stmt = null;
try {
System.out
.println("Finding the variable value from Disparam for parameters["
+ prdCode + "," + varName + "]");
stmt = conn.createStatement();
sql = "SELECT VAR_VALUE FROM DISPARM WHERE PRD_CODE ='" + prdCode
+ "' AND VAR_NAME ='" + varName + "'";
rs = stmt.executeQuery(sql);
if (rs.next()) {
retVal = (rs.getString(1) == null ? " " : rs.getString(1));
} else {
retVal = "NULLFOUND";
}
rs.close();
stmt.close();
rs = null;
stmt = null;
} catch (Exception e) {
e.printStackTrace();
}
return (retVal);
}*/
public String getDisparamsServerLog(String prdCode, String varName, Connection conn) {
String retVal = null;
String sql = null;
ResultSet rs = null;
Statement stmt = null;
try {
System.out
.println("Finding the variable value from Disparam for parameters["
+ prdCode + "," + varName + "]");
stmt = conn.createStatement();
sql = "SELECT VAR_VALUE FROM DISPARM WHERE PRD_CODE ='" + prdCode
+ "' AND VAR_NAME ='" + varName + "'";
rs = stmt.executeQuery(sql);
if (rs.next()) {
retVal = (rs.getString(1) == null ? " " : rs.getString(1));
} else {
retVal = "NULLFOUND";
}
rs.close();
stmt.close();
rs = null;
stmt = null;
} catch (Exception e) {
e.printStackTrace();
}
return (retVal);
}
public void processQuery(String query1,String fileName,Connection conn)
{
PreparedStatement pstmt = null;
PrintWriter pw = null ;
PreparedStatement pstmt1 = null;
String currTime = null;
SimpleDateFormat sdf1=null;
try
{
try {
sdf1 = new SimpleDateFormat(this.genericUtility.getDBDateFormat());
} catch (ITMException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//System.out.println("list >> " +list);
System.out.println("@V@ Before Query1 Executed");
System.out.println("@V@ query1:- ["+query1+"]");
System.out.println("@V@ fileName:- ["+fileName+"]");
/* if(query2!=null)
query1 = query1+" "+query2;
*/
currTime = sdf1.format(new Timestamp(System.currentTimeMillis())).toString();
currTime = currTime.replaceAll("-", "");
String logFileName = "SFA_Monthely_Report_" + currTime+"_";
pstmt = conn.prepareStatement(query1);
/*if(list!=null && list.length()>0)
{
pstmt.setString(1,list.trim());*/
ResultSet rs = pstmt.executeQuery();
System.out.println("@V@ Query Executed");
System.out.println("rs row==>"+rs.getRow());
System.out.println("@V@ Query Executed");
//fileName = fileName+"_"+(new SimpleDateFormat("ddMMyyyyhhmm").format(new Date()));
//String jbossHome = CommonConstants.JBOSSHOME;
fileName = fileName+"_"+(new SimpleDateFormat("ddMMyyyyhhmm").format(new Date()));
DistCommon disCom = new DistCommon();
String jbossHome= disCom.getDisparams("999999", "MONTHLY_REPORT_", conn);
System.out.println("jbossHome File Path >> "+ jbossHome);
File filDir=new File(jbossHome);
if(!filDir.exists())
{
System.out.println("@V@ Folder not found In IF");
filDir.mkdir();
}
else
{
System.out.println("@V@ Folder found In ELSE");
}
/*pw = new PrintWriter(jbossHome + File.separator
+ "SSCMonthlyReport"+ File.separator + fileName +".csv");*/// vallabh change folder name.
pw = new PrintWriter(jbossHome + File.separator + fileName +".csv");
ResultSetMetaData rsmd = rs.getMetaData();
int columnsNumber = rsmd.getColumnCount();
System.out.println("@V@ ColumnCount: " + columnsNumber);
String sql = "select var_value from finparm where var_name='SSCDAILY_SEP'";
pstmt1 = conn.prepareStatement(sql);
ResultSet rs2 = pstmt1.executeQuery();
String seperator = ",";
if(rs2.next())
{
seperator = rs2.getString("var_value");
}
StringBuilder sb1 = new StringBuilder();
for (int i = 1; i <= columnsNumber; i++)
{
sb1.append(" "+rsmd.getColumnName(i) + ""+seperator.trim()+" ");
// sb1.append(""+rsmd.getColumnName(i) + ""+seperator.trim()+" ");
}
pw.println(sb1.substring(0, sb1.length() - 1));
while (rs.next())
{
StringBuilder sb = new StringBuilder();
for (int i = 1; i <= columnsNumber; i++)
{
/*Object obj = rs.getObject(i);*/
String str = "" + rs.getString(i);
/*if(obj!=null)
str = changeType(obj);*/
//System.out.println("Data: " + str);
str = str.replaceAll("\n", " ");
str = str.replaceAll("\r", " ");
str = str.replaceAll("\t", " ");
//sb.append(" "+str.trim() + ""+seperator.trim()+"");
sb.append(str.trim()+seperator.trim());
}
//String csvLine = sb.toString();
System.out.println("@V@ StringBuider: "+sb);
// print to csv file after removing the trailing ',' character
pw.println(sb.substring(0, sb.length() - 1));
}
System.out.println("@V@ File Generated");
pw.flush();
pw.close();
SFACSVToExcelConverter csv = new SFACSVToExcelConverter();
System.out.println("@V@ file name before EXCEL conversion :- ["+fileName+"]");
//csv.convertMonthlyReport(fileName,seperator.trim(),list,conn);
csv.convertMonthlyReport(fileName,seperator.trim(),logFileName,conn);
printLogFile("STDOUT", "File Not Generated Because Division Not Found For :: <" +fileName+">",logFileName, conn);
}
catch (SQLException e)
{
e.printStackTrace();
}
catch (FileNotFoundException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
catch (IOException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
finally
{
try
{
pw.flush();
pw.close();
pstmt.close();
}
catch (SQLException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment