package cn.ksource.web.facade.wechat.ewyw;

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

import javax.servlet.http.HttpServletRequest;

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

import com.lowagie.tools.handout_pdf;

import cn.ksource.beans.SC_WORKFLOW_CI_HEALTH;
import cn.ksource.beans.WORKFLOW_BASE;
import cn.ksource.beans.WORKFLOW_NODE;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.SysInfoMsg;
import cn.ksource.core.web.WebUtil;
import cn.ksource.core.workflow.NodeAnswerEntity;
import cn.ksource.core.workflow.NodeFinishEntity;
import cn.ksource.core.workflow.WorkflowCoreService;
import cn.ksource.web.Constants;
import cn.ksource.web.entity.WorkFlowSupportEntity;
import cn.ksource.web.facade.health.HealthFacade;
import cn.ksource.web.service.workFlowSupport.WorkFlowSupportService;

@Service
public class EwHealthFacadeImpl implements EwHealthFacade {
	@Autowired
	private BaseDao baseDao;
	@Autowired
	private WorkflowCoreService workflowCoreService;
	@Autowired
	private HealthFacade healthFacade;
	@Autowired
	private WorkFlowSupportService workFlowSupportService;
	@Override
	public int ewMyHealthCount(HttpServletRequest request) {
		Map supportMap = getMyHealthListSql(request);
		String sql = "select count(*) from ( " + supportMap.get("sql").toString() + " ) t";
		return baseDao.queryForInteger(sql,(Map)supportMap.get("param"));
	}

	@Override
	public List ewMyHealthData(HttpServletRequest request) {
		Map supportMap = getMyHealthListSql(request);
		List<Map> list = baseDao.queryforSplitPage(request, supportMap.get("sql").toString(), (Map)supportMap.get("param"));
		return list;
	}
	/**
	 * 我的工单列表
	 * @param request
	 * @return
	 */
	private Map getMyHealthListSql(HttpServletRequest request){
		String userId = WebUtil.getEngineerUserId(request);
		String flowState = request.getParameter("status");
		String nodeState = request.getParameter("flowstate");
		String customerId = request.getParameter("customerId");
		String subCustomerId = request.getParameter("subCustomerId");
		String begintime = request.getParameter("begintime");
		String endtime = request.getParameter("endtime");
		
		Map paramMap = new HashMap();
		paramMap.put("userId", userId);
		paramMap.put("nodeState", nodeState);
		paramMap.put("flowState", flowState);
		paramMap.put("businessType", Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH);
		paramMap.put("customerId", customerId);
		paramMap.put("subCustomerId", subCustomerId);
		
		
		StringBuilder builder = new StringBuilder();
		builder.append(" select n.NODESTATE FLOWSTATE,b.BUSINESS_ID,n.*,b.WFNAME,b.CREATERNAME,b.CREATETIME,b.CURRENT_NODE_NAME, ");
		builder.append(" b.BUSINESSTYPE,b.CUSTOMER_NAME,b.SUB_CUSTOMER_NAME,B.WFSTATE, ");
		builder.append(" t.PLAN_EXE_DATE,r.PLAN_TIME,r.ORDER_CODE,r.ID ORDERID,r.CI_RUN_NOTE ");
		builder.append(" from SC_WORKFLOW_CI_HEALTH r  ");
		builder.append(" inner join WORKFLOW_BASE B on r.FLOW_ID = b.ID ");
		builder.append(" inner join CI_HEALTH_PLAN_TIMER t on r.ID = t.FLOW_ID ");
		builder.append(" inner join  ");
		builder.append(" ( ");
		builder.append(" 	select * from (  ");
		builder.append(" 		select CREATETIME NODETIME,ID NODEID,FLOWSTATE NODESTATE,FLOWID from WORKFLOW_NODE  ");
		builder.append(" 		where CURRENT_DEALER_ID = :userId  ");
								//环节状态
								if(StringUtil.isNotBlank(nodeState)){
									if(!nodeState.equals("end") && !nodeState.equals("close")){
										builder.append("and FLOWSTATE =:nodeState ");	
									}
								}
		builder.append(" 	order by FLOWSTATE asc	 ");
		builder.append(" 	) t group by FLOWID	 ");
		builder.append(" ) n  ");
		builder.append("  on b.ID = n.FLOWID ");
		builder.append(" where 1=1 ");
		//工单类型
		builder.append(" AND b.BUSINESSTYPE = :businessType");
		//工单状态
		if(StringUtil.isNotBlank(nodeState)){
			if(nodeState.equals("end")) {
				builder.append(" AND (b.WFSTATE = :status1 OR b.WFSTATE = :status2)");
				paramMap.put("status1", Constants.WORKFLOW_BASE_WFSTATE_EVALUATE);
				paramMap.put("status2", Constants.WORKFLOW_BASE_WFSTATE_FINISH);
			}else if(nodeState.equals("close")){
				builder.append(" AND b.WFSTATE = :status ");
				paramMap.put("status", Constants.WORKFLOW_BASE_WFSTATE_CLOSE);
			}
		}
		//客户
		if(StringUtil.isNotBlank(customerId)) {
			builder.append(" AND b.CUSTOMER_ID = :customerId ");
		}
		//下属单位
		if(StringUtil.isNotBlank(subCustomerId)) {
			builder.append(" AND b.SUB_CUSTOMER_ID = :subCustomerId ");
		}
		
		if(StringUtil.notEmpty(begintime)) {
			builder.append(" AND b.CREATETIME >= :begintime ");
			paramMap.put("begintime", begintime+"000000");
		}
		if(StringUtil.notEmpty(endtime)) {
			builder.append(" AND b.CREATETIME <= :endtime ");
			paramMap.put("endtime", endtime+"240000");
		}
		
		builder.append(" order by b.CREATETIME desc,t.PLAN_EXE_DATE desc ");
		
		Map supportMap = new HashMap();
		supportMap.put("sql", builder.toString());
		supportMap.put("param", paramMap);
		return supportMap;
	}

