充电量月报表

yiming
1 parent c7a85169
Showing 9 changed files with 388 additions and 17 deletions
pom.xml
src/main/java/com/bsth/controller/RefuelController.java
src/main/java/com/bsth/entity/oil/JdlReception.java
src/main/java/com/bsth/repository/RefuelRepository.java
src/main/java/com/bsth/repository/oil/JdlReceptionRepository.java
src/main/java/com/bsth/service/RefuelService.java
src/main/java/com/bsth/service/impl/RefuelServiceImpl.java
src/main/java/com/bsth/util/ExcelUtil.java
src/main/resources/static/pages/forms/statement/refuelDcMouth.html
@@ -279,11 +279,11 @@
 		</dependency>
-		<dependency>
+		<!--<dependency>
 			<groupId>ojdbc</groupId>
 			<artifactId>ojdbc</artifactId>
 			<version>14</version>
-		</dependency>
+		</dependency>-->
 		<dependency>
 			<groupId>org.apache.mina</groupId>
@@ -15,6 +15,8 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.multipart.MultipartFile;
+import javax.servlet.http.HttpServletResponse;
+
 /**
  * Created in 19/9/3.
  */
@@ -83,5 +85,14 @@ public class RefuelController extends BaseController&lt;Refuel, Long&gt; {
 	private String getDataImportClasspath(){
 		return this.getClass().getResource("/").getPath() + "/static/pages/forms";
 	}
-	
+
+	@RequestMapping(value = "/queryDcMouth", method = RequestMethod.GET)
+	public Map<String,Object> queryDcMouth(@RequestParam Map<String, String> map){
+		return refuelService.queryDcMouth(map);
+	}
+
+	@RequestMapping(value = "/queryDcMouthExport" , method = RequestMethod.GET)
+	public Map<String, Object> queryDcMouthExport(@RequestParam Map<String, String> map, HttpServletResponse resp) {
+		return refuelService.queryDcMouthExport(map, resp);
+	}
 }
