package cn.ksource.web.facade.uc.fulltext;

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.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.fulltext.FullTextConstants;
import cn.ksource.core.fulltext.FullText_QueryEntity;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.HttpCharset;
import cn.ksource.core.util.HttpUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.StringUtil;

@Service("ucFullTextFacade")
public class UcFullTextFacadeImpl implements UcFullTextFacade {

	

	@Autowired
	private BaseDao baseDao;
	
	/**
	 * 查询结果数据
	 */
	@Override
	public Map query(HttpServletRequest request,String customerId) {
		FullText_QueryEntity queryEntity = new FullText_QueryEntity();
		String kw = request.getParameter("kw");
		
		String type = request.getParameter("type");
		
		if(!StringUtil.notEmpty(type)) {
			type = ConvertUtil.obj2StrBlank(FullTextConstants.knowledge);
		}
		
		String currPage = request.getParameter("currPage");
		String pageSize = request.getParameter("pageSize");
		
		String smallCategory = request.getParameter("smallCategory");
		
		if(!StringUtil.notEmptyNum(currPage)) {
			currPage = "1";
		}
		if(!StringUtil.notEmptyNum(pageSize)) {
			pageSize = "10";
		}
		
		Map<String,String[]> filter = new HashMap();
		filter.put("big_category", new String[]{type});
		
		if(StringUtil.notEmpty(smallCategory)) {
			filter.put("small_category", new String[]{smallCategory});
		}
		
		if(type.equals(ConvertUtil.obj2StrBlank(FullTextConstants.knowledge))) {
			//查询所有可以被当前用户看到的知识
			String selectSql = "SELECT A.ID FROM KM_LIBRARY A WHERE A.ACCESS_TYPE = 1 AND EXISTS (SELECT B.ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS B WHERE A.ID = B.KNOWLEDGE_ID AND B.CUSTOMER_ID = :customerId )";
			List<Map> knows = baseDao.queryForList(selectSql,new SqlParameter("customerId",customerId));
			if(null!=knows && knows.size()>0) {
				String[] knowIds = new String[knows.size()];
				for(int i=0; i<knows.size();i++) {
					Map know = knows.get(i);
					knowIds[i] = ConvertUtil.obj2StrBlank(know.get("ID"));
				}
				filter.put("extend_paramter_2", knowIds);
			}
		} else {
			filter.put("extend_paramter_0", new String[]{customerId});
		}
		
		
		int pageindex = ConvertUtil.obj2Int(currPage);
		int pagesize = ConvertUtil.obj2Int(pageSize);
		queryEntity.setFilter(filter);
		queryEntity.setKeywords(kw);
		queryEntity.setPageindex((pageindex-1)*pagesize);
		queryEntity.setPagesize(pagesize);
		
		String param = queryEntity.toJson();
		
		Map params = new HashMap();
		params.put("param", param);
		String result = HttpUtil.doPost(FullTextConstants.getQuery_data_path(), params, HttpCharset.UTF8);
		System.out.println("查询结果-------------------->"+result);
		
		if(StringUtil.notEmpty(result)) {
			Map rs = JsonUtil.json2Map(result);
			rs.put("type", type);
			return rs;
		}
		
		return new HashMap();
	}

	private List<Map> queryKnowLedgeMsg(List<String> bs,String word) throws Exception{
		StringBuilder builder= new StringBuilder("SELECT * FROM KM_LIBRARY WHERE ID IN ( ");
		StringBuffer sBuffer = new StringBuffer();
		for(String id : bs) {
			sBuffer.append("'");
			sBuffer.append(id);
			sBuffer.append("'");
			sBuffer.append(",");
		}
		
		sBuffer.deleteCharAt(sBuffer.length()-1);
		builder.append(sBuffer.toString());
		builder.append(") ");
		builder.append("order by field(id,");
		builder.append(sBuffer.toString());
		builder.append(")");
		List<Map> result = baseDao.queryForList(builder.toString());
		
		
		/*if(null!=result && result.size()>0) {
			for(Map data : result) {
				String title = ConvertUtil.obj2StrBlank(data.get("TITLE"));
				String content = new HtmlRegexpUtil().filterHtml(ConvertUtil.obj2StrBlank(data.get("CONTENT")));
				String tag = ConvertUtil.obj2StrBlank(data.get("TAG"));
				
				if(StringUtil.notEmpty(word)) {
					
					String[] words = word.split(",");
					title = StringUtil.msg(title, words);
					content = StringUtil.msg(content, words);
					tag = StringUtil.msg(tag, words);
					
					data.put("TITLE", title);
					data.put("CONTENT", content);
					data.put("TAG", tag);
					data.put("UPDATE_DATE", DateUtil.format("yyyy-MM-dd", data.get("UPDATE_DATE")));
				}
			}
		}*/
		
		return result;
	}

	@Override
	public Map queryCount(HttpServletRequest request) {
		FullText_QueryEntity queryEntity = new FullText_QueryEntity();
		String kw = request.getParameter("kw");
		
		String type = request.getParameter("type");
		
		if(!StringUtil.notEmpty(type)) {
			type = ConvertUtil.obj2StrBlank(FullTextConstants.knowledge);
		}
		
		String currPage = request.getParameter("currPage");
		String pageSize = request.getParameter("pageSize");
		if(!StringUtil.notEmptyNum(currPage)) {
			currPage = "1";
		}
		if(!StringUtil.notEmptyNum(pageSize)) {
			pageSize = "10";
		}
		
		Map<String,String[]> filter = new HashMap();
		filter.put("big_category", new String[]{type});
		
		int pageindex = ConvertUtil.obj2Int(currPage);
		int pagesize = ConvertUtil.obj2Int(pageSize);
		queryEntity.setFilter(filter);
		queryEntity.setKeywords(kw);
		queryEntity.setPageindex((pageindex-1)*pagesize);
		queryEntity.setPagesize(pagesize);
		
		String param = queryEntity.toJson();
		
		Map params = new HashMap();
		params.put("param", param);
		String result = HttpUtil.doPost(FullTextConstants.getQuery_data_path(), params, HttpCharset.UTF8);
		System.out.println("查询结果-------------------->"+result);
		
		if(StringUtil.notEmpty(result)) {
			Map rs = JsonUtil.json2Map(result);
			return rs;
		}
		
		return null;
	}

	
}