	@Override
	public String doOrderConfirm(HttpServletRequest request) {
        String flowId = request.getParameter("flowId");
        String nodeId = request.getParameter("nodeId");
		
		Map user = WebUtil.getEngineerMsg(request);
		String userId = ConvertUtil.obj2StrBlank(user.get("ID"));
		String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM"));
		
		NodeAnswerEntity answerEntity = new NodeAnswerEntity();
		answerEntity.setUser_id(userId);
		answerEntity.setUser_name(userName);
		WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById();
		//工单响应
		boolean result = workflowCoreService.answerNode(base, new WORKFLOW_NODE(nodeId).getInstanceById(), answerEntity);
		if(!result) {
			return "2";
		}		
		return "1";
	}

	@Override
	public Map queryHealthCalandar(HttpServletRequest request) {
		String year = request.getParameter("year");
		String month = request.getParameter("month");
		String queryType = request.getParameter("queryType");
		if(!StringUtil.notEmpty(year)) {
			year = DateUtil.getToday("yyyy");
		}
		if(!StringUtil.notEmpty(month)) {
			month = DateUtil.getToday("MM");
		}
		String time = new String();
		long nMonth = DateUtil.getCurrentDate6();
		String yearMonth = year+month;
		if(String.valueOf(nMonth).equals(yearMonth)) {
			time = DateUtil.getToday("yyyyMMdd");
		} else {
			time = yearMonth+"01";
		}
		//所在周的前一个周日和后一个周六
		Long[] sunSat = DateUtil.getSundaySaturday(Long.valueOf(time));
		List<String> weekDays = DateUtil.getBetweenTwoDateCycleList(String.valueOf(sunSat[0]), String.valueOf(sunSat[1]), 2, 1, "yyyyMMdd", "yyyyMMdd");
		//查询该月的第一天和最后一天
		String[] dates = StringUtil.queryFirstLastDate(year,month);
		//查询第一天属于周几
		long firstDay = ConvertUtil.obj2Long(dates[0].replaceAll("-", ""));
		long endDay = ConvertUtil.obj2Long(dates[1].replaceAll("-", ""));
		int week = DateUtil.getDayOfWeek(firstDay);
		List<String> allDate = new ArrayList<String>();
		for(int i=week; i>0; i--) {
			allDate.add(ConvertUtil.obj2StrBlank(DateUtil.getDateAdd(firstDay, -i, 8)));
		}
		List<String> list = new ArrayList<String>();
			list = DateUtil.getBetweenTwoDateList(ConvertUtil.obj2StrBlank(firstDay), ConvertUtil.obj2StrBlank(endDay), 2, "yyyyMMdd");
		
		for(String str : list) {
			allDate.add(str.replaceAll("-", ""));
		}
		int lastSize = 42-allDate.size();
		for(int i=1; i<=lastSize; i++) {
			allDate.add(ConvertUtil.obj2StrBlank(DateUtil.getDateAdd(endDay, i, 8)));
		}
		
		List<Map> orderList = new ArrayList<Map>();
		List<Map> planList = new ArrayList<Map>();
		Map orderSetMap = new HashMap();
		Map planSetMap = new HashMap();
		
			Map params = new HashMap();
			String selMonth = year+month;
			String bustype = "7";
			String userId = WebUtil.getEngineerUserId(request);
			params.put("selMonth", selMonth);
			if(StringUtil.isNotBlank(queryType)){
				params.put("queryType", queryType);
			}
			params.put("bustype", bustype);
			params.put("userId", userId);
			
			Map result = healthFacade.queryHealthDate(params);
			orderList=(List<Map>)result.get("orderDatas");
			planList=(List<Map>)result.get("planDatas");
		
		if(orderList!=null&&orderList.size()>0){
			for(Map map : orderList) {
				orderSetMap.put(ConvertUtil.obj2StrBlank(map.get("m_date")).replace("-", ""), "1");
			}
		}
		
		if(planList!=null&&planList.size()>0){
			for(Map map : planList) {
				planSetMap.put(ConvertUtil.obj2StrBlank(map.get("m_date")).replace("-", ""), "1");
			}
		}
		List resultList = new ArrayList();
		List weekList = new ArrayList();
		
		String today = DateUtil.getToday("yyyyMMdd");
		for(String dateStr : allDate) {
			if(orderSetMap.containsKey(dateStr)) {
				Map map = new HashMap();
				//判断当天是否有工单
				map.put("hasOrder", true);
				map.put("dateStr", dateStr);
				//判断是不是当月,如果不是当月当月颜色不一致
				String nowMonth = DateUtil.format("MM", dateStr);
				if(month.equals(nowMonth)) {
					map.put("nowMonth", 1);
				} else {
					map.put("nowMonth", 2);
				}
				//展示的日期（天）
				map.put("showMonth", DateUtil.format("dd", dateStr));
				//查询是否是当天之前
				if(dateStr.equals(today)) {
					map.put("isTody", "1");
				} else {
					if(ConvertUtil.obj2Long(today)>ConvertUtil.obj2Long(dateStr)) {
						map.put("isTody", "0");
					} else {
						if(planSetMap.containsKey(dateStr)){
							map.put("isTody", "2");
						}
						
					}
				}
				if(weekDays.contains(dateStr)) {
					weekList.add(map);
				}
				resultList.add(map);
			} else {
				Map map = new HashMap();
				map.put("hasOrder", false);
				String nowMonth = DateUtil.format("MM", dateStr);
				if(month.equals(nowMonth)) {
					map.put("nowMonth", 1);
				} else {
					map.put("nowMonth", 2);
				}
				map.put("showMonth", DateUtil.format("dd", dateStr));
				if(dateStr.equals(today)) {
					map.put("isTody", "1");
				}else {
					if(ConvertUtil.obj2Long(today)>ConvertUtil.obj2Long(dateStr)) {
						map.put("isTody", "0");
					} else {
						if(planSetMap.containsKey(dateStr)){
							map.put("isTody", "2");
						}
					}
				}
				resultList.add(map);
				
				if(weekDays.contains(dateStr)) {
					weekList.add(map);
				}
			}
		}
		
		Map resultMap = new HashMap();
		resultMap.put("monthDays", resultList);
		resultMap.put("weekDays", weekList);
		
		return resultMap;
	}
	@Override
	public int ewHealthCount(HttpServletRequest request) {
		Map supportMap = getAllHealthSql(request);
		String sql = "select count(*) from ( " + supportMap.get("sql").toString() + " ) t";
		return baseDao.queryForInteger(sql,(Map)supportMap.get("param"));
		
		
	}

