package cn.ksource.web.facade.uc.order;

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

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.util.TreeUtil;
import cn.ksource.core.web.WebUtil;
import cn.ksource.web.Constants;
import cn.ksource.web.facade.incident.IncidentFacade;
import cn.ksource.web.service.file.FileService;

@Service("ucHealthFacade")
public class UcHealthFacadeImpl implements UcHealthFacade {
	
	@Autowired
	private BaseDao baseDao;
	
	@Autowired
	private IncidentFacade incidentFacade;
	@Resource
	private FileService fileService;

	@Override
	public int queryHealthOrderCount(Map<String, String> params) {
		StringBuilder builder = new StringBuilder();
		
		builder = getAllHealthSql(params);
		String sql = "select count(*) from ( " + builder.toString() + " ) t" ;
		return baseDao.queryForInteger(sql.toString(),params);
	}

	@Override
	public PageInfo queryHealthOrderList(PageInfo pageInfo,
			Map<String, String> params) {
		StringBuilder builder = new StringBuilder();
		builder = getAllHealthSql(params);
		return baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), params);
	}
	
	
	/**
	 * 服务台工单列表
	 * @param request
	 * @return
	 */
	private StringBuilder getAllHealthSql(Map<String, String> params){
		String flowState = params.get("flowState");
		String subCustomerId = params.get("subCustomerId");
		
		
		StringBuilder builder = new StringBuilder();
		builder.append(" select b.ID FLOWID,b.WFNAME,b.CREATERNAME,b.CREATETIME,b.CURRENT_NODE_NAME,b.BUSINESSTYPE, ");
		builder.append(" r.ORDER_CODE,r.ID ORDERID,r.CI_RUN_NOTE,b.CUSTOMER_NAME,b.SUB_CUSTOMER_NAME,B.WFSTATE  ");
		builder.append(" from SC_WORKFLOW_CI_HEALTH r  ");
		builder.append(" inner join WORKFLOW_BASE B on r.FLOW_ID = b.ID ");
		builder.append(" where b.BUSINESSTYPE = :businessType ");
		//工单状态
		if(StringUtil.notEmpty(flowState)) {
			builder.append(" AND b.WFSTATE =:flowState ");
		}
		
		builder.append(" AND  r.CUSTOMER_ID = :customer_Id ");
		//客户
		//下属单位
		if(StringUtil.isNotBlank(subCustomerId)) {
			builder.append(" AND b.SUB_CUSTOMER_ID = :subCustomerId ");
			
		}
		//工单编号
		String orderCode = params.get("orderCode");
		if(StringUtil.notEmpty(orderCode)) {
			builder.append(" AND r.ORDER_CODE LIKE :orderCode");
			params.put("orderCode", "%"+params.get("orderCode")+"%");
		}
		return builder;
	}

	@Override
	public List<Map> getCiPatrolItem(String orderId) {
		StringBuilder sql = new StringBuilder();
		SqlParameter param = new SqlParameter("orderId",orderId);
		
		sql.append(" select b.LV3_ID CATEID,b.id CIID,d.id,b.CINAME text,'' as parentId from SC_WORKFLOW_CI_HEALTH_CIDETAIL d ") ;
		sql.append(" inner join cmdb_ci_base b on d.CI_ID = b.ID ");
		sql.append(" where d.CI_ID = b.ID and d.ORDER_ID = :orderId ");
		List<Map> categoryList = baseDao.queryForList(sql.toString(),param);
		
		sql.setLength(0);
		sql.append(" select d.ORDER_CI_ID cateId,d.id,d.DEAL_STATE,d.USER_NAME,d.ITEM_RESULT,i.ITEM_NAME from SC_WORKFLOW_ITEM_HEALTH_CIDETAIL d ");
		sql.append(" inner join CI_HEALTH_ITEM i ");
		sql.append(" on d.ITEM_ID = i.ID ");
		sql.append(" where ORDER_ID = :orderId  ");
		List<Map> dataList = baseDao.queryForList(sql.toString(),param);
		
		TreeUtil treeUtil = new TreeUtil();
		List list = treeUtil.createTreeByCate(categoryList, dataList);
		return list;
	}

	@Override
	public Map getPatrolItemInfo(String patrolItemId) {
		String sql = " select * from SC_WORKFLOW_ITEM_HEALTH_CIDETAIL where id = :patrolItemId ";
		return baseDao.queryForMap(sql,new SqlParameter("patrolItemId",patrolItemId));
	}
	
	@Override
	public Map getHealthReportInfo(String orderId, String flowId) {
		Map healthInfo = new HashMap();
		SqlParameter param = new SqlParameter();
		param.addValue("orderId", orderId)
			.addValue("flowId", flowId)
			.addValue("managerNodeId", Constants.HEALTH_APPROVE)
			.addValue("engineerNodeId", Constants.HEALTH_PATROL);
		StringBuilder sql = new StringBuilder();
		//查询基本信息
		sql.append(" select * from SC_WORKFLOW_CI_HEALTH where id=:orderId ");
		Map baseInfo = baseDao.queryForMap(sql.toString(),param);
		//查询设备信息
		sql.setLength(0);
		sql.append(" select c.id,c.name from ( ");
		sql.append(" 	select c.PID from SC_WORKFLOW_CI_HEALTH_CATEGORY h inner join cmdb_ci_category c ");
		sql.append(" 	on h.LV3_CATE_ID = c.ID ");
		sql.append(" 	where  h.BUS_ID =:orderId  ");
		sql.append(" 	group by c.PID ");
		sql.append(" ) t inner join cmdb_ci_category c on t.pid = c.id ");
		List<Map> categoryList = baseDao.queryForList(sql.toString(),param);
		if(categoryList!=null&&categoryList.size()>0){
			sql.setLength(0);
			sql.append(" select c.PID cateId,c.name,h.TOTAL_NUM totalnum,h.TRUE_NUM realnum,(h.ALERT_NUM+h.ERROR_NUM) warnnum,truncate(((h.ALERT_NUM+h.ERROR_NUM)*100/h.TRUE_NUM),2) warnrate ");
			sql.append(" from SC_WORKFLOW_CI_HEALTH_CATEGORY h inner join cmdb_ci_category c ");
			
			sql.append(" on h.LV3_CATE_ID = c.ID where h.BUS_ID =:orderId ");
			List<Map> dataList =baseDao.queryForList(sql.toString(),param);
			TreeUtil treeUtil = new TreeUtil();
			List<Map> cateList = treeUtil.createTreeByCate(categoryList, dataList);
			healthInfo.put("cateList", cateList);
		}
		List<Map> commonList = this.getCommonPatrolItem(orderId);
		
		//查询告警异常设备
		sql.setLength(0);
		sql.append(" select b.SEARCHCODE,b.CINAME,b.POSITION,h.ORDER_NOTE from SC_WORKFLOW_CI_HEALTH_CIDETAIL h  ");
		sql.append(" inner join cmdb_ci_base b on h.CI_ID = b.ID ");
		sql.append(" where (h.CI_STATE=2 or h.CI_STATE=3) and h.ORDER_ID=:orderId ");
		List<Map> ciList =baseDao.queryForList(sql.toString(),param);
		
		//项目经理环节信息
		sql.setLength(0);
		sql.append(" select DEAL_NOTE,DEALTIME,CURRENT_DEALER_NAME from workflow_node  ");
		sql.append(" where NODE_TEMPLATE_ID=:managerNodeId and FLOWID =:flowId order by CREATETIME desc LIMIT 1 ");
		Map approveNodeInfo = baseDao.queryForMap(sql.toString(),param);
		//工程师执行环节信息
		sql.setLength(0);
		sql.append(" select b.ENDTIME,n.CREATETIME,g.SJHM,n.DEALTIME,n.CURRENT_DEALER_NAME from workflow_node n ");
		sql.append(" inner join gg_user g on n.CURRENT_DEALER_ID = g.ID  ");
		sql.append(" inner join workflow_base b on b.id = n.FLOWID  ");
		sql.append(" where n.IS_ADMIN=1 and n.NODE_TEMPLATE_ID=:engineerNodeId and n.FLOWID =:flowId order by CREATETIME desc LIMIT 1 ");
		Map engineerNodeInfo = baseDao.queryForMap(sql.toString(),param);
				
		//查询关联工单信息
		List linkOrders = incidentFacade.queryOrders(flowId);
		//查询附件信息
		List<Map> fileList = fileService.getFileList(flowId,1);
		
		healthInfo.put("baseInfo", baseInfo);
		healthInfo.put("commonList", commonList);
		healthInfo.put("ciList", ciList);
		healthInfo.put("linkOrders", linkOrders);
		healthInfo.put("fileList", fileList);
		healthInfo.put("approveNodeInfo", approveNodeInfo);
		healthInfo.put("engineerNodeInfo", engineerNodeInfo);
		return healthInfo;
	}
	
	@Override
	public List<Map> getCommonPatrolItem(String orderId) {
		StringBuilder sql = new StringBuilder();
		SqlParameter param = new SqlParameter();
		param.addValue("orderId", orderId);
		//获取通用指标分类
		sql.append(" select CATEGORY_ID,CATEGORY_NAME ");
		sql.append(" from CI_HEALTH_PATROL_COMMON_RECORD ");
		sql.append(" where ORDER_ID = :orderId ");
		sql.append(" group by CATEGORY_ID ");
		List<Map> categoryList = baseDao.queryForList(sql.toString(),param);
		//获取通用指标
		sql.setLength(0);
		sql.append(" select ID,CATEGORY_ID,ITEM_ID,ITEM_NAME,RESULT_TYPE,NOTE ");
		sql.append(" from CI_HEALTH_PATROL_COMMON_RECORD ");
		sql.append(" where ORDER_ID = :orderId ");
		List<Map> dataList = baseDao.queryForList(sql.toString(),param);
		
		Map categoryMap = new HashMap();
		if(categoryList!=null&&categoryList.size()>0){
			for(Map category:categoryList){
				ArrayList<Map> children = new ArrayList<Map>();
				category.put("children", children);
				categoryMap.put(category.get("CATEGORY_ID").toString(), category);
			}
		}
		//组装树
		if(dataList!=null&&dataList.size()>0){
			for(Map data:dataList){
				if(categoryMap.get(data.get("CATEGORY_ID").toString())!=null){
					((List<Map>)((Map)categoryMap.get(data.get("CATEGORY_ID").toString())).get("children")).add(data);
				}
			}
		}
		return categoryList;
	}
	
	@Override
	public Map getHealthCiDetail(String flowId) {
		Map infoMap = new HashMap();
		StringBuilder sql = new StringBuilder();
		sql.append("SELECT B.ID AS orderCiID,C.ID AS ciID,C.SEARCHCODE,C.CINAME,C.POSITION,B.ORDER_NOTE ");
		sql.append("FROM SC_WORKFLOW_CI_HEALTH A,SC_WORKFLOW_CI_HEALTH_CIDETAIL B,CMDB_CI_BASE C ");
		sql.append("WHERE A.ID=B.ORDER_ID AND B.CI_ID=C.ID AND A.FLOW_ID=:flowId");
		List<Map> ciList=baseDao.queryForList(sql.toString(),new SqlParameter().addValue("flowId", flowId));
		if(null!=ciList && ciList.size()>0){
			for(Map ciMap:ciList){
				sql.setLength(0);
				sql.append("SELECT B.ITEM_NAME,A.ITEM_RESULT,A.ORDER_NOTE,A.USER_NAME FROM SC_WORKFLOW_ITEM_HEALTH_CIDETAIL A,CI_HEALTH_ITEM B");
				sql.append(" WHERE A.ITEM_ID=B.ID AND A.CI_ID=:ciId AND A.ORDER_CI_ID=:orderCiId ");
				List<Map> itemList=baseDao.queryForList(sql.toString(),new SqlParameter().addValue("ciId", ciMap.get("ciID")).addValue("orderCiId", ciMap.get("orderCiID")));
				if(null!=itemList && itemList.size()>0){
					for(Map map :itemList){
						if(map.get("ITEM_RESULT")!=null && StringUtil.notEmpty(map.get("ITEM_RESULT").toString())){
							map.put("ITEM_RESULT", Constants.getmapCI_HEALTH_PLAN_CI_STATE_Label(Integer.parseInt(map.get("ITEM_RESULT").toString())));
						}
					}
				}
				ciMap.put("itemList", itemList);
			}
		}
		//服务工程师
		StringBuilder selSql=new StringBuilder();
		selSql.append("SELECT A.CURRENT_DEALER_NAME FROM workflow_node A,GG_USER B WHERE A.CURRENT_DEALER_ID=B.ID AND A.FLOWID=:flowId AND A.IS_ADMIN=1 AND A.NODE_TEMPLATE_ID=:nodeId");
		Map dealerMap=baseDao.queryForMap(selSql.toString(),new SqlParameter().addValue("flowId", flowId).addValue("nodeId", Constants.HEALTH_PATROL));
		infoMap.put("dealerMap", dealerMap);
		infoMap.put("ciList", ciList);
		return infoMap;
	}
}