package com.ui.ctrl;

import com.ui.contants.HttpUriContants;
import com.ui.http.HttpRestClient;
import com.ui.model.BaseResponse;
import com.ui.model.domain.BuildMessage;
import com.ui.model.req.BuildRequest;
import com.ui.model.req.User;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.http.HttpSession;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


@RestController
@RequestMapping("nodeBuild")
public class NodeBuildCtrl {
    Logger log = LoggerFactory.getLogger(NodeBuildCtrl.class);

    @Autowired
    private HttpRestClient httpRestClient;

    private String URL = "http://172.31.16.167:8883/node/";

    @RequestMapping("/toProject")
    public ModelAndView toProject(Model model,String workJobId) {
        if(StringUtils.isNotBlank(workJobId)){
            BaseResponse response = httpRestClient.defaultGet(HttpUriContants.GET_RELEASEWORKJOB_ID + "?id=" + workJobId, BaseResponse.class);
            if(response!=null&&response.getCode()==200&&response.getData()!=null){
                Map map=(Map)response.getData();
                String releaseWorkJob_environment=(String)(map.get("environment")==null?"":map.get("environment"));

                if(releaseWorkJob_environment!=null&&releaseWorkJob_environment.length()>0&&!releaseWorkJob_environment.endsWith(",")){
                    releaseWorkJob_environment+=",";
                }
                String releaseWorkJob_project =  map.get("project")==null?"":(String)map.get("project");
                if(releaseWorkJob_project!=null&&releaseWorkJob_project.length()>0&&!releaseWorkJob_project.endsWith(",")){
                    releaseWorkJob_project += ",";
                }
                int releaseWorkJob_nodeProjectCount=0;
                for(String tmp:releaseWorkJob_project.split(",")){
                    if(tmp!=null&&tmp.length()>0){
                        releaseWorkJob_nodeProjectCount++;
                    }
                }
                model.addAttribute("releaseWorkJob_nodeProjectCount", releaseWorkJob_nodeProjectCount);
                model.addAttribute("releaseWorkJob_environment", releaseWorkJob_environment);
                model.addAttribute("releaseWorkJob_branch", map.get("branch")==null?"":(String)map.get("branch"));
                model.addAttribute("releaseWorkJob_project",releaseWorkJob_project);
                model.addAttribute("releaseWorkJob_id", workJobId);
            }
        }

        return new ModelAndView("project/node_project");
    }

    /**
     * 获取所有项目
     *
     * @return
     */
    @RequestMapping(value = "getProjects", method = RequestMethod.POST)
    @ResponseBody
    public String getProjects() {
        try {
            return httpRestClient.get(URL + "getProjects", String.class, null);
        } catch (Exception ex) {
            return "failed";
        }
    }

    /**
     * 获取所有项目
     *
     * @return
     */
    @RequestMapping(value = "getProject", method = RequestMethod.POST)
    @ResponseBody
    public String getProjects(String name) {
        try {
            return httpRestClient.get(URL + "getProject?name="+name , String.class, null);
        } catch (Exception ex) {
            return "failed";
        }
    }

    /**
     * 发布前校验
     *
     * @return
     */
    @RequestMapping(value = "check")
    @ResponseBody
    public String check(String workid,HttpSession httpSession) {

        User user = (User) httpSession.getAttribute("user");
        Map<String,String> map = new HashMap<>();
        if (!StringUtils.equals("release0", workid)){//查询用户是否有工单处理权限
            map.put("id",workid);
            map.put("user",user.getName());
            BaseResponse baseResponse = httpRestClient.defaultGet(HttpUriContants.CHECK_JOB_BY_OPERATOR,BaseResponse.class,map);
            if (baseResponse.getCode() != 200){
                return baseResponse.getMessage();
            }
        }

        return "1";

    }

    /**
     * 执行任务
     *
     * @return
     */
    @RequestMapping(value = "build", method = RequestMethod.POST)
    public ModelAndView build(String workid_name,String project_name, String environment_name, String operate_name, String branch_name, String rollbackfile_name, String hosts_name, boolean force_name, Model model, HttpSession session) {
        try {
            User user = (User) session.getAttribute("user");
            Map<String,String> map = new HashMap<>();
            if (StringUtils.equals("Deploy",operate_name) && !StringUtils.equals("release0",workid_name)){//查询用户是否有工单处理权限
                map.put("id",workid_name);
                map.put("user",user.getName());
                BaseResponse baseResponse = httpRestClient.defaultGet(HttpUriContants.UPDATE_JOB_BY_OPERATOR,BaseResponse.class,map);
                if (baseResponse.getCode() != 200){
                    model.addAttribute("environment_name", baseResponse.getMessage());
                    return new ModelAndView("project/project_build");
                }
            }
            List<BuildMessage> list = new ArrayList<>();
            BuildRequest buildRequest = new BuildRequest();
            buildRequest.setBranch(branch_name);
            buildRequest.setUser(user.getName());
            buildRequest.setEnvironment(environment_name);
            buildRequest.setRollbackfile(rollbackfile_name);
            buildRequest.setOperate(operate_name);
            buildRequest.setHost(hosts_name);
            buildRequest.setIsForce(String.valueOf(force_name));
            buildRequest.setWorkid(workid_name);

            String messageids = "";
            buildRequest.setProject(project_name);
            BuildMessage buildMessage = httpRestClient.post(URL + "build", buildRequest, BuildMessage.class);
            if (buildMessage != null) {
                list.add(buildMessage);
                messageids = messageids + buildMessage.getId() + ",";
            }
            model.addAttribute("environment_name", environment_name);
            model.addAttribute("operate_name", operate_name);
            model.addAttribute("branch_name", branch_name);
            model.addAttribute("rollbackfile_name", rollbackfile_name);
            model.addAttribute("messageids", messageids);
            model.addAttribute("messageList", list);
            model.addAttribute("hosts_name", hosts_name);

        } catch (Exception ex) {
            log.error("build", ex.toString());
        }
        return new ModelAndView("project/node_project_build");
    }

    /**
     * 获取执行结果
     *
     * @param messageid
     * @return
     */
    @RequestMapping(value = "getbuildmsg", method = RequestMethod.POST)
    @ResponseBody
    public String getbuildmsg(String messageid, String project) {
        try {
            Map<String, String> map = new HashMap<>();
            map.put("messageid", messageid);
            map.put("project", project);

            return httpRestClient.get(URL + "getbuildmsg", String.class, map);

        } catch (Exception ex) {
            return "failed";
        }
    }

    @RequestMapping(value = "cancelBuild")
    @ResponseBody
    public String cancelBuild(String id) {
        try {
            Map<String, String> map = new HashMap<>();
            map.put("id", id);
            return httpRestClient.get(URL + "cancelBuild", String.class, map);
        } catch (Exception ex) {
            return "failed";
        }
    }

    @RequestMapping(value = "rollbackList", method = RequestMethod.POST)
    @ResponseBody
    public String rollbackList(String project, String environment) {
        try {
            Map<String, String> map = new HashMap<>();
            map.put("project", project);
            map.put("environment", environment);
            return httpRestClient.get(URL + "rollbackList", String.class, map);
        } catch (Exception ex) {
            return "failed";
        }
    }

    @RequestMapping(value = "refreshGit", method = RequestMethod.POST)
    @ResponseBody
    public String refreshGit() {
        try {
            return httpRestClient.get(URL + "refreshGit", String.class, null);
        } catch (Exception ex) {
            return "failed";
        }
    }


}