kafka推送加lineId

yiming
1 parent 1a30b3f9
Showing 2 changed files with 10 additions and 0 deletions
src/main/java/com/example/demo/model/TJRL.java
src/main/java/com/example/demo/service/Contrast.java
@@ -48,6 +48,7 @@ public class TJRL implements Cloneable {
     private String ACTUAL_ARRIVE_TIME;// VARCHAR2(100) Y                实际到达时间实际到达时间
     private String TRAD_ID;
     private String COUNT;//计数器
+    private String lineId;
     public TJRL(){
  
     }
@@ -391,4 +392,12 @@ public class TJRL implements Cloneable {
     public Object clone() throws CloneNotSupportedException {
         return super.clone();
     }
+
+    public String getLineId() {
+        return lineId;
+    }
+
+    public void setLineId(String lineId) {
+        this.lineId = lineId;
+    }
 }
@@ -257,6 +257,7 @@ public class Contrast {
                     }
  
                     if (scheduling!=null) {
+                        data.setLineId(scheduling.getXl_bm());
                         data.setSTATION_FLAG("1");
                         data.setTJRLUNITID(scheduling.getGs_name());
                         data.setTJRLSTATID(scheduling.getXl_name());