删除测试脚本

o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/test/ActionTest1.java

@@ -1,34 +0,0 @@
-package com.x.processplatform.service.processing.jaxrs.test;
-
-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.thread.ParameterRunnable;
-import com.x.processplatform.service.processing.ThisApplication;
-
-class ActionTest1 extends BaseAction {
-
-	ActionResult<Wo> execute(EffectivePerson effectivePerson) throws Exception {
-		ActionResult<Wo> result = new ActionResult<>();
-		ThisApplication.context().threadFactory().start(new ParameterRunnable() {
-			public void run() {
-				try {
-					for (int i = 0; i < 180; i++) {
-						System.out.println("aaaaaaaaaaaaaaaaaaaaa" + i);
-						this.parameter.put("asdfasdf", i);
-						Thread.sleep(1000);
-					}
-				} catch (Exception e) {
-					e.printStackTrace();
-				}
-
-			}
-		}, "112233");
-		return result;
-	}
-
-	public static class Wo extends WrapBoolean {
-
-	}
-
-}

o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/test/ActionTest2.java

@@ -1,22 +0,0 @@
-package com.x.processplatform.service.processing.jaxrs.test;
-
-import com.x.base.core.project.http.ActionResult;
-import com.x.base.core.project.http.EffectivePerson;
-import com.x.base.core.project.jaxrs.WrapString;
-import com.x.processplatform.service.processing.ThisApplication;
-
-class ActionTest2 extends BaseAction {
-
-	ActionResult<Wo> execute(EffectivePerson effectivePerson) throws Exception {
-		ActionResult<Wo> result = new ActionResult<>();
-		Wo wo = new Wo();
-		wo.setValue(ThisApplication.context().threadFactory().alive("112233"));
-		result.setData(wo);
-		return result;
-	}
-
-	public static class Wo extends WrapString {
-
-	}
-
-}

o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/test/ActionTest3.java

@@ -1,28 +0,0 @@
-package com.x.processplatform.service.processing.jaxrs.test;
-
-import java.util.Map;
-import java.util.TreeMap;
-
-import com.x.base.core.project.gson.XGsonBuilder;
-import com.x.base.core.project.http.ActionResult;
-import com.x.base.core.project.http.EffectivePerson;
-import com.x.processplatform.service.processing.ThisApplication;
-
-class ActionTest3 extends BaseAction {
-
-	ActionResult<Wo> execute(EffectivePerson effectivePerson) throws Exception {
-		ActionResult<Wo> result = new ActionResult<>();
-		Wo wo = new Wo();
-		Map<Object, Object> value = ThisApplication.context().threadFactory().parameter("112233").orElse(null);
-		if (null != value) {
-			wo = XGsonBuilder.convert(value, Wo.class);
-		}
-		result.setData(wo);
-		return result;
-	}
-
-	public static class Wo extends TreeMap<Object, Object> {
-
-	}
-
-}

o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/test/ActionTest4.java

@@ -1,21 +0,0 @@
-package com.x.processplatform.service.processing.jaxrs.test;
-
-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.processplatform.service.processing.ThisApplication;
-
-class ActionTest4 extends BaseAction {
-
-	ActionResult<Wo> execute(EffectivePerson effectivePerson) throws Exception {
-		ActionResult<Wo> result = new ActionResult<>();
-		Wo wo = new Wo();
-		wo.setValue(ThisApplication.context().threadFactory().stop("112233"));
-		result.setData(wo);
-		return result;
-	}
-
-	public static class Wo extends WrapBoolean {
-
-	}
-}

o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/test/ActionTest5.java

