package com.newvideo.service.imp;

import java.io.Serializable;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.TreeSet;

import javax.annotation.Resource;

import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.orm.hibernate4.HibernateCallback;
import org.springframework.stereotype.Service;

import com.newvideo.dao.DetailSystemDao;
import com.newvideo.dao.HotSearchDao;
import com.newvideo.dao.SearchDao;
import com.newvideo.dao.SuperHotSearchDao;
import com.newvideo.dao.VideoBanQuanVideoDao;
import com.newvideo.dao.VideoInfoDao;
import com.newvideo.domain.DetailSystem;
import com.newvideo.domain.HotSearch;
import com.newvideo.domain.SearchHistory;
import com.newvideo.domain.SuperHotSearch;
import com.newvideo.domain.UserInfo;
import com.newvideo.domain.VideoInfo;
import com.newvideo.domain.web.DetailSystemSelect;
import com.newvideo.domain.web.HotSearchAdmin;
import com.newvideo.util.BaiduVideoUtil;
import com.newvideo.util.BanQuanUtil;
import com.newvideo.util.Constant;
import com.newvideo.util.SolrUtil;
import com.newvideo.util.StringUtil;

@Service
public class SearchService {
	@Resource
	private SearchDao searchDao;
	@Resource
	private ClassService classService;
	@Resource
	private VideoInfoDao videoInfoDao;
	@Resource
	private HotSearchDao hotSearchDao;
	@Resource
	private SuperHotSearchDao superHotSearchDao;
	@Resource
	private ConfigService configService;
	@Resource
	private VideoBanQuanVideoDao videoBanQuanVideoDao;
	@Resource
	private DetailSystemDao detailSystemDao;

	public VideoBanQuanVideoDao getVideoBanQuanVideoDao() {
		return videoBanQuanVideoDao;
	}

	public void setVideoBanQuanVideoDao(VideoBanQuanVideoDao videoBanQuanVideoDao) {
		this.videoBanQuanVideoDao = videoBanQuanVideoDao;
	}

	public ConfigService getConfigService() {
		return configService;
	}

	public void setConfigService(ConfigService configService) {
		this.configService = configService;
	}

	public SuperHotSearchDao getSuperHotSearchDao() {
		return superHotSearchDao;
	}

	public void setSuperHotSearchDao(SuperHotSearchDao superHotSearchDao) {
		this.superHotSearchDao = superHotSearchDao;
	}

	public HotSearchDao getHotSearchDao() {
		return hotSearchDao;
	}

	public void setHotSearchDao(HotSearchDao hotSearchDao) {
		this.hotSearchDao = hotSearchDao;
	}

	public VideoInfoDao getVideoInfoDao() {
		return videoInfoDao;
	}

	public void setVideoInfoDao(VideoInfoDao videoInfoDao) {
		this.videoInfoDao = videoInfoDao;
	}

	public ClassService getClassService() {
		return classService;
	}

	public void setClassService(ClassService classService) {
		this.classService = classService;
	}

	public SearchDao getSearchDao() {
		return searchDao;
	}

	public void setSearchDao(SearchDao searchDao) {
		this.searchDao = searchDao;
	}

	@SuppressWarnings("rawtypes")
	@Cacheable(value = "userCache", key = "'suggestSearch'+'-'+#key+'-'+#system")
	public List<String> suggestSearch(String key, String system) {
		if (StringUtil.isNullOrEmpty(key) || key.startsWith("%"))
			return new ArrayList<String>();

		List<String> list;
		Session session = null;
		if (key != null && key.length() > 10)
			key = key.substring(0, 10);
		String sql = "";
		if (system.equalsIgnoreCase("1")) {
			sql = "select name as result from wk_video_video where name like ?";
		}

		list = new ArrayList<String>();

		List li = null;
		try {
			li = videoInfoDao.sqlList(sql,
					new String[] { (new StringBuilder(String.valueOf(key))).append("%").toString() });
		} catch (Exception e) {

		}
		if (li != null) {
			for (int i = 0; i < li.size(); i++) {
				Object objs = (Object) li.get(i);
				list.add(objs.toString());
			}

		}

		Set<String> set = new TreeSet<String>();
		if (list != null) {
			String st;
			for (Iterator<String> iterator = list.iterator(); iterator.hasNext(); set.add(st))
				st = (String) iterator.next();

		}

		Iterator<String> it = set.iterator();
		list = new ArrayList<String>();
		while (it.hasNext()) {
			list.add(it.next());
			if (list.size() > 10)
				break;
		}

		return list;
	}

