package com.qxueyou.scc.school.service.impl;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
import java.util.List;

import javax.annotation.PostConstruct;

import org.apache.commons.lang3.StringUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

//import com.aliyun.openservices.ons.api.ConsumeContext;
//import com.aliyun.openservices.ons.api.Message;
import com.qxueyou.scc.base.dao.CommonDAO;
import com.qxueyou.scc.base.model.Pager;
import com.qxueyou.scc.base.service.IONSExceptionLogService;
//import com.qxueyou.scc.base.service.IONSMsgDealService;
//import com.qxueyou.scc.base.service.impl.CommonONSConsumer;
import com.qxueyou.scc.base.util.CollectionUtils;
import com.qxueyou.scc.base.util.TraceUtils;
//import com.qxueyou.scc.base.util.UUIDUtils;
import com.qxueyou.scc.school.model.SchRank;
import com.qxueyou.scc.school.model.SchRankHis;
import com.qxueyou.scc.school.model.SchRankVer;

@Service("RankMsgDealService")
public class RankMsgDealService{
//public class RankMsgDealService implements IONSMsgDealService {
	
	@Autowired
	CommonDAO dao;
	
//	@Autowired
//	ICacheService cache;
	
	@Autowired
	IONSExceptionLogService onsExceptionLogService;
	

	
	@SuppressWarnings("unused")
	private static Logger log = LogManager.getLogger("ONSExceptionLogService");
	
	/**
	 * 排名更新时间,默认60秒
	 */
	@SuppressWarnings("unused")
	private int updateRankMinutes = 60;
	
	@PostConstruct
	void init() {
		
//		CommonONSConsumer.registerHandler("SCH_RANK", "RankMsgDealService");
		
//		updateRankMinutes = Integer.parseInt(cfg.getConfigByEnv("ons-rank-update-minutes"));
	}

//	@Override
//	public void doHandle(Message msg, ConsumeContext context) {
//		
//		try {
//			
//			String userId = msg.getUserProperties("userId");
//			String rankType = msg.getUserProperties("rankType");
//			String scopeType = msg.getUserProperties("scopeType");
//			String scopeId = msg.getUserProperties("scopeId");
//			
//			// 判断哪些需要更新排名
//			List<SchRank> rankLst = getRankLstNeedUpdate(userId,rankType,scopeType,scopeId);
//			
//			// 如果有，则更新排名
//			updateRankLst(rankLst);
//			
//		}catch(Exception e){
//			
//			String businessId = cfg.getConfigByEnv("ons-common-topic") + "-" + UUIDUtils.generateUUID();
//			String desp = "userId:" + msg.getUserProperties("userId")+ 
//					";rankType:" + msg.getUserProperties("rankType") +
//					";scopeType:" + msg.getUserProperties("scopeType") + 
//					";scopeId:" + msg.getUserProperties("scopeId") ;
//
//			log.error( businessId + " :排名消息发送失败:" + e , e);
//			onsExceptionLogService.logSaveExceptionLog(cfg.getConfigByEnv("ons-common-topic"), "SCH_RANK", businessId , desp );
//		}
//		
//		
//	}

	/**
	 * 更新排名
	 * 
	 * @param rankLst
	 */
	@SuppressWarnings("unused")
	private void updateRankLst(List<SchRank> rankLst) {

		for (SchRank rank : rankLst) {
			updateRank(rank);
		}

	}

	/**
	 * 更新排名
	 * 
	 * @param rank
	 */
	private void updateRank(SchRank rank) {

		// 查询所有待排名实时数据列表
		List<SchRank> rankLst = querySchRankLstByRank(rank);

		// 按value排序
		Collections.sort(rankLst, new Comparator<SchRank>() {
			@Override
			public int compare(SchRank r1, SchRank r2) {
				if(r1.getValue()==null){
					return -1;
				}
				if(r2.getValue()==null){
					return 1;
				}
				return r2.getValue().compareTo(r1.getValue());
			}
		});

		// 新建版本记录
		SchRankVer version = insertRankVersion(rank);

		// 插入rank_his数据
		saveRankHisData(version, rankLst);

		// 插入缓存记录，标记本次更新排名时间
		updateUpdateTime(rank);

	}

	/**
	 * 插入缓存记录，标记本次更新排名时间
	 * 
	 * @param rank
	 */
	private void updateUpdateTime(SchRank rank) {
//		cache.set(getCacheIdFromRank(rank), 60 * updateRankMinutes, 1);
	}

