BS系統自動更新的實現

背景：

我公司做的考試系統(基於java開發的BS系統)是賣給學校的，隨着客戶數量增多，日常版本升級、遠程維護工作占了程序員很多時間，遂考慮實現系統自動化更新。

---

 

要解決的問題及解決方案：

1.什么時候檢查更新及更新策略。

由於系統隨時有可能處於使用狀態，全自動更新容易導致問題，因此是否執行自動更新由系統管理員決定，當系統管理員登錄到后台管理界面時系統會自動檢查更新並提示。管理員點擊觸發執行更新。由於更新的執行依托系統本身的程序，因此不能在更新前關停掉tomcat。也就是只能執行熱更新，但是熱更新也有些問題需要解決，java類的class需要動態裝載，而spring、struts的配置文件由於依賴關系、文件較多，難以實現動態加載，就算實現了，系統session也會被重新初始化，這樣很容易產生錯誤數據，且學生們也必須重新登錄。與其這樣，倒不如更新完直接提示管理員必須重啟服務器后才可繼續使用。

 

2.要支持三種類型的更新：程序補丁包、數據庫更新、特殊數據更新

程序補丁包：日常bug解決,新增或修改的功能，按運行環境目錄結構組織更新文件，打包成zip文件，客戶端下載后解壓覆蓋實現更新。

數據庫更新：將對數據庫的任何操作，制作成sql腳本，客戶端下載sql腳本並調用執行腳本方法實現更新。

特殊數據更新：我們系統是考試系統，有題庫，題數據保存在數據庫中，但也可以導入導出成文件，我們給學校更新題庫時，是給文件進行導入。自動更新就需要實現自動導入。

3.客戶端不應重復更新，而且應確保准確無誤的的執行完整的更新。

有兩個概念要區分：每次更新與每個更新。每次更新是系統管理員不定期的檢查和執行整體更新，每個更新是一次更新中的每個具體更新，每次更新包含多個“每個更新”，因為每次更新可能會多次下載多個文件執行更新。

客戶端每執行完一個更新時，會將本更新的文件單獨留存到客戶端的一個叫last-updated-files的目錄下，下次系統請求遠程服務器檢查更新時會帶上這個文件名，得到大於這個文件名的文件列表（也就是認為還沒更新的），這樣可以防止重復更新，保證按順序更新。

因此，更新包必須加入時間概念來確保更新順序，我采用的是更新包的命名上入手，每個更新包文件命名必須包含日期時間，同類更新包，客戶端按日期時間排序逐個逐個下載並執行更新。

4.如何應對更新失敗及客戶端版本回滾。

基於第3點的機制，更新失敗不會在本地留存更新包文件，因此檢查更新時服務器會傳回所有文件，這樣就可以重復執行這個更新。本方案不考慮直接的版本回滾，實現起來有些麻煩，通過另外的方式解決回滾問題，即如果某次更新包有問題，那么就推出新的更新包，用后來的更新覆蓋之前的更新來解決問題。

 

---

 

程序構成：

整個自動化更新系統由服務端、客戶端構成。服務端即一個提供更新包的遠程服務器，客戶端即學校安裝的BS系統。

基本原理:下載並解壓zip替換文件,下載執行sql,下載dat文件並更新題庫.

服務端主要包含:

一個包文件夾，更新包以時間命名后都放到包目錄下，名稱規則：201710201433.zip(年月日時分.zip)
一個文件上傳及管理jsp

一個更新檢查jsp
客戶端：
后台主界面添加代碼，管理員登錄后自動ajax請求遠程服務器，帶上本地最后一次更新的文件名(文件名根據不同類型可能是多個)，
獲得未更新的文件名列表，如果有新的更新，則提示某類型發現N個新更新，是否立即更新，點更新后，前端挨個挨個請求后台下載更新包,執行更新.
程序文件更新(zip),下載后解壓並覆蓋舊文件;數據庫更新,下載sql文件並執行;試題更新,下載試題執行試題導入功能.
更新時在頁面上顯示更新進度。更新結束要求重啟系統。

---

 

關鍵程序代碼：

本功能是在一個Struts2、Spring、Hibernate項目中實現的。

