DocumentPersistService.java

package com.x.cms.assemble.control.service;

import com.google.gson.JsonElement;
import com.x.base.core.container.EntityManagerContainer;
import com.x.base.core.container.factory.EntityManagerContainerFactory;
import com.x.base.core.entity.annotation.CheckPersistType;
import com.x.base.core.entity.dataitem.ItemCategory;
import com.x.base.core.project.tools.ListTools;
import com.x.cms.assemble.control.DocumentDataHelper;
import com.x.cms.assemble.control.jaxrs.document.ActionPersistBatchModifyData.WiDataChange;
import com.x.cms.assemble.control.jaxrs.document.ActionPersistBatchModifyData.Wo;
import com.x.cms.assemble.control.jaxrs.permission.element.PermissionInfo;
import com.x.cms.core.entity.CategoryInfo;
import com.x.cms.core.entity.Document;
import com.x.cms.core.entity.content.Data;
import com.x.query.core.entity.Item;
import org.apache.commons.lang3.StringUtils;

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

/**
 * 对文档信息进行持久化服务类
 */
public class DocumentPersistService {
	private DocumentInfoService documentInfoService = new DocumentInfoService();
	private PermissionOperateService permissionService = new PermissionOperateService();
	
	public Document save( Document document, JsonElement jsonElement ) throws Exception {
		if( document == null ){
			throw new Exception("document is null!");
		}
		if (document.getPictureList() != null && !document.getPictureList().isEmpty()) {
			document.setHasIndexPic(true);
		}
		try ( EntityManagerContainer emc = EntityManagerContainerFactory.instance().create() ) {
			document.setModifyTime( new Date());	
			document.setSequenceAppAlias( document.getAppAlias() + document.getId() );
			document.setSequenceCategoryAlias( document.getCategoryAlias() + document.getId() );
			if( document.getTitle().length() > 30 ) {
				document.setSequenceTitle( document.getTitle().substring(0, 30) + document.getId() );
			}else {
				document.setSequenceTitle( document.getTitle() + document.getId() );
			}
			if( document.getCreatorPerson().length() > 50 ) {
				document.setSequenceCreatorPerson( document.getCreatorPerson().substring(0, 50) + document.getId() );
			}else {
				document.setSequenceCreatorPerson( document.getCreatorPerson() + document.getId() );
			}
			if( document.getCreatorUnitName().length() > 50 ) {
				document.setSequenceCreatorUnitName( document.getCreatorUnitName().substring(0, 50) + document.getId() );
			}else {
				document.setSequenceCreatorUnitName( document.getCreatorUnitName() + document.getId() );
			}			
			
			document =  documentInfoService.save( emc, document );
			//如果有数据信息，则保存数据信息
			
			DocumentDataHelper documentDataHelper = new DocumentDataHelper( emc, document );
			if( jsonElement != null ) {
				documentDataHelper.update( jsonElement );
			}
			emc.commit();

			Data data = documentDataHelper.get();
			data.setDocument( document );
			documentDataHelper.update( data );
			
			emc.commit();
			return document;
		} catch ( Exception e ) {
			throw e;
		}
	}
	
	/**
	 * 根据文档信息更新数据内容中的文档信息内容
	 * @param document
	 * @return
	 * @throws Exception
	 */
	public Document refreshDocInfoData( Document document ) throws Exception {
		if( document == null ){
			throw new Exception("document is null!");
		}
		try ( EntityManagerContainer emc = EntityManagerContainerFactory.instance().create() ) {
			document =  documentInfoService.save( emc, document );
			//如果有数据信息，则保存数据信息
			DocumentDataHelper documentDataHelper = new DocumentDataHelper( emc, document );
			Data data = documentDataHelper.get();
			data.setDocument( document );
			documentDataHelper.update(data);
			emc.commit();
			return document;
		} catch ( Exception e ) {
			throw e;
		}
	}

	void fill(Item o, Document document) {
		/** 将DateItem与Document放在同一个分区 */
		o.setDistributeFactor(document.getDistributeFactor());
		o.setBundle(document.getId());
		o.setItemCategory(ItemCategory.cms);
	}
	
	

