充电量接口接入到集调的表中

娄高锋
1 parent dbcc28c9
Showing 2 changed files with 70 additions and 15 deletions
src/main/java/com/bsth/repository/ScheduleRealInfoRepository.java
src/main/java/com/bsth/server_rs/electric/ElectricService.java
@@ -92,4 +92,10 @@ public interface ScheduleRealInfoRepository extends PagingAndSortingRepository&lt;S
 	@Query(value = " select bc_type from bsth_c_s_sp_info where id = ?1 ", nativeQuery = true)
 	List<String> findoOriginalType(Long spId);
+	@Query("select s from ScheduleRealInfo s where s.clZbh = ?1 and s.scheduleDateStr = ?2 and s.realExecDate = ?3 order by fcsj asc")
+	List<ScheduleRealInfo> getFirstByClZbhAndScheduleDateStrAndRealExecDateOrderByFcsjAsc(String clZbh, String scheduleDateStr, String realExecDate);
+	
+	@Query("select s from ScheduleRealInfo s where s.clZbh = ?1 and s.scheduleDateStr >= ?2 and s.scheduleDateStr <= ?3 order by scheduleDateStr desc")
+	List<ScheduleRealInfo> getFirstByClZbhAndScheduleDateStrBetweenOrderByScheduleDateStrDesc(String clZbh, String scheduleDateStr1, String scheduleDateStr2);
+	
 }
@@ -2,7 +2,9 @@ package com.bsth.server_rs.electric;
 import com.alibaba.fastjson.JSONObject;
 import com.bsth.entity.JdlReception;
+import com.bsth.entity.ScheduleRealInfo;
 import com.bsth.repository.JdlReceptionRepository;
+import com.bsth.repository.ScheduleRealInfoRepository;
 import com.bsth.server_ws.electric_oil.entity.Electric;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -19,6 +21,7 @@ import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
+import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
@@ -39,6 +42,9 @@ public class ElectricService {
     @Autowired
     JdlReceptionRepository jdlReceptionRepository;
+    
+    @Autowired
+    ScheduleRealInfoRepository scheduleRealInfoRepository;
     @GET
     @Path("/{company}/{rq}")
@@ -61,25 +67,68 @@ public class ElectricService {
 	public Map<String, Object> orderDataEnter(@RequestBody JSONObject body){
 		Map<String, Object> resMap = new HashMap<String, Object>();
         try {
+        	System.out.println(body);
+			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+			SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			
+			String startTime = body.getString("startTime");
+			String endTime = body.getString("endTime");
+			
 			JdlReception jdlReception = new JdlReception();
-			jdlReception.setStationName(body.getString("StationName"));
-			jdlReception.setConnectorId(body.getString("ConnectorID"));
-			jdlReception.setOrderNo(body.getString("OrderNo"));
-			jdlReception.setStartTime(body.getString("StartTime"));
-			jdlReception.setEndTime(body.getString("EndTime"));
-			jdlReception.setStartSoc(body.getDouble("StartSoc"));
-			jdlReception.setEndSoc(body.getDouble("EndSoc"));
-			jdlReception.setStopReason(body.getString("StopReason"));
-			jdlReception.setChargeCapacity(body.getDouble("ChargeCapacity"));
-			jdlReception.setElectricCharge(body.getDouble("ElectricCharge"));
-			jdlReception.setServiceCharge(body.getDouble("ServiceCharge"));
-			jdlReception.setTotalAmount(body.getDouble("TotalAmount"));
-			jdlReception.setVinCode(body.getString("VinCode"));
-			jdlReception.setCardNo(body.getString("CardNo"));
-			jdlReception.setCarCode(body.getString("CarCode"));
+			jdlReception.setStationName(body.getString("stationName"));
+			jdlReception.setConnectorId(body.getString("connectorId"));
+			jdlReception.setOrderNo(body.getString("orderNo"));
+			jdlReception.setStartTime(startTime);
+			jdlReception.setEndTime(endTime);
+			jdlReception.setStartSoc(body.getDouble("startSoc"));
+			jdlReception.setEndSoc(body.getDouble("endSoc"));
+			jdlReception.setStopReason(body.getString("stopReason"));
+			jdlReception.setChargeCapacity(body.getDouble("chargeCapacity"));
+			jdlReception.setElectricCharge(body.getDouble("electricCharge"));
+			jdlReception.setServiceCharge(body.getDouble("serviceCharge"));
+			jdlReception.setTotalAmount(body.getDouble("totalAmount"));
+			jdlReception.setVinCode(body.getString("vinCode"));
+			jdlReception.setCardNo(body.getString("cardNo"));
+			jdlReception.setCarCode(body.getString("carCode"));
 			jdlReception.setOrigin(0);
 			jdlReception.setCreateBy("接口接入");
 			jdlReception.setCreateDate(new Date());
+			String carCode = body.getString("carCode");
+			
+			String startDate = startTime.split(" ")[0];
+//			String startCTime = startTime.split(" ")[1];
+
+			//根据充电开始时间保存到调度系统的充电量的表中,逻辑为根据充电开始时间来根据该车辆最后营运班次所在线路的次日首班车发车时间前
+			//比如这条记录的开始时间,日期是15号,按15号查路单,拿一个最早的发车时间,开始充电时间比这个发车时间早的算前一天
+			List<ScheduleRealInfo> scheduleRealInfo = scheduleRealInfoRepository.getFirstByClZbhAndScheduleDateStrAndRealExecDateOrderByFcsjAsc(carCode, startDate, startDate);
+
+			String searchDate;
+			//如果存在路单,则作为当天的数据,保存到开始充电时间那一天,如果不存在路单,则直接作为前一天的数据保存
+			if (scheduleRealInfo != null && scheduleRealInfo.size() > 0) {
+//				log.info("存在路单,作为当天的数据保存");
+				//保存到当天的数据
+				searchDate = startDate;
+			} else {
+//				log.info("不存在路单,直接作为前一天的数据保存");
+//				String oldDate = DateUtils.getBeforeDate(30, DateUtils.parseDate(startDate));
+				Date parse = sdf.parse(startDate);
+				parse.setTime(parse.getTime() - (30l*1000*60*60*24));
+				String oldDate = sdf.format(parse);
+				List<ScheduleRealInfo> scheduleRealInfo1 = scheduleRealInfoRepository.getFirstByClZbhAndScheduleDateStrBetweenOrderByScheduleDateStrDesc(carCode, oldDate, startDate);
+				if (scheduleRealInfo1 != null && scheduleRealInfo1.size() > 0) {
+					//DateUtils.getBeforeDate(1, DateUtils.parseDate(startDate));
+					searchDate = oldDate;
+				} else {
+					//如果是新车，则作为当天的数据
+					searchDate = startDate;
+				}
+			}
+
+			Date startTime_Date = df.parse(startTime);
+			Date endTime_Date = df.parse(endTime);
+			jdlReception.setDateStr(searchDate);
+			jdlReception.setSumTime(Integer.valueOf(((endTime_Date.getTime() - startTime_Date.getTime()) / 60000)+""));
+			
 			jdlReceptionRepository.save(jdlReception);
 			resMap.put("Status", 0);