package com.newvideo.service.imp;
|
|
import java.util.Iterator;
|
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.VideoResourceDao;
|
import com.newvideo.domain.LeShiAccount;
|
import com.newvideo.domain.VideoResource;
|
import com.newvideo.util.StringUtil;
|
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
|
@Service
|
public class VideoResourceService {
|
@Resource
|
private VideoResourceDao videoResourceDao;
|
|
public VideoResourceDao getVideoResourceDao() {
|
return videoResourceDao;
|
}
|
|
public void setVideoResourceDao(VideoResourceDao videoResourceDao) {
|
this.videoResourceDao = videoResourceDao;
|
}
|
|
public List<VideoResource> getResourceList() {
|
return videoResourceDao.list("from VideoResource");
|
}
|
|
public VideoResource getResource(String id) {
|
return (VideoResource) videoResourceDao.find(VideoResource.class, id);
|
}
|
|
public void addResource(VideoResource re) {
|
videoResourceDao.create(re);
|
}
|
|
public void deleteResource(String id) {
|
VideoResource re = new VideoResource();
|
re.setId(id);
|
videoResourceDao.delete(re);
|
}
|
|
public void updateResource(VideoResource re) {
|
videoResourceDao.update(re);
|
}
|
|
public String resourceListToJson(List<VideoResource> list, List<LeShiAccount> accountList) {
|
JSONObject object = new JSONObject();
|
JSONArray array = new JSONArray();
|
VideoResource vr;
|
for (Iterator<VideoResource> iterator = list.iterator(); iterator.hasNext(); array
|
.add(StringUtil.outPutResultJson(vr)))
|
vr = (VideoResource) iterator.next();
|
|
object.put("Type", array);
|
return object.toString();
|
}
|
|
public void excuteSQL(final String sql) {
|
videoResourceDao.excute(new HibernateCallback() {
|
public Object doInHibernate(Session session) throws HibernateException {
|
session.getTransaction().begin();
|
session.createSQLQuery(sql).executeUpdate();
|
session.flush();
|
session.getTransaction().commit();
|
return null;
|
}
|
});
|
}
|
|
}
|