	/**
	 * 变更一个文档的分类信息
	 * @param document
	 * @param categoryInfo
	 * @throws Exception
	 */
	public Boolean changeCategory( Document document, CategoryInfo categoryInfo) throws Exception {
		if( document == null ){
			throw new Exception("document is empty!");
		}		
		if( categoryInfo == null ){
			throw new Exception("categoryInfo is empty!");
		}
		Data data = null;
		DocumentDataHelper documentDataHelper = null;
		try ( EntityManagerContainer emc = EntityManagerContainerFactory.instance().create() ) {
			emc.beginTransaction( Document.class );
			emc.beginTransaction(  Item.class );
			
			document = emc.find( document.getId(), Document.class );
			
			//更新document分类相关信息
			document.setAppId( categoryInfo.getAppId() );
			document.setAppName( categoryInfo.getAppName() );
			document.setCategoryId( categoryInfo.getId() );
			document.setCategoryName( categoryInfo.getCategoryName() );
			document.setCategoryAlias( categoryInfo.getCategoryAlias() );
			document.setForm( categoryInfo.getReadFormId() );
			document.setFormName( categoryInfo.getReadFormName() );
			document.setModifyTime( new Date());
			
			document.setSequenceAppAlias( document.getAppAlias() + document.getId() );
			document.setSequenceCategoryAlias( document.getCategoryAlias() + document.getId() );
			if( document.getTitle().length() > 30 ) {
				document.setSequenceTitle( document.getTitle().substring(0, 30) + document.getId() );
			}else {
				document.setSequenceTitle( document.getTitle() + document.getId() );
			}
			if( document.getCreatorPerson().length() > 50 ) {
				document.setSequenceCreatorPerson( document.getCreatorPerson().substring(0, 50) + document.getId() );
			}else {
				document.setSequenceCreatorPerson( document.getCreatorPerson() + document.getId() );
			}
			if( document.getCreatorUnitName().length() > 50 ) {
				document.setSequenceCreatorUnitName( document.getCreatorUnitName().substring(0, 50) + document.getId() );
			}else {
				document.setSequenceCreatorUnitName( document.getCreatorUnitName() + document.getId() );
			}
			
			emc.check( document, CheckPersistType.all );
			
			//更新数据里的document对象信息
			documentDataHelper = new DocumentDataHelper( emc, document );
			data = documentDataHelper.get();
			data.setDocument( document );
			documentDataHelper.update( data );

			emc.commit();
			return true;
		} catch ( Exception e ) {
			throw e;
		}
	}
	
	public Wo changeData(List<String> docIds, List<WiDataChange> dataChanges) throws Exception {
		if( ListTools.isEmpty( docIds )){
			throw new Exception("docIds is empty!");
		}
		if( ListTools.isEmpty( dataChanges )){
			throw new Exception("dataChanges is empty!");
		}
		Wo wo = new Wo();
		Data data = null;
		Document document_entity = null;
		DocumentDataHelper documentDataHelper = null;
		for( String docId : docIds ) {
			try ( EntityManagerContainer emc = EntityManagerContainerFactory.instance().create() ) {
				
				emc.beginTransaction( Document.class );
				emc.beginTransaction( Item.class );
				
				document_entity = emc.find( docId, Document.class );
				document_entity.setModifyTime( new Date());
				
				documentDataHelper = new DocumentDataHelper( emc, document_entity );
				data = documentDataHelper.get();
				for( WiDataChange dataChange : dataChanges ) {
					if( "Integer".equals(dataChange.getDataType() )) {
						data.put( dataChange.getDataPath(), dataChange.getDataInteger());
					}else if( "String".equals(dataChange.getDataType() )) {
						data.put( dataChange.getDataPath(), dataChange.getDataString());
					}else if( "Date".equals(dataChange.getDataType() )) {
						data.put( dataChange.getDataPath(), dataChange.getDataDate());
					}else if( "Boolean".equals(dataChange.getDataType() )) {
						data.put( dataChange.getDataPath(), dataChange.getDataBoolean());
					}else {
						data.put( dataChange.getDataPath(), dataChange.getDataString());
					}
				}
				data.setDocument( document_entity );
				documentDataHelper.update( data );
				emc.commit();
				wo.increaseSuccess_count(1);
			} catch ( Exception e ) {
				wo.appendErorrId(docId);
				wo.increaseError_count(1);
				e.printStackTrace();
			}
		}
		return wo;
	}

