package com.x.processplatform.service.processing.jaxrs.attachment;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;

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.project.annotation.ActionLogger;
import com.x.base.core.project.annotation.FieldDescribe;
import com.x.base.core.project.config.StorageMapping;
import com.x.base.core.project.exception.ExceptionEntityNotExist;
import com.x.base.core.project.executor.ProcessPlatformExecutorFactory;
import com.x.base.core.project.gson.GsonPropertyObject;
import com.x.base.core.project.http.ActionResult;
import com.x.base.core.project.http.EffectivePerson;
import com.x.base.core.project.jaxrs.WoId;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
import com.x.base.core.project.tools.ListTools;
import com.x.processplatform.core.entity.content.Attachment;
import com.x.processplatform.core.entity.content.WorkCompleted;
import com.x.processplatform.service.processing.ThisApplication;

/**
 * 
 * @author zhour 复制指定的附件到work,仅拷贝内容,并清除其他附带的信息
 */
class ActionCopyToWorkCompleted extends BaseAction {

	@ActionLogger
	private static Logger logger = LoggerFactory.getLogger(ActionCopyToWorkCompleted.class);

	ActionResult<List<Wo>> execute(EffectivePerson effectivePerson, String workCompletedId, JsonElement jsonElement)
			throws Exception {

		Wi wi = this.convertToWrapIn(jsonElement, Wi.class);
		String executorSeed = null;

		try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
			WorkCompleted work = emc.fetch(workCompletedId, WorkCompleted.class,
					ListTools.toList(WorkCompleted.job_FIELDNAME));
			if (null == work) {
				throw new ExceptionEntityNotExist(workCompletedId, WorkCompleted.class);
			}
			executorSeed = work.getJob();
		}

		Callable<ActionResult<List<Wo>>> callable = new Callable<ActionResult<List<Wo>>>() {
			public ActionResult<List<Wo>> call() throws Exception {
				List<Wo> wos = new ArrayList<>();
				ActionResult<List<Wo>> result = new ActionResult<>();
				try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
					WorkCompleted work = emc.find(workCompletedId, WorkCompleted.class);
					if (null == work) {
						throw new ExceptionEntityNotExist(workCompletedId, WorkCompleted.class);
					}
					List<Attachment> adds = new ArrayList<>();
					for (WiAttachment w : ListTools.trim(wi.getAttachmentList(), true, true)) {
						Attachment o = emc.find(w.getId(), Attachment.class);
						if (null == o) {
							throw new ExceptionEntityNotExist(w.getId(), Attachment.class);
						}
						StorageMapping fromStorageMapping = ThisApplication.context().storageMappings()
								.get(Attachment.class, o.getStorage());
						StorageMapping mapping = ThisApplication.context().storageMappings().random(Attachment.class);
						byte[] bs = o.readContent(fromStorageMapping);
						Attachment attachment = new Attachment(work, effectivePerson.getDistinguishedName(),
								w.getSite());
						attachment.saveContent(mapping, bs, w.getName());
						adds.add(attachment);
					}
					if (!adds.isEmpty()) {
						emc.beginTransaction(Attachment.class);
						for (Attachment o : adds) {
							emc.persist(o, CheckPersistType.all);
							Wo wo = new Wo();
							wo.setId(o.getId());
							wos.add(wo);
						}
						emc.commit();
					}
				}

				result.setData(wos);
				return result;
			}
		};

		return ProcessPlatformExecutorFactory.get(executorSeed).submit(callable).get(300, TimeUnit.SECONDS);

	}

	public static class Wi extends GsonPropertyObject {

		@FieldDescribe("附件对象")
		private List<WiAttachment> attachmentList = new ArrayList<>();

		public List<WiAttachment> getAttachmentList() {
			return attachmentList;
		}

		public void setAttachmentList(List<WiAttachment> attachmentList) {
			this.attachmentList = attachmentList;
		}

	}

	public static class WiAttachment extends Attachment {

		private static final long serialVersionUID = 5623475924507252797L;

	}

	public static class Wo extends WoId {

	}

}