package com.yeshi.buwan.service.imp;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.hibernate.HibernateException;
|
import org.hibernate.Session;
|
import org.springframework.cache.annotation.CacheEvict;
|
import org.springframework.cache.annotation.Cacheable;
|
import org.springframework.orm.hibernate4.HibernateCallback;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.yeshi.buwan.dao.CategoryContryDao;
|
import com.yeshi.buwan.domain.CategoryContry;
|
import com.yeshi.buwan.domain.system.DetailSystem;
|
import com.yeshi.buwan.domain.VideoInfo;
|
import com.yeshi.buwan.domain.VideoResource;
|
import com.yeshi.buwan.util.StringUtil;
|
|
@Service
|
public class CategoryAreaService {
|
@Resource
|
private ClassService classService;
|
@Resource
|
private CategoryContryDao categoryContryDao;
|
|
@Cacheable(value = "classCache", key = "'categoryContryList'+'-'+#cid")
|
public List<CategoryContry> categoryContryList(String cid) {
|
|
return categoryContryDao.list("from CategoryContry cc where cc.parent.id=" + cid + " order by cc.orderby desc");
|
}
|
|
@Cacheable(value = "classCache", key = "'getCategoryContryListByCid'+'-'+#cid")
|
public List<CategoryContry> getCategoryContryListByCid(String cid) {
|
|
return categoryContryDao.list("from CategoryContry cc where cc.cid=" + cid + " order by cc.orderby desc");
|
}
|
|
@Cacheable(value = "classCache", key = "'getCategoryArea'+'-'+#id")
|
public CategoryContry getCategoryArea(String id) {
|
|
return categoryContryDao.find(CategoryContry.class, Long.parseLong(id));
|
}
|
|
@SuppressWarnings("unchecked")
|
@Cacheable(value = "homeCache", key = "'getVideoInfoByArea'+'-'+#type+'-'+#ds.id+'-'+#page+'-'+#pageCount+'-'+#order+'-'+#md5")
|
public List<VideoInfo> getVideoInfoByArea(String type, DetailSystem ds, final int page,final int pageCount, int order,
|
final List<Long> resourceList, final String areas, String md5) {
|
|
String resourceWhere = "";
|
for (Long re : resourceList) {
|
resourceWhere += " rv.resourceid=" + re + " or";
|
}
|
|
if (resourceWhere.endsWith("or"))
|
resourceWhere = resourceWhere.substring(0, resourceWhere.length() - 2);
|
|
String orderby = "";
|
if (order == 1) {
|
orderby = " order by FROM_UNIXTIME(v.updatetime/1000) desc";
|
} else if (order == 2) {
|
orderby = " order by v.watchcount desc";
|
} else if (order == 3) {
|
orderby = " order by v.commentcount desc";
|
}
|
|
if (StringUtil.isNullOrEmpty(type)) {
|
final String orderByNew = orderby;
|
return (List<VideoInfo>) categoryContryDao.excute(new HibernateCallback<List<VideoInfo>>() {
|
public List<VideoInfo> doInHibernate(Session session) throws HibernateException {
|
|
try {
|
String sql = String.format(
|
"SELECT v.id,v.`name`,v.`tag`,v.`picture`,v.`hpicture`,v.`latest_hpicture`,v.watchcount,v.commentcount,temp.resources,v.`vpicture` FROM wk_video_video v LEFT JOIN wk_video_area_video_temp temp ON temp.`id`=v.`id` WHERE v.show=1 AND temp.`areas` LIKE '%s' and v.id is not null %s",
|
"%" + areas + "%", orderByNew);
|
|
List<VideoInfo> videoList = classService.getVideoInfoData(
|
session.createSQLQuery(sql).setFirstResult((page - 1) * pageCount)
|
.setMaxResults(pageCount).list(),resourceList);
|
if (videoList != null)
|
for (int i = 0; i < videoList.size(); i++) {
|
if (!isContainsResource(resourceList, videoList.get(i).getResourceList())) {
|
videoList.remove(i);
|
if (i > 0)
|
i--;
|
}
|
}
|
System.out.println("列表数量:" + videoList.size());
|
List<VideoInfo> newVideoList = new ArrayList<>();
|
if (videoList.size() > 0)
|
newVideoList.addAll(videoList);
|
return newVideoList;
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
});
|
}
|
|
List<VideoInfo> list = new ArrayList<>();
|
String sql = String.format(
|
"SELECT v.id,v.`name`,v.`tag`,v.`picture`,v.`hpicture`,v.`latest_hpicture`,v.watchcount,v.commentcount,temp.resources,v.`vpicture` FROM wk_video_video v LEFT JOIN wk_video_area_video_temp temp ON temp.`id`=v.`id` WHERE v.show=1 AND temp.`areas` LIKE '%s' AND temp.`typeid`=%s and v.id is not null %s",
|
"%" + areas + "%", type, orderby);
|
System.out.println(sql);
|
list = categoryContryDao.sqlList(sql, (page - 1) *pageCount, pageCount, null);
|
|
List<VideoInfo> videoList = classService.getVideoInfoData(list,resourceList);
|
|
if (videoList != null)
|
for (int i = 0; i < videoList.size(); i++) {
|
if (!isContainsResource(resourceList, videoList.get(i).getResourceList())) {
|
videoList.remove(i);
|
if (i > 0)
|
i--;
|
}
|
}
|
|
System.out.println("列表数量:" + videoList.size());
|
|
List<VideoInfo> newVideoList = new ArrayList<>();
|
if (videoList.size() > 0)
|
newVideoList.addAll(videoList);
|
return newVideoList;
|
}
|
|
private boolean isContainsResource(List<Long> resourceList, List<VideoResource> relist) {
|
List<Long> targetList = new ArrayList<>();
|
for (VideoResource vr : relist)
|
if(!StringUtil.isNullOrEmpty(vr.getId())) {
|
targetList.add(Long.parseLong(vr.getId()));
|
}
|
targetList.retainAll(resourceList);
|
return targetList.size() > 0;
|
}
|
|
@Transactional
|
@CacheEvict(value="classCache",allEntries=true)
|
public void updateArea(CategoryContry area) {
|
categoryContryDao.update(area);
|
}
|
|
}
|
