数据进入数据库

src/main/java/com/logwire/bhft/domain/InterfaceParkingGate.java

@@ -17,12 +17,12 @@ public class InterfaceParkingGate implements Serializable {
     /**
      * id
      */
-    private Object id;
+    private Long id;
 
     /**
      * 请求时间戳
      */
-    private Object requestTime;
+    private Long requestTime;
 
     /**
      * 请求id
@@ -32,7 +32,7 @@ public class InterfaceParkingGate implements Serializable {
     /**
      * 出场请求时间戳
      */
-    private Object exitRequestTime;
+    private Long exitRequestTime;
 
     /**
      * 出场请求id
@@ -57,7 +57,7 @@ public class InterfaceParkingGate implements Serializable {
     /**
      * 进场时间
      */
-    private Object entryTime;
+    private Long entryTime;
 
     /**
      * 入口id
@@ -67,7 +67,7 @@ public class InterfaceParkingGate implements Serializable {
     /**
      * 出场时间
      */
-    private Object exitTime;
+    private Long exitTime;
 
     /**
      * 出口id
@@ -77,7 +77,7 @@ public class InterfaceParkingGate implements Serializable {
     /**
      * 交易时间
      */
-    private Object tradeTime;
+    private Long tradeTime;
 
     /**
      * 费率版本

src/main/java/com/logwire/bhft/listener/TopicReceiveListener.java

@@ -53,6 +53,8 @@ public class TopicReceiveListener {
             parkingGate.setRequestId(infomation.getRequestId());
             parkingGate.setRequestTime(infomation.getRequestTime());
             parkingGate.setSlotId(infomation.getSlotId());
+            parkingGate.setTradeTime(infomation.getTradeTime());
+            parkingGate.setTradeType(infomation.getTradeType());
             parkingGate.setTollRateVersion(infomation.getTollRateVersion());
             parkingGate.setTollCollectorName(infomation.getTollCollectorName());
             parkingGate.setUseType(infomation.getUseType());
@@ -60,7 +62,6 @@ public class TopicReceiveListener {
             parkingGate.setExitFlagNum(infomation.getEntryTime()+infomation.getPlateNo());
 //            parkingGate.setVersion(0);
             parkingGate.setVehicleType(infomation.getVehicleType());
-
             logger.info(infomation.toString());
             logger.info(parkingGate.toString());
 

src/main/java/com/logwire/bhft/service/impl/ParkingGateServiceImpl.java

@@ -46,6 +46,16 @@ public class ParkingGateServiceImpl implements ParkingGateService {
             exitInfo.setExitTime(parkingGate.getExitTime());
             exitInfo.setExitRequestId(parkingGate.getRequestId());
             exitInfo.setExitRequestTime(parkingGate.getRequestTime());
+            exitInfo.setTradeTime(parkingGate.getTradeTime());
+            exitInfo.setTradeType(parkingGate.getTradeType());
+            exitInfo.setAccount(parkingGate.getAccount());
+            exitInfo.setCash(parkingGate.getCash());
+            exitInfo.setTollCollectorName(parkingGate.getTollCollectorName());
+            exitInfo.setUseType(parkingGate.getUseType());
+            exitInfo.setAreaId(parkingGate.getAreaId());
+            exitInfo.setSlotId(parkingGate.getSlotId());
+            exitInfo.setParkingDetail(parkingGate.getParkingDetail());
+
 
             exitInfo.setUpdateUser("interface");
             exitInfo.setUpdateDate(new Date());