加个count计数去除kafka推送

yiming
1 parent 222feac8
Showing 4 changed files with 15 additions and 6 deletions
src/main/java/com/example/demo/model/TJRL.java
src/main/java/com/example/demo/service/Analysis.java
src/main/java/com/example/demo/service/Contrast.java
src/main/resources/mapping/db1/Site-mapper1.xml
@@ -47,7 +47,7 @@ public class TJRL implements Cloneable {
     private String ACTUAL_START_TIME;//  VARCHAR2(100) Y                实际发车时间
     private String ACTUAL_ARRIVE_TIME;// VARCHAR2(100) Y                实际到达时间实际到达时间
     private String TRAD_ID;
-
+    private String COUNT;//计数器
     public TJRL(){
     }
@@ -379,6 +379,14 @@ public class TJRL implements Cloneable {
         this.TRAD_ID = TRAD_ID;
     }
+    public String getCOUNT() {
+        return COUNT;
+    }
+
+    public void setCOUNT(String COUNT) {
+        this.COUNT = COUNT;
+    }
+
     @Override
     public Object clone() throws CloneNotSupportedException {
         return super.clone();
@@ -86,7 +86,7 @@ public class Analysis {
                         } catch (ParseException e) {
                             e.printStackTrace();
                         }
-                        //map.put("COUNT", text.substring(114, 120));    //交易计数器，BCD编码
+                        tjrl.setCOUNT(text.substring(114, 120));//交易计数器，BCD编码
                         tjrl.setTJRLORGAMT(text.substring(120, 124));//交易原始金额Orignal Txn Amount
                         //map.put("CARDSPEC", text.substring(124, 126));   //卡规范，BCD编码 01—建设部卡 02—交通部卡 03-交通部二维码
                         String TAC=text.substring(126, 134);//HEX格式，交易认证码，BCD编码
@@ -301,7 +301,7 @@ public class Contrast {
             });
         }
-        List<List<TJRLDB>> subList2 = getSubList(500, allData);
+        /*List<List<TJRLDB>> subList2 = getSubList(500, allData);
         if(!subList2.isEmpty()){
             subList2.forEach(data->{
                 if (!data.isEmpty()) {
@@ -327,7 +327,7 @@ public class Contrast {
                     });
                 }
             });
-        }
+        }*/
         //如果是上次遗留的数据不管这是是否匹配到都清空
         if(isOld){
             oldData.clear();
@@ -14,7 +14,7 @@
         BUS_PLATE, ROAD_CODE, DEPART_NAME,DEPART_CODE, DEPART_ACTUAL_TIME,
         REACH_NAME,REACH_CODE,REACH_ACTUAL_TIME,
         LEVELS_FLAG,LEVELS1, LEVELS_NAME1, LEVELS1_CODE,LEVELS2, LEVELS_NAME2,LEVELS2_CODE,MARK,TRAD_ID,
-        GPS_DATE_TIME1,GPS_DATE_TIME2,B_STATION_ID,PLAN_START_TIME,PLAN_ARRIVE_TIME,ACTUAL_START_TIME,ACTUAL_ARRIVE_TIME
+        GPS_DATE_TIME1,GPS_DATE_TIME2,B_STATION_ID,PLAN_START_TIME,PLAN_ARRIVE_TIME,ACTUAL_START_TIME,ACTUAL_ARRIVE_TIME,COUNT
         )
         VALUES
         <foreach collection="list" item="em" index="index" separator=",">
@@ -25,7 +25,8 @@
             #{em.BUS_PLATE}, #{em.ROAD_CODE}, #{em.DEPART_NAME},#{em.DEPART_CODE}, #{em.DEPART_ACTUAL_TIME},
             #{em.REACH_NAME},#{em.REACH_CODE},#{em.REACH_ACTUAL_TIME},
             #{em.LEVELS_FLAG},#{em.LEVELS1}, #{em.LEVELS_NAME1}, #{em.LEVELS1_CODE},#{em.LEVELS2}, #{em.LEVELS_NAME2}, #{em.LEVELS2_CODE}, #{em.MARK},#{em.TRAD_ID},
-            #{em.GPS_DATE_TIME1},#{em.GPS_DATE_TIME2},#{em.B_STATION_ID},#{em.PLAN_START_TIME},#{em.PLAN_ARRIVE_TIME},#{em.ACTUAL_START_TIME},#{em.ACTUAL_ARRIVE_TIME})
+            #{em.GPS_DATE_TIME1},#{em.GPS_DATE_TIME2},#{em.B_STATION_ID},#{em.PLAN_START_TIME},#{em.PLAN_ARRIVE_TIME},#{em.ACTUAL_START_TIME},#{em.ACTUAL_ARRIVE_TIME},
+            #{em.COUNT})
         </foreach>
     </insert>