diff --git a/src/main/java/MakeRfidnfo.java b/src/main/java/MakeRfidnfo.java index 3d6cae5..5e7281b 100644 --- a/src/main/java/MakeRfidnfo.java +++ b/src/main/java/MakeRfidnfo.java @@ -17,7 +17,7 @@ public class MakeRfidnfo { private static String[] g_strDB = new String[4]; public static final Logger logger = Logger.getLogger(MakeRfidnfo .class); - + public static void main(String[] args) { try { @@ -39,7 +39,7 @@ public class MakeRfidnfo { g_strDB[1] = props.getProperty("db_connect"); g_strDB[2] = props.getProperty("db_id"); g_strDB[3] = props.getProperty("db_pw"); - + // 콘솔 출력 MakeRfidnfo.logger.info(String.format("=== DB접속정보 : %s, %s, %s", g_strDB[1], g_strDB[2], g_strDB[3])); } catch (Exception e) { @@ -48,29 +48,29 @@ public class MakeRfidnfo { MakeRfidnfo obj = new MakeRfidnfo(); try { - + if(args.length != 2) { System.err.println("총 2개의 args를 입력하지 않았습니다."); System.err.println("sFileDir, sFileName"); - System.exit(0); + System.exit(0); } - + double d = 0.0; d = obj.runMakeRfidMstBin(Long.parseLong(args[0]), Long.parseLong(args[1])); MakeRfidnfo.logger.info("=== 파일 생성 소요시간 : " + d); } catch (Exception e) { e.printStackTrace(); } - + System.exit(0); } - // + // private Connection getOrclConn( ) throws Exception{ Class.forName(g_strDB[0]); return DriverManager.getConnection(g_strDB[1], g_strDB[2], g_strDB[3]); } - + private double runMakeRfidMstBin(long nStart, long nEnd) throws Exception { long start = System.currentTimeMillis(); // 작동 시간 측정용 @@ -81,7 +81,7 @@ public class MakeRfidnfo { try { conn = (Connection) getOrclConn(); // Connection 생성 시 Connection으로 형변환 - + // prepareStatement를 PreparedStatement으로 형변환 StringBuffer strSQL = new StringBuffer(); strSQL.append(" SELECT ") ; @@ -95,18 +95,18 @@ public class MakeRfidnfo { strSQL.append(" WHERE A.CAR_NO NOT IN ('00x0000', '01괘0006')") ; strSQL.append(" and car_type_kbn in ('000E', '000F')") ; strSQL.append(")") ; - - + + logger.info(strSQL.toString()); - + Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY,java.sql.ResultSet.CONCUR_READ_ONLY); - stmt.setFetchSize(10000); + stmt.setFetchSize(10000); rs = stmt.executeQuery( strSQL.toString() ); String str = ""; int n = 0; File file = new File("/gpta/source-app/cfs/relay_jar/data/IMMRFID"); - FileOutputStream fos = new FileOutputStream(file); + FileOutputStream fos = new FileOutputStream(file); while (rs.next()) { n++; if(n % 10000 == 0) { @@ -115,8 +115,8 @@ public class MakeRfidnfo { str = String.format("%s%s%s%s%s%s%s", rs.getString(1), rs.getString(2), rs.getString(3), rs.getString(4), rs.getString(5), rs.getString(6), rs.getString(7)); fos.write(str.getBytes()); - } // end while - + } // end while + fos.close(); logger.info(strSQL.toString()); @@ -127,12 +127,12 @@ public class MakeRfidnfo { return (end - start) / 1000.0; // insertBatchFileToDB 실행에 걸린 시간 } - + String sql = "update TB_CFS_MST_FLAG set RFID_FLAG = '1', RFID_SENDTIME = SYSDATE "; ps = (PreparedStatement) conn.prepareStatement(sql); ps.executeUpdate(); conn.commit(); - + }catch(Exception e){ e.printStackTrace(); }finally{ @@ -140,7 +140,7 @@ public class MakeRfidnfo { rs.close(); if(ps != null) ps.close(); - + conn.close(); } @@ -150,13 +150,13 @@ public class MakeRfidnfo { } private int setFtpData(File file, String fileNm) { - + FTPUtil sftp = new FTPUtil(); logger.debug("======== 업로드 시작 : " + fileNm); - + sftp.init("175.193.201.56", "tmax","tmax1234"); - + Map map = new HashMap(); map.put("return", "0"); @@ -165,18 +165,18 @@ public class MakeRfidnfo { } catch (Exception e) { e.printStackTrace(); } - + logger.debug("======== : " + map.get("return")); - + int nReturn = Integer.parseInt(map.get("return")); - + sftp.disconnect(); logger.debug("======== 업로드 끝 : " + nReturn); - + return nReturn; } - - + + }