1.解决路单批量保存时可能失败的情况

王通
1 parent f3af1893
Showing 1 changed file with 14 additions and 6 deletions
src/main/java/com/bsth/data/schedule/thread/SchedulePstThread.java
@@ -12,6 +12,7 @@ import org.springframework.jdbc.core.BatchPreparedStatementSetter;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.TransactionStatus;
+import org.springframework.transaction.support.TransactionCallback;
 import org.springframework.transaction.support.TransactionCallbackWithoutResult;
 import org.springframework.transaction.support.TransactionTemplate;
@@ -81,19 +82,20 @@ public class SchedulePstThread extends Thread {
         logger.info("real schedule update size: " + saveList.size());
         //批量入库
-        update2Db();
+        boolean success = update2Db();
-        //清空容器
-        saveList.clear();
+        if (success) {
+            saveList.clear();
+        }
         logger.info("update end! ");
     }
-    private void update2Db(){
+    private boolean update2Db(){
         final List<ScheduleRealInfo> pstList = saveList;
-        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
+        Boolean success = transactionTemplate.execute(new TransactionCallback<Boolean>() {
             @Override
-            public void doInTransactionWithoutResult(TransactionStatus status) {
+            public Boolean doInTransaction(TransactionStatus status) {
                 try {
                     //更新
                     jdbcTemplate.batchUpdate("update bsth_c_s_sp_info_real set bc_type=?,bcs=?,bcsj=?,cl_zbh=?,create_date=?" +
@@ -163,6 +165,8 @@ public class SchedulePstThread extends Thread {
                             return pstList.size();
                         }
                     });
+
+                    return true;
                 } catch (Exception e) {
                     status.setRollbackOnly();
                     try {
@@ -171,7 +175,11 @@ public class SchedulePstThread extends Thread {
                         jsonProcessingException.printStackTrace();
                     }
                 }
+
+                return false;
             }
         });
+
+        return success.booleanValue();
     }
 }