	@Override
	public List ewHealthData(HttpServletRequest request) {
		Map supportMap = getAllHealthSql(request);
		List<Map> list = baseDao.queryforSplitPage(request, supportMap.get("sql").toString(), (Map)supportMap.get("param"));
		return list;
	}
	/**
	 * 工单列表
	 * @param request
	 * @return
	 */
	private Map getAllHealthSql(HttpServletRequest request){
		
		String flowState = request.getParameter("flowstate");
		String customerId = request.getParameter("customerId");
		String subCustomerId = request.getParameter("subCustomerId");
		String orderCode = request.getParameter("orderCode");
		String nodeTemplateId = request.getParameter("node");
		String begintime = request.getParameter("begintime");
		String endtime = request.getParameter("endtime");
		
		Map paramMap = new HashMap();
		paramMap.put("flowState", flowState);
		paramMap.put("customerId",  customerId);
		paramMap.put("subCustomerId", subCustomerId);
		paramMap.put("nodeTemplateId", nodeTemplateId);
		paramMap.put("orderCode", "%"+orderCode+"%");
		paramMap.put("businessType", Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH);
		
		StringBuilder builder = new StringBuilder();
		builder.append(" select b.PROJECT_NAME,b.BUSINESS_ID,b.ID FLOWID,b.WFNAME,b.CREATERNAME,b.CREATETIME,b.CURRENT_NODE_NAME,b.BUSINESSTYPE, ");
		builder.append(" t.PLAN_EXE_DATE,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(" inner join CI_HEALTH_PLAN_TIMER t on r.ID = t.FLOW_ID ");
		if(StringUtil.isNotBlank(flowState)){
			if(flowState.equals("11")){
				builder.append(" inner join WORKFLOW_NODE N on b.CURRENT_NODE_ID = n.ID ");
				builder.append(" AND N.FLOWSTATE = 1  AND N.CURRENT_DEALER_ID IS NOT NULL ");
			}
		}
		//工单类型
		builder.append(" AND b.BUSINESSTYPE = :businessType");
		if(StringUtil.isNotBlank(nodeTemplateId)){
			builder.append(" and n.NODE_TEMPLATE_ID IS NOT NULL and  n.NODE_TEMPLATE_ID =:nodeTemplateId and b.WFSTATE = 1 ");
		}
		//客户
		if(StringUtil.isNotBlank(customerId)) {
			builder.append(" AND b.CUSTOMER_ID = :customerId ");
		}
		//下属单位
		if(StringUtil.isNotBlank(subCustomerId)) {
			builder.append(" AND b.SUB_CUSTOMER_ID = :subCustomerId ");
		}
		//工单状态
		if(StringUtil.isNotBlank(flowState) && !flowState.equals("11")){
			builder.append(" AND b.WFSTATE = :flowState ");
		}
		
		if(StringUtil.notEmpty(begintime)) {
			builder.append(" AND b.CREATETIME >= :begintime ");
			paramMap.put("begintime", begintime+"000000");
		}
		if(StringUtil.notEmpty(endtime)) {
			builder.append(" AND b.CREATETIME <= :endtime ");
			paramMap.put("endtime", endtime+"240000");
		}
		
		builder.append(" order by b.CREATETIME desc,t.PLAN_EXE_DATE desc ");			
				
		Map supportMap = new HashMap();
		supportMap.put("sql",builder);
		supportMap.put("param", paramMap);
		return supportMap;
	}

	@Override
	public List queryDevices(String flowId) {
		String sqlString="SELECT C.* FROM SC_WORKFLOW_CI_HEALTH A,SC_WORKFLOW_CI_HEALTH_CIDETAIL B,CMDB_CI_BASE C WHERE A.FLOW_ID=:flowId AND B.ORDER_ID=A.ID AND C.ID=B.CI_ID";
		return baseDao.queryForList(sqlString, new SqlParameter("flowId",flowId));
	}
	
	@Override
	public Map doDispatch(SC_WORKFLOW_CI_HEALTH health,Map<String, String> param,HttpServletRequest request) {
		String orderId = param.get("orderId");
		String flowId = param.get("flowId");
		String nodeId = param.get("nodeId");
		String flowNote = param.get("flowNote");
		String executorIds = param.get("executorIds");
		String executorNames = param.get("executorNames");
		String main_executorId = param.get("main_executorId");
		Map user = WebUtil.getWywEngineerLoginUser(request);
		String[] ciIdAry = request.getParameterValues("ciId");
		String items = request.getParameter("items");
		List itemlist=JsonUtil.json2List(items);
		//更新基本信息
		health.setId(orderId).update();
		//添加巡检设备和指标（edit by peikezhan 2016.07.14）
		//addPatrolCi(orderId,ciIdAry,itemlist);
				
		//设定执行人
		List<Map> userList = new ArrayList<Map>();
		String[] executorIdAry =  executorIds.split(",");
		String[] executorNameAry =  executorNames.split(",");
		for(int i=0;i<executorIdAry.length;i++){
			Map tempMap = new HashMap();
			tempMap.put("USER_ID", executorIdAry[i]);
			tempMap.put("USER_NAME", executorNameAry[i]);
			if(executorIdAry[i].equals(main_executorId)){
				tempMap.put("IS_ADMIN", "1");
			}
			userList.add(tempMap);
		}
				
		//环节流转
		WorkFlowSupportEntity support = new WorkFlowSupportEntity();
		support.setFlowId(flowId);
		support.setNodeId(nodeId);
		support.setNote(flowNote);
		support.setUserName(user.get("ZSXM").toString());
		support.setUserId(user.get("ID").toString());
		support.setNextNodeTemplateId(Constants.HEALTH_PATROL);
		support.setNextUserList(userList);
		support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH);
		
		
		Map resultMap = new  HashMap();
		resultMap.put("result", "1");
		SysInfoMsg msg = workFlowSupportService.doOrderFlow(support);
		resultMap.put("msg", msg);
		return resultMap;
	}
	
