package cn.ksource.web.controller.business.pages.traffic;

import java.io.ByteArrayInputStream;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.dom4j.Attribute;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.ModelAndView;

import com.lhw.util.CRequest;
import com.lhw.util.CResponse;
import com.lhw.util.MyHttpPost;

import cn.ksource.beans.GG_USER;
import cn.ksource.beans.SC_WORKFLOW_INCIDENT;
import cn.ksource.config.SysConfigConstants;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.ParamsMapUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.SysInfo;
import cn.ksource.core.web.SysInfoMsg;
import cn.ksource.core.web.WebUtil;
import cn.ksource.web.Constants;
import cn.ksource.web.facade.incident.IncidentFacade;
import cn.ksource.web.facade.timetask.TimeTaskFacade;
import cn.ksource.web.facade.traffic.TrafficFacade;
import cn.ksource.web.service.DataDictionaryService;

/**
 * 话务管理
 * @author 高发展
 *2018-04-09
 */
@Controller
@RequestMapping("/business/pages/traffic")
public class TrafficController {
	@Autowired
	private TrafficFacade trafficFacade;
	@Autowired
	private IncidentFacade incidentFacade;
	@Autowired
	private DataDictionaryService dataDictionaryService;
	@Autowired
	private TimeTaskFacade timeTaskFacade;
	/**
	 * 通话记录
	 * @param request
	 * @return
	 */
	@RequestMapping("trafficList.html")
	public ModelAndView trafficList(HttpServletRequest request){
		ModelAndView view=new ModelAndView("/business/pages/traffic/trafficList");
		return view;
	}
	/**
	 * 通话记录数据
	 * @param model
	 * @param request
	 * @return
	 */
	@SuppressWarnings("rawtypes")
	@RequestMapping("trafficData.html")
	public ModelAndView trafficData(Model model,HttpServletRequest request,PageInfo pageInfo){
		ModelAndView view=new ModelAndView("business/pages/traffic/trafficData");
		Map param=ParamsMapUtil.getParameterMap(request);
		PageInfo info=trafficFacade.getTrafficData(param, pageInfo);
		view.addObject("info", info);
		return view;
	}
	/**
	 * 通话记录数据数量
	 * @param model
	 * @param request
	 * @param response
	 */
	@SuppressWarnings("rawtypes")
	@RequestMapping("trafficCount.html")
	public void trafficCount(Model model,HttpServletRequest request,HttpServletResponse response){
		Map param=ParamsMapUtil.getParameterMap(request);
		Integer count = trafficFacade.getTrafficCount(param);
		WebUtil.write(response, count.toString());
	}
	/**
	 * 跳转到工程师添加事件页面
	 */
	@SuppressWarnings({ "unchecked", "rawtypes" })
	@RequestMapping("trafficAddIncident.html")
	public ModelAndView engineerAddIncident(HttpServletRequest request) {
		ModelAndView view = new ModelAndView("/business/pages/traffic/addTrafficDesk");
		String orderId=request.getParameter("orderId");
		if(StringUtil.notEmpty(orderId)) {
			view.addObject("info", incidentFacade.getemplate(orderId));
		}else {
           Map map= new HashMap();
            map.put("happen_time",DateUtil.getCurrentDate14());
			view.addObject("info",map);
		}
		String repair = request.getParameter("repair");

		//查询事件类型数据字典
		List<Map> types = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.INCIDENT_TYPE);
		//取得事件类型的第一条数据
		if(null!=types && types.size()>0) {
			Map type = types.get(0);
			view.addObject("typeId", type.get("DATAKEY"));
			view.addObject("typeName", type.get("DATAVALUE"));
		}
		//查询申报方式数据字典
		List<Map> ways = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.INCIDENT_APPLY_TYPE);
		//取得申报方式的第一条数据
		if(null!=ways && ways.size()>0) {
			Map way = ways.get(0);
			view.addObject("wayId", way.get("DATAKEY"));
			view.addObject("wayName", way.get("DATAVALUE"));
		}
		//查询事件来源数据字典
		List<Map> froms = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.INCIDENT_SOURCE);
		//取得事件来源的第一条数据
		if(null!=froms && froms.size()>0) {
			Map from = froms.get(0);
			view.addObject("fromId", from.get("DATAKEY"));
			view.addObject("fromName", from.get("DATAVALUE"));
		}
		//事件来源为一键报修
		if(!StringUtil.isEmpty(repair)){
			view.addObject("fromId", Constants.INCIDENT_SOURCE_REPAIR_KEY);
			view.addObject("fromName", Constants.INCIDENT_SOURCE_REPAIR_VALUE);
		}

		//客户列表
		List<Map> cusList = incidentFacade.getCustomerList();
		view.addObject("customers", cusList);
		//查询事件优先级
		List<Map> eventPri = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.EVENT_PRI);
		view.addObject("eventPri", eventPri);
		//查询事件影响度数据字典
		List<Map> eventDg = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.EVENT_EFFECT_DG);
		view.addObject("eventDg", eventDg);

		view.addObject("types", types);
		view.addObject("ways", ways);
		view.addObject("froms", froms);

		//定义参数Map
		Map<String,String> params = ParamsMapUtil.getParameterMap(request);
		params.put("userId", WebUtil.getLoginedUserId(request));
		params.put("type","2");
		Map map = incidentFacade.getOrderNum(params);
		view.addObject("data", map);
		view.addObject("data", map);
		view.addObject("tra_id", request.getParameter("tra_id"));
		view.addObject("mobile", request.getParameter("mobile"));
		return view;
	}
	/**
	 * 工程师保存事件
	 */
	@SuppressWarnings("rawtypes")
	@RequestMapping("saveTrafficIncident.html")
	public ModelAndView engineerSaveIncident(HttpServletRequest request,HttpServletResponse response,SC_WORKFLOW_INCIDENT sc_workflow_incident) {
		Map map = incidentFacade.saveIncident(request,sc_workflow_incident);
		String incidentId = ConvertUtil.obj2StrBlank(map.get("incidentId"));
		String result = ConvertUtil.obj2StrBlank(map.get("result"));
		String nouser = ConvertUtil.obj2StrBlank(map.get("nouser"));
		String type = request.getParameter("type");
		if(result.equals("1")) {
			SysInfoMsg msg = (SysInfoMsg)map.get("msg");
			if(type.equals("1")) {
				ModelAndView modelAndView = new ModelAndView("/business/pages/incident/success");
				modelAndView.addObject("type", type);
				modelAndView.addObject("incidentId", incidentId);
				modelAndView.addObject("sysInfo", "Success");
				modelAndView.addObject("message", "操作成功");
				modelAndView.addObject("info", msg);
				return modelAndView;
			} else if (type.equals("2")) {
				ModelAndView modelAndView = new ModelAndView("redirect:/business/pages/incident/endTask.html?incidentId="+incidentId);
				return modelAndView;
			} else if (type.equals("3")) {
				ModelAndView modelAndView = new ModelAndView("redirect:/business/pages/incident/closeReason.html?incidentId="+incidentId);
				return modelAndView;
			}
			
		} else {
			if(nouser.equals("1")){
				return WebUtil.sysInfoPage(request, "服务台角色下没有人员",
						"",
						SysInfo.Error,"");
			}else{
				return WebUtil.sysInfoPage(request, "操作失败！",
						"",
						SysInfo.Error,"");
			}
		}
		return null;
	}
	/**
	 * 通话记录
	 * @param request
	 * @return
	 */
	@SuppressWarnings("rawtypes")
	@RequestMapping("trafficDetail.html")
	public ModelAndView trafficDetail(HttpServletRequest request){
		ModelAndView view=new ModelAndView("/business/pages/traffic/trafficDetail");
		Map param=ParamsMapUtil.getParameterMap(request);
		Map info=trafficFacade.getTraffic(param);
		view.addObject("info", info);
		return view;
	}
	/**
	 * 通话记录数据
	 * @param model
	 * @param request
	 * @return
	 */
	@SuppressWarnings("rawtypes")
	@RequestMapping("trafficAddData.html")
	public ModelAndView trafficAddData(Model model,HttpServletRequest request,PageInfo pageInfo){
		ModelAndView view=new ModelAndView("business/pages/traffic/trafficAddData");
		Map param=ParamsMapUtil.getParameterMap(request);
		PageInfo info=trafficFacade.getTrafficData(param, pageInfo);
		view.addObject("info", info);
		return view;
	}
	/**
	 * 通话记录数据数量
	 * @param model
	 * @param request
	 * @param response
	 */
	@SuppressWarnings("rawtypes")
	@RequestMapping("trafficAddCount.html")
	public void trafficAddCount(Model model,HttpServletRequest request,HttpServletResponse response){
		Map param=ParamsMapUtil.getParameterMap(request);
		Integer count = trafficFacade.getTrafficCount(param);
		WebUtil.write(response, count.toString());
	}
	/**
	 * 工单记录数据
	 * @param model
	 * @param request
	 * @return
	 */
	@SuppressWarnings("rawtypes")
	@RequestMapping("trafficOrderData.html")
	public ModelAndView trafficOrderData(Model model,HttpServletRequest request,PageInfo pageInfo){
		ModelAndView view=new ModelAndView("business/pages/traffic/trafficOrderData");
		Map param=ParamsMapUtil.getParameterMap(request);
		PageInfo info=trafficFacade.getTrafficOrderData(param, pageInfo);
		view.addObject("info", info);
		return view;
	}
	/**
	 * 工单记录数据数量
	 * @param model
	 * @param request
	 * @param response
	 */
	@SuppressWarnings("rawtypes")
	@RequestMapping("trafficOrderCount.html")
	public void trafficOrderCount(Model model,HttpServletRequest request,HttpServletResponse response){
		Map param=ParamsMapUtil.getParameterMap(request);
		Integer count = trafficFacade.getTrafficOrderCount(param);
		WebUtil.write(response, count.toString());
		
	}
	@SuppressWarnings({ "unused", "unchecked", "rawtypes" })
	@RequestMapping("saveTraffic.html")
	public void saveTraffic(HttpServletRequest request,HttpServletResponse response){
		String str=request.getParameter("req");
		System.out.println(str);
		String strs[]=str.split(",");
		Map param=new HashMap();
		param.put("H", strs[0].replace("H=",""));
		param.put("ch", strs[1].replace("ch=",""));
		param.put("ph", strs[2].replace("ph=",""));
		param.put("sp", strs[3].replace("sp=",""));
		param.put("ty", strs[4].replace("ty=",""));
		param.put("tm", ConvertUtil.obj2StrBlank(DateUtil.getCurrentDate6()).substring(0, 2)+strs[5].replace("tm=",""));
		param.put("op", strs[6].replace("op=",""));
		param.put("sn", strs[7].replace("sn=",""));
		param.put("so", strs[8].replace("so=",""));
		param.put("cu", strs[9].replace("cu=",""));
		param.put("dm", strs[10].replace("dm=",""));
		Map user = WebUtil.getLoginUser(request).getLoginUser();
        String userId = ConvertUtil.obj2StrBlank(user.get("ID"));
        String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM"));
		param.put("userId", userId);
		param.put("userName", userName);
		Map result=trafficFacade.saveTraffic(param);
		WebUtil.write(response, JsonUtil.map2Json(result));
	}
	@SuppressWarnings({ "unchecked", "rawtypes" })
	@RequestMapping("updateTraffic.html")
	public void updateTraffic( HttpServletRequest request,HttpServletResponse response){
		 Map param=ParamsMapUtil.getParameterMap(request);
		 System.out.println("222222222222222");
			List<Map> list=new LinkedList<Map>();
			try {
				list=dom4jReadXMLFile();
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			String code=request.getParameter("sn");
			System.out.println("code:"+code);
			String time="";
			if(list.size()>0){
				for(Map map:list){
					String sn=ConvertUtil.obj2StrBlank(map.get("sn"));
					if(sn.equals(code)){
						time=ConvertUtil.obj2StrBlank(map.get("tme"));
						param.put("time", time);
					}
				}
			}
			if(StringUtil.notEmpty(time)){
				trafficFacade.updateTraffic(param);
				System.out.println("11111111111111111");
			}
			
	}
	public static String ls() throws Exception{
		 MyHttpPost myHttpPostProxy=new MyHttpPost();		
	   		CRequest reqProxy=new CRequest();
			reqProxy.setParameter("vo_id","getCustCall");
			reqProxy.setParameter("_secs_","lcall");
			String time="";
			Long now=DateUtil.getCurrentDate8();
			time=ConvertUtil.obj2StrBlank(now).substring(0, 4)+"-"+ConvertUtil.obj2StrBlank(now).substring(4, 6)+ConvertUtil.obj2StrBlank(now).substring(6, 8);
			reqProxy.setParameter("call_date_start",time);
			
			String vproxyURL="http://"+SysConfigConstants.CALL_PATH+":"+SysConfigConstants.CALL_DK+"/v/vack";
			
			
			CResponse repProxy=myHttpPostProxy.sendRequest_XML_V4(reqProxy,vproxyURL);
			int rcode=repProxy.getRCode();
			
			if(rcode!=0){
				System.out.println("sendRequestWithTag error="+rcode+repProxy.getmsg());
				return null;
			}else{
				System.out.println(repProxy.getParameter("xml"));
				return ConvertUtil.obj2StrBlank(repProxy.getParameter("xml"));
			}
			
	}
	 @SuppressWarnings({ "unchecked", "rawtypes" })
	private static List<Map> dom4jReadXMLFile() throws Exception {  
		 String ls=ls();
		 ls.replace("utf-8", "utf8");
		 ByteArrayInputStream tInputStringStream = new ByteArrayInputStream(ls.getBytes("UTF-8"));
		 List<Map> trafficList=new LinkedList<Map>();
	        // Dom4j解析books.xml  
	        // 创建的对象reader  
	        SAXReader reader = new SAXReader();  
	        reader.setEncoding("UTF-8");
	        try {  
	            // 通过reader对象的read方法加载books.xml文件，获取document对象  
	            Document document = reader.read(tInputStringStream); 
	            reader.setEncoding("UTF8");
	            // 通过document对象获取根节点bookstore  
	            Element bookstore = document.getRootElement();  
	            // 通过element对象的elementIterator方法获取迭代器  
	            Iterator it = bookstore.elementIterator();  
	            // 全局变量记录第几本书籍  
	            int num = 0;  
	            // 遍历迭代器，获取根节点中的信息(书籍)  
	            while (it.hasNext()) {  
	                Map map=new HashMap();
	                num++;  
	                Element book = (Element) it.next();  
	                // 获取book的属性名以及属性值  
	                List<Attribute> bookAttrs = book.attributes();  
	                for (Attribute attr : bookAttrs) {  
	                    System.out.println("属性名：" + attr.getName() + "--属性值："  
	                            + attr.getStringValue());  
	                    map.put("id", attr.getStringValue())  ;
	                }  
	                // 解析子节点的信息  
	                Iterator itt = book.elementIterator();  
	                while (itt.hasNext()) {  
	                    Element bookChild = (Element) itt.next();  
	                    if (bookChild.getName().equals("id")) {  
	                        map.put("idTwo", bookChild.getStringValue());  
	                    }  
	                    if (bookChild.getName().equals("sn")) {  
	                    	 map.put("sn",bookChild.getStringValue());  
	                    }  
	                    if (bookChild.getName().equals("tms")) {  
	                    	map.put("tms",bookChild.getStringValue());  
	                    }  
	                    if (bookChild.getName().equals("tme")) {  
	                    	map.put("tme",bookChild.getStringValue());  
	                    }  
	                }  
	                trafficList.add(map);  
	            }  
	        } catch (DocumentException e) {  
	            e.printStackTrace();  
	        }  
	        return trafficList;
	    }  
	
	 /**
		 * 跳转到工程师添加事件页面
		 */
		@SuppressWarnings({ "unchecked", "rawtypes" })
		@RequestMapping("trafficYyAddIncident.html")
		public ModelAndView engineerAddIncidentYy(HttpServletRequest request) {
			ModelAndView view = new ModelAndView("/business/pages/traffic/addTrafficYyDesk");
			String orderId=request.getParameter("orderId");
			if(StringUtil.notEmpty(orderId)) {
				view.addObject("info", incidentFacade.getemplate(orderId));
			}else {
	           Map map= new HashMap();
	            map.put("happen_time",DateUtil.getCurrentDate14());
				view.addObject("info",map);
			}
			String repair = request.getParameter("repair");

			//查询事件类型数据字典
			List<Map> types = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.INCIDENT_TYPE);
			//取得事件类型的第一条数据
			if(null!=types && types.size()>0) {
				Map type = types.get(0);
				view.addObject("typeId", type.get("DATAKEY"));
				view.addObject("typeName", type.get("DATAVALUE"));
			}
			//查询申报方式数据字典
			List<Map> ways = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.INCIDENT_APPLY_TYPE);
			//取得申报方式的第一条数据
			if(null!=ways && ways.size()>0) {
				Map way = ways.get(0);
				view.addObject("wayId", way.get("DATAKEY"));
				view.addObject("wayName", way.get("DATAVALUE"));
			}
			//查询事件来源数据字典
			List<Map> froms = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.INCIDENT_SOURCE);
			//取得事件来源的第一条数据
			if(null!=froms && froms.size()>0) {
				Map from = froms.get(0);
				view.addObject("fromId", from.get("DATAKEY"));
				view.addObject("fromName", from.get("DATAVALUE"));
			}
			//事件来源为一键报修
			if(!StringUtil.isEmpty(repair)){
				view.addObject("fromId", Constants.INCIDENT_SOURCE_REPAIR_KEY);
				view.addObject("fromName", Constants.INCIDENT_SOURCE_REPAIR_VALUE);
			}

			//客户列表
			List<Map> cusList = incidentFacade.getCustomerList();
			view.addObject("customers", cusList);
			//查询事件优先级
			List<Map> eventPri = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.EVENT_PRI);
			view.addObject("eventPri", eventPri);
			//查询事件影响度数据字典
			List<Map> eventDg = dataDictionaryService.getDataDictionaryByCategoryKey(Constants.EVENT_EFFECT_DG);
			view.addObject("eventDg", eventDg);

			view.addObject("types", types);
			view.addObject("ways", ways);
			view.addObject("froms", froms);

			//定义参数Map
			Map<String,String> params = ParamsMapUtil.getParameterMap(request);
			params.put("userId", WebUtil.getLoginedUserId(request));
			params.put("type","2");
			Map map = incidentFacade.getOrderNum(params);
			view.addObject("data", map);
			view.addObject("data", map);
			view.addObject("mobile", request.getParameter("mobile"));
			return view;
		}
		@RequestMapping("saveTrafficYy.html")
		public void saveTrafficYy(HttpServletRequest request,HttpServletResponse response){
			String userId=WebUtil.getLoginedUserId(request);
			GG_USER user=new GG_USER(userId).getInstanceById();
			Map result=new HashMap();
			result.put("msg", "1");
			String gh=user.getGh();
			if(gh!=null){
				if(gh.equals("801")){
					result=timeTaskFacade.saveTrafficYy();
					WebUtil.write(response, JsonUtil.map2Json(result));
				}else{
					WebUtil.write(response, JsonUtil.map2Json(result));
				}
			}else{
				WebUtil.write(response, JsonUtil.map2Json(result));
			}
		}
		/**
		 * 北京优音工单记录数据
		 * @param model
		 * @param request
		 * @return
		 */
		@SuppressWarnings("rawtypes")
		@RequestMapping("trafficOrderDataTwo.html")
		public ModelAndView trafficOrderDataTwo(Model model,HttpServletRequest request,PageInfo pageInfo){
			ModelAndView view=new ModelAndView("business/pages/traffic/trafficOrderData");
			Map param=ParamsMapUtil.getParameterMap(request);
			PageInfo info=trafficFacade.getTrafficOrderDataTwo(param, pageInfo);
			view.addObject("info", info);
			return view;
		}
		/**
		 * 工单记录数据数量
		 * @param model
		 * @param request
		 * @param response
		 */
		@SuppressWarnings("rawtypes")
		@RequestMapping("trafficOrderCountTwo.html")
		public void trafficOrderCountTwo(Model model,HttpServletRequest request,HttpServletResponse response){
			Map param=ParamsMapUtil.getParameterMap(request);
			Integer count = trafficFacade.getTrafficOrderCountTwo(param);
			WebUtil.write(response, count.toString());
			
		}
		/**
		 * 工程师保存事件
		 */
		@SuppressWarnings("rawtypes")
		@RequestMapping("saveTrafficYyIncident.html")
		public ModelAndView engineerSaveIncidentTwo(HttpServletRequest request,HttpServletResponse response,SC_WORKFLOW_INCIDENT sc_workflow_incident) {
			Map map = incidentFacade.saveIncident(request,sc_workflow_incident);
			String incidentId = ConvertUtil.obj2StrBlank(map.get("incidentId"));
			String result = ConvertUtil.obj2StrBlank(map.get("result"));
			String nouser = ConvertUtil.obj2StrBlank(map.get("nouser"));
			String type = request.getParameter("type");
			if(result.equals("1")) {
				SysInfoMsg msg = (SysInfoMsg)map.get("msg");
				if(type.equals("1")) {
					ModelAndView modelAndView = new ModelAndView("/business/pages/incident/success");
					modelAndView.addObject("type", type);
					modelAndView.addObject("incidentId", incidentId);
					modelAndView.addObject("sysInfo", "Success");
					modelAndView.addObject("message", "操作成功");
					modelAndView.addObject("info", msg);
					return modelAndView;
				} else if (type.equals("2")) {
					ModelAndView modelAndView = new ModelAndView("redirect:/business/pages/incident/endTask.html?incidentId="+incidentId);
					return modelAndView;
				} else if (type.equals("3")) {
					ModelAndView modelAndView = new ModelAndView("redirect:/business/pages/incident/closeReason.html?incidentId="+incidentId);
					return modelAndView;
				}
				
			} else {
				if(nouser.equals("1")){
					return WebUtil.sysInfoPage(request, "服务台角色下没有人员",
							"",
							SysInfo.Error,"");
				}else{
					return WebUtil.sysInfoPage(request, "操作失败！",
							"",
							SysInfo.Error,"");
				}
			}
			return null;
		}

		
}