天天看點

Nginx上傳視訊等大檔案

Nginx上傳視訊等大檔案

檔案夾資料庫處理邏輯

public class DbFolder

{

    JSONObject root;

    public DbFolder()

    {

        this.root = new JSONObject();

        this.root.put("f_id", "");

        this.root.put("f_nameLoc", "根目錄");

        this.root.put("f_pid", "");

        this.root.put("f_pidRoot", "");

    }

    /**

     * 将JSONArray轉換成map

     * @param folders

     * @return

     */

    public Map<String, JSONObject> toDic(JSONArray folders)

        Map<String, JSONObject> dt = new HashMap<String, JSONObject>();

        for(int i = 0 , l = folders.size();i<l;++i)

        {

            JSONObject o = folders.getJSONObject(i);

            String id = o.getString("f_id");

            dt.put(id, o);

        }

        return dt;

    public Map<String, JSONObject> foldersToDic(String pidRoot)

        //預設加載根目錄

        String sql = String.format("select f_id,f_nameLoc,f_pid,f_pidRoot from up6_folders where f_pidRoot='%s'", pidRoot);

        SqlExec se = new SqlExec();

        JSONArray folders = se.exec("up6_folders", sql, "f_id,f_nameLoc,f_pid,f_pidRoot","");

        return this.toDic(folders);

    public ArrayList<JSONObject> sortByPid( Map<String, JSONObject> dt, String idCur, ArrayList<JSONObject> psort) {

        String cur = idCur;

        while (true)

            //key不存在

            if (!dt.containsKey(cur)) break;

            JSONObject d = dt.get(cur);//查父ID

            psort.add(0, d);//将父節點排在前面           

            cur = d.getString("f_pid").trim();//取父級ID

            if (cur.trim() == "0") break;

            if ( StringUtils.isBlank(cur) ) break;

        return psort;

    public JSONArray build_path_by_id(JSONObject fdCur) {

        String id = fdCur.getString("f_id").trim();//

        String pidRoot = fdCur.getString("f_pidRoot").trim();//

        //根目錄

        ArrayList<JSONObject> psort = new ArrayList<JSONObject>();

        if (StringUtils.isBlank(id))

            psort.add(0, this.root);

            return JSONArray.fromObject(psort);

        //建構目錄映射表(id,folder)

        Map<String, JSONObject> dt = this.foldersToDic(pidRoot);

        //按層級順序排列目錄

        psort = this.sortByPid(dt, id, psort);

        //是子目錄->添加根目錄

        if (!StringUtils.isBlank(pidRoot))

            JSONObject root = se.read("up6_files"

                    , "f_id,f_nameLoc,f_pid,f_pidRoot"

                    , new SqlParam[] { new SqlParam("f_id", pidRoot) });

            psort.add(0, root);

        }//是根目錄->添加根目錄

        else if (!StringUtils.isBlank(id) && StringUtils.isBlank(pidRoot))

                    , new SqlParam[] { new SqlParam("f_id", id) });

        psort.add(0, this.root);

        return JSONArray.fromObject(psort);

    public FileInf read(String id) {

        String sql = String.format("select f_pid,f_pidRoot,f_pathSvr from up6_files where f_id='%s' union select f_pid,f_pidRoot,f_pathSvr from up6_folders where f_id='%s'", id,id);

        JSONArray data = se.exec("up6_files", sql, "f_pid,f_pidRoot,f_pathSvr","");

        JSONObject o = (JSONObject)data.get(0);

        FileInf file = new FileInf();

        file.id = id;

        file.pid = o.getString("f_pid").trim();

        file.pidRoot = o.getString("f_pidRoot").trim();

        file.pathSvr = o.getString("f_pathSvr").trim();

        return file;

    public Boolean exist_same_file(String name,String pid)

        SqlWhereMerge swm = new SqlWhereMerge();

        swm.equal("f_nameLoc", name.trim());

        swm.equal("f_pid", pid.trim());

        swm.equal("f_deleted", 0);

        String sql = String.format("select f_id from up6_files where %s ", swm.to_sql());

        JSONArray arr = se.exec("up6_files", sql, "f_id", "");

        return arr.size() > 0;

     * 檢查是否存在同名目錄

     * @param name

     * @param pid

    public Boolean exist_same_folder(String name,String pid)

        swm.equal("LTRIM (f_pid)", pid.trim());

        String where = swm.to_sql();

        String sql = String.format("(select f_id from up6_files where %s ) union (select f_id from up6_folders where %s)", where,where);

        JSONArray fid = se.exec("up6_files", sql, "f_id", "");

        return fid.size() > 0;     

    public Boolean rename_file_check(String newName,String pid)

        SqlExec se = new SqlExec();           

        JSONArray res = se.select("up6_files"

            , "f_id"

            ,new SqlParam[] {

                new SqlParam("f_nameLoc",newName)

                ,new SqlParam("f_pid",pid)

            },"");

        return res.size() > 0;

    public Boolean rename_folder_check(String newName, String pid)

        JSONArray res = se.select("up6_folders"

            , new SqlParam[] {

    public void rename_file(String name,String id) {

        se.update("up6_files"

            , new SqlParam[] { new SqlParam("f_nameLoc", name) }

            , new SqlParam[] { new SqlParam("f_id", id) });

    public void rename_folder(String name, String id, String pid) {

        se.update("up6_folders"

}

1.在webuploader.js大概4880行代碼左右,在動态生成的input元件的下面(也可以直接搜尋input),增加webkitdirectory屬性。

function FileUploader(fileLoc, mgr)

    var _this = this;

    this.id = fileLoc.id;

    this.ui = { msg: null, process: null, percent: null, btn: { del: null, cancel: null,post:null,stop:null }, div: null};

    this.isFolder = false; //不是檔案夾

    this.app = mgr.app;

    this.Manager = mgr; //上傳管理器指針

    this.event = mgr.event;

    this.Config = mgr.Config;

    this.fields = jQuery.extend({}, mgr.Config.Fields, fileLoc.fields);//每一個對象自帶一個fields幅本

    this.State = this.Config.state.None;

    this.uid = this.fields.uid;

    this.fileSvr = {

          pid: ""

        , id: ""

        , pidRoot: ""

        , f_fdTask: false

        , f_fdChild: false

        , uid: 0

        , nameLoc: ""

        , nameSvr: ""

        , pathLoc: ""

        , pathSvr: ""

        , pathRel: ""

        , md5: ""

        , lenLoc: "0"

        , sizeLoc: ""

        , FilePos: "0"

        , lenSvr: "0"

        , perSvr: "0%"

        , complete: false

        , deleted: false

    };//json obj,伺服器檔案資訊

    this.fileSvr = jQuery.extend(this.fileSvr, fileLoc);

2.可以擷取路徑

     this.open_files = function (json)

     {

         for (var i = 0, l = json.files.length; i < l; ++i)

             this.addFileLoc(json.files[i]);

         }

         setTimeout(function () { _this.PostFirst(); },500);

     };

     this.open_folders = function (json)

        for (var i = 0, l = json.folders.length; i < l; ++i) {

            this.addFolderLoc(json.folders[i]);

         setTimeout(function () { _this.PostFirst(); }, 500);

     this.paste_files = function (json)

         {

繼續閱讀