package cn.ksource.web.service.partner;

import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.beans.GG_FILES;
import cn.ksource.beans.SC_PARTNER_INFO;
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.EqualUtil;
import cn.ksource.core.util.FileUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.TreeNode;
import cn.ksource.core.web.WebUtil;

@Service("partnerService")
public class PartnerServiceImpl implements PartnerService {
    @Autowired
    public BaseDao baseDao;
    
	@Override
	public List<Map> getPartnerCustomerList(String partnerId) {
		String sql = "select ID as CUSTOMER_ID,CUSTOMER_NAME from sc_partner_customer_info " 
			+ "where PARTNER_ID=:partner_id and CUSTOMER_STATE=1 order by CREATE_TIME";
		
		return baseDao.queryForList(sql, new SqlParameter("partner_id", partnerId));
	}

	@Override
	public List<Map> getZcCustomerList(String zcUserId) {
		String sql = "select DISTINCT CUSTOMER_ID,CUSTOMER_NAME from sc_expatriates " 
			+ "where USER_ID=:employee_id and USINGSTATE=1 ORDER BY CUSTOMER_NAME";

		return baseDao.queryForList(sql, new SqlParameter("employee_id", zcUserId));
	}

	@Override
	public TreeNode getPartnerCiCategoryTree(String categoryId, String partnerId) {
		TreeNode root = new TreeNode("0","配置分类树");
		StringBuilder sql = new StringBuilder();
		sql.append(" select c.* from CMDB_CI_CATEGORY c where c.partner_id=:partner_id and leix = 1 and cate_type=1 ");
		
		if (StringUtils.isBlank(categoryId)) {
			sql.append("and c.JB=1 and c.pid is null ");
		} else {
			sql.append("and c.pid=:pid ");
		}
		sql.append("order by c.STATE,c.JB,c.SERIAL ");
		SqlParameter param = new SqlParameter("pid",categoryId);
		param.addValue("partner_id", partnerId);
		
		List<Map> categoryList = baseDao.queryForList(sql.toString(), param);
		
		for (Map map : categoryList) {
			TreeNode yjTree = new TreeNode(map.get("ID").toString(),map.get("NAME").toString());
			if (!EqualUtil.isStringEqual(map.get("JB"), "3")) {
				yjTree.setIsOpen(false);
			}
			Map attr = new HashMap();
			attr.put("ISNODE", "1");
			attr.put("JB", map.get("JB").toString());
			yjTree.setAttributes(attr);
			root.addChild(yjTree);
		}
		return root;
	}

	@Override
	public List<Map> getPartnerList() {
		String sql = "select ID as PARTNER_ID,PARTNER_NAME from sc_partner_info where PARTNER_STATE=1 order by PARTNER_NAME "; 
			
		return baseDao.queryForList(sql, new SqlParameter());
	}

	@Override
	public List<Map> getPartnerUserList(String partnerId) {
		String sql = "select ID as USER_ID,ZSXM as USER_NAME from gg_user " 
			+ "where MANUFACTURERID=:partner_id and ZT=1 and ACCOUNTTYPE=3 ";
		
		return baseDao.queryForList(sql, new SqlParameter("partner_id", partnerId));
	}

	@Override
	public List<Map> getPartnerManufactureList(String partnerId, Integer type) {
		String sql = "select ID,MANUFACTURERNAME,TYPE from cmdb_mainufacturer " 
			+ "where PARTNER_ID=:partner_id and STATE=1 ";
		
		SqlParameter param = new SqlParameter("partner_id", partnerId);
		
		// 动态查询type 参数 zhaoqt 2015.05.10 modify
		if(type != null) {
			sql += " and TYPE=:type";
			param.addValue("type", type);
		}
		
		return baseDao.queryForList(sql, param);
	}

