Java Structs 中动态创建 CSV 文件并上传到 FTP 服务器的教程

import java.io.*;

public class CSVGenerator {

    public static InputStream generateCSV(String[] business, String[] position) throws IOException {
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        try (Writer writer = new OutputStreamWriter(bos)) {
            // 写入 CSV 文件的头部（如果需要）
            writer.write("Business,Position\n");

            // 写入 business 数据
            for (String b : business) {
                writer.write(b + ",");
            }

            // 写入 position 数据
            for (String p : position) {
                writer.write(p + ",");
            }

            writer.write("\n"); //换行符

        }
        return new ByteArrayInputStream(bos.toByteArray());
    }
}

import java.io.InputStream;
import java.io.IOException;

public class FTPUploader {

    public boolean uploadFile(InputStream isUploadFile, String dirName, String loggedInUser, String fileName) {
        boolean storeRetVal = false;
        String fileType = fileName.substring(fileName.lastIndexOf(".") + 1, fileName.length());
        storeRetVal = SISSFTPManager.getInstance().put(isUploadFile, dirName, fileName);
        if (storeRetVal) {
            try {
                if (fileType.trim().equalsIgnoreCase("csv")) {
                    ICSAPI.getInstance().getSIMSOrderManager().createFileAudit(loggedInUser, fileName);
                } else {
                    // Handle other file types if needed
                }
            } catch (Exception e) {
                // TODO: Handle exceptions appropriately (logging, etc.)
                e.printStackTrace();
            }
            System.out.println("BulkUploadAction:fileUpload SFTP Transfer file successfully!");
        } else {
            System.err.println("BulkUploadAction:fileUpload SFTP Transfer file FAILED!");
        }

        return storeRetVal;
    }
}

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.io.IOException;

public class PayrollAction extends Action {

    @Override
    public ActionForward generatePayroll(ActionMapping mapping, ActionForm form,
                                          HttpServletRequest request, HttpServletResponse response) {
        SessionInfoForm _form = (SessionInfoForm) form;
        SisTransactionsSession _config = _form.getSisTransactionsSession();
        String loggedInUser = _form.getLoggedinEmployeeDVO().getLoginId().toUpperCase();
        String[] business = request.getParameterValues("selectedBusinessValues");
        String[] position = request.getParameterValues("selectedPositionValues");

        try {
            // 1. Generate CSV InputStream
            InputStream isFixedValue = CSVGenerator.generateCSV(business, position);

            // 2. Upload to FTP
            FTPUploader ftpUploader = new FTPUploader();
            String fileName = "PAYROLL_PRM.csv"; // Define your filename
            String dirName = "/payroll"; // Define your directory on the FTP server

            boolean uploadSuccess = ftpUploader.uploadFile(isFixedValue, dirName, loggedInUser, fileName);

            if (uploadSuccess) {
                System.out.println("Payroll file uploaded successfully!");
            } else {
                System.err.println("Payroll file upload failed!");
            }

        } catch (IOException e) {
            // TODO: Handle exceptions appropriately (logging, error page, etc.)
            e.printStackTrace();
        }

        return mapping.findForward("success");
    }
}