大间隔统计表（大间隔发生次数汇总表）

娄高锋
1 parent 9e15d4d9
Showing 3 changed files with 158 additions and 0 deletions
src/main/java/com/bsth/controller/calc/CalcIntervalController.java
src/main/java/com/bsth/service/calc/CalcIntervalService.java
src/main/java/com/bsth/service/calc/impl/CalcIntervalServiceImpl.java
@@ -41,5 +41,11 @@ public class CalcIntervalController  extends BaseController&lt;CalcInterval,Integer
 		return list;
 	}
+	@RequestMapping(value="/sumInterval")
+	public List<Map<String,Object>> sumInterval(@RequestParam Map<String, Object> map){
+		List<Map<String, Object>> list=calcIntervalService.sumInterval(map);
+		return list;
+	}
+	
 }
@@ -17,5 +17,7 @@ public interface CalcIntervalService extends BaseService&lt;CalcInterval,Integer&gt; {
 	 List<Map<String,Object>> interval(Map<String, Object> map);
 	 //根据预统计表查询
 	 List<Map<String,Object>> intervalDetail(Map<String, Object> map);
+	 //大间隔统计表（大间隔发生次数统计表）
+	 List<Map<String,Object>> sumInterval(Map<String, Object> map);
 }
 package com.bsth.service.calc.impl;
+import java.math.BigDecimal;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.text.DecimalFormat;
@@ -34,8 +35,10 @@ import com.bsth.repository.realcontrol.ScheduleRealInfoRepository;
 import com.bsth.service.LineService;
 import com.bsth.service.calc.CalcIntervalService;
 import com.bsth.service.impl.BaseServiceImpl;
+import com.bsth.util.Arith;
 import com.bsth.util.ComparableReal;
 import com.bsth.util.ReportUtils;
+import com.mysql.fabric.xmlrpc.base.Array;
 @Service
 public class CalcIntervalServiceImpl extends BaseServiceImpl<CalcInterval,Integer> implements CalcIntervalService {
@@ -696,6 +699,153 @@ public class CalcIntervalServiceImpl extends BaseServiceImpl&lt;CalcInterval,Intege
     	return minSj;
     }