服務端：

服務端是一個web應用，主要功能有管理員登錄、文件管理、文件上傳、更新檢查（接收客戶端請求，根據客戶端的參數）。

此處只貼出更新檢查的代碼。

<%@ page language="java" import="java.util.*,java.io.*" pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";


/***
 *
 *
 * 私有雲自動更新
 *
 *
 * 自動更新原理：
 * 客戶端(私有雲)admin登錄到后台系統后，后台系統會自動從本web獲取還未下載的更新包名稱列表。
 * 更細包包含程序更新包（.zip文件）、數據庫更新文件（.sql文件）和題庫更新包（.dat文件），
 *
 * 補丁包（zip）和數據庫更新（sql）有可能根據時間推移會產生多個版本，他們的文件名前綴直接以時間命名即可。
 * 試題比較特殊，同一套試卷原則上只應該有一個對應的更新文件，如果有新的改動，刪除舊的包，取新名上傳。
 * 同套試卷也支持上傳多個包，但是更新檢查時只會獲得最新那個包名（按文件名中的日期部分排序）。
 * 不同的試題試卷號不同，他們是針對具體內容的更新，因此試卷的命名以“試卷編號_加密狗權限識別碼_年月日時分.dat”格式，
 * 舉例：666_yyn_201712051422.dat,
 * 釋意：
 * 666:試卷編號
 * yyn:該題屬於財務核算實訓雲平台版及財務管理實訓雲平台版，不屬於管理信息化實訓雲平台，y=yes，n=no，三個字符分別表示三個版本權限
 * 201712051422:本更新包時間點是2017年12月5日14點22分，私有雲檢查更新時同一套試卷會根據此部分值排序得到最大的。
 *
 * 客戶端（私有雲平台）請求檢查更新時，默認傳來最后一次更新的程序補丁文件名（zip或sql）以及最后一次更新的試題名（多個），
 * 本程序根據名稱（日期命名的）與本程序包目錄下的文件進行對比，得出大於該日期的程序文件名（也就是還未被它下載更新過的）。
 * 更新后將最后一次更新的包存放到last-update-file目錄，便於下次更新時傳給服務器獲取新列表。
 * 同一時間的程序補丁包和數據庫更新文件作為一個整體補丁業務處理，因為它們是相互依存的，同一時間，如果程序和數據庫同時發生了變化，
 * 那么它們本來就是一個整體更新，更新包必須保持順序執行，因此它們的區別只是后綴名不同。
 *
 * 試題的更新，客戶端傳來最后一次更新的試卷名稱（不同的試卷有自己的最后包名）與服務器最新試卷包名（每個試卷都有自己的）進行對比，
 * 只要所屬試卷的最后一次更新名稱（日期命名的）小於服務器返回的，就是要下載安裝的。
 * 試題更新結束將當前試卷最后一次更新的包放到last-updated-file目錄里，便於下次更新對比。
 *
 * 更新檢查時服務端按.zip、.sql、.dat分組排序返回，客戶端下載更新時也按分組列表順序。
 *
 * 注意，如果sql文件內容包含中文，那么文件和內容必須是UTF-8編碼的，否則更新到數據庫會形成亂碼。
 *
 * 程序組成：
 * 分服務端與客戶端，不設計更新前備份與回滾機制，如果某次更新有問題，再出新的更新包執行替換來解決。
 * 基本原理:下載並解壓zip替換文件,下載執行sql,下載dat文件並更新題庫.
 * 服務端主要包含:
 * 一個包文件夾，更新包以時間命名后都放到包目錄下，名稱規則：201710201433.zip(年月日時分.zip)
 * 一個文件上傳及管理jsp
 * 一個更新檢查jsp
 * 客戶端：
 * 后台主界面添加代碼，管理員登錄后自動ajax請求遠程服務器，帶上本地最后一次更新的文件名(文件名根據不同類型可能是多個)，
 * 獲得未更新的文件名列表，如果有新的更新，則提示某類型發現N個新更新，是否立即更新，點更新后，前端挨個挨個請求后台下載更新包,執行更新.
 * 程序文件更新(zip),下載后解壓並覆蓋舊文件;數據庫更新,下載sql文件並執行;試題更新,下載試題執行試題導入功能.
 * 更新時在頁面上顯示更新進度。更新結束要求重啟系統。
 *
 *
 */



