Java掃描指定文件路徑下的文件並且遞歸掃描其子目錄下的所有文件

 

　　本文主要實現了掃描指定文件路徑下的文件，遞歸掃描其子目錄下的所有文件信息，示例文件為：

 

　　要求將后綴為.dat的文件夾信息也寫入到數據庫中，然后將.chk文件解析，將文件中對應的內容讀出來寫入到數據庫，對應類為ChkFileParseFactroy，本文文件發現代碼為：

package com.src.service.impl;

import java.io.File;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
import java.util.Date;
import java.util.Enumeration;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Set;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.src.dao.ChkFileDao;
import com.src.dao.FileDao;
import com.src.dao.impl.ChkFileDaoImpl;
import com.src.dao.impl.FileDaoImpl;
import com.src.factory.ChkFileParseFactroy;
import com.src.service.FoundFileService;
import com.src.util.Config;
import com.src.util.UUIDUtil;

/**
 * @ClassName: FoundFileServiceImpl
 * @Description: 掃描文件
 * @date Aug 24, 2014 1:26:18 AM
 */
public class FoundFileServiceImpl implements FoundFileService {

    private static Logger logger = LoggerFactory.getLogger(FoundFileServiceImpl.class);
    private static String interDir;

    /**
     * @Title: foundFile
     * @Description: 獲取接口文件目錄
     * @最后修改時間：Aug 24, 2014 1:26:50 AM
     */
    public void foundFile() {
        interDir = Config.getInstance().interDir;
        if (!isExist(interDir)) {
            logger.info("The file path " + interDir + " does not exists.");
        } else {
            logger.info("The current scanning directory: " + interDir);
            foundFile(interDir);
        }
    }

    /**
     * @Title: foundFile
     * @Description: 獲取接口文件目錄下的文件列表
     * @最后修改時間：Aug 24, 2014 1:27:40 AM
     * @param rootStr
     */
    public void foundFile(String rootStr) {

        String host = Config.getInstance().host; // 獲取配置文件中的IP地址

        File root = new File(rootStr);
        File[] file = root.listFiles();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        FileDao fileDao = new FileDaoImpl();
        ChkFileDao chkFileDao = new ChkFileDaoImpl();

        /** 接口文件變量 */
        String id = null; // UUID
        String interNo = null; // 接口號
        String opTime; // 數據日期
        String interFileName; // 源接口文件名
        String sourceDir = null; // 源接口文件路徑
        String fileSize; // 源接口文件大小
        String updateTime; // 源接口文件最后修改時間
        int status = 6; // 接口文件FTP狀態
        String loadStatus = ""; // 接口文件Load狀態

        /** CHK文件變量 */
        String totalNum; // 接口記錄總數
        String chkFileSize; // 接口文件總大小
        int chkFileNum = 0; // 接口文件個數
        String ftpStatus = ""; // FTP狀態

        for (File f : file) {
            interFileName = f.getName(); // 獲取文件名
            logger.info("The current scan the file: " + interFileName);

            id = UUIDUtil.getUUID(); // 獲取ID, Unique
            sourceDir = f.getAbsolutePath().toString().replace("\\", "/");

            if (interFileName.endsWith(".dat") || interFileName.endsWith(".DAT")) {
                updateTime = sdf.format(new Date(f.lastModified())); // 獲取接口文件最后修改時間
                String interID = interFileName.substring(11, 15); // 獲取6位接口號
                List<Map<String, String>> list = fileDao.getInterNoByID(interID);

                for (Map<String, String> map : list) {
                    interNo = map.get("FULLINTERCODE");
                }

                if ("M".equalsIgnoreCase(interNo.substring(0, 1))) {
                    opTime = interFileName.substring(0, 6);
                } else {
                    opTime = interFileName.substring(0, 8);
                }

                if (-1 != fileDao.insert(id, interFileName,updateTime, interNo, opTime, sourceDir, host,loadStatus, status)) {
                    logger.info(" The inter file " + interFileName + " successfully logged into the database.");
                } else {
                    logger.info(" The inter file " + interFileName + " already exists in the database.");
                }

            }

            if (f.isFile()) {

                if (interFileName.endsWith(".avl") || interFileName.endsWith(".AVL")) {
                    fileSize = Long.toString(f.length()); // 獲取文件大小
                    updateTime = sdf.format(new Date(f.lastModified())); // 獲取接口文件最后修改時間
                    interNo = interFileName.substring(0, 6); // 獲取6位接口號
                    opTime = getOpTime(interFileName); // 獲取操作時間

                    if (-1 != fileDao.insert(id, interFileName, updateTime, interNo, opTime, sourceDir, fileSize, host, loadStatus, status)) {
                        logger.info(" The inter file " + interFileName + " successfully logged into the database.");
                    } else {
                        logger.info(" The inter file " + interFileName + " already exists in the database.");
                    }

                } else if (interFileName.endsWith(".chk") || interFileName.endsWith(".CHK")) {
                    ChkFileParseFactroy chkFileParse = new ChkFileParseFactroy();
                    Map<String, String> chkFileMap = new LinkedHashMap<String, String>();
                    chkFileMap = chkFileParse.fileParsing(f);

                    opTime = getOpTime(interFileName); // 獲取操作時間
                    updateTime = sdf.format(new Date()); // 獲取更新時間：系統當前時間
                    interNo = interFileName.substring(0, 6);
                    chkFileNum = Integer.valueOf(chkFileMap.get("fileNum"));
                    totalNum = chkFileMap.get("totalNum");
                    chkFileSize = chkFileMap.get("fileSize");

                    /**
                     * 根據interNo和opTime字段判斷表中是否存在該記錄
                     */
                    if (!chkFileDao.query(interNo, opTime)) {
                        chkFileDao.insert(id, interNo, opTime, chkFileNum, totalNum, chkFileSize, sourceDir, updateTime, ftpStatus, loadStatus);
                        logger.info(" The CHK file " + interFileName + " successfully logged into the database.");
                    } else {
                        logger.info(" The CHK file " + interFileName + " already exists in the database.");
                    }

                } else {
                    logger.info("The file " + interFileName + " is illegal, pass it.");
                }
            } else if (f.isDirectory()) {
                foundFile(f.toString());
            }

        }
    }

