修改的定时器时间

yiming
1 parent aefacb21
Showing 3 changed files with 15 additions and 168 deletions
src/main/java/com/example/demo/model/TJRL.java
src/main/java/com/example/demo/service/Contrast.java
src/main/resources/mapping/db1/Site-mapper1.xml
@@ -7,7 +7,7 @@ import java.lang.reflect.Field;
 import java.lang.reflect.Method;
 public class TJRL implements Cloneable {
-    //@JsonProperty
+
     private String TJRLCARDNO;//         NUMBER        Y                交通卡号
     private String TJRLINSID; //         NUMBER        Y                行业
     private String TJRLCDKIND;//         NUMBER        Y                卡类型
 package com.example.demo.service;
+import cn.hutool.json.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.bsth.util.HttpUtils;
@@ -7,8 +8,6 @@ import com.example.demo.SaticScheduleTask;
 import com.example.demo.mapper.db1.SiteMapper1;
 import com.example.demo.mapper.db2.SiteMapper2;
 import com.example.demo.model.*;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -313,15 +312,8 @@ public class Contrast {
                         data2.add(tjrl);
                     }
                     map.put("datas", data2);
-
-                    ObjectMapper mapper = new ObjectMapper();
-                    String json = null;
-                    try {
-                        json = mapper.writeValueAsString(map);
-                    } catch (JsonProcessingException e) {
-                        e.printStackTrace();
-                    }
-
+                    JSON j=new cn.hutool.json.JSONObject(map);
+                    String json =j.toString();
                     ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("PDGJ", json);
                     future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
                         @Override
@@ -343,154 +335,7 @@ public class Contrast {
     }
-    /**
-     * @Description: 根据carid 获取票务数据
-     * @Param: allData交易记录 isOld是否是残余数据(上次未匹配到的数据)
-     * @return:
-     * @Author: YM
-     * @Date: 2021/10/13
-     */
-    public void filterCardListByDB(List<TJRLDB> allData,Boolean isOld) {
-        long start = System.currentTimeMillis();
-        List<Map> driverCardList = getDriverCardList();//获取司机信息
-        Map<String,List<Scheduling>> schedulingS =getSchedulingS;
-        Map<String,List<Scheduling>> schedulingSSell =getSchedulingSSell;
-        DateTimeFormatter dtf=DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
-        int b=0;//用于计算匹配成功的数量
-        for (int i = 0; i < allData.size(); i++) {
-            TJRLDB data = allData.get(i);
-            //通过司售卡找到司机
-            String carId = data.getTJRLDRVCRDID().length()>8?
-                    data.getTJRLDRVCRDID().substring( data.getTJRLDRVCRDID().length()-8):
-                    data.getTJRLDRVCRDID();
-            List<Map> collect = driverCardList.stream().filter(map -> map.get("cardno").equals(carId)).collect(Collectors.toList());
-            String mark="";
-            String jobCodes = "";
-            Boolean flag=false;//用来判断是否没有匹配成功
-            Long cardDate = null;
-            if (!collect.isEmpty()) {
-                if (null != collect.get(0).get("jobCode") && null != collect.get(0).get("personalName")) {
-                    String personalName = collect.get(0).get("personalName").toString();//姓名
-                    String[] arr=collect.get(0).get("jobCode").toString().split("-");
-                    jobCodes =arr.length==0?collect.get(0).get("jobCode").toString():arr[arr.length-1];//工号
-                    String time=String.valueOf(data.getTJRLRTIME());//时间
-                    String date=String.valueOf(data.getTJRLRDATE());//日期
-                    cardDate = LocalDateTime.parse(date+" "+time,dtf).toInstant(ZoneOffset.of("+8")).toEpochMilli(); //刷卡时间(时间戳)
-                    //通过司机姓名获得进出记录
-                    List<Scheduling> schedulingList1=schedulingS.get(personalName);
-                    //没匹配到匹配售票员
-                    if(schedulingList1==null){
-                        schedulingList1=schedulingSSell.get(personalName);
-                    }
-                    Scheduling scheduling = null;
-
-                    if(schedulingList1!=null){
-                        Collections.sort(schedulingList1, Comparator.comparing(Scheduling::getTs).reversed());
-                        for (int i1 = 0; i1 < schedulingList1.size(); i1++) {
-                            Scheduling s=schedulingList1.get(i1);
-                            if((Long.parseLong(s.getTs())-TIME2*60*1000)<=cardDate){
-                                scheduling=s;
-                                b++;
-                                flag=true;
-                                break;
-                            }
-                        }
-                    }else {
-                        mark="未查到驾驶员排班："+personalName+" 工号："+jobCodes;
-                    }
-
-                    if (scheduling!=null) {
-                        data.setSTATION_FLAG("1");
-                        data.setTJRLUNITID(scheduling.getGs_name());
-                        data.setTJRLSTATID(scheduling.getXl_name());
-                        data.setROAD_FORM_TYPE(scheduling.getBc_type());
-                        data.setUPDOWN(scheduling.getXl_dir());
-                        data.setBUS_CODE(scheduling.getCl_zbh());
-                        data.setBUS_PLATE(scheduling.getCar_plate());
-                        data.setROAD_CODE(scheduling.getLp_name());
-                        data.setDEPART_NAME(scheduling.getQdz_name());
-                        data.setDEPART_CODE(scheduling.getQdz_code());
-                        data.setDEPART_ACTUAL_TIME(scheduling.getFcsj_actual());
-                        data.setREACH_NAME(scheduling.getZdz_name());
-                        data.setREACH_CODE(scheduling.getZdz_code());
-                        data.setREACH_ACTUAL_TIME(scheduling.getZdsj_actual());
-                        if(scheduling.getStation_name()!=null){
-                            data.setLEVELS_FLAG("1");
-                            data.setLEVELS1(scheduling.getStation_route_code());//站点路由序号
-                            data.setLEVELS_NAME1(scheduling.getStation_name());//站点名
-                            data.setLEVELS1_CODE(scheduling.getStop_no());//站点编号
-                        }else {
-                            data.setLEVELS_FLAG("0");
-                        }
-                    } else {
-                        data.setSTATION_FLAG("0");
-                    }
-                }
-            }else {
-                mark="未查到驾驶员 卡号："+carId;
-                data.setSTATION_FLAG("0");
-            }
-            if(mark.length()==0 && !flag){
-                mark="未匹配到班次 "+jobCodes+"刷卡时间为:"+LocalDateTime.ofEpochSecond(cardDate/1000, 0, ZoneOffset.ofHours(8));
-            }
-            data.setMARK(mark);
-            //如果是新数据 没匹配到 去除这条记录 并放入缓存等到下次继续匹配
-            if(!isOld && !flag){
-                List<TJRLDB> m =oldData;
-                m.add(data);
-                allData.set(i,null);
-
-            }
-        }
-        int size=allData.size();
-        allData.removeIf(Objects::isNull);
-        //防止数据过多 分批插入
-        List<List<TJRLDB>> subList = getSubList(2000, allData);
-        if(!subList.isEmpty()){
-            subList.forEach(data->{
-                if (!data.isEmpty()) {
-                    siteMapper1.insertResult(data);
-                }
-            });
-        }
-
-        List<List<TJRLDB>> subList2 = getSubList(500, allData);
-        if(!subList2.isEmpty()){
-            subList2.forEach(data->{
-                if (!data.isEmpty()) {
-                    Map<String, Object> map = new HashMap<>();
-                    map.put("datatype", "passengerflow");
-                    TJRL tjrl= (TJRL) data;
-                    map.put("datas", tjrl);
-
-                    ObjectMapper mapper = new ObjectMapper();
-                    String json = null;
-                    try {
-                        json = mapper.writeValueAsString(map);
-                    } catch (JsonProcessingException e) {
-                        e.printStackTrace();
-                    }
-
-                    ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("PDGJ", json);
-                    future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
-                        @Override
-                        public void onSuccess(SendResult<String, String> result) {
-                        }
-                        @Override
-                        public void onFailure(Throwable ex) {
-                            logger.error("kafka发送票务数据异常", ex);
-                        }
-                    });
-                }
-            });
-        }
-        //如果是上次遗留的数据不管这是是否匹配到都清空
-        if(isOld){
-            oldData.clear();
-        }
-        logger.warn("======匹配"+size+"条======匹配到"+b+"条=====耗时=="+(System.currentTimeMillis() - start)/1000 + "秒");
-    }
@@ -534,7 +379,7 @@ public class Contrast {
             record.setTJRLRDATE(s.split(" ")[0]);
             record.setTJRLRTIME(s.split(" ")[1]);
         }
