package com.newvideo.service.imp;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

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.AdStatisticsDao;
import com.newvideo.dao.CommonAdDao;
import com.newvideo.dao.CommonAdPositionAdDao;
import com.newvideo.dao.CommonAdPositionDao;
import com.newvideo.dao.CommonAdStatisticsDao;
import com.newvideo.dao.MineAdDao;
import com.newvideo.dao.RecommendAdDao;
import com.newvideo.dao.SuperRecommendAdDao;
import com.newvideo.dao.WXAdDao;
import com.newvideo.dao.WXStatisticsDao;
import com.newvideo.domain.DetailSystem;
import com.newvideo.domain.RecommendAd;
import com.newvideo.domain.SuperRecommendAd;
import com.newvideo.domain.SystemInfo;
import com.newvideo.domain.WXAd;
import com.newvideo.domain.WXStatistics;
import com.newvideo.domain.ad.AdStatistics;
import com.newvideo.domain.ad.CommonAd;
import com.newvideo.domain.ad.CommonAdPosition;
import com.newvideo.domain.ad.CommonAdPositionAd;
import com.newvideo.domain.ad.CommonAdStatistics;
import com.newvideo.domain.ad.MineAd;
import com.newvideo.domain.web.DetailSystemSelect;
import com.newvideo.domain.web.RecommendAdAdmin;
import com.newvideo.util.Constant;

@Service
public class AdService {
	@Resource
	private RecommendAdDao recommendAdDao;
	@Resource
	private MineAdDao mineAdDao;
	@Resource
	private AdStatisticsDao adStatisticsDao;
	@Resource
	private WXAdDao wxAdDao;
	@Resource
	private WXStatisticsDao wxStatisticsDao;
	@Resource
	private SuperRecommendAdDao superRecommendAdDao;
	@Resource
	private CommonAdPositionAdDao commonAdPositionAdDao;
	@Resource
	private CommonAdStatisticsDao commonAdStatisticsDao;
	@Resource
	private CommonAdDao commonAdDao;

	@Resource
	private CommonAdPositionDao commonAdPositionDao;

	public CommonAdDao getCommonAdDao() {
		return commonAdDao;
	}

	public void setCommonAdDao(CommonAdDao commonAdDao) {
		this.commonAdDao = commonAdDao;
	}

	public CommonAdStatisticsDao getCommonAdStatisticsDao() {
		return commonAdStatisticsDao;
	}

	public void setCommonAdStatisticsDao(CommonAdStatisticsDao commonAdStatisticsDao) {
		this.commonAdStatisticsDao = commonAdStatisticsDao;
	}

	public CommonAdPositionAdDao getCommonAdPositionAdDao() {
		return commonAdPositionAdDao;
	}

	public void setCommonAdPositionAdDao(CommonAdPositionAdDao commonAdPositionAdDao) {
		this.commonAdPositionAdDao = commonAdPositionAdDao;
	}

	public SuperRecommendAdDao getSuperRecommendAdDao() {
		return superRecommendAdDao;
	}

	public void setSuperRecommendAdDao(SuperRecommendAdDao superRecommendAdDao) {
		this.superRecommendAdDao = superRecommendAdDao;
	}

	public WXStatisticsDao getWxStatisticsDao() {
		return wxStatisticsDao;
	}

	public void setWxStatisticsDao(WXStatisticsDao wxStatisticsDao) {
		this.wxStatisticsDao = wxStatisticsDao;
	}

	public WXAdDao getWxAdDao() {
		return wxAdDao;
	}

	public void setWxAdDao(WXAdDao wxAdDao) {
		this.wxAdDao = wxAdDao;
	}

	public AdStatisticsDao getAdStatisticsDao() {
		return adStatisticsDao;
	}

	public void setAdStatisticsDao(AdStatisticsDao adStatisticsDao) {
		this.adStatisticsDao = adStatisticsDao;
	}

	public MineAdDao getMineAdDao() {
		return mineAdDao;
	}