//得到加密狗信息
String encrypt = request.getParameter("encrypt");
if(encrypt==null || "".equals(encrypt) || "0".equals(encrypt)){
    
    Integer.parseInt("加密狗參數錯誤！");
    return;
}

//取得傳來的最后一次更新的程序文件的名，參數不能帶.zip后綴，因為下面要直接用於比較數字大小。
String lastUpdateFileNames = request.getParameter("lastUpdateFileNames");

System.out.println("lastUpdateFileNames:"+lastUpdateFileNames);

String[] lastUpdateFileNamesArray = null;//被以逗號分隔的傳遞來的最后更新的文件名數組。
ArrayList<String> paperNames = new ArrayList<String>();//最后更新的試卷更新包名稱集合

String lastZipName = "";//最后更新的補丁名
String lastSqlName = "";//最后更新的sql腳本名
if(lastUpdateFileNames!=null && !"".equals(lastUpdateFileNames)){
    
    if(lastUpdateFileNames.indexOf(",")!=-1){
        lastUpdateFileNamesArray = lastUpdateFileNames.split(",");
    }else{

        lastUpdateFileNamesArray = new String[]{lastUpdateFileNames};
    }
    
    
    for(String ss:lastUpdateFileNamesArray){
        String fileName = ss.split("\\.")[0];
        String extendName = ss.split("\\.")[1];
        if("dat".equals(extendName)){
            //將試卷的最后更新的文件名稱添加到集合中，便於下面對比
            paperNames.add(ss);
        }else if("zip".equals(extendName)){
            //最后更新的補丁名稱
            lastZipName = ss;
        }else if("sql".equals(extendName)){
            //最后更新的補丁名稱
            lastSqlName = ss;
        }
    }
}

//本web路徑，用於讀取包文件列表
String realPath = request.getRealPath("/files");


String result = "";

