package cn.ksource.web.facade.customermanage;

import cn.ksource.beans.SC_PARTNER_CUSTOMER_INFO;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.*;
import cn.ksource.core.web.LoginUser;
import cn.ksource.core.web.WebUtil;
import cn.ksource.web.Constants;
import cn.ksource.web.service.file.FileService;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service("customerManageFacade")
public class CustomerManageFacadeImpl implements CustomerManageFacade {

	@Autowired
	private BaseDao baseDao;

	@Autowired
	private FileService fileService;

	@Override
	public int queryCustomerCount(Map<String, String> params) {
		StringBuilder sql = new StringBuilder("SELECT COUNT(ID) FROM SC_PARTNER_CUSTOMER_INFO ");
		queryCustomerIf(params, sql);
		return baseDao.queryForInteger(sql.toString(), params);
	}

	@Override
	public PageInfo queryCustomerData(Map<String, String> params,
			PageInfo pageInfo) {
		StringBuilder sql = new StringBuilder("SELECT * FROM SC_PARTNER_CUSTOMER_INFO ");
		queryCustomerIf(params, sql);
		sql.append(" ORDER BY CUSTOMER_STATE,CREATE_TIME DESC");
		return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
	}
	@Override
	public List<Map> queryCustomerDataList(Map<String, String> params) {
		StringBuilder sql = new StringBuilder("SELECT * FROM SC_PARTNER_CUSTOMER_INFO ");
		queryCustomerIf(params, sql);
		sql.append(" ORDER BY CUSTOMER_STATE,CREATE_TIME DESC");
		return baseDao.queryForList(sql.toString(), params);
	}

	private void queryCustomerIf(Map<String, String> params, StringBuilder sql) {
		sql.append(" WHERE 1=1 ");
		//客户名称
		if(StringUtil.notEmpty(params.get("cusName"))){
			sql.append(" AND CUSTOMER_NAME LIKE :cusName");
			String cusName = String.valueOf(params.get("cusName"));
			params.put("cusName", "%"+cusName+"%");
		}
		//客户状态
		if(StringUtil.notEmpty(params.get("state"))){
			sql.append(" AND CUSTOMER_STATE = :state");
		}
		//客户联系人联系电话
		if(StringUtil.notEmpty(params.get("phone"))){
			sql.append(" AND PHONE = :phone");
		}
		//服务期限
		if (StringUtils.isNotBlank(params.get("beginTime"))) {
			sql.append(" AND VALID_BEGIN_DATE >= :beginTime ");
		}
		if (StringUtils.isNotBlank(params.get("endTime"))) {
			sql.append(" AND VALID_END_DATE <= :endTime ");
		}
	}

	@Override
	public Map getPartnerCostomerById(String id) {
		String sql = new String("SELECT * FROM SC_PARTNER_CUSTOMER_INFO WHERE ID = :id");
		Map map = baseDao.queryForMap(sql, new SqlParameter().addValue("id", id));
		List<Map> fileList = fileService.getFileList(id);
		map.put("fileList", fileList);
		return map;
	}

