|
|
@@ -1,12 +1,16 @@
|
|
|
package com.x.cms.assemble.control.jaxrs.document;
|
|
|
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.Date;
|
|
|
-import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
+import java.io.ByteArrayInputStream;
|
|
|
+import java.io.InputStream;
|
|
|
+import java.util.*;
|
|
|
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
|
|
|
+import com.x.base.core.entity.annotation.CheckPersistType;
|
|
|
+import com.x.base.core.project.config.StorageMapping;
|
|
|
+import com.x.base.core.project.exception.ExceptionWhen;
|
|
|
+import com.x.processplatform.core.entity.content.Attachment;
|
|
|
+import org.apache.commons.io.FilenameUtils;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
|
|
import com.google.gson.JsonElement;
|
|
|
@@ -228,6 +232,48 @@ public class ActionPersistPublishContent extends BaseAction {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ //从流程管理中复制所有的附件到CMS
|
|
|
+ if (check) {
|
|
|
+ if ( wi.getWf_attachmentIds() != null && wi.getWf_attachmentIds().length > 0 ) {
|
|
|
+ FileInfo fileInfo = null;
|
|
|
+ Attachment attachment = null;
|
|
|
+ StorageMapping mapping_attachment = null;
|
|
|
+ StorageMapping mapping_fileInfo = null;
|
|
|
+ InputStream input = null;
|
|
|
+ byte[] attachment_content = null;
|
|
|
+ for (String attachmentId : wi.getWf_attachmentIds()) {
|
|
|
+ try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
|
|
|
+ document = emc.find(document.getId(), Document.class, ExceptionWhen.not_found);
|
|
|
+ attachment = emc.find(attachmentId, Attachment.class, ExceptionWhen.not_found);
|
|
|
+ if (attachment != null) {
|
|
|
+ emc.beginTransaction(FileInfo.class);
|
|
|
+ emc.beginTransaction(Document.class);
|
|
|
+
|
|
|
+ mapping_attachment = ThisApplication.context().storageMappings().get(Attachment.class, attachment.getStorage());
|
|
|
+ attachment_content = attachment.readContent(mapping_attachment);
|
|
|
+
|
|
|
+ mapping_fileInfo = ThisApplication.context().storageMappings().random(FileInfo.class);
|
|
|
+ fileInfo = concreteFileInfo(effectivePerson.getDistinguishedName(), document, mapping_fileInfo, attachment.getName(), attachment.getSite());
|
|
|
+ input = new ByteArrayInputStream(attachment_content);
|
|
|
+ fileInfo.saveContent(mapping_fileInfo, input, attachment.getName());
|
|
|
+ fileInfo.setName(attachment.getName());
|
|
|
+ emc.check(document, CheckPersistType.all);
|
|
|
+ emc.persist(fileInfo, CheckPersistType.all);
|
|
|
+
|
|
|
+ emc.commit();
|
|
|
+ }
|
|
|
+ } catch (Throwable th) {
|
|
|
+ th.printStackTrace();
|
|
|
+ result.error(th);
|
|
|
+ } finally {
|
|
|
+ if (input != null) {
|
|
|
+ input.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
if (check) {
|
|
|
try {
|
|
|
Wo wo = new Wo();
|
|
|
@@ -240,6 +286,7 @@ public class ActionPersistPublishContent extends BaseAction {
|
|
|
throw exception;
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
if (check) {
|
|
|
try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
|
|
|
logService.log(emc, wi.getCreatorIdentity(),
|
|
|
@@ -358,11 +405,45 @@ public class ActionPersistPublishContent extends BaseAction {
|
|
|
logger.error( e, effectivePerson, request, null);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
+ ApplicationCache.notify(FileInfo.class);
|
|
|
ApplicationCache.notify(Document.class);
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
+ private FileInfo concreteFileInfo(String person, Document document, StorageMapping storage, String name, String site) throws Exception {
|
|
|
+ String fileName = UUID.randomUUID().toString();
|
|
|
+ String extension = FilenameUtils.getExtension(name);
|
|
|
+ FileInfo attachment = new FileInfo();
|
|
|
+ if (StringUtils.isEmpty(extension)) {
|
|
|
+ throw new Exception("file extension is empty.");
|
|
|
+ } else {
|
|
|
+ fileName = fileName + "." + extension;
|
|
|
+ }
|
|
|
+ if (name.indexOf("\\") > 0) {
|
|
|
+ name = StringUtils.substringAfterLast(name, "\\");
|
|
|
+ }
|
|
|
+ if (name.indexOf("/") > 0) {
|
|
|
+ name = StringUtils.substringAfterLast(name, "/");
|
|
|
+ }
|
|
|
+ attachment.setCreateTime(new Date());
|
|
|
+ attachment.setLastUpdateTime(new Date());
|
|
|
+ attachment.setExtension(extension);
|
|
|
+ attachment.setName(name);
|
|
|
+ attachment.setFileName(fileName);
|
|
|
+ attachment.setStorage(storage.getName());
|
|
|
+ attachment.setAppId(document.getAppId());
|
|
|
+ attachment.setCategoryId(document.getCategoryId());
|
|
|
+ attachment.setDocumentId(document.getId());
|
|
|
+ attachment.setCreatorUid(person);
|
|
|
+ attachment.setSite(site);
|
|
|
+ attachment.setFileHost("");
|
|
|
+ attachment.setFilePath("");
|
|
|
+ attachment.setFileType("ATTACHMENT");
|
|
|
+
|
|
|
+ return attachment;
|
|
|
+ }
|
|
|
+
|
|
|
public static class Wi {
|
|
|
|
|
|
public static WrapCopier<Wi, Document> copier = WrapCopierFactory.wi( Wi.class, Document.class, null, null);
|
o2null