提交 2f77112f 编写于 作者: O o2null

Merge branch 'release' into 'master'

Release

See merge request o2oa/o2oa!1754
...@@ -2,17 +2,9 @@ package com.x.base.core.project; ...@@ -2,17 +2,9 @@ package com.x.base.core.project;
import javax.servlet.ServletContext; import javax.servlet.ServletContext;
import org.quartz.DateBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.DateBuilder.IntervalUnit;
import com.x.base.core.project.annotation.Module; import com.x.base.core.project.annotation.Module;
import com.x.base.core.project.config.Config; import com.x.base.core.project.jaxrs.WrapClearCacheRequest;
import com.x.base.core.project.queue.AbstractQueue;
import com.x.base.core.project.schedule.AbstractJob; import com.x.base.core.project.schedule.AbstractJob;
import com.x.base.core.project.thread.ThreadFactory; import com.x.base.core.project.thread.ThreadFactory;
...@@ -54,4 +46,6 @@ public abstract class AbstractContext { ...@@ -54,4 +46,6 @@ public abstract class AbstractContext {
} }
public abstract <T extends AbstractJob> void fireScheduleOnLocal(Class<T> cls, Integer delay) throws Exception; public abstract <T extends AbstractJob> void fireScheduleOnLocal(Class<T> cls, Integer delay) throws Exception;
public abstract AbstractQueue<WrapClearCacheRequest> clearCacheRequestQueue();
} }
...@@ -338,6 +338,13 @@ public class ProcessPlatform extends ConfigObject { ...@@ -338,6 +338,13 @@ public class ProcessPlatform extends ConfigObject {
return o; return o;
} }
public Merge() {
this.enable = DEFAULT_ENABLE;
this.cron = DEFAULT_CRON;
this.thresholdDays = DEFAULT_THRESHOLDDAYS;
this.batchSize = DEFAULT_BATCHSIZE;
}
public static final Boolean DEFAULT_ENABLE = false; public static final Boolean DEFAULT_ENABLE = false;
public static final String DEFAULT_CRON = "30 30 6 * * ?"; public static final String DEFAULT_CRON = "30 30 6 * * ?";
......
...@@ -3,6 +3,7 @@ package com.x.base.core.project.jaxrs.cache; ...@@ -3,6 +3,7 @@ package com.x.base.core.project.jaxrs.cache;
import javax.servlet.ServletContext; import javax.servlet.ServletContext;
import com.google.gson.JsonElement; import com.google.gson.JsonElement;
import com.x.base.core.project.AbstractContext;
import com.x.base.core.project.cache.ApplicationCache; import com.x.base.core.project.cache.ApplicationCache;
import com.x.base.core.project.cache.CacheManager; import com.x.base.core.project.cache.CacheManager;
import com.x.base.core.project.http.ActionResult; import com.x.base.core.project.http.ActionResult;
...@@ -21,19 +22,15 @@ class ActionReceive extends BaseAction { ...@@ -21,19 +22,15 @@ class ActionReceive extends BaseAction {
logger.debug(effectivePerson, "receive:{}.", jsonElement); logger.debug(effectivePerson, "receive:{}.", jsonElement);
ActionResult<Wo> result = new ActionResult<>(); ActionResult<Wo> result = new ActionResult<>();
Wi wi = this.convertToWrapIn(jsonElement, Wi.class); Wi wi = this.convertToWrapIn(jsonElement, Wi.class);
Object o = servletContext.getAttribute(com.x.base.core.project.AbstractContext.class.getName()); // Object o =
if (null != o) { // servletContext.getAttribute(com.x.base.core.project.AbstractContext.class.getName());
com.x.base.core.project.Context ctx = (com.x.base.core.project.Context) o; AbstractContext ctx = AbstractContext.fromServletContext(servletContext);
if (null != ctx.clearCacheRequestQueue()) { if (null != ctx.clearCacheRequestQueue()) {
ctx.clearCacheRequestQueue().send(wi); ctx.clearCacheRequestQueue().send(wi);
} else { } else {
ApplicationCache.receive(wi); ApplicationCache.receive(wi);
CacheManager.receive(wi); CacheManager.receive(wi);
} }
} else {
ApplicationCache.receive(wi);
CacheManager.receive(wi);
}
result.setData(new Wo(wi.getClassName())); result.setData(new Wo(wi.getClassName()));
return result; return result;
} }
......
...@@ -19,7 +19,7 @@ class ActionExecute extends BaseAction { ...@@ -19,7 +19,7 @@ class ActionExecute extends BaseAction {
throws Exception { throws Exception {
logger.debug(effectivePerson, "execute:{}.", className); logger.debug(effectivePerson, "execute:{}.", className);
ActionResult<Wo> result = new ActionResult<>(); ActionResult<Wo> result = new ActionResult<>();
AbstractContext ctx = com.x.base.core.project.Context.fromServletContext(servletContext); AbstractContext ctx = AbstractContext.fromServletContext(servletContext);
Class<?> clz = Class.forName(className); Class<?> clz = Class.forName(className);
ctx.fireScheduleOnLocal((Class<AbstractJob>) clz, 1); ctx.fireScheduleOnLocal((Class<AbstractJob>) clz, 1);
Wo wo = new Wo(); Wo wo = new Wo();
......
...@@ -128,8 +128,8 @@ class ActionAppend extends BaseAction { ...@@ -128,8 +128,8 @@ class ActionAppend extends BaseAction {
identities = business.organization().identity().list(ListTools.trim(identities, true, true)); identities = business.organization().identity().list(ListTools.trim(identities, true, true));
emc.beginTransaction(Work.class); emc.beginTransaction(Work.class);
work.setManualTaskIdentityList(identities); work.setManualTaskIdentityList(identities);
emc.beginTransaction(Task.class);
// 转派后设置过期为空 // 转派后设置过期为空
emc.beginTransaction(Task.class);
task.setExpired(false); task.setExpired(false);
task.setExpireTime(null); task.setExpireTime(null);
emc.commit(); emc.commit();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册