	@Override
	public void addPartnerCustomer(SC_PARTNER_CUSTOMER_INFO customer,
			HttpServletRequest request) {
		//修改项目名称时同时修改流程中的项目信息
		  String customer_id=customer.getId();
		  if(StringUtil.isNotBlank(customer_id)) {
			SC_PARTNER_CUSTOMER_INFO sc_partner_customer_info_old = new SC_PARTNER_CUSTOMER_INFO(customer.getId()).getInstanceById();
            String customer_name_old=sc_partner_customer_info_old.getCustomer_name();
			String customer_name=request.getParameter("customer_name");
			if(!customer_name_old.equals(customer_name)){
				String sql="update WORKFLOW_BASE set CUSTOMER_NAME=:customer_name where CUSTOMER_ID=:customer_id ";
				String sql_super="update WORKFLOW_BASE set SUB_CUSTOMER_NAME=:customer_name where SUB_CUSTOMER_ID=:customer_id ";
				String order_super="update SC_WORKFLOW_QUESTION set SUB_CUSTOMER_NAME=:customer_name where SUB_CUSTOMER_ID=:customer_id  ";
				String order="update SC_WORKFLOW_QUESTION set CUSTOMER_NAME=:customer_name where CUSTOMER_ID=:customer_id  ";
				String order_in="update SC_WORKFLOW_INCIDENT set CUSTOMER_NAME=:customer_name where CUSTOMER_ID=:customer_id  ";
				String sup_super="update SC_WORKFLOW_INCIDENT set SUB_CUSTOMER_NAME=:customer_name where SUB_CUSTOMER_ID=:customer_id  ";

				Map map=new HashMap();
				 map.put("customer_id",customer_id);
				 map.put("customer_name",customer_name);
                baseDao.execute(sql,map);
				baseDao.execute(sql_super,map);
				baseDao.execute(order_super,map);
				baseDao.execute(order,map);
				baseDao.execute(order_in,map);
				baseDao.execute(sup_super,map);
			}

		}

		//登陆用户信息
		LoginUser user = WebUtil.getLoginUser(request);
		String userid =(String)user.getLoginUser().get("ID");
		String userName = (String)user.getLoginUser().get("ZSXM");

		String industry_name = request.getParameter("industry_name");
		customer.setIndustry_name(industry_name);

		String addressId = request.getParameter("addressId");
		String addressName = request.getParameter("addressName");
		if(StringUtil.notEmpty(addressId) && StringUtil.notEmpty(addressName)) {
			String[] addressIds = addressId.split("-");
			String[] addressNames = addressName.split("-");
			if(addressIds.length == 3 && addressIds.length == addressNames.length) {
				customer.setProvince_id(addressIds[0]);
				customer.setProvince_name(addressNames[0]);
				customer.setCity_id(addressIds[1]);
				customer.setCity_name(addressNames[1]);
				customer.setCounty_id(addressIds[2]);
				customer.setCounty_name(addressNames[2]);
			}
		}
		customer.setEmail(request.getParameter("email"));
		customer.setPhone(request.getParameter("phone"));
		customer.setContact(request.getParameter("contact"));
		customer.setCustomer_code(request.getParameter("code"));

		String customerId = customer.getId();
		if (StringUtil.isEmpty(customerId)) {
			//新增
			//保存客户基本信息
			customer.setCreate_time(DateUtil.getCurrentDate14())
			.setCustomer_state(Constants.SC_PARTNER_CUSTOMER_INFO_STATE_ENABLE).setBusiness_desc(request.getParameter("business_desc")).setCreate_user_id(userid).setCreate_user_name(userName);
			customer.setCustomer_name_f(PinYinUtil.getFirstStringPinYin(customer.getCustomer_name().substring(0, 1), false));
			customer = customer.insert();

			//初始化配置信息（流程配置，服务等级配置，服务目录和服务协议）
			initConfig(customer.getId());

		} else {
			//修改
			customer.setCustomer_name_f(PinYinUtil.getFirstStringPinYin(customer.getCustomer_name().substring(0, 1), false)).setBusiness_desc(request.getParameter("business_desc"));
			customer.update();
			Map param=new HashMap();
			param.put("name", customer.getCustomer_name());
			param.put("id", customer.getId());
			String sqla="update SC_WORKFLOW_INCIDENT_TEMPLATE set CUSTOMER_NAME=:name  where CUSTOMER_ID=:id";
			String sqlb="update SC_WORKFLOW_INCIDENT set CUSTOMER_NAME=:name  where CUSTOMER_ID=:id";
			String sqlc="update SC_WORKFLOW_QUESTION set CUSTOMER_NAME=:name  where CUSTOMER_ID=:id";
			baseDao.execute(sqla, param);
			baseDao.execute(sqlb, param);
			baseDao.execute(sqlc, param);
		}

		//保存附件
	/*	Map parameter = ParamsMapUtil.getParameterMap(request);
		parameter.put("business_id", customerId);
	    parameter.put("userId",userid);
	    parameter.put("userName",userName );
	    fileService.uploadFile(parameter);*/
		fileService.uploadFile(request,customer.getId(),null,null,null,Constants.GG_FOLDERS_CUSTOMERS,Constants.FILE_STATE_SHTG,null);

	}

	public void initConfig(String customerId){

		//String sqlsj = "SELECT * FROM SC_WORKFLOW_INCIDENT_FLOWRULE WHERE PROJECT_ID IS NULL ";

		//String sqlwt = "SELECT * FROM QUESTION_FLOWRULE WHERE CUSTOMER_ID IS NULL  ";

		String sqllevel = "SELECT * FROM SC_SLA_LEVEL_CONFIG WHERE CUSTOMER_ID IS NULL  ";
		//List<Map> sjrule = baseDao.queryForList(sqlsj);
		//List<Map> wtrule = baseDao.queryForList(sqlwt);
		List<Map> slalevel = baseDao.queryForList(sqllevel);
		//List<SqlParameter> sjparamList = new ArrayList<SqlParameter>();
		//List<SqlParameter> wtparamList = new ArrayList<SqlParameter>();
		List<SqlParameter> levelparamList = new ArrayList<SqlParameter>();
		/*for(Map map:sjrule){
			SqlParameter param = new SqlParameter();
			map.put("ID", StringUtil.getUUID());
			map.put("PROJECT_ID", customerId);
			param.setSource(map);
			sjparamList.add(param);
		}
		for(Map map:wtrule){
			SqlParameter param = new SqlParameter();
			map.put("ID", StringUtil.getUUID());
			map.put("CUSTOMER_ID", customerId);
			param.setSource(map);
			wtparamList.add(param);
		}*/
		for(Map map:slalevel){
			SqlParameter param = new SqlParameter();
			map.put("ID", StringUtil.getUUID());
			map.put("CUSTOMER_ID", customerId);
			param.setSource(map);
			levelparamList.add(param);
		}
		/*String insertsj = "INSERT INTO SC_WORKFLOW_INCIDENT_FLOWRULE(ID,KFRY,YCJSZC,YXGCS,EXGCS,SXGCS,PROJECT_ID)VALUES(:ID,:KFRY,:YCJSZC,:YXGCS,:EXGCS,:SXGCS,:PROJECT_ID)";
		String insertwt = "INSERT INTO QUESTION_FLOWRULE(ID,WTFQ,WTSL,WTSH,WTZD,FASP,FASS,WTHG,CUSTOMER_ID,CLOSEJD,GOBACKJD)VALUES(:ID,:WTFQ,:WTSL,:WTSH,:WTZD,:FASP,:FASS,:WTHG,:CUSTOMER_ID,:CLOSEJD,:GOBACKJD)";
	    baseDao.executeBatch(insertsj, sjparamList);
	    baseDao.executeBatch(insertwt, wtparamList);*/
	    String insertlevel = "INSERT INTO SC_SLA_LEVEL_CONFIG(ID,INFLUENCE_ID,INFLUENCE_NAME,PRIORITY_ID,PRIORITY_NAME,LEVEL_ID,LEVEL_NAME,SHOW_NAME,TYPE,CUSTOMER_ID)VALUES(:ID,:INFLUENCE_ID,:INFLUENCE_NAME,:PRIORITY_ID,:PRIORITY_NAME,:LEVEL_ID,:LEVEL_NAME,:SHOW_NAME,:TYPE,:CUSTOMER_ID)";
	    baseDao.executeBatch(insertlevel, levelparamList);

	    //服务目录和服务协议
	    /*String sqlservice = "SELECT ID FROM SC_SERVCE_CATEGORY WHERE STATE = 1 ";
	    List<Map> serviceList = baseDao.queryForList(sqlservice);
	    List<SqlParameter> svparamList = new ArrayList<SqlParameter>();
	    List<SqlParameter> configparamList = new ArrayList<SqlParameter>();
	    List<SqlParameter> configuserparamList = new ArrayList<SqlParameter>();
	    for(Map map:serviceList){
	    	SqlParameter params = new SqlParameter();
	    	params.put("ID", StringUtil.getUUID());
	    	params.put("CATEGORY_ID", map.get("ID"));
	    	params.put("CUSTOMER_ID", customerId);
	    	params.put("STATE", 1);
	    	svparamList.add(params);
	    }
	    String sqlconfig = "SELECT * FROM SC_SLA_CONFIG WHERE CUSTOMER_ID IS NULL OR CUSTOMER_ID = '' ";
	    String sqlconfiguser = "SELECT B.* FROM SC_SLA_CONFIG A,SC_SLA_USER B WHERE (A.CUSTOMER_ID IS NULL OR A.CUSTOMER_ID = '') AND A.ID = B.LEVEL_ID ";
	    List<Map> configList = baseDao.queryForList(sqlconfig);
	    List<Map> configuserList = baseDao.queryForList(sqlconfiguser);
	    Map cacheMap = new HashMap();
	    for(Map map:configList){
	    	SqlParameter params = new SqlParameter();
	    	String id = StringUtil.getUUID();
	    	cacheMap.put(map.get("ID"), id);
	    	params.putAll(map);
	    	params.put("ID", id);
	    	params.put("CUSTOMER_ID", customerId);
	    	configparamList.add(params);
	    }
	    for(Map map:configuserList){
	    	SqlParameter params = new SqlParameter();
	    	String id = StringUtil.getUUID();
	    	params.putAll(map);
	    	params.put("ID", id);
	    	params.put("LEVEL_ID", cacheMap.get(map.get("LEVEL_ID")));
	    	configuserparamList.add(params);
	    }
	    String insertsv = "INSERT INTO SC_SERVCE_CATEGORY_CUSTOMER (ID,CATEGORY_ID,CUSTOMER_ID,STATE) VALUES(:ID,:CATEGORY_ID,:CUSTOMER_ID,:STATE);";
	    String insertconfig = "INSERT INTO SC_SLA_CONFIG (ID,CATEGORY_ID,CATEGORY_NAME,LEVEL_ID,LEVEL_NAME,RESPONSE_TIME,RESOLVE_TIME,STATE,SERIAL,TYPE,USER_ID,USER_NAME,GROUP_ID,GROUP_NAME,CUSTOMER_ID,DEALER_TYPE) VALUES(:ID,:CATEGORY_ID,:CATEGORY_NAME,:LEVEL_ID,:LEVEL_NAME,:RESPONSE_TIME,:RESOLVE_TIME,:STATE,:SERIAL,:TYPE,:USER_ID,:USER_NAME,:GROUP_ID,:GROUP_NAME,:CUSTOMER_ID,:DEALER_TYPE);";
	    String insertconfiguser = "INSERT INTO SC_SLA_USER (ID,LEVEL_ID,NOTICE_TYPE,OVER_TIME,USER_ID,USER_NAME,SERIAL,TYPE,DEALER_TYPE,GROUP_ID,GROUP_NAME) VALUES(:ID,:LEVEL_ID,:NOTICE_TYPE,:OVER_TIME,:USER_ID,:USER_NAME,:SERIAL,:TYPE,:DEALER_TYPE,:GROUP_ID,:GROUP_NAME);";
	    baseDao.executeBatch(insertsv, svparamList);
	    baseDao.executeBatch(insertconfig, configparamList);
	    baseDao.executeBatch(insertconfiguser, configuserparamList);*/
	}

