update...

潘钊
1 parent 0fd7f578
Showing 1 changed file with 83 additions and 3 deletions
src/main/java/com/bsth/data/schedule/DayOfSchedule.java
@@ -13,7 +13,6 @@ import com.bsth.entity.realcontrol.ScheduleRealInfo;
 import com.bsth.entity.schedule.SchedulePlanInfo;
 import com.bsth.repository.realcontrol.ScheduleRealInfoRepository;
 import com.bsth.service.schedule.SchedulePlanInfoService;
-import com.bsth.util.BatchSaveUtils;
 import com.bsth.websocket.handler.SendUtils;
 import com.google.common.base.Predicate;
 import com.google.common.collect.ArrayListMultimap;
@@ -25,9 +24,16 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.DataIntegrityViolationException;
+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.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -381,7 +387,7 @@ public class DayOfSchedule {
      * @Title: batchSave
      * @Description: TODO(批量入库)
      */
-    private void batchSave(List<ScheduleRealInfo> list) {
+    private void batchSave(final List<ScheduleRealInfo> list) {
         // 查询数据库最大ID
         Long id = schRepository.getMaxId();
         if (null == id)
@@ -395,8 +401,82 @@ public class DayOfSchedule {
             item.setScheduleDateStr(sdfyyyyMMdd.format(item.getScheduleDate()));
         }
+        //编程式事务
+        DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
+        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
+        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
+        TransactionStatus status = tran.getTransaction(def);
+
+        try{
+            //写入
+            jdbcTemplate.batchUpdate("insert into bsth_c_s_sp_info_real(id,bc_type,bcs,bcsj,cl_zbh,create_date,dfsj,directive_state,fcno,fcsj,fcsj_actual,j_gh,j_name,jhlc,lp_name,qdz_code,qdz_name,real_exec_date,remarks,s_gh,s_name,schedule_date,schedule_date_str,sflj,sp_id,status,update_date,xl_bm,xl_dir,xl_name,zdsj,zdsj_actual,zdz_code,zdz_name,ccno,df_auto,fgs_bm,fgs_name,gs_bm,gs_name,online,adjust_exps,reissue,jhlc_orig,sigin_compate,drift_status,cc_service,major_station_name)" +
+                    " VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    ScheduleRealInfo sch = list.get(i);
+                    ps.setLong(1, sch.getId());
+                    ps.setString(2, sch.getBcType());
+                    ps.setInt(3, sch.getBcs()==null?0:sch.getBcs());
+                    ps.setInt(4, sch.getBcsj()==null?0:sch.getBcsj());
+                    ps.setString(5, sch.getClZbh());
+                    ps.setDate(6, new java.sql.Date(sch.getCreateDate().getTime()));
+                    ps.setString(7, sch.getDfsj());
+                    ps.setInt(8, sch.getDirectiveState());
+                    ps.setInt(9, sch.getFcno()==null?0:sch.getFcno());
+                    ps.setString(10, sch.getFcsj());
+                    ps.setString(11, sch.getFcsjActual());
+                    ps.setString(12, sch.getjGh());
+                    ps.setString(13, sch.getjName());
+                    ps.setDouble(14, sch.getJhlc());
+                    ps.setString(15, sch.getLpName());
+                    ps.setString(16, sch.getQdzCode());
+                    ps.setString(17, sch.getQdzName());
+                    ps.setString(18, sch.getRealExecDate());
+                    ps.setString(19, sch.getRemarks());
+                    ps.setString(20, sch.getsGh());
+                    ps.setString(21, sch.getsName());
+                    ps.setDate(22, new java.sql.Date(sch.getScheduleDate().getTime()));
+                    ps.setString(23, sch.getScheduleDateStr());
+                    ps.setBoolean(24, sch.isSflj());
+                    ps.setLong(25, sch.getSpId());
+                    ps.setInt(26, sch.getStatus());
+                    ps.setDate(27, new java.sql.Date(sch.getUpdateDate().getTime()));
+                    ps.setString(28, sch.getXlBm());
+                    ps.setString(29, sch.getXlDir());
+                    ps.setString(30, sch.getXlName());
+                    ps.setString(31, sch.getZdsj());
+                    ps.setString(32, sch.getZdsjActual());
+                    ps.setString(33, sch.getZdzCode());
+                    ps.setString(34, sch.getZdzName());
+                    ps.setInt(35, sch.getCcno()==null?0:sch.getCcno());
+                    ps.setBoolean(36, sch.isDfAuto());
+                    ps.setString(37, sch.getFgsBm());
+                    ps.setString(38, sch.getFgsName());
+                    ps.setString(39, sch.getGsBm());
+                    ps.setString(40, sch.getGsName());
+                    ps.setBoolean(41, sch.isOnline());
+                    ps.setString(42, sch.getAdjustExps());
+                    ps.setBoolean(43, sch.isReissue());
+                    ps.setDouble(44, sch.getJhlcOrig());
+                    ps.setInt(45, sch.getSiginCompate());
+                    ps.setInt(46, sch.getDriftStatus());
+                    ps.setBoolean(47, sch.isCcService());
+                    ps.setString(48, sch.getMajorStationName());
+                }
+
+                @Override
+                public int getBatchSize() {
+                    return list.size();
+                }
+            });
+
+            tran.commit(status);
+        }catch (Exception e){
+            tran.rollback(status);
+            logger.error("real schedule batchSave error...", e);
+        }
         // 入库
-        new BatchSaveUtils<ScheduleRealInfo>().saveList(list, ScheduleRealInfo.class);
+        //new BatchSaveUtils<ScheduleRealInfo>().saveList(list, ScheduleRealInfo.class);
     }
     public List<SchedulePlanInfo> cleanSchPlanItr(Iterator<SchedulePlanInfo> itrab) {