	public Boolean inReview(String documentId) throws Exception {
		if( StringUtils.isEmpty( documentId ) ){
			throw new Exception("documentId is empty!");
		}
		try ( EntityManagerContainer emc = EntityManagerContainerFactory.instance().create() ) {
			return documentInfoService.inReview( emc, documentId );
		} catch ( Exception e ) {
			throw e;
		}
	}

	public void topDocument(String id) throws Exception {
		if( StringUtils.isEmpty( id ) ){
			throw new Exception("id is empty!");
		}
		try ( EntityManagerContainer emc = EntityManagerContainerFactory.instance().create() ) {
			Document document = emc.find( id, Document.class );
			if( document != null ) {
//				emc.beginTransaction( Item.class );
				emc.beginTransaction( Document.class );
				document.setIsTop( true );			
				
				DocumentDataHelper documentDataHelper = new DocumentDataHelper( emc, document );
				Data data = documentDataHelper.get();
				data.setDocument( document );
				documentDataHelper.update( data );
				
				emc.commit();
			}
			
		} catch ( Exception e ) {
			throw e;
		}
	}
	
	public void unTopDocument(String id) throws Exception {
		if( StringUtils.isEmpty( id ) ){
			throw new Exception("id is empty!");
		}
		try ( EntityManagerContainer emc = EntityManagerContainerFactory.instance().create() ) {
			Document document = emc.find( id, Document.class );
			if( document != null ) {
				emc.beginTransaction( Document.class );
				document.setIsTop( false );
				DocumentDataHelper documentDataHelper = new DocumentDataHelper( emc, document );
				Data data = documentDataHelper.get();
				data.setDocument( document );
				documentDataHelper.update( data );
				emc.commit();
			}
			
		} catch ( Exception e ) {
			throw e;
		}
	}
	
	/**
	 * 删除指定ID的文档
	 * @param docId
	 * @throws Exception
	 */
	public void delete(  String docId ) throws Exception {
		if( StringUtils.isEmpty(  docId ) ){
			throw new Exception("docId is empty!");
		}
		try ( EntityManagerContainer emc = EntityManagerContainerFactory.instance().create() ) {
			documentInfoService.delete(emc, docId);
		} catch ( Exception e ) {
			throw e;
		}
	}

	/**
	 * 根据读者作者列表更新文档所有的权限信息
	 * @param docId
	 * @param readerList
	 * @param authorList
	 * @throws Exception
	 */
	public void refreshDocumentPermission( String docId, List<PermissionInfo> readerList, List<PermissionInfo> authorList ) throws Exception {
		if( StringUtils.isEmpty( docId ) ){
			throw new Exception("docId is empty!");
		}
		permissionService.refreshDocumentPermission( docId, readerList, authorList);
		
		new CmsBatchOperationPersistService().addOperation( 
				CmsBatchOperationProcessService.OPT_OBJ_DOCUMENT, 
				CmsBatchOperationProcessService.OPT_TYPE_PERMISSION,  docId,  docId, "刷新文档权限：ID=" +  docId );
	}

	/**
	 * 根据组织好的权限信息列表更新指定文档的权限信息
	 * @param docId
	 * @param permissionList
	 * @throws Exception
	 */
	public void refreshDocumentPermission( String docId, List<PermissionInfo> permissionList ) throws Exception {
		if( StringUtils.isEmpty( docId ) ){
			throw new Exception("docId is empty!");
		}
		permissionService.refreshDocumentPermission(docId, permissionList);
	}
}