	@SuppressWarnings("unchecked")
	public List<Serializable> search(String ip, String uid, String key, int page, int type, int videoType,
			String system) {

		SearchHistory sh = new SearchHistory();
		sh.setCreatetime((new StringBuilder(String.valueOf(System.currentTimeMillis()))).toString());
		sh.setIp(ip);
		sh.setKey(key);
		UserInfo user = new UserInfo();
		user.setId(uid);
		sh.setUser(user);
		searchDao.create(sh);
		// 查询数据库
		String videoTypeList[] = classService.getChildrenType(videoType);
		String typewhere = "";
		if (system.equalsIgnoreCase("2")) {
			typewhere = " v.videoType.id=105 or v.videoType.id=106 or v.videoType.id=107 or v.videoType.id=108 ";
		} else if (videoType > 0) {
			for (int i = 0; i < videoTypeList.length; i++)
				typewhere = (new StringBuilder(String.valueOf(typewhere))).append(" or v.videoType.id=")
						.append(videoTypeList[i]).toString();

			if (typewhere.startsWith(" or"))
				typewhere = typewhere.substring(3, typewhere.length());
		}

		String sql;
		if (!StringUtil.isNullOrEmpty(typewhere))// 改为sql
			sql = (new StringBuilder("from VideoInfo v where v.show='1' and (v.name like ?) and (")).append(typewhere)
					.append(") order by REPLACE(v.name,?,'') ,v.watchCount desc").toString();
		else
			sql = "from VideoInfo v where v.show='1' and (v.name like ?) order by REPLACE(v.name,?,''),v.watchCount desc";// 改为sql
		List<Serializable> list = new ArrayList<Serializable>();
		BaiduVideoUtil util = new BaiduVideoUtil();
		List<VideoInfo> localList = videoInfoDao.list(sql, (page - 1) * Constant.pageCount, Constant.pageCount,
				new String[] { (new StringBuilder("")).append(key).append("%").toString(), key });
		if (localList != null && localList.size() > 0) {
			for (VideoInfo info : localList) {
				list.add(info);
			}
		}

		// 查询数据库结束

		if (system.equalsIgnoreCase("1"))
			if (page == 1)
				try {
					List<VideoInfo> fromNet = util.searchVideo(key);
					if (fromNet != null && fromNet.size() > 0) {
						for (int i = 0; i < fromNet.size(); i++)
							if (videoType == 0)
								list.add((VideoInfo) fromNet.get(i));
							else if (((VideoInfo) fromNet.get(i)).getVideoType().getId() == (long) videoType)
								list.add((VideoInfo) fromNet.get(i));

					}
				} catch (UnsupportedEncodingException e) {
					e.printStackTrace();
				}

		final List<Serializable> newList = list;
		list = (List<Serializable>) searchDao.excute(new HibernateCallback<List<Serializable>>() {
			public List<Serializable> doInHibernate(Session session) throws HibernateException {
				return BanQuanUtil.filterShowVideo(newList, session);
			}
		});
		return list;
	}

	@SuppressWarnings("unchecked")
	@Cacheable(value = "userCache", key = "'search'+'-'+#detailSystem+'-'+#key+'-'+#page+'-'+#contentType+'-'+#system+'-'+#cacheMD5")
	public List<VideoInfo> search(String detailSystem, String ip, String uid, String key, int page, int contentType,
			String system, List<Long> resourceList, String cacheMD5) {
		String resourceWhere = "";
		for (Long re : resourceList) {
			resourceWhere += " rv.resourceid=" + re + " or";
		}

		if (resourceWhere.endsWith("or"))
			resourceWhere = resourceWhere.substring(0, resourceWhere.length() - 2);

		SearchHistory sh = new SearchHistory();
		sh.setCreatetime((new StringBuilder(String.valueOf(System.currentTimeMillis()))).toString());
		sh.setIp(ip);
		if (!StringUtil.isNullOrEmpty(key) && key.length() > 30)
			key = key.substring(0, 30);
		sh.setKey(key);
		UserInfo user = new UserInfo();
		user.setId(uid);
		sh.setUser(user);

		searchDao.create(sh);
		// 查询数据库

		List<VideoInfo> list = new ArrayList<VideoInfo>();
		List<VideoInfo> localList = null;
		try {
			// localList = session0
			// .createQuery(sql)
			// .setParameter(
			// 0,
			// (new StringBuilder("")).append(key).append("%")
			// .toString()).setParameter(1, key)
			// .setFirstResult((page - 1) * Constant.pageCount)
			// .setMaxResults(Constant.pageCount).list();
			long startt = System.currentTimeMillis();
			localList = null;

			if (contentType == 0)
				localList = SolrUtil.search(key, page);
			else if (contentType == 1)
				localList = SolrUtil.searchZhengPian(key, page);
			else
				localList = SolrUtil.searchZhuanJi(key, page);
			System.out.println("搜索耗时:" + (System.currentTimeMillis() - startt));

			String sql = "";
			startt = System.currentTimeMillis();
			for (int i = 0; i < localList.size(); i++) {
				sql += " select count(*) from wk_resource_video rv left join wk_video_video v on rv.videoid=v.id where v.id is not null and v.show=1 and rv.videoid="
						+ localList.get(i).getId() + " and (" + resourceWhere + ") union all";
			}

			if (sql.endsWith("union all"))
				sql = sql.substring(0, sql.length() - 9);

			List rlist = videoInfoDao.sqlList(sql);
			List<Integer> pList = new ArrayList<Integer>();
			for (int i = 0; i < localList.size(); i++) {
				if (Integer.parseInt(rlist.get(i) + "") < 1) {
					pList.add(i);
					// localList.remove(i);
					// i--;
				}
			}

			Collections.sort(pList);
			for (int i = pList.size() - 1; i >= 0; i--) {
				localList.remove((int) pList.get(i));
			}

			System.out.println("排除耗时:" + (System.currentTimeMillis() - startt));

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
		}
		if (localList != null && localList.size() > 0) {
			for (VideoInfo info : localList) {
				list.add(info);
			}
		}

		// 查询数据库结束
		// //Session session = HibernateSessionFactory.getSession();
		// try {
		//
		// // 暂时不用版权数据库
		// // list = BanQuanUtil.filterShowVideo(detailSystem, list, session);
		//
		//
		//
		//
		// } catch (Exception e) {
		// e.printStackTrace();
		// } finally {
		// // session.close();
		// }
		return list;
	}

