Skip to content

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

SFAMonthlyReport

parent fd817d25
Hide whitespace changes
Inline Side-by-side
Showing with 533 additions and 0 deletions
ibase/webitm/ejb/sc/SFAMonthlyReport.java 0 → 100644
View file @ 19e5cd0e
/* */ package ibase.webitm.ejb.sc;
/* */
/* */ import ibase.scheduler.utility.interfaces.Schedule;
/* */ import ibase.system.config.ConnDriver;
/* */ import ibase.utility.CommonConstants;
/* */ import ibase.utility.E12GenericUtility;
/* */ import ibase.utility.UserInfoBean;
/* */ import ibase.webitm.ejb.DBAccessEJB;
/* */ import ibase.webitm.ejb.ITMDBAccessEJB;
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
* Qualified Name: ibase.webitm.ejb.sc.SFAMonthlyReport
* JD-Core Version: 0.6.0
*/
\ No newline at end of file
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