@@ -1,96 +0,0 @@
-package com.x.processplatform.service.processing.jaxrs.test;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-
-import com.x.base.core.container.EntityManagerContainer;
-import com.x.base.core.container.factory.EntityManagerContainerFactory;
-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.processplatform.core.entity.content.Work;
-
-class ActionTest5 extends BaseAction {
-
-	ActionResult<Wo> execute(EffectivePerson effectivePerson) throws Exception {
-		ActionResult<Wo> result = new ActionResult<>();
-		Wo wo = new Wo();
-		try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
-			for (int i = 0; i < 10000; i++) {
-				final String j = i + "";
-				CompletableFuture<List<String>> f1 = CompletableFuture.supplyAsync(() -> {
-					List<String> list = new ArrayList<>();
-					try {
-						for (Work work : emc.listNotEqual(Work.class, Work.activityToken_FIELDNAME, j)) {
-							list.add(work.getProcess());
-						}
-					} catch (Exception e) {
-						e.printStackTrace();
-					}
-					return list;
-				});
-
-				CompletableFuture<List<String>> f2 = CompletableFuture.supplyAsync(() -> {
-					List<String> list = new ArrayList<>();
-					try {
-						emc.beginTransaction(Work.class);
-						for (Work work : emc.listNotEqual(Work.class, Work.process_FIELDNAME, j)) {
-							list.add(work.getProcess());
-							work.setScratchString(j);
-						}
-						emc.commit();
-					} catch (Exception e) {
-						e.printStackTrace();
-					}
-					return list;
-				});
-
-				CompletableFuture<List<String>> f3 = CompletableFuture.supplyAsync(() -> {
-					List<String> list = new ArrayList<>();
-					try {
-						emc.beginTransaction(Work.class);
-						for (Work work : emc.listNotEqual(Work.class, Work.activity_FIELDNAME, j)) {
-							list.add(work.getProcess());
-							work.setScratchString(j);
-						}
-						emc.commit();
-					} catch (Exception e) {
-						e.printStackTrace();
-					}
-					return list;
-				});
-
-				CompletableFuture<List<String>> f4 = CompletableFuture.supplyAsync(() -> {
-					List<String> list = new ArrayList<>();
-					try {
-						for (Work work : emc.listNotEqual(Work.class, Work.id_FIELDNAME, j)) {
-							list.add(work.getProcess());
-						}
-					} catch (Exception e) {
-						e.printStackTrace();
-					}
-					return list;
-				});
-
-				List<String> list1 = f1.get();
-				List<String> list2 = f2.get();
-				List<String> list3 = f3.get();
-				List<String> list4 = f4.get();
-				System.out.println("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
-				System.out.println("loop:" + i + "list1:" + list1.size());
-				System.out.println("loop:" + i + "list2:" + list2.size());
-				System.out.println("loop:" + i + "list3:" + list3.size());
-				System.out.println("loop:" + i + "list4:" + list4.size());
-				System.out.println("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
-			}
-
-		}
-		result.setData(wo);
-		return result;
-	}
-
-	public static class Wo extends WrapBoolean {
-
-	}
-}

o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/test/ActionTest6.java

@@ -1,95 +0,0 @@
-package com.x.processplatform.service.processing.jaxrs.test;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-
-import com.x.base.core.container.EntityManagerContainer;
-import com.x.base.core.container.factory.EntityManagerContainerFactory;
-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.processplatform.core.entity.content.Work;
-
-class ActionTest6 extends BaseAction {
-
-	ActionResult<Wo> execute(EffectivePerson effectivePerson) throws Exception {
-		ActionResult<Wo> result = new ActionResult<>();
-		Wo wo = new Wo();
-
-		for (int i = 0; i < 10000; i++) {
-			final String j = i + "";
-			CompletableFuture<List<String>> f1 = CompletableFuture.supplyAsync(() -> {
-				List<String> list = new ArrayList<>();
-				try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
-					for (Work work : emc.listNotEqual(Work.class, Work.activityToken_FIELDNAME, j)) {
-						list.add(work.getProcess());
-					}
-				} catch (Exception e) {
-					e.printStackTrace();
-				}
-				return list;
-			});
-
-			CompletableFuture<List<String>> f2 = CompletableFuture.supplyAsync(() -> {
-				List<String> list = new ArrayList<>();
-				try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
-					emc.beginTransaction(Work.class);
-					for (Work work : emc.listNotEqual(Work.class, Work.process_FIELDNAME, j)) {
-						list.add(work.getProcess());
-						work.setScratchString(j);
-					}
-					emc.commit();
-				} catch (Exception e) {
-					e.printStackTrace();
-				}
-				return list;
-			});
-
-			CompletableFuture<List<String>> f3 = CompletableFuture.supplyAsync(() -> {
-				List<String> list = new ArrayList<>();
-				try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
-					emc.beginTransaction(Work.class);
-					for (Work work : emc.listNotEqual(Work.class, Work.activity_FIELDNAME, j)) {
-						list.add(work.getProcess());
-						work.setScratchString(j);
-					}
-					emc.commit();
-				} catch (Exception e) {
-					e.printStackTrace();
-				}
-				return list;
-			});
-
-			CompletableFuture<List<String>> f4 = CompletableFuture.supplyAsync(() -> {
-				List<String> list = new ArrayList<>();
-				try (EntityManagerContainer emc = EntityManagerContainerFactory.instance().create()) {
-					for (Work work : emc.listNotEqual(Work.class, Work.id_FIELDNAME, j)) {
-						list.add(work.getProcess());
-					}
-				} catch (Exception e) {
-					e.printStackTrace();
-				}
-				return list;
-			});
-
-			List<String> list1 = f1.get();
-			List<String> list2 = f2.get();
-			List<String> list3 = f3.get();
-			List<String> list4 = f4.get();
-			System.out.println("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
-			System.out.println("loop:" + i + "list1:" + list1.size());
-			System.out.println("loop:" + i + "list2:" + list2.size());
-			System.out.println("loop:" + i + "list3:" + list3.size());
-			System.out.println("loop:" + i + "list4:" + list4.size());
-			System.out.println("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
-		}
-
-		result.setData(wo);
-		return result;
-	}
-
-	public static class Wo extends WrapBoolean {
-
-	}
-}

