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

import java.io.Serializable;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.Calendar;
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.cache.annotation.Cacheable;
import org.springframework.orm.hibernate4.HibernateCallback;
import org.springframework.stereotype.Service;

import com.yeshi.fanli.dao.user.ScanHistoryDao;
import com.yeshi.fanli.entity.admin.ScanHistoryAdmin;
import com.yeshi.fanli.entity.system.System;
import com.yeshi.fanli.entity.taobao.PidUser;
import com.yeshi.fanli.entity.taobao.ScanHistory;
import com.yeshi.fanli.entity.taobao.SearchFilter;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;
import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult;
import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig;
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
import com.yeshi.fanli.service.inter.user.ScanHistoryService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.TimeUtil;
import com.yeshi.fanli.util.Utils;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;

@Service
public class ScanHistoryServiceImpl implements ScanHistoryService {

	@Resource
	private ScanHistoryDao scanHistoryDao;

	@Resource
	private HongBaoManageService hongBaoManageService;

	@Resource
	private TaoBaoUnionConfigService taoBaoUnionConfigService;

	public void addScanHistory(ScanHistory scanHistory) {
		scanHistoryDao.create(scanHistory);
	}

	public List<ScanHistory> getScanHistory(long systemid, String device, int page, int count, long uid) {
		List list = scanHistoryDao.list(
				"select sh , MAX(sh.id) as maxid from ScanHistory sh where ((sh.system.id=? and sh.device=?) or (sh.uid = ?)) and sh.state=0 GROUP BY sh.auctionId order by maxid desc ",
				(page - 1) * count, count, new Serializable[] { systemid, device, uid });
		List<ScanHistory> shList = new ArrayList<ScanHistory>();
		for (int i = 0; i < list.size(); i++) {
			shList.add((ScanHistory) ((Object[]) list.get(i))[0]);
		}
		return shList;
	}

	public long getScanHistoryCount(long systemid, String device, long uid) {
		return scanHistoryDao.getCountSQL(
				"select count(b.a) from (select sh.auctionId a from yeshi_ec_scanhistory sh where ((sh.systemid=? and sh.device=?) or sh.uid = ? ) and sh.state=0 GROUP BY sh.auctionId) b ",
				new Serializable[] { systemid, device, uid });
	}

	public List<ScanHistory> getScanHistoryByUid(int index, long uid) {

		int start = index * Constant.PAGE_SIZE;
		List<ScanHistory> list = scanHistoryDao.list("from ScanHistory sh where sh.uid=? order by sh.id desc ", start,
				Constant.PAGE_SIZE, new Serializable[] { uid });

		return list;
	}

	public int getCountByUid(long uid) {

		Long lcount = scanHistoryDao.getCount("select count(sh.uid) from ScanHistory sh where sh.uid=?",
				new Serializable[] { uid });

		return lcount.intValue();
	}

	public long getScanHistory(long startTime, long endTime) {

		Date start = new Date(startTime);
		Date end = new Date(endTime);

		return scanHistoryDao.getCount(
				"select count(sh.id) from ScanHistory sh where sh.createtime >= ? and sh.createtime < ? ",
				new Serializable[] { start, end });

	}

	@SuppressWarnings("unchecked")
	public List<ScanHistoryAdmin> getTop(final long startTime, final long endTime, final int topSum) {

		final Date start = new Date(startTime);
		final Date end = new Date(endTime);
		return (List<ScanHistoryAdmin>) scanHistoryDao.excute(new HibernateCallback<List<ScanHistoryAdmin>>() {

			public List<ScanHistoryAdmin> doInHibernate(Session session) throws HibernateException {
				Query query = session.createQuery(
						"SELECT sh.title,count(sh.id) as counts from ScanHistory sh where sh.createtime >= ? and sh.createtime < ? GROUP BY  sh.auctionId ORDER BY counts desc");
				query.setParameter(0, start);
				query.setParameter(1, end);
				query.setFirstResult(0);
				query.setMaxResults(topSum);
				List<ScanHistoryAdmin> list = query.list();
				return list;
			}
		});

	}

	@SuppressWarnings("unchecked")
	public Map<String, Integer> getDataCountByDate(final int day) {
		final Map<String, Integer> map = new HashMap<String, Integer>();
		List<String> list = TimeUtil.getEmupDate(day);
		for (String dataStr : list) {
			map.put(dataStr, 0);
		}
		return (Map<String, Integer>) scanHistoryDao.excute(new HibernateCallback<Map<String, Integer>>() {

			public Map<String, Integer> doInHibernate(Session session) throws HibernateException {
				SQLQuery sqlQuery = session.createSQLQuery(
						"SELECT createtime,COUNT(*) FROM yeshi_ec_scanhistory WHERE DATE_SUB(CURDATE(), INTERVAL ? DAY) <= DATE(createtime) GROUP BY createtime");
				sqlQuery.setParameter(0, day);
				List<Object[]> list = sqlQuery.list();
				for (Object[] objArr : list) {
					map.put(TimeUtil.getSimpleDate((Date) objArr[0]), ((BigInteger) objArr[1]).intValue());
				}
				return map;
			}
		});
	}