	public void setMineAdDao(MineAdDao mineAdDao) {
		this.mineAdDao = mineAdDao;
	}

	public RecommendAdDao getRecommendAdDao() {
		return recommendAdDao;
	}

	public void setRecommendAdDao(RecommendAdDao recommendAdDao) {
		this.recommendAdDao = recommendAdDao;
	}

	// 获取广告
	public List<RecommendAd> getRecommendAdList() {

		return recommendAdDao.list("from RecommendAd");
	}

	public List<RecommendAd> getRecommendAdList(int type) {

		return recommendAdDao.list("from RecommendAd a where a.platform=3 or a.platform=" + type);
	}

	public RecommendAd getAdById(String id) {

		return recommendAdDao.find(RecommendAd.class, id);
	}

	public void updateRecommendAd(RecommendAd ad) {

		recommendAdDao.update(ad);
	}

	public void addRecommendAd(RecommendAd ad) {
		recommendAdDao.create(ad);
	}

	@SuppressWarnings("unchecked")
	public void deleteRecommendAd(final String id) {
		recommendAdDao.excute(new HibernateCallback() {
			public Object doInHibernate(Session session) throws HibernateException {
				try {
					session.getTransaction().begin();
					List<SuperRecommendAd> list = session
							.createQuery("from SuperRecommendAd sv where sv.recommendAd.id=?").setParameter(0, id)
							.list();
					for (SuperRecommendAd sv : list)
						session.delete(sv);
					session.delete(new RecommendAd(id));
					session.flush();
					session.getTransaction().commit();
				} catch (Exception e) {
					session.getTransaction().rollback();
				}
				return null;
			}
		});

	}

	public List<MineAd> getMineAdList(String key) {
		return mineAdDao.list(
				"from MineAd ma where ma.open=1 and ma.adKey.key=? order by ma.first desc,ma.percent desc",
				new String[] { key });
	}

	/**
	 * 后台操作
	 */