//讀取包文件列表
File file = new File(realPath);
File[] files=file.listFiles();
if(files.length>0){
    
    ArrayList<File> fileList = new ArrayList<File>();
    ArrayList<File> datFileList = new ArrayList<File>();
    
    for(File temp:files){
        String extName = temp.getName().substring(temp.getName().indexOf('.')+1);
        if("zip".equals(extName) || "sql".equals(extName)){
            fileList.add(temp);
        }else if("dat".equals(extName)){
            //此處還需要根據加密狗過濾無權的試卷（加密狗權限識別碼）。
            //實訓雲平台加密狗版本號、標識及權限：
            //0=ER=加密狗加載錯誤
            //104=HN=財務核算實訓雲平台
            //105=HO=財務管理實訓雲平台
            //106=HP=管理信息化實訓雲平台
            String permissionsDescribedString = temp.getName().split("_")[1];
            char[] pd = permissionsDescribedString.toCharArray();

            //財務核算實訓雲平台104對應第一個元素
            if("104".equals(encrypt) && pd[0]=='y'){
                datFileList.add(temp);
            }else

            //財務管理實訓雲平台105對應第二個元素
            if("105".equals(encrypt) && pd[1]=='y'){
                datFileList.add(temp);
            }else

            //管理信息化實訓雲平台106對應第三個元素
            if("106".equals(encrypt) && pd[2]=='y'){
                datFileList.add(temp);
            }
            
        } 
    }

    //對zip和sql文件名按從小到大排序
    Collections.sort(fileList, new Comparator<File>() {
        @Override
        public int compare(File o1, File o2) {
            if (o1.isDirectory() && o2.isFile())
                return -1;
            if (o1.isFile() && o2.isDirectory())
                return 1;
            return o1.getName().compareTo(o2.getName());
        }
    });

    
    
    
    //對比補丁包和sql文件，找出文件名（時間）大於傳來的名稱
    if(fileList.size()>0){

        
        for(int i=0;i<fileList.size();i++){
            
            String tempFileName = ((File) fileList.get(i)).getName();
            
            //System.out.println(tempFileName);
            
            String qzName = tempFileName.split("\\.")[0];//取前綴
            String hzName = tempFileName.split("\\.")[1];//取后綴

            
            
            //if(tempName)
            
            if("zip".equals(hzName)){

                //傳來的最后一次更新名有可能為空
                if(!"".equals(lastZipName)){
            
                    //大於傳來的文件名的就是客戶端還未更新的文件，將文件名記入list作為結果返回
                    long lastUpdatepatchNameInt = Long.parseLong(lastZipName.split("\\.")[0]);
                    long tempNameInt = Long.parseLong(qzName);
                    if(tempNameInt>lastUpdatepatchNameInt){

                        result += ","+tempFileName;
                    }
                }else{

                    result += ","+tempFileName;
                }
            }else if("sql".equals(hzName)){

                //傳來的最后一次更新名有可能為空
                if(!"".equals(lastSqlName)){
            
                    //大於傳來的文件名的就是客戶端還未更新的文件，將文件名記入list作為結果返回
                    long lastUpdatepatchNameInt = Long.parseLong(lastSqlName.split("\\.")[0]);
                    long tempNameInt = Long.parseLong(qzName);
                    if(tempNameInt>lastUpdatepatchNameInt){

                        result += ","+tempFileName;
                    }
                }else{

                    result += ","+tempFileName;
                }
            }
                
            
            
        }

        
    }
    
    
    //對dat文件進行分組排序，同套試卷的找出最新包，返回最新包名
    if(datFileList.size()>0){

        
        //創建map，對試卷更新包按試卷編碼分組存儲。
        HashMap<String,ArrayList<File>> paperMap = new HashMap<String,ArrayList<File>>();
        for(int i=0;i<datFileList.size();i++){
            File datFile = (File)datFileList.get(i);//當前文件
            String paperNumber = datFile.getName().split("_")[0];//取得試卷號（作為map的key）
            ArrayList<File> tempList = paperMap.get(paperNumber);//從map中取該試卷的所有更新（一個ArrayList集合）
            if(tempList==null){
                tempList = new ArrayList<File>();//如果為空，說明是第一次，則創建一個。
            }
            tempList.add(datFile);//將當前文件添加進list
            paperMap.put(paperNumber,tempList);//將list放回map
            
        }
        
        //遍歷map，對各試卷分組的更新包進行按日期（明細）排序，取最后一個（最新包）名稱。
        for (String key : paperMap.keySet()) {
            ArrayList<File> tempList = paperMap.get(key);

            //文件名按從小到大排序
            Collections.sort(tempList, new Comparator<File>() {
                @Override
                public int compare(File o1, File o2) {
                    if (o1.isDirectory() && o2.isFile())
                        return -1;
                    if (o1.isFile() && o2.isDirectory())
                        return 1;
                    return o1.getName().compareTo(o2.getName());
                }
            });

            
            
            //取排序后的最后一個的名稱
            String lastPaperVersion = tempList.get(tempList.size()-1).getName();
            //遍歷最后更新的試卷包名集合，檢查更新，如果傳來的試題包名中找不到lastPaperVersion，則說明試卷有新版本，則返回給客戶端。
            if(paperNames!=null && paperNames.size()>0){
                boolean flag = false;
                for(String temp : paperNames){
                    if(temp.equals(lastPaperVersion)){
                        flag = true;
                        break;
                    }
                }
                
                if(flag==false){

                    result += ","+lastPaperVersion;            
                }
            }else{
                result += ","+lastPaperVersion;//如果沒有傳來任何試卷信息，服務端卻又試卷更新包，那么說明有新的更新，客戶端初次安裝就是這種情況。
            }
            
        }
        
    }
    
    
    
    
    
    if(!"".equals(result)){
        result = result.substring(1);
    }
    
}


out.print(result);

%>

 

客戶端：

請求檢查更新js（用到了jquery）:

var global_system_update_files=null;

