增加自动删除草稿配置

o2server/x_processplatform_assemble_surface/src/main/java/com/x/processplatform/assemble/surface/jaxrs/work/ActionCloseCheck.java

@@ -0,0 +1,138 @@
+package com.x.processplatform.assemble.surface.jaxrs.work;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+import org.apache.commons.lang3.BooleanUtils;
+
+import com.x.base.core.container.EntityManagerContainer;
+import com.x.base.core.container.factory.EntityManagerContainerFactory;
+import com.x.base.core.project.Applications;
+import com.x.base.core.project.x_processplatform_service_processing;
+import com.x.base.core.project.annotation.FieldDescribe;
+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.WrapBoolean;
+import com.x.base.core.project.tools.ListTools;
+import com.x.processplatform.assemble.surface.Business;
+import com.x.processplatform.assemble.surface.ThisApplication;
+import com.x.processplatform.core.entity.content.Task;
+import com.x.processplatform.core.entity.content.Work;
+import com.x.processplatform.core.entity.element.ActivityType;
+import com.x.processplatform.core.entity.element.Manual;
+import com.x.processplatform.core.entity.element.ManualMode;
+import com.x.processplatform.core.entity.element.Process;
+
+class ActionCloseCheck extends BaseAction {
+
+	ActionResult<Wo> execute(EffectivePerson effectivePerson, String id) throws Exception {
+		try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
+			ActionResult<Wo> result = new ActionResult<>();
+			Business business = new Business(emc);
+			Work work = emc.find(id, Work.class);
+			Wo wo = new Wo();
+			wo.setDraft(this.draft(business, effectivePerson, work));
+			if (BooleanUtils.isFalse(wo.getDraft().getValue())) {
+				wo.setGrabRelease(this.grabRelease(business, effectivePerson, work));
+			}
+			result.setData(wo);
+			return result;
+		}
+	}
+
+	private WoDraft draft(Business business, EffectivePerson effectivePerson, Work work) throws Exception {
+		WoDraft wo = new WoDraft();
+		wo.setValue(false);
+		if ((null != work) && (BooleanUtils.isFalse(work.getDataChanged()))
+				&& (Objects.equals(ActivityType.manual, work.getActivityType()))) {
+			Process process = business.process().pick(work.getProcess());
+			if ((null != process) && (BooleanUtils.isTrue(process.getCheckDraft()))) {
+				if (effectivePerson.isPerson(work.getCreatorPerson())) {
+					ThisApplication.context().applications().deleteQuery(x_processplatform_service_processing.class,
+							Applications.joinQueryUri("work", work.getId())).getData(Wo.class);
+					wo.setValue(true);
+				}
+			}
+		}
+		return wo;
+	}
+
+	private WoGrabRelease grabRelease(Business business, EffectivePerson effectivePerson, Work work) throws Exception {
+		WoGrabRelease wo = new WoGrabRelease();
+		if ((null != work) && (Objects.equals(work.getActivityType(), ActivityType.manual))) {
+			Manual manual = business.manual().pick(work.getActivity());
+			if ((null != manual) && Objects.equals(ManualMode.grab, manual.getManualMode())) {
+				if (ListTools.isEmpty(work.getManualTaskIdentityList())
+						|| (work.getManualTaskIdentityList().size() == 1)) {
+					business.entityManagerContainer().beginTransaction(Work.class);
+					work.getManualTaskIdentityList().clear();
+					business.entityManagerContainer().commit();
+					ThisApplication.context().applications().putQuery(effectivePerson.getDebugger(),
+							x_processplatform_service_processing.class,
+							Applications.joinQueryUri("work", work.getId(), "processing"), null);
+					List<Task> tasks = business.entityManagerContainer().fetchEqual(Task.class,
+							ListTools.toList(Task.identity_FIELDNAME), Task.work_FIELDNAME, work.getId());
+					wo.setRelease(true);
+					wo.setTaskList(tasks);
+				}
+			}
+		}
+		return wo;
+	}
+
+	public static class Wo extends GsonPropertyObject {
+
+		@FieldDescribe("检查删除草稿结果")
+		private WoDraft draft;
+		@FieldDescribe("检查抢办释放结果")
+		private WoGrabRelease grabRelease;
+
+		public WoDraft getDraft() {
+			return draft;
+		}
+
+		public void setDraft(WoDraft draft) {
+			this.draft = draft;
+		}
+
+		public WoGrabRelease getGrabRelease() {
+			return grabRelease;
+		}
+
+		public void setGrabRelease(WoGrabRelease grabRelease) {
+			this.grabRelease = grabRelease;
+		}
+
+	}
+
+	public static class WoDraft extends WrapBoolean {
+
+	}
+
+	public static class WoGrabRelease extends GsonPropertyObject {
+
+		private List<Task> taskList = new ArrayList<>();
+
+		private Boolean release = false;
+
+		public List<Task> getTaskList() {
+			return taskList;
+		}
+
+		public void setTaskList(List<Task> taskList) {
+			this.taskList = taskList;
+		}
+
+		public Boolean getRelease() {
+			return release;
+		}
+
+		public void setRelease(Boolean release) {
+			this.release = release;
+		}
+
+	}
+
+}