-        filterCardListByDB(records,false);
+        filterCardList(records,false);
     }
     public List<List<TJRLDB>> getSubList(int length, List<TJRLDB> list){
@@ -7,13 +7,14 @@
     <insert id="insertResult" parameterType="List">
-        INSERT INTO `passenger_flow`.`t_jc_result` (
-        `TJRLCARDNO`, `TJRLINSID`, `TJRLCDKIND`, `TJRLPOSID`,`TJRLRDATE`,
-        `TJRLRTIME`,`TJRLCDBAL`,`TJRLAMT`,`TJRLORGAMT`,
-        `TJRLTXFG`,`STATION_FLAG`,`TJRLUNITID`,`TJRLSTATID`,`ROAD_FORM_TYPE`, `UPDOWN`, `BUS_CODE`,
-        `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`,`MARK`,TRAD_ID
+        INSERT INTO passenger_flow.t_jc_result (
+        TJRLCARDNO, TJRLINSID, TJRLCDKIND, TJRLPOSID,TJRLRDATE,
+        TJRLRTIME,TJRLCDBAL,TJRLAMT,TJRLORGAMT,
+        TJRLTXFG,STATION_FLAG,TJRLUNITID,TJRLSTATID,ROAD_FORM_TYPE, UPDOWN, BUS_CODE,
+        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
         )
         VALUES
         <foreach collection="list" item="em" index="index" separator=",">
@@ -23,7 +24,8 @@
             #{em.BUS_CODE},
             #{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.MARK},#{em.TRAD_ID})
+            #{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})
         </foreach>
     </insert>