o2server/x_processplatform_service_processing/src/main/java/com/x/processplatform/service/processing/jaxrs/test/TestAction.java

@@ -164,106 +164,4 @@ public class TestAction extends StandardJaxrsAction {
 		asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result));
 	}
 
-	@JaxrsMethodDescribe(value = "test1.", action = ActionTest1.class)
-	@GET
-	@Path("test1")
-	@Produces(HttpMediaType.APPLICATION_JSON_UTF_8)
-	@Consumes(MediaType.APPLICATION_JSON)
-	public void test1(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request) {
-		ActionResult<ActionTest1.Wo> result = new ActionResult<>();
-		EffectivePerson effectivePerson = this.effectivePerson(request);
-		try {
-			result = new ActionTest1().execute(effectivePerson);
-		} catch (Exception e) {
-			logger.error(e, effectivePerson, request, null);
-			result.error(e);
-		}
-		asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result));
-	}
-
-	@JaxrsMethodDescribe(value = "test1.", action = ActionTest1.class)
-	@GET
-	@Path("test2")
-	@Produces(HttpMediaType.APPLICATION_JSON_UTF_8)
-	@Consumes(MediaType.APPLICATION_JSON)
-	public void test2(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request) {
-		ActionResult<ActionTest2.Wo> result = new ActionResult<>();
-		EffectivePerson effectivePerson = this.effectivePerson(request);
-		try {
-			result = new ActionTest2().execute(effectivePerson);
-		} catch (Exception e) {
-			logger.error(e, effectivePerson, request, null);
-			result.error(e);
-		}
-		asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result));
-	}
-
-	@JaxrsMethodDescribe(value = "test1.", action = ActionTest1.class)
-	@GET
-	@Path("test3")
-	@Produces(HttpMediaType.APPLICATION_JSON_UTF_8)
-	@Consumes(MediaType.APPLICATION_JSON)
-	public void test3(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request) {
-		ActionResult<ActionTest3.Wo> result = new ActionResult<>();
-		EffectivePerson effectivePerson = this.effectivePerson(request);
-		try {
-			result = new ActionTest3().execute(effectivePerson);
-		} catch (Exception e) {
-			logger.error(e, effectivePerson, request, null);
-			result.error(e);
-		}
-		asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result));
-	}
-
-	@JaxrsMethodDescribe(value = "test1.", action = ActionTest1.class)
-	@GET
-	@Path("test4")
-	@Produces(HttpMediaType.APPLICATION_JSON_UTF_8)
-	@Consumes(MediaType.APPLICATION_JSON)
-	public void test4(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request) {
-		ActionResult<ActionTest4.Wo> result = new ActionResult<>();
-		EffectivePerson effectivePerson = this.effectivePerson(request);
-		try {
-			result = new ActionTest4().execute(effectivePerson);
-		} catch (Exception e) {
-			logger.error(e, effectivePerson, request, null);
-			result.error(e);
-		}
-		asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result));
-	}
-
-	@JaxrsMethodDescribe(value = "test5.", action = ActionTest5.class)
-	@GET
-	@Path("test5")
-	@Produces(HttpMediaType.APPLICATION_JSON_UTF_8)
-	@Consumes(MediaType.APPLICATION_JSON)
-	public void test5(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request) {
-		ActionResult<ActionTest5.Wo> result = new ActionResult<>();
-		EffectivePerson effectivePerson = this.effectivePerson(request);
-		try {
-			result = new ActionTest5().execute(effectivePerson);
-		} catch (Exception e) {
-			logger.error(e, effectivePerson, request, null);
-			result.error(e);
-		}
-		asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result));
-	}
-
-	@JaxrsMethodDescribe(value = "test6.", action = ActionTest6.class)
-	@GET
-	@Path("test6")
-	@Produces(HttpMediaType.APPLICATION_JSON_UTF_8)
-	@Consumes(MediaType.APPLICATION_JSON)
-	public void test6(@Suspended final AsyncResponse asyncResponse, @Context HttpServletRequest request) {
-		ActionResult<ActionTest6.Wo> result = new ActionResult<>();
-		EffectivePerson effectivePerson = this.effectivePerson(request);
-		try {
-			result = new ActionTest6().execute(effectivePerson);
-		} catch (Exception e) {
-			logger.error(e, effectivePerson, request, null);
-			result.error(e);
-		}
-		asyncResponse.resume(ResponseFactory.getEntityTagActionResultResponse(request, result));
-	}
-
 }