	@Override
	public void doInitCiCategory(String partnerId) {
		//配置项分类表初始化
		String sql = "select * from CMDB_CI_CATEGORY where STATE=1 AND JB = :jb and cate_type=1 AND PARTNER_ID is null and cate_type=1  ";
		List<Map> yjlist = baseDao.queryForList(sql,new SqlParameter("jb",1));
		List<Map> ejlist = baseDao.queryForList(sql,new SqlParameter("jb",2));
		List<Map> sjlist = baseDao.queryForList(sql,new SqlParameter("jb",3));
		Map cacheMap = new HashMap();
		sql = "insert into CMDB_CI_CATEGORY(ID,NAME,CODE,JB,SERIAL,NOTE,PID,STATE,ICON,TABLE_NAME,LEIX,PARTNER_ID) values(:id,:name,:code,:jb,:serial,:note,:pid,:state,:icon,:table_name,:leix,:partner_id)";
		List<SqlParameter> paramList = new ArrayList<SqlParameter>();
		if (yjlist != null && yjlist.size() > 0) {
			for (Map map : yjlist) {
				String newid = StringUtil.getUUID();
				cacheMap.put(map.get("ID"), newid);
				SqlParameter param = new SqlParameter();
				param.addValue("id", newid);
				param.addValue("name", map.get("NAME"));
				param.addValue("code", map.get("CODE"));
				param.addValue("jb", map.get("JB"));
				param.addValue("serial", map.get("SERIAL"));
				param.addValue("note", map.get("NOTE"));
				param.addValue("state", map.get("STATE"));
				param.addValue("icon", map.get("ICON"));
				param.addValue("note", map.get("NOTE"));
				param.addValue("pid", null);
				param.addValue("table_name", map.get("TABLE_NAME"));
				param.addValue("leix", map.get("LEIX"));
				param.addValue("partner_id", partnerId);
				
				paramList.add(param);
			}
		}
		if (ejlist != null && ejlist.size() > 0) {
			for (Map map : ejlist) {
				String newid = StringUtil.getUUID();
				cacheMap.put(map.get("ID"), newid);
				SqlParameter param = new SqlParameter();
				param.addValue("id", newid);
				param.addValue("name", map.get("NAME"));
				param.addValue("code", map.get("CODE"));
				param.addValue("jb", map.get("JB"));
				param.addValue("serial", map.get("SERIAL"));
				param.addValue("note", map.get("NOTE"));
				param.addValue("state", map.get("STATE"));
				param.addValue("icon", map.get("ICON"));
				param.addValue("note", map.get("NOTE"));
				param.addValue("pid", cacheMap.get(map.get("PID")));
				param.addValue("table_name", map.get("TABLE_NAME"));
				param.addValue("leix", map.get("LEIX"));
				param.addValue("partner_id", partnerId);
				
				paramList.add(param);
			}
		}
		if (sjlist != null && sjlist.size() > 0) {
			for (Map map : sjlist) {
				String newid = StringUtil.getUUID();
				cacheMap.put(map.get("ID"), newid);
				SqlParameter param = new SqlParameter();
				param.addValue("id", newid);
				param.addValue("name", map.get("NAME"));
				param.addValue("code", map.get("CODE"));
				param.addValue("jb", map.get("JB"));
				param.addValue("serial", map.get("SERIAL"));
				param.addValue("note", map.get("NOTE"));
				param.addValue("state", map.get("STATE"));
				param.addValue("icon", map.get("ICON"));
				param.addValue("note", map.get("NOTE"));
				param.addValue("pid", cacheMap.get(map.get("PID")));
				param.addValue("table_name", map.get("TABLE_NAME"));
				param.addValue("leix", map.get("LEIX"));
				param.addValue("partner_id", partnerId);
				
				paramList.add(param);
			}
		}
			
		baseDao.executeBatch(sql, paramList);
		//配置项属性分组表初始化
		sql = "select B.* from CMDB_CI_CATEGORY A,CMDB_CI_PROPERTIY_GROUP B where A.ID = B.CATEGORY_ID AND B.STATE=1 AND A.STATE=1 and cate_type=1 AND A.PARTNER_ID is null ";
		List<Map> grouplist = baseDao.queryForList(sql);
		Map groupcacheMap = new HashMap();
		sql = "insert into CMDB_CI_PROPERTIY_GROUP(ID,GROUP_NAME,ORDERNUM,NOTE,STATE,CATEGORY_ID) values(:id,:group_name,:ordernum,:note,:state,:category_id)";
		List<SqlParameter> groupparamList = new ArrayList<SqlParameter>();
		if(grouplist != null && grouplist.size() > 0){
			for(Map map:grouplist){
				String newid = StringUtil.getUUID();
				groupcacheMap.put(map.get("ID"), newid);
				SqlParameter param = new SqlParameter();
				param.addValue("id", newid);
				param.addValue("group_name", map.get("GROUP_NAME"));
				param.addValue("ordernum", map.get("ORDERNUM"));
				param.addValue("jb", map.get("JB"));
				param.addValue("note", map.get("NOTE"));
				param.addValue("state", map.get("STATE"));
				param.addValue("category_id", cacheMap.get(map.get("CATEGORY_ID")));
				groupparamList.add(param);
			}
		}
		baseDao.executeBatch(sql, groupparamList);
		//扩展字段表初始化
		sql = "select * from CMDB_CI_EXTEND_COLUMN where STATE=1 AND PARTNER_ID is null ";
		List<Map> columnlist = baseDao.queryForList(sql);
		Map columncacheMap = new HashMap();
		sql = "insert into CMDB_CI_EXTEND_COLUMN(ID,COLUMNNAME,COLUMNCODE,DATATYPE,ALLOWNULL,MINVALUES,MAXVALUES,SHOWINLIST,ALLOWQUERY,INPUTTYPE,SELECTVALUE,STATE,CREATETIME,NOTE,ORDERNUM,ALERT,CMDB_CI_PRO_GROUP_ID,BUSINESS_TYPE,PARTNER_ID) values(:id,:columnname,:columncode,:datatype,:allownull,:minvalues,:maxvalues,:showinlist,:allowquery,:inputtype,:selectvalue,:state,:createtime,:note,:ordernum,:alert,:cmdb_ci_pro_group_id,:business_type,:partner_id)";
		List<SqlParameter> columnparamList = new ArrayList<SqlParameter>();
		if(columnlist != null && columnlist.size() > 0){
			for(Map map:columnlist){
				String newid = StringUtil.getUUID();
				columncacheMap.put(map.get("ID"), newid);
				SqlParameter param = new SqlParameter();
				param.addValue("id", newid);
				param.addValue("columnname", map.get("COLUMNNAME"));
				param.addValue("columncode", map.get("COLUMNCODE"));
				param.addValue("datatype", map.get("DATATYPE"));
				param.addValue("allownull", map.get("ALLOWNULL"));
				param.addValue("minvalues", map.get("MINVALUES"));
				param.addValue("maxvalues", cacheMap.get(map.get("MAXVALUES")));
				param.addValue("showinlist", cacheMap.get(map.get("SHOWINLIST")));
				param.addValue("allowquery", cacheMap.get(map.get("ALLOWQUERY")));
				param.addValue("inputtype", cacheMap.get(map.get("INPUTTYPE")));
				param.addValue("selectvalue", cacheMap.get(map.get("SELECTVALUE")));
				param.addValue("state", cacheMap.get(map.get("STATE")));
				param.addValue("createtime", cacheMap.get(map.get("CREATETIME")));
				param.addValue("note", cacheMap.get(map.get("NOTE")));
				param.addValue("ordernum", cacheMap.get(map.get("ORDERNUM")));
				param.addValue("alert", cacheMap.get(map.get("ALERT")));
				param.addValue("cmdb_ci_pro_group_id", groupcacheMap.get(map.get("CMDB_CI_PRO_GROUP_ID")));
				param.addValue("business_type", 1);
				param.addValue("partner_id",partnerId);
				columnparamList.add(param);
			}
		}
		baseDao.executeBatch(sql, columnparamList);
		//选择项可选值表初始化
		sql = "select A.* from CMDB_CI_EXTEND_COLUMN_SELECTITEMS A,CMDB_CI_EXTEND_COLUMN B where A.EXTENDID = B.ID AND B.STATE=1 AND A.STATE=1 AND B.PARTNER_ID is null ";
		List<Map> itemslist = baseDao.queryForList(sql);
		sql = "insert into CMDB_CI_EXTEND_COLUMN_SELECTITEMS(ID,EXTENDID,STATE,ITEMVALUE,ORDERNUM) values(:id,:extendid,:state,:itemvalue,:ordernum)";
		List<SqlParameter> itemsparamList = new ArrayList<SqlParameter>();
		if(itemslist != null && itemslist.size() > 0){
			for(Map map:itemslist){
				String newid = StringUtil.getUUID();
				SqlParameter param = new SqlParameter();
				param.addValue("id", newid);
				param.addValue("extendid", columncacheMap.get(map.get("EXTENDID")));
				param.addValue("state", map.get("STATE"));
				param.addValue("itemvalue", map.get("ITEMVALUE"));
				param.addValue("ordernum", map.get("ORDERNUM"));
				itemsparamList.add(param);
			}
		}
		baseDao.executeBatch(sql, itemsparamList);
	}

