package cn.ksource.web.facade.order;

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 cn.ksource.beans.WORKFLOW_BASE;
import cn.ksource.beans.WORKFLOW_NODE;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.WebUtil;
import cn.ksource.web.Constants;

@Service("orderFacade")
public class OrderFacadeImpl implements OrderFacade {
	
	@Autowired
	private BaseDao baseDao;
	
	@Override
	public PageInfo queryMyOrderData(PageInfo pageInfo,Map<String,String> params) {
		
		StringBuilder builder = new StringBuilder();
		params.put("ysc", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		
		
		/**
		 * 查询逻辑
		 * 1.如果节点状态选择为全部，则查询节点表中处理人是我的，（或者处理角色是我的并且没有分配处理人的）--------------我的工单不再查询处理角色问题，
		 * 	 但查询出来的数据会有重复，因为一个节点我可以处理多次，这样查询出来会有重复的工单，需要过滤，如果同一个工单 有待处理，已处理   或者进行中，已处理，则显示待处理 或进行中，不显示已处理 （待处理和进行中是不会同时存在的）
		 * 2.如果节点状态选择为待处理，则查询节点表中处理人是我的，或者处理角色是我的并且没有分配处理人的 （不需要过滤，因为一个工单待处理节点，只会有一个）
		 * 3.如果节点状态选择为进行中，则查询节点表中处理人是我的 （不需要过滤，因为一个工单进行中节点，只会有一个）
		 * 4.如果节点状态查询未已处理，则查询节点表中处理人是我的，需要过滤（因为一个节点一个人可以处理多次，通过节点表作为主表查询出来的工单会有重复）
		 */
		
		String flowstate = params.get("flowstate");
		if(StringUtil.notEmpty(flowstate)) {
			if(flowstate.equals("1")) {
				builder.append(" SELECT D.* FROM ( ");
				//查询处理人是我的
				builder.append(" SELECT B.*,A.FLOWSTATE  FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId ");
				builder.append(")D");
				builder.append(" WHERE D.FLOWSTATE = :jddcl ");
				params.put("jddcl", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_NODE_FLOWSTATE_UNDISPOSE));
			} else if(flowstate.equals("2")) {
				builder.append(" SELECT D.* FROM ( ");
				builder.append(" SELECT B.*,A.FLOWSTATE FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId AND A.FLOWSTATE = :jdjxz");
				builder.append(")D");
				builder.append(" WHERE 1 = 1");
				params.put("jdjxz", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_NODE_FLOWSTATE_DOING));
			}else {
				builder.append(" SELECT D.* FROM ( ");
				builder.append(" SELECT DISTINCT B.*,A.FLOWSTATE FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId AND  A.FLOWSTATE = :jdywc ");
				builder.append(")D");
				builder.append(" WHERE 1 = 1 ");
				params.put("jdywc", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_NODE_FLOWSTATE_FINISH));
			}
		} else {
			builder.append(" SELECT D.* FROM ( ");
			//查询处理人是我的
			builder.append(" SELECT B.*,A.FLOWSTATE FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId ");
			builder.append(")D");
			builder.append(" WHERE D.WFSTATE != :ysc  ");
		}
		
		
		String status = params.get("status");
		if(StringUtil.notEmpty(status)) {
			builder.append(" AND D.WFSTATE = :status ");
		}
		
		String orderName = params.get("orderName");
		if(StringUtil.notEmpty(orderName)) {
			builder.append(" AND D.WFNAME LIKE :orderName ");
			params.put("orderName", "%"+orderName+"%");
		}
		
		
		String hjName = params.get("hjName");
		if(StringUtil.notEmpty(hjName)) {
			builder.append(" AND D.CURRENT_NODE_NAME LIKE :hjName ");
			params.put("hjName", "%"+hjName+"%");
		}
		
		String orderCode = params.get("orderCode");
		if(StringUtil.notEmpty(orderCode)) {
			builder.append(" AND D.ORDER_CODE LIKE :orderCode");
			params.put("orderCode", "%"+orderCode+"%");
		}
		
		String customerName = params.get("customerName");
		if(StringUtil.notEmpty(customerName)) {
			builder.append(" AND D.CUSTOMER_NAME LIKE :customerName ");
			params.put("customerName", "%"+customerName+"%");
		}
		String customer_id = params.get("customer_id");
		if(StringUtil.notEmpty(customer_id)) {
			builder.append(" AND D.customer_id =:customer_id ");
			params.put("customer_id", customer_id);
		}

		String types = params.get("types");
		if(StringUtil.notEmpty(types)) {
			String[] type = types.split(",");
			if(type.length==1) {
				builder.append(" AND D.BUSINESSTYPE = :businessType");
				params.put("businessType", type[0]);
			} else {
				builder.append(" AND D.BUSINESSTYPE IN (");
				for(int i=0; i<type.length; i++) {
					builder.append(" :type"+i);
					builder.append(",");
					params.put("type"+i, type[i]);
				}
				builder.deleteCharAt(builder.lastIndexOf(","));
				builder.append(")");
			}
		}
		String pageSize = pageInfo.getPageSize();
		String currPage = pageInfo.getCurrPage();
		if(!StringUtil.notEmptyNum(pageSize)){
			pageSize = "10";
		}
		if(!StringUtil.notEmptyNum(currPage)){
			currPage = "1";
		}
		int begin = Integer.valueOf(currPage);
		int size = Integer.valueOf(pageSize);
		if(!StringUtil.notEmpty(flowstate)) {
			builder.append( " ORDER BY D.FLOWSTATE,D.CREATETIME DESC" );
			List<Map> result = baseDao.queryForList(builder.toString(),params);
			List resultList = new ArrayList();
			List<String> list = new ArrayList<String>();
			Map cacheMap = new HashMap();
			if(null!=result && result.size()>0) {
				for(Map m : result) {
					String flowId = ConvertUtil.obj2StrBlank(m.get("ID"));
					if(cacheMap.containsKey(flowId)) {
						String flowState = ConvertUtil.obj2StrBlank(m.get("FLOWSTATE"));
						if(flowState.equals(Constants.WORKFLOW_NODE_FLOWSTATE_UNDISPOSE.toString()) || flowState.equals(Constants.WORKFLOW_NODE_FLOWSTATE_DOING.toString())) {
							cacheMap.put(flowId, m);
							if(!list.contains(flowId)) {
								list.add(flowId);
							}
						}
					} else {
						cacheMap.put(flowId, m);
						list.add(flowId);
					}
				}
				
				if(cacheMap.size()>0) {
					for(String str : list) {
						resultList.add(cacheMap.get(str));
					}
				}
			}
			
			int infoCount = resultList.size();
			int bin = (begin-1)* size ;
			int end = (begin-1)* size + size;
			if(end>infoCount){
				end=infoCount;
			}
			PageInfo info = new PageInfo();
			info.setDatas(resultList.subList(bin, end));
			info.setRowNum(infoCount);
			return info;
		} else {
			builder.append( " ORDER BY D.CREATETIME DESC  ");
			
			PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), params);
			return info;
		}
		
		
		
	}

	@Override
	public int queryMyOrderCount(Map<String,String> params) {
		
		StringBuilder builder = new StringBuilder();
		params.put("ysc", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		
		
		/**
		 * 查询逻辑
		 * 1.如果节点状态选择为全部，则查询节点表中处理人是我的，或者处理角色是我的并且没有分配处理人的，
		 * 	 但查询出来的数据会有重复，因为一个节点我可以处理多次，这样查询出来会有重复的工单，需要过滤，如果同一个工单 有待处理，已处理   或者进行中，已处理，则显示待处理 或进行中，不显示已处理 （待处理和进行中是不会同时存在的）
		 * 2.如果节点状态选择为待处理，则查询节点表中处理人是我的，或者处理角色是我的并且没有分配处理人的 （不需要过滤，因为一个工单待处理节点，只会有一个）
		 * 3.如果节点状态选择为进行中，则查询节点表中处理人是我的 （不需要过滤，因为一个工单进行中节点，只会有一个）
		 * 4.如果节点状态查询未已处理，则查询节点表中处理人是我的，需要过滤（因为一个节点一个人可以处理多次，通过节点表作为主表查询出来的工单会有重复）
		 */
		
		
		String flowstate = params.get("flowstate");
		if(StringUtil.notEmpty(flowstate)) {
			if(flowstate.equals("1")) {
				builder.append(" SELECT DISTINCT D.* FROM ( ");
				//查询处理人是我的
				builder.append(" SELECT B.ID,B.WFSTATE,B.CUSTOMER_ID,B.CURRENT_NODE_NAME,B.ORDER_CODE,B.CUSTOMER_NAME,B.BUSINESSTYPE,B.WFNAME FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId AND A.FLOWSTATE = :jddcl ");
				
				builder.append(") D");
				builder.append(" WHERE 1 = 1 ");
				params.put("jddcl", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_NODE_FLOWSTATE_UNDISPOSE));
			} else if(flowstate.equals("2")) {
				builder.append(" SELECT DISTINCT D.* FROM ( ");
				builder.append(" SELECT B.ID,B.WFSTATE,B.CUSTOMER_ID,B.CURRENT_NODE_NAME,B.ORDER_CODE,B.CUSTOMER_NAME,B.BUSINESSTYPE,B.WFNAME FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId AND A.FLOWSTATE = :jdjxz");
				builder.append(")D");
				builder.append(" WHERE 1 = 1");
				params.put("jdjxz", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_NODE_FLOWSTATE_DOING));
			}else {
				builder.append(" SELECT DISTINCT D.* FROM ( ");
				builder.append(" SELECT B.ID,B.WFSTATE,B.CUSTOMER_ID,B.CURRENT_NODE_NAME,B.ORDER_CODE,B.CUSTOMER_NAME,B.BUSINESSTYPE,B.WFNAME FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId AND A.FLOWSTATE = :jdywc ");
				builder.append(")D");
				builder.append(" WHERE 1 = 1");
				params.put("jdywc", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_NODE_FLOWSTATE_FINISH));
			}
		} else {
			builder.append(" SELECT DISTINCT D.* FROM ( ");
			//查询处理人是我的
			builder.append(" SELECT B.ID,B.WFSTATE,B.CUSTOMER_ID,B.CURRENT_NODE_NAME,B.ORDER_CODE,B.CUSTOMER_NAME,B.BUSINESSTYPE,B.WFNAME FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId ");
			builder.append(")D");
			builder.append(" WHERE  D.WFSTATE != :ysc ");
		}
		
		
		String status = params.get("status");
		if(StringUtil.notEmpty(status)) {
			builder.append(" AND D.WFSTATE = :status ");
			params.put("status", status);
		}
		
		String orderName = params.get("orderName");
		if(StringUtil.notEmpty(orderName)) {
			builder.append(" AND D.WFNAME LIKE :orderName ");
			params.put("orderName", "%"+orderName+"%");
		}

		String customer_id = params.get("customer_id");
		if(StringUtil.notEmpty(customer_id)) {
			builder.append(" AND D.customer_id =:customer_id ");
			params.put("customer_id", customer_id);
		}
		
		String hjName = params.get("hjName");
		if(StringUtil.notEmpty(hjName)) {
			builder.append(" AND D.CURRENT_NODE_NAME LIKE :hjName ");
			params.put("hjName", "%"+hjName+"%");
		}
		
		String orderCode = params.get("orderCode");
		if(StringUtil.notEmpty(orderCode)) {
			builder.append(" AND D.ORDER_CODE LIKE :orderCode");
			params.put("orderCode", "%"+orderCode+"%");
		}
		
		String customerName = params.get("customerName");
		if(StringUtil.notEmpty(customerName)) {
			builder.append(" AND D.CUSTOMER_NAME LIKE :customerName ");
			params.put("customerName", "%"+customerName+"%");
		}

		String types = params.get("types");
		if(StringUtil.notEmpty(types)) {
			String[] type = types.split(",");
			if(type.length==1) {
				builder.append(" AND D.BUSINESSTYPE = :businessType");
				params.put("businessType", type[0]);
			} else {
				builder.append(" AND D.BUSINESSTYPE IN (");
				for(int i=0; i<type.length; i++) {
					builder.append(" :type"+i);
					builder.append(",");
					params.put("type"+i, type[i]);
				}
				builder.deleteCharAt(builder.lastIndexOf(","));
				builder.append(")");
			}
		}
		
		
		StringBuilder newBuild = new StringBuilder();
		newBuild.append("SELECT COUNT(*) FROM ( ");
		newBuild.append(builder.toString());
		newBuild.append(") E");
		
		return baseDao.queryForInteger(newBuild.toString(),params);
	}
	
	
	
	
	/**
	 * 查询服务台所有工单数量，默认查询未完成的
	 */
	@Override
	public int ordersListCount(Map<String, String> params) {
		StringBuilder builder = new StringBuilder("SELECT COUNT(A.ID) FROM WORKFLOW_BASE A WHERE WFSTATE != :ysc ");
		params.put("ysc", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		
		
		String orderName = params.get("orderName");
		if(StringUtil.notEmpty(orderName)) {
			builder.append(" AND A.WFNAME LIKE :orderName ");
			params.put("orderName", "%"+orderName+"%");
		}
		String create_name = params.get("create_name");
		if(StringUtil.notEmpty(create_name)) {
			builder.append(" AND A.CREATERNAME LIKE :create_name ");
			params.put("create_name", "%"+create_name+"%");
		}
		String create_time=params.get("create_time");
		if(StringUtil.notEmpty(create_time)){
			builder.append(" AND A.CREATETIME > :create_time ");
			params.put("create_time", create_time+"000000");
		}
		String end_time=params.get("end_time");
		if(StringUtil.notEmpty(end_time)){
			builder.append(" AND A.CREATETIME < :end_time ");
			params.put("end_time", end_time+"235959");
		}
		String jjr = params.get("jjr");
		if(StringUtil.notEmpty(jjr)) {
			builder.append(" AND A.CURRENT_DEALER_NAME LIKE :jjr ");
			params.put("jjr", "%"+jjr+"%");
		}
		String types = params.get("types");
		if(StringUtil.notEmpty(types)) {
			String[] type = types.split(",");
			if(type.length==1) {
				builder.append(" AND A.BUSINESSTYPE = :businessType");
				params.put("businessType", type[0]);
			} else {
				builder.append(" AND A.BUSINESSTYPE IN (");
				for(int i=0; i<type.length; i++) {
					builder.append(" :type"+i);
					builder.append(",");
					params.put("type"+i, type[i]);
				}
				builder.deleteCharAt(builder.lastIndexOf(","));
				builder.append(")");
			}
		}
		
		String orderStatus = params.get("orderStatus");
		if(StringUtil.notEmpty(orderStatus)) {
			builder.append(" AND A.WFSTATE = :orderStatus ");
			params.put("orderStatus", orderStatus);
		}
		
		String customerName = params.get("customerName");
		if(StringUtil.notEmpty(customerName)) {
			builder.append(" AND A.CUSTOMER_NAME LIKE :customerName ");
			params.put("customerName", "%"+customerName+"%");
		}
		String customer_id = params.get("customer_id");
		if(StringUtil.notEmpty(customer_id)) {
			builder.append(" AND A.customer_id =:customer_id ");
			params.put("customer_id", customer_id);
		}

		String orderCode = params.get("orderCode");
		if(StringUtil.notEmpty(orderCode)) {
			builder.append(" AND A.ORDER_CODE LIKE :orderCode ");
			params.put("orderCode", "%"+orderCode+"%");
		}
		
		
		String beginTime = params.get("beginTime");
		if(StringUtil.notEmpty(beginTime)) {
			builder.append(" AND A.CREATETIME >= :beginTime ");
			params.put("beginTime", beginTime+"000000");
		}
		
		String endTime = params.get("endTime");
		if(StringUtil.notEmpty(endTime)) {
			builder.append(" AND A.CREATETIME <= :endTime ");
			params.put("endTime", endTime+"240000");
		}
		return baseDao.queryForInteger(builder.toString(),params);
	}

	@Override
	public PageInfo ordersListData(PageInfo pageInfo, Map<String, String> params) {
		StringBuilder builder = new StringBuilder("SELECT A.* FROM WORKFLOW_BASE A WHERE WFSTATE != :ysc ");
		params.put("ysc", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		
		String orderName = params.get("orderName");
		if(StringUtil.notEmpty(orderName)) {
			builder.append(" AND A.WFNAME LIKE :orderName ");
			params.put("orderName", "%"+orderName+"%");
		}
		String create_name = params.get("create_name");
		if(StringUtil.notEmpty(create_name)) {
			builder.append(" AND A.CREATERNAME LIKE :create_name ");
			params.put("create_name", "%"+create_name+"%");
		}
		String create_time=params.get("create_time");
		if(StringUtil.notEmpty(create_time)){
			builder.append(" AND A.CREATETIME > :create_time ");
			params.put("create_time", create_time+"000000");
		}
		String end_time=params.get("end_time");
		if(StringUtil.notEmpty(end_time)){
			builder.append(" AND A.CREATETIME < :end_time ");
			params.put("end_time", end_time+"235959");
		}
		String jjr = params.get("jjr");
		if(StringUtil.notEmpty(jjr)) {
			builder.append(" AND A.CURRENT_DEALER_NAME LIKE :jjr ");
			params.put("jjr", "%"+jjr+"%");
		}
		
		String types = params.get("types");
		if(StringUtil.notEmpty(types)) {
			String[] type = types.split(",");
			if(type.length==1) {
				builder.append(" AND A.BUSINESSTYPE = :businessType");
				params.put("businessType", type[0]);
			} else {
				builder.append(" AND A.BUSINESSTYPE IN (");
				for(int i=0; i<type.length; i++) {
					builder.append(" :type"+i);
					builder.append(",");
					params.put("type"+i, type[i]);
				}
				builder.deleteCharAt(builder.lastIndexOf(","));
				builder.append(")");
			}
		}
		
		String orderStatus = params.get("orderStatus");
		if(StringUtil.notEmpty(orderStatus)) {
			builder.append(" AND A.WFSTATE = :orderStatus ");
			params.put("orderStatus", orderStatus);
		}
		
		String customerName = params.get("customerName");
		if(StringUtil.notEmpty(customerName)) {
			builder.append(" AND A.CUSTOMER_NAME LIKE :customerName ");
			params.put("customerName", "%"+customerName+"%");
		}

		String customer_id = params.get("customer_id");
		if(StringUtil.notEmpty(customer_id)) {
			builder.append(" AND A.customer_id =:customer_id ");
			params.put("customer_id", customer_id);
		}
		String orderCode = params.get("orderCode");
		if(StringUtil.notEmpty(orderCode)) {
			builder.append(" AND A.ORDER_CODE LIKE :orderCode ");
			params.put("orderCode", "%"+orderCode+"%");
		}
		
		
		String beginTime = params.get("beginTime");
		if(StringUtil.notEmpty(beginTime)) {
			builder.append(" AND A.CREATETIME >= :beginTime ");
			params.put("beginTime", beginTime+"000000");
		}
		
		String endTime = params.get("endTime");
		if(StringUtil.notEmpty(endTime)) {
			builder.append(" AND A.CREATETIME <= :endTime ");
			params.put("endTime", endTime+"240000");
		}
		
		
		builder.append(" ORDER BY A.CREATETIME DESC ");
		
		return baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), params);
	}

	@Override
	public Map queryOrderCountByCate(HttpServletRequest request, String type) {
		String userId = WebUtil.getLoginedUserId(request);
		Map paramMap = new HashMap();
		
		StringBuilder builder = new StringBuilder();
		paramMap.put("ysc", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
		paramMap.put("userId", userId);
		
		
		builder.append(" SELECT DISTINCT D.* FROM ( ");
		//查询处理人是我的
		builder.append(" SELECT B.ID,A.FLOWSTATE,B.WFSTATE FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId ");
		if(StringUtil.notEmpty(type)) {
			builder.append(" AND B.BUSINESSTYPE = :type ");
			paramMap.put("type", type);
		}
		builder.append(")D");
		builder.append(" WHERE  D.WFSTATE != :ysc  ");
		
		StringBuilder newBuild = new StringBuilder();
		newBuild.append("SELECT COUNT(*) AS NUM,E.FLOWSTATE FROM ( ");
		newBuild.append(builder.toString());
		newBuild.append(") E GROUP BY E.FLOWSTATE ORDER BY E.FLOWSTATE");
		
		List<Map> list =  baseDao.queryForList(newBuild.toString(),paramMap);
		Map resultMap = new HashMap();
		for(Map m : list) {
			resultMap.put("state"+m.get("FLOWSTATE"), m.get("NUM"));
		}
		
		int totalNum = queryAllOrderCount(request,type);
		paramMap.put("types", type);
		int orderPool = myorderpoolCount(paramMap);
		resultMap.put("totalOrder", totalNum);
		resultMap.put("orderPool", orderPool);
		
		return resultMap;
	}
	
	@Override
	public int queryAllOrderCount(HttpServletRequest request,String type) {
		String userId = WebUtil.getLoginedUserId(request);
		Map<String,String> groupMap = WebUtil.getLoginUser(request).getGroupMap();
		Map paramMap = new HashMap();
		
		StringBuilder builder = new StringBuilder();
		paramMap.put("ysc", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
		paramMap.put("userId", userId);
		
		
		builder.append(" SELECT DISTINCT D.* FROM ( ");
		//查询处理人是我的
		builder.append(" SELECT B.ID,B.WFSTATE FROM WORKFLOW_NODE A,WORKFLOW_BASE B WHERE A.FLOWID = B.ID AND A.CURRENT_DEALER_ID = :userId ");
		if(StringUtil.notEmpty(type)) {
			builder.append(" AND B.BUSINESSTYPE = :type ");
			paramMap.put("type", type);
		}
		builder.append(")D");
		builder.append(" WHERE  D.WFSTATE != :ysc  ");
		
		StringBuilder newBuild = new StringBuilder();
		newBuild.append("SELECT COUNT(*) AS NUM FROM ( ");
		newBuild.append(builder.toString());
		newBuild.append(") E");
		
		int count =  baseDao.queryForInteger(newBuild.toString(),paramMap);
		System.out.println(count);
		return count;
	}

	@Override
	public int myorderpoolCount(Map<String, String> params) {
		/**
		 * 查询我的工单池规则
		 * 如果是一二三线或者驻场工程师桌面,则直接查询工单表中 所属分组是当前工程师所在组的
		 * 如果是项目服务台，则直接查询工单表中所属分组是当前工程师所在组的 （同上）
		 * 如果是客户服务台，查询我的工单池  则查询工单表中分组是 （查询该客户下所有的项目的服务台分组）
		 * 如果是总服务台，则查询所有客户下（加盟商下所有项目的服务台分组）
		 */
		
		
		String sql = new String();
		params.put("wfstate", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		sql = "SELECT COUNT(D.ID) FROM WORKFLOW_BASE D,((SELECT DISTINCT B.JSBH FROM AC_USER_REF_ROLE B WHERE B.YHBH = :userId) UNION ALL (SELECT DISTINCT A.GROUP_ID AS JSBH  FROM AC_ROLE_GROUP_USER A WHERE A.USER_ID = :userId AND A.STATE = 1) ) C  WHERE D.CURRENT_DEAL_ROLEIDA = C.JSBH AND D.WFSTATE != :wfstate AND (D.CURRENT_DEALER_ID IS NULL OR D.CURRENT_DEALER_ID = '' ) ";
		
		
		if(StringUtil.notEmpty(sql)) {
			
			StringBuilder builder = new StringBuilder(sql);
			
			String status = params.get("status");
			if(StringUtil.notEmpty(status)) {
				builder.append(" AND D.WFSTATE = :status ");
			}
			
			String orderName = params.get("orderName");
			if(StringUtil.notEmpty(orderName)) {
				builder.append(" AND D.WFNAME LIKE :orderName ");
				params.put("orderName", "%"+orderName+"%");
			}

			
			String orderCode = params.get("orderCode");
			if(StringUtil.notEmpty(orderCode)) {
				builder.append(" AND D.ORDER_CODE LIKE :orderCode");
				params.put("orderCode", "%"+orderCode+"%");
			}
			
			String customerName = params.get("customerName");
			if(StringUtil.notEmpty(customerName)) {
				builder.append(" AND D.CUSTOMER_NAME LIKE :customerName ");
				params.put("customerName", "%"+customerName+"%");
			}
			String customer_id = params.get("customer_id");
			if(StringUtil.notEmpty(customer_id)) {
				builder.append(" AND D.customer_id =:customer_id ");
				params.put("customer_id", customer_id);
			}

			String types = params.get("types");
			if(StringUtil.notEmpty(types)) {
				String[] type = types.split(",");
				if(type.length==1) {
					builder.append(" AND D.BUSINESSTYPE = :businessType");
					params.put("businessType", type[0]);
				} else {
					builder.append(" AND D.BUSINESSTYPE IN (");
					for(int i=0; i<type.length; i++) {
						builder.append(" :type"+i);
						builder.append(",");
						params.put("type"+i, type[i]);
					}
					builder.deleteCharAt(builder.lastIndexOf(","));
					builder.append(")");
				}
			}
			
			
			int count = baseDao.queryForInteger(builder.toString(),params);
			
			return count;
		}

		return 0;
	}

	@Override
	public PageInfo myorderpoolData(PageInfo pageInfo,
			Map<String, String> params) {
		
		/**
		 * 查询我的工单池规则
		 * 如果是一二三线或者驻场工程师桌面,则直接查询工单表中 所属分组是当前工程师所在组的
		 * 如果是项目服务台，则直接查询工单表中所属分组是当前工程师所在组的 （同上）
		 * 如果是客户服务台，查询我的工单池  则查询工单表中分组是 （查询该客户下所有的项目的服务台分组）
		 * 如果是总服务台，则查询所有客户下（加盟商下所有项目的服务台分组）
		 */
		
		
		String sql = new String();
		params.put("wfstate", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		sql = "SELECT D.* FROM WORKFLOW_BASE D,((SELECT DISTINCT B.JSBH FROM AC_USER_REF_ROLE B WHERE B.YHBH = :userId) UNION ALL (SELECT DISTINCT A.GROUP_ID AS JSBH  FROM AC_ROLE_GROUP_USER A WHERE A.USER_ID = :userId AND A.STATE = 1)) C WHERE D.CURRENT_DEAL_ROLEIDA = C.JSBH AND D.WFSTATE != :wfstate AND (D.CURRENT_DEALER_ID IS NULL OR D.CURRENT_DEALER_ID = '' ) ";
		
		if(StringUtil.notEmpty(sql)) {
			
			StringBuilder builder = new StringBuilder(sql);
			
			String status = params.get("status");
			if(StringUtil.notEmpty(status)) {
				builder.append(" AND D.WFSTATE = :status ");
			}
			
			String orderName = params.get("orderName");
			if(StringUtil.notEmpty(orderName)) {
				builder.append(" AND D.WFNAME LIKE :orderName ");
				params.put("orderName", "%"+orderName+"%");
			}
			
			
			String orderCode = params.get("orderCode");
			if(StringUtil.notEmpty(orderCode)) {
				builder.append(" AND D.ORDER_CODE LIKE :orderCode");
				params.put("orderCode", "%"+orderCode+"%");
			}
			
			String customerName = params.get("customerName");
			if(StringUtil.notEmpty(customerName)) {
				builder.append(" AND D.CUSTOMER_NAME LIKE :customerName ");
				params.put("customerName", "%"+customerName+"%");
			}
			String customer_id = params.get("customer_id");
			if(StringUtil.notEmpty(customer_id)) {
				builder.append(" AND D.customer_id =:customer_id ");
				params.put("customer_id", customer_id);
			}

			String types = params.get("types");
			if(StringUtil.notEmpty(types)) {
				String[] type = types.split(",");
				if(type.length==1) {
					builder.append(" AND D.BUSINESSTYPE = :businessType");
					params.put("businessType", type[0]);
				} else {
					builder.append(" AND D.BUSINESSTYPE IN (");
					for(int i=0; i<type.length; i++) {
						builder.append(" :type"+i);
						builder.append(",");
						params.put("type"+i, type[i]);
					}
					builder.deleteCharAt(builder.lastIndexOf(","));
					builder.append(")");
				}
			}
			
			builder.append(" ORDER BY D.CREATETIME DESC ");
			PageInfo result = baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), params);
			
			return result;
		}
		return new PageInfo();
	}

	@Override
	public int orderpoolCount(Map<String, String> params) {
		/**
		 * 查询我的工单池规则
		 * 如果是一二三线或者驻场工程师桌面,则直接查询工单表中 所属分组是当前工程师所在组的
		 * 如果是项目服务台，则直接查询工单表中所属分组是当前工程师所在组的 （同上）
		 * 如果是客户服务台，查询我的工单池  则查询工单表中分组是 （查询该客户下所有的项目的服务台分组）
		 * 如果是总服务台，则查询所有客户下（加盟商下所有项目的服务台分组）
		 */
		
		StringBuilder sql = new StringBuilder();
		
		params.put("wfstate",ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE) );
		sql.append("SELECT COUNT(D.ID) FROM WORKFLOW_BASE D,((SELECT B.ID FROM AC_ROLE B WHERE B.STATE =1) UNION ALL (SELECT DISTINCT A.ID  FROM AC_ROLE_GROUP A WHERE  A.STATE = 1) ");
		
		
		sql.append(" ) C WHERE  D.CURRENT_DEAL_ROLEIDA = C.ID AND D.WFSTATE != :wfstate AND (D.CURRENT_DEALER_ID IS NULL OR D.CURRENT_DEALER_ID = '' ) ");

		StringBuilder builder = new StringBuilder(sql);
		
		String status = params.get("status");
		if(StringUtil.notEmpty(status)) {
			builder.append(" AND D.WFSTATE = :status ");
		}
		
		String orderName = params.get("orderName");
		if(StringUtil.notEmpty(orderName)) {
			builder.append(" AND D.WFNAME LIKE :orderName ");
			params.put("orderName", "%"+orderName+"%");
		}

		
		String orderCode = params.get("orderCode");
		if(StringUtil.notEmpty(orderCode)) {
			builder.append(" AND D.ORDER_CODE LIKE :orderCode");
			params.put("orderCode", "%"+orderCode+"%");
		}
		
		String customerName = params.get("customerName");
		if(StringUtil.notEmpty(customerName)) {
			builder.append(" AND D.CUSTOMER_NAME LIKE :customerName ");
			params.put("customerName", "%"+customerName+"%");
		}
		String customer_id = params.get("customer_id");
		if(StringUtil.notEmpty(customer_id)) {
			builder.append(" AND D.customer_id =:customer_id ");
			params.put("customer_id", customer_id);
		}
		String types = params.get("types");
		if(StringUtil.notEmpty(types)) {
			String[] type = types.split(",");
			if(type.length==1) {
				builder.append(" AND D.BUSINESSTYPE = :businessType");
				params.put("businessType", type[0]);
			} else {
				builder.append(" AND D.BUSINESSTYPE IN (");
				for(int i=0; i<type.length; i++) {
					builder.append(" :type"+i);
					builder.append(",");
					params.put("type"+i, type[i]);
				}
				builder.deleteCharAt(builder.lastIndexOf(","));
				builder.append(")");
			}
		}
		
		
		int count = baseDao.queryForInteger(builder.toString(),params);
		
		return count;
	}

	@Override
	public PageInfo orderpoolData(PageInfo pageInfo, Map<String, String> params) {
		
		/**
		 * 查询我的工单池规则
		 * 如果是项目服务台，则直接查询工单表 
		 * 如果是客户服务台，查询我的工单池  则查询工单表中分组是 （查询该客户下所有的项目的分组）
		 * 如果是总服务台，则查询所有客户下（加盟商下所有项目的分组）
		 */
		
		StringBuilder sql = new StringBuilder();
		params.put("wfstate", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		sql.append("SELECT D.* FROM WORKFLOW_BASE D,((SELECT B.ID FROM AC_ROLE B WHERE B.STATE =1) UNION ALL (SELECT DISTINCT A.ID  FROM AC_ROLE_GROUP A WHERE  A.STATE = 1) ");
		
			
		sql.append(" ) C WHERE  D.CURRENT_DEAL_ROLEIDA = C.ID AND D.WFSTATE != :wfstate AND (D.CURRENT_DEALER_ID IS NULL OR D.CURRENT_DEALER_ID = '' ) ");
		
		StringBuilder builder = new StringBuilder(sql);
		
		String status = params.get("status");
		if(StringUtil.notEmpty(status)) {
			builder.append(" AND D.WFSTATE = :status ");
		}
		
		String orderName = params.get("orderName");
		if(StringUtil.notEmpty(orderName)) {
			builder.append(" AND D.WFNAME LIKE :orderName ");
			params.put("orderName", "%"+orderName+"%");
		}
		
		String customerName = params.get("customerName");
		if(StringUtil.notEmpty(customerName)) {
			builder.append(" AND D.CUSTOMER_NAME LIKE :customerName ");
			params.put("customerName", "%"+customerName+"%");
		}
		String customer_id = params.get("customer_id");
		if(StringUtil.notEmpty(customer_id)) {
			builder.append(" AND D.customer_id =:customer_id ");
			params.put("customer_id", customer_id);
		}
		String orderCode = params.get("orderCode");
		if(StringUtil.notEmpty(orderCode)) {
			builder.append(" AND D.ORDER_CODE LIKE :orderCode");
			params.put("orderCode", "%"+orderCode+"%");
		}
		
		String types = params.get("types");
		if(StringUtil.notEmpty(types)) {
			String[] type = types.split(",");
			if(type.length==1) {
				builder.append(" AND D.BUSINESSTYPE = :businessType");
				params.put("businessType", type[0]);
			} else {
				builder.append(" AND D.BUSINESSTYPE IN (");
				for(int i=0; i<type.length; i++) {
					builder.append(" :type"+i);
					builder.append(",");
					params.put("type"+i, type[i]);
				}
				builder.deleteCharAt(builder.lastIndexOf(","));
				builder.append(")");
			}
		}
		
		
		PageInfo result = baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), params);
		
		return result;
	}

	@Override
	public Integer getOrderCount(Map<String, String> params){
		StringBuilder sql = new StringBuilder();
		sql.append(" select count(id) from workflow_base where wfstate<>:defstate and businesstype=:flowtype ");
		params.put("defstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE.toString());
		if(params.get("flag").equals("jxz")){
			sql.append(" and wfstate=:fstate ");
			params.put("fstate",Constants.WORKFLOW_BASE_WFSTATE_DOING.toString());
		}else if(params.get("flag").equals("ywc")){
			sql.append(" and wfstate=:fstate ");
			params.put("fstate",Constants.WORKFLOW_BASE_WFSTATE_FINISH.toString());
		}else if(params.get("flag").equals("ygb")){
			sql.append(" and wfstate=:fstate ");
			params.put("fstate",Constants.WORKFLOW_BASE_WFSTATE_CLOSE.toString());
		}else if(params.get("flag").equals("ypj")){
			sql.append(" and wfstate=:fstate ");
			params.put("fstate",Constants.WORKFLOW_BASE_WFSTATE_EVALUATE.toString());
		}else if(params.get("flag").equals("ygq")){
			sql.append(" and wfstate=:fstate ");
			params.put("fstate",Constants.WORKFLOW_BASE_WFSTATE_UP.toString());
		}
		return baseDao.queryForInteger(sql.toString(),params);
	}

	@Override
	public int getDealerIsMy(String flowId, String loginedUserId) {
		Map params = new HashMap();
		params.put("flowId", flowId);
		params.put("userId", loginedUserId);
		int count = 0;
		WORKFLOW_BASE flow = new WORKFLOW_BASE(flowId).getInstanceById();
		WORKFLOW_NODE node = new WORKFLOW_NODE(flow.getCurrent_node_id()).getInstanceById();
		if(StringUtil.isEmpty(node.getCurrent_dealer_id())&&!StringUtil.isEmpty(node.getCurrent_deal_roleida())){
			String sql = "SELECT COUNT(ID) FROM AC_USER_REF_ROLE WHERE YHBH = :userId AND JSBH = :jsbh ";
			params.put("jsbh", node.getCurrent_deal_roleida());
			count = baseDao.queryForInteger(sql, params);
			if(count == 0){
				sql = "SELECT COUNT(ID) FROM AC_ROLE_GROUP_USER WHERE USER_ID = :userId AND GROUP_ID = :jsbh ";
				count = baseDao.queryForInteger(sql, params);
			}
		}else{
			if(StringUtil.isEmpty(node.getSame_node_key())){
				if(node.getCurrent_dealer_id().equals(loginedUserId)&&node.getFlowstate() != Constants.WORKFLOW_NODE_FLOWSTATE_FINISH){
					count = 1;
				}
			}else{
				String sql = "SELECT COUNT(ID) FROM WORKFLOW_NODE WHERE SAME_NODE_KEY = :same_node_key AND FLOWID = :flowId AND CURRENT_DEALER_ID = :userId AND FLOWSTATE <> :flowstate ";
				params.put("same_node_key", node.getSame_node_key());
				params.put("flowstate", Constants.WORKFLOW_NODE_FLOWSTATE_FINISH);
				count = baseDao.queryForInteger(sql, params);
			}
		}
		
		return count;
	}
	

}