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.GG_RECORD;
import cn.ksource.beans.SC_WORKFLOW_CI_REMIND;
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.page.PageInfo;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.ClientUtil;
import cn.ksource.core.web.SysInfoMsg;
import cn.ksource.core.web.WebUtil;
import cn.ksource.core.workflow.NodeAnswerEntity;
import cn.ksource.core.workflow.WorkflowCoreService;
import cn.ksource.web.Constants;
import cn.ksource.web.entity.WorkFlowSupportEntity;
import cn.ksource.web.service.order.OrderService;
import cn.ksource.web.service.record.RecordService;
import cn.ksource.web.service.workFlowSupport.WorkFlowSupportService;


@Service("ewRemindFacade")
public class EwRemindFacadeImpl implements EwRemindFacade {
	
	@Autowired
	private BaseDao baseDao;
	@Autowired
	private OrderService orderService;
	@Autowired
	private WorkFlowSupportService workFlowSupportService;
	@Autowired
	private WorkflowCoreService workflowCoreService;
	@Autowired
	private RecordService recordService;	
	
	/**
	 * 事件工单确认
	 */
	@Override
	public String doOrderConfirm(Map<String, String> param) {
		String flowId = param.get("flowId");
		
		String userId = param.get("userId");
		String userName =param.get("userName");
		
		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(base.getCurrent_node_id()).getInstanceById(), answerEntity);
		if(!result) {
			return "2";
		}		
		return "1";
	}
	
	
	/**
	 * 我的工单列表
	 */
	@Override
	public PageInfo ewMyRemindData(PageInfo pageInfo,Map<String, String> param) {
		Map supportMap = getMyRemindListSql(param);
		PageInfo list=baseDao.queryforSplitPageInfo(pageInfo, supportMap.get("sql").toString(), param);
		return list;
	}
	
	/**
	 * 我的工单数量
	 */
	@Override
	public int ewMyRemindCount(Map<String, String> param) {
		Map supportMap = getMyRemindListSql(param);
		String sql = "select count(*) from ( " + supportMap.get("sql").toString() + " ) t";
		return baseDao.queryForInteger(sql,(Map)supportMap.get("param"));
	}
	
	
	/**
	 * 我的工单列表
	 * @param request
	 * @return
	 */
	private Map getMyRemindListSql(Map<String, String> param){
		//String userId = WebUtil.getEngineerUserId(request);
		String userId =param.get("userId");
		String flowState = param.get("status");
		String nodeState = param.get("flowstate");
		String customerId = param.get("customerId");
		String subCustomerId = param.get("subCustomerId");
		String begintime = param.get("begintime");
		String endtime = param.get("endtime");
		
		
		//String userId="aba12d6ad3b9432fa3176f91a159c3c1";
		param.put("userId", userId);
		param.put("nodeState", nodeState);
		param.put("flowState", flowState);
		param.put("businessType", String.valueOf(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND));
		param.put("customerId", customerId);
		param.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,b.BUSINESSTYPE, ");
		builder.append(" t.PLAN_EXECUTION_DATE, r.ORDER_CODE,r.ID ORDERID,r.SERVICE_CONTENT,b.CUSTOMER_NAME,b.SUB_CUSTOMER_NAME,B.WFSTATE  ");
		builder.append(" from SC_WORKFLOW_CI_REMIND r  ");
		builder.append(" inner join WORKFLOW_BASE B on r.FLOW_ID = b.ID ");
		builder.append(" inner join CI_REMIND_TIMERTASK t on r.FLOW_ID = t.FLOW_ID ");
		builder.append(" inner join  ");
		builder.append(" ( ");
		builder.append(" 	select * from ( ");
		builder.append(" 	select ID NODEID, CREATETIME NODETIME,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  ");
		builder.append(" 	group by FLOWID ");
		builder.append(" ) n  ");
		builder.append("  on b.ID = n.FLOWID ");
		
		//工单类型
		builder.append(" AND b.BUSINESSTYPE = :businessType");
		//工单状态
		if(StringUtil.isNotBlank(nodeState)){
			if(nodeState.equals("end")) {
				builder.append(" AND  b.WFSTATE = :status2 ");
				//param.put("status1", String.valueOf(Constants.WORKFLOW_BASE_WFSTATE_EVALUATE));
				param.put("status2", String.valueOf(Constants.WORKFLOW_BASE_WFSTATE_FINISH));
			}else if(nodeState.equals("close")){
				builder.append(" AND b.WFSTATE = :status ");
				param.put("status", String.valueOf(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 ");
			param.put("begintime", begintime+"000000");
		}
		if(StringUtil.notEmpty(endtime)) {
			builder.append(" AND b.CREATETIME <= :endtime ");
			param.put("endtime", endtime+"240000");
		}
		builder.append(" order by n.NODESTATE ASC,n.NODETIME desc,b.CREATETIME desc ");
		
		Map supportMap = new HashMap();
		supportMap.put("sql", builder.toString());
		supportMap.put("param", param);
		return supportMap;
	}
	/**
	 * 基本信息
	 */
	@Override
	public Map queryRemindInfo(String orderId) {
		String sql = " select b.WFSTATE,h.*,t.PLAN_EXECUTION_DATE from SC_WORKFLOW_CI_REMIND h ,CI_REMIND_TIMERTASK t, WORKFLOW_BASE b " + 
					" where h.FLOW_ID = t.FLOW_ID and b.ID=h.FLOW_ID  and h.id = :orderId ";
		return baseDao.queryForMap(sql,new SqlParameter("orderId",orderId));
	}
	
	/**
	 * 例行维护报告
	 */
	@Override
	public Map getRemindeItem(Map<String, String> param) {
		String flowId= param.get("flowId");
		param.put("flowId",flowId);
		StringBuilder sql = new StringBuilder();
		sql.append("SELECT * FROM SC_WORKFLOW_CI_REMIND c ");
		sql.append(" WHERE  c.FLOW_ID=:flowId");
		Map remindMap=baseDao.queryForMap(sql.toString(), param);
		Map map =new HashMap();
		if(remindMap!=null && remindMap.size()>0){
			//服务工程师
			StringBuilder selSql=new StringBuilder();
			selSql.append("SELECT A.CURRENT_DEALER_NAME,B.SJHM 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.REMIND_DEAL));
			System.out.println(dealerMap);
			map.put("dealerMap", dealerMap);
			//应维护配置数量
			sql.setLength(0);
			param.put("orderId",String.valueOf(remindMap.get("ID")));
			sql.append("SELECT ID FROM SC_WORKFLOW_CI_REMIND_DETAIL WHERE ORDER_ID=:orderId");
			List detailCountList=baseDao.queryForList(sql.toString(),param);
			map.put("detailCount", detailCountList.size());
			if(detailCountList==null || detailCountList.size()==0)map.put("detailCount", 0);
			//实际维护配置数量
			sql.setLength(0);
			param.put("state",String.valueOf(Constants.CI_REMIND_DETAIL_STATE_ONE));
			sql.append("SELECT ID FROM SC_WORKFLOW_CI_REMIND_DETAIL WHERE ORDER_ID=:orderId AND DEAL_STATE=:state");
			List detailStateCountList=baseDao.queryForList(sql.toString(),param);
			map.put("detailStateCount", detailStateCountList.size());
			if(detailStateCountList==null || detailStateCountList.size()==0)map.put("detailStateCount", 0);
			//审核人
			sql.setLength(0);
			sql.append("SELECT * FROM WORKFLOW_NODE WHERE NODE_TEMPLATE_ID=:templateId AND FLOWID=:flowId ORDER BY CREATETIME DESC");
			param.put("templateId", "04e5ae6861fd4ef6bbc521e30b4d11bc");
			param.put("flowId", flowId);
			List<Map> nodeList=baseDao.queryForList(sql.toString(), param);
			if(nodeList!=null && nodeList.size()>0){
				map.put("node", nodeList.get(0));
			}
			//文档列表
			String fileSql = "select * from GG_FILES where EXTEND1=:BUSINESS_ID AND DEL_FLAG = 1 order by  ORDERNUM";
			List<Map> fileList = baseDao.queryForList(fileSql,new SqlParameter("BUSINESS_ID",flowId));
			map.put("fileList", fileList);
			//涉及工单列表
			List<Map> orderList=orderService.queryLinkOrders(flowId);
			if(orderList!=null && orderList.size()>0){
				for(Map orderMap:orderList){
					orderMap.put("WFSTATE", Constants.getWORKFLOW_BASE_WFSTATE_Label(orderMap.get("WFSTATE").toString()));
				}
			}
			map.put("orderList", orderList);
		}
		map.put("remindMap", remindMap);
		return map;
	}
	/**
	 * 获取例行维护日历
	 */
	@Override
	public Map queryRemindCalandar(Map<String, String> param) {
		String year = param.get("year");
		String month = param.get("month");
		String queryType = param.get("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<String,String> params = new HashMap<String,String>();
			params.putAll(param);
			String selMonth = year+month;
			String bustype = "6";
			
			String userId=param.get("userId");
			
			params.put("selMonth", selMonth);
			if(StringUtil.isNotBlank(queryType)){
				params.put("queryType", queryType);
			}
			params.put("bustype", bustype);
			params.put("userId", userId);
			params.put("customer_id", params.get("customerId"));
			Map result = queryRemindDate(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 Map queryRemindDate(Map paramMap) {
		StringBuilder builder = new StringBuilder();
		
		String queryType = ConvertUtil.obj2StrBlank(paramMap.get("queryType"));
		if(queryType.equals("1")){
			workFlowSupportService.getMyOrderDateSql(builder, paramMap);
		}else{
			workFlowSupportService.getAllOrderDateSql(builder, paramMap);
		}
		List<Map> orderDatas = baseDao.queryForList(builder.toString(), paramMap);
		
		Map resultMap = new HashMap();
		//例行维护计划
		if(StringUtil.isBlank(queryType)){
			builder.setLength(0);
			builder.append(" select DATE_FORMAT(t.PLAN_EXECUTION_DATE,'%Y-%m-%d') m_date from CI_REMIND_TIMERTASK T,CI_REMIND_CUSTOMER_ITEM I ");
			builder.append(" where t.CUSTOMER_ITEM_ID = i.ID and t.state=1 and DATE_FORMAT(t.PLAN_EXECUTION_DATE,'%Y%m') = :selMonth ");
			
			List<Map> planDatas = baseDao.queryForList(builder.toString(), paramMap);
			resultMap.put("planDatas", planDatas);
		}
		resultMap.put("orderDatas", orderDatas);
		resultMap.put(ClientUtil.SUCCESS, true);
		resultMap.put(ClientUtil.MSG, "成功");
		return resultMap;
	}
	/**
	 * 查询所有事件工单列表
	 */
	@Override
	public PageInfo ewRemindData(PageInfo pageInfo,Map<String, String> param) {    
		
		Map supportMap = getAllRemindSql(param);
		//List<Map> list = baseDao.queryforSplitPage(request, supportMap.get("sql").toString(), (Map)supportMap.get("param"));
		PageInfo list=baseDao.queryforSplitPageInfo(pageInfo, supportMap.get("sql").toString(), param);
		return list;
	}
	
	/**
	 * 查询所有事件工单列表总数
	 */
	@Override
	public int ewRemindCount(Map<String, String> param) {
		
		Map supportMap = getAllRemindSql(param);
		String sql = "select count(*) from ( " + supportMap.get("sql").toString() + " ) t";
		return baseDao.queryForInteger(sql,(Map)supportMap.get("param"));
		
		
	}
	
	/**
	 * 工单列表
	 * @param request
	 * @return
	 */
	private Map getAllRemindSql(Map<String, String> param){
		
		String flowState = param.get("flowstate");
		String customerId = param.get("customerId");
		String subCustomerId = param.get("subCustomerId");
		String orderCode = param.get("orderCode");
		String nodeTemplateId = param.get("node");
		String begintime = param.get("begintime");
		String endtime = param.get("endtime");
		
		param.put("flowState", flowState);
		param.put("customerId",  customerId);
		param.put("subCustomerId", subCustomerId);
		param.put("nodeTemplateId", nodeTemplateId);
		param.put("orderCode", "%"+orderCode+"%");
		param.put("businessType", String.valueOf(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND));
		
		StringBuilder builder = new StringBuilder();
		builder.append(" select b.BUSINESS_ID,b.ID FLOWID,b.WFNAME,b.CREATERNAME,b.CREATETIME,b.CURRENT_NODE_NAME,b.BUSINESSTYPE, ");
		builder.append(" t.PLAN_EXECUTION_DATE,r.ORDER_CODE,r.ID ORDERID,r.SERVICE_CONTENT,b.CUSTOMER_NAME,b.SUB_CUSTOMER_NAME,B.WFSTATE  ");
		builder.append(" from SC_WORKFLOW_CI_REMIND r  ");
		builder.append(" inner join WORKFLOW_BASE b on r.FLOW_ID = b.ID ");
		builder.append(" inner join CI_REMIND_TIMERTASK t on r.FLOW_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(" where 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 ");
			param.put("begintime", begintime+"000000");
		}
		if(StringUtil.notEmpty(endtime)) {
			builder.append(" AND b.CREATETIME <= :endtime ");
			param.put("endtime", endtime+"240000");
		}
		
		builder.append(" order by b.CREATETIME desc,t.PLAN_EXECUTION_DATE desc ");		
			
		Map supportMap = new HashMap();
		supportMap.put("sql",builder);
		supportMap.put("param", param);
		return supportMap;
	}
	
	/**
	 * 查询所有事件工单列表(根据客户ID)
	 */
	@Override
	public PageInfo ewRemindByCusIdData(PageInfo pageInfo,
			Map<String, String> param) {
		Map supportMap = getAllRemindSql(param);
		PageInfo list=baseDao.queryforSplitPageInfo(pageInfo, supportMap.get("sql").toString(), param);
		return list;
	}

	/**
	 * 查询所有事件工单数量(根据客户ID)
	 */
	@Override
	public int ewRemindByCusIdCount(Map<String, String> param) {	
		Map supportMap = getAllRemindSql(param);
		String sql = "select count(*) from ( " + supportMap.get("sql").toString() + " ) t";
		return baseDao.queryForInteger(sql,(Map)supportMap.get("param"));
	}
	
	@Override
	public List<Map> getRemindCiList(String orderId) {
		StringBuilder sql = new StringBuilder();
		sql.append(" select b.ID CIID,r.USER_NAME,r.DEAL_STATE,r.ID,c.NAME CATENAME,c.ID CATEID,b.CINAME,b.SEARCHCODE,b.POSITION " +
				" from SC_WORKFLOW_CI_REMIND_DETAIL r  ");
		sql.append(" inner join cmdb_ci_base b   ");
		sql.append(" on r.CI_ID = b.ID   ");
		sql.append(" inner join cmdb_ci_category c   ");
		sql.append(" on b.LV3_ID  = c.ID   ");
		sql.append(" where r.ORDER_ID = :orderId  ");
		return baseDao.queryForList(sql.toString(),new SqlParameter("orderId",orderId));
	}
	
	/**
	 * 服务台调度 提交
	 */
	@Override
	public Map doServerDispatch(Map<String, String> param,SC_WORKFLOW_CI_REMIND remind,String[] ciIdAry) {
		String orderId =param.get("orderId");
		String nodeId =param.get("nodeId");
		String executorIds = param.get("executorIds");
		String executorNames = param.get("executorNames");
		String main_executorId = param.get("main_executorId");
		String flowNote = param.get("flowNote");
		String dealUserName = "";
		
		String flowId = new SC_WORKFLOW_CI_REMIND(orderId).getInstanceById().getFlow_id();
		//更新业务表数据
		remind.setId(orderId).update();
		//设定执行人
		List<Map> userList = new ArrayList<Map>();
		String[] executorIdAry =  executorIds.split(",");
		String[] executorNameAry =  executorNames.split(",");
		
		Map cacheuser = new HashMap();
		
		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");
				dealUserName=executorNameAry[i];
				 
			}
			userList.add(tempMap);
		}
		
		
		
		String userId=param.get("ID");
		String userName=param.get("ZSXM");
		
		
		Map flowMsg = getFlowMsg(flowId,userId);
		String nodeid = ConvertUtil.obj2StrBlank(flowMsg.get("ID"));
		String nodeName = ConvertUtil.obj2StrBlank(flowMsg.get("NODENAME"));
		
		//增加处理记录
		GG_RECORD record = new GG_RECORD();
		record.setDeal_content(nodeName+"："+userName+",将问题指派给了,"+dealUserName);
		record.setDeal_time(DateUtil.getCurrentDate14());
		record.setDeal_user_id(userId);
		record.setDeal_user_name(userName);
		record.setBusiness_id(flowId);
		record.setNode_id(nodeId).setNode_name(nodeName);
		recordService.addRecord(record);
		
		//环节流转
		WorkFlowSupportEntity support = new WorkFlowSupportEntity();
		support.setFlowId(flowId);
		support.setNodeId(nodeId);
		support.setNote(flowNote);
		support.setUserName(userName);
		support.setUserId(userId);
		support.setNextNodeTemplateId(Constants.REMIND_DEAL);
		support.setNextUserList(userList);
		support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND);
		SysInfoMsg msg = workFlowSupportService.doOrderFlow(support);
		//addPatrolCi(orderId,ciIdAry);
		 
		Map resultMap = new HashMap();
		resultMap.put("result", "1");
		resultMap.put("msg", msg);
		return resultMap;
	}
	
	/**
	 * 例行维护  添加巡检设备信息
	 * */
	@Override
	public void addPatrolCi(String orderId, String[] ciIdAry) {
		baseDao.execute("delete from SC_WORKFLOW_CI_REMIND_DETAIL where order_id = :orderId", new SqlParameter("orderId",orderId));
		if(ciIdAry!=null&&ciIdAry.length>0){
			ArrayList<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for(int i=0;i<ciIdAry.length;i++){
				SqlParameter param = new SqlParameter();
				param.addValue("id", StringUtil.getUUID())
					.addValue("ciId", ciIdAry[i])
					.addValue("orderId", orderId);
				paramList.add(param);
			}
			String sql = " insert into SC_WORKFLOW_CI_REMIND_DETAIL (ID,CI_ID,ORDER_ID,DEAL_STATE) " +
					" values (:id,:ciId,:orderId,3)";
			baseDao.executeBatch(sql, paramList);
		}
	}
	
	/**
	 * 通过orderid获取流程信息
	 */
	@Override
	public Map getFlowMsg(String flowId,String userId) {
		String selectSql = "SELECT * FROM WORKFLOW_NODE WHERE FLOWID = :flowId AND CURRENT_DEALER_ID = :userId AND FLOWSTATE <> 3 ";
		return baseDao.queryForMap(selectSql,new SqlParameter("flowId",flowId).addValue("userId", userId));
	}
	
	@Override
	public Map doEngineerPatrol(Map<String, String> param) {
		String orderId = ConvertUtil.obj2StrBlank(param.get("orderId"));
		String nodeId = ConvertUtil.obj2StrBlank(param.get("nodeId")); 
		String note = ConvertUtil.obj2StrBlank(param.get("flowNote")); 
		String summary = ConvertUtil.obj2StrBlank(param.get("summary")); 
		
		
		String userName = param.get("ZSXM");
		String userId = param.get("Id");
		
		new SC_WORKFLOW_CI_REMIND(orderId).getInstanceById().setOrder_note(summary).update();
		String flowId = new SC_WORKFLOW_CI_REMIND(orderId).getInstanceById().getFlow_id();
		
		Map flowMsg = getFlowMsg(flowId,userId);
		String nodeid = ConvertUtil.obj2StrBlank(flowMsg.get("ID"));
		String nodeName = ConvertUtil.obj2StrBlank(flowMsg.get("NODENAME"));
		
		//增加处理记录
		GG_RECORD record = new GG_RECORD();
		record.setDeal_content(nodeName+"："+userName+",已处理维护执行");
		record.setDeal_time(DateUtil.getCurrentDate14());
		record.setDeal_user_id(userId);
		record.setDeal_user_name(userName);
		record.setBusiness_id(flowId);
		record.setNode_id(nodeId).setNode_name(nodeName);
		recordService.addRecord(record);
		
		//环节流转
		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_REMIND);
		Integer is_admin = new WORKFLOW_NODE(nodeId).getInstanceById().getIs_admin();
		if(is_admin!=null&&is_admin==1){
			support.setNextNodeTemplateId(Constants.REMIND_APPROVE);
			support.setEverDealflag(true);
			support.setEverNodeTemplateId(Constants.REMIND_DISPATCH);
		}
		SysInfoMsg msg = workFlowSupportService.doOrderFlow(support);
		Map resultMap = new HashMap();
		resultMap.put("result", "1");
		resultMap.put("msg", msg);
		return resultMap;
	}
	
	/**
	 * 回退
	 */
	@Override
	public Map doSendback(Map<String, String> param) {
		String orderId = param.get("orderId");
		String nodeId = param.get("nodeId");
		String lastNodeTemplateId = param.get("lastNodeTemplateId");
		String note = param.get("backNote");
		
		String userName = ConvertUtil.obj2StrBlank(param.get("ZSXM"));
		String userId = ConvertUtil.obj2StrBlank(param.get("ID"));
		
		String flowId = param.get("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_REMIND);
		SysInfoMsg msg = workFlowSupportService.doOrderSendback(support);
		Map resultMap = new HashMap();
		resultMap.put("result", "1");
		resultMap.put("msg", msg);
		return resultMap;
	}
	
}