	@Override
	public String getInitPassword() {
		return "88888888";
	}

	@Override
	public boolean getCustomerCount(HttpServletRequest request) {
		int CUSTOMER_ACCOUNT_NUM =  ConvertUtil.obj2Int(baseDao.queryForInteger("SELECT CUSTOMER_ACCOUNT_NUM FROM SC_PARTNER_INFO"));
		String sql = "SELECT COUNT(ID) FROM SC_PARTNER_CUSTOMER_INFO WHERE CUSTOMER_STATE=1";
		int customercount = baseDao.queryForInteger(sql);
		if(customercount < CUSTOMER_ACCOUNT_NUM){
			return true;
		}else{
			return false;
		}
	}

	@Override
	public void updateStatus(HttpServletRequest request) {
		String state = request.getParameter("state");
		String id = request.getParameter("id");
		SC_PARTNER_CUSTOMER_INFO sc_customer_info = new SC_PARTNER_CUSTOMER_INFO();
		sc_customer_info.setId(id).setCustomer_state((ConvertUtil.obj2Integer(state))).update();
	}

	@Override
	public List<Map> getCusList() {
		return baseDao.queryForList(" select id,customer_name name,contact,phone from sc_partner_customer_info where customer_state=1 ");
	}

	@Override
	public List<Map> getSubCusTreeList(String cusId) {
		String sql = "select id,p_id pid,customer_name name from sc_partner_customer_sub where del_flag=1 and customer_id=:cusId ";
		List<Map> list = baseDao.queryForList(sql,new SqlParameter("cusId",cusId));
		list= TreeUtil.createTreeByList(list);
		return list;
	}