	/**
	 * 添加巡检设备
	 * @param orderId
	 * @param ciIdAry(现在应该为CI_HEALTH_PLAN_CILIST表的ID ADD BY peikezhan2016.7.13)
	 */
	@Override
	public void addPatrolCi(String orderId, String[] ciIdAry,List itemList) {
		//删除巡检设备和巡检项！！！！！！！！！！！！！！！！！
		baseDao.execute("delete from SC_WORKFLOW_CI_HEALTH_CIDETAIL where order_id = :orderId", new SqlParameter("orderId",orderId));
		baseDao.execute("delete from SC_WORKFLOW_ITEM_HEALTH_CIDETAIL where order_id = :orderId", new SqlParameter("orderId",orderId));
		
		if(ciIdAry!=null&&ciIdAry.length>0){
			ArrayList<SqlParameter> paramList = new ArrayList<SqlParameter>();
			ArrayList<SqlParameter> paramList_item = new ArrayList<SqlParameter>();
			for(int i=0;i<ciIdAry.length;i++){
				SqlParameter param = new SqlParameter();
				String orderCiId = StringUtil.getUUID();
				param.addValue("id", orderCiId)
					.addValue("ciId", ciIdAry[i])
					.addValue("orderId", orderId);
				paramList.add(param);
				//查询设备对应巡检项
				/*StringBuilder itemSql = new StringBuilder();
				itemSql.append(" select i.ID ITEM_ID,i.ITEM_NAME from CI_HEALTH_CUSTOMIZE_DETAIL d  ");
				itemSql.append(" inner join CI_HEALTH_CUSTOMER_ITEM r  ");
				itemSql.append(" on d.CUSTOMER_ITEM_ID = r.ID  ");
				itemSql.append(" inner join CI_HEALTH_ITEM i  ");
				itemSql.append(" on r.ITEM_ID = i.ID ");
				itemSql.append(" where d.CI_PATROL_ID = :ciId ");
				List<Map> itemList = baseDao.queryForList(itemSql.toString(),new SqlParameter().addValue("ciId", ciIdAry[i]));*/
				if(itemList!=null&&itemList.size()>0){
						Map<String,String> map=(Map)itemList.get(i);
						String itemString=map.get("itemId");
						if(!StringUtil.isEmpty(itemString)){
							String items[]=itemString.split("-");
							for(int k=0;k<items.length;k++){
								SqlParameter param_item = new SqlParameter();
								param_item.addValue("id", StringUtil.getUUID())
								.addValue("orderId", orderId)
								.addValue("orderCiId", orderCiId)
								.addValue("ciId", ciIdAry[i])
								.addValue("itemId", items[k]);
								paramList_item.add(param_item);
							}
					}
				}
			}
			
			//插入设备巡检表
			String sql = " insert into SC_WORKFLOW_CI_HEALTH_CIDETAIL (ID,CI_ID,ORDER_ID,DEAL_STATE) " +
					" values (:id,:ciId,:orderId,3)";
			baseDao.executeBatch(sql, paramList);
			//插入设备指标项巡检表
			String sql_item = " insert into SC_WORKFLOW_ITEM_HEALTH_CIDETAIL " +
					" (ID,ORDER_CI_ID,ORDER_ID,CI_ID,ITEM_ID,DEAL_STATE) " +
					" values " +
					" (:id,:orderCiId,:orderId,:ciId,:itemId,3) ";
			baseDao.executeBatch(sql_item, paramList_item);
		}
	}
	