	@SuppressWarnings("unchecked")
	public Map<String, Integer> getDataCountByDate(final int day, final String endtime) {
		long stamp = TimeUtil.convertDateToTemp(endtime);
		final Map<String, Integer> map = new HashMap<String, Integer>();
		List<String> list = TimeUtil.getEmupDate(day, stamp);
		for (String dataStr : list) {
			map.put(dataStr, 0);
		}
		return (Map<String, Integer>) scanHistoryDao.excute(new HibernateCallback<Map<String, Integer>>() {

			public Map<String, Integer> doInHibernate(Session session) throws HibernateException {
				SQLQuery sqlQuery = session.createSQLQuery(
						"SELECT createtime,COUNT(*) FROM yeshi_ec_scanhistory WHERE DATE_SUB(?, INTERVAL ? DAY) <= DATE(createtime) AND DATE(createtime) <= ? GROUP BY createtime");
				sqlQuery.setParameter(0, endtime);
				sqlQuery.setParameter(1, day);
				sqlQuery.setParameter(2, endtime);
				List<Object[]> list = sqlQuery.list();
				for (Object[] objArr : list) {
					map.put(TimeUtil.getSimpleDate((Date) objArr[0]), ((BigInteger) objArr[1]).intValue());
				}
				return map;
			}
		});
	}

	@SuppressWarnings("unchecked")
	public Map<String, Integer> getDataCountByMonth(final int cmonth, final Date endDate) {
		// SELECT *,DATE_FORMAT(createtime,'%Y-%m') months FROM
		// yeshi_ec_scanhistory WHERE createtime BETWEEN DATE_SUB(NOW(),INTERVAL
		// 6 MONTH) AND NOW() GROUP BY months;
		List<String> monthList = Utils.getDateMonthList(cmonth, endDate);
		final Map<String, Integer> map = new HashMap<String, Integer>();
		for (String monthStr : monthList) {
			map.put(monthStr, 0);
		}
		return (Map<String, Integer>) scanHistoryDao.excute(new HibernateCallback<Map<String, Integer>>() {

			public Map<String, Integer> doInHibernate(Session session) throws HibernateException {
				Calendar calendar = Calendar.getInstance();
				calendar.setTime(endDate);
				calendar.set(Calendar.MONTH, calendar.get(Calendar.MONTH) + 1);
				calendar.set(Calendar.DAY_OF_MONTH, 1);
				String curTime = TimeUtil.getSimpleDate(calendar.getTime());
				SQLQuery sqlQuery = session.createSQLQuery(
						"SELECT DATE_FORMAT(createtime,'%Y-%m') months,count(*) FROM yeshi_ec_scanhistory WHERE createtime >= DATE_SUB(?,INTERVAL ? MONTH) AND createtime < ? GROUP BY months");
				sqlQuery.setParameter(0, curTime);
				sqlQuery.setParameter(1, cmonth);
				sqlQuery.setParameter(2, curTime);
				List<Object[]> list = sqlQuery.list();
				for (Object[] objArr : list) {
					map.put((String) objArr[0], ((BigInteger) objArr[1]).intValue());
				}
				return map;
			}
		});
	}

	@Cacheable(value="crgCache")
	@SuppressWarnings("unchecked")
	public List<TaoBaoGoodsBriefExtra> getHotTaoBaoGoodsBriefExtras(final String key, final int pageIndex) {
		final List<TaoBaoUnionConfig> config = taoBaoUnionConfigService
				.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);
		return (List<TaoBaoGoodsBriefExtra>) scanHistoryDao
				.excute(new HibernateCallback<List<TaoBaoGoodsBriefExtra>>() {

					public List<TaoBaoGoodsBriefExtra> doInHibernate(Session session) throws HibernateException {
						SearchFilter filter = new SearchFilter();
						filter.setKey(key);
						filter.setPage(pageIndex);
						filter.setSort(TaoBaoUtil.SORT_SALE_HIGH_TO_LOW);
						filter.setType(0);
						TaoBaoSearchResult result = TaoBaoUtil.search2(filter, config.get(0));
						List<TaoBaoGoodsBrief> taoBaoGoodsBriefs = result.getTaoBaoGoodsBriefs();
						List<TaoBaoGoodsBriefExtra> tbbeList = new ArrayList<TaoBaoGoodsBriefExtra>();
						TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra;
						BigDecimal  rate = hongBaoManageService.getFanLiRate();
						for (TaoBaoGoodsBrief taoBaoGoodsBrief : taoBaoGoodsBriefs) {
							taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, rate.toString(), "");
							tbbeList.add(taoBaoGoodsBriefExtra);
						}
						return tbbeList;
					}
				});

	}

	public void deleteScanHistory(final String device, final System sys, final long uid) {
		scanHistoryDao.excute(new HibernateCallback() {

			public Object doInHibernate(Session session) throws HibernateException {
				try {
					session.getTransaction().begin();
					Query query = session.createQuery(
							"update ScanHistory sh set sh.state=1 where ((sh.device = ? and sh.system.id = ? ) or sh.uid = ? ) ");
					query.setParameter(0, device);
					query.setParameter(1, sys.getId());
					query.setParameter(2, uid);
					query.executeUpdate();
					session.getTransaction().commit();
				} catch (Exception e) {
					e.printStackTrace();
					session.getTransaction().rollback();
				}

				return null;
			}
		});
	}

	public void deleteScanHistory(final String device, final System sys, final long auctionId, final long uid) {
		scanHistoryDao.excute(new HibernateCallback() {

			public Object doInHibernate(Session session) throws HibernateException {
				try {
					session.getTransaction().begin();
					Query query = session.createQuery(
							"update ScanHistory sh set sh.state=1 where ((sh.device = ? and sh.system.id = ? ) or sh.uid = ? ) and sh.auctionId = ? ");
					query.setParameter(0, device);
					query.setParameter(1, sys.getId());
					query.setParameter(2, uid);
					query.setParameter(3, auctionId);
					query.executeUpdate();
					session.getTransaction().commit();
				} catch (Exception e) {
					e.printStackTrace();
					session.getTransaction().rollback();
				}

				return null;
			}
		});
	}

}