	/**
	 * 获取cacheId
	 * 
	 * @param rank
	 * @return
	 */
	@SuppressWarnings("unused")
	private String getCacheIdFromRank(SchRank rank) {
		return rank.getScopeType()
				.concat(rank.getScopeId() != null ? rank.getScopeId() : "")
				.concat(rank.getRankType());
	}

	/**
	 * 创建新的版本记录
	 * 
	 * @param rank
	 * @return
	 */
	private SchRankVer insertRankVersion(SchRank rank) {

		// 更新旧的最新版本
		String hql = "from SchRankVer where rankType=? and scopeId=? and scopeType=? and latest is true order by version desc";
		List<SchRankVer> oldLastestVerLst = dao.find(hql, CollectionUtils.newList(
				rank.getRankType(), rank.getScopeId(), rank.getScopeType()),
				SchRankVer.class);

		SchRankVer lastestVer = oldLastestVerLst.isEmpty()?null:oldLastestVerLst.get(0);
		
		for(SchRankVer oldVer:oldLastestVerLst){
			TraceUtils.setUpdateTrace(oldVer);
			oldVer.setLatest(false);
			dao.saveOrUpdate(oldVer);
		}

		// 创建新的版本
		SchRankVer ver = new SchRankVer();

		TraceUtils.setCreateTrace(ver);
		ver.setDeleteFlag(false);

		ver.setLatest(true);
		ver.setRankType(rank.getRankType());
		ver.setScopeId(rank.getScopeId());
		ver.setScopeType(rank.getScopeType());
		ver.setVersion(lastestVer == null ? 1
				: lastestVer.getVersion() + 1);
		ver.setVersionTime(new Date());

		dao.saveOrUpdate(ver);

		return ver;
	}

	/**
	 * 根据任何一条排名数据查询所有待排名实时数据列表
	 * 
	 * @param rank
	 * @return
	 */
	private List<SchRank> querySchRankLstByRank(SchRank rank) {
		Pager page = new Pager();
		page.setPageNum(1);
		page.setPageSize(200);
		String hql = "from SchRank where rankType=? and scopeId=? and scopeType=? order by value desc";
		List<SchRank> lstSchRank = dao.findList(hql, page, CollectionUtils.newList(
				rank.getRankType(), rank.getScopeId(), rank.getScopeType()),
				SchRank.class);

		return lstSchRank;
	}

	/**
	 * 判断哪些需要更新排名
	 * 
	 * @param userId
	 * @return
	 */
	@SuppressWarnings("unused")
	private List<SchRank> getRankLstNeedUpdate(String userId,String rankType,String scopeType,String scopeId) {

		StringBuffer sb = new StringBuffer("from SchRank where userId=? and rankType = ? and scopeType = ? ");
		// 参数集合
		List<Object> args = CollectionUtils.newList(userId,rankType,scopeType);
		
		if(!SchRank.SCOPE_TYPE_QXUEYOU.equals(scopeType) 
				&& StringUtils.isNotBlank(scopeId)){// qxueyou排名 不需要
			sb.append(" and scopeId = ?");
			args.add(scopeId);
		}
		
		List<SchRank> lstSchRank = dao.find(sb.toString(), args, SchRank.class);

		List<SchRank> result = new ArrayList<SchRank>(5);
		
		String cacheId = null;

//		for (SchRank rank : lstSchRank) {
//			cacheId = getCacheIdFromRank(rank);
//			if (cache.get(cacheId, Integer.class) == null) {
//				result.add(rank);
//			}
//		}

		return result;
	}

	/**
	 * 插入rank_his数据
	 * 
	 * @param version
	 * @param rankLst
	 */
	private void saveRankHisData(SchRankVer version, List<SchRank> rankLst) {

		List<SchRankHis> hisLst = new ArrayList<SchRankHis>(rankLst.size());

		int i = 1;
		Date now = new Date();
		SchRankHis his = null;

		for (SchRank rank : rankLst) {

			// Q学友只处理前一百名
			if (i > 100
					&& SchRank.SCOPE_TYPE_QXUEYOU.equals(rank.getScopeType())) {
				break;
			}

			his = new SchRankHis();

			TraceUtils.setCreateTrace(his);
			his.setDeleteFlag(false);

			his.setRank(i++);
			his.setRankId(rank.getRankId());
			his.setRankTime(now);
			his.setUserId(rank.getUserId());
			his.setValue(rank.getValue());
			his.setVersionId(version.getVersionId());

			hisLst.add(his);
		}

		dao.saveOrUpdateAll(hisLst);
	}
	
}