//页面初始化
$(function() {
    refreshAutosSalingTable();
});

function changeByCloudType(){
    refreshAutosSalingTable();
}

//刷新表格数据
function refreshAutosSalingTable() {
    var columns = getColumns();
    $("#autoscalingTable").table(
        {
            columnAutoWidth : false,
            url : contextPath + "autoScalingTool/getAutoScalingGroups?cloudType=" + $("#cloudType").val(),
            striped : true,
            dataType: "json",
            pagination: false,
            loadFilter : function(data) {
                return defaultLoadFilter(data);
            },
            columns : columns
        });

}

//根据类型获取需要显示的列:特殊的地方，腾讯云的伸缩组有groupid和groupname属性，而亚马逊的伸缩组主键是awsGroupName，但是同时又有一个Name标签
function getColumns(){
    var columns = [
        {
            title : "索引",
            width : "50px",
            formatter : function(value, rowData, rowIndex) {
                return (rowIndex + 1);
            },
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        },
        {
            title : "组名",
            field : "name",
            width : "20%",
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        },
       /* {
            title : "aws组名",
            field : "awsGroupName",
            hidden:true,
            width : "20%",
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        },*/
        {
            title : "主机",
            field : "ip",
            width : "30%",
          /*  align : "center",*/
            align:"left",
            formatter : function(value, rowData, rowIndex) {
                var instances = rowData.autoScalingHosts;
                if(instances == null || instances.length == 0){
                    return;
                }
                var ips = "";
                for(var index = 0;index < instances.length;index++){
                    var healthCss=' style="background-color: #5bc0de;font-weight:normal;" ';
                    var runningStatusMessage = '&nbsp;&nbsp;<a href="#"  title="健康"><span class="badge" style="background-color: #5bc0de;font-weight:normal;"><i class="fa fa-check-circle" aria-hidden="true"></i></span></a>';
                    if("Healthy"!=instances[index].runningStatus){
                        healthCss=' style="background-color: #DD514D;font-weight:normal;" ';
                        runningStatusMessage='&nbsp;&nbsp;<a href="#"  title="异常"><span class="badge" style="background-color: #DD514D;font-weight:normal;"><i class="fa fa-exclamation-circle" aria-hidden="true"></i></span></a>';
                    }
                    var protectedB = instances[index].protected;
                    var canScaleMessage='' ;
                    if(protectedB != null && protectedB != undefined){
                        if(protectedB){
                            canScaleMessage = '&nbsp;&nbsp;<a href="#"  title="该主机免于缩减"><span class="badge" style="background-color:#5bc0de;font-weight:normal;">免</span></a>';
                        }else{
                            canScaleMessage = '&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;';
                        }
                    }

                    var hostip='<span  class="label" style="font-weight:normal;">';
                    hostip+= ('<span class="badge" '+healthCss+'>'+instances[index].ip);

                    //在个别机器的chrome版本上instances[index].ip取不到值，很奇怪，因此添加一个if判断，跳过
                    if(instances[index]!=null&&instances[index].ip!=null&& instances[index].ip != undefined&&instances[index].ip!=""){
                        for(var i=0;i<=(15-instances[index].ip.length);i++){
                            hostip+="&nbsp;&nbsp;"
                        }
                    }

                    hostip += runningStatusMessage;

                    hostip += '</span>';
                    hostip += canScaleMessage;
                    hostip += '</span>';

                    //新增属性 主机标签 --tags
                    var tags = instances[index].tags;
                    if(tags != null && tags!= ""){//展示标签信息
                        hostip = hostip + "<span class=\"badge\" style=\"background-color: #5bc0de;font-weight:normal;font-size: 13px\";>标签:&nbsp;" + tags +"</span>";
                    }

                    var onehost='<h4>'+hostip+'</h4>';
                    if(protectedB){
                        ips=onehost+ips;
                    }else{
                        ips += onehost;
                    }
                }
                return ips;
            },
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        },
        {
            title : "期望容量",
            field : "desired",
            width : "50px",
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        },
        {
            title : "当前容量",
            field : "size",
            width : "50px",
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        },
        {
            title : "最少实例数",
            field : "min",
            width : "75px",
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        },
        {
            title : "最多实例数",
            field : "max",
            width : "75px",
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        },
        {
            title : "操作",
            width : "100px",
            formatter : function(value, rowData, rowIndex) {
                var tmp_protectedFromCount=0;
                var instances = rowData.autoScalingHosts;
                if(instances != null&& instances.length > 0){
                    for(var index = 0;index < instances.length;index++){
                        var protectedB = instances[index].protected;
                        var message = "";
                        if(protectedB != null && protectedB != undefined){
                            if(protectedB){
                                tmp_protectedFromCount++; // 免于缩减
                            }
                        }
                    }
                }

                var div = $("<div>");
                $("<button onclick=\"changeServer(\'"
                    + rowData.id + "\',\'"
                    + rowData.name + "\',\'"
                    + rowData.awsGroupName + "\',\'"
                    + tmp_protectedFromCount + "\',\'"
                    + rowData.desired + "\',\'"
                    + rowData.min + "\',\'"
                    + rowData.max + "\')\">").addClass(
                    "btn btn-xs btn-info").html("扩充或缩减")
                    .appendTo(div);
                return div;
            },
            styler : function(value, rowData, rowIndex){
                return {
                    "vertical-align" : "middle"
                };
            }
        } ];
    return columns;
}

//修改前原始数据,用于判断是否需要调用修改接口
var scalingGroupName;
var aws_scalingGroupName;
var souScalingGroupId;
var souProtectedFromCount;
var souDesiredCapacity;
var souMinSize;
var souMaxSize;
//需要发布的版本
var souBranch;
//原实例ip
var souInstanceIps;
//原实例ip,并且非保护
var souInstanceNoneProtectedIps;
var newInstanceIps;
var souProjectNames;
//修改伸缩组
function changeServer(scalingGroupId, groupName,awsGroupName, protectedFromCount, desiredCapacity, minSize, maxSize){
    scalingGroupName = groupName;
    aws_scalingGroupName=awsGroupName;
    souScalingGroupId = scalingGroupId;
    souProtectedFromCount = protectedFromCount;
    souDesiredCapacity = desiredCapacity;
    souMinSize = minSize;
    souMaxSize = maxSize;
    souInstanceIps="";
    newInstanceIps="";
    souProjectNames="";
    souInstanceNoneProtectedIps="";

    $("#myModalLabel").text("");
    $("#protectedFromCount").val("");
    $("#minSize").val("");
    $("#maxSize").val("");
    $("#desiredCapacity").val("");

    $("#myModalLabel").text(groupName + " : 扩充或缩减");
    $("#protectedFromCount").val(protectedFromCount);
    $("#minSize").val(minSize);
    $("#maxSize").val(maxSize);
    $("#desiredCapacity").val(desiredCapacity);
    $("#myModal").modal('show');
}

function changeOk(){
    //分支版本
    souBranch = $("#branch").val();
    if(souBranch == "" || souBranch == undefined){
        alert("需要发布的分支版本不能为空");
        return;
    }
    //异常处理
    if(souScalingGroupId == "" || souScalingGroupId == undefined
                || souProtectedFromCount == "" || souProtectedFromCount == undefined
                || souMinSize == "" || souMinSize == undefined
                || souMaxSize == "" || souMaxSize == undefined
                || souDesiredCapacity == "" || souDesiredCapacity == undefined){
        alert("异常,请重新点击 扩充或缩减 开始");
        return;
    }
    //受保护的实例数
    var protectedFromCount = $("#protectedFromCount").val();
    //最少实例数,大于等于受保护的实例数
    var minSize = $("#minSize").val();
    //最多实例数
    var maxSize = $("#maxSize").val();
    //期望实例数,大于等于最小实例数 小于等于最多实例数
    var desiredCapacity = $("#desiredCapacity").val();
    if((protectedFromCount == souProtectedFromCount) && (minSize == souMinSize)
                                                     && (maxSize == souMaxSize)
                                                     && (desiredCapacity == souDesiredCapacity)){
        alert("数据未做修改!");
        $("#myModal").modal('hide');
        return;
    }
    if(maxSize*1 < minSize*1){
        alert("期望调整的最大实例数 小于 最小实例数!");
        return;
    }else if((desiredCapacity*1 < minSize*1) || (desiredCapacity*1 > maxSize*1)){
        alert("期望调整的容量必须在最小和最大实例数之间,最大<=容量>=最小!");
        return;
    }
    var showMessage;
    if(parseInt(desiredCapacity) == parseInt(souDesiredCapacity)){
        //基础信息修改,不涉及到缩容或者扩容
        showMessage = "";
    }else{
        if(parseInt(desiredCapacity) < parseInt(souDesiredCapacity)){
            showMessage = "缩容";
        }else if(parseInt(desiredCapacity) > parseInt(souDesiredCapacity)){
            showMessage = "扩容";
        }
    }

    if(confirm("是否确定要执行?-->"+showMessage)){
        $("#myModal").modal('hide');
        var cloudParms = {};
        if(1 == $("#cloudType").val()||2 == $("#cloudType").val()){
            cloudParms.scalingGroupId = souScalingGroupId;
            cloudParms.scalingGroupName = scalingGroupName;//aws需要以伸缩组名作为主键
            cloudParms.awsScalingGroupName=aws_scalingGroupName;
            cloudParms.minSize = parseInt(minSize);
            cloudParms.maxSize = parseInt(maxSize);
            cloudParms.desiredCapacity = parseInt(desiredCapacity);
        }else{
            alert("只提供腾讯云和亚马逊云的操作!");
            return;
        }

        //2:根据实例id获取内网ip地址
        //清空
        $("#resultScalingMessage").html("");
        writeToText("第 0 步:获取原实例ip-->");
        if(1 == $("#cloudType").val()){
            souInstanceIps = getIpByGroupId(aws_scalingGroupName,souScalingGroupId);
        }else{
            souInstanceIps = getIpByGroupId(scalingGroupName,souScalingGroupId);
        }
        writeToText("获取原实例ip获取完成："+souInstanceIps);
        writeToText("获取原实例ip获取完成");
        souProjectNames = getDeployProjectNames(scalingGroupName);
        writeToText("该伸缩组部署的项目列表："+souProjectNames);

        $("#myModalMessageLabel").text(scalingGroupName + ":正在 " + showMessage);
        $("#myModalMessage").modal('show');
        $("#myModalMessage").unbind("keyup");
        $(".modal-backdrop").unbind("click");

        $("#closeButton").attr("disabled","disabled");

        //如果是缩容，并且如果是java项目的缩容，需要先停止非保护机器（kill相关机器的java项目进程，从zk中移除），再执行缩容，再拉起
        if( "缩容"==showMessage){
            if(scalingGroupName!="PCH5-memcache"&&scalingGroupName!="java-gateway-memcache"
                &&scalingGroupName!="PCH5-AutoScaling"&&scalingGroupName!="PCH5-NODE"
                &&scalingGroupName!="ELASTICSEARCH"&&scalingGroupName.indexOf("nginx")<0)
            {
                writeToText("java项目的缩容，需要先停止非受保护机器,请稍后...");

                var paramStopNoneProtectedJava={};
                paramStopNoneProtectedJava.cloudType=$("#cloudType").val();
                paramStopNoneProtectedJava.groupName=aws_scalingGroupName;
                paramStopNoneProtectedJava.groupId=souScalingGroupId;
                paramStopNoneProtectedJava.projects=souProjectNames;
                var rtnProcMsgId=stopNoneProtectedJavaProcessForUnDeploy(paramStopNoneProtectedJava);

                if(rtnProcMsgId.length>0){
                    var count=0;
                    var urlMsg=contextPath + "/javaRestart/getMessageStatus";
                    var intervalIndex = setInterval(function() {
                        $.ajax({
                            url: urlMsg,
                            type: "post",
                            dataType: "json",
                            //async: false,
                            //timeout:120000, //超时时间：120秒
                            data: {
                                ids:rtnProcMsgId
                            },
                            success: function (checkResponse) {
                                count++;
                                if(checkResponse!=null&&checkResponse.code==200&&checkResponse.data=="ok"){
                                    clearInterval(intervalIndex);
                                    writeToText(">>>---stop ok!");
                                    beginModifyScalingGroup(cloudParms,showMessage);
                                }else if(count > 30){
                                    clearInterval(intervalIndex);
                                    writeToText(">>>---超过规定的次数，直接跳过，进入下一步!");//3分钟
                                    beginModifyScalingGroup(cloudParms,showMessage);
                                }else{
                                    writeToText("..........*return process status >>>>>>"+checkResponse.data);
                                }
                            },
                            error: function (e) {
                                clearInterval(intervalIndex);
                                writeToText("getMessageStatus发生错误， 程序终止..........");
                                requestError(urlMsg);
                            }
                        });
                    }, 6000);
                }else{
                    beginModifyScalingGroup(cloudParms,showMessage);
                }
            }else{
                beginModifyScalingGroup(cloudParms,showMessage);
            }
        }else{
            beginModifyScalingGroup(cloudParms,showMessage);
        }
    }
}

function beginModifyScalingGroup(cloudParms,showMessage) {
    writeToText("开始修改伸缩组信息..........");
    $.ajax({
        url: contextPath + 'autoScalingTool/modifyScalingGroup?cloudType=' + parseInt($("#cloudType").val()),
        type: 'POST',
        data: cloudParms,
        dataType: 'json',
        success: function (data) {
            if (!data || data.code != 200) {
                alert('修改伸缩组失败:'+data.message);
            }else{
                if(showMessage == "" || showMessage == undefined){
                    alert("修改基础信息成功!");
                    clear_Sour();
                    return;
                }

                //1:开始伸缩通知,成功扩容后才能执行下一步
                refCloudMessage($("#cloudType").val(),showMessage, Math.abs(souDesiredCapacity - cloudParms.desiredCapacity),cloudParms.desiredCapacity);
            }
        },
        error: function (e) {
            alert('系统异常');
            clear_Sour();
        }
    });
}

//调用java stop
function stopNoneProtectedJavaProcessForUnDeploy(paramFront) {
    writeToText(">>> 非保护 java 项目停止，开始检查,请稍后...");
    var url = contextPath + "/autoScalingTool/stopNoneProtectedJavaProcess";
    var rtnProcMsgId="";
    $.ajax({
        url: url,
        type: "post",
        dataType: "json",
        async: false,
        data: paramFront,
        success: function (response) {
            if(response!=null&&response.code==200){
                rtnProcMsgId=response.data.rtnProcMsgId;
                var stopJavaFlag=response.data.stopJavaFlag;
                writeToText(">>>  java 项目停止，免于停止的受保护ip..."+response.data.protectedIps);
                if("1"==stopJavaFlag){
                    souInstanceNoneProtectedIps=response.data.noneProtectedIps;
                    writeToText(">>>  java 项目停止，停止的ip..."+response.data.noneProtectedIps);
                    writeToText(">>>  java 项目停止，返回操作进程列表..."+rtnProcMsgId);
                }else{
                    writeToText(">>>  java 项目停止， 不存在需要停止的机器，此步骤跳过！");
                }
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
    return rtnProcMsgId;
}

function clear_Sour(){
    //清空
    souProtectedFromCount = "";
    souDesiredCapacity = "";
    souMinSize = "";
    souMaxSize = "";
    souInstanceIps ="";
    newInstanceIps="";
    souProjectNames="";
    souInstanceNoneProtectedIps="";
}

//腾讯云:修改伸缩组后的下一个流程是查询伸缩活动
function refCloudMessage(cloudType,showMessage, serverChangeCount,desiredCapacity){
    var tmpGroupName=scalingGroupName;
    if(1 == $("#cloudType").val()){
        tmpGroupName=aws_scalingGroupName;
    }
    var url = contextPath + 'autoScalingTool/getIpsByScalingGroupId?groupName='+tmpGroupName+'&groupId='+souScalingGroupId+"&cloudType="+$("#cloudType").val();
    writeToText("开始..........");
    var count = 0;
    var errorTimes = 0;
    var intervalIndex = setInterval(function() {
        $.ajax({
            url: url,
            type: 'POST',
            dataType: 'json',
            timeout : 0,
            success: function (data) {
                if (!data || data.code != 200) {
                    errorTimes++;
                    if(errorTimes>5){
                        clearInterval(intervalIndex);
                        writeToText("发生错误data is null or data code !=200，refCloudMessage data 程序终止..........");
                        writeToText("data is "+data);
                        responseError(data);
                    }else{
                        writeToText("发生错误data is null or data code !=200，继续获取数据，请耐心等待，getIpsByScalingGroupId data errorTimes =."+errorTimes);
                        writeToText("data is "+data);
                    }
                }else{
                    //计算变化主机的ip
                    var checkPassFlag=true;
                    var changedIps="";
                    newInstanceIps="";
                    if(data.data.length != desiredCapacity){
                        checkPassFlag=false;
                    }else{
                        for(var tmp=0;tmp<data.data.length;tmp++){
                            var tmpInstIp=data.data[tmp];
                            if(tmpInstIp==null||tmpInstIp==""||tmpInstIp==undefined){
                                checkPassFlag=false;
                                newInstanceIps="";
                                break;
                            }
                            if(newInstanceIps.length>0){
                                newInstanceIps += ",";
                            }
                            newInstanceIps += tmpInstIp;
                            if(souInstanceIps.indexOf(tmpInstIp) < 0){
                                if(changedIps.length>0){
                                    changedIps += ",";
                                }
                                writeToText("扩容机器实例IP为:"+tmpInstIp);
                                changedIps += tmpInstIp;
                            }
                        }
                    }
                    if(!checkPassFlag){
                        writeToText("............"+count);
                    }else{
                        clearInterval(intervalIndex);
                        if(showMessage == "缩容"){
                            writeToText("第 1 步: 缩容成功");
                            writeToText("...");
                            unDeploy(showMessage);
                            writeToText("结束..........");
                            return;
                        }else{
                            pingHost(changedIps);
                        }
                    }
                }
                count += 1;
            },
            error: function (e) {
                errorTimes++;
                if(errorTimes>5){
                    clearInterval(intervalIndex);
                    writeToText("发生错误error，refCloudMessage 程序终止..........");
                    writeToText("error is "+e);
                    requestError(url);
                }else{
                    writeToText("发生错误error，继续获取数据，请耐心等待，getIpsByScalingGroupId data errorTimes =."+errorTimes);
                    writeToText("error is "+e);
                }
            }
        });
    }, 20000);
}

function pingHost(changedIps){
    writeToText("探测host.........."+changedIps);
    var url =contextPath  + "autoScalingTool/checkHostReachable";
    var count = 0;
    //检测ip的22端口是否通，如果全部通，则代表扩容成功

    var intervalIndex = setInterval(function() {
        $.ajax({
            url: url,
            type: "post",
            dataType: "json",
            //async: false,
            //timeout:120000, //超时时间：120秒
            data: {
                changedIps:changedIps
            },
            success: function (checkResponse) {
                if (!checkResponse || checkResponse.code != 200) {
                    clearInterval(intervalIndex);
                    writeToText("发生错误，checkHostReachable code 程序终止..........");
                    responseError(checkResponse);
                }else{
                    if(checkResponse.data=="allReachable"){
                        clearInterval(intervalIndex);
                        writeToText("第 1 步: 扩容成功");
                        writeToText("...");

                        writeToText("新扩容的内网ip合计："+changedIps);
                        //扩容成功后执行
                        deploy(changedIps);
                    }else{
                        writeToText("..........*."+count+".."+checkResponse.data);
                    }
                }
                count += 1;
            },
            error: function (e) {
                clearInterval(intervalIndex);
                writeToText("发生错误，checkHostReachable  程序终止..........");
                requestError(url);
            }
        });
    }, 20000);
}

//缩容成功后执行
function unDeploy(showMessage){
    if(scalingGroupName=="PCH5-memcache"){
        //pch5的memcache：获得镜像机器之后，把ips保存到mobject_info（监控对象）和internal_domain
        updateMemcacheInfo("pch5",showMessage);
    }else if(scalingGroupName=="java-gateway-memcache"){
        //java-gateway的memcache：获得镜像机器之后，把ips保存到mobject_info（监控对象）和internal_domain
        updateMemcacheInfo("java",showMessage);
    }else if(scalingGroupName=="PCH5-AutoScaling"||scalingGroupName=="PCH5-NODE"){
        writeToText("node项目缩，正在更新ansible deploy配置文件,请稍后...");
        updateAnsibleDeployForNode(showMessage);

        updateAnsibleDeployForNode_2_gitupstream(showMessage);
        upHostCmdbInfo(showMessage);
    }else if(scalingGroupName=="ELASTICSEARCH"){
        updateEsConfig(showMessage);
    }else if(scalingGroupName.indexOf("nginx")>=0){
        updateNginxInfo(showMessage);
    }else{
        //把之前停掉的机器启动
        if(souInstanceNoneProtectedIps!=null&&souInstanceNoneProtectedIps.length>0){
            writeToText("原stop的机器ip为 "+souInstanceNoneProtectedIps);
            var restartProcessMsgId=restartJavaProcess();
            if(restartProcessMsgId!=null&&restartProcessMsgId.length>0){
                writeToText("等待java 进程重启，检查进程restartProcessMsgId "+restartProcessMsgId);

                var urlMsg=contextPath + "/javaRestart/getMessageStatus";
                var count=0;
                var intervalIndex = setInterval(function() {
                    $.ajax({
                        url: urlMsg,
                        type: "post",
                        dataType: "json",
                        //async: false,
                        //timeout:120000, //超时时间：120秒
                        data: {
                            ids:restartProcessMsgId
                        },
                        success: function (checkResponse) {
                            count++;
                            if(checkResponse!=null&&checkResponse.code == 200&&checkResponse.data=="ok"){
                                clearInterval(intervalIndex);
                                writeToText(">>>---restart ok!");
                                //5:更新git文件
                                editToGit(showMessage);
                            }else if(count>=30){
                                clearInterval(intervalIndex);
                                writeToText(">>>---检查次数超过上线，直接跳过 !");
                                //5:更新git文件
                                editToGit(showMessage);
                            }else{
                                writeToText("..........*return process status >>>>>>"+checkResponse.data);
                            }
                        },
                        error: function (e) {
                            count++;
                            writeToText("Restart getMessageStatus发生错误,不影响整体步骤，继续");
                            //即使失败也继续进行
                            /*clearInterval(intervalIndex);
                            writeToText("getMessageStatus发生错误， 程序终止..........");
                            requestError(urlMsg);*/
                        }
                    });
                }, 6000);

            }else{
                //5:更新git文件
                editToGit(showMessage);
            }
        }else{
            writeToText("不存在需要重启的机器，直接进入下一步 ");
            //5:更新git文件
            editToGit(showMessage);
        }

    }
}

//1:扩容成功后执行
function deploy(ips){
    writeToText("第 2 步:获取内网成功!");
    if(ips == undefined || ips == null || ips == ""){
        writeToText("系统异常,执行失败....");
        deployLaster();
        return;
    }

    writeToText(">>>正在部署系统,请稍后..."+scalingGroupName);
    if(scalingGroupName=="PCH5-memcache"){
        //pch5的memcache：获得镜像机器之后，把ips保存到mobject_info（监控对象）和internal_domain
        updateMemcacheInfo("pch5");
    }else if(scalingGroupName=="java-gateway-memcache"){
        //java-gateway的memcache：获得镜像机器之后，把ips保存到mobject_info（监控对象）和internal_domain
        updateMemcacheInfo("java");
    }else if(scalingGroupName=="PCH5-AutoScaling"||scalingGroupName=="PCH5-NODE"){
        //node项目
        writeToText(">>>node项目,请稍后...");
        //3:根据ip部署项目,得到消息id
        writeToText(">>>更新到ansible_deploy,请稍后...");
        //5:node项目扩容之后，要更新到ansible_deploy
        updateAnsibleDeployForNode();

        updateAnsibleDeployForNode_2_gitupstream();

        var messageId = deployProjectForNode(ips);
        writeToText("第 3 步:node项目正在部署!messageId is "+messageId)
        deployProjectForNodeGetMsg(messageId,ips);

    }else if(scalingGroupName=="ELASTICSEARCH"){
        //伸缩ELASTICSEARCH机器
        updateEsConfig();
    }else if(scalingGroupName.indexOf("nginx")>=0){
        updateNginxInfo();
    }else{
        //普通java项目
        writeToText(">>>普通项目,请稍后...");
        //3:根据ip部署项目,得到消息id
        var messageId = deployProject(ips);
        writeToText("第 3 步:项目正在部署!messageId is "+messageId)
        //3.1:发布项目的同时获取发布的消息,由于定时器是异步行为,故下一步骤智能在内部进行
        deployProjectGetMsg(messageId,ips);
    }
}

/**************************************************************
 * memcache的伸缩:把伸缩之后的机器ip，
 * 随机均匀的分布在几个internal_donmain上
 **************************************************************/

function updateMemcacheInfo(memcacheType,showMessage){
    var paramFront={};
    paramFront.newInstanceIps = newInstanceIps;
    paramFront.cloudType=$("#cloudType").val();
    paramFront.memcacheType=memcacheType;

    //1.更新internal_domain
    writeToText("开始更新内部dns：internal_domain.......");
    var url=contextPath+'autoScalingTool/updateMemcacheInfoForInternalDomain';
    $.ajax({
        url: url,
        type: 'POST',
        data: paramFront,
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                writeToText(" ");
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
    writeToText("开始更新内部dns结束.......");

    //2.更新监控对象
    upHostMobjectInfo();

    //
    writeToText("开始刷新dns.......");
    var currentCloud="aws";
    if(2==$("#cloudType").val()){
        currentCloud="qcloud";
    }
    $.ajax({
        url: contextPath + "internalDns/refresh",
        type: 'post',
        async: false,
        dataType: "json",
        data: {
            domain: "yohoops.org.",
            environment: currentCloud
        },
        success: function (data) {

        }
    });
    writeToText("刷新dns结束.......");
    //更新主机标签
    upHostCmdbInfo(showMessage);

}

/**************************************************************
 * nginx的伸缩
 **************************************************************/

//nginx类型机器伸之后
function updateNginxInfo(showMessage){
    writeToText(">>>nginx项目,请稍后...");
    //
    writeToText(">>>nginx项目，调用本机脚本更新nginx配置...");
    var url=contextPath+'autoScalingTool/updateNginxConfig';
    var paramFront={};
    paramFront.cloudType=$("#cloudType").val();
    paramFront.newInstanceIps=newInstanceIps;
    if(scalingGroupName.toUpperCase().indexOf("PCH5")>=0){
        paramFront.nginxType="pch5";
    }else{
        paramFront.nginxType="java";
    }

    $.ajax({
        url: url,
        type: 'POST',
        data: paramFront,
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                writeToText("执行完毕");
            }
        },
        error: function (e) {
            requestError(url);
        }
    });

    upHostMobjectInfo();
    upHostCmdbInfo(showMessage);
}

/**************************************************************
 * es的伸缩
 **************************************************************/

//更新es
function updateEsConfig(showMessage){
    //elasticsearch项目，更新后台ssh
    writeToText(">>>elasticsearch项目,请稍后...");
    var url = contextPath  + "autoScalingTool/updateEsConfig";
    $.ajax({
        url: url,
        type: "post",
        dataType: "json",
        //async: false,
        data: {
            allIps:newInstanceIps
        },
        success: function (response) {
            writeToText("elasticsearch伸缩完毕");
            upHostCmdbInfo(showMessage);
        },
        error: function (e) {
            requestError(url);
        }
    });
}

/**************************************************************
 * java项目和node项目的伸缩
 **************************************************************/

//3:根据ip部署项目,返回部署的消息id,同步获取部署的进展
function deployProject(ips){
    var cloudType = "aws";
    if(2==$("#cloudType").val()){
        cloudType="qcloud";
    }
    var returnMessageId = "";
    var url = contextPath + 'autoScalingTool/deployCloudProject?projectName='+scalingGroupName+'&ips='+ips+'&branch=' + souBranch + '&environment='+cloudType;
    $.ajax({
        url: url,
        type: 'POST',
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                returnMessageId = data.data.messageids.split(',')[0];
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
    return returnMessageId;
}

function deployProjectForNode(ips){
    var cloudType = "aws";
    if(2==$("#cloudType").val()){
        cloudType="qcloud";
    }
    var returnMessageId = "";
    var url = contextPath + 'autoScalingTool/deployCloudProjectForNode?projectName='+scalingGroupName+'&ips='+ips+'&branch=' + souBranch + '&environment='+cloudType;
    $.ajax({
        url: url,
        type: 'POST',
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                returnMessageId = data.data.messageids.split(',')[0];
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
    return returnMessageId;
}

//3.1:发布项目的同时获取发布的消息
function deployProjectGetMsg(msgId, ips){
    var count=0;
    var intervalIndexMsg = setInterval(function() {
        var url = contextPath + 'autoScalingTool/getBuildMsgAfterDeploy?messageid=' + msgId+"&project="+scalingGroupName;
        $.ajax({
            url: url,
            type: 'POST',
            dataType: 'json',
            success: function (respdata3) {
                count++;
                if(respdata3!=null&&respdata3.data==true){
                    writeToText("第 3 步:系统部署成功!");
                    writeToText(respdata3.message);
                    clearInterval(intervalIndexMsg);

                    writeToText(">>>第 4 步:正在进行集成测试,请稍后...");
                    //4:集成测试
                    //integrationTest(ips);
                    writeToText(">>>集成测试暂时不需要，忽略...");

                    writeToText(">>>更新到git,请稍后...");
                    //5:更新git文件
                    editToGit();


                } else{
                    if(respdata3.message!=null&&respdata3.message.length>0){
                        writeToText(respdata3.message+"......."+count);
                    }else{
                        writeToText("......."+count);
                    }
                }
            },
            error: function (e) {
                requestError(url);
                clearInterval(intervalIndexMsg);
            }
        });
    }, 10000);
}

function deployProjectForNodeGetMsg(msgId, ips){
    var count=0;
    var intervalIndexMsg = setInterval(function() {
        var url = contextPath + 'autoScalingTool/getBuildMsgAfterDeployForNode?messageid=' + msgId+"&project="+scalingGroupName;
        $.ajax({
            url: url,
            type: 'POST',
            dataType: 'json',
            success: function (respdata3) {
                count++;
                if(respdata3!=null&&respdata3.data==true){
                    writeToText("第 3 步:系统部署成功!");
                    writeToText(respdata3.message);
                    clearInterval(intervalIndexMsg);

                    writeToText(">>>第 4 步:正在进行集成测试,请稍后...");
                    //4:集成测试
                    //integrationTest(ips);
                    writeToText(">>>集成测试暂时不需要，忽略...");

                    upHostCmdbInfo();

                } else{
                    if(respdata3.message!=null&&respdata3.message.length>0){
                        writeToText(respdata3.message+"......."+count);
                    }else{
                        writeToText("......."+count);
                    }
                }
            },
            error: function (e) {
                requestError(url);
                clearInterval(intervalIndexMsg);
            }
        });
    }, 10000);
}

function updateAnsibleDeployForNode(showMessage){
    var upDownFlag="up";//伸缩标志 ：1 伸
    if(showMessage != null && showMessage != undefined){
        upDownFlag="down"; //缩减
    }
    var paramFront={};
    paramFront.cloudType=$("#cloudType").val();
    paramFront.scalingGroupName=scalingGroupName;
    paramFront.scalingGroupId=souScalingGroupId;
    paramFront.oldInstanceIps=souInstanceIps;
    paramFront.newInstanceIps=newInstanceIps;
    paramFront.upDownFlag=upDownFlag;
    writeToText("第 5 步:开始更新node git to ansible_deploy.......");
    var url=contextPath+'autoScalingTool/updateAnsibleDeployForNode';

    paramFront.updateType="deploy";
    $.ajax({
        url: url,
        type: 'POST',
        data: paramFront,
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                writeToText(" ");
                writeToText("ansible_deploy update info is:"+data.message);
                writeToText("第 5 步: ansible_deploy update 结束.......");
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
}

function updateAnsibleDeployForNode_2_gitupstream(showMessage){
    //
    var upDownFlag="up";//伸缩标志 ：1 伸
    if(showMessage != null && showMessage != undefined){
        upDownFlag="down"; //缩减
    }
    var paramFront={};
    paramFront.cloudType=$("#cloudType").val();
    paramFront.scalingGroupName=scalingGroupName;
    paramFront.scalingGroupId=souScalingGroupId;
    paramFront.oldInstanceIps=souInstanceIps;
    paramFront.newInstanceIps=newInstanceIps;
    paramFront.upDownFlag=upDownFlag;
    writeToText("第 6 步:开始更新node git to upstream.......");
    paramFront.updateType="nginx";

    var url=contextPath+'autoScalingTool/updateAnsibleDeployForNode';
    $.ajax({
        url: url,
        type: 'POST',
        data: paramFront,
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                writeToText(" ");
                writeToText("git to upstream info is:"+data.message);
                writeToText("第 6 步:更新node git to upstream 结束.......");
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
}

//调用java stop
function restartJavaProcess() {
    writeToText(">>>java 项目 restart,请稍后...");

    var rtnProcMsgId="";
    var suoIps="";
    var tmpNewIps=newInstanceIps+",";
    var array_souInstanceIps=souInstanceNoneProtectedIps.split(",");
    for(var i=0;i<array_souInstanceIps.length;i++){
        var oldTmpIp=array_souInstanceIps[i];
        var tmpWithComm=oldTmpIp+",";
        if(tmpNewIps.indexOf(tmpWithComm)>=0){
            if(suoIps.length>0){
                suoIps+=",";
            }
            suoIps += oldTmpIp;
        }
    }
    if(suoIps.length<=0){
        writeToText(">>>java进程 不存在需要重启拉起的机器！"+suoIps);
        return "";
    }else{
        writeToText(">>>java进程 需要重启拉起的机器的ip为："+suoIps);
        var url = contextPath + "/javaRestart/stopOrRestart";
        var array_souProjectNames=souProjectNames.split(",");
        var array_suoIps=suoIps.split(",");
        for(var tmp_m=0;tmp_m<array_souProjectNames.length;tmp_m++)
        {
            for(var tmp_n=0;tmp_n<array_suoIps.length;tmp_n++)
            {
                var project=array_souProjectNames[tmp_m];
                var ip=array_suoIps[tmp_n];
                writeToText(">>>开始java 项目 restart,..."+project+"--"+ip);

                $.ajax({
                    url: url,
                    type: "post",
                    dataType: "json",
                    async: false,
                    data: {
                        cloud : "single",
                        exe :"restart",
                        ip :ip,
                        project :project
                    },
                    success: function (response) {
                        if(response!=null&&response.code==200){
                            if(rtnProcMsgId.length>0){
                                rtnProcMsgId += ",";
                            }
                            rtnProcMsgId += response.data[0].id;
                        }
                    },
                    error: function (e) {
                        requestError(url);
                    }
                });
            }
        }
        writeToText(">>>java 项目 restart,返回操作进程列表："+rtnProcMsgId);
        return rtnProcMsgId;
    }
}

//5 和 6:ip写入git
function editToGit(showMessage){
    writeToText("正在更新git-iptables,请稍后...");
    var upDownFlag="up";//伸缩标志 ：1 伸
    if(showMessage != null && showMessage != undefined){
        upDownFlag="down"; //缩减
    }
    var paramFront={};
    paramFront.cloudType=$("#cloudType").val();
    paramFront.scalingGroupName=scalingGroupName;
    paramFront.scalingGroupId=souScalingGroupId;
    paramFront.oldInstanceIps=souInstanceIps;
    paramFront.newInstanceIps=newInstanceIps;
    paramFront.upDownFlag=upDownFlag;
    var url=contextPath+'autoScalingTool/updateIpToGit';
    writeToText("第 5 步:开始更新git - app-iptable.......");
    var allProjectsArray=souProjectNames.split(",");
    for(var tmp=0;tmp<allProjectsArray.length;tmp++){
        paramFront.projectName=allProjectsArray[tmp];//每次变更的都只是项目名称
        writeToText("开始更新项目【"+paramFront.projectName+"】的iptable信息");
        $.ajax({
            url: url,
            type: 'POST',
            data: paramFront,
            dataType: 'json',
            async: false,
            success: function (data) {
                if (!data || data.code != 200) {
                    responseError(data);
                }else{
                    writeToText(" ");
                    writeToText("更新之后的ip集合是:"+data.message);
                }
            },
            error: function (e) {
                requestError(url);
            }
        });
    }
    writeToText("第 5 步:更新git - app-iptable文件成功!");

    if(scalingGroupName=="gateway"||scalingGroupName=="java-gateway"){
        writeToText("第 6 步:开始更新gateway upstream.......");
        url=contextPath+'autoScalingTool/updateGatewayUpstream';
        $.ajax({
            url: url,
            type: 'POST',
            data: paramFront,
            dataType: 'json',
            async: false,
            success: function (data) {
                if (!data || data.code != 200) {
                    responseError(data);
                }else{
                    writeToText(" ");
                    writeToText("gateway upstream update info is:"+data.message);
                    writeToText("第 6 步: gateway upstream 结束.......");
                }
            },
            error: function (e) {
                requestError(url);
            }
        });
    }

    upHostMobjectInfo();
    upHostCmdbInfo(showMessage);

}

/**************************************************************
 * 伸缩之后都需要调用，伸缩的结束方法：更新cmdb信息
 **************************************************************/

//更新主机信息到监控对象
function upHostMobjectInfo(){
    writeToText("开始更新监控对象：mobject_info.......");
    var paramFront={};
    paramFront.cloudType=$("#cloudType").val();
    paramFront.scalingGroupName=scalingGroupName;
    paramFront.newInstanceIps=newInstanceIps;

    var url=contextPath+'autoScalingTool/updateMobjectInfo';
    $.ajax({
        url: url,
        type: 'POST',
        data: paramFront,
        dataType: 'json',
        async: false,
        success: function (respBack) {
            if (!respBack || respBack.code != 200) {
                responseError(respBack);
            }else{
                writeToText(" ");
                writeToText(respBack.data);
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
    writeToText("开始更新监控对象结束.......");
}

//更新主机信息到cmdb
function upHostCmdbInfo(showMessage){
    writeToText(">>>更新主机信息到cmdb,请稍后...");
    var upDownFlag="up";//伸缩标志 ：1 伸
    if(showMessage != null && showMessage != undefined&& showMessage != "扩容"){
        upDownFlag="down"; //缩减
    }
    var paramFront={};
    paramFront.cloudType=$("#cloudType").val();
    paramFront.scalingGroupName=scalingGroupName;
    paramFront.scalingGroupId=souScalingGroupId;
    paramFront.oldInstanceIps=souInstanceIps;
    paramFront.newInstanceIps=newInstanceIps;
    paramFront.upDownFlag=upDownFlag;

    var url=contextPath+'autoScalingTool/updateToHost';
    $.ajax({
        url: url,
        type: 'POST',
        data: paramFront,
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                writeToText(" ");
                writeToText("更新主机信息到cmdb成功");

                //扩容成功后刷新数据
                refreshAutosSalingTable();
                //部署全部成功后执行
                deployLaster();
                writeToText("完毕..........");
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
}

/**************************************************************
 * 公共方法
 **************************************************************/

//获取伸缩组内的项目
function getDeployProjectNames(groupName){
    var returnProjects = "";
    var tmpEnvironment="aws";
    if(2==$("#cloudType").val()){
        tmpEnvironment="qcloud";
    }
    var url = contextPath + 'autoScalingTool/getDeployProjectNames?scalingGroupName='+groupName+"&environment="+tmpEnvironment;
    $.ajax({
        url: url,
        type: 'POST',
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                //项目信息
                returnProjects = data.data;
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
    return returnProjects;
}


//发布成功和失败都执行
function deployLaster(){
    //发布完之后,显示关闭按钮
    $("#closeButton").removeAttr("disabled");
    //成功后清空
    clear_Sour();
}

//根据伸缩组id获取内网ip地址
function getIpByGroupId(groupName,groupId){
    var returnIps = "";
    var url = contextPath + 'autoScalingTool/getIpsByScalingGroupId?groupName='+groupName+'&groupId='+groupId+"&cloudType="+$("#cloudType").val();
    $.ajax({
        url: url,
        type: 'POST',
        dataType: 'json',
        async: false,
        success: function (data) {
            if (!data || data.code != 200) {
                responseError(data);
            }else{
                //组装内网ip
                var dataJson = data.data;
                if(dataJson == undefined){
                    writeToText("系统异常,执行失败....");
                    //发布完之后,显示关闭按钮
                    $("#closeButton").removeAttr("disabled");
                    return;
                }
                //展现
                var ips = "";
                for(var i = 0;i < dataJson.length;i++){
                    if(i == dataJson.length - 1){
                        ips += dataJson[i];
                    }else{
                        ips += dataJson[i] + ",";
                    }
                    writeToText("实例id: - ip:" + dataJson[i]);
                }
                returnIps = ips;
            }
        },
        error: function (e) {
            requestError(url);
        }
    });
    return returnIps;
}


//写入消息
function writeToText(msg){
    var d = $("#resultScalingMessage").val();
    $("#resultScalingMessage").html(d + "&#13" + msg);
    var scrollTop = $("#resultScalingMessage")[0].scrollHeight;
    $("#resultScalingMessage").scrollTop(scrollTop);
}

//请求接口异常
function requestError(api){
    writeToText('系统异常:' + api);
    deployLaster();
}

//接口返回异常
function responseError(data){
    if(!data){
        writeToText('返回数据异常:data为空');
    }else{
        writeToText('返回数据异常:code=' + data.code + ',message=' + data.message);
    }
    deployLaster();
}