Skip to content

G
gjjs-bd-common
Commit f1ae9ead by s_guodong
Options

checkAll

parent 0d2d9f5f
Showing with 85 additions and 69 deletions
gjjs-bd-runtime/src/main/java/com/brilliance/mda/runtime/mda/driver/compile/component/AbstractAutoCompileEmitter.java
...@@ -17,39 +17,47 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter { ...@@ -17,39 +17,47 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter {
private static Logger log = LoggerFactory.getLogger(AbstractAutoCompileEmitter.class); private static Logger log = LoggerFactory.getLogger(AbstractAutoCompileEmitter.class);
private boolean executeRuleList(String ruleType,String target,int order){ private boolean executeRuleList(String ruleType, String target, int order) {
return executeRuleList(ruleType,target,order,false); return executeRuleList(ruleType, target, order, false);
} }
private boolean executeRuleList(String ruleType,String target,int order,boolean verifyHead){ private boolean executeRuleList(String ruleType, String target, int order, boolean verifyHead) {
String moduleName = getModuleName(); String moduleName = getModuleName();
ModuleRuleContext moduleRuleContext = ModuleAnnotationProcess.cache.get(moduleName); ModuleRuleContext moduleRuleContext = ModuleAnnotationProcess.cache.get(moduleName);
if(moduleRuleContext == null){ if (moduleRuleContext == null) {
return false; return false;
} }
if(target != null){ if (target != null) {
target = getRealPath(target); target = getRealPath(target);
// if(target.charAt(0) == '.' || target.charAt(0) == '\\') { if (target.charAt(0) == '\\') {
// target = target.substring(1); target = target.substring(1);
// } }
MdaEnv.getContext().pushEventPath(target); MdaEnv.getContext().pushEventPath(target);
} }
List<RuleItem> ruleItemList = null; List<RuleItem> ruleItemList = null;
switch (ruleType){ switch (ruleType) {
case RuleItem.INIT:ruleItemList = moduleRuleContext.getInitList();break; case RuleItem.INIT:
case RuleItem.RULE:ruleItemList = moduleRuleContext.getEventRule().get(target);break; ruleItemList = moduleRuleContext.getInitList();
case RuleItem.CHECK:ruleItemList = moduleRuleContext.getCheckRule().get(target);break; break;
case RuleItem.DEFAULT:ruleItemList = moduleRuleContext.getDefaultRule().get(target);break; case RuleItem.RULE:
ruleItemList = moduleRuleContext.getEventRule().get(target);
break;
case RuleItem.CHECK:
ruleItemList = moduleRuleContext.getCheckRule().get(target);
break;
case RuleItem.DEFAULT:
ruleItemList = moduleRuleContext.getDefaultRule().get(target);
break;
} }
if(ruleItemList == null){ if (ruleItemList == null) {
return false; return false;
} }
//开始执行RuleChain //开始执行RuleChain
for (int i = 0; i < ruleItemList.size(); i++) { for (int i = 0; i < ruleItemList.size(); i++) {
RuleItem ruleItem = ruleItemList.get(i); RuleItem ruleItem = ruleItemList.get(i);
log.debug("executeRule {}.{}.{}{}",MdaEnv.getContext().getTransName(),ruleItem.getDotPath(),ruleItem.getRuleType(),ruleItem.getOrder()); log.debug("executeRule {}.{}.{}{}", MdaEnv.getContext().getTransName(), ruleItem.getDotPath(), ruleItem.getRuleType(), ruleItem.getOrder());
//校验函数头，当是复合型的rule声明时，需要第一个target为当前target时才会被ExecuteDefaultRule执行 //校验函数头，当是复合型的rule声明时，需要第一个target为当前target时才会被ExecuteDefaultRule执行
if(verifyHead && !verifyMethodHead(this,ruleItem,target,ruleType)){ if (verifyHead && !verifyMethodHead(this, ruleItem, target, ruleType)) {
continue; continue;
} }
try { try {
...@@ -68,7 +76,7 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter { ...@@ -68,7 +76,7 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter {
break; break;
} }
} catch (Exception e) { } catch (Exception e) {
log.error("execute Rule Exception",e); log.error("execute Rule Exception", e);
throw e; throw e;
} finally { } finally {
this.printSlowExecutionLog(); this.printSlowExecutionLog();
...@@ -77,54 +85,56 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter { ...@@ -77,54 +85,56 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter {
this.printSlowExecutionLog(); this.printSlowExecutionLog();
return true; return true;
} }
public static boolean verifyMethodHead(IRuleEmitter emitter,RuleItem ruleItem, String target, String ruleType){
if(ruleItem.getMethod() instanceof Method && ruleType.equals(RuleItem.DEFAULT)){ public static boolean verifyMethodHead(IRuleEmitter emitter, RuleItem ruleItem, String target, String ruleType) {
if (ruleItem.getMethod() instanceof Method && ruleType.equals(RuleItem.DEFAULT)) {
Method method = (Method) ruleItem.getMethod(); Method method = (Method) ruleItem.getMethod();
Default defaultAno = method.getAnnotation(Default.class); Default defaultAno = method.getAnnotation(Default.class);
if(defaultAno.value()!=null && defaultAno.value().length > 1){ if (defaultAno.value() != null && defaultAno.value().length > 1) {
String firstTarget = defaultAno.value()[0]; String firstTarget = defaultAno.value()[0];
String path = null;; String path = null;
if(firstTarget.startsWith(".")){ ;
if (firstTarget.startsWith(".")) {
path = firstTarget; path = firstTarget;
}else { } else {
path = ruleItem.getDotPath()+"."+ firstTarget; path = ruleItem.getDotPath() + "." + firstTarget;
} }
path = emitter.getRealPath(path); path = emitter.getRealPath(path);
//复合声明，仅与第一个路径相等时，才触发 //复合声明，仅与第一个路径相等时，才触发
if(!target.equals(path)){ if (!target.equals(path)) {
return false; return false;
} }
} }
} }
return true; return true;
} }
public boolean invokeRuleList(String ruleType,String target,int order){
return invokeRuleList(ruleType,target,order,false); public boolean invokeRuleList(String ruleType, String target, int order) {
return invokeRuleList(ruleType, target, order, false);
} }
public boolean invokeRuleList(String ruleType,String target,int order,boolean verifyHead){
public boolean invokeRuleList(String ruleType, String target, int order, boolean verifyHead) {
IContext ctx = MdaEnv.getContext(); IContext ctx = MdaEnv.getContext();
try { try {
//ctx.pushEventPath(target); //ctx.pushEventPath(target);
return executeRuleList(ruleType,target,order,verifyHead); return executeRuleList(ruleType, target, order, verifyHead);
} catch (Exception e) { } catch (Exception e) {
if(e.getCause() instanceof RuleExitException) if (e.getCause() instanceof RuleExitException)
throw (RuleExitException) e.getCause(); throw (RuleExitException) e.getCause();
else if(e instanceof RuleExitException){ else if (e instanceof RuleExitException) {
throw (RuleExitException) e; throw (RuleExitException) e;
}else if(e.getCause() instanceof RulePromptException){ } else if (e.getCause() instanceof RulePromptException) {
throw (RulePromptException) e.getCause(); throw (RulePromptException) e.getCause();
}else if(e instanceof RulePromptException){ } else if (e instanceof RulePromptException) {
throw (RulePromptException) e; throw (RulePromptException) e;
} } else if (e.getCause() instanceof RuleExecuteException) {
else if(e.getCause() instanceof RuleExecuteException){
throw (RuleExecuteException) e.getCause(); throw (RuleExecuteException) e.getCause();
}else if(e instanceof RuleExecuteException){ } else if (e instanceof RuleExecuteException) {
throw (RuleExecuteException) e; throw (RuleExecuteException) e;
} } else
else
throw new RuntimeException(e); throw new RuntimeException(e);
}finally { } finally {
if(!RuleItem.INIT.equals(ruleType)) { if (!RuleItem.INIT.equals(ruleType)) {
ctx.popEventPath(); ctx.popEventPath();
} }
} }
...@@ -132,65 +142,67 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter { ...@@ -132,65 +142,67 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter {
@Override @Override
public boolean executeInit(int order) { public boolean executeInit(int order) {
return invokeRuleList(RuleItem.INIT,null,order); return invokeRuleList(RuleItem.INIT, null, order);
} }
//执行Rule //执行Rule
public boolean executeRule(String target, int order) public boolean executeRule(String target, int order) {
{ return invokeRuleList(RuleItem.RULE, target, order);
return invokeRuleList(RuleItem.RULE,target,order);
} }
//执行Check //执行Check
public boolean executeCheck( String target, int order) public boolean executeCheck(String target, int order) {
{
target = getRealPath(target); target = getRealPath(target);
String moduleName = getModuleName(); String moduleName = getModuleName();
ModuleRuleContext moduleRuleContext = ModuleAnnotationProcess.cache.get(moduleName); ModuleRuleContext moduleRuleContext = ModuleAnnotationProcess.cache.get(moduleName);
if(moduleRuleContext == null){ if (moduleRuleContext == null) {
return true; return true;
} }
for(Map.Entry<String,List<RuleItem>> entry:moduleRuleContext.getCheckRule().entrySet()){ for (Map.Entry<String, List<RuleItem>> entry : moduleRuleContext.getCheckRule().entrySet()) {
if(!checkPathMatch(entry.getKey(),target)) if (!checkPathMatch(entry.getKey(), target))
continue; continue;
boolean result = invokeRuleList(RuleItem.CHECK,entry.getKey(),order); boolean result = invokeRuleList(RuleItem.CHECK, entry.getKey(), order);
if(!result) { if (!result) {
log.warn(String.format("execute @Check[%s,%d] return false", entry.getKey(), order)); log.warn(String.format("execute @Check[%s,%d] return false", entry.getKey(), order));
} }
} }
return true; return true;
} }
//执行Default //执行Default
public boolean executeDefault( String target, int order) { public boolean executeDefault(String target, int order) {
boolean result; boolean result;
try { try {
result = invokeRuleList(RuleItem.DEFAULT,target,order); result = invokeRuleList(RuleItem.DEFAULT, target, order);
}catch (Exception ex) } catch (Exception ex) {
{
DCR.emptyDefaultQueue(); DCR.emptyDefaultQueue();
throw new RuleExecuteException("Rule执行异常",ex); throw new RuleExecuteException("Rule执行异常", ex);
}finally { } finally {
} }
return result; return result;
} }
//执行Post 的default，因为它需要验证复合声明的头 //执行Post 的default，因为它需要验证复合声明的头
public boolean executePostDefault(String target){ public boolean executePostDefault(String target) {
return invokeRuleList(RuleItem.DEFAULT,target,-1,true); return invokeRuleList(RuleItem.DEFAULT, target, -1, true);
} }
public String getModuleName(){
public String getModuleName() {
return relatedTransaction().getCanonicalName(); return relatedTransaction().getCanonicalName();
} }
@Override @Override
public Map<String, Integer> getDefaultQueue() { public Map<String, Integer> getDefaultQueue() {
Map<String,Integer> defaultQueue = super.getDefaultQueue(); Map<String, Integer> defaultQueue = super.getDefaultQueue();
if(defaultQueue.isEmpty()){ if (defaultQueue.isEmpty()) {
synchronized (defaultQueue){ synchronized (defaultQueue) {
if(defaultQueue.isEmpty()){ if (defaultQueue.isEmpty()) {
String moduleName = getModuleName(); String moduleName = getModuleName();
ModuleRuleContext moduleRuleContext = ModuleAnnotationProcess.cache.get(moduleName); ModuleRuleContext moduleRuleContext = ModuleAnnotationProcess.cache.get(moduleName);
//设置默认的DefaultQueue，但要排除ModuleList //设置默认的DefaultQueue，但要排除ModuleList
if(moduleRuleContext != null){ if (moduleRuleContext != null) {
moduleRuleContext.getDefaultRule().entrySet().forEach(stringListEntry -> { moduleRuleContext.getDefaultRule().entrySet().forEach(stringListEntry -> {
if(!(stringListEntry.getValue().size() == 1 if (!(stringListEntry.getValue().size() == 1
&& stringListEntry.getValue().get(0).getMethodName().equals("executeDefault"))) { && stringListEntry.getValue().get(0).getMethodName().equals("executeDefault"))) {
defaultQueue.put(stringListEntry.getKey(), 0); defaultQueue.put(stringListEntry.getKey(), 0);
} }
...@@ -201,15 +213,16 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter { ...@@ -201,15 +213,16 @@ public abstract class AbstractAutoCompileEmitter extends AbstractRuleEmitter {
} }
return defaultQueue; return defaultQueue;
} }
@Override @Override
public boolean executeDefaultAll(){ public boolean executeDefaultAll() {
String moduleName = getModuleName(); String moduleName = getModuleName();
ModuleRuleContext moduleRuleContext = ModuleAnnotationProcess.cache.get(moduleName); ModuleRuleContext moduleRuleContext = ModuleAnnotationProcess.cache.get(moduleName);
if(moduleRuleContext == null){ if (moduleRuleContext == null) {
return false; return false;
} }
moduleRuleContext.getDefaultRule().entrySet().forEach(stringListEntry -> { moduleRuleContext.getDefaultRule().entrySet().forEach(stringListEntry -> {
executeRuleList(RuleItem.DEFAULT,stringListEntry.getKey(),-1); executeRuleList(RuleItem.DEFAULT, stringListEntry.getKey(), -1);
}); });
return true; return true;
} }
......
gjjs-bd-runtime/src/main/java/com/brilliance/mda/runtime/mda/impl/AbstractRuleEmitter.java
...@@ -109,6 +109,9 @@ public abstract class AbstractRuleEmitter implements IRuleEmitter { ...@@ -109,6 +109,9 @@ public abstract class AbstractRuleEmitter implements IRuleEmitter {
protected boolean checkPathMatch(String path, String target) { protected boolean checkPathMatch(String path, String target) {
if(target.startsWith("\\")){
target = target.substring(1).toLowerCase();
}
int targetLen = target.length(); int targetLen = target.length();
return targetLen == 0 || return targetLen == 0 ||
(path.startsWith(target) && (path.length() == targetLen || path.charAt(targetLen) == '.')); (path.startsWith(target) && (path.length() == targetLen || path.charAt(targetLen) == '.'));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment