/******************************************************************************
|
* Copyright (C) 2015 Shenzhen Penguin Network Technology Co., Ltd
|
* All Rights Reserved.
|
* 本软件为深圳市企鹅网络科技有限公司开发研制。未经本公司正式书面同意，其他任何个人、团体
|
* 不得使用、复制、修改或发布本软件.
|
*****************************************************************************/
|
|
package com.qxueyou.scc.media.dao;
|
|
import java.text.ParseException;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.hibernate.HibernateException;
|
import org.hibernate.Query;
|
import org.hibernate.Session;
|
import org.springframework.orm.hibernate4.HibernateCallback;
|
import org.springframework.stereotype.Repository;
|
|
import com.qxueyou.scc.base.dao.BaseDAO;
|
import com.qxueyou.scc.media.model.MediaVideo;
|
import com.qxueyou.scc.media.model.MediaVideoTrans;
|
import com.qxueyou.scc.media.model.MediaVideoViewVO;
|
import com.qxueyou.scc.school.model.SchClassSchedule;
|
import com.qxueyou.scc.school.model.SchReLessonVideo;
|
|
|
|
/**
|
*
|
* @author ody.yuan
|
*
|
*/
|
@Repository(value="mediaVideoDAO")
|
public class MediaVideoDAO extends BaseDAO {
|
|
private Logger log = LogManager.getLogger(MediaVideoDAO.class);
|
|
/**
|
*查询错题 收藏对应的练习记录
|
* @return
|
* @throws ParseException
|
*/
|
@SuppressWarnings({ "unchecked"})
|
public List<MediaVideoViewVO> queryMediaVideoList(String hql,List<Object> args){
|
List<MediaVideoViewVO> lstViewVOs = new ArrayList<MediaVideoViewVO>();
|
MediaVideoViewVO viewVO;
|
List<Object[]> lst = (List<Object[]>) this.getHibernateTemplate().find(hql, args.toArray());
|
try {
|
for (Object[] obj : lst) {
|
viewVO = new MediaVideoViewVO();
|
|
viewVO.setVideoId(String.valueOf(obj[0]));
|
|
String tempName = String.valueOf(obj[1]);
|
if(StringUtils.isNotBlank(tempName) && tempName.indexOf(".") != -1){
|
viewVO.setName(tempName.substring(0, tempName.lastIndexOf(".")));
|
}else{
|
viewVO.setName("");
|
}
|
|
viewVO.setUrl(String.valueOf(obj[2]));
|
viewVO.setOrigUrl(String.valueOf(obj[3]));
|
viewVO.setSize( null != obj[4] ? Integer.parseInt(String.valueOf(obj[4])) : 0 );
|
viewVO.setPlayTime( null != obj[5] ? Integer.parseInt(String.valueOf(obj[5])) : 0 );
|
viewVO.setCoverPageUrl(String.valueOf(obj[6]));
|
viewVO.setPlayTimes( null != obj[7] ? Integer.parseInt(String.valueOf(obj[7])) : 0 );
|
viewVO.setRemark(String.valueOf(obj[8]));
|
viewVO.setFormat(String.valueOf(obj[9]));
|
|
viewVO.setTeacherId(String.valueOf(obj[10]));
|
viewVO.setTeacherName(String.valueOf(obj[11]));
|
|
viewVO.setCacheFlag(false);
|
viewVO.setDownloadFlag(false);
|
|
lstViewVOs.add(viewVO);
|
}
|
} catch (Exception e) {
|
log.error("APP视频列表出错：", e);
|
}
|
|
return lstViewVOs;
|
}
|
|
/**
|
* 组装查询转码记录
|
* @return
|
*/
|
@SuppressWarnings("unchecked")
|
public List<MediaVideoTrans> queryTransItem(String hql,
|
List<Object> args) {
|
List<MediaVideoTrans> lstitems = new ArrayList<MediaVideoTrans>();
|
MediaVideoTrans item;
|
List<Object[]> lst = (List<Object[]>) this.getHibernateTemplate().find(hql, args.toArray());
|
for (Object[] obj : lst) {
|
|
item = (MediaVideoTrans) obj[0];
|
item.setOrgName(String.valueOf(obj[1]));
|
|
lstitems.add(item);
|
}
|
|
return lstitems;
|
}
|
|
/**
|
* 组装查询转码记录
|
* @return
|
*/
|
@SuppressWarnings("unchecked")
|
public List<MediaVideo> queryVideoItem(String hql,List<Object> args) {
|
List<MediaVideo> lstitems = new ArrayList<MediaVideo>();
|
MediaVideo item;
|
List<Object[]> lst = (List<Object[]>) this.getHibernateTemplate().find(hql, args.toArray());
|
for (Object[] obj : lst) {
|
|
item = (MediaVideo) obj[0];
|
item.setClassScheduleName(String.valueOf(obj[1]));
|
item.setClassScheduleId(String.valueOf(obj[2]));
|
|
lstitems.add(item);
|
}
|
|
return lstitems;
|
}
|
|
/**
|
* 组装查询转码记录
|
* @return
|
*/
|
@SuppressWarnings("unchecked")
|
public Map<String,SchClassSchedule> queryInitMap(String hql,List<Object> args) {
|
|
Map<String,SchClassSchedule> result = new HashMap<String,SchClassSchedule>();
|
|
List<Object[]> lst = (List<Object[]>) this.getHibernateTemplate().find(hql, args.toArray());
|
for (Object[] obj : lst) {
|
result.put(String.valueOf(obj[0]), (SchClassSchedule) obj[2]);
|
}
|
|
return result;
|
}
|
|
/**
|
* 组装查询转码记录
|
* @return
|
*/
|
@SuppressWarnings("unchecked")
|
public boolean queryInitDoubleMap(String hql,List<Object> args,Map<SchReLessonVideo,MediaVideo> reMap,Map<SchReLessonVideo,SchClassSchedule> scheMap ) {
|
|
List<Object[]> lst = (List<Object[]>) this.getHibernateTemplate().find(hql, args.toArray());
|
for (Object[] obj : lst) {
|
|
reMap.put((SchReLessonVideo) obj[1], (MediaVideo) obj[0]);
|
scheMap.put((SchReLessonVideo) obj[1], (SchClassSchedule) obj[2]);
|
|
}
|
|
return true;
|
}
|
|
/**
|
* 新增视频观看次数
|
* @param videoId
|
* @return true 新增成功 false 新增失败
|
*/
|
public boolean addPlayTimes(final String videoId){
|
|
return getHibernateTemplate().execute(new HibernateCallback<Boolean>(){
|
|
@Override
|
public Boolean doInHibernate(Session session) throws HibernateException {
|
|
String hql = "update MediaVideo set playTimes = playTimes+1 where videoId=:videoId and deleteFlag is false";
|
Query qry = session.createQuery(hql);
|
qry.setParameter("videoId", videoId);
|
int count = qry.executeUpdate();
|
|
return count>0;
|
}
|
|
});
|
}
|
|
}
|