	@Override
	public void doInitManufacture(String partnerId) {
		String sql = "select MANUFACTURERNAME,TYPE,ZH_NAME,PHONE,WEB_URL,NOTE,STATE from cmdb_mainufacturer where STATE=1 and PARTNER_ID is null "; 
		List<Map> tlist= baseDao.queryForList(sql);
		if (tlist != null && tlist.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : tlist) {
				map.put("ID", StringUtil.getUUID());
				map.put("PARTNER_ID", partnerId);
				SqlParameter param = new SqlParameter();
				param.setSource(map);
				paramList.add(param);
			}
			
			//保存
			sql = "insert into cmdb_mainufacturer(ID,MANUFACTURERNAME,TYPE,ZH_NAME,PHONE,WEB_URL,NOTE,STATE,PARTNER_ID) "
				+ "values(:ID,:MANUFACTURERNAME,:TYPE,:ZH_NAME,:PHONE,:WEB_URL,:NOTE,:STATE,:PARTNER_ID)";
			
			baseDao.executeBatch(sql, paramList);
		}
		
	}

	@Override
	public void doInitMaintainItem(String partnerId) {
		//日常巡检项
		String sql = "select t.ID,t.ITEM_NAME,t.ITEM_NOTE,t.GET_STEPS,t.NORMAL_VALUE,t.EXCEPT_VALUE,t.ORDER_NUM,t.THIRDLEVEL_ID,t.THIRDLEVEL_NAME,t.SECONDLEVEL_ID,t.SECONDLEVEL_NAME " 
			+ "from ci_daily_patrol_item_template t where t.STATE=1 "
			+ "and exists (select p.ID from cmdb_ci_category_partner p where (p.CATEGORY_ID = t.THIRDLEVEL_ID or P.CATEGORY_ID=t.SECONDLEVEL_ID) and p.PARTNER_ID=:partner_id) ";
		
		List<Map> tlist= baseDao.queryForList(sql, new SqlParameter("partner_id", partnerId));
		if (tlist != null && tlist.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : tlist) {
				map.put("ID", StringUtil.getUUID());
				map.put("PARTNER_ID", partnerId);
				SqlParameter param = new SqlParameter();
				param.setSource(map);
				paramList.add(param);
			}
			
			//保存通用巡检项
			sql = "insert into ci_daily_patrol_item(ID,ITEM_NAME,ITEM_NOTE,GET_STEPS,NORMAL_VALUE,EXCEPT_VALUE,ORDER_NUM,THIRDLEVEL_ID,THIRDLEVEL_NAME,ITEM_TYPE,STATE,PARTNER_ID,SECONDLEVEL_ID,SECONDLEVEL_NAME) "
				+ "values(:ID,:ITEM_NAME,:ITEM_NOTE,:GET_STEPS,:NORMAL_VALUE,:EXCEPT_VALUE,:ORDER_NUM,:THIRDLEVEL_ID,:THIRDLEVEL_NAME,1,1,:PARTNER_ID,:SECONDLEVEL_ID,:SECONDLEVEL_NAME)";
			
			baseDao.executeBatch(sql, paramList);
		}
		
		//健康检查项
		sql = "select t.ID,t.ITEM_NAME,t.PRIORITY_LEVEL_ID,t.PRIORITY_LEVEL_NAME,t.ITEM_NOTE,t.STEPS,t.EXPECT_VALUE,t.THIRDLEVEL_ID,t.THIRDLEVEL_NAME,t.ORDER_NUM,SECONDLEVEL_ID,SECONDLEVEL_NAME " 
			+ "from ci_health_item_template t where t.STATE=1 "
			+ "and exists (select p.ID from cmdb_ci_category_partner p where (p.CATEGORY_ID = t.THIRDLEVEL_ID or P.CATEGORY_ID=t.SECONDLEVEL_ID) and p.PARTNER_ID=:partner_id) ";
		
		tlist= baseDao.queryForList(sql, new SqlParameter("partner_id", partnerId));
		if (tlist != null && tlist.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : tlist) {
				map.put("ID", StringUtil.getUUID());
				map.put("PARTNER_ID", partnerId);
				SqlParameter param = new SqlParameter();
				param.setSource(map);
				paramList.add(param);
			}
			
			//保存新的通用巡检项
			sql = "insert into ci_health_item(ID,ITEM_NAME,PRIORITY_LEVEL_ID,PRIORITY_LEVEL_NAME,ITEM_NOTE,STEPS,EXPECT_VALUE,ORDER_NUM,THIRDLEVEL_ID,THIRDLEVEL_NAME,ITEM_TYPE,STATE,PARTNER_ID,SECONDLEVEL_ID,SECONDLEVEL_NAME) "
				+ "values(:ID,:ITEM_NAME,:PRIORITY_LEVEL_ID,:PRIORITY_LEVEL_NAME,:ITEM_NOTE,:STEPS,:EXPECT_VALUE,:ORDER_NUM,:THIRDLEVEL_ID,:THIRDLEVEL_NAME,1,1,:PARTNER_ID,:SECONDLEVEL_ID,:SECONDLEVEL_NAME)";
			
			baseDao.executeBatch(sql, paramList);
		}
		
		//作业计划项
		sql = "select t.ID,t.ITEM_NAME,t.CYCLE,t.PRIORITY_LEVEL_ID,t.PRIORITY_LEVEL_NAME,t.ITEM_NOTE,t.THIRDLEVEL_ID,t.THIRDLEVEL_NAME,t.ORDER_NUM, " 
			+ "t.SECONDLEVEL_ID,t.SECONDLEVEL_NAME "
			+ "from ci_remind_item_template t where t.STATE=1 "
		    + "and exists (select p.ID from cmdb_ci_category_partner p where (p.CATEGORY_ID = t.THIRDLEVEL_ID or P.CATEGORY_ID=t.SECONDLEVEL_ID) and p.PARTNER_ID=:partner_id) ";
		tlist= baseDao.queryForList(sql, new SqlParameter("partner_id", partnerId));
		if (tlist != null && tlist.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : tlist) {
				map.put("ID", StringUtil.getUUID());
				map.put("PARTNER_ID", partnerId);
				
				//计算首次提醒时间
				int cycle = map.get("CYCLE") == null ? 0 : ConvertUtil.obj2Int(map.get("CYCLE"));
				map.put("BASE_REMIND_TIME", DateUtil.getDateAdd(DateUtil.getCurrentDate8(), cycle, 8));
				
				SqlParameter param = new SqlParameter();
				param.setSource(map);
				paramList.add(param);
			}
			
			//保存新的通用巡检项
			sql = "insert into ci_remind_item(ID,ITEM_NAME,CYCLE,PRIORITY_LEVEL_ID,PRIORITY_LEVEL_NAME,ITEM_NOTE,ORDER_NUM,THIRDLEVEL_ID,THIRDLEVEL_NAME,ITEM_TYPE,STATE,PARTNER_ID,SECONDLEVEL_ID,SECONDLEVEL_NAME,"
				+ "BASE_REMIND_TIME) "
				+ "values(:ID,:ITEM_NAME,:CYCLE,:PRIORITY_LEVEL_ID,:PRIORITY_LEVEL_NAME,:ITEM_NOTE,:ORDER_NUM,:THIRDLEVEL_ID,:THIRDLEVEL_NAME,1,1,:PARTNER_ID,:SECONDLEVEL_ID,:SECONDLEVEL_NAME,:BASE_REMIND_TIME)";
			
			baseDao.executeBatch(sql, paramList);
		}
		
	}

	@Override
	public void doInitCustomerSatisConfig(String partnerId) {
		String insertSql = "INSERT INTO CUSTOMER_SATIS_CONFIG(ID,NAME,LEVEL,P_ID,SATIS_TYPE,ORDER_NUM,SCORE,STATE,PARTNER_ID) "
               + " VALUES (:ID,:NAME,:LEVEL,:P_ID,:SATIS_TYPE,:ORDER_NUM,:SCORE,:STATE,:PARTNER_ID)";
		
		StringBuilder sql = new StringBuilder();
		sql.append("SELECT * ");
		sql.append(" FROM CUSTOMER_SATIS_CONFIG_TEMPLATE ");
		sql.append(" WHERE STATE=1  ");
		sql.append(" ORDER BY ORDER_NUM ");
		
		// 同步数据
		List<Map> list = baseDao.queryForList(sql.toString());
		if (list != null && list.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : list) {
				SqlParameter param = new SqlParameter();
				param.setSource(map);
				param.addValue("PARTNER_ID", partnerId);
				param.addValue("ID", StringUtil.getUUID());
				paramList.add(param);
			}
			
			baseDao.executeBatch(insertSql, paramList);
		}
		
		
		
	}

	@Override
	public void doInitServiceCard(HttpServletRequest request, String partnerId) {
		// 获取平台模板
		/*StringBuilder sql = new StringBuilder();
		sql.append("select t.TEMPLATE_NAME,f.FILE_NAME,f.FILE_PATH,f.FILE_SIZE,f.FILE_FORMAT ");
		sql.append("from sc_expatriates_supervise_card_template t ");
		sql.append("left join gg_files f on f.BUSINESS_ID=t.ID ");
		sql.append("where t.PARTNER_ID is null and t.STATE=1 ");
		
		List<Map> list = baseDao.queryForList(sql.toString());
		if (list != null && list.size() > 0) {
			for (Map map : list) {
				String filePath = ConvertUtil.obj2Str(map.get("FILE_PATH"));
				if (StringUtil.isEmpty(filePath)) {
					return;
				}
				String path = StringUtils.substringBeforeLast(filePath, "/") + "/";
				String format = StringUtils.substringAfterLast(filePath, ".");
				String tname = WebUtil.getRealPath(request, path + DateUtil.getCurrentDate14() + "_" + (Math.random()*9000+1000) + "." + format);
			
				//判断源文件是否存在
				File file = new File(WebUtil.getRealPath(request, filePath));
				if (file.exists()) {
					try {
						FileUtil.copyFile(WebUtil.getRealPath(request, filePath), tname);
						
						//写入文件记录
						SC_EXPATRIATES_SUPERVISE_CARD_TEMPLATE template = new SC_EXPATRIATES_SUPERVISE_CARD_TEMPLATE().setPartner_id(partnerId)
						.setState(1)
						.setTemplate_name(ConvertUtil.obj2Str(map.get("TEMPLATE_NAME")))
						.setUpload_time(DateUtil.getCurrentDate14())
						.setUser_name("系统同步")
						.insert();
						
						new GG_FILES().setBusiness_id(template.getId())
						.setFile_format(format)
						.setFile_name(ConvertUtil.obj2Str(map.get("FILE_NAME")))
						.setFile_path(path + DateUtil.getCurrentDate14() + "_" + (Math.random()*9000+1000) + "." + format)
						.setFile_size(ConvertUtil.obj2Str(map.get("FILE_SIZE")))
						.insert();
					} catch (IOException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			}	
		}*/
		
	}

	@Override
	public List<Map> getPartnerZcList(String partnerId) {
		String sql ="SELECT A.USER_ID,A.USER_NAME FROM SC_EXPATRIATES A,GG_USER B " +
		"WHERE A.USER_ID= B.ID AND B.MANUFACTURERID = :partnerid";

		return baseDao.queryForList(sql, new SqlParameter("partnerid", partnerId));
		
	}

	@Override
	public void doInitServiceCatolog(String partnerId) {
		
		String partnerName = "";
		SC_PARTNER_INFO partner = new SC_PARTNER_INFO().setId(partnerId).queryForBean();
		if (partner != null) {
			partnerName = partner.getPartner_name();
		}
		
		Map categoryIdMap = new HashMap();
		Map levelIdMap = new HashMap();
		
		//服务目录
		String insertSql = "INSERT INTO sc_servce_category (ID,CATEGORY_NAME,LEVEL,P_ID,STATE,SERIAL,PARTNER_ID,PARTNER_NAME,TYPE) "
            + " VALUES (:ID,:CATEGORY_NAME,:LEVEL,:P_ID,:STATE,:SERIAL,:PARTNER_ID,:PARTNER_NAME,:TYPE) ";
		
		StringBuilder sql = new StringBuilder();
		sql.append("select ID,CATEGORY_NAME,LEVEL,P_ID,STATE,SERIAL ");
		sql.append("from sc_servce_category_template where STATE=1 ");
		
		List<Map> list = baseDao.queryForList(sql.toString());
		if (list != null && list.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : list) {
				SqlParameter param = new SqlParameter();
				String newId = StringUtil.getUUID();
				param.setSource(map);
				param.addValue("PARTNER_ID", partnerId);
				param.addValue("PARTNER_NAME", partnerName);
				param.addValue("ID", newId);
				param.addValue("TYPE", 1);
				
				categoryIdMap.put(map.get("ID"), newId);
				
				paramList.add(param);
			}
			
			baseDao.executeBatch(insertSql, paramList);
		}
		
		//SLA
		insertSql = "INSERT INTO sc_sla(ID,LEVEL_NAME,STATE,SERIAL,PARTNER_ID,PARTNER_NAME,TYPE) "
            + " VALUES (:ID,:LEVEL_NAME,:STATE,:SERIAL,:PARTNER_ID,:PARTNER_NAME,:TYPE) ";
		
		sql = new StringBuilder();
		sql.append("select ID,LEVEL_NAME,STATE,SERIAL ");
		sql.append("from sc_sla_template where STATE=1 ");
		
		list = baseDao.queryForList(sql.toString());
		if (list != null && list.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : list) {
				SqlParameter param = new SqlParameter();
				String newId = StringUtil.getUUID();
				param.setSource(map);
				param.addValue("PARTNER_ID", partnerId);
				param.addValue("PARTNER_NAME", partnerName);
				param.addValue("TYPE", 1);
				param.addValue("ID", newId);
				
				levelIdMap.put(map.get("ID"), newId);
				
				paramList.add(param);
			}
			
			baseDao.executeBatch(insertSql, paramList);
		}
		
		//SLA设置
		insertSql = "INSERT INTO sc_sla_config (ID,CATEGORY_ID,CATEGORY_NAME,LEVEL_ID,LEVEL_NAME,RESPONSE_TIME,RESOLVE_TIME,STATE,SERIAL,PARTNER_ID,PARTNER_NAME,TYPE) "
            + "  VALUES (:ID,:CATEGORY_ID,:CATEGORY_NAME,:LEVEL_ID,:LEVEL_NAME,:RESPONSE_TIME,:RESOLVE_TIME,:STATE,:SERIAL,:PARTNER_ID,:PARTNER_NAME,:TYPE) ";
		
		sql = new StringBuilder();
		sql.append("select CATEGORY_ID,CATEGORY_NAME,LEVEL_ID,LEVEL_NAME,RESPONSE_TIME,RESOLVE_TIME,STATE,SERIAL ");
		sql.append("from sc_sla_config_template where STATE=1 ");
		
		list = baseDao.queryForList(sql.toString());
		if (list != null && list.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : list) {
				SqlParameter param = new SqlParameter();
				param.setSource(map);
				param.addValue("PARTNER_ID", partnerId);
				param.addValue("PARTNER_NAME", partnerName);
				param.addValue("ID", StringUtil.getUUID());
				param.addValue("TYPE", 1);
				param.addValue("CATEGORY_ID", categoryIdMap.get(map.get("CATEGORY_ID")));
				param.addValue("LEVEL_ID", levelIdMap.get(map.get("LEVEL_ID")));
				
				paramList.add(param);
			}
			
			baseDao.executeBatch(insertSql, paramList);
		}
		
		//SLA时间
		insertSql = "INSERT INTO sc_sla_time (ID,LEVEL_ID,TYPE,OVER_TIME,SERIAL) "
            + "  VALUES (:ID,:LEVEL_ID,:TYPE,:OVER_TIME,:SERIAL) ";
		
		sql = new StringBuilder();
		sql.append("select LEVEL_ID,TYPE,OVER_TIME,SERIAL ");
		sql.append("from sc_sla_time_template ");
		
		list = baseDao.queryForList(sql.toString());
		if (list != null && list.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : list) {
				SqlParameter param = new SqlParameter();
				param.setSource(map);
				param.addValue("ID", StringUtil.getUUID());
				param.addValue("LEVEL_ID", levelIdMap.get(map.get("LEVEL_ID")));
				
				paramList.add(param);
			}
			
			baseDao.executeBatch(insertSql, paramList);
		}
		
		//SLA级别
		insertSql = "INSERT INTO sc_sla_level_config (ID,INFLUENCE_ID,INFLUENCE_NAME,PRIORITY_ID,PRIORITY_NAME,LEVEL_ID,LEVEL_NAME,SHOW_NAME,PARTNER_ID,PARTNER_NAME,TYPE) "
            + " VALUES (:ID,:INFLUENCE_ID,:INFLUENCE_NAME,:PRIORITY_ID,:PRIORITY_NAME,:LEVEL_ID,:LEVEL_NAME,:SHOW_NAME,:PARTNER_ID,:PARTNER_NAME,:TYPE) ";
		
		sql = new StringBuilder();
		sql.append("select INFLUENCE_ID,INFLUENCE_NAME,PRIORITY_ID,PRIORITY_NAME,LEVEL_ID,LEVEL_NAME,SHOW_NAME ");
		sql.append("from sc_sla_level_config_template ");
		
		list = baseDao.queryForList(sql.toString());
		if (list != null && list.size() > 0) {
			List<SqlParameter> paramList = new ArrayList<SqlParameter>();
			for (Map map : list) {
				SqlParameter param = new SqlParameter();
				param.setSource(map);
				param.addValue("PARTNER_ID", partnerId);
				param.addValue("PARTNER_NAME", partnerName);
				param.addValue("ID", StringUtil.getUUID());
				param.addValue("TYPE", 1);
				param.addValue("LEVEL_ID", levelIdMap.get(map.get("LEVEL_ID")));
				
				paramList.add(param);
			}
			
			baseDao.executeBatch(insertSql, paramList);
		}
	}

	@SuppressWarnings("unchecked")
	@Override
	public void doInitPartnerPatrolRoom(String partnerId) {
		//插入加盟商机房巡查项分类数据
		String searchSql="SELECT * FROM SC_DAILY_PATROL_ROOM_CATEGORY_TEMPLATE WHERE STATE=1";
		List<Map> list_category_s = baseDao.queryForList(searchSql);
		if(list_category_s!=null&&list_category_s.size()>0){
			StringBuilder insertSql_category = new StringBuilder();
			insertSql_category.append("INSERT INTO SC_DAILY_PATROL_ROOM_CATEGORY (ID,CATEGORY_NAME,ORDER_NUM,PARTNER_ID,STATE) ");
			insertSql_category.append("VALUES (:ID,:CATEGORY_NAME,:ORDER_NUM,:PARTNER_ID,:STATE) ");
			for(Map map_category : list_category_s){
				SqlParameter param_category = new SqlParameter();
				String ID = StringUtil.getUUID();
				param_category.addValue("ID", ID);
				param_category.addValue("PARTNER_ID", partnerId);
				param_category.addValue("CATEGORY_NAME",map_category.get("CATEGORY_NAME"));
				param_category.addValue("ORDER_NUM",map_category.get("ORDER_NUM"));
				param_category.addValue("STATE", 1);
				baseDao.execute(insertSql_category.toString(), param_category);
				//插入机房巡检项数据
				String searchSql_item = "select * from sc_daily_patrol_room_item_template where state=1 and CATEGORY_ID=:CATEGORY_ID";
				SqlParameter param_item_s = new SqlParameter();
				param_item_s.addValue("CATEGORY_ID", map_category.get("ID"));
				List<Map> list_item_s = new ArrayList<Map>();
				list_item_s = baseDao.queryForList(searchSql_item, param_item_s);
				if(list_item_s!=null&&list_item_s.size()>0){
					List<SqlParameter> paramList = new ArrayList<SqlParameter>();
					StringBuilder insertSql_item = new StringBuilder();
					insertSql_item.append(" INSERT INTO sc_daily_patrol_room_item (ID,CATEGORY_id,CATEGORY_NAME,ITEM_CODE,ITEM_NAME,IS_RESULT,IS_VALUE,ORDER_NUM,STATE)");
					insertSql_item.append(" VALUES (:ID,:CATEGORY_id,:CATEGORY_NAME,:ITEM_CODE,:ITEM_NAME,:IS_RESULT,:IS_VALUE,:ORDER_NUM,:STATE)");
					
					for(Map map_item:list_item_s){
						SqlParameter param_item = new SqlParameter();
						param_item.addValue("ID", StringUtil.getUUID());
						param_item.addValue("CATEGORY_id", ID);
						param_item.addValue("CATEGORY_NAME", map_item.get("CATEGORY_NAME"));
						param_item.addValue("ITEM_CODE", map_item.get("ITEM_CODE"));
						param_item.addValue("ITEM_NAME", map_item.get("ITEM_NAME"));
						param_item.addValue("IS_RESULT", map_item.get("IS_RESULT"));
						param_item.addValue("IS_VALUE", map_item.get("IS_VALUE"));
						param_item.addValue("ORDER_NUM", map_item.get("ORDER_NUM"));
						param_item.addValue("STATE", "1");
						paramList.add(param_item);
					}
					baseDao.executeBatch(insertSql_item.toString(),paramList);
				}
			}
			
		}	
	}

	@Override
	public void doInitIncidentFlowRule(String partnerId) {
		Map paramMap = new HashMap();
		paramMap.put("partnerId", partnerId);
		//查询出事件管理流转策略模板
		String selectSql = "SELECT * FROM SC_WORKFLOW_INCIDENT_FLOWRULE WHERE PARTNER_ID IS NULL ";
		Map template = baseDao.queryForMap(selectSql);
		if(null!=template && template.size()>0) {
			String kfry = ConvertUtil.obj2StrBlank(template.get("NODE_INCIDENT_DEAL"));
			String ycjszc = ConvertUtil.obj2StrBlank(template.get("NODE_INCIDENT_STARTEND"));
			String yxgcs = ConvertUtil.obj2StrBlank(template.get("YXGCS"));
			String exgcs = ConvertUtil.obj2StrBlank(template.get("EXGCS"));
			String sxgcs = ConvertUtil.obj2StrBlank(template.get("SXGCS"));
			paramMap.put("kfry", kfry);
			paramMap.put("ycjszc", ycjszc);
			paramMap.put("yxgcs", yxgcs);
			paramMap.put("exgcs", exgcs);
			paramMap.put("sxgcs", sxgcs);
			paramMap.put("id", StringUtil.getUUID());
			String insertSql = "INSERT INTO SC_WORKFLOW_INCIDENT_FLOWRULE(ID,NODE_INCIDENT_DEAL,NODE_INCIDENT_STARTEND,YXGCS,EXGCS,SXGCS,PARTNER_ID) VALUES (:id,:kfry,:ycjszc,:yxgcs,:exgcs,:sxgcs,:partnerId)";
			baseDao.execute(insertSql, paramMap);
		}
		
	}
	
	public List<Map> getRoleList(String partnerId){
		String sql =
			"SELECT * from (\n" +
			"SELECT * FROM ac_role WHERE TYPE = 0 AND CATEGORY = 2\n" +
			"UNION\n" +
			"SELECT * from ac_role WHERE PARTNER_ID = :partnerId ) r \n" +
			"ORDER BY r.BIGCATEGORY asc,sxh asc";
		
		return baseDao.queryForList(sql,new SqlParameter("partnerId",partnerId));
	}

	@Override
	public List<Map> partnerPzflTree(HttpServletRequest request) {
		Map paramMap = new HashMap();
		//String partnerId = WebUtil.getLoginedPartnerId(request);
		String selectSubSql = "SELECT * FROM CMDB_CI_CATEGORY WHERE PARTNER_ID=:partnerId AND LEIX  = 1 AND STATE = 1 ORDER BY JB,SERIAL ";
		//paramMap.put("partnerId", partnerId);
		List<Map> cates = baseDao.queryForList(selectSubSql,paramMap);
        Map result = new HashMap();
		
		List<Map> resultList = new LinkedList<Map>();
		
		Map<String, Map> yjgnCache = new HashMap<String, Map>();
		Map<String, Map> ejgnCache = new HashMap<String, Map>();
		Map<String, Map> sjgnCache = new HashMap<String, Map>();
		
		for (Map map : cates) {
			String level = map.get("JB").toString();
			String id = map.get("ID").toString();
			
			//一级树
			if (level.equalsIgnoreCase("1")) {
				yjgnCache.put(id, map);
				List<Map> ejgnList = new LinkedList<Map>();
				map.put("ejTree", ejgnList);
				resultList.add(map);
				continue;
			}
			//二级树
			if (level.equalsIgnoreCase("2")) {
				String pId = map.get("PID").toString();
				if(yjgnCache.containsKey(pId)) {
					Map yjgnMap = yjgnCache.get(pId);
					List<Map> list = (List<Map>)yjgnMap.get("ejTree");
					map.put("sjTree", new LinkedList<Map>());
					list.add(map);
					
					ejgnCache.put(id, map);
				}
				continue;
			}
			//三级树
			if (level.equalsIgnoreCase("3")) {
				if(null!=map.get("PID")){
					String pId = map.get("PID").toString();
					if(ejgnCache.containsKey(pId)) {
						Map ejgnMap = ejgnCache.get(map.get("PID").toString());
						List<Map> list = (List<Map>)ejgnMap.get("sjTree");
						list.add(map);
					}
				}
			}
		}
		System.out.println(JsonUtil.list2Json(resultList));
		return resultList;
	}

	
			
}