@@ -68,7 +68,41 @@ public class JdlReception {
 	private String updateBy;
 	@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
 	private Date updateDate;
-	
+	public static String[] parks = {"一期","二三期","青浦新城","商榻","大盈浦路","P23","重固","东站","漕盈路","朱家角","练塘","G1503","华新"};
+
+	public static String getParkName(String str) {
+		if ("特来电上海青浦巴士公交充电站".equals(str)) {
+			return "一期";
+		} else if ("上海青浦公交二期充电站".equals(str)) {
+			return "二三期";
+		} else if ("特来电上海青浦盈港公交停保场三期充电项目".equals(str)) {
+			return "二三期";
+		} else if ("特来电上海青浦新城一站公交停保场充电站".equals(str)) {
+			return "青浦新城";
+		} else if ("特来电上海青浦商榻汽车站充电项目".equals(str)) {
+			return "商榻";
+		} else if ("特来电上海青浦大盈浦路公交枢纽充电站".equals(str)) {
+			return "大盈浦路";
+		} else if ("P23公交场站".equals(str)) {
+			return "P23";
+		} else if ("重固公交站2期".equals(str)) {
+			return "重固";
+		} else if ("青浦区长途客运充电站".equals(str)) {
+			return "东站";
+		} else if ("青浦区漕盈路公交枢纽充电站".equals(str)) {
+			return "漕盈路";
+		} else if ("特来电上海青浦朱家角公交枢纽充电站".equals(str)) {
+			return "朱家角";
+		} else if ("特来电上海青浦练塘公交枢纽充电站".equals(str)) {
+			return "练塘";
+		} else if ("明仕电站青浦中心站".equals(str)) {
+			return "G1503";
+		} else if ("特来电上海青浦华新枢纽公交站".equals(str)) {
+			return "华新";
+		} else {
+			return "";
+		}
+	}
 	public Long getId() {
 		return id;
@@ -214,5 +248,9 @@ public class JdlReception {
 	public void setUpdateDate(Date updateDate) {
 		this.updateDate = updateDate;
 	}
-	
+
+	public String getParkName() {
+		return getParkName(this.stationName);
+	}
+
 }
 \ No newline at end of file
@@ -66,5 +66,9 @@ public interface RefuelRepository extends BaseRepository&lt;Refuel, Long&gt; {
 	@Query(value="select s from Cars s where s.hydrogen=?1")
 	List<Cars> findCarsByHydrogen(Boolean hydrogen);
+
+	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
+	@Query(value="select DISTINCT s from ScheduleRealInfo s where s.scheduleDateStr >= ?1 and s.scheduleDateStr <= ?2")
+	List<ScheduleRealInfo> scheduleByDate(String dateS, String dateE);
 }
@@ -16,4 +16,8 @@ public interface JdlReceptionRepository extends PagingAndSortingRepository&lt;JdlRe
 	@Query(value="SELECT j FROM JdlReception j where j.dateStr = ?1 and j.carCode like ?2 order by j.createDate")
 	List<JdlReception> queryListByDateStrAndCar(String dateStr,String car);
+
+	@Query(value="SELECT j FROM JdlReception j where j.dateStr >=?1 and j.dateStr <=?2")
+	List<JdlReception> queryListByDateStr(String dateS,String dateE);
+
 }
 \ No newline at end of file
@@ -6,6 +6,8 @@ import java.util.Map;
 import com.bsth.entity.Refuel;
+import javax.servlet.http.HttpServletResponse;
+
 /**
  * Created in 19/9/3.
  */
@@ -30,4 +32,8 @@ public interface RefuelService extends BaseService&lt;Refuel, Long&gt; {
 	List<Map<String, Object>> exportQueryQc(Map<String, Object> map);
 	public String importExcel(File file);
+
+	Map<String,Object> queryDcMouth(Map<String, String> map);
+
+	Map<String, Object> queryDcMouthExport(Map<String,String> map, HttpServletResponse response);
 }
 package com.bsth.service.impl;
+import com.bsth.common.ResponseCode;
 import com.bsth.entity.Cars;
 import com.bsth.entity.Refuel;
 import com.bsth.entity.oil.JdlReception;
@@ -13,22 +14,18 @@ import com.bsth.security.util.SecurityUtils;
 import com.bsth.service.RefuelService;
 import com.bsth.service.report.CulateMileageService;
 import com.bsth.util.Arith;
+import com.bsth.util.ExcelUtil;
 import com.bsth.util.ReportUtils;
 import java.io.File;
 import java.io.FileInputStream;
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.text.DecimalFormat;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+import java.util.*;
+import java.util.stream.Collectors;
 import org.apache.poi.hssf.usermodel.HSSFCell;
 import org.apache.poi.hssf.usermodel.HSSFRow;
@@ -38,6 +35,8 @@ import org.apache.poi.poifs.filesystem.POIFSFileSystem;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import javax.servlet.http.HttpServletResponse;
+
 /**
  * Created in 19/9/3.
  */
@@ -1473,5 +1472,160 @@ public class RefuelServiceImpl extends BaseServiceImpl&lt;Refuel, Long&gt; implements 
         BigDecimal b2 = new BigDecimal(v2.toString());
         return b1.add(b2).toString();
     }
