修改的定时器时间

yiming
1 parent 78137fe0
Showing 4 changed files with 75 additions and 7 deletions
src/main/java/com/example/demo/SaticScheduleTask.java
src/main/java/com/example/demo/service/Contrast.java
src/main/resources/application.properties
src/main/resources/logback.xml
@@ -56,6 +56,8 @@ public class SaticScheduleTask implements InitializingBean {
         List<Map<String,List<Scheduling>>> result=contrast.getSchedulingS(now,1);
         contrast.getSchedulingS=result.get(0);
         contrast.getSchedulingSSell=result.get(1);
+        logger.info("===============================数据存放结束================================");
+        logger.info("===============================开始读取文件================================");
         WatchKey watchKey = null;
         List<File> files = new ArrayList<>();
         while ((watchKey = watchService.poll()) != null) {
@@ -69,6 +71,7 @@ public class SaticScheduleTask implements InitializingBean {
             watchKey.reset();
         }
         System.out.println("文件数"+files.size());
+        logger.info("===============================读取文件结束================================");
         //先把处理上一次没匹配到的
         if(!contrast.oldData.isEmpty()){
             contrast.filterCardList(contrast.oldData,true);
@@ -180,8 +180,8 @@ public class Contrast {
         List<Map<String,List<Scheduling>>> result=new ArrayList<>();
         result.add(getSchedulingS);
         result.add(getSchedulingSSell);
-
-        logger.warn("======匹配"+arrivalInfoList.size()+"条======匹配成功 "+b+"条=====耗时=="+(System.currentTimeMillis() - start)/1000 + "秒");
+        logger.info("======匹配"+arrivalInfoList.size()+"条======匹配成功 "+b+"条=====耗时=="+(System.currentTimeMillis() - start)/1000 + "秒");
+        logger.info("===============================预加载数据匹配结束================================");
         return result;
     }
@@ -193,6 +193,7 @@ public class Contrast {
      * @Date: 2021/10/13
      */
     public void filterCardList(List<TJRLDB> allData, Boolean isOld)  {
+        logger.info("===============================票务数据匹配开始================================");
         long start = System.currentTimeMillis();
         List<Map> driverCardList = getDriverCardList();//获取司机信息
         Map<String,List<Scheduling>> schedulingS =getSchedulingS;
@@ -332,6 +333,7 @@ public class Contrast {
             oldData.clear();
         }
         logger.warn("======匹配"+size+"条======匹配到"+b+"条=====耗时=="+(System.currentTimeMillis() - start)/1000 + "秒");
+        logger.info("===============================票务数据匹配结束================================");
     }
@@ -34,10 +34,7 @@ spring.kafka.producer.acks=all
 spring.kafka.producer.properties.max.request.size=20971520
-
-logging.path=/home/demo/log
-
-
+#
 #spring.datasource.db1.jdbc-url=jdbc:mysql://192.168.168.240:3306/pd_control?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
 #spring.datasource.db1.username=root
 #spring.datasource.db1.password=root2jsp
@@ -70,4 +67,5 @@ logging.path=/home/demo/log
 #spring.kafka.producer.properties.max.request.size=10485760
-#logging.path=E:/log
 \ No newline at end of file
+logging.path=./logs
+logging.file=Log
 \ No newline at end of file
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+    <appender name="CONSOLE-LOG" class="ch.qos.logback.core.ConsoleAppender">
+        <layout class="ch.qos.logback.classic.PatternLayout">
+            <pattern>[%d{yyyy-MM-dd' 'HH:mm:ss.sss}] [%C] [%t] [%L] [%-5p] %m%n</pattern>
+        </layout>
+    </appender>
+
+    <!--获取比info级别高(包括info级别)但除error级别的日志-->
+    <appender name="INFO-LOG" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>ERROR</level>
+            <onMatch>DENY</onMatch>
+            <onMismatch>ACCEPT</onMismatch>
+        </filter>
+        <encoder>
+            <pattern>[%d{yyyy-MM-dd' 'HH:mm:ss.sss}] [%C] [%t] [%L] [%-5p] %m%n</pattern>
+        </encoder>
+
+        <!--滚动策略-->
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!--路径-->
+            <fileNamePattern>${LOG_INFO_HOME}//%d.log</fileNamePattern>
+            <maxHistory>30</maxHistory>
+        </rollingPolicy>
+    </appender>
+    <appender name="ERROR-LOG" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
+            <level>ERROR</level>
+        </filter>
+        <encoder>
+            <pattern>[%d{yyyy-MM-dd' 'HH:mm:ss.sss}] [%C] [%t] [%L] [%-5p] %m%n</pattern>
+        </encoder>
+        <!--滚动策略-->
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!--路径-->
+            <fileNamePattern>${LOG_ERROR_HOME}//%d.log</fileNamePattern>
+            <maxHistory>30</maxHistory>
+        </rollingPolicy>
+    </appender>
+
+    <appender name="ASYNC-INFO" class="ch.qos.logback.classic.AsyncAppender">
+        <!-- 不丢失日志.默认的,如果队列的80%已满,则会丢弃TRACT、DEBUG、INFO级别的日志 -->
+        <discardingThreshold>0</discardingThreshold>
+        <!-- 更改默认的队列的深度,该值会影响性能.默认值为256 -->
+        <queueSize>256</queueSize>
+        <!-- 添加附加的appender,最多只能添加一个 -->
+        <appender-ref ref="INFO-LOG"/>
+    </appender>
+
+    <appender name="ASYNC-ERROR" class="ch.qos.logback.classic.AsyncAppender">
+        <!-- 不丢失日志.默认的,如果队列的80%已满,则会丢弃TRACT、DEBUG、INFO级别的日志 -->
+        <discardingThreshold>0</discardingThreshold>
+        <!-- 更改默认的队列的深度,该值会影响性能.默认值为256 -->
+        <queueSize>256</queueSize>
+        <!-- 添加附加的appender,最多只能添加一个 -->
+        <appender-ref ref="ERROR-LOG"/>
+    </appender>
+
+    <root level="info">
+        <appender-ref ref="CONSOLE-LOG" />
+        <appender-ref ref="INFO-LOG" />
+        <appender-ref ref="ERROR-LOG" />
+    </root>
+</configuration>