update...

潘钊
1 parent d2623603
Showing 3 changed files with 94 additions and 12 deletions
src/main/java/com/bsth/server_rs/base_info/car/buffer/CarBufferData.java
src/main/java/com/bsth/server_rs/base_info/person/buffer/PersonBufferData.java
src/main/java/com/bsth/server_rs/thread/RfidCardInfoPersistenceThread.java
@@ -9,10 +9,7 @@ import org.springframework.boot.CommandLineRunner;
 import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.concurrent.TimeUnit;
 /**
@@ -30,7 +27,7 @@ public class CarBufferData implements CommandLineRunner {
     /**
      * 待入库的bus car
      */
-    private static List<Car> pstList = new ArrayList<>();
+    public static LinkedList<Car> pstList = new LinkedList<>();
     @Autowired
     CarRefreshThread carRefreshThread;
@@ -9,10 +9,7 @@ import org.springframework.boot.CommandLineRunner;
 import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.concurrent.TimeUnit;
 /**
@@ -32,7 +29,7 @@ public class PersonBufferData implements CommandLineRunner {
     /**
      * 待入库的personnel
      */
-    private static List<Personnel> pstList = new ArrayList<>();
+    public static LinkedList<Personnel> pstList = new LinkedList<>();
     public static List<Personnel> findAll() {
         return data;
     }
 package com.bsth.server_rs.thread;
+import com.bsth.server_rs.base_info.car.Car;
+import com.bsth.server_rs.base_info.car.buffer.CarBufferData;
+import com.bsth.server_rs.base_info.person.Personnel;
+import com.bsth.server_rs.base_info.person.buffer.PersonBufferData;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+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.transaction.TransactionDefinition;
+import org.springframework.transaction.TransactionStatus;
+import org.springframework.transaction.support.DefaultTransactionDefinition;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
 /**
  * 场站提交的RFID卡信息入库线程
@@ -14,23 +30,95 @@ public class RfidCardInfoPersistenceThread extends Thread{
     @Autowired
     JdbcTemplate jdbcTemplate;
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
     @Override
     public void run() {
-        personCardSave();
-        carCardSave();
+        try{
+            personCardSave();
+            carCardSave();
+        }catch (Exception e){
+            logger.error("", e);
+        }
     }
     /**
      * 人卡数据入库
      */
     private void personCardSave(){
+        List<Personnel> list = new ArrayList<>();
+        for(int i = 0; i < 1000; i ++){
+            list.add(PersonBufferData.pstList.poll());
+        }
+
+        final List<Personnel> finalList = list;
+
+        //编程式事务
+        DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
+        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
+        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
+        TransactionStatus status = tran.getTransaction(def);
+        try{
+
+            jdbcTemplate.update("update bsth_c_personnel set id_rfid=?, tag_rfid=? where job_code=?", new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    Personnel p = finalList.get(i);
+                    ps.setString(1, p.getIdRfid());
+                    ps.setString(2, p.getTagRfid());
+                    ps.setString(3, p.getJobCode());
+                }
+                @Override
+                public int getBatchSize() {
+                    return finalList.size();
+                }
+            });
+
+            tran.commit(status);
+        }catch (Exception e){
+            tran.rollback(status);
+            logger.error("", e);
+        }
     }
     /**
      * 车卡数据入库
      */
     private void carCardSave(){
+        List<Car> list = new ArrayList<>();
+        for(int i = 0; i < 1000; i ++){
+            list.add(CarBufferData.pstList.poll());
+        }
+
+        final List<Car> finalList = list;
+
+        //编程式事务
+        DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
+        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
+        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
+        TransactionStatus status = tran.getTransaction(def);
+        try{
+
+            jdbcTemplate.update("update bsth_c_cars set id_rfid=?, tag_rfid=? where nbbm=?", new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    Car c = finalList.get(i);
+                    ps.setString(1, c.getIdRfid());
+                    ps.setString(2, c.getTagRfid());
+                    ps.setString(3, c.getNbbm());
+                }
+
+                @Override
+                public int getBatchSize() {
+                    return finalList.size();
+                }
+            });
+            tran.commit(status);
+        }catch (Exception e){
+            tran.rollback(status);
+            logger.error("", e);
+        }
     }
 }