	@SuppressWarnings("unchecked")
	public List<RecommendAdAdmin> getRecommendAdAdmin(final String key, final int detailSystem, final int page) {
		return (List<RecommendAdAdmin>) recommendAdDao.excute(new HibernateCallback<List<RecommendAdAdmin>>() {
			public List<RecommendAdAdmin> doInHibernate(Session session) throws HibernateException {
				List<RecommendAdAdmin> zhiBoClassList = new ArrayList<RecommendAdAdmin>();
				try {
					List<DetailSystem> detailSystemList = session.createQuery("from DetailSystem").list();
					String sql = "";
					if (detailSystem > 0)
						sql = "select sh.recommendAd from SuperRecommendAd sh where  sh.detailSystem.id=" + detailSystem
								+ " order by  sh.recommendAd.createtime desc";
					else
						sql = "from RecommendAd zb order by zb.createtime desc";

					List<RecommendAd> list = session.createQuery(sql).setFirstResult((page - 1) * Constant.pageCount)
							.setMaxResults(Constant.pageCount).list();
					for (RecommendAd vb : list) {
						List<DetailSystem> detailSystemS = session
								.createQuery(
										"select vb.detailSystem from SuperRecommendAd vb where vb.recommendAd.id=?")
								.setParameter(0, vb.getId()).list();

						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;
								}
							}
						}
						SuperRecommendAd sz = new SuperRecommendAd();
						sz.setDetailSystem(null);
						sz.setRecommendAd(vb);
						zhiBoClassList.add(new RecommendAdAdmin(sz, dssList));
					}

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

	}

	public long getRecommendAdAdminCount(String key, int detailSystem) {
		String sql = "";
		if (detailSystem > 0)
			sql = "select count(*) from  (select count(*) from wk_video_super_recommendad zb left join wk_ad_recommend c on c.id=zb.recommendadid where zb.detailsystem="
					+ detailSystem + " group by zb.recommendadid) s";
		else
			sql = "select count(*) from  (select count(*) from wk_video_super_recommendad zb left join wk_ad_recommend c on c.id=zb.recommendadid  group by zb.recommendadid) s";

		return recommendAdDao.getCountSQL(sql);
	}

	@SuppressWarnings("rawtypes")
	public void addRecommendAdAdmin(final String classid, final String detailSystemId) {
		recommendAdDao.excute(new HibernateCallback() {
			public Object doInHibernate(Session session) throws HibernateException {
				try {
					session.getTransaction().begin();
					List list = session
							.createQuery("from SuperRecommendAd vb where vb.recommendAd.id=? and vb.detailSystem.id=?")
							.setParameter(0, classid).setParameter(1, detailSystemId).list();
					if (list == null || list.size() == 0) {
						SuperRecommendAd vb = new SuperRecommendAd();
						vb.setCreatetime(System.currentTimeMillis() + "");
						vb.setDetailSystem(new DetailSystem(detailSystemId));
						vb.setRecommendAd(new RecommendAd(classid));
						session.persist(vb);
					}
					session.flush();
					session.getTransaction().commit();

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

	}

	@SuppressWarnings({ "unchecked", "rawtypes" })
	public void deleteRecommendAdAdmin(final String classId, final String detailSystemId) {
		recommendAdDao.excute(new HibernateCallback() {
			public Object doInHibernate(Session session) throws HibernateException {
				try {
					session.getTransaction().begin();
					List<SuperRecommendAd> list = session
							.createQuery("from SuperRecommendAd vb where vb.recommendAd.id=? and vb.detailSystem.id=?")
							.setParameter(0, classId).setParameter(1, detailSystemId).list();
					if (list != null && list.size() > 0) {
						for (SuperRecommendAd vb : list)
							session.delete(vb);
					}
					session.flush();
					session.getTransaction().commit();
				} catch (Exception e) {
					e.printStackTrace();
					session.getTransaction().rollback();
				}
				return null;
			}
		});

	}

	public void AddStatistics(String key, String platform, int type) {
		AdStatistics ad = new AdStatistics();
		ad.setKey(key);
		ad.setPlatformId(platform);
		ad.setTime(System.currentTimeMillis() + "");
		ad.setType(type);
		adStatisticsDao.create(ad);
	}

	/**
	 * 获取微信广告
	 * 
	 * @return
	 */
	public List<WXAd> getWinAd(SystemInfo system) {
		List<WXAd> list = wxAdDao.list("from WXAd w where w.system.id=" + system.getId());
		return list;
	}

	public List<WXAd> getWinAd() {
		List<WXAd> list = wxAdDao.list("from WXAd");
		return list;
	}

	/**
	 * 添加微信广告
	 * 
	 * @param ad
	 */
	public void addWX(WXAd ad) {
		wxAdDao.create(ad);
	}

	public void deleteWX(WXAd ad) {
		wxAdDao.delete(ad);
	}

	public WXAd getWXAd(Serializable id) {
		return wxAdDao.find(WXAd.class, id);
	}

	public void updateWXAd(WXAd ad) {
		wxAdDao.update(ad);
	}

	/**
	 * 插入微信统计代码
	 * 
	 * @param bean
	 */
	public void insertWXStatistics(WXStatistics bean) {
		wxStatisticsDao.create(bean);
	}

	/**
	 * 推荐广告条
	 */
	@Cacheable(value = "homeCache",key="'getRecommendAdList'+'-'+#detailSystem")
	public List<RecommendAd> getRecommendAdList(String detailSystem) {
		return recommendAdDao
				.list("select hs.recommendAd FROM SuperRecommendAd hs where hs.detailSystem.id=" + detailSystem);
	}

	public void addRecommendAd(SuperRecommendAd sv) {
		List<SuperRecommendAd> list = superRecommendAdDao.list("from SuperRecommendAd sv where sv.recommendAd.id="
				+ sv.getRecommendAd().getId() + " and sv.detailSystem.id=" + sv.getDetailSystem().getId());
		if (list != null && list.size() > 0)
			return;
		superRecommendAdDao.create(sv);
	}

	public void updateSuperRecommendAd(SuperRecommendAd hotSearch) {
		superRecommendAdDao.update(hotSearch);
	}

	public void deleteSuperRecommendAd(SuperRecommendAd hotSearch) {
		superRecommendAdDao.delete(hotSearch);
	}

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

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

	}

	@Cacheable(value = "classCache",key="'getCommonAdByPid'+'-'+#pid")
	public List<CommonAdPositionAd> getCommonAdByPid(String pid) {
		return commonAdPositionAdDao.list("from CommonAdPositionAd pa where pa.adPosition.id=?",
				new Serializable[] { pid + "" });
	}

	// 添加广告统计
	public void addCommonAdStatistics(int type, String pid, String commonAdid, String device) {
		CommonAdStatistics cas = new CommonAdStatistics();
		cas.setCommonAd(new CommonAd(commonAdid));
		cas.setCreatetime(System.currentTimeMillis() + "");
		cas.setType(type);
		cas.setPositionid(pid);
		cas.setDevice(device);
		commonAdStatisticsDao.create(cas);
	}

	public List<CommonAdPosition> getCommonAdPositionList() {
		return (List<CommonAdPosition>) commonAdPositionDao.list("from CommonAdPosition");
	}

	public List<CommonAdPositionAd> getCommonAdPositionAd(String key, int pid, int pageIndex) {
		List<CommonAdPositionAd> adList = new ArrayList<CommonAdPositionAd>();
		adList = commonAdPositionAdDao.list("from CommonAdPositionAd ca where ca.adPosition.id=" + pid + "",
				(pageIndex - 1) * Constant.pageCount, Constant.pageCount, null);

		for (CommonAdPositionAd ad : adList) {
			ad.setCommonAdPositionList(commonAdPositionDao
					.list("select pa.adPosition from CommonAdPositionAd pa where pa.ad.id=" + ad.getAd().getId()));

		}
		return adList;
	}

	public long getCommonAdPositionAdCount(String key, int pid) {
		return commonAdPositionAdDao
				.getCount("select count(*) from CommonAdPositionAd ca where ca.adPosition.id=" + pid + "");
	}

	public Serializable addCommonAd(CommonAd commonAd) {
		return commonAdDao.save(commonAd);
	}

	public void addCommonAdPositionAd(CommonAdPositionAd commonAdPositionAd) {
		commonAdPositionAdDao.create(commonAdPositionAd);
	}

	public CommonAd getCommonAdById(String id) {
		return commonAdDao.find(CommonAd.class, id);
	}

	// 更新
	public void updateCommonAd(CommonAd commonAd) {
		commonAdDao.update(commonAd);
	}

	@SuppressWarnings({ "unchecked", "rawtypes" })
	public void deleteCommonAd(final CommonAd ca) {
		recommendAdDao.excute(new HibernateCallback() {
			public Object doInHibernate(Session session) throws HibernateException {
				try {
					session.getTransaction().begin();
					List<CommonAdPositionAd> list = session
							.createQuery("from CommonAdPositionAd cp where cp.ad.id=" + ca.getId()).list();
					for (CommonAdPositionAd cp : list) {
						session.delete(cp);
					}
					session.delete(ca);
					session.flush();
					session.getTransaction().commit();
				} catch (Exception e) {
					if (session.getTransaction().isActive())
						session.getTransaction().rollback();
				}
				return null;
			}
		});

	}

	public void deleteCommonAdPositionAd(CommonAdPositionAd ad) {
		commonAdPositionAdDao.delete(ad);
	}

	public void deleteCommonAdPositionAd(String adid, String pid) {
		List<CommonAdPositionAd> list = commonAdPositionAdDao
				.list("from CommonAdPositionAd ca where ca.ad.id=" + adid + " and ca.adPosition.id=" + pid);
		for (CommonAdPositionAd ca : list)
			deleteCommonAdPositionAd(ca);
	}

}