src/db/java/org/apache/openmeetings/db/dao/record/FlvRecordingDao.java - openmeetings - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF licenses this file
  * to you under the Apache License, Version 2.0 (the
  * "License") +  you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  * KIND, either express or implied.  See the License for the
  * specific language governing permissions and limitations
  * under the License.
  */
 package org.apache.openmeetings.db.dao.record;

 import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;

 import java.util.Date;
 import java.util.List;

 import javax.persistence.EntityManager;
 import javax.persistence.NoResultException;
 import javax.persistence.PersistenceContext;
 import javax.persistence.TypedQuery;

 import org.apache.openmeetings.db.dto.file.RecordingObject;
 import org.apache.openmeetings.db.entity.record.FlvRecording;
 import org.red5.logging.Red5LoggerFactory;
 import org.slf4j.Logger;
 import org.springframework.transaction.annotation.Transactional;

 /**
  * @author sebastianwagner
  *
  */
 @Transactional
 public class FlvRecordingDao {
 	private static final Logger log = Red5LoggerFactory.getLogger(FlvRecordingDao.class, webAppRootKey);
 	@PersistenceContext
 	private EntityManager em;

 	public FlvRecording get(Long flvRecordingId) {
 		try {
 			TypedQuery<FlvRecording> query = em.createNamedQuery("getRecordingById", FlvRecording.class);
 			query.setParameter("id", flvRecordingId);

 			FlvRecording flvRecording = null;
 			try {
 				flvRecording = query.getSingleResult();
 			} catch (NoResultException ex) {
 			}
 			return flvRecording;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingById]: ", ex2);
 		}
 		return null;
 	}

 	public FlvRecording getRecordingByHash(String hash) {
 		try {
 			TypedQuery<FlvRecording> query = em.createNamedQuery("getRecordingByHash", FlvRecording.class);
 			query.setParameter("fileHash", hash);

 			try {
 				return query.getSingleResult();
 			} catch (NoResultException ex) {
 				// noop
 			}
 		} catch (Exception ex2) {
 			log.error("[getRecordingByHash]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordings() {
 		try {
 			return em.createQuery("SELECT c FROM FlvRecording c WHERE c.deleted = false", FlvRecording.class)
 					.getResultList();
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordings]: ", ex2);
 		}
 		return null;
 	}

 	public List<RecordingObject> getFlvRecordingByExternalUserId(String externalUserId, String externalUserType) {
 		try {
 			log.debug("getFlvRecordingByExternalUserId :externalUserId: {}; externalType: {}", externalUserId, externalUserType);

 			TypedQuery<RecordingObject> query = em.createNamedQuery("getRecordingsByExternalUser", RecordingObject.class);
 			query.setParameter("externalUserId", externalUserId);
 			query.setParameter("externalUserType", externalUserType);

 			List<RecordingObject> flvRecordingList = query.getResultList();

 			log.debug("getFlvRecordingByExternalUserId :: " + flvRecordingList.size());

 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingByExternalUserId]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordingByExternalRoomTypeAndCreator(String externalRoomType, Long insertedBy) {
 		try {

 			log.debug("getFlvRecordingByExternalRoomType :externalRoomType: " + externalRoomType);

 			String hql = "SELECT c FROM FlvRecording c, Room r WHERE c.room_id = r.rooms_id "
 					+ "AND r.externalRoomType LIKE :externalRoomType AND c.insertedBy LIKE :insertedBy "
 					+ "AND c.deleted = false";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
 			query.setParameter("externalRoomType", externalRoomType);
 			query.setParameter("insertedBy", insertedBy);
 			query.setParameter("deleted", true);

 			List<FlvRecording> flvRecordingList = query.getResultList();

 			log.debug("getFlvRecordingByExternalRoomType :: " + flvRecordingList.size());

 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingByExternalRoomType]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getAllFlvRecordings() {
 		try {
 			String hql = "SELECT c FROM FlvRecording c LEFT JOIN FETCH c.flvRecordingMetaData ORDER BY c.flvRecordingId";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);

 			return query.getResultList();
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordings]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordingByExternalRoomType(String externalRoomType) {
 		try {

 			log.debug("getFlvRecordingByExternalRoomType :externalRoomType: " + externalRoomType);

 			String hql = "SELECT c FROM FlvRecording c, Room r " + "WHERE c.room_id = r.rooms_id "
 					+ "AND r.externalRoomType LIKE :externalRoomType " + "AND c.deleted <> :deleted ";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
 			query.setParameter("externalRoomType", externalRoomType);
 			query.setParameter("deleted", true);

 			List<FlvRecording> flvRecordingList = query.getResultList();

 			log.debug("getFlvRecordingByExternalRoomType :: " + flvRecordingList.size());

 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingByExternalRoomType]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordingsPublic() {
 		try {

 			String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted = false "
 					+ "AND (c.ownerId IS NULL OR c.ownerId = 0)  "
 					+ "AND (c.parentFileExplorerItemId IS NULL OR c.parentFileExplorerItemId = 0) "
 					+ "ORDER BY c.isFolder DESC, c.fileName ";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);

 			List<FlvRecording> flvRecordingList = query.getResultList();
 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingsPublic]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordingRootByPublic(Long organization_id) {
 		try {

 			String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted <> :deleted " + "AND c.ownerId IS NULL "
 					+ "AND c.organization_id = :organization_id "
 					+ "AND (c.parentFileExplorerItemId IS NULL OR c.parentFileExplorerItemId = 0) "
 					+ "ORDER BY c.isFolder DESC, c.fileName ";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
 			query.setParameter("organization_id", organization_id);
 			query.setParameter("deleted", true);

 			List<FlvRecording> flvRecordingList = query.getResultList();

 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingRootByPublic]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordingRootByOwner(Long ownerId) {
 		try {

 			String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted <> :deleted " + "AND c.ownerId = :ownerId "
 					+ "AND (c.parentFileExplorerItemId IS NULL OR c.parentFileExplorerItemId = 0) "
 					+ "ORDER BY c.isFolder DESC, c.fileName ";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
 			query.setParameter("deleted", true);
 			query.setParameter("ownerId", ownerId);

 			List<FlvRecording> flvRecordingList = query.getResultList();

 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingByOwner]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordingByOwner(Long ownerId, Long parentFileExplorerItemId) {
 		try {

 			String hql = "SELECT c FROM FlvRecording c "
 					+ "WHERE c.deleted <> :deleted "
 					+ "AND c.ownerId = :ownerId "
 					+ "AND (c.parentFileExplorerItemId IS NULL OR c.parentFileExplorerItemId = :parentFileExplorerItemId)"
 					+ "ORDER BY c.isFolder DESC, c.fileName ";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
 			query.setParameter("deleted", true);
 			query.setParameter("ownerId", ownerId);
 			query.setParameter("parentFileExplorerItemId", parentFileExplorerItemId);

 			List<FlvRecording> flvRecordingList = query.getResultList();

 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingByOwner]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordingByRoomId(Long room_id) {
 		try {

 			String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted <> :deleted " + "AND c.room_id = :room_id "
 					+ "ORDER BY c.isFolder DESC, c.fileName ";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
 			query.setParameter("deleted", true);
 			query.setParameter("room_id", room_id);

 			List<FlvRecording> flvRecordingList = query.getResultList();

 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingByOwner]: ", ex2);
 		}
 		return null;
 	}

 	public List<FlvRecording> getFlvRecordingByParent(Long parentFileExplorerItemId) {
 		try {

 			String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted <> :deleted "
 					+ "AND c.parentFileExplorerItemId = :parentFileExplorerItemId "
 					+ "ORDER BY c.isFolder DESC, c.fileName ";

 			TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
 			query.setParameter("deleted", true);
 			query.setParameter("parentFileExplorerItemId", parentFileExplorerItemId);

 			List<FlvRecording> flvRecordingList = query.getResultList();

 			return flvRecordingList;
 		} catch (Exception ex2) {
 			log.error("[getFlvRecordingByParent]: ", ex2);
 		}
 		return null;
 	}

 	public Long addFlvFolderRecording(String fileHash, String fileName, Long fileSize, Long user_id, Long room_id,
 			Date recordStart, Date recordEnd, Long ownerId, String comment, Long parentFileExplorerItemId,
 			Long organization_id) {
 		try {

 			FlvRecording flvRecording = new FlvRecording();

 			flvRecording.setParentFileExplorerItemId(parentFileExplorerItemId);

 			flvRecording.setDeleted(false);
 			flvRecording.setFileHash(fileHash);
 			flvRecording.setFileName(fileName);
 			flvRecording.setFileSize(fileSize);
 			flvRecording.setInserted(new Date());
 			flvRecording.setInsertedBy(user_id);
 			flvRecording.setIsFolder(true);
 			flvRecording.setIsImage(false);
 			flvRecording.setIsPresentation(false);
 			flvRecording.setIsRecording(true);
 			flvRecording.setComment(comment);
 			flvRecording.setOrganization_id(organization_id);

 			flvRecording.setRoom_id(room_id);
 			flvRecording.setRecordStart(recordStart);
 			flvRecording.setRecordEnd(recordEnd);

 			flvRecording.setOwnerId(ownerId);

 			flvRecording = em.merge(flvRecording);
 			Long flvRecordingId = flvRecording.getFlvRecordingId();

 			return flvRecordingId;
 		} catch (Exception ex2) {
 			log.error("[addFlvRecording]: ", ex2);
 		}
 		return null;
 	}

 	public Long addFlvRecording(String fileHash, String fileName, Long fileSize, Long user_id, Long room_id,
 			Date recordStart, Date recordEnd, Long ownerId, String comment, String recorderStreamId, Integer width,
 			Integer height, Boolean isInterview) {
 		try {

 			FlvRecording flvRecording = new FlvRecording();

 			flvRecording.setDeleted(false);
 			flvRecording.setFileHash(fileHash);
 			flvRecording.setFileName(fileName);
 			flvRecording.setFileSize(fileSize);
 			flvRecording.setInserted(new Date());
 			flvRecording.setInsertedBy(user_id);
 			flvRecording.setIsFolder(false);
 			flvRecording.setIsImage(false);
 			flvRecording.setIsPresentation(false);
 			flvRecording.setIsRecording(true);
 			flvRecording.setComment(comment);
 			flvRecording.setIsInterview(isInterview);

 			flvRecording.setRoom_id(room_id);
 			flvRecording.setRecordStart(recordStart);
 			flvRecording.setRecordEnd(recordEnd);

 			flvRecording.setWidth(width);
 			flvRecording.setHeight(height);

 			flvRecording.setOwnerId(ownerId);

 			flvRecording = em.merge(flvRecording);
 			Long flvRecordingId = flvRecording.getFlvRecordingId();

 			return flvRecordingId;
 		} catch (Exception ex2) {
 			log.error("[addFlvRecording]: ", ex2);
 		}
 		return null;
 	}

 	public Long addFlvRecordingObj(FlvRecording flvRecording) {
 		try {

 			flvRecording = em.merge(flvRecording);
 			Long flvRecordingId = flvRecording.getFlvRecordingId();

 			return flvRecordingId;
 		} catch (Exception ex2) {
 			log.error("[addFlvRecording]: ", ex2);
 		}
 		return null;
 	}

 	public void updateFlvRecordingOrganization(Long flvRecordingId, Long organization_id) {
 		try {

 			FlvRecording fId = get(flvRecordingId);

 			fId.setOrganization_id(organization_id);

 			if (fId.getFlvRecordingId() == 0) {
 				em.persist(fId);
 			} else {
 				if (!em.contains(fId)) {
 					em.merge(fId);
 				}
 			}

 		} catch (Exception ex2) {
 			log.error("[deleteFileExplorerItem]: ", ex2);
 		}
 	}

 	public void updateFlvRecordingEndTime(Long flvRecordingId, Date recordEnd, Long organization_id) {
 		try {

 			FlvRecording fId = get(flvRecordingId);

 			fId.setProgressPostProcessing(0);
 			fId.setRecordEnd(recordEnd);
 			fId.setOrganization_id(organization_id);

 			if (fId.getFlvRecordingId() == 0) {
 				em.persist(fId);
 			} else {
 				if (!em.contains(fId)) {
 					em.merge(fId);
 				}
 			}

 		} catch (Exception ex2) {
 			log.error("[deleteFileExplorerItem]: ", ex2);
 		}
 	}

 	public void updateFlvRecordingProgress(Long flvRecordingId, Integer progress) {
 		try {

 			FlvRecording fId = get(flvRecordingId);

 			fId.setProgressPostProcessing(progress);

 			if (fId.getFlvRecordingId() == 0) {
 				em.persist(fId);
 			} else {
 				if (!em.contains(fId)) {
 					em.merge(fId);
 				}
 			}

 		} catch (Exception ex2) {
 			log.error("[deleteFileExplorerItem]: ", ex2);
 		}
 	}

 	/**
 	 * @param fileExplorerItemId
 	 */
 	public boolean deleteFlvRecording(Long flvRecordingId) {
 		try {

 			FlvRecording fId = get(flvRecordingId);

 			if (fId == null) {
 				return false;
 			}

 			fId.setDeleted(true);
 			fId.setUpdated(new Date());

 			if (fId.getFlvRecordingId() == 0) {
 				em.persist(fId);
 			} else {
 				if (!em.contains(fId)) {
 					em.merge(fId);
 				}
 			}

 			return true;

 		} catch (Exception ex2) {
 			log.error("[deleteFileExplorerItem]: ", ex2);
 		}

 		return false;
 	}

 	/**
 	 * @param fileExplorerItemId
 	 * @param fileName
 	 */
 	public void updateFileOrFolderName(Long flvRecordingId, String fileName) {
 		try {

 			FlvRecording fId = get(flvRecordingId);

 			fId.setFileName(fileName);
 			fId.setUpdated(new Date());

 			if (fId.getFlvRecordingId() == 0) {
 				em.persist(fId);
 			} else {
 				if (!em.contains(fId)) {
 					em.merge(fId);
 				}
 			}

 		} catch (Exception ex2) {
 			log.error("[updateFileOrFolderName]: ", ex2);
 		}
 	}

 	public void updateFlvRecording(FlvRecording fId) {
 		try {

 			if (fId.getFlvRecordingId() == 0) {
 				em.persist(fId);
 			} else {
 				if (!em.contains(fId)) {
 					em.merge(fId);
 				}
 			}

 		} catch (Exception ex2) {
 			log.error("[updateFileOrFolderName]: ", ex2);
 		}
 	}

 	/**
 	 * @param fileExplorerItemId
 	 * @param newParentFileExplorerItemId
 	 * @param isOwner
 	 */
 	public void moveFile(Long flvRecordingId, Long parentFileExplorerItemId, Boolean isOwner, Long ownerId) {
 		try {

 			FlvRecording fId = get(flvRecordingId);

 			fId.setParentFileExplorerItemId(parentFileExplorerItemId);

 			if (parentFileExplorerItemId == 0) {
 				if (isOwner) {
 					// move to personal Folder
 					fId.setOwnerId(ownerId);
 				} else {
 					// move to public room folder
 					fId.setOwnerId(null);
 				}
 			} else {
 				fId.setOwnerId(null);
 			}

 			fId.setUpdated(new Date());

 			if (fId.getFlvRecordingId() == 0) {
 				em.persist(fId);
 			} else {
 				if (!em.contains(fId)) {
 					em.merge(fId);
 				}
 			}
 		} catch (Exception ex2) {
 			log.error("[moveFile]: ", ex2);
 		}
 	}

 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one
	* or more contributor license agreements. See the NOTICE file
	* distributed with this work for additional information
	* regarding copyright ownership. The ASF licenses this file
	* to you under the Apache License, Version 2.0 (the
	* "License") + you may not use this file except in compliance
	* with the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing,
	* software distributed under the License is distributed on an
	* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
	* KIND, either express or implied. See the License for the
	* specific language governing permissions and limitations
	* under the License.
	*/
	package org.apache.openmeetings.db.dao.record;

	import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;

	import java.util.Date;
	import java.util.List;

	import javax.persistence.EntityManager;
	import javax.persistence.NoResultException;
	import javax.persistence.PersistenceContext;
	import javax.persistence.TypedQuery;

	import org.apache.openmeetings.db.dto.file.RecordingObject;
	import org.apache.openmeetings.db.entity.record.FlvRecording;
	import org.red5.logging.Red5LoggerFactory;
	import org.slf4j.Logger;
	import org.springframework.transaction.annotation.Transactional;

	/**
	* @author sebastianwagner
	*
	*/
	@Transactional
	public class FlvRecordingDao {
	private static final Logger log = Red5LoggerFactory.getLogger(FlvRecordingDao.class, webAppRootKey);
	@PersistenceContext
	private EntityManager em;

	public FlvRecording get(Long flvRecordingId) {
	try {
	TypedQuery<FlvRecording> query = em.createNamedQuery("getRecordingById", FlvRecording.class);
	query.setParameter("id", flvRecordingId);

	FlvRecording flvRecording = null;
	try {
	flvRecording = query.getSingleResult();
	} catch (NoResultException ex) {
	}
	return flvRecording;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingById]: ", ex2);
	}
	return null;
	}

	public FlvRecording getRecordingByHash(String hash) {
	try {
	TypedQuery<FlvRecording> query = em.createNamedQuery("getRecordingByHash", FlvRecording.class);
	query.setParameter("fileHash", hash);

	try {
	return query.getSingleResult();
	} catch (NoResultException ex) {
	// noop
	}
	} catch (Exception ex2) {
	log.error("[getRecordingByHash]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordings() {
	try {
	return em.createQuery("SELECT c FROM FlvRecording c WHERE c.deleted = false", FlvRecording.class)
	.getResultList();
	} catch (Exception ex2) {
	log.error("[getFlvRecordings]: ", ex2);
	}
	return null;
	}

	public List<RecordingObject> getFlvRecordingByExternalUserId(String externalUserId, String externalUserType) {
	try {
	log.debug("getFlvRecordingByExternalUserId :externalUserId: {}; externalType: {}", externalUserId, externalUserType);

	TypedQuery<RecordingObject> query = em.createNamedQuery("getRecordingsByExternalUser", RecordingObject.class);
	query.setParameter("externalUserId", externalUserId);
	query.setParameter("externalUserType", externalUserType);

	List<RecordingObject> flvRecordingList = query.getResultList();

	log.debug("getFlvRecordingByExternalUserId :: " + flvRecordingList.size());

	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingByExternalUserId]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordingByExternalRoomTypeAndCreator(String externalRoomType, Long insertedBy) {
	try {

	log.debug("getFlvRecordingByExternalRoomType :externalRoomType: " + externalRoomType);

	String hql = "SELECT c FROM FlvRecording c, Room r WHERE c.room_id = r.rooms_id "
	+ "AND r.externalRoomType LIKE :externalRoomType AND c.insertedBy LIKE :insertedBy "
	+ "AND c.deleted = false";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
	query.setParameter("externalRoomType", externalRoomType);
	query.setParameter("insertedBy", insertedBy);
	query.setParameter("deleted", true);

	List<FlvRecording> flvRecordingList = query.getResultList();

	log.debug("getFlvRecordingByExternalRoomType :: " + flvRecordingList.size());

	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingByExternalRoomType]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getAllFlvRecordings() {
	try {
	String hql = "SELECT c FROM FlvRecording c LEFT JOIN FETCH c.flvRecordingMetaData ORDER BY c.flvRecordingId";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);

	return query.getResultList();
	} catch (Exception ex2) {
	log.error("[getFlvRecordings]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordingByExternalRoomType(String externalRoomType) {
	try {

	log.debug("getFlvRecordingByExternalRoomType :externalRoomType: " + externalRoomType);

	String hql = "SELECT c FROM FlvRecording c, Room r " + "WHERE c.room_id = r.rooms_id "
	+ "AND r.externalRoomType LIKE :externalRoomType " + "AND c.deleted <> :deleted ";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
	query.setParameter("externalRoomType", externalRoomType);
	query.setParameter("deleted", true);

	List<FlvRecording> flvRecordingList = query.getResultList();

	log.debug("getFlvRecordingByExternalRoomType :: " + flvRecordingList.size());

	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingByExternalRoomType]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordingsPublic() {
	try {

	String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted = false "
	+ "AND (c.ownerId IS NULL OR c.ownerId = 0) "
	+ "AND (c.parentFileExplorerItemId IS NULL OR c.parentFileExplorerItemId = 0) "
	+ "ORDER BY c.isFolder DESC, c.fileName ";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);

	List<FlvRecording> flvRecordingList = query.getResultList();
	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingsPublic]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordingRootByPublic(Long organization_id) {
	try {

	String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted <> :deleted " + "AND c.ownerId IS NULL "
	+ "AND c.organization_id = :organization_id "
	+ "AND (c.parentFileExplorerItemId IS NULL OR c.parentFileExplorerItemId = 0) "
	+ "ORDER BY c.isFolder DESC, c.fileName ";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
	query.setParameter("organization_id", organization_id);
	query.setParameter("deleted", true);

	List<FlvRecording> flvRecordingList = query.getResultList();

	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingRootByPublic]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordingRootByOwner(Long ownerId) {
	try {

	String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted <> :deleted " + "AND c.ownerId = :ownerId "
	+ "AND (c.parentFileExplorerItemId IS NULL OR c.parentFileExplorerItemId = 0) "
	+ "ORDER BY c.isFolder DESC, c.fileName ";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
	query.setParameter("deleted", true);
	query.setParameter("ownerId", ownerId);

	List<FlvRecording> flvRecordingList = query.getResultList();

	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingByOwner]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordingByOwner(Long ownerId, Long parentFileExplorerItemId) {
	try {

	String hql = "SELECT c FROM FlvRecording c "
	+ "WHERE c.deleted <> :deleted "
	+ "AND c.ownerId = :ownerId "
	+ "AND (c.parentFileExplorerItemId IS NULL OR c.parentFileExplorerItemId = :parentFileExplorerItemId)"
	+ "ORDER BY c.isFolder DESC, c.fileName ";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
	query.setParameter("deleted", true);
	query.setParameter("ownerId", ownerId);
	query.setParameter("parentFileExplorerItemId", parentFileExplorerItemId);

	List<FlvRecording> flvRecordingList = query.getResultList();

	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingByOwner]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordingByRoomId(Long room_id) {
	try {

	String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted <> :deleted " + "AND c.room_id = :room_id "
	+ "ORDER BY c.isFolder DESC, c.fileName ";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
	query.setParameter("deleted", true);
	query.setParameter("room_id", room_id);

	List<FlvRecording> flvRecordingList = query.getResultList();

	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingByOwner]: ", ex2);
	}
	return null;
	}

	public List<FlvRecording> getFlvRecordingByParent(Long parentFileExplorerItemId) {
	try {

	String hql = "SELECT c FROM FlvRecording c " + "WHERE c.deleted <> :deleted "
	+ "AND c.parentFileExplorerItemId = :parentFileExplorerItemId "
	+ "ORDER BY c.isFolder DESC, c.fileName ";

	TypedQuery<FlvRecording> query = em.createQuery(hql, FlvRecording.class);
	query.setParameter("deleted", true);
	query.setParameter("parentFileExplorerItemId", parentFileExplorerItemId);

	List<FlvRecording> flvRecordingList = query.getResultList();

	return flvRecordingList;
	} catch (Exception ex2) {
	log.error("[getFlvRecordingByParent]: ", ex2);
	}
	return null;
	}

	public Long addFlvFolderRecording(String fileHash, String fileName, Long fileSize, Long user_id, Long room_id,
	Date recordStart, Date recordEnd, Long ownerId, String comment, Long parentFileExplorerItemId,
	Long organization_id) {
	try {

	FlvRecording flvRecording = new FlvRecording();

	flvRecording.setParentFileExplorerItemId(parentFileExplorerItemId);

	flvRecording.setDeleted(false);
	flvRecording.setFileHash(fileHash);
	flvRecording.setFileName(fileName);
	flvRecording.setFileSize(fileSize);
	flvRecording.setInserted(new Date());
	flvRecording.setInsertedBy(user_id);
	flvRecording.setIsFolder(true);
	flvRecording.setIsImage(false);
	flvRecording.setIsPresentation(false);
	flvRecording.setIsRecording(true);
	flvRecording.setComment(comment);
	flvRecording.setOrganization_id(organization_id);

	flvRecording.setRoom_id(room_id);
	flvRecording.setRecordStart(recordStart);
	flvRecording.setRecordEnd(recordEnd);

	flvRecording.setOwnerId(ownerId);

	flvRecording = em.merge(flvRecording);
	Long flvRecordingId = flvRecording.getFlvRecordingId();

	return flvRecordingId;
	} catch (Exception ex2) {
	log.error("[addFlvRecording]: ", ex2);
	}
	return null;
	}

	public Long addFlvRecording(String fileHash, String fileName, Long fileSize, Long user_id, Long room_id,
	Date recordStart, Date recordEnd, Long ownerId, String comment, String recorderStreamId, Integer width,
	Integer height, Boolean isInterview) {
	try {

	FlvRecording flvRecording = new FlvRecording();

	flvRecording.setDeleted(false);
	flvRecording.setFileHash(fileHash);
	flvRecording.setFileName(fileName);
	flvRecording.setFileSize(fileSize);
	flvRecording.setInserted(new Date());
	flvRecording.setInsertedBy(user_id);
	flvRecording.setIsFolder(false);
	flvRecording.setIsImage(false);
	flvRecording.setIsPresentation(false);
	flvRecording.setIsRecording(true);
	flvRecording.setComment(comment);
	flvRecording.setIsInterview(isInterview);

	flvRecording.setRoom_id(room_id);
	flvRecording.setRecordStart(recordStart);
	flvRecording.setRecordEnd(recordEnd);

	flvRecording.setWidth(width);
	flvRecording.setHeight(height);

	flvRecording.setOwnerId(ownerId);

	flvRecording = em.merge(flvRecording);
	Long flvRecordingId = flvRecording.getFlvRecordingId();

	return flvRecordingId;
	} catch (Exception ex2) {
	log.error("[addFlvRecording]: ", ex2);
	}
	return null;
	}

	public Long addFlvRecordingObj(FlvRecording flvRecording) {
	try {

	flvRecording = em.merge(flvRecording);
	Long flvRecordingId = flvRecording.getFlvRecordingId();

	return flvRecordingId;
	} catch (Exception ex2) {
	log.error("[addFlvRecording]: ", ex2);
	}
	return null;
	}

	public void updateFlvRecordingOrganization(Long flvRecordingId, Long organization_id) {
	try {

	FlvRecording fId = get(flvRecordingId);

	fId.setOrganization_id(organization_id);

	if (fId.getFlvRecordingId() == 0) {
	em.persist(fId);
	} else {
	if (!em.contains(fId)) {
	em.merge(fId);
	}
	}

	} catch (Exception ex2) {
	log.error("[deleteFileExplorerItem]: ", ex2);
	}
	}

	public void updateFlvRecordingEndTime(Long flvRecordingId, Date recordEnd, Long organization_id) {
	try {

	FlvRecording fId = get(flvRecordingId);

	fId.setProgressPostProcessing(0);
	fId.setRecordEnd(recordEnd);
	fId.setOrganization_id(organization_id);

	if (fId.getFlvRecordingId() == 0) {
	em.persist(fId);
	} else {
	if (!em.contains(fId)) {
	em.merge(fId);
	}
	}

	} catch (Exception ex2) {
	log.error("[deleteFileExplorerItem]: ", ex2);
	}
	}

	public void updateFlvRecordingProgress(Long flvRecordingId, Integer progress) {
	try {

	FlvRecording fId = get(flvRecordingId);

	fId.setProgressPostProcessing(progress);

	if (fId.getFlvRecordingId() == 0) {
	em.persist(fId);
	} else {
	if (!em.contains(fId)) {
	em.merge(fId);
	}
	}

	} catch (Exception ex2) {
	log.error("[deleteFileExplorerItem]: ", ex2);
	}
	}

	/**
	* @param fileExplorerItemId
	*/
	public boolean deleteFlvRecording(Long flvRecordingId) {
	try {

	FlvRecording fId = get(flvRecordingId);

	if (fId == null) {
	return false;
	}

	fId.setDeleted(true);
	fId.setUpdated(new Date());

	if (fId.getFlvRecordingId() == 0) {
	em.persist(fId);
	} else {
	if (!em.contains(fId)) {
	em.merge(fId);
	}
	}

	return true;

	} catch (Exception ex2) {
	log.error("[deleteFileExplorerItem]: ", ex2);
	}

	return false;
	}

	/**
	* @param fileExplorerItemId
	* @param fileName
	*/
	public void updateFileOrFolderName(Long flvRecordingId, String fileName) {
	try {

	FlvRecording fId = get(flvRecordingId);

	fId.setFileName(fileName);
	fId.setUpdated(new Date());

	if (fId.getFlvRecordingId() == 0) {
	em.persist(fId);
	} else {
	if (!em.contains(fId)) {
	em.merge(fId);
	}
	}

	} catch (Exception ex2) {
	log.error("[updateFileOrFolderName]: ", ex2);
	}
	}

	public void updateFlvRecording(FlvRecording fId) {
	try {

	if (fId.getFlvRecordingId() == 0) {
	em.persist(fId);
	} else {
	if (!em.contains(fId)) {
	em.merge(fId);
	}
	}

	} catch (Exception ex2) {
	log.error("[updateFileOrFolderName]: ", ex2);
	}
	}

	/**
	* @param fileExplorerItemId
	* @param newParentFileExplorerItemId
	* @param isOwner
	*/
	public void moveFile(Long flvRecordingId, Long parentFileExplorerItemId, Boolean isOwner, Long ownerId) {
	try {

	FlvRecording fId = get(flvRecordingId);

	fId.setParentFileExplorerItemId(parentFileExplorerItemId);

	if (parentFileExplorerItemId == 0) {
	if (isOwner) {
	// move to personal Folder
	fId.setOwnerId(ownerId);
	} else {
	// move to public room folder
	fId.setOwnerId(null);
	}
	} else {
	fId.setOwnerId(null);
	}

	fId.setUpdated(new Date());

	if (fId.getFlvRecordingId() == 0) {
	em.persist(fId);
	} else {
	if (!em.contains(fId)) {
	em.merge(fId);
	}
	}
	} catch (Exception ex2) {
	log.error("[moveFile]: ", ex2);
	}
	}

	}