$(document).ready(function(){




    /**
     *  自動更新流程:
     *  1.先得到本地最后一次更新的包名,請求遠程服務器,將包名上報,得到還未更新的文件列表
     *  2.判斷返回的列表,如果有記錄,則彈出自動更新提示,管理員點立即更新后,循環遍歷文件列表,並請求后台執行更新.
     *  3.更新完一個包就顯示一個進度.
     */

    $.ajax({
        url:"exam_admin/common/updater!checkUpdate",
        type:"post",
        async:true,
        cache:false,
        success:function(data,status){
            var systemFiles = data.names;

            var tips = "";
            tips += "<div id='updateTips' style='position:absolute;width:auto; display:inline-block !important; display:inline; top:4px;right:4px;line-height:20px;border:1px solid orangered;background-color:orange;text-align:center;padding:4px;'>";


            if(systemFiles!=null && systemFiles!="" && systemFiles!="error"){
                systemFiles = systemFiles.split(",");
                global_system_update_files = systemFiles;

                var zipCount = 0;
                var sqlCount = 0;
                var datCount = 0;
                for(var i=0;i<systemFiles.length;i++){
                    var extendName = systemFiles[i].split(".")[1];
                    if(extendName=="zip"){
                        zipCount++;
                    }
                    else if(extendName=="sql"){
                        sqlCount++;
                    }
                    else if(extendName=="dat"){
                        datCount++;
                    }

                }




               tips += "發現";
                if(zipCount>0){
                    tips += zipCount+"個程序更新,";
                }
                if(sqlCount>0){
                    tips += sqlCount+"個數據庫更新,";
                }
                if(datCount>0){
                    tips += datCount+"個試題更新,";
                }

                tips += "<a href='javascript:updateSystem()'>立即更新</a>";
                tips += "</div>";
                $(document.body).append(tips);

            }else if(systemFiles=="error"){

                tips += "更新檢查失敗,請檢查網絡或加密狗是否正常.";
                tips += "</div>";
                $(document.body).append(tips);
            }


        }
    });



    //



});

 

后台請求檢查更新方法(java struts2 action)：

    /***
     * 檢查更新
     * 請求服務器,獲得需要更新的補丁包或sql文件列表以及需要對比的最新試題包名.
     *
     * 補丁包和sql作為程序更新,與試題包的處理不同,本方法會獲得:
     * 還未更新的補丁包(包括zip和sql文件),所有最新試題包文件名
     * 還未更新的補丁包可以直接進行安裝,而試題更新包名需要與本地相關試卷最后一次更新進對比后確認是否執行更新.
     *
     * @return
     */
    public String checkUpdate(){

        names = "error";

        String dirPath = ServletActionContext.getServletContext().getRealPath("/");//得到目標目錄的絕對路徑
        ///Users/jianyuchen/IdeaProjects/git_project/chanjetedu-exam-standard/exam-admin-mvc/target/exam-admin-mvc-prod-1.0-SNAPSHOT/
        //路徑為webroot,取更新包名應該用../,也就是到exam/webapps下

        String lastUpdateNames = "";

        //定位文件,如果找不到,也說明是初次使用自動更新功能,則創建一個包目錄,用於存放下載的文件
        File file = new File(dirPath+"../"+lastUpdateFileDirName+"/");
        if(!file.exists()){
            file.mkdir();
            lastUpdateNames = "";
        }else{

            File[] files=file.listFiles();

            String namesparameter = "";
            if(files.length>0){
                for(File temp:files){
                    namesparameter += ","+temp.getName();
                }
                lastUpdateNames = namesparameter.substring(1);
            }else{
                lastUpdateNames = "";
            }

        }


        //根據最后一次更新文件名查詢遠程服務器還未更新的文件名串,返回的數據格式:201710201741.sql,201710201741.zip,201710201744.zip,201710201745.zip
        try {

            Integer encrypt = 106;//moduleEncryption.getVersion();//將加密狗信息傳給服務器,服務器返回有權限更新的文件列表(不同的加密狗試題權限是不同的).
            String url = server+"check_update.jsp?lastUpdateFileNames="+lastUpdateNames+"&encrypt="+encrypt;
            HttpURLConnection huc = (HttpURLConnection) new URL(url).openConnection();
            //創建輸入流讀取器對象
            BufferedReader br = new BufferedReader(new InputStreamReader(huc.getInputStream(), "utf-8"));
            huc.connect();
            String data = "";
            String line = null;
            //循環按行讀取文本流
            while ((line = br.readLine()) != null) {
                data += ("\r\n" + line);
            }
            data = data.trim();

            names = data;
            huc.disconnect();
        }catch (Exception e){
            e.printStackTrace();
        }


        return "checkUpdate";
    }

 

 