	@Override
	public Map getCusById(String cusId) {
		return baseDao.queryForMap("select id,customer_name name,contact,phone,valid_begin_date begin_date,valid_end_date end_date from sc_partner_customer_info where id=:cusId",new SqlParameter("cusId",cusId));
	}

	@Override
	public PageInfo getCusData(PageInfo pageInfo, Map<String, String> params) {
		Map support = getCusSupport(params);
		String sql = support.get("sql").toString();
		return baseDao.queryforSplitPageInfo(pageInfo, sql, params);
	}

	@Override
	public Integer getCusCount(Map<String, String> params) {
		Map support = getCusSupport(params);
		String sql = "select count(*) from ( " + support.get("sql").toString() + " ) t ";
		return baseDao.queryForInteger(sql, params);
	}

	private Map getCusSupport(Map<String, String> params){
		Map<String, Object> support = new HashMap<String, Object>();
		StringBuilder sql = new StringBuilder();
		sql.append(" select a.*  ");
		sql.append(" from sc_partner_customer_info a ");
		sql.append(" where customer_state=1 ");

		if(StringUtil.isNotBlank(params.get("cusId"))){
			sql.append(" and a.id = :cusId ");
		}

		sql.append(" order by a.create_time desc ");
		support.put("sql", sql.toString());
		support.put("param", params);
		return support;
	}

	@Override
	public String checkCusCode(String code) {
		String sql = new String("SELECT COUNT(ID) FROM SC_PARTNER_CUSTOMER_INFO WHERE CUSTOMER_CODE = :code");
		Integer count = baseDao.queryForInteger(sql, new SqlParameter("code",code));
		if(count > 0){
			return "1";
		}else{
			return "0";
		}
	}
	@Override
	public String checkCusCodeTwo(String code,String id) {
		String sql = " SELECT COUNT(ID) FROM SC_PARTNER_CUSTOMER_INFO WHERE CUSTOMER_CODE = :code ";
		if(StringUtil.notEmpty(id)){
			sql+=" and id<> :id ";
		}
		Map param=new HashMap();
		param.put("code", code);
		param.put("id", id);
		Integer count = baseDao.queryForInteger(sql, param);
		if(count > 0){
			return "1";
		}else{
			return "0";
		}
	}

	/**
	 * 查询客户基本信息
	 */
	@Override
	public Map queryCustomerBaseMsg(String id) {
		String sql = "SELECT A.* FROM SC_PARTNER_CUSTOMER_INFO A WHERE   A.ID=:id  " ;
		SqlParameter param = new SqlParameter();
		param.addValue("id", id);
		Map map = baseDao.queryForMap(sql, param);
		return map;
	}


	@Override
	public List<Map> queryCtmChildAcountList(String id) {
		String sql = "select A.CUSTOMER_NAME,B.* from SC_PARTNER_CUSTOMER_INFO A " +
		", CUSTOMER_CONTACTS B WHERE A.ID = B.CUSTOMER_ID AND B.STATE = 1 AND A.ID = :id " ;
		SqlParameter param = new SqlParameter();
		param.addValue("id", id);
		List<Map> list  = baseDao.queryForList(sql, param);
		return list;
	}