	/**
	 * 关闭工单(orderId,closeNote,nodeId)
	 * @param request
	 */
	@Override
	public void doCloseWrokFlow(HttpServletRequest request){
		String orderId = request.getParameter("orderId");
		String closeNote = request.getParameter("closeNote");
		String nodeId = request.getParameter("nodeId");
		String flowId = request.getParameter("flowId");
		String userName = WebUtil.getWywEngineerLoginUser(request).get("ZSXM").toString();
		WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById();
		NodeFinishEntity finishEntity = new NodeFinishEntity();
		finishEntity.setDeal_result(1);
		finishEntity.setDeal_note_title(userName+"关闭了工单");
		finishEntity.setDeal_note(closeNote);
		WORKFLOW_NODE node = new WORKFLOW_NODE(nodeId).getInstanceById();
		workflowCoreService.finishNode(base, node, finishEntity);
		workflowCoreService.closeWorkFlow(base);
	}
	
	@Override
	public Map doSendToManager(HttpServletRequest request) {
		String orderId = request.getParameter("orderId");
		String flowId = request.getParameter("flowId");
		String nodeId = request.getParameter("nodeId");
		String flowNote = request.getParameter("flowNote");
		String ciRunNote = request.getParameter("ciRunNote");
		String ciErrorNote = request.getParameter("ciErrorNote");
		String commonJsonList = request.getParameter("commonJsonList");
		Map user = WebUtil.getWywEngineerLoginUser(request);
		
		String updateSql = " update SC_WORKFLOW_CI_HEALTH set CI_RUN_NOTE=:ciRunNote, CI_ERROR_NOTE=:ciErrorNote " +
					" where ID =:orderId ";
		SqlParameter param = new SqlParameter().addValue("orderId", orderId)
											.addValue("ciRunNote", ciRunNote)
											.addValue("ciErrorNote", ciErrorNote);
		baseDao.execute(updateSql, param);
		
		//通用指标信息
		if(StringUtil.isNotBlank(commonJsonList)){
			saveCommontItem(commonJsonList);
		}
		
		//环节流转
		WorkFlowSupportEntity support = new WorkFlowSupportEntity();
		support.setFlowId(flowId);
		support.setNodeId(nodeId);
		support.setNote(flowNote);
		support.setUserName(user.get("ZSXM").toString());
		support.setUserId(user.get("ID").toString());
		support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH);
		Integer is_admin = new WORKFLOW_NODE(nodeId).getInstanceById().getIs_admin();
		if(is_admin!=null&&is_admin==1){
			support.setNextNodeTemplateId(Constants.HEALTH_APPROVE);
			support.setEverDealflag(true);
			support.setEverNodeTemplateId(Constants.HEALTH_DISPATCH);
		}
		