+	public List<Map<String, Object>> sumInterval(Map<String, Object> map) {
+		// TODO Auto-generated method stub
+    	final DecimalFormat df = new DecimalFormat("0.00");
+		List<Map<String, Object>> list=new ArrayList<>();
+		String gs=map.get("gs").toString().trim();
+		String fgs=map.get("fgs").toString().trim();
+		String sDate=map.get("date").toString();
+		String eDate=map.get("endDate").toString();
+//		String nature=map.get("nature").toString();
+		
+        List<Map<String, Object>> listAll=new ArrayList<Map<String, Object>>();
+        
+        String sql="select gsbm,fgsbm,level,djg_all,bcs"
+    			+ " from bsth_c_calc_interval where date>= '"+sDate+"' and date<='"+eDate+"'"
+    			+ " and level is not null and level <> '' ";
+		if(gs.length() > 0){
+			if(fgs.length() > 0){
+				sql +=" and gsbm = '"+gs+"' and fgsbm = '"+fgs+"'";
+			} else {
+				sql +=" and gsbm = '"+gs+"'";
+			}
+		}
+		sql += " order by gsbm,fgsbm,level";
+    			
+		List<Map<String, Object>> countList=jdbcTemplate.query(sql, 
+				 new RowMapper<Map<String,Object>>(){
+			 @Override 
+			 public Map<String, Object>  mapRow(ResultSet rs, int rowNum) throws SQLException { 
+				 Map<String, Object> m=new HashMap<String,Object>();
+				 m.put("gs", BasicData.businessCodeNameMap.get(rs.getString("gsbm")));
+				 m.put("fgs", BasicData.businessFgsCodeNameMap.get(rs.getString("fgsbm")+"_"+rs.getString("gsbm")));
+				 m.put("level", rs.getString("level"));
+				 m.put("djgAll", rs.getInt("djg_all"));
+				 m.put("bcs", rs.getInt("bcs"));
+				 return m;
+			 }
+		});
+        
+        List<String> keyList = new ArrayList<String>();
+        Map<String, Map<String, Object>> keyMap = new HashMap<String, Map<String, Object>>();
+        Map<String, Object> sumMap1 = new HashMap<String, Object>();
+        Map<String, Object> sumMap2 = new HashMap<String, Object>();
+        sumMap1.put("fgs", "合计");	//分公司合计
+        sumMap1.put("djgNum", "0");
+        sumMap1.put("bcs", "0");
+        sumMap2.put("gs", "合计");	//公司合计
+        sumMap2.put("djgNum", "0");
+        sumMap2.put("bcs", "0");
+        for(Map<String, Object> m : countList){
+        	String gsName = m.get("gs").toString();
+        	String fgsName = m.get("fgs").toString();
+        	String level = m.get("level").toString();
+        	String key = gsName + "^" + fgsName + "/" + level;
+        	Map<String, Object> temp = new HashMap<String, Object>();
+        	if(keyList.size() == 0){
+        		sumMap1.put("gs", gsName);
+        	}
+        	if(!(keyMap.containsKey(key))){
+        		if(keyList.size() > 0 && !(keyList.get(keyList.size() - 1).split("/")[0].equals(key.split("/")[0]))){
+        			keyList.add(sumMap1.get("gs").toString() + "^合计_" + fgsName);
+        			keyMap.put(sumMap1.get("gs").toString() + "^合计_" + fgsName, sumMap1);
+        			sumMap1 = new HashMap<String, Object>();
+            		sumMap1.put("gs", gsName);
+        			sumMap1.put("fgs", "合计");
+        	        sumMap1.put("djgNum", "0");
+        	        sumMap1.put("bcs", "0");
+        		}
+        		temp.put("gs", gsName);
+        		temp.put("fgs", fgsName);
+        		temp.put("level", level);
+        		temp.put("djgNum", "0");
+        		temp.put("bcs", "0");
+        		keyList.add(key);
+        		keyMap.put(key, temp);
+        	} else {
+        		temp = keyMap.get(key);
+        	}
+        	if(m.get("djgAll") != null && m.get("djgAll").toString().trim().length() > 0){
+	        	temp.put("djgNum", Arith.add(temp.get("djgNum"), m.get("djgAll")));
+	        	sumMap1.put("djgNum", Arith.add(sumMap1.get("djgNum"), m.get("djgAll")));
+	        	sumMap2.put("djgNum", Arith.add(sumMap2.get("djgNum"), m.get("djgAll")));
+        	}
+        	if(m.get("bcs") != null && m.get("bcs").toString().trim().length() > 0){
+	        	temp.put("bcs", Arith.add(temp.get("bcs"), m.get("bcs")));
+	        	sumMap1.put("bcs", Arith.add(sumMap1.get("bcs"), m.get("bcs")));
+	        	sumMap2.put("bcs", Arith.add(sumMap2.get("bcs"), m.get("bcs")));
+        	}
+        }
+		keyList.add((sumMap1.get("gs")!=null?sumMap1.get("gs").toString():"") + "^合计_");
+		keyMap.put((sumMap1.get("gs")!=null?sumMap1.get("gs").toString():"") + "^合计_", sumMap1);
+		keyList.add("合计");
+		keyMap.put("合计", sumMap2);
+		
+		for(String key : keyList){
+			Map<String, Object> m = keyMap.get(key);
+			double djgAll = new BigDecimal(m.get("djgNum").toString()).doubleValue();
+			double bcs = new BigDecimal(m.get("bcs").toString()).doubleValue();
+			//万班次发生率 （大间隔次数/全日班次数*10000）
+			if(bcs > 0){
+				double fsl = djgAll / bcs * 10000;
+				m.put("fsl", df.format(fsl));
+			} else {
+				m.put("fsl", "0.0");
+			}
+			listAll.add(m);
+		}
+		
+		if(map.get("type").equals("export")){
+			String lineName="";
+			if(listAll.size()>0){
+				if(fgs.equals("")){
+					lineName=listAll.get(0).get("gs").toString();
+				}else{
+					lineName=listAll.get(0).get("fgs").toString();
+				}
+			}
+			List<Iterator<?>> listI = new ArrayList<Iterator<?>>();
+			Map<String, Object> m = new HashMap<String, Object>();
+			
+			ReportUtils ee = new ReportUtils();
+			try {
+				String dateTime = "";
+				if(sDate.equals(eDate)){
+					dateTime = sDate.replaceAll("-", "");
+				} else {
+					dateTime = sDate.replaceAll("-", "")+"-"+
+							eDate.replaceAll("-", "");
+				}
+				listI.add(listAll.iterator());
+				String path = this.getClass().getResource("/").getPath() + "static/pages/forms/";
+				String xls="";
+				String xlsName="";
+				m.put("sDate", sDate);
+				m.put("eDate", eDate);
+				xls="calcIntervalCount.xls";
+				xlsName="大间隔情况表.xls";
+				
+				ee.excelReplace(listI, new Object[]{m}, path + "mould/" + ""+xls,
+						path + "export/"+dateTime+"-"+lineName+"-"+xlsName);
+			} catch (Exception e) {
+				// TODO: handle exception
+				e.printStackTrace();
+			}
+		}
+		return listAll;
+	}
+	
 }
 class ComparableJhfc implements Comparator<ScheduleRealInfo>{