	public long searchCount(String key, String system) {
		String sql = "";
		if (system.equalsIgnoreCase("2")) {
			sql = "select count(*)  from VideoInfo v where v.show='1' and (v.name like ?) and (v.videoType.id=105 or v.videoType.id=106 or v.videoType.id=107 or v.videoType.id=108))";
		} else {
			sql = "select count(*)  from VideoInfo v where v.show='1' and (v.name like ?)";
		}

		long count = videoInfoDao.getCount(sql,
				new String[] { (new StringBuilder("")).append(key).append("%").toString() });
		return count;
	}

	@SuppressWarnings({ "rawtypes" })
	@Cacheable(value = "userCache", key = "'getHotSearchList'+'-'+#system")
	public List<String> getHotSearchList(String system) {
		List<String> list = new ArrayList<String>();
		try {
			List li = searchDao.sqlList(
					"SELECT h.`name` FROM wk_video_super_hotsearch sh LEFT JOIN wk_video_hotsearch h ON sh.`hotsearchid`=h.`id`  WHERE sh.`detailsystem`=? ORDER BY h.`orderby` DESC",
					0, Constant.HOT_SEARCH_COUNT, new Serializable[] { system });
			for (int i = 0; i < li.size(); i++) {
				list.add(li.get(i) + "");
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {

		}
		return list;
	}

	public List<HotSearch> getHotSearchListByDS(String dsid) {
		return hotSearchDao.list("from HotSearch hs where hs.system.id=" + dsid + " order by hs.orderby desc");
	}

	public List<HotSearch> getHotSearchList() {
		return hotSearchDao.list("from HotSearch");
	}

	/**
	 * 热门搜索
	 */

	public void addSuperHotSearch(SuperHotSearch sv) {
		List<SuperHotSearch> list = superHotSearchDao.list("from SuperHotSearch sv where sv.hotSearch.id="
				+ sv.getHotSearch().getId() + " and sv.detailSystem.id=" + sv.getDetailSystem().getId());
		if (list != null && list.size() > 0)
			return;
		superHotSearchDao.create(sv);
	}

	public void updateSuperHotSearch(SuperHotSearch hotSearch) {
		superHotSearchDao.update(hotSearch);
	}

	public void deleteSuperHotSearch(SuperHotSearch hotSearch) {
		superHotSearchDao.delete(hotSearch);
	}

	@SuppressWarnings("unchecked")
	public void updateSuperHotSearchList(final String detailSystemId, final List<SuperHotSearch> typeList) {
		searchDao.excute(new HibernateCallback() {
			public Object doInHibernate(Session session) throws HibernateException {
				try {
					List<SuperHotSearch> list = session
							.createQuery("from SuperHotSearch sh where sh.detailSystem.id=" + detailSystemId).list();
					session.getTransaction().begin();
					for (SuperHotSearch ad : list) {
						session.delete(ad);
					}

					for (SuperHotSearch videoType : typeList) {
						session.persist(videoType);
					}
					session.flush();
					session.getTransaction().commit();
				} catch (Exception e) {
					e.printStackTrace();
					session.getTransaction().rollback();
				}

				return null;
			}
		});

	}

	@SuppressWarnings("unchecked")
	public List<HotSearchAdmin> getHotSearchAdmin(String key, int detailSystem, int page) {
		List<HotSearchAdmin> zhiBoClassList = new ArrayList<HotSearchAdmin>();
		try {
			List<DetailSystem> detailSystemList = detailSystemDao.list("from DetailSystem");
			String sql = "";
			if (detailSystem > 0)
				sql = "select sh.hotSearch from SuperHotSearch sh where sh.hotSearch.name like ? and sh.detailSystem.id="
						+ detailSystem + " order by  sh.createtime desc";
			else
				sql = "from HotSearch zb where zb.name like ? order by zb.createtime desc";

			List<HotSearch> list = hotSearchDao.list(sql, (page - 1) * Constant.pageCount, Constant.pageCount,
					new Serializable[] { "%" + key + "%" });
			for (HotSearch vb : list) {
				List<DetailSystem> detailSystemS = detailSystemDao
						.list("select vb.detailSystem from SuperHotSearch vb where vb.hotSearch.id=" + vb.getId());

				List<DetailSystemSelect> dssList = new ArrayList<DetailSystemSelect>();

				for (DetailSystem ds : detailSystemList) {
					DetailSystemSelect dss = new DetailSystemSelect();
					dss.setDetailSystem(ds);
					dss.setSelected(false);
					dssList.add(dss);
				}

				// 设置已经存在的
				for (DetailSystem ds : detailSystemS) {
					for (DetailSystemSelect dss : dssList) {
						if (dss.getDetailSystem().getId().equalsIgnoreCase(ds.getId())) {
							dss.setSelected(true);
							break;
						}
					}
				}
				SuperHotSearch sz = new SuperHotSearch();
				sz.setDetailSystem(null);
				sz.setHotSearch(vb);
				zhiBoClassList.add(new HotSearchAdmin(sz, dssList));
			}

		} catch (Exception e) {
			e.printStackTrace();
		}
		return zhiBoClassList;
	}

	public long getHotSearchAdminCount(String key, int detailSystem) {
		String sql = "";
		if (detailSystem > 0)
			sql = "select count(*) from  (select count(*) from wk_video_super_hotsearch zb left join wk_video_hotsearch c on c.id=zb.hotsearchid where zb.detailsystem="
					+ detailSystem + " and c.name like '%" + key + "%' group by zb.hotsearchid) s";
		else
			sql = "select count(*) from  (select count(*) from wk_video_super_hotsearch zb left join wk_video_hotsearch c on c.id=zb.hotsearchid where  c.name like '%"
					+ key + "%' group by zb.hotsearchid) s";

		return videoBanQuanVideoDao.getCountSQL(sql);
	}

	/**
	 * 添加热门搜索
	 * 
	 * @param search
	 */
	public void addHotSearch(HotSearch search) {
		hotSearchDao.create(search);
	}

	/**
	 * 修改热门搜索
	 * 
	 * @param search
	 */
	public void updateHotSearch(HotSearch search) {

		hotSearchDao.update(search);
	}

	/**
	 * 删除热门搜索
	 * 
	 * @param search
	 */
	@SuppressWarnings({ "unchecked", "rawtypes" })
	public void deleteHotSearch(final HotSearch search) {
		searchDao.excute(new HibernateCallback() {
			public Object doInHibernate(Session session) throws HibernateException {
				try {
					session.getTransaction().begin();
					List<SuperHotSearch> list = session.createQuery("from SuperHotSearch sv where sv.hotSearch.id=?")
							.setParameter(0, search.getId()).list();
					for (SuperHotSearch sv : list)
						session.delete(sv);
					session.createSQLQuery("delete from wk_video_hotsearch  where id=" + search.getId())
							.executeUpdate();
					session.flush();
					session.getTransaction().commit();
				} catch (Exception e) {
					e.printStackTrace();
					session.getTransaction().rollback();
				}
				return null;
			}
		});

	}

	/**
	 * 获取热门搜索
	 * 
	 * @param id
	 * @return
	 */
	public HotSearch getHotSearch(String id) {
		List<HotSearch> list = hotSearchDao.getSession().createQuery("from HotSearch where id=?").setParameter(0, id)
				.list();
		if (list != null && list.size() > 0) {
			return list.get(0);
		}
		return null;
	}

	@SuppressWarnings("unchecked")
	public void deleteHotSearchAdmin(final String classId, final String detailSystemId) {
		searchDao.excute(new HibernateCallback() {
			public Object doInHibernate(Session session) throws HibernateException {
				try {

					List<SuperHotSearch> list = session
							.createQuery("from SuperHotSearch vb where vb.hotSearch.id=? and vb.detailSystem.id=?")
							.setParameter(0, classId).setParameter(1, detailSystemId).list();
					if (list != null && list.size() > 0) {
						session.getTransaction().begin();
						for (SuperHotSearch vb : list)
							session.delete(vb);
						session.flush();
						session.getTransaction().commit();
					}

				} catch (Exception e) {
					e.printStackTrace();
				}
				return null;
			}
		});

	}

}