package com.yeshi.fanli.service.impl.user;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.springframework.orm.hibernate4.HibernateCallback;
import org.springframework.stereotype.Service;

import com.yeshi.fanli.dao.user.HistorySearchDao;
import com.yeshi.fanli.entity.admin.HistorySearchAdmin;
import com.yeshi.fanli.entity.bus.search.HistorySearch;
import com.yeshi.fanli.service.inter.user.HistorySearchService;
import com.yeshi.fanli.util.TimeUtil;
import com.yeshi.fanli.util.Utils;

@Service
public class HistorySearchServiceImpl implements HistorySearchService {
	
	@Resource
	private HistorySearchDao historySearchDao;
	
	public void addHistorySearch(String searchKey, String bid) {
		HistorySearch historySearch = new HistorySearch();
		historySearch.setName(searchKey);
		historySearch.setBusinessId(bid);
		historySearch.setCreatetime(new Date());
		historySearch.setState(0);
		historySearchDao.create(historySearch);
	}

	public List<HistorySearch> getHistorySearch(String bid) {
		
		List list = historySearchDao.list("select hs,MAX(hs.id) as maxid from HistorySearch hs where hs.state=0 and hs.businessId=? GROUP BY hs.name order by maxid desc ",0,10,new String[]{bid});
		List<HistorySearch> hlist= new ArrayList<HistorySearch>();
		for(int i = 0 ; i <list.size() ;i++ ){
			hlist.add((HistorySearch)((Object[])list.get(i))[0]);
		}
		return hlist;
		
	}

	public int clearHistorySearch(final String bid) {
		return (Integer) historySearchDao.excute(new HibernateCallback() {
			public Object doInHibernate(Session session)
					throws HibernateException {
				int count;
				try {
					session.getTransaction().begin();
					Query query = session.createQuery("update HistorySearch hs set hs.state=1 where businessId=?");
					query.setString(0, bid);
					count = query.executeUpdate();
					session.getTransaction().commit();
					return count;
				} catch (Exception e) {
					e.printStackTrace();
					session.getTransaction().rollback();
				}
				return 0;
			}
		});
	}

	@SuppressWarnings("unchecked")
	public Map<String, Integer> getSearchTotalByDate(int days, Date date) {

		final Map<String, Integer> map =new HashMap<String, Integer>();
		long timestampms = date.getTime();
		final List<String> list = TimeUtil.getEmupDate(days,timestampms);
		for (String dataStr : list) {
			map.put(dataStr, 0);
		}
		return (Map<String, Integer>) historySearchDao.excute(new HibernateCallback<Map<String, Integer>>() {

			public Map<String, Integer> doInHibernate(Session session)
					throws HibernateException {
				StringBuffer sb = new StringBuffer();
				int ii=0;
				for (String day : list) {
					if(ii==0){
						sb.append("SELECT '"+day+"' AS t,IFNULL(SUM(a.s),0) FROM yeshi_ec_history_search_day a WHERE a.c<= '"+day+"' ");
					}else{
						sb.append("UNION ALL SELECT '"+day+"' AS t,IFNULL(SUM(a.s),0) FROM yeshi_ec_history_search_day a WHERE a.c<= '"+day+"' ");
					}
					ii++;
				}
				
				SQLQuery sqlQuery = session.createSQLQuery(sb.toString());
				List<Object[]> list = sqlQuery.list();
				for (Object[] objArr : list) {
						map.put(String.valueOf(objArr[0]),((BigDecimal)objArr[1]).intValue());
				}
				return map;
			}
		});
	}

	@SuppressWarnings("unchecked")
	public Map<String, Integer> getSearchTotalByMonth(int months, Date date) {
		 final List<String> monthList = Utils.getDateMonthList(months,date);
		 final Map<String, Integer> map =new HashMap<String, Integer>();
		 for (String monthStr : monthList) {
			 map.put(monthStr, 0);
		}
		 return (Map<String, Integer>) historySearchDao.excute(new HibernateCallback<Map<String, Integer>>() {

				public Map<String, Integer> doInHibernate(Session session)
						throws HibernateException {
					
					StringBuffer sb = new StringBuffer();
					int ii=0;
					for (String month : monthList) {
						if(ii==0){
							sb.append("SELECT '"+month+"' AS t,IFNULL(SUM(a.s),0) FROM yeshi_ec_history_search_month a WHERE a.months<= '"+month+"' ");
						}else{
							sb.append("UNION ALL SELECT '"+month+"' AS t,IFNULL(SUM(a.s),0) FROM yeshi_ec_history_search_month a WHERE a.months<= '"+month+"' ");
						}
						ii++;
					}
					
					SQLQuery sqlQuery = session.createSQLQuery(sb.toString());
					List<Object[]> list = sqlQuery.list();
					for (Object[] objArr : list) {
							map.put((String) objArr[0],((BigDecimal)objArr[1]).intValue());
					}
					return map;
				}
			});
	}

	@SuppressWarnings("unchecked")
	public List<HistorySearchAdmin> getSearchRankByDate(final int days, final Date date) {
		
	return	(List<HistorySearchAdmin>) historySearchDao.excute(new HibernateCallback<List<HistorySearchAdmin>>() {

			public List<HistorySearchAdmin> doInHibernate(Session session)
					throws HibernateException {
				
				SQLQuery query = session.createSQLQuery("SELECT `name`,COUNT(`name`) `sum` FROM yeshi_ec_history_search WHERE createtime >= DATE_SUB(?,INTERVAL ? DAY) AND createtime < ? GROUP BY `name` ORDER BY `sum` DESC LIMIT 0,20");
				query.setParameter(0, date);
				query.setParameter(1, days);
				query.setParameter(2, date);
				List<HistorySearchAdmin> list = query.list();
				return list;
			}
		});
	}

}