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

import java.awt.image.BufferedImage;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.imageio.ImageIO;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.poi.util.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.stereotype.Service;

import com.alibaba.fastjson.JSON;
import com.qxueyou.scc.base.model.Pager;
import com.qxueyou.scc.base.model.Result;
import com.qxueyou.scc.base.service.impl.CommonAppService;
import com.qxueyou.scc.base.util.ClientUtils;
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.config.AliOssConfig;
import com.qxueyou.scc.school.model.SchStudyReport;
import com.qxueyou.scc.school.service.IStudyReportService;
import com.qxueyou.scc.school.util.StudyReportUtils;
//import com.qxueyou.scc.sys.service.IOssService;
import com.qxueyou.scc.user.model.User;
import com.qxueyou.scc.user.model.UserRegistration;

/**
 * 学习报告查询及生成接口，如果存在，则直接查询，否则根据各类数据生成
 * @author xiadehu
 *
 */
@Service("StudyReportService")
@EnableConfigurationProperties(AliOssConfig.class)
public class StudyReportService extends CommonAppService implements
		IStudyReportService {
//	@Autowired
//	ICacheService cache;
//	
//	@Autowired
//	IOssService oss;
	
	@Autowired
	AliOssConfig aliOssConfig;
	
	private static final Logger log = LogManager.getLogger("StudyReportService");

	@Override
	public Result doGetOrCreateStudyReport() {

		String hql = "from SchStudyReport where userId=? and deleteFlag is false";

		SchStudyReport report = findUnique(hql,
				CollectionUtils.newList(ClientUtils.getUserId()),
				SchStudyReport.class);

		if (report == null) {
			report = createReport();
		}

		return new Result(true, null, toMapByReport(report));
	}

	/**
	 * 创建新的学习报告
	 * 汇聚各类数据
	 * 
	 * @return
	 */
	private SchStudyReport createReport() {

		SchStudyReport report = new SchStudyReport();
		TraceUtils.setCreateTrace(report);

		User user = read(User.class, ClientUtils.getUserId());

		report.setUserId(user.getUserId());
		report.setName(user.getName());
		report.setStudentOrder(getStudyOrder(user.getCreateTime()));
		report.setStudyPeriod(getStudyPeriod(user.getCreateTime()));
		report.setCourseCount(getCourseCount(user.getUserId()));
		setFirstCourseAndClass(report);
		report.setStudyHandoutCount(getStudyHandoutCount(user.getUserId()));
		report.setStudyVideoCount(getStudyVideoCount(user.getUserId()));
		report.setViewLiveCount(getViewLiveCount(user.getUserId()));
		setExerciseData(report);
		setAtsData(report);
		setOrgs(report);
		setRecCourses(report);
		setStudyTime(report);
		
		save(report);

		return report;
	}
	

	private int getStudyPeriod(Date createTime) {
		Calendar cal = Calendar.getInstance();    
        cal.setTime(createTime);
        long time1 = cal.getTimeInMillis();   
        long between_days=(System.currentTimeMillis()-time1)/(1000*3600*24);  
        return Integer.parseInt(String.valueOf(between_days));
	}

	/**
	 * 统计出用户集中学习的时间段，选取排名靠前的三个时间段(每个时间段1小时)进行显示
	 * @param report
	 */
	private void setStudyTime(SchStudyReport report) {
		
		List<Map<String, Object>> result = queryStudyTime();
		
		//从0点到23点，统计每个时间段学习的次数
		int[] hours = new int[24];
		
		int h=0;
		int num = 0;
		int count = 0;
		for(Map<String,Object> item:result){
			h = (Integer)item.get("h");
			num = ((Long)item.get("num")).intValue();
			hours[h]=hours[h]+num;
			count = count + num;
		}
		
		//计算出前三
		int[][] most3 = new int[][]{{0,0},{0,0},{0,0}};
		
		for(int i=0;i<24;i++){
			for(int j=0;j<3;j++){
				if(hours[i]>most3[j][0]){
					most3[j][0]=hours[i];
					most3[j][1]=i;
					break;
				}
			}
		}
		
		
		List<Map<String,Object>> data = new ArrayList<Map<String,Object>>();
		
		//返回前三（非零）的数据
		for(int j=0;j<3;j++){
			if(most3[j][0]>0){
				data.add(CollectionUtils.newObjectMap(
						"name",getTimeAlias(most3[j][1]),
						"timeFrom",most3[j][1],
						"timeTo",most3[j][1]+1,
						"percent",String.format("%.1f%%",(double)most3[j][0]/count*100)));
			}
		}
		
		report.setStudyTime(JSON.toJSONString(data));
		report.setStudyTimeImg(createImg(data));
	}

	private String createImg(List<Map<String, Object>> data) {
		ByteArrayOutputStream os=null;
		InputStream is=null;
		try {
			BufferedImage img = StudyReportUtils.drawPng(180, 180, data);
			os = new ByteArrayOutputStream();  
			ImageIO.write(img, "png", os);
			is = new ByteArrayInputStream(os.toByteArray());
			String destPath = "/web/res/img/studyreport/"+ClientUtils.getUserId()+"/"+UUIDUtils.generateUUID()+".png";
//			oss.uplpadImage(is, "PNG", destPath);
			return destPath;
		} catch (IOException e) {
			log.error(e,e);
		}  finally{
			IOUtils.closeQuietly(is);
			IOUtils.closeQuietly(os);			
		}
		return null;
	}

	/**
	 * 查询练习、讲义、视频学习的时间统计数据
	 * @return
	 */
	private List<Map<String, Object>> queryStudyTime() {
		String hql1 = " select hour(createTime) as h,count(1) as num from ExerciseItemAnalisiU where userId=:userId group by hour(createTime) ";
		String hql2 = " select hour(createTime) as h,count(1) as num from MediaVideoLiveRecord where userId=:userId group by hour(createTime) ";
		String hql3 = " select hour(createTime) as h,count(1) as num from MediaVideoRecord where userId=:userId group by hour(createTime) ";
		
		List<Map<String,Object>> r1 = findListWithMapByHql(hql1, CollectionUtils.newObjectMap("userId",ClientUtils.getUserId()));
		List<Map<String,Object>> r2 = findListWithMapByHql(hql2, CollectionUtils.newObjectMap("userId",ClientUtils.getUserId()));
		List<Map<String,Object>> r3 = findListWithMapByHql(hql3, CollectionUtils.newObjectMap("userId",ClientUtils.getUserId()));
		r1.addAll(r2);
		r1.addAll(r3);
		return r1;
	}
	
	private String getTimeAlias(int hour){
		if(hour<3){
			return "深夜";
		}
		if(hour<6){
			return "凌晨";
		}
		if(hour<12){
			return "早上";
		}
		if(hour<14){
			return "中午";
		}
		if(hour<18){
			return "下午";
		}
		if(hour<24){
			return "晚上";
		}
		return null;
	}

	private void setRecCourses(SchStudyReport report) {
		
		String hql = " select cls.orgId from UserRegistration reg,ClsClass cls where reg.userId=? and reg.status=? and reg.deleteFlag is false " +
				" and reg.classId=cls.classId order by reg.activationTime desc";
		
		String orgId = findUnique(hql, CollectionUtils.newList(
				ClientUtils.getUserId(),UserRegistration.STATUS_ACTIVE),
				String.class);
		
		hql = " select code from Organization where organizationId=?";
		
		String code = findUnique(hql, CollectionUtils.newList(
				orgId),
				String.class);
		
		hql = "select org.logoPath as imgPath,cls.name as name, org.name as orgName,concat('/transact/class/view/',cls.classId) as clickUrl from ClsClass cls,Organization org "+ 
				"where cls.deleteFlag is false and cls.recommend is true and cls.orgId=:orgId and org.organizationId=cls.orgId " +
				"order by cls.studentCount desc,cls.clickNum desc";	
		
		List<Map<String,Object>> data = findListWithMapByHql(hql, 
				CollectionUtils.newObjectMap(
						"orgId",orgId),new Pager(3,1));
		
		report.setRecCourses(JSON.toJSONString(data));
		report.setMoreRecUrl("/weixin/qxueyou/redirect?orgCode="+code+"&routerUrl=/course/market");
	}

	private void setOrgs(SchStudyReport report) {
		String hql = " select distinct org.name as name,org.logoPath as logoUrl from UserRegistration reg,ClsClass cls,Organization org " +
				"where reg.classId=cls.classId and cls.orgId=org.organizationId " +
				"and reg.userId=:userId and reg.deleteFlag is false and reg.status=:status";
		
		List<Map<String,Object>> data = findListWithMapByHql(hql, 
				CollectionUtils.newObjectMap(
						"userId",ClientUtils.getUserId(),
						"status",UserRegistration.STATUS_ACTIVE),new Pager(10,1));
		
		report.setOrgs(JSON.toJSONString(data));
	}

	/**
	 * 设置传播大使数据
	 * @param report
	 */
	@SuppressWarnings("unchecked")
	private void setAtsData(SchStudyReport report) {
		String hql = "select className from AtsShare where userId=? and deleteFlag is false order by shareTime";

		String className = findUnique(hql, CollectionUtils.newList(
				ClientUtils.getUserId()),
				String.class);
		report.setFirstShareCourse(className);
		
		hql = "select sum(viewCount) as c from AtsShare where userId=? and deleteFlag is false";

		BigDecimal count= findUnique(hql, CollectionUtils.newList(ClientUtils.getUserId()), BigDecimal.class);
		report.setViewCountOfShare(count==null?0:count.intValue());
		
		hql = "select allBalance from TransAccount where userId=? and deleteFlag is false and accountTypeId=4";

		BigDecimal allBalance= findUnique(hql, CollectionUtils.newList(ClientUtils.getUserId()), BigDecimal.class);
		report.setAwardAmountOfShare(allBalance);
		
		hql = "select count(1) from TransAccount where deleteFlag is false and accountTypeId=3";

		int accountTotal= ((Number) findUnique(hql, Collections.EMPTY_LIST, Number.class)).intValue();
		
		hql = "select his.rank from SchRankHis his,SchRankVer ver where his.versionId=ver.versionId and ver.rankType='ATS_SCORE' and his.userId=?";
		Number rankN = findUnique(hql, CollectionUtils.newList(ClientUtils.getUserId()), Number.class);
		int rank= rankN==null?0:rankN.intValue();
		report.setAtsOrder(BigDecimal.valueOf((double)(accountTotal-rank)/accountTotal));
	}

	private void setExerciseData(SchStudyReport report) {
		
		String hql = "select count(distinct exerciseItemId) as c,coalesce(avg(accuracy),0) as accuracy from ExerciseItemAnalisiU where userId=:userId and deleteFlag is false";

		List<Map<String,Object>> data = findListWithMapByHql(hql, CollectionUtils.newObjectMap("userId",ClientUtils.getUserId()));
		
		if(data.isEmpty()){
			report.setDoExerciseCount(0);
			report.setExerciseAccuracy(BigDecimal.ZERO);
			report.setAccuracyOrder(BigDecimal.valueOf(800000+(int)Math.random()*400000));
			return;
		}
		
		report.setDoExerciseCount(((Long)(data.get(0).get("c"))).intValue());
		report.setExerciseAccuracy(BigDecimal.valueOf((Double)data.get(0).get("accuracy")));
		
		hql = "select count(1) from SchStudyReport where exerciseAccuracy>? and deleteFlag is false";

		int order= findUnique(hql, CollectionUtils.newList(report.getExerciseAccuracy()), Number.class).intValue();
		report.setAccuracyOrder(BigDecimal.valueOf(order));
	}

	private int getViewLiveCount(String userId) {

		String hql = "select count(liveId) from MediaVideoLiveRecord where userId=? and deleteFlag is false";

		return findUnique(hql, CollectionUtils.newList(userId), Number.class).intValue();
	}

	private int getStudyVideoCount(String userId) {
		String hql = "select count(videoId) from MediaVideoRecord where userId=? and deleteFlag is false";

		return findUnique(hql, CollectionUtils.newList(userId), Number.class).intValue();
	}

	private int getStudyHandoutCount(String userId) {
		String hql = "select count(handoutId) from SchHandoutRecord where userId=? and deleteFlag is false";

		return findUnique(hql, CollectionUtils.newList(userId), Number.class).intValue();
	}

	private int getCourseCount(String userId) {

		String hql = "select count(classId) from UserRegistration where userId=? and deleteFlag is false and status=?";

		return findUnique(
				hql,
				CollectionUtils.newList(userId, UserRegistration.STATUS_ACTIVE),
				Number.class).intValue();

	}

	private void setFirstCourseAndClass(SchStudyReport report) {

		String hql = "select classId from UserRegistration where userId=? and deleteFlag is false and status=? order by activationTime";

		String classId = findUnique(hql, CollectionUtils.newList(
				ClientUtils.getUserId(), UserRegistration.STATUS_ACTIVE),
				String.class);

		hql = "select coalesce(cls.name,'') as className,coalesce(cls.collegeCourseName,'') as courseName from ClsClass cls " +
				"where cls.classId=:classId and cls.deleteFlag is false";

		List<Map<String,Object>> cou = findListWithMapByHql(hql, CollectionUtils.newObjectMap("classId",classId));
		
		if(cou==null||cou.isEmpty()){
			return;
		}

		report.setFirstClass((String)cou.get(0).get("className"));
		report.setFirstCourse((String)cou.get(0).get("courseName"));

	}

	private int getStudyOrder(Date createTime) {

		String hql = "select count(1) from User where createTime<? and deleteFlag is false";

		return findUnique(hql, CollectionUtils.newList(createTime),
				Number.class).intValue();

	}

	/**
	 * 将report转换为返回机构数据结果
	 * 
	 * @param report
	 * @return
	 */
	private Map<String, Object> toMapByReport(SchStudyReport report) {
		String resDomain = aliOssConfig.getDomain();
		
		Map<String,Object> result = new HashMap<String,Object>();
		result.put("resDomain", resDomain);
		result.put("name", report.getName());
		result.put("studentOrder", report.getStudentOrder());
		result.put("studyPeriod", report.getStudyPeriod());
		result.put("courseCount", report.getCourseCount());
		result.put("firstCourse", report.getFirstCourse());
		result.put("firstClass", report.getFirstClass());
		result.put("studyHandoutCount", report.getStudyHandoutCount());
		result.put("studyVideoCount", report.getStudyVideoCount());
		result.put("viewLiveCount", report.getViewLiveCount());
		result.put("doExerciseCount", report.getDoExerciseCount());
		result.put("exerciseAccuracy", report.getExerciseAccuracy());
		result.put("accuracyOrder", report.getAccuracyOrder());
		result.put("firstShareCourse", report.getFirstShareCourse());
		result.put("viewCountOfShare", report.getViewCountOfShare());
		result.put("awardAmountOfShare", report.getAwardAmountOfShare());
		result.put("atsOrder", report.getAtsOrder());
		result.put("studyTime", JSON.parse(report.getStudyTime()));
		result.put("setStudyTimeImg",report.getStudyTimeImg());
		result.put("orgs", JSON.parse(report.getOrgs()));
		result.put("recCourses", JSON.parse(report.getRecCourses()));
		result.put("moreRecUrl", report.getMoreRecUrl());
		result.put("atsWithAwardCount", getatsWithAwardCount());
		
		return result;
	}

	private Integer getatsWithAwardCount() {
		
//		Long atsWithAwardCount = cache.get("school/studyReport/atsWithAwardCount", Long.class);
//		if(atsWithAwardCount!=null){
//			return atsWithAwardCount.intValue();
//		}
		
		String hql = "select count(1) from TransAccount where userId=? and allBalance>0 and deleteFlag is false and accountTypeId=4";

		Number c= findUnique(hql, CollectionUtils.newList(ClientUtils.getUserId()), BigDecimal.class);
//		cache.set("school/studyReport/atsWithAwardCount",3600*3, c);
		
		return c.intValue();
	}

}