[update] 停车事件添加部分数据添加到拓展字段

wj-realtime-computing/src/main/java/com/wanji/indicators/entity/EventInfo.java

@@ -96,7 +96,8 @@ public class EventInfo implements Serializable {
     @ApiModelProperty(value = "入库时间", hidden = true)
     @JSONField(serialize = false)
     private LocalDateTime ruksj;
+    @ApiModelProperty(value = "备注")
     private String remark;
-
-
+    @ApiModelProperty(value = "拓展字段")
+    private String extend;
 }

wj-realtime-computing/src/main/java/com/wanji/indicators/task/citybrainreceive/event/park/LaneParkEventReceiveMap.java

@@ -22,10 +22,7 @@ import java.time.Instant;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
 import java.time.ZonedDateTime;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
 
 /**
  * @author duanruiming
@@ -81,6 +78,12 @@ public class LaneParkEventReceiveMap implements MapFunction<String, List<EventIn
                     }
                     eventInfo.setSource("5");
                     eventInfo.setRemark(ParkTypeEnum.getMsg(laneParkEventVO.getType()) + SpilloverStateEnum.getMsg(laneParkEventVO.getState()));
+                    Map<String, String> map = new HashMap<>();
+                    map.put("vehicleType", laneParkEventVO.getVehicleType());
+                    map.put("vehicleColor", laneParkEventVO.getVehicleColor());
+                    map.put("plateType", laneParkEventVO.getPlateType());
+                    map.put("plateNumber", laneParkEventVO.getPlateType());
+                    eventInfo.setExtend(mapper.writeValueAsString(map));
                     eventInfos.add(eventInfo);
                 }
             }