package com.newvideo.service.imp;
|
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.hibernate.HibernateException;
|
import org.hibernate.Session;
|
import org.springframework.orm.hibernate4.HibernateCallback;
|
import org.springframework.stereotype.Service;
|
|
import com.newvideo.dao.CategoryVideoDao;
|
import com.newvideo.dao.VideoInfoDao;
|
import com.newvideo.domain.CategoryVideo;
|
import com.newvideo.domain.VideoInfo;
|
import com.newvideo.util.Constant;
|
|
@Service
|
public class VideoService {
|
@Resource
|
private VideoInfoDao videoInfoDao;
|
@Resource
|
private ClassService classServcie;
|
@Resource
|
private CategoryVideoDao categoryVideoDao;
|
|
public CategoryVideoDao getCategoryVideoDao() {
|
return categoryVideoDao;
|
}
|
|
public void setCategoryVideoDao(CategoryVideoDao categoryVideoDao) {
|
this.categoryVideoDao = categoryVideoDao;
|
}
|
|
public ClassService getClassServcie() {
|
return classServcie;
|
}
|
|
public void setClassServcie(ClassService classServcie) {
|
this.classServcie = classServcie;
|
}
|
|
public VideoInfoDao getVideoInfoDao() {
|
return videoInfoDao;
|
}
|
|
public void setVideoInfoDao(VideoInfoDao videoInfoDao) {
|
this.videoInfoDao = videoInfoDao;
|
}
|
|
public VideoService() {
|
|
}
|
|
public VideoInfo getVideoInfo(String id) {
|
return videoInfoDao.find(VideoInfo.class, id);
|
}
|
|
public List<VideoInfo> getVideoListByClass(int type, int page) {
|
String types[] = classServcie.getChildrenType(type);
|
String wheres = "";
|
String as[];
|
int j = (as = types).length;
|
for (int i = 0; i < j; i++) {
|
String st = as[i];
|
wheres = (new StringBuilder(String.valueOf(wheres))).append("or v.videoType.id=").append(st).append(" ")
|
.toString();
|
}
|
|
if (wheres.startsWith("or"))
|
wheres = wheres.substring(2, wheres.length());
|
List<VideoInfo> list = videoInfoDao.list(
|
(new StringBuilder("from VideoInfo v where v.show='1' and (")).append(wheres).append(")").toString(),
|
(page - 1) * Constant.pageCount, 20, new String[] {});
|
return list;
|
}
|
|
public List<VideoInfo> searchVideoUsedByAdmin(String name) {
|
return videoInfoDao.list("from VideoInfo v where v.name like ? order by REPLACE(v.name,?,'')", 0, 20,
|
new String[] { "%" + name + "%", name });
|
}
|
|
public long getVideoCountByClass(int type) {
|
String types[] = classServcie.getChildrenType(type);
|
String wheres = "";
|
String as[];
|
int j = (as = types).length;
|
for (int i = 0; i < j; i++) {
|
String st = as[i];
|
wheres = (new StringBuilder(String.valueOf(wheres))).append("or v.videoType.id=").append(st).append(" ")
|
.toString();
|
}
|
|
if (wheres.startsWith("or"))
|
wheres = wheres.substring(2, wheres.length());
|
return videoInfoDao
|
.getCount((new StringBuilder("select count(*) from VideoInfo v where ")).append(wheres).toString());
|
}
|
|
public void addVideoWatch(final String vid) {
|
videoInfoDao.excute(new HibernateCallback() {
|
public Object doInHibernate(Session session) throws HibernateException {
|
try {
|
session.getTransaction().begin();
|
session.createSQLQuery("update wk_video_video v set v.watchcount=v.watchcount+1 where v.id=?")
|
.setParameter(0, vid).executeUpdate();
|
session.flush();
|
session.getTransaction().commit();
|
} catch (Exception exception) {
|
exception.printStackTrace();
|
}
|
return null;
|
}
|
});
|
|
}
|
|
public void addCategoryVideo(CategoryVideo cv) {
|
categoryVideoDao.save(cv);
|
}
|
|
/**
|
* 将没有添加进分裂视频的视频加入杂类
|
*/
|
public void addNOAddToCategoryVideo() {
|
videoInfoDao.excute(new HibernateCallback() {
|
public Object doInHibernate(Session session) throws HibernateException {
|
try {
|
session.getTransaction().begin();
|
List list = session
|
.createSQLQuery(
|
"SELECT DISTINCT(v.`id`) FROM wk_video_video v LEFT JOIN wk_category_video cv ON cv.`videoid`=v.`id` WHERE cv.`id` IS NULL")
|
.setFirstResult(0).setMaxResults(10000).list();
|
for (int i = 0; i < list.size(); i++) {
|
String videoId = list.get(i) + "";
|
session.createSQLQuery(
|
"INSERT INTO wk_category_video(videoid,videotypeid) VALUES(" + videoId + ",299)")
|
.executeUpdate();
|
}
|
session.flush();
|
session.getTransaction().commit();
|
} catch (Exception exception) {
|
exception.printStackTrace();
|
}
|
return null;
|
}
|
});
|
|
}
|
}
|