	@Override
	public PageInfo queryCustomerOrder(PageInfo pageInfo, Map<String, String> params) {
		String customerId = params.get("id");
		String selectSql = "SELECT B.ID , A.FLOWSTATE, B.WFNAME , B.BUSINESSTYPE , B.WFSTATE , B.WORKFLOWTYPE , B.CREATERNAME , B.CREATERID , B.CREATETIME , B.ENDTIME, B.MAINFLOWID , B.CURRENT_NODE_NAME , B.CURRENT_NODE_ID , B.DEAL_TYPE , B.CURRENT_DEALER_ID , B.CURRENT_DEALER_NAME , B.CURRENT_DEAL_ROLEIDA, B.CURRENT_DEAL_ROLENAME , B.WF_TEMPLATE_ID, B.BUSINESS_ID , B.ORDER_CODE, B.CUSTOMER_ID, B.CUSTOMER_NAME , B.PROJECT_ID, B.PROJECT_NAME , B.SUB_CUSTOMER_NAME , B.SUB_CUSTOMER_ID FROM WORKFLOW_BASE B LEFT JOIN WORKFLOW_NODE A ON B.ID = A.FLOWID WHERE B.CUSTOMER_ID = :customerId AND B.WFSTATE != :ysc GROUP BY   B.ID , A.FLOWSTATE, B.WFNAME , B.BUSINESSTYPE , B.WFSTATE , B.WORKFLOWTYPE , B.CREATERNAME , B.CREATERID , B.CREATETIME , B.ENDTIME, B.MAINFLOWID , B.CURRENT_NODE_NAME , B.CURRENT_NODE_ID , B.DEAL_TYPE , B.CURRENT_DEALER_ID , B.CURRENT_DEALER_NAME , B.CURRENT_DEAL_ROLEIDA, B.CURRENT_DEAL_ROLENAME , B.WF_TEMPLATE_ID, B.BUSINESS_ID , B.ORDER_CODE, B.CUSTOMER_ID, B.CUSTOMER_NAME , B.PROJECT_ID, B.PROJECT_NAME , B.SUB_CUSTOMER_NAME , B.SUB_CUSTOMER_ID ORDER BY B.CREATETIME DESC ";
		params.put("customerId", customerId);
		params.put("ysc", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		return baseDao.queryforSplitPageInfo(pageInfo, selectSql, params);
	}

	@Override
	public int queryCustomerOrderCount(Map<String, String> params) {
		String customerId = params.get("id");
		String selectSql = "SELECT COUNT(B.ID) FROM WORKFLOW_BASE B WHERE B.CUSTOMER_ID = :customerId AND B.WFSTATE != :ysc ORDER BY B.CREATETIME DESC ";
		params.put("customerId", customerId);
		params.put("ysc", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE));
		return baseDao.queryForInteger(selectSql,params);
	}

	@Override
	public List queryDeviceMsg(String id) {
		String sql = "SELECT B.NUM,B.LV3_ID,C.NAME AS THIRD_NAME,B.LV2_ID,(SELECT D.NAME FROM CMDB_CI_CATEGORY D WHERE CATE_TYPE=1 AND  B.LV2_ID = D.ID) SECOND_NAME FROM (SELECT COUNT(A.ID) NUM, A.LV3_ID,A.LV2_ID FROM CMDB_CI_BASE A WHERE A.CUS_ID = :userId AND STATE = :state GROUP BY A.LV3_ID,A.LV2_ID) B,CMDB_CI_CATEGORY C WHERE B.LV3_ID = C.ID AND C.CATE_TYPE=1  ;";
		List<Map> list = baseDao.queryForList(sql,new SqlParameter("userId",id).addValue("state", Constants.CMDB_CI_BASE_USINGSTATE_NORMAL));
		List newList = new ArrayList();
		Map cacheMap = new HashMap();
		for(Map map : list) {
			if(cacheMap.containsKey(map.get("LV2_ID"))) {
				List cacheList = (List)cacheMap.get(map.get("LV2_ID"));
				cacheList.add(map);
			} else {
				List cacheList = new ArrayList();
				cacheList.add(map);
				Map map2 = new HashMap();
				map2.put("secondId", map.get("LV2_ID"));
				map2.put("secondName", map.get("SECOND_NAME"));
				map2.put("third", cacheList);
				cacheMap.put(map.get("LV2_ID"), cacheList);
				newList.add(map2);
			}
		}
		System.out.println(JsonUtil.list2Json(newList));
		return newList;
	}