-	
+
+
+	public Map<String,Object> queryDcMouth(Map<String,String> map){
+		Map<String,Object> resultMap=new HashMap<>();
+		if(map.get("dateS") == null || map.get("dateE") == null){
+			return resultMap;
+		}
+		List<Map<String, Object>> result = new ArrayList<>();
+		String dateS=map.get("dateS");
+		String dateE=map.get("dateE");
+		List<JdlReception> jdlReceptions=jdlReceptionRepository.queryListByDateStr(dateS,dateE);
+		Set<String> carSet = new HashSet<>();
+		Set<String> stationSet = new HashSet<>();
+		Map<String,String> carPlate = new HashMap<>();
+		for (JdlReception jdlReception : jdlReceptions) {
+			if(jdlReception.getCarCode()!=null && !"".equals(jdlReception.getCarCode())){
+				carSet.add(jdlReception.getCarCode());
+				carPlate.put(jdlReception.getCarCode(),jdlReception.getCarPlate());
+			}
+			if(jdlReception.getStationName()!=null && !"".equals(jdlReception.getStationName())){
+				stationSet.add(jdlReception.getStationName());
+			}
+		}
+
+		List<String> cars = new ArrayList<>(carSet);
+		List<String> stations = Arrays.asList(JdlReception.parks);
+		//路单分组
+		List<ScheduleRealInfo> realInfos=repository.scheduleByDate(dateS,dateE);
+		Map<String,List<ScheduleRealInfo>> sMap=realInfos.stream().collect(Collectors.groupingBy(ScheduleRealInfo::getClZbh));
+
+		//给每个站充电量赋默认值
+		Map<String, Map<String, Double>> matrix = new LinkedHashMap<>();
+		for (String car : cars) {
+			Map<String, Double> stationMap = new HashMap<>();
+			for (String station : stations) {
+				stationMap.put(station, 0.00);
+			}
+			matrix.put(car, stationMap);
+		}
+
+		//计算实际充电量
+		for (JdlReception data : jdlReceptions) {
+			String car = data.getCarCode();
+			String station = data.getParkName();
+			Double capacity = data.getChargeCapacity();
+
+			if (car != null && station != null && capacity != null) {
+				Map<String, Double> stationMap = matrix.get(car);
+				if (stationMap != null && !station.equals("")) {
+					Double current = stationMap.getOrDefault(station, 0.00);
+					stationMap.put(station, Arith.add(current, capacity));
+				}
+			}
+		}
+
+		//数据统计
+		for (String car : cars) {
+			Map<String, Object> row = new LinkedHashMap<>();
+			row.put("plate", carPlate.get(car));
+			row.put("car", car);
+			String realMileage ="0";
+			List<ScheduleRealInfo> list = sMap.get(car);
+			if(list!=null){
+				List<ScheduleRealInfo> list_s = new ArrayList<>(); // 实际路单（已完成班次与烂班班次等）
+				for(ScheduleRealInfo s : list){
+					Set<ChildTaskPlan> cts = s.getcTasks();
+					if(cts != null && cts.size() > 0){
+						list_s.add(s);
+					}else{
+						if(s.getZdsjActual()!=null&& s.getFcsjActual()!=null){
+							list_s.add(s);
+						}
+					}
+				}
+
+				//计算总公里
+				Double sjgl = culateMileageService.culateSjgl(list_s);//实际
+				Double ksgl = culateMileageService.culateKsgl(list_s);//空驶
+				Double jccgl = culateMileageService.culateJccgl(list_s);//进出场
+				Double ljgl = culateMileageService.culateLjgl(list_s);//临加
+				realMileage = add(add(sjgl, ksgl), add(jccgl, ljgl));
+			}
+			row.put("zgl", realMileage);
+
+			//按序存入充电数据 方便动态列
+			List<Double> refuels=new ArrayList<>(Collections.nCopies(stations.size(), new Double(0)));
+			Map<String, Double> stationMap = matrix.get(car);
+			for (int i = 0; i < stations.size(); i++) {
+				Double total = stationMap.get(stations.get(i));
+				refuels.set(i,total);
+				row.put("refuels", refuels);
+			}
+
+			//计算充电合计
+			Double carTotal = stationMap.values().stream().reduce(0.00,Double::sum);
+			BigDecimal total=new BigDecimal(carTotal).setScale(3, RoundingMode.HALF_UP);
+			row.put("total", total.doubleValue());
+
+			//计算百公里电耗
+			BigDecimal bgl= new BigDecimal(0);
+			if(Double.parseDouble(realMileage)!=0){
+				bgl=total.divide(new BigDecimal(realMileage), 4, RoundingMode.HALF_UP).multiply(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP);
+			}
+			row.put("bgl", bgl);
+			result.add(row);
+		}
+		resultMap.put("data",result);
+		resultMap.put("stations",stations);
+		return resultMap;
+	}
+
+	public Map<String, Object> queryDcMouthExport(Map<String,String> map, HttpServletResponse response){
+		Map<String, Object> resultMap = new HashMap<>();
+		try {
+			Map<String, Object> params=new HashMap<>();
+			Map<String,Object> result=queryDcMouth(map);
+			List<String> titleList = new ArrayList<>();
+			titleList.add("序号");
+			titleList.add("车牌");
+			titleList.add("自编号");
+			titleList.add("充电合计");
+			titleList.add("公里");
+			titleList.add("度/百公里");
+			List<String> stations = (List<String>) result.get("stations");
+			for (String station : stations) {
+				titleList.add(station);
+			}
+			params.put("title",titleList);
+
+			Map<String,List<String>> content = new HashMap<>();
+			List<Map<String, Object>> datas = (List<Map<String, Object>>) result.get("data");
+			for (int i = 1; i <= datas.size(); i++) {
+				Map<String, Object> d=datas.get(i-1);
+				List<String> list=new ArrayList<>();
+				list.add(String.valueOf(i));
+				list.add(String.valueOf(d.get("plate")));
+				list.add(String.valueOf(d.get("car")));
+				list.add(String.valueOf(d.get("total")));
+				list.add(String.valueOf(d.get("zgl")));
+				list.add(String.valueOf(d.get("bgl")));
+				List<Double> refuels= (List<Double>) d.get("refuels");
+				for (Double refuel : refuels) {
+					list.add(String.valueOf(refuel));
+				}
+				content.put(String.valueOf(i),list);
+			}
+			params.put("content",content);
+			ExcelUtil.buildExcelDocument(params,"充电量月报表",response);
+			resultMap.put("status", ResponseCode.SUCCESS);
+		} catch (Exception e) {
+			resultMap.put("status", ResponseCode.ERROR);
+			logger.error("save erro.", e);
+		}
+		return resultMap;
+	}
+
 }
