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

娄高锋
1 parent 73f9bcc9
Showing 1 changed file with 39 additions and 22 deletions
src/main/java/com/bsth/server_rs/electric/ElectricService.java
 package com.bsth.server_rs.electric;
 import com.alibaba.fastjson.JSONObject;
+import com.bsth.entity.JdlReception;
+import com.bsth.repository.JdlReceptionRepository;
 import com.bsth.server_ws.electric_oil.entity.Electric;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -8,9 +10,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jdbc.core.BeanPropertyRowMapper;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.RequestBody;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
 import javax.ws.rs.GET;
 import javax.ws.rs.POST;
 import javax.ws.rs.Path;
@@ -18,8 +19,8 @@ import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
-import java.io.BufferedReader;
-import java.io.InputStreamReader;
+import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -35,6 +36,9 @@ public class ElectricService {
     @Autowired
     JdbcTemplate jdbcTemplate;
+    
+    @Autowired
+    JdlReceptionRepository jdlReceptionRepository;
     @GET
     @Path("/{company}/{rq}")
@@ -47,33 +51,46 @@ public class ElectricService {
             list = jdbcTemplate.query("select fgsdm as fgs_bm,c.business_name as fgs_name,ssgsdm as gs_bm,b.business_name as gs_name,cdl as jdl,'' as jdz,'' as remarks,rq,createtime as create_date,nbbm,'' as jsy from (select fgsdm,ssgsdm,sum(cdl * 1000) / 1000 as cdl,rq,max(createtime) as createtime,nbbm from bsth_c_dlb where rq = ? GROUP BY fgsdm,ssgsdm,rq,nbbm) a left join bsth_c_business b on a.ssgsdm = b.business_code LEFT JOIN bsth_c_business c on concat(a.ssgsdm, '_', a.fgsdm) = concat(c.up_code, '_', c.business_code) where ssgsdm = ?"
             		, new Object[]{ rq, company }, BeanPropertyRowMapper.newInstance(Electric.class));
         }catch (Exception e){
-            logger.error("", e);
+            logger.error("ElectricService", e);
         }
         return list;
     }
 	@POST
-	@Path("/charge")
-	public void charge(HttpServletRequest request, HttpServletResponse response){
+	@Path("/orderDataEnter")
+	public Map<String, Object> orderDataEnter(@RequestBody JSONObject body){
+		Map<String, Object> resMap = new HashMap<String, Object>();
         try {
-            request.setCharacterEncoding("UTF-8");
-            response.setContentType("application/json; charset=UTF-8");
-			// 读取请求体
-			StringBuilder sb = new StringBuilder();
-			String line;
-			BufferedReader reader = new BufferedReader(new InputStreamReader(request.getInputStream()));
-			while ((line = reader.readLine()) != null) {
-			    sb.append(line);
-			}
-			reader.close();
-			// 处理消息主体
-			String messageBody = sb.toString();
-			JSONObject body = JSONObject.parseObject(messageBody);
-//			JSONObject data = body.getJSONObject("Data");
+			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.setOrigin(0);
+			jdlReception.setCreateBy("接口接入");
+			jdlReception.setCreateDate(new Date());
+			jdlReceptionRepository.save(jdlReception);
+			resMap.put("Status", 0);
+			resMap.put("msg", "成功");
 		}catch (Exception e){
-			logger.error("", e);
+			logger.error("ElectricService.orderDataEnter", body);
+			logger.error("ElectricService.orderDataEnter", e);
+			resMap.put("Status", 1);
+			resMap.put("Msg", "内部错误");
 		}
+        return resMap;
 	}
 }