前端通過上面的方法得到需要更新的文件列表字符串，遍歷文件名請求后台執行更新的js

/***
 * 執行更新函數
 * 函數將遍歷文件名列表,挨個挨個請求后台進行下載安裝.
 */
function updateSystem(){
    if(global_system_update_files!=null && global_system_update_files.length>0){

        var index = 0;




        //創建一個匿名函數去執行請求
        (function(){

            var name = global_system_update_files[index];



            var funarg = arguments;//得到匿名函數本身引用

            $("#updateTips").html("正在安裝第"+(index+1)+"個更新:"+name);

            //請求后台執行更新
            $.ajax({
                url:"exam_admin/common/updater!executeUpdate?name="+name,
                type:"post",
                async:true,
                cache:false,
                success:function(data,status){

                    //所有的更新完后則不再遞歸執行.
                    if(index==global_system_update_files.length-1){

                        $("#updateTips").css("border","1px solid #00aa00").css("background-color","#66ff66");
                        $("#updateTips").html("更新完成,請重啟服務器后再使用!");
                        return;
                    }

                    index++;

                    //匿名函數自我遞歸調用,執行下一個更新
                    setTimeout(function(){
                        funarg.callee();
                    },2000);



                },
                error:function(){
                    $("#updateTips").css("border","1px solid orangered").css("background-color","lightcoral");
                    $("#updateTips").html("第"+(index+1)+"個更新:"+name+"安裝失敗.");

                }
            });



        })();







    }

}

 