@@ -26,7 +26,7 @@ import org.apache.poi.hssf.util.HSSFColor;
 public class ExcelUtil {
-	public void buildExcelDocument(Map<String, Object> map, String exportName, HttpServletResponse response) throws Exception {
+	public static void buildExcelDocument(Map<String, Object> map, String exportName, HttpServletResponse response) throws Exception {
 		// 声明一个工作薄
 	      HSSFWorkbook workbook = new HSSFWorkbook();
 	    /*  // 生成一个表格
@@ -64,13 +64,13 @@ public class ExcelUtil {
 		//创建第一行
 		HSSFRow row = sheet.createRow(0);
 		//设置 ABCD列名
-		sheet.autoSizeColumn((short)0);
+
 		for(int i=0;i<titleList.size();i++){
 			row.createCell(i).setCellValue(titleList.get(i));
 			row.setRowStyle(cellStyle);
 		}
+		sheet.autoSizeColumn((short)0);
 		for(int i=1;i<=content.size();i++){
-			sheet.autoSizeColumn((short)i); //调整第一列宽度
 			HSSFRow row_ = sheet.createRow(i);
 			List<String> temp = content.get(i+"");
 			for(int j=0;j<temp.size();j++){
+<style type="text/css">
+	.table-bordered {
+	  border: 1px solid; }
+	  .table-bordered > thead > tr > th,
+	  .table-bordered > thead > tr > td,
+	  .table-bordered > tbody > tr > th,
+	  .table-bordered > tbody > tr > td,
+	  .table-bordered > tfoot > tr > th,
+	  .table-bordered > tfoot > tr > td {
+	    border: 1px solid; }
+	  .table-bordered > thead > tr > th,
+	  .table-bordered > thead > tr > td {
+	    border-bottom-width: 2px; }
+	 
+	  .table > tbody + tbody {
+	   border-top: 1px solid; }
+	  .btn-default{
+	   margin-left: 5px;
+	  }
+</style>
+
+<div class="page-head">
+	<div class="page-title">
+		<h1>充电量月报表</h1>
+	</div>
+</div>
+
+<div class="row">
+	<div class="col-md-12">
+		<div class="portlet light porttlet-fit bordered">
+			<div class="portlet-title">
+				<form class="form-inline" action="">
+					<div style="display: inline-block;margin-left: 15px;">
+						<span class="item-label" style="width: 80px;">开始时间: </span>
+						<input class="form-control" type="text" id="dateS" style="width: 180px;"/>
+						<span class="item-label" style="width: 80px;">结束时间: </span>
+						<input class="form-control" type="text" id="dateE" style="width: 180px;"/>
+					</div>
+                    <div class="form-group">
+                        <input class="btn btn-default" type="button" id="query" value="筛选"/>
+						<input class="btn btn-default" type="button" id="export" value="导出"/>
+                    </div>
+				</form>
+			</div>
+			<div class="portlet-body">
+				<div class="table-container" style="margin-top: 10px;overflow:auto;min-width: 906px">
+					<table class="table table-bordered table-hover table-checkable" id="forms">
+						<thead>
+							<tr>
+								<td width="3%">序号</td>
+								<td width="7%">车牌</td>
+								<td width="7%">自编号</td>
+								<td>充电合计</td>
+								<td>公里</td>
+								<td id="bgl">度/百公里</td>
+							</tr>
+						</thead>
+						<tbody id="tbody">
+							
+						</tbody>
+					</table>
+				</div>
+			</div>
+		</div>
+	</div>
+</div>
+
+<script>
+	$(function(){
+		
+		// 关闭左侧栏
+		if (!$('body').hasClass('page-sidebar-closed'))
+			$('.menu-toggler.sidebar-toggler').click();
+
+		//日期插件
+		$("#dateS").datetimepicker({
+			format : 'YYYY-MM',
+			locale : 'zh-cn'
+		});
+		$("#dateE").datetimepicker({
+			format : 'YYYY-MM',
+			locale : 'zh-cn'
+		});
+
+		//重置
+        $('#czcl').on('click', function () {
+            $('#code').val('').change();
+        });
+		
+
+	$("#query").on("click",function(){
+		var dateS = $("#dateS").val();
+		var dateE = $("#dateE").val();
+		if(dateS==""||dateS==null||dateE==""||dateE==null){
+			layer.msg('请选择日期.');
+			return;
+		}
+		dateS+="-01"
+		dateE+="-31"
+		var i = layer.load(2);
+		$get('/refuel/queryDcMouth',{dateS:dateS,dateE:dateE,type:'query'},function(result){
+			const tr = document.querySelector('tr');
+			const dynamicCols = tr.querySelectorAll('.dynamic-col');
+			dynamicCols.forEach(col => col.remove());
+			const totalTd = document.getElementById('bgl');
+			// 生成所有新的td元素HTML
+			const newTdsHTML = result.stations.map(item =>
+					`<td class="dynamic-col">${item}</td>`
+			).join('');
+			// 在总计td后插入
+			totalTd.insertAdjacentHTML('afterend', newTdsHTML);
+
+			// 把数据填充到模版中
+			var tbodyHtml = template('refuel_dc',{list:result.data});
+			// 把渲染好的模版html文本追加到表格中
+			$('#tbody').html(tbodyHtml);
+			layer.close(i);
+		});
+	});
+	
+	$("#export").on("click",function(){
+		var dateS = $("#dateS").val();
+		var dateE = $("#dateE").val();
+		if(dateS==""||dateS==null||dateE==""||dateE==null){
+			layer.msg('请选择日期.');
+			return;
+		}
+		dateS+="-01"
+		dateE+="-31"
+		window.open('/refuel/queryDcMouthExport?dateS='+dateS+'&dateE='+dateE);
+	});
+	
+});
+</script>
+<script type="text/html" id="refuel_dc">
+	{{each list as obj i}}
+		<tr>
+			<td>{{i + 1}}</td>
+			<td>{{obj.plate}}</td>
+			<td>{{obj.car}}</td>
+			<td>{{obj.total}}</td>
+			<td>{{obj.zgl}}</td>
+			<td>{{obj.bgl}}</td>
+			{{each obj.refuels as refuel j}}
+				<td>{{refuel}}</td>
+			{{/each}}
+		</tr>
+	{{/each}}
+	{{if list.length == 0}}
+		<tr>1
+			<td colspan="17"><h6 class="muted">没有找到相关数据</h6></td>
+		</tr>
+	{{/if}}
+</script>
 \ No newline at end of file