青浦客流

yiming
1 parent 5570148a
Showing 3 changed files with 33 additions and 24 deletions
src/main/java/com/example/demo/SaticScheduleTask.java
src/main/java/com/example/demo/service/Contrast.java
src/main/resources/application.properties
@@ -9,8 +9,10 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import javax.annotation.PostConstruct;
+import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
@@ -30,21 +32,16 @@ public class SaticScheduleTask {
     private Contrast contrast;
-    //@Scheduled(cron = "0 0/5 * * * ?")
-    @PostConstruct
+    @Scheduled(cron = "0 0 12 * * ?")
     void getArrivalInfos(){
-        logger.info("票务数据缓存加载: " + LocalDateTime.now());
         try {
-            LocalDateTime now=LocalDateTime.now();
-            DateTimeFormatter tdf=DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
-            now=LocalDateTime.parse("2024-08-26 00:00",tdf);
-            List<Scheduling> result=contrast.getSchedulingS(now,1);
+            LocalDateTime now=LocalDate.now().atStartOfDay();
+            /*DateTimeFormatter tdf=DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
+            now=LocalDateTime.parse("2024-08-26 00:00",tdf);*/
+            contrast.getSchedulingS(now,1);
             contrast.getStationRoutes();
-            System.out.println(result.size());
         } catch (Exception e) {
             e.printStackTrace();
         }
     }
-
-
 }
 \ No newline at end of file
@@ -9,7 +9,11 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.kafka.support.SendResult;
 import org.springframework.stereotype.Service;
+import org.springframework.util.concurrent.ListenableFuture;
+import org.springframework.util.concurrent.ListenableFutureCallback;
+
 import java.text.SimpleDateFormat;
 import java.time.*;
 import java.time.format.DateTimeFormatter;
@@ -167,7 +171,7 @@ public class Contrast {
             schedulingKFKS.add(schedulingKFK);
         }
-        List<List<SchedulingKFK>> subList = getSubList(500, schedulingKFKS);
+        List<List<SchedulingKFK>> subList = getSubList(100, schedulingKFKS);
         if(!subList.isEmpty()){
             subList.forEach(data->{
                 if (!data.isEmpty()) {
@@ -176,17 +180,17 @@ public class Contrast {
                     map2.put("datas", data);
                     JSON j=new JSONObject(map2);
                     String json =j.toString();
-                    /*ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("PDGJ", json);
+                    ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("QPGJ", json);
                     future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
                         @Override
                         public void onSuccess(SendResult<String, String> result) {
-                            logger.info("kafka发送票务数据成功条数:"+data.size());
+                            logger.info("kafka发送路单数据成功");
                         }
                         @Override
                         public void onFailure(Throwable ex) {
-                            logger.error("kafka发送票务数据异常", ex);
+                            logger.error("kafka发送单数数据异常", ex);
                         }
-                    });*/
+                    });
                 }
             });
         }
@@ -207,23 +211,23 @@ public class Contrast {
             map.put("datas", list);
             JSON j=new JSONObject(map);
             String json =j.toString();
-            /*ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("PDGJ", json);
+            ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("QPGJ", json);
             future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
                 @Override
                 public void onSuccess(SendResult<String, String> result) {
-                    logger.info("kafka发送票务数据成功");
+                    logger.info("kafka站点路由数据成功");
                 }
                 @Override
                 public void onFailure(Throwable ex) {
-                    logger.error("kafka发送票务数据异常", ex);
+                    logger.error("kafka发送站点路由数据异常", ex);
                 }
-            });*/
+            });
         }
         System.out.println(">>>>>>>>>>>>>>>>"+list.size());
         return list;
     }
-    public List<List<SchedulingKFK>> getSubList(int length, List<SchedulingKFK> list)throws Exception{
+    public List<List<SchedulingKFK>> getSubList(int length, List<SchedulingKFK> list){
         int size = list.size();
         int temp = size / length + 1;
         boolean result = size % length == 0;
 server.port=8087
-spring.datasource.db1.jdbc-url=jdbc:mysql://127.0.0.1:3306/control_qp?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
+spring.datasource.db1.jdbc-url=jdbc:mysql://192.168.50.213:3306/control?useUnicode=true&characterEncoding=utf-8&useSSL=false
 spring.datasource.db1.username=root
-spring.datasource.db1.password=123456
+spring.datasource.db1.password=root2jsp
 spring.datasource.db1.driver-class-name=com.mysql.cj.jdbc.Driver
 spring.datasource.db1.druid.test-on-borrow=true
 spring.datasource.db1.druid.test-while-idle=true
-spring.datasource.db2.jdbc-url=jdbc:mysql://127.0.0.1:3306/ms?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
+spring.datasource.db2.jdbc-url=jdbc:mysql://192.168.50.213:3306/ms?useUnicode=true&characterEncoding=utf-8&useSSL=false
 spring.datasource.db2.username=root
-spring.datasource.db2.password=123456
+spring.datasource.db2.password=root2jsp
 spring.datasource.db2.driver-class-name=com.mysql.cj.jdbc.Driver
 spring.datasource.db2.druid.test-on-borrow=true
 spring.datasource.db2.druid.test-while-idle=true
@@ -20,4 +20,12 @@ mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
 logging.level.com.example.demo.mapper=info
 #logging.level.org.mybatis = debug
+spring.kafka.bootstrap-servers=192.168.40.82:9092
+spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
+spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
+spring.kafka.producer.buffer-memory=33554432
+spring.kafka.producer.acks=all
+spring.kafka.producer.properties.max.request.size=20971520
+
+