浙农对账文件

src/main/java/com/jqtx/windows/component/enums/SftpTypeEnum.java

+package com.jqtx.windows.component.enums;
+
+public enum SftpTypeEnum {
+    COMPENSATORY("compensatory", "代偿文件"),
+    ASSURANCE("assurance", "融担费还款明细文件"),
+    PAYMENT("payment", "放款对账文件"),
+    REPAYMENTCHECK("repayment_check", "还款对账文件"),
+    ;
+
+    SftpTypeEnum(String code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+
+    public static SftpTypeEnum getByCode(String code) {
+        for (SftpTypeEnum e : SftpTypeEnum.values()) {
+            if (e.getCode().equals(code)) {
+                return e;
+            }
+        }
+        return null;
+    }
+
+    private String code;
+
+    private String msg;
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+}

src/main/java/com/jqtx/windows/service/SftpService.java

+package com.jqtx.windows.service;
+
+import com.jqtx.windows.web.response.JsonResult;
+
+public interface SftpService {
+
+    JsonResult<String> getFileByType(String date, String type);
+}

src/main/java/com/jqtx/windows/service/impl/SftpServiceImpl.java

+package com.jqtx.windows.service.impl;
+
+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.SftpConfig;
+import com.jqtx.windows.component.enums.SftpTypeEnum;
+import com.jqtx.windows.service.SftpService;
+import com.jqtx.windows.web.response.JsonResult;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+@Slf4j
+public class SftpServiceImpl implements SftpService {
+    @Autowired
+    private OssUtils ossUtils;
+
+    @Autowired
+    private SftpConfig sftpConfig;
+
+    @Override
+    public JsonResult<String> getFileByType(String date, String type) {
+        String ossUrl = "ZN/" + type + "/" + type + "_" + date + ".txt";
+        String dir = "/download/" + type + "/" + date;
+        String sfptName = type + "_" + date + ".txt";
+        String path = "/" + type + "_sftp.txt";
+        if (!ossUtils.exist(ossUrl)) {
+            Sftp sftp = new Sftp(sftpConfig.getSshHost(), sftpConfig.getSshPort(), sftpConfig.getSshUser(), sftpConfig.getSshPass(), CharsetUtil.CHARSET_UTF_8);
+            try {
+                if (sftp.isDir(dir)) {
+                    sftp.cd(dir);
+                    sftp.get(sfptName, path);
+                    ossUtils.ossUpload(ossUrl, FileUtil.file(path));
+                    FileUtil.del(path);
+                } else {
+                    return JsonResult.error("浙农" + date + "日无" + SftpTypeEnum.getByCode(type).getMsg() + "！");
+                }
+            } catch (Exception e) {
+            } finally {
+                //关闭sftp连接
+                sftp.close();
+            }
+        }
+        return JsonResult.success(ossUtils.generateTempURL(ossUrl));
+
+    }
+
+
+}

src/main/java/com/jqtx/windows/web/SftpController.java

+package com.jqtx.windows.web;
+
+import com.jqtx.windows.service.SftpService;
+import com.jqtx.windows.web.response.JsonResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @description:
+ * @author: lsl
+ * @create: 2023年12月7日
+ **/
+@RestController
+@RequestMapping("sftp")
+@Api(value = "file", tags = {"浙农文件接口"})
+@Slf4j
+public class SftpController {
+
+    @Autowired
+    private SftpService sftpService;
+
+    @ApiOperation(value = "获取浙农文件", tags = {"浙农文件接口"}, notes = "获取浙农文件")
+    @GetMapping("/getFileByType")
+    public JsonResult<String> getFileByType(String type, String date) {
+        log.info("获取浙农文件:{},{}", date, type);
+        return sftpService.getFileByType(date, type);
+    }
+
+
+}