浙农定时时间问题

src/main/java/com/jqtx/windows/job/BackedBurdenJob.java

@@ -5,7 +5,6 @@ import cn.hutool.core.io.FileUtil;
 import cn.hutool.core.util.CharsetUtil;
 import cn.hutool.extra.ssh.Sftp;
 import com.jqtx.infrastructure.oss.starter.config.OssUtils;
-import com.jqtx.windows.common.config.BaseConfig;
 import com.jqtx.windows.common.config.SftpConfig;
 import com.jqtx.windows.common.config.snow.SnowSequenceHelper;
 import com.jqtx.windows.component.BackedDetailComponent;
@@ -64,36 +63,42 @@ public class BackedBurdenJob {
     public void run() {
         String param = XxlJobHelper.getJobParam();
         Sftp sftp = new Sftp(sftpConfig.getSshHost(), sftpConfig.getSshPort(), sftpConfig.getSshUser(), sftpConfig.getSshPass(), CharsetUtil.CHARSET_UTF_8);
-        String date = "";
-        if (StringUtils.isNotEmpty(param)) {
-            date = param;
-        }else {
-            Calendar cal = Calendar.getInstance();
-            //获取前面的时间用-负号
-            cal.setTime(new Date());
-            cal.add(Calendar.DAY_OF_MONTH, -1);
-            Date time = cal.getTime();
-            date = DateUtil.format(time, "yyyyMMdd");
-        }
-        if (sftp.isDir("/download/assurance/" + date)) {
-            sftp.cd("/download/assurance/" + date);
-            sftp.get("assurance_" + date + ".txt", "/assurance_sftp.txt");
-            ossUtils.ossUpload("ZN/assurance/" + "assurance_" + date + ".txt", FileUtil.file("/assurance_sftp.txt"));
-            String stringObject = getStringObject("ZN/assurance/" + "assurance_" + date + ".txt");
-            log.info("oss融担数据:{}", stringObject);
-            //存储并去平账
-            List<BurdenModel> getlist = getlist(stringObject);
-            for (BurdenModel model : getlist) {
-                if (new BigDecimal(model.getPepayBurden()).compareTo(BigDecimal.ZERO) > 0 ) {
-                    backedBurdenComponent.insert(model);
-                    backedBurden(model);
+        try {
+            String date = "";
+            if (StringUtils.isNotEmpty(param)) {
+                date = param;
+            } else {
+                Calendar cal = Calendar.getInstance();
+                //获取前面的时间用-负号
+                cal.setTime(new Date());
+                cal.add(Calendar.DAY_OF_MONTH, -1);
+                Date time = cal.getTime();
+                date = DateUtil.format(time, "yyyyMMdd");
+            }
+            if (sftp.isDir("/download/assurance/" + date)) {
+                sftp.cd("/download/assurance/" + date);
+                sftp.get("assurance_" + date + ".txt", "/assurance_sftp.txt");
+                ossUtils.ossUpload("ZN/assurance/" + "assurance_" + date + ".txt", FileUtil.file("/assurance_sftp.txt"));
+                String stringObject = getStringObject("ZN/assurance/" + "assurance_" + date + ".txt");
+                log.info("oss融担数据:{}", stringObject);
+                //存储并去平账
+                List<BurdenModel> getlist = getlist(stringObject);
+                for (BurdenModel model : getlist) {
+                    if (new BigDecimal(model.getPepayBurden()).compareTo(BigDecimal.ZERO) > 0) {
+                        backedBurdenComponent.insert(model);
+                        backedBurden(model);
+                    }
                 }
+                FileUtil.del("/assurance_sftp.txt");
+            } else {
+                log.info("浙农融担文件不存在:{}", date);
             }
-            FileUtil.del("/assurance_sftp.txt");
-        } else {
-            log.info("浙农融担文件不存在:{}", date);
+        } catch (Exception e) {
+            log.info("浙农代偿错误:{}", e.getMessage());
+        } finally {
+            //关闭sftp连接
+            sftp.close();
         }
-
     }
 
     public String getStringObject(String uri) {

src/main/java/com/jqtx/windows/job/RedeemJob.java

@@ -43,27 +43,34 @@ public class RedeemJob {
     public void run() {
         String param = XxlJobHelper.getJobParam();
         Sftp sftp = new Sftp(sftpConfig.getSshHost(), sftpConfig.getSshPort(), sftpConfig.getSshUser(), sftpConfig.getSshPass(), CharsetUtil.CHARSET_UTF_8);
-        String date = "";
-        if (StringUtils.isNotEmpty(param)) {
-            date = param;
-        }else {
-            Calendar cal = Calendar.getInstance();
-            //获取前面的时间用-负号
-            cal.setTime(new Date());
-            cal.add(Calendar.DAY_OF_MONTH, -1);
-            Date time = cal.getTime();
-            date = DateUtil.format(time, "yyyyMMdd");
-        }
-        if (sftp.isDir("/download/compensatory/" + date)) {
-            sftp.cd("/download/compensatory/" + date);
-            sftp.get("compensatory_" + date + ".txt", "/compensatory_sftp.txt");
-            ossUtils.ossUpload("ZN/compensatory/" + "compensatory_" + date + ".txt", FileUtil.file("/compensatory_sftp.txt"));
-            String stringObject = getStringObject("ZN/compensatory/" + "compensatory_" + date + ".txt");
-            log.info("oss代偿数据:{}", stringObject);
-            redeemComponent.insert(getlist(stringObject));
-            FileUtil.del("/compensatory_sftp.txt");
-        } else {
-            log.info("浙农代偿文件不存在:{}", date);
+        try {
+            String date = "";
+            if (StringUtils.isNotEmpty(param)) {
+                date = param;
+            } else {
+                Calendar cal = Calendar.getInstance();
+                //获取前面的时间用-负号
+                cal.setTime(new Date());
+                cal.add(Calendar.DAY_OF_MONTH, -1);
+                Date time = cal.getTime();
+                date = DateUtil.format(time, "yyyyMMdd");
+            }
+            if (sftp.isDir("/download/compensatory/" + date)) {
+                sftp.cd("/download/compensatory/" + date);
+                sftp.get("compensatory_" + date + ".txt", "/compensatory_sftp.txt");
+                ossUtils.ossUpload("ZN/compensatory/" + "compensatory_" + date + ".txt", FileUtil.file("/compensatory_sftp.txt"));
+                String stringObject = getStringObject("ZN/compensatory/" + "compensatory_" + date + ".txt");
+                log.info("oss代偿数据:{}", stringObject);
+                redeemComponent.insert(getlist(stringObject));
+                FileUtil.del("/compensatory_sftp.txt");
+            } else {
+                log.info("浙农代偿文件不存在:{}", date);
+            }
+        } catch (Exception e) {
+            log.info("浙农代偿错误:{}", e.getMessage());
+        } finally {
+            //关闭sftp连接
+            sftp.close();
         }
 
     }