    /**
     * @Title: isExist
     * @Description: 判斷文件目錄是否存在
     * @最后修改時間：Aug 28, 2014 10:54:13 AM
     * @param filePath
     * @return boolean 返回類型
     */
    public static boolean isExist(String filePath) {
        boolean exists = true;
        File file = new File(filePath);
        if (!file.exists()) {
            exists = false;
        }
        return exists;
    }

    /**
     * 
     * @Title: unifiedSeparator
     * @Description: 獲取文件路徑，統一格式全部都以分隔符結束
     * @最后修改時間：Aug 31, 2014 12:59:54 AM
     * @param interDirectory
     * @return String 返回類型
     */
    public static String unifiedSeparator(String interDirectory) {
        String separator = "/";

        if (interDirectory.endsWith(separator)) {
            return interDirectory;
        } else {
            return interDirectory + separator;
        }
    }

    /**
     * @Title: getOpTime
     * @Description: 判斷是日接口還是月接口，並獲取相應的日期; 
     * 月接口：例M24289201408231155 非月接口：A/I/P，I0606920140820230045
     * @最后修改時間：Aug 31, 2014 1:00:16 AM
     * @param interDirectory
     * @return String 返回類型
     */
    public static String getOpTime(String interDirectory) {
        String opTimeString = null;
        try {
            if ("M".equalsIgnoreCase(interDirectory.substring(0, 1))) {
                opTimeString = interDirectory.substring(6, 12);
            } else {
                opTimeString = interDirectory.substring(6, 14);
            }
        } catch (Exception e) {
            logger.info("Failure to obtain the operating time: "
                    + e.getMessage());
        }
        return opTimeString;
    }

}

 

示例演示存儲為：

.dat后綴的文件夾和.avl文件存到inter_file_log表中：

 

.chk文件存到inter_log表中：

 

---

本文出自 “Forever Love” 博客，轉載請務必保留此出處http://www.cnblogs.com/dwf07223/p/3999225.html。