package com.ecar.apm.controller;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import com.ecar.apm.http.client.HttpSequenceHandle;
import com.ecar.apm.model.APITestForm;
import com.ecar.apm.model.HttpRequest;
import com.ecar.apm.model.HttpRequestForm;
import com.ecar.apm.model.HttpRequestLog;
import com.ecar.apm.model.HttpSequence;
import com.ecar.apm.model.HttpSequence.MonitorType;
import com.ecar.apm.model.HttpSystem;
import com.ecar.apm.model.MonitorFrequency;
import com.ecar.apm.service.HttpRequestService;
import com.ecar.apm.service.HttpSequenceService;
import com.ecar.apm.util.GuidGenerator;
import com.ecar.apm.util.PostManResolver;
import com.github.pagehelper.StringUtil;

@Controller
public class MonitorEditController {

	protected static final Logger LOGGER = LoggerFactory.getLogger(MonitorEditController.class);

	@Autowired
	private HttpSequenceService httpSequenceService;
	
	@Autowired
	private HttpRequestService httpRequestService;


    @RequestMapping("/addSingleMonitor")
    public String addSingleMonitor(ModelMap map) {    	
    	HttpRequestForm form = new HttpRequestForm();
    	map.put("form", form);
    	return "monitor_add_single";
    }
    
	@ResponseBody
    @RequestMapping(value="/addGroup",method=RequestMethod.POST)
    public boolean addGroup(@RequestParam("systemName") String systemName){
		return httpSequenceService.addHttpSystem(systemName);
    }

	@ResponseBody
    @RequestMapping(value="/getGroups")
    public List<HttpSystem> addGroup(){
		return httpSequenceService.getAllSystem();
    }

	@ResponseBody
    @RequestMapping(value="/saveSingleMonitor",method=RequestMethod.POST)
    public boolean saveSingleMonitor(@ModelAttribute HttpRequestForm form){
		try{
			//添加
			if(StringUtil.isEmpty(form.getGuid())){
				HttpSequence httpSequence = HttpSequence.getHttpSequence(form);
				httpSequence.setGuid(GuidGenerator.generate());
				HttpRequest httpRequest = HttpRequest.getHttpRequest(form);
				httpRequest.setGuid(GuidGenerator.generate());
				httpRequest.setPguid(httpSequence.getGuid());
				httpSequenceService.insert(httpSequence);
				httpRequestService.insertHttpRequest(httpRequest);
			}else{
				//修改
				HttpSequence httpSequence = HttpSequence.getHttpSequence(form);
				HttpRequest httpRequest = HttpRequest.getHttpRequest(form);
				httpSequenceService.update(httpSequence);
				httpRequestService.updateHttpRequest(httpRequest);
			}
	        return true;
		}catch(Exception e){
			LOGGER.error("错误日志",e);
			return false;
		}
    }

    @RequestMapping("/editSingleMonitor")
    public String editSingleMonitor(ModelMap map, HttpServletRequest request) {
    	String guid = request.getParameter("guid");
    	HttpSequence httpSequence = httpSequenceService.getByGuid(guid);
    	List<HttpRequest> list = httpRequestService.getHttpRequestListByPguid(guid);
    	HttpRequest httpRequest = list.get(0);
    	HttpRequestForm form = HttpRequestForm.getHttpRequestForm(httpSequence, httpRequest);
    	map.put("form", form);
    	return "monitor_add_single";
    }

    @RequestMapping("/editSequenceMonitor")
    public String addSequenceMonitor(ModelMap map, HttpServletRequest request) {
    	String guid = request.getParameter("guid");
    	HttpSequence httpSequence;
    	if(StringUtil.isEmpty(guid)){
    		httpSequence = new HttpSequence();
    		httpSequence.setType(MonitorType.SEQUENCE);
    	}else{

        	httpSequence = httpSequenceService.getByGuid(guid);
        	List<HttpRequest> list = httpRequestService.getHttpRequestListByPguid(guid);
        	httpSequence.setHttpRequest(list);
    	}
    	map.put("form", httpSequence);
    	List<HttpSystem> systems = httpSequenceService.getAllSystem();
    	map.put("systems", systems);
    	map.put("frequencys", MonitorFrequency.values());
    	return "monitor_add_sequence";
    }

	@ResponseBody
    @RequestMapping(value="/saveSequenceMonitor",method=RequestMethod.POST)
    public boolean saveSequenceMonitor(@ModelAttribute HttpSequence httpSequence){
		try{
			//添加
			if(StringUtil.isEmpty(httpSequence.getGuid())){
				httpSequence.setGuid(GuidGenerator.generate());
				List<HttpRequest> httpRequests = httpSequence.getHttpRequest();
				for(HttpRequest request : httpRequests){
					request.setPguid(httpSequence.getGuid());
					httpRequestService.insertHttpRequest(request);
				}
				httpSequenceService.insert(httpSequence);
			}else{
				//修改
				List<HttpRequest> httpRequests = httpSequence.getHttpRequest();
				for(HttpRequest request : httpRequests){
					request.setPguid(httpSequence.getGuid());
					if(StringUtil.isEmpty(request.getGuid())){
						httpRequestService.insertHttpRequest(request);
					}else{
						httpRequestService.updateHttpRequest(request);
					}
				}
				httpSequenceService.update(httpSequence);
			}
	        return true;
		}catch(Exception e){
			LOGGER.error("错误日志",e);
			return false;
		}
    }

	@ResponseBody
    @RequestMapping(value="/resolverPostMan",method=RequestMethod.POST)
    public ArrayList<HttpRequest> resolverPostMan(@RequestParam("postmanScript") String postmanScript){
		ArrayList<HttpRequest> list = new ArrayList<HttpRequest>();
		try{
			list = PostManResolver.readV2FromJsonText(postmanScript);
			return list;
		}catch(Exception e){
			LOGGER.error("错误日志",e);
			return null;
		}
    }
	
	@ResponseBody
    @RequestMapping(value="/testApi",method=RequestMethod.POST)
    public ArrayList<APITestForm> testApi(@ModelAttribute HttpSequence httpSequence){
		try{
			 ArrayList<APITestForm> list = new ArrayList<APITestForm>();
	    	//执行接口探测
	    	HttpSequenceHandle httpSequenceHandle = new HttpSequenceHandle(httpSequence);
	    	httpSequenceHandle.execute();
	    	List<HttpRequest> requests = httpSequence.getHttpRequest();
	    	for(int i=0;i<requests.size();i++){
	    		HttpRequest request = requests.get(i);
	    		HttpRequestLog log = httpSequenceHandle.httpRequestLogList.get(i);
		    	APITestForm form = new APITestForm();
		    	form.setCostTime(log.getCostTime());
		    	form.setLog(log.getLog());
		    	form.setResponseBody(log.getResponseBody());
		    	form.setSort(request.getSort());
		    	form.setStatus(log.isStatus()?"成功":"失败");
		    	form.setStatusCode(log.getStatusCode());
		    	form.setUrl(request.getUrl());
		    	HashMap<String, String>  map = request.getVariablesMap();
				StringBuffer varables = new StringBuffer();
				if(map!=null){
					for (String key : map.keySet()) {
						varables.append(key).append("=").append(httpSequenceHandle.getVariables(key));
					}
				}
		    	form.setVariables(varables.toString());
		    	list.add(form);
	    	}
	    	return list;
		}catch(Exception e){
			LOGGER.error("错误日志",e);
			return null;
		}
	}
}