package com.qxueyou.scc.teach.live.service.impl;

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 com.qxueyou.scc.sdk.MTCloud;
import io.swagger.models.auth.In;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import com.qxueyou.scc.admin.teacher.service.ITeacherService;
import com.qxueyou.scc.base.model.Pager;
import com.qxueyou.scc.base.model.Result;
import com.qxueyou.scc.base.service.ICacheService;
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.SccConfig;
import com.qxueyou.scc.msg.model.MsgInfo;
import com.qxueyou.scc.msg.service.IMsgInfoService;
import com.qxueyou.scc.teach.live.dao.MediaLiveDAO;
import com.qxueyou.scc.teach.live.model.MediaVideoLive;
import com.qxueyou.scc.teach.live.model.MediaVideoLiveReClass;
import com.qxueyou.scc.teach.live.service.IMediaLiveService;
import com.qxueyou.scc.teach.subject.model.Subject;
import com.qxueyou.scc.user.model.UserTeacher;

@Service
public class MediaLiveService extends CommonAppService implements IMediaLiveService {
	
	@Autowired
	MediaLiveDAO liveDao;
	
	@Autowired
	SccConfig cfg;
	
	@Autowired
	IMsgInfoService msgInfoService;
	
	@Autowired
	ICacheService cacheService;
	
	@Autowired
	private ITeacherService teacherService;
	
	
	@Override
	public Result add(String name, String content, String teacherId, String teacherName , String subjectId, String subjectName,
					  String definition, String imgPath, Date startTime, Date endTime, Integer courseId, boolean record, List<String> classIds,String portalStatus) {
		
		UserTeacher teacher = teacherService.getTeacherByUserId(ClientUtils.getUserId());
		
		MediaVideoLive live = new MediaVideoLive();
		TraceUtils.setCreateTrace(live);

		live.setCourseId(courseId);
		live.setName(name);
		live.setRemark(content);
		live.setPreviewImgUrl(imgPath);
		live.setStartTime(startTime);
		live.setEndTime(endTime);
		live.setPortalStatus(portalStatus);
		live.setStatus(MediaVideoLive.STATUS_LIVE_DRAFT);
		
		if(teacher!=null){
			live.setAnchorId(teacher.getTeacherId());
			live.setAnchor(teacher.getName());
		}else{
			live.setAnchorId(ClientUtils.getUserId());
			live.setAnchor(ClientUtils.getUserName());
		}
		
		live.setSubjectId(subjectId);
		live.setSubjectName(subjectName);
	
		String uuid = UUIDUtils.UUID();
		live.setWyLiveNumber(uuid);
		live.setPushUrl(cfg.getRtmpService().concat(uuid));
		live.setHlsPullUrl(cfg.getHlsService().concat(uuid).concat(".m3u8"));
		
		save(live);
		
		//保存直播权限班级
		if(classIds!=null && classIds.size()>0){
			this.doClearAndAddLiveReClass(live.getVideoLiveId(), classIds.toArray(new String[classIds.size()]));
		}
		
		return new Result(true,"",CollectionUtils.newObjectMap("videoLiveId",live.getVideoLiveId()));
	}

	@Override
	public Result update(String liveId, String name, String content,String teacherId,String teacherName , String subjectId,String subjectName,
			String definition,String imgPath, Date startTime, Date endTime,boolean record, List<String> classIds) {
		MediaVideoLive live = read(MediaVideoLive.class,liveId);
		TraceUtils.setUpdateTrace(live);
		
		live.setName(name);
		live.setRemark(content);
		live.setPreviewImgUrl(imgPath);
		live.setStartTime(startTime);
		live.setEndTime(endTime);
		live.setSubjectId(subjectId);
		live.setSubjectName(subjectName);
		
		save(live);
		
		//更新班级课程关联关系
		this.doClearAndAddLiveReClass(live.getVideoLiveId(), classIds!=null?classIds.toArray(new String[classIds.size()]):null);
		
		
//		liveDao.saveLiveClasses(liveId, classIds);
		
		return Result.SUCCESS;
	}
	
	/**
	 * 清理并添加直播权限班级
	 * @param liveId
	 * @param classIds
	 */
	private void doClearAndAddLiveReClass(String liveId, String [] classIds) {
		List<String>  reIdLst =  this.find("select r.liveReClassId from MediaVideoLiveReClass r where r.liveId=?",
					CollectionUtils.newList(liveId), String.class);

		//删除关联关系
		if(reIdLst!=null && reIdLst.size()>0){
			this.bulkUpdateInLoop("delete from MediaVideoLiveReClass  where liveReClassId=?", reIdLst.toArray());  
		}
		if(classIds!=null && classIds.length>0){
			for(String classId:classIds){
				MediaVideoLiveReClass re = new MediaVideoLiveReClass();
			    TraceUtils.setCreateTrace(re);
			    re.setClassId(classId);
			    re.setLiveId(liveId);
			    save(re);
			}
		}
	}	