	/**
	 * 查询该客户的设备总数量
	 */
	@Override
	public int queryCateDeviceCount( Map<String, String> params) {
		String selectSql = "SELECT COUNT(ID) FROM CMDB_CI_BASE WHERE CUS_ID = :customerId AND LV3_ID = :cate AND STATE = :state";
		params.put("state", ConvertUtil.obj2StrBlank(Constants.CMDB_CI_BASE_USINGSTATE_NORMAL));
		return baseDao.queryForInteger(selectSql,params);
	}

	/**
	 * 查询该客户的设备数据
	 */
	@Override
	public PageInfo queryCateDeviceData(PageInfo pageInfo, Map<String, String> params) {
		String selectSql = "SELECT * FROM CMDB_CI_BASE WHERE CUS_ID = :customerId AND LV3_ID = :cate AND STATE = :state";
		params.put("state",ConvertUtil.obj2StrBlank( Constants.CMDB_CI_BASE_USINGSTATE_NORMAL));
		return baseDao.queryforSplitPageInfo(pageInfo, selectSql, params);
	}

	@Override
	public int queryXjReportCount(Map<String, String> params) {
		String beginTime = params.get("beginTime");
		String endTime = params.get("endTime");
		String sql = "SELECT COUNT(B.ID) ";
		sql += "FROM CI_DAILY_PATROL B ";
		sql += " WHERE B.CUS_ID = :customerId ";
		if(StringUtil.notEmpty(beginTime) && StringUtil.notEmpty(endTime)) {
			beginTime = beginTime.replaceAll("-", "");
			endTime = endTime.replaceAll("-", "");
			sql += " AND B.PATROL_DATE >= :beginTime AND B.PATROL_DATE < :endTime ";
		}
	    int count = baseDao.queryForInteger(sql, params);
		return count;
	}

	@Override
	public String queryByName(String name) {
		return baseDao.queryForString("select id from sc_partner_customer_info where customer_name=:name",new SqlParameter("name",name));
	}

	@Override
	public String queryBySubname(String name) {
		return baseDao.queryForString("select id from sc_partner_customer_sub where customer_name=:name",new SqlParameter("name",name));
	}
	@Override
	public Integer checkname(String customer_id,String id) {
		return baseDao.queryForInteger("select count(id) from sc_partner_customer_sub where id=:id and customer_id=:customer_id",new SqlParameter("customer_id",customer_id).addValue("id",id));
	}

	@Override
	public PageInfo queryXjReportData(PageInfo pageInfo, Map<String, String> params) {
		String beginTime = params.get("beginTime");
		String endTime = params.get("endTime");
		String sql = "SELECT A.*   FROM CI_DAILY_PATROL A  WHERE A.CUS_ID = :customerId ";

		if(StringUtil.notEmpty(beginTime) && StringUtil.notEmpty(endTime)) {
			beginTime = beginTime.replaceAll("-", "");
			endTime = endTime.replaceAll("-", "");
			sql += " AND A.PATROL_DATE >= :beginTime AND A.PATROL_DATE <= :endTime ";
		}

		sql +=" ORDER BY A.PATROL_DATE DESC ";
		PageInfo list = baseDao.queryforSplitPageInfo(pageInfo, sql, params);
		return list;
	}

	@SuppressWarnings("unchecked")
	@Override
	public List getSubList(Map param) {
		String lid=ConvertUtil.obj2StrBlank(param.get("lv1Id"));
		if(StringUtil.isEmpty(lid)){
			param.put("lv1Id", "");
		}
		String lv=ConvertUtil.obj2StrBlank(param.get("lv"));
		String sql="";
		if(lv.equals("1")){
			sql="select id,CUSTOMER_NAME name from SC_PARTNER_CUSTOMER_SUB where CUSTOMER_ID=:lv1Id and MY_LEVEL=1";
		}else if(lv.equals("2")){
			sql="select id,CUSTOMER_NAME name from SC_PARTNER_CUSTOMER_SUB where P_ID=:lv1Id and MY_LEVEL=2";
		}
		return baseDao.queryForList(sql, param);
	}

}