		Map resultMap = new  HashMap();
		resultMap.put("result", "1");
		SysInfoMsg msg = workFlowSupportService.doOrderFlow(support);
		resultMap.put("msg", msg);
		return resultMap;
	}
	
	private void saveCommontItem(String commonJsonList){
		List<Map> commonList = JsonUtil.json2List(commonJsonList);
		List<SqlParameter> paramList = new ArrayList<SqlParameter>();
		if(commonList!=null&&commonList.size()>0){
			for(Map common:commonList){
				SqlParameter param = new SqlParameter();
				param.addValue("result", common.get("result"))
					.addValue("commonId", common.get("commonId"))
					.addValue("note", common.get("note"));
				paramList.add(param);
			}
		}
		String sql = " update CI_HEALTH_PATROL_COMMON_RECORD set RESULT_TYPE=:result,NOTE=:note " +
				"	where ID=:commonId ";
		baseDao.executeBatch(sql,paramList);
	}
	
	@Override
	public SysInfoMsg doEndHealthFlow(HttpServletRequest request) {
		String orderId = ConvertUtil.obj2StrBlank(request.getParameter("orderId"));
		String flowId = ConvertUtil.obj2StrBlank(request.getParameter("flowId"));
		String nodeId = ConvertUtil.obj2StrBlank(request.getParameter("nodeId")); 
		String note = ConvertUtil.obj2StrBlank(request.getParameter("flowNote")); 
		Map user = WebUtil.getWywEngineerLoginUser(request);
		String userName = user.get("ZSXM").toString();
		String userId = user.get("Id").toString();
		
		//保存概况
		StringBuilder sql = getStatisSql();
		List<Map> list = baseDao.queryForList(sql.toString(),new SqlParameter("orderId",orderId));
		if(list!=null&&list.size()>0){
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for(Map map:list){
				SqlParameter param = new SqlParameter();
				param.addValue("id", StringUtil.getUUID())
					.addValue("orderId", orderId)
					.addValue("thirdid", map.get("thirdid").toString())
					.addValue("totalnum", map.get("totalnum").toString())
					.addValue("realnum", map.get("realnum").toString())
					.addValue("normalnum", map.get("normalnum").toString())
					.addValue("warnnum", map.get("warnnum").toString())
					.addValue("errornum", map.get("errornum").toString());
				paramList.add(param);
			}
			sql.setLength(0);
			sql.append(" insert into SC_WORKFLOW_CI_HEALTH_CATEGORY  ");
			sql.append(" (ID,BUS_ID,LV3_CATE_ID,TOTAL_NUM,TRUE_NUM,NORMAL_NUM,ALERT_NUM,ERROR_NUM) ");
			sql.append(" values ");
			sql.append(" (:id,:orderId,:thirdid,:totalnum,:realnum,:normalnum,:warnnum,:errornum) ");
			baseDao.executeBatch(sql.toString(), paramList);
		}
		
		//环节流转
		WorkFlowSupportEntity support = new WorkFlowSupportEntity();
		support.setFlowId(flowId);
		support.setNodeId(nodeId);
		support.setNote(note);
		support.setUserName(userName);
		support.setUserId(userId);
		support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH);
		support.setFlowEndflag(true);
		SysInfoMsg msg = workFlowSupportService.doOrderFlow(support);
		return msg;
	}
	
	/**
	 * 获取统计sql
	 * @return
	 */
	private StringBuilder getStatisSql(){
		StringBuilder builder = new StringBuilder();
		builder.append("  ");
		builder.append(" select m_total.LV3_ID thirdid,IFNULL(m_total.totalnum,0) totalnum, ");
		builder.append(" IFNULL(m_real.realnum,0) realnum, ");
		builder.append(" IFNULL(m_normal.normalnum,0) normalnum, ");
		builder.append(" IFNULL(m_warn.warnnum,0) warnnum, ");
		builder.append(" IFNULL(m_error.errornum,0) errornum ");
		builder.append(" from  ");
		builder.append(" ( ");
		builder.append(" 	select count(*) totalnum,b.LV3_ID from SC_WORKFLOW_CI_HEALTH_CIDETAIL d ");
		builder.append(" 	inner join cmdb_ci_base b  ");
		builder.append(" 	on d.CI_ID = b.ID ");
		builder.append(" 	where d.ORDER_ID = :orderId ");
		builder.append(" 	group by b.LV3_ID ");
		builder.append(" ) m_total left join  ");
		builder.append(" ( ");
		builder.append(" 	select count(*) realnum,b.LV3_ID from SC_WORKFLOW_CI_HEALTH_CIDETAIL d ");
		builder.append(" 	inner join cmdb_ci_base b  ");
		builder.append(" 	on d.CI_ID = b.ID ");
		builder.append(" 	where d.ORDER_ID = :orderId ");
		builder.append(" 	and d.DEAL_STATE=1 ");
		builder.append(" 	group by b.LV3_ID ");
		builder.append(" ) m_real on m_total.LV3_ID = m_real.LV3_ID ");
		builder.append(" left join  ");
		builder.append(" ( ");
		builder.append(" 	select count(*) normalnum,b.LV3_ID from SC_WORKFLOW_CI_HEALTH_CIDETAIL d ");
		builder.append(" 	inner join cmdb_ci_base b  ");
		builder.append(" 	on d.CI_ID = b.ID ");
		builder.append(" 	where d.ORDER_ID = :orderId ");
		builder.append(" 	and d.CI_STATE = 1 ");
		builder.append(" 	group by b.LV3_ID ");
		builder.append(" ) m_normal on m_total.LV3_ID = m_normal.LV3_ID ");
		builder.append(" left JOIN ");
		builder.append(" ( ");
		builder.append(" 	select count(*) warnnum,b.LV3_ID from SC_WORKFLOW_CI_HEALTH_CIDETAIL d ");
		builder.append(" 	inner join cmdb_ci_base b  ");
		builder.append(" 	on d.CI_ID = b.ID ");
		builder.append(" 	where d.ORDER_ID = :orderId ");
		builder.append(" 	and d.CI_STATE=2 ");
		builder.append(" 	group by b.LV3_ID ");
		builder.append(" ) m_warn on m_total.LV3_ID = m_warn.LV3_ID ");
		builder.append(" left JOIN  ");
		builder.append(" ( ");
		builder.append(" 	select count(*) errornum,b.LV3_ID from SC_WORKFLOW_CI_HEALTH_CIDETAIL d ");
		builder.append(" 	inner join cmdb_ci_base b  ");
		builder.append(" 	on d.CI_ID = b.ID ");
		builder.append(" 	where d.ORDER_ID = :orderId ");
		builder.append(" 	and d.CI_STATE=3 ");
		builder.append(" 	group by b.LV3_ID ");
		builder.append(" ) m_error on m_total.LV3_ID = m_error.LV3_ID ");
		return builder;
	}
	
	@Override
	public Map doSendback(HttpServletRequest request) {
		String orderId = request.getParameter("orderId");
		String nodeId = request.getParameter("nodeId");
		String lastNodeTemplateId = request.getParameter("lastNodeTemplateId");
		String note = request.getParameter("backNote");
		Map user = WebUtil.getWywEngineerLoginUser(request);
		String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM"));
		String userId = ConvertUtil.obj2StrBlank(user.get("ID"));
		String flowId = request.getParameter("flowId");
		
		WorkFlowSupportEntity support = new WorkFlowSupportEntity();
		support.setFlowId(flowId);
		support.setNodeId(nodeId);
		support.setUserName(userName);
		support.setUserId(userId);
		support.setNote(note);
		support.setEverNodeTemplateId(lastNodeTemplateId);
		support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH);
		
		Map resultMap = new  HashMap();
		resultMap.put("result", "1");
		SysInfoMsg msg = workFlowSupportService.doOrderSendback(support);
		resultMap.put("msg", msg);
		return resultMap;
	}
	
}