From 1ac208953f0b6e08f5d3b759991525367fa9bd4c Mon Sep 17 00:00:00 2001 From: xuhaoxiang <1216720373@qq.com> Date: Thu, 15 Jul 2021 10:47:27 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=91=E5=88=9B=E6=8E=A5=E5=8F=A3=E4=BC=98?= =?UTF-8?q?=E5=8C=96=EF=BC=8C=E6=94=B9webservice=E5=A4=84=E7=90=86?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/ann/demo/job/ScheduledJob.java | 15 ++++++++++++++- .../ScanningFileRepository.java | 14 ++++++++++++-- .../com/ann/demo/service/AnalysisService.java | 16 +++++++++------- src/main/resources/application.yml | 4 +++- 4 files changed, 38 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/ann/demo/job/ScheduledJob.java b/src/main/java/com/ann/demo/job/ScheduledJob.java index 5bf5ab9..fba5562 100644 --- a/src/main/java/com/ann/demo/job/ScheduledJob.java +++ b/src/main/java/com/ann/demo/job/ScheduledJob.java @@ -8,6 +8,7 @@ import org.quartz.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.Trigger; import org.springframework.scheduling.TriggerContext; @@ -17,6 +18,7 @@ import org.springframework.scheduling.support.CronTrigger; import java.text.SimpleDateFormat; import java.time.LocalDateTime; +import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.concurrent.ScheduledFuture; @@ -41,11 +43,22 @@ public class ScheduledJob implements Job { @Autowired private Scheduler scheduler; + @Value("${start}") + private int start; + + @Value("${over}") + private int over; + @Override public void execute(JobExecutionContext context) { QuartzUtils.pauseScheduleJob(scheduler, "group1", "job1"); + List scanningFiles =new ArrayList(); try { - List scanningFiles = scanningFileRepository.findScanningFiles(); + if(start==0){ + scanningFiles = scanningFileRepository.findScanningFiles(over); + }else{ + scanningFiles = scanningFileRepository.findScanningFilesMore(over-start,start); + } analysisService.handleScanningFile(scanningFiles); } catch (Exception e) { // 如果报错-- 捕捉异常 继续执行 diff --git a/src/main/java/com/ann/demo/primaryRepository/ScanningFileRepository.java b/src/main/java/com/ann/demo/primaryRepository/ScanningFileRepository.java index 96c4edb..fcc1762 100644 --- a/src/main/java/com/ann/demo/primaryRepository/ScanningFileRepository.java +++ b/src/main/java/com/ann/demo/primaryRepository/ScanningFileRepository.java @@ -1,15 +1,25 @@ package com.ann.demo.primaryRepository; import com.ann.demo.primaryEntity.ScanningFile; +import org.apache.xml.res.XMLErrorResources_tr; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.Query; +import org.springframework.data.repository.query.Param; import org.springframework.stereotype.Repository; +import java.awt.print.Pageable; import java.util.List; @Repository public interface ScanningFileRepository extends JpaRepository { // and FBIHID = '370067' and FBINCU = '4' - @Query(nativeQuery= true,value = "select top 70 * from scanning_file where STATUS = 0 order by id") - public List findScanningFiles(); + /*@Query(nativeQuery= true,value = "select top 70 * from scanning_file where STATUS = 0 order by id") + public List findScanning();*/ + //@Query(nativeQuery= true,value = ":sql")n-m+1 + /*@Query(nativeQuery= true,value = "SELECT DISTINCT c FROM Customer c JOIN c.partyCerts p where p.certNum=?") + public List findScanningFiles(@Param("sql") String sql);*/ + @Query(nativeQuery= true,value = "select top(?1) * from scanning_file where STATUS = 0 order by id desc") + public List findScanningFiles(int over); + @Query(nativeQuery= true,value = "select top(?1) * from scanning_file where STATUS = 0 and id not in (select top(?2) id from scanning_file where STATUS = 0 order by id desc) order by id desc") + public List findScanningFilesMore(int length,int start); } diff --git a/src/main/java/com/ann/demo/service/AnalysisService.java b/src/main/java/com/ann/demo/service/AnalysisService.java index 730341c..294453b 100644 --- a/src/main/java/com/ann/demo/service/AnalysisService.java +++ b/src/main/java/com/ann/demo/service/AnalysisService.java @@ -110,21 +110,23 @@ public class AnalysisService { } LocalDateTime now4 = LocalDateTime.now();//删掉 - //Object[] objects = WebServiceUtils.connect(scanningFile.getPath() + "\\" + scanningFile.getFileName()); + Object[] objects = WebServiceUtils.connect(scanningFile.getPath() + "\\" + scanningFile.getFileName()); + LocalDateTime end4 = LocalDateTime.now();//删掉 + logger.error("WebServiceUtils.connect耗时:"+Duration.between(now4,end4).toMillis());//删掉 //Object[] objects = WebServiceUtil.urlConnectionUtil("http://10.6.0.224/cdms/cdmsservice.asmx?wsdl",scanningFile.getPath() + "\\" + scanningFile.getFileName()); //使用HttpURLConnection方式连接 - String s = WebServiceUtil.urlConnectionUtil("http://10.6.0.224/cdms/cdmsservice.asmx?wsdl", scanningFile.getPath() + "\\" + scanningFile.getFileName()); +// String s = WebServiceUtil.urlConnectionUtil("http://10.6.0.224/cdms/cdmsservice.asmx?wsdl", scanningFile.getPath() + "\\" + scanningFile.getFileName()); - LocalDateTime end4 = LocalDateTime.now();//删掉 - logger.error("WebServiceUtils.connect耗时:"+Duration.between(now4,end4).toMillis());//删掉 + + /*if(!"".equals(s)){ + int w=9; + } //s转Object[] String[] strArr = s.split(",");//注意分隔符是需要转译 Object[] objects = new Object[strArr.length]; for(int i=0;i