package com.shlanbao.tzsc.pms.msg.info.controller;

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

import javax.servlet.http.HttpServletRequest;

import com.shlanbao.tzsc.base.mapping.MdEquipment;
import com.shlanbao.tzsc.pms.sys.user.beans.UserBean;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.shlanbao.tzsc.base.controller.BaseController;
import com.shlanbao.tzsc.base.mapping.MsgInfo;
import com.shlanbao.tzsc.base.model.DataGrid;
import com.shlanbao.tzsc.base.model.Json;
import com.shlanbao.tzsc.base.model.PageParams;
import com.shlanbao.tzsc.pms.msg.info.beans.MsgInfoBean;
import com.shlanbao.tzsc.pms.msg.info.service.MsgInfoServiceI;
import com.shlanbao.tzsc.utils.tools.StringUtil;

/**
 * 机台通知信息管理控制类 增删改查操作
 * @author yangbo
 *
 */
@Controller
@RequestMapping("/pms/msg")
public class MsgInfoController extends BaseController{
	protected Logger log = Logger.getLogger(this.getClass());
	@Autowired
	protected MsgInfoServiceI msgInfoService;
	
	@RequestMapping("/gotoMsgInfo")
	public String gotoMsgInfo(HttpServletRequest request){
		//设置当前用户的操作 控制审批或者签发按钮的显示
		try {
			request.setAttribute("msgOperator", msgInfoService.getCurrUserOperator());
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "/pms/msg/info/msgInfo";
	}
	
	@RequestMapping("/gotoMsgInfoForm")
	public String gotoMsgInfoForm(String id,HttpServletRequest request){
		try {
			if(id!=null){
				MsgInfoBean msgInfoById = msgInfoService.getMsgInfoById(id);
//				List<MdEquipment> mdEquipments = msgInfoService.queryMdequipment();
				//组装告警信息中设备选择状态
//				msgInfoService.getMsgEqu(msgInfoById,mdEquipments);
				if(StringUtil.notNull(id)){
					request.setAttribute("msgInfo", msgInfoById);
				}
				//查询设备表
//				request.setAttribute("mdEquipments", mdEquipments);
			}

		} catch (Exception e) {
			e.printStackTrace();
		}
		return "/pms/msg/info/msgInfoForm";
	}
	@RequestMapping("/gotoMsgInfoApprove")
	public String gotoMsgInfoApprove(String id,HttpServletRequest request){
		try {
			if(StringUtil.notNull(id))
				request.setAttribute("msgInfo", msgInfoService.getMsgInfoBeanById(id));
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "/pms/msg/info/msgInfoApprove";
	}
	@RequestMapping("/gotoMsgInfoIssuer")
	public String gotoMsgInfoIssuer(String id,HttpServletRequest request){
		try {
			if(StringUtil.notNull(id))
				request.setAttribute("msgInfo", msgInfoService.getMsgInfoBeanById(id));
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "/pms/msg/info/msgInfoIssuer";
	}
	
	@RequestMapping("/openMsgInfoView")
	public String openMsgInfoView(String id,HttpServletRequest request){
		try {
			if(StringUtil.notNull(id)){
				request.setAttribute("msgInfo", msgInfoService.getMsgInfoBeanById(id));
				request.setAttribute("msgInfos", msgInfoService.getMsgInfoApprove(id));
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "/pms/msg/info/msginfoView";
	}

	/**
	 *
	 * @param msgInfo
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/saveOrUpdateMsgInfo")
	public Json saveOrUpdateMsgInfo(MsgInfo msgInfo){
		Json json = new Json();
		try {
			Json st= msgInfoService.addMsgInfo(msgInfo);
			if(st.isSuccess()==false){
				json.setMsg(st.getMsg());
				json.setSuccess(false);		
			}else{		
				json.setMsg("操作成功");
				json.setSuccess(true);
			}
		} catch (Exception e) {
			json.setMsg("操作失败");
			json.setSuccess(false);
			e.printStackTrace();
		}
		return json;
	}
	
	
	/**
	 * 保存审批信息，更改机台通知信息发布状态
	 * @param msgInfo
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/saveMsgInfo")
	public Json saveMsgInfo(MsgInfo msgInfo){
		Json json = new Json();
		try {
			msgInfoService.saveMsgInfo(msgInfo);
			json.setMsg("操作成功");
			json.setSuccess(true);
		} catch (Exception e) {
			json.setMsg("操作失败");
			json.setSuccess(false);
			e.printStackTrace();
		}
		return json;
	}

	/**
	 * @param msgInfo id
	 * @return
	 * @desc 保存消息的推送状态
	 */
	@ResponseBody
	@RequestMapping("/saveMsgSend")
	public Json saveMsgSend(MsgInfo msgInfo){
		Json json = new Json();
		try {
			Map<String,Object> param = new HashMap<>();
			param.put("msg",msgInfo);
			//需要推送到wct的设备code
			param.put("eid",msgInfo.getEid());
			param.put("type",msgInfo.getSendType());
			boolean b = msgInfoService.pushToWctOrPms(param);
            if(b){
				msgInfoService.addMsgInfo(msgInfo);
				json.setMsg("操作成功");
				json.setSuccess(true);
			}else {
				json.setMsg("操作失败");
				json.setSuccess(false);
			}

		} catch (Exception e) {
			json.setMsg("操作失败");
			json.setSuccess(false);
		    e.printStackTrace();

		}
		return json;
	}
	
	@ResponseBody
	@RequestMapping("/queryMsgInfo")
	public DataGrid queryMsgInfo(MsgInfoBean msgInfo,PageParams pageParams){
		try {
			DataGrid gd = msgInfoService.queryMsgInfo(msgInfo, pageParams);
			return gd;
		} catch (Exception e) {
			log.error("查询机台通知信息失败!", e);
		}
		return null;
	}
	
	@ResponseBody
	@RequestMapping("/deleteMsgInfo")
	public Json deleteMsgInfo(String id){
		Json json = new Json();
		try {
			msgInfoService.deleteMsgInfoById(id);
			json.setSuccess(true);
			json.setMsg("操作成功!");
		} catch (Exception e) {
			json.setSuccess(false);
			json.setMsg("操作失败");
			e.printStackTrace();
		}
		return json;
	}


	/**
	 * 批量删除
	 * @param ids
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/batchDeleteMsgInfo")
	public Json batchDeleteMsgInfo(String ids){
		Json json = new Json();
		try {
			msgInfoService.batchDeleteMsgInfo(ids);
			json.setSuccess(true);
			json.setMsg("操作成功!");
		} catch (Exception e) {
			json.setSuccess(false);
			json.setMsg("操作失败");
			e.printStackTrace();
		}
		return json;
	}
	
	@ResponseBody
	@RequestMapping("/getMsgInfo")
	public List<MsgInfoBean> getMsgInfo(){
		try {
			return msgInfoService.getMsgInfo();
		} catch (Exception e) {
			log.error("获取通知信息失败!", e);
		}
		return null;
	}

	@ResponseBody
	@RequestMapping("/getEquInfo")
	public List<MdEquipment> getEquInfo(UserBean userBean){
		try {
			List<MdEquipment> equInfo = msgInfoService.getEquInfo(userBean);
			//userBean  id为eid（告警下设备id集合）
			MsgInfoBean msg  = new MsgInfoBean();
			//组装告警信息中设备选择状态
			if(userBean!=null&&!StringUtils.isEmpty(userBean.getId())){
				msg.setEid(userBean.getId());
				msgInfoService.getMsgEqu(msg,equInfo);
			}

			return equInfo;
		} catch (Exception e) {
			log.error("获取设备信息失败!", e);
		}
		return null;
	}


	/**
	 * 跳转到wct在线设备弹出层
	 * @return
	 */
	@RequestMapping("/goToWctOnlineEquJsp")
	public String goToWctOnlineEquJsp(){

		return "/pms/msg/info/wctOnlineEqu";
	}

	/**
	 * @return  wct websocket在线的设备
	 */
	@ResponseBody
	@RequestMapping("/getWctOnlineEqu")
	public List<MdEquipment> getWctOnlineEqu(){
		List<MdEquipment>  list= new ArrayList<>();
		List<MdEquipment> wctOnlineEqu = msgInfoService.getWctOnlineEqu();
		if(wctOnlineEqu!=null) list.addAll(wctOnlineEqu);
		return list;
	}
}