后台下載執行更新

    /***
     * 執行更新
     * 下載文件,判斷類型,執行解壓或調用sql腳本執行器或執行試題的更新
     * @return
     */
    public String executeUpdate(){

        System.out.println("正在安裝:"+name);


        String webapps = ServletActionContext.getServletContext().getRealPath("/")+"../";//得到目標目錄的絕對路徑

        String ext = name.substring(name.length()-3);

        //刪除上一次更新的文件
        File f=new File(webapps+""+lastUpdateFileDirName+"/");
        File[] fs=f.listFiles();
        for(File t:fs){

            //不同后綴的文件只會有一個,所以后綴相等就找到了上次更新的文件,然后刪掉
            if(!"dat".equals(ext)){
                if(t.getName().split("\\.")[1].equals(ext)){
                    t.delete();
                }
            }else{//由於試卷更新包dat文件組織和命名比較特殊,需要特殊處理
                //試題更新包名稱格式:666_yyn_20171205.dat
                //刪除試題更新包時,應對比試卷號,不能刪除掉其他試卷包.

                String tempName1 = t.getName().split("_")[0];
                String tempName2 = name.split("_")[0];
                if(tempName1.equals(tempName2)){
                    t.delete();
                }

            }

        }


        //1.根據文件名從遠程服務器下載文件
        String url = server+"files/"+name;

        String tempfilename = url.substring(url.lastIndexOf("/")+1,url.lastIndexOf("."));
        File download=new File(webapps+""+lastUpdateFileDirName+"/"+name);
        byte[] tempfile = null;
        try {
            URL u = new URL(url);
            InputStream is = u.openStream();

            //取得文件真實類型（不通過后綴和content-type）
            //BufferedInputStream bis = new BufferedInputStream(is);
            //String fileType = HttpURLConnection.guessContentTypeFromStream(bis);
            //System.out.println(fileType);

            FileOutputStream os = new FileOutputStream(download);
            byte[] buffer = new byte[1024];
            int length = -1;
            while((length = is.read(buffer))!=-1){
                os.write(buffer,0,length);
            }
            is.close();
            os.flush();
            os.close();
        } catch (Exception e) {
            e.printStackTrace();
        }

        //2.判斷文件類型,如果是zip執行解壓覆蓋,如果是sql,調用sql腳本執行,如果是dat(試題)文件,則執行導入.
        if(("zip").equals(ext)){
            //程序更新

            System.out.println("正在解壓"+name);

            ZipFile zip=null;
            InputStream in=null;
            OutputStream out=null;

            try {
                zip=new ZipFile(download);
                Enumeration<?> entries=zip.entries();
                while(entries.hasMoreElements()){
                    ZipEntry entry=(ZipEntry) entries.nextElement();
                    String zipEntryName=entry.getName();
                    in=zip.getInputStream(entry);

                    String outPath=(webapps+zipEntryName).replace("\\*", "/");
                    //判斷路徑是否存在，不存在則創建文件路徑
                    File file=new File(outPath.substring(0, outPath.lastIndexOf('/')));
                    if(!file.exists()){
                        file.mkdirs();
                    }
                    //判斷文件全路徑是否為文件夾,如果是上面已經創建,不需要解壓
                    if(new File(outPath).isDirectory()){
                        continue;
                    }
                    out=new FileOutputStream(outPath);

                    byte[] buf=new byte[4*1024];
                    int len;
                    while((len=in.read(buf))>=0){
                        out.write(buf, 0, len);
                    }
                    in.close();

                    //System.out.println("==================解壓完畢==================");
                }
            } catch (Exception e) {
                //System.out.println("==================解壓失敗==================");
                //刪除執行失敗的更新包,以便下次再次更新.
                download.delete();
                e.printStackTrace();

            }finally{
                try {
                    if(zip!=null){
                        zip.close();
                    }
                    if(in!=null){
                        in.close();
                    }
                    if(out!=null){
                        out.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

        }else if(("sql").equals(ext)){
            //sql腳本


            System.out.println("正在執行"+name);

            StringBuffer sb = new StringBuffer();
            try{
                BufferedReader br = new BufferedReader(new FileReader(download));//構造一個BufferedReader類來讀取文件
                String s = null;
                while((s = br.readLine())!=null){//使用readLine方法，一次讀一行
                    sb.append(System.lineSeparator()+s);
                }
                br.close();
                updaterService.ddl_executeSqlScript(sb);
            }catch(Exception e){
                //刪除執行失敗的更新包,以便下次再次更新.
                download.delete();
                e.printStackTrace();
            }

        }else if(("dat").equals(ext)){
            //試卷更新

            //調用試卷包處理方法
            HashMap<String,Object> paperDetailMap;//創建題數據map
            try {
                // 解密,雲平台導出題是用1進行加的密,解密時也用1解密,雲平台TblpaperAction的DEFAULT_PASS變量.
                byte[] buffer = Files.toByteArray(download);
                paperDetailMap = Encryptor.i("1").decrypt(HashMap.class, buffer);

                if(paperDetailMap != null && !paperDetailMap.isEmpty()){
                    paperDetailMap.put("orgcode",getCookieValue(Constant.SESSION_ADMIN_ORGCODE));
                    paperDetailMap.put("adminUserid",getCookieValue(Constant.SESSION_ADMINUSERID));

                    /***
                     * 獲取map對象中所有圖片的byte[],並讀出到相應路徑的文件中
                     * 1、確定圖片路徑
                     * 2、將圖片讀出到指定路徑下
                     * 3、刪除map中的圖片信息
                     */
                    paperDetailMap = tblpaperService.exportPictureToLocalPath(getRequest(),paperDetailMap);
                    //新添加的方法，2017.08.10 by wangweiaw  end

                    //將上傳的試卷信息保存到數據庫,此方法會判斷是否已存在,已存在會刪除,再新增.
                    tblpaperService.ddl_savePaperDetailByMap(paperDetailMap);
                }else{

                }

            }catch(Exception ex){
                //刪除執行失敗的更新包,以便下次再次更新.
                download.delete();
                ex.printStackTrace();
            }


        }


        //執行完等待200毫秒,防止網速太快,執行太快,前端進度一閃而過,搞慢點,顯示個進度效果.
        try {
            Thread.currentThread().sleep(200);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        return "executeUpdate";
    }