油量表重复数据抛出异常

廖磊
1 parent ce4e5383
Showing 3 changed files with 87 additions and 5 deletions
src/main/java/com/bsth/service/oil/impl/YlbServiceImpl.java
src/main/java/com/bsth/service/report/impl/CulateMileageServiceImpl.java
src/main/java/com/bsth/util/BatchSaveUtils.java
@@ -198,7 +198,16 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 			} 
 			if(addList.size()>0){ 
-				new BatchSaveUtils<Ylb>().saveList(addList, Ylb.class); 
+				try {
+					new BatchSaveUtils<Ylb>().saveList2(addList, Ylb.class); 
+				} catch (Exception e) {
+					// TODO: handle exception
+					if(e.getMessage().indexOf("PK_YLB_UK")>0){
+						newMap.put("fage", "存在相同数据,数据已经过滤");
+						logger.info("定时器:存在相同数据,数据已经过滤");
+					}
+				}
+//				new BatchSaveUtils<Ylb>().saveList(addList, Ylb.class); 
 			}
 			result = "success";
 		}catch (Exception e) {
@@ -363,7 +372,16 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 				}
 			}
 			if(addList.size()>0){ 
-				new BatchSaveUtils<Ylb>().saveList(addList, Ylb.class); 
+				try {
+					new BatchSaveUtils<Ylb>().saveList2(addList, Ylb.class); 
+				} catch (Exception e) {
+					// TODO: handle exception
+					if(e.getMessage().indexOf("PK_YLB_UK")>0){
+						newMap.put("fage", "存在相同数据,数据已经过滤");
+						logger.info("获取:存在相同数据,数据已经过滤");
+					}
+				}
+				
 			}
 			if(updateList.size()>0){
@@ -372,7 +390,7 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 				}
 			}
 			newMap.put("status", ResponseCode.SUCCESS);
-		} catch (ParseException e) {
+		} catch (Exception e) {
 			// TODO Auto-generated catch block
 			newMap.put("status", ResponseCode.ERROR);
 			throw e;
@@ -778,7 +796,16 @@ public class YlbServiceImpl extends BaseServiceImpl&lt;Ylb,Integer&gt; implements YlbS
 					t.setYh(0.0);
 					 if(!(t.getSsgsdm().equals("") || t.getFgsdm().equals(""))){
 						 t.setCreatetime(new Date());
-						repository.save(t);
+						 try {
+							 repository.save(t);
+						} catch (Exception e) {
+							// TODO: handle exception
+							if(e.getMessage().indexOf("PK_YLB_UK")>0){
+								newMap.put("fage", "存在相同数据,数据已经过滤");
+								logger.info("核对有存油没里程：存在相同数据,数据已经过滤");
+							}
+						}
+						
 						/*if(null!=cyl){
 							cyl.setCyl(Arith.add(t.getJzl(), t.getCzyl()));
 							cyl.setUpdatetime(y1.getYyrq());
@@ -222,7 +222,21 @@ public class CulateMileageServiceImpl  implements CulateMileageService{
 			if (!isInOut(scheduleRealInfo)) {
 				if(!scheduleRealInfo.isDestroy()){
 					if(scheduleRealInfo.isSflj()){
-						ljgl=Arith.add(ljgl,scheduleRealInfo.getJhlc()==null?0:scheduleRealInfo.getJhlc());
+						Set<ChildTaskPlan> childTaskPlans = scheduleRealInfo.getcTasks();
+						if(childTaskPlans.isEmpty()){
+							ljgl=Arith.add(ljgl,scheduleRealInfo.getJhlc()==null?0:scheduleRealInfo.getJhlc());
+						}else{
+							Iterator<ChildTaskPlan> it = childTaskPlans.iterator();
+			                while (it.hasNext()) {
+			                    ChildTaskPlan childTaskPlan = it.next();
+			                    if(childTaskPlan.getMileageType().equals("service")){
+			                    	 if (!childTaskPlan.isDestroy()) {
+			 	                    	Float jhgl=childTaskPlan.getMileage()==null?0:childTaskPlan.getMileage();
+			 	                    	ljgl=Arith.add(ljgl,jhgl);
+			 	                    } 
+			                    }
+			                }
+						}
 					}else{
 						Set<ChildTaskPlan> childTaskPlans = scheduleRealInfo.getcTasks();
 						if(!childTaskPlans.isEmpty()){
@@ -99,6 +99,47 @@ public class BatchSaveUtils&lt;T&gt; {
 		return 0;
 	}
+	public int saveList2(List<T> list, Class<T> clazz) throws Exception{
+		//获取泛型 T 的字节码
+		Table table = clazz.getAnnotation(Table.class);
+		if(null == table){
+			logger.error("找不到" + clazz.getSimpleName() + "类的表映射");
+			return -1;
+		}
+		List<Field> fs = fieldFilter(clazz.getDeclaredFields());
+		String sql = createSql(table, fs);
+		logger.info(sql);
+		
+		//每5000条批量入库一次
+		Connection conn = null;
+		PreparedStatement ps = null;
+		try{
+			conn = getConn();
+			conn.setAutoCommit(false);
+			ps = conn.prepareStatement(sql);
+			
+			int fsize = fs.size(), count = 0;
+			for(T t : list){
+				count ++;
+				for(int i = 0; i < fsize; i ++){
+					ps.setObject(i + 1, fs.get(i).get(t));
+				}
+				
+				ps.addBatch();
+				if(count % batchSize == 0){
+					ps.executeBatch();
+					conn.commit();
+                    ps.clearBatch();
+				}
+			}
+			ps.executeBatch();
+			conn.commit();
+		}finally {
+			closeAll(conn, ps, null);
+		}
+		
+		return 0;
+	}
 	public String createSql(Table table, List<Field> fs){
 		String sqlBefore = "insert into " + table.name() + "("
 				,sqlValues = " values(";