update...

潘钊
1 parent 2237c740
Showing 1 changed file with 49 additions and 31 deletions
src/main/java/com/bsth/data/car_out_info/CarOutInfoHandler.java
 package com.bsth.data.car_out_info;
+import com.bsth.Application;
 import com.bsth.data.BasicData;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.data.schedule.ScheduleComparator;
@@ -12,13 +13,18 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.jdbc.core.BatchPreparedStatementSetter;
 import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.TransactionDefinition;
+import org.springframework.transaction.TransactionStatus;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.support.DefaultTransactionDefinition;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 /**
  * 发车信息表处理程序
@@ -60,7 +66,7 @@ public class CarOutInfoHandler implements CommandLineRunner, CarOutInfo {
             Set<String> ks = lpScheduleMap.keySet();
             String prefix = lineCode + "_";
             for (String k : ks) {
-                if (k.indexOf(prefix) != -1) {
+                if (k.startsWith(prefix)) {
                     list.addAll(lpScheduleMap.get(k));
                 }
             }
@@ -90,36 +96,48 @@ public class CarOutInfoHandler implements CommandLineRunner, CarOutInfo {
                 downArray = nexts(downs);
         final List<ScheduleRealInfo> pstArray = mergeArray(upArray, downArray);
-        //删除
-        jdbcTemplate.update("delete from bsth_t_clfcxxb where line_code=?", lineCode);
-        //重新写入
-        jdbcTemplate.batchUpdate("insert into bsth_t_clfcxxb(rq, line_code, line_name, lp_name, lp_sn, dfsj, nbbm, cph, bc_type, end_station_name, updown, jGh, jName, remarks, sn)" +
-                " VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", new BatchPreparedStatementSetter() {
-            @Override
-            public void setValues(PreparedStatement ps, int i) throws SQLException {
-                ScheduleRealInfo sch = pstArray.get(i);
-                ps.setString(1, sch.getScheduleDateStr());
-                ps.setString(2, sch.getXlBm());
-                ps.setString(3, sch.getXlName());
-                ps.setString(4, /*sch.getLpName()*/"0");
-                ps.setInt(5, sch.getFcno()==null?-1:sch.getFcno());
-                ps.setString(6, sch.getDfsj().replace(":", ""));
-                ps.setString(7, sch.getClZbh().replace("-", ""));
-                ps.setString(8, BasicData.nbbmCompanyPlateMap.get(sch.getClZbh()));
-                ps.setString(9, bcTypeMap.containsKey(sch.getBcType()) ? bcTypeMap.get(sch.getBcType()) : sch.getBcType());
-                ps.setString(10, sch.getZdzName());
-                ps.setInt(11, Integer.parseInt(sch.getXlDir()));
-                ps.setString(12, sch.getjGh());
-                ps.setString(13, sch.getjName());
-                ps.setString(14, sch.getRemarks());
-                ps.setInt(15, sch.getFcpSn());
-            }
+        //编程式事务
+        DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
+        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
+        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
+        TransactionStatus status = tran.getTransaction(def);
+
+        try{
+            //删除
+            jdbcTemplate.update("delete from bsth_t_clfcxxb where line_code=?", lineCode);
+            //重新写入
+            jdbcTemplate.batchUpdate("insert into bsth_t_clfcxxb(rq, line_code, line_name, lp_name, lp_sn, dfsj, nbbm, cph, bc_type, end_station_name, updown, jGh, jName, remarks, sn)" +
+                    " VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    ScheduleRealInfo sch = pstArray.get(i);
+                    ps.setString(1, sch.getScheduleDateStr());
+                    ps.setString(2, sch.getXlBm());
+                    ps.setString(3, sch.getXlName());
+                    ps.setString(4, /*sch.getLpName()*/"0");
+                    ps.setInt(5, sch.getFcno()==null?-1:sch.getFcno());
+                    ps.setString(6, sch.getDfsj().replace(":", ""));
+                    ps.setString(7, sch.getClZbh().replace("-", ""));
+                    ps.setString(8, BasicData.nbbmCompanyPlateMap.get(sch.getClZbh()));
+                    ps.setString(9, bcTypeMap.containsKey(sch.getBcType()) ? bcTypeMap.get(sch.getBcType()) : sch.getBcType());
+                    ps.setString(10, sch.getZdzName());
+                    ps.setInt(11, Integer.parseInt(sch.getXlDir()));
+                    ps.setString(12, sch.getjGh());
+                    ps.setString(13, sch.getjName());
+                    ps.setString(14, sch.getRemarks());
+                    ps.setInt(15, sch.getFcpSn());
+                }
-            @Override
-            public int getBatchSize() {
-                return pstArray.size();
-            }
-        });
+                @Override
+                public int getBatchSize() {
+                    return pstArray.size();
+                }
+            });
+
+            tran.commit(status);
+        }catch (Exception e){
+            tran.rollback(status);
+        }
     }
     private List<ScheduleRealInfo> mergeArray(ScheduleRealInfo[] upArray, ScheduleRealInfo[] downArray) {
@@ -190,7 +208,7 @@ public class CarOutInfoHandler implements CommandLineRunner, CarOutInfo {
         bcTypeMap.put("venting", "直放");
         bcTypeMap.put("major", "放站");
         bcTypeMap.put("ldks", "两点间空驶");
-        //Application.mainServices.scheduleWithFixedDelay(updateInfoThread, 60, 40, TimeUnit.SECONDS);
+        Application.mainServices.scheduleWithFixedDelay(updateInfoThread, 60, 40, TimeUnit.SECONDS);
     }
     @Component