优化READER

@@ -52,7 +52,7 @@ public class Main {
                 //数据仓库给九州的发送程序
                 Timer timer = new Timer();
                 IMFSender CangKu2Jiuzhou = new IMFSender(client,"data/fid_index.txt");
-                timer.schedule(CangKu2Jiuzhou, 30000L, 1200000L);
+                timer.schedule(CangKu2Jiuzhou, 10000L, 1200000L);
 
             }
         }

@@ -9,9 +9,9 @@ import com.airport.bean.MessageBak;
 import java.util.List;
 
 public interface Dao {
-    int insertRecord(String var1, String var2);
+    int insertRecord(String var1, String var2,String var3,String var4);
 
-    void saveRecord(String var1, String var2, String var3) throws Exception;
+    void saveRecord(String var1, String var2, String var3,String var4,String var5) throws Exception;
 
     void delete(int var1);
 

@@ -40,15 +40,17 @@ public class DaoImpl implements Dao {
         this.jdbcTemplate = jdbcTemplate;
     }
 
-    public int insertRecord(final String oper, final String sndr) {
+    public int insertRecord(final String oper, final String sndr,String type,String styp) {
         KeyHolder keyHolder = new GeneratedKeyHolder();
         this.jdbcTemplate.update(new PreparedStatementCreator() {
             public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
-                DaoImpl.logger.info("oper=" + oper + " sndr=" + sndr);
-                String sql = "insert into  T_ETL_MESSAGE(OPER,SNDR,SNTM,content) values(?,?,sysdate,empty_clob())";
+                DaoImpl.logger.info("oper=" + oper + " sndr=" + sndr+"type="+type+"styp="+styp);
+                String sql = "insert into  T_ETL_MESSAGE(OPER,SNDR,SNTM,content,TYPE,STYP) values(?,?,sysdate,empty_clob(),?,?)";
                 PreparedStatement ps = connection.prepareStatement(sql, new String[]{"FID"});
                 ps.setString(1, oper);
                 ps.setString(2, sndr);
+                ps.setString(3, type);
+                ps.setString(4, styp);
                 return ps;
             }
         }, keyHolder);
@@ -56,14 +58,14 @@ public class DaoImpl implements Dao {
         return generatedId;
     }
 
-    public void saveRecord(String messaegType, String sndr, String xmlContent) throws Exception {
+    public void saveRecord(String messaegType, String sndr, String xmlContent,String type,String styp) throws Exception {
         Connection conn = null;
         Statement stmt = null;
         ResultSet rs = null;
         int fid = -100;
 
         try {
-            fid = this.insertRecord(messaegType, sndr);
+            fid = this.insertRecord(messaegType, sndr,type,styp);
             conn = this.jdbcTemplate.getDataSource().getConnection();
             conn.setAutoCommit(false);
             stmt = conn.createStatement();