update...

潘钊
1 parent 2143ef3a
Showing 3 changed files with 42 additions and 0 deletions
src/main/java/com/bsth/data/line_version/EnableRouteVersionHandler.java
src/main/java/com/bsth/data/line_version/thread/FixedEnableVerionsThread.java
src/main/java/com/bsth/service/geo_data/impl/GeoDataServiceImpl.java
@@ -59,6 +59,25 @@ public class EnableRouteVersionHandler {
         }
     }
+    public void sync(String lineCode, int version){
+        //编程式事务
+        DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
+        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
+        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
+        TransactionStatus status = tran.getTransaction(def);
+
+
+        try{
+            enableStation(lineCode, version);
+            enableRoad(lineCode, version);
+
+            tran.commit(status);
+        }catch (Exception e){
+            tran.rollback(status);
+            logger.error("", e);
+        }
+    }
+
     /**
      * 启用新版本站点
      * @param lineCode
@@ -43,6 +43,16 @@ public class FixedEnableVerionsThread extends Thread{
                 enableRouteVersionHandler.enable(lineCode, version);
             }
+
+            //要从历史表同步当前表的变更（当前版本）
+            List<String> syncs = jdbcTemplate.queryForList("SELECT CONCAT(line_code,'_',versions) FROM bsth_c_line_versions WHERE STATUS = 1 AND CONCAT(line_code, '_', versions) IN (SELECT CONCAT(line_code, '_', version) FROM logger_route_synchro)", String.class);
+
+            String[] ks;
+            for(String keys : syncs){
+                ks = keys.split("_");
+
+                enableRouteVersionHandler.sync(ks[0], Integer.parseInt(ks[1]));
+            }
         }catch (Exception e){
             logger.error("", e);
         }
@@ -279,6 +279,10 @@ public class GeoDataServiceImpl implements GeoDataService {
                         }
                     });
+
+            //写一条走向变更记录
+            jdbcTemplate.update("insert into logger_route_synchro(t, line_code, version) values(?, ?, ?)", System.currentTimeMillis(), lineCode, versions);
+
             tran.commit(status);
             //返回更新之后的数据
@@ -765,6 +769,9 @@ public class GeoDataServiceImpl implements GeoDataService {
                         }
                     });
+            //写一条走向变更记录
+            jdbcTemplate.update("insert into logger_route_synchro(t, line_code, version) values(?, ?, ?)", System.currentTimeMillis(), lineCode, versions);
+
             tran.commit(status);
             //返回更新之后的数据
@@ -874,6 +881,9 @@ public class GeoDataServiceImpl implements GeoDataService {
                         }
                     });
+            //写一条走向变更记录
+            jdbcTemplate.update("insert into logger_route_synchro(t, line_code, version) values(?, ?, ?)", System.currentTimeMillis(), station.getLineCode(), station.getVersions());
+
             tran.commit(status);
             //返回更新之后的数据
@@ -897,6 +907,9 @@ public class GeoDataServiceImpl implements GeoDataService {
             String sql = "update bsth_c_ls_sectionroute set destroy=1 where id=?";
             jdbcTemplate.update(sql, road.getId());
+            //写一条走向变更记录
+            jdbcTemplate.update("insert into logger_route_synchro(t, line_code, version) values(?, ?, ?)", System.currentTimeMillis(), road.getLineCode(), road.getVersions());
+
             //返回更新之后的数据
             List<GeoRoad> list = findRoadByUpdown(road.getLineCode(), road.getDirections(), road.getVersions());
             rs.put("list", list);