	@Override
	public List<String> getLiveClasses(String liveId) {
		return this.find("select r.classId from MediaVideoLiveReClass r where r.liveId=? and r.deleteFlag is false",
				CollectionUtils.newList(liveId), String.class);
	}

	@Override
	public Result delete(String liveId) {
		MediaVideoLive live = read(MediaVideoLive.class,liveId);
		TraceUtils.setUpdateTrace(live);
		live.setDeleteFlag(true);
		save(live);
		return Result.SUCCESS;
	}

	@Override
	public Result delete(String[] liveIds,String [] courseIds) throws Exception {
		for(String liveId:liveIds) {
			delete(liveId);
			for(String courseId:courseIds) {
				MTCloud client = new MTCloud();
				String s = client.courseDelete(courseId);
			}
		}
		return Result.SUCCESS;
	}


	@Override
	public Result doIssue(String liveId) {
		status(liveId,MediaVideoLive.STATUS_LIVE_ORDER);
		doSendMsg(liveId,MsgInfo.TYPE_LIVE,"发布了直播");
		return new Result(true);
	}
	
	private void doSendMsg(String liveId,short type,String msg){
		MediaVideoLive  liveInfo = this.read(liveId);
		//查询直播关联的班级
		String hql = "select s.userId from MediaVideoLiveReClass m,StuStudent s where m.classId=s.classId and m.liveId=? and m.deleteFlag is false and s.deleteFlag is false";
		
		List<String> lstUserIds = this.find(hql, CollectionUtils.newList(liveId),String.class);
		
		if(lstUserIds!=null && lstUserIds.size()>0){
			Map<String,String> attrs = CollectionUtils.newStringMap("liveId",liveId,"liveName",liveInfo.getName(),"subjectId",liveInfo.getSubjectId(),
					"subjectName",liveInfo.getSubjectName(),"startTime",String.valueOf(liveInfo.getStartTime().getTime()));
				
			msgInfoService.doSendTextMsgToUsers(lstUserIds.toArray(new String[lstUserIds.size()]),type,msg,attrs);
		}
	}
	
	@Scheduled(cron = " 0 0/5 * * * ?")
	protected void doTimer() {
//		System.out.println("执行直播提醒定时器");
		Calendar cal = Calendar.getInstance();
		cal.add(Calendar.HOUR, 1);
		Date beginDate = cal.getTime();
		
		cal.add(Calendar.MINUTE, 5);
		Date endDate = cal.getTime();

		//查询1小时内将开始的直播
 		List<MediaVideoLive> lstLives = this.find("from MediaVideoLive where startTime>=? and startTime<? and status=? and deleteFlag is false ", 
 				CollectionUtils.newList(beginDate,endDate,MediaVideoLive.STATUS_LIVE_REVIEW), MediaVideoLive.class);
		
		if(lstLives!=null && lstLives.size()>0){
			for(MediaVideoLive live:lstLives){
				this.doLiveRemindMsg(live.getVideoLiveId(),MsgInfo.TYPE_REMIND, "直播马上开始了，请做好直播准备");
			}
		}
	}
	
	private void doLiveRemindMsg(String liveId,short type,String msg){
		MediaVideoLive  liveInfo = this.read(liveId);
		Map<String,String> attrs = CollectionUtils.newStringMap("liveId",liveId,
					"liveName",liveInfo.getName(),
					"remindType","live",
					"status",String.valueOf(liveInfo.getStatus()),
				    "subjectId",liveInfo.getSubjectId(),
					"subjectName",liveInfo.getSubjectName(),
					"startTime",String.valueOf(liveInfo.getStartTime().getTime()),
					"endTime",String.valueOf(liveInfo.getEndTime().getTime()));
				
		msgInfoService.doSendTextMsgToUsers(new String[]{liveInfo.getCreateId()},type,msg,attrs);
	}

	@Override
	public Result doCancel(String liveId) {
		return status(liveId,MediaVideoLive.STATUS_LIVE_DRAFT);
	}

	@Override
	public Result doStart(String liveId) {
		return status(liveId,MediaVideoLive.STATUS_LIVE_LIVE);
	}

	@Override
	public Result doPause(String liveId) {
		return status(liveId,MediaVideoLive.STATUS_LIVE_PAUSE);
	}

	@Override
	public Result doStop(String liveId) {
		//发送生成回放消息
		cacheService.lstRightPush(MediaVideoLivePlayBackService.LIVE_PLAYBACK_LST, liveId);
		
		return status(liveId,MediaVideoLive.STATUS_LIVE_DOWNLOAD);
		
	}
	
	private Result status(String liveId,short status) {
		MediaVideoLive live = read(MediaVideoLive.class,liveId);
		TraceUtils.setUpdateTrace(live);
		live.setStatus(status);
		save(live);
		return Result.SUCCESS;
	}

	@Override
	public Result doPraise(String liveId) {
		return this.bulkUpdate("update MediaVideoLive set praiseTimes = praiseTimes+1 where videoLiveId=?",new Object[]{liveId});
	}

	@Override
	public List<MediaVideoLive> list(String keyword, String [] classIds,String subjectId,Short status,Integer pageNum, Integer pageSize) {
		StringBuffer hql = new StringBuffer(1000);
		Map<String,Object> params = new HashMap<String,Object>();
		hql.append("from MediaVideoLive m left join fetch m.classes  c left join fetch m.subject s where m.deleteFlag is false  and m.name like :name ");
		
		params.put("name",keyword + "%");
		
		if(classIds!=null && classIds.length>0){
			hql.append(" and (c.classId in(:classIds) or s.type=:Type)");
			params.put("classIds", classIds);
			params.put("Type", Subject.TYPE_PUBLIC_SUBJECT);
		}else{
			hql.append(" and  s.type=:subjectType");
			params.put("subjectType", Subject.TYPE_PUBLIC_SUBJECT);
		}
		
		if(!StringUtils.isEmpty(subjectId)){
			 hql.append(" and m.subjectId=:subjectId");
			 params.put("subjectId", subjectId);
		}
		
		if(status!=null){
			hql.append(" and m.status=:status");
			params.put("status", status);
		}else{
			hql.append(" and m.status!=:status");
			params.put("status",MediaVideoLive.STATUS_LIVE_DRAFT);
		}
		
		hql.append(" order by m.createTime desc");
		
		return this.findByComplexHql(hql.toString(),new Pager(pageSize,pageNum),params,MediaVideoLive.class);
	}	
	
	@Override
	public int listCount(String keyword,String [] classIds,String subjectId,Short status) {
		StringBuffer hql = new StringBuffer(1000);
		Map<String,Object> params = new HashMap<String,Object>();
		hql.append("from MediaVideoLive m left join m.subject s where m.deleteFlag is false and m.name like :name ");
		params.put("name","%" + keyword + "%");
		
		if(!StringUtils.isEmpty(subjectId)){
			 hql.append(" and m.subjectId=:subjectId");
			 params.put("subjectId", subjectId);
		}
		
		if(status!=null){
			hql.append(" and m.status=:status");
			params.put("status", status);
		}else{
			hql.append(" and m.status!=:status");
			params.put("status",MediaVideoLive.STATUS_LIVE_DRAFT);
		}
		
		if(classIds!=null && classIds.length>0){
			 hql.append(" and ( exists (select 1 from MediaVideoLiveReClass r where r.deleteFlag is false and r.liveId= m.videoLiveId and r.classId in (:classIds) ) or s.type=:subjectType )");
			 params.put("classIds", classIds);
			 params.put("subjectType", Subject.TYPE_PUBLIC_SUBJECT);
		}else{
			 hql.append(" and  s.type=:subjectType ");
			 params.put("subjectType", Subject.TYPE_PUBLIC_SUBJECT);
		}
		
		return this.findCountByComplexHql(hql.toString(), params);
	}

	@Override
	public List<MediaVideoLive> listvideo(String status) {

		String hql = "from MediaVideoLive where deleteFlag is false and status=?  order by createTime desc";


		return find(hql, CollectionUtils.newList(status), MediaVideoLive.class);
	}

	@Override
	public List<MediaVideoLive> listOfMine(String keyword,String portalStatus, Integer pageNum, Integer pageSize) {
		
		String hql = "from MediaVideoLive where deleteFlag is false and name like ? and portalStatus = ? order by createTime desc";


		return findList(hql, new Pager(pageSize, pageNum), CollectionUtils.newList(keyword + "%",portalStatus), MediaVideoLive.class);
	}
	
	@Override
	public int listCountOfMine(String keyword) {
		
		String hql = "from MediaVideoLive where deleteFlag is false and name like ? and createId=? order by createTime desc";

		return findCount(hql, CollectionUtils.newList(keyword + "%",ClientUtils.getUserId()));
	}

	@Override
	public MediaVideoLive read(String liveId) {
		return read(MediaVideoLive.class,liveId);
	}

	@Override
	public MediaVideoLive revamp(int courseId) {
		String hql = "from MediaVideoLive where deleteFlag is false and courseId=?";
		MediaVideoLive unique = findUnique(hql, CollectionUtils.newList(courseId), MediaVideoLive.class);
		return unique ;
	}

	@SuppressWarnings("unchecked")
	@Override
	public List<MediaVideoLive> readByStatus(List<String> liveIdLst,short[] status) {
		
		if(liveIdLst.isEmpty()) {
			return Collections.EMPTY_LIST;
		}
		
		Object[] _status = new Object[status.length];
		for(int i=0;i<status.length;i++) {
			_status[i]=status[i];
		}
		
		String hql = "from MediaVideoLive where deleteFlag is false and videoLiveId in (:liveId) and status in (:status)";
		return findByComplexHql(hql, CollectionUtils.newObjectMap("liveId",liveIdLst,"status",_status), MediaVideoLive.class);
	}

}