消息队列切点

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/aspect/RocketMQAspect.java.ftl

@@ -78,7 +78,8 @@ public class RocketMQAspect
             <#list dataEntity.getAllPSDEDataSyncs() as dataSync>
                 <#if dataSync.getOutPSSysDataSyncAgent?? && dataSync.getOutPSSysDataSyncAgent()??>
                     <#assign producer=dataEntity.codeName+dataSync.codeName>
-    @AfterReturning(value = "${getPointCut(dataSync)}"
+    <#--@AfterReturning(value = "${getPointCut(dataSync)}")-->
+    <@getPointCut dataSync/>
     @Async
     public void ${srfmethodname(producer)}(JoinPoint point) {
         <#if dataSync.getOutTestPSDEAction?? && dataSync.getOutTestPSDEAction()??>
@@ -155,17 +156,22 @@ public class RocketMQAspect
 </#if>
 
 <#comment>输出切点</#comment>
-<#function getPointCut dataSync>
+<#macro getPointCut dataSync>
     <#comment>数值代码表 1=新建; 2=编辑; 4=删除</#comment>
     <#assign createArray = [1,3,5]>
     <#assign updateArray = [2,3,6]>
     <#assign deleteArray=[4,5,6]>
     <#assign result="">
+    //1
     <#if dataSync.getEventType?? && dataSync.getEventType()??>
         <#assign type=dataSync.getEventType()>
+        // type:${type}
         <#assign isCreate=createArray?seq_contains(type)>
+        // isCreate:${isCreate?c}
         <#assign isUpdate=updateArray?seq_contains(type)>
+        // isUpdate:${isUpdate?c}
         <#assign isDelete=deleteArray?seq_contains(type)>
+        // isDelete:${isDelete?c}
         <#if isCreate>
             <#assign result="execution(*"+pub.getPKGCodeName()+".core.*.service.*"+dataEntity.codeName+"*.create*(..))">
         </#if>
@@ -182,5 +188,35 @@ public class RocketMQAspect
             <#assign result=result+"execution(*"+pub.getPKGCodeName()+".core.*.service.*"+dataEntity.codeName+"*.remove*(..))">
         </#if>
     </#if>
-    <#return "("+result+")">
-</#function>
\ No newline at end of file
+</#macro>
+
+<#--<#comment>输出切点</#comment>-->
+<#--<#function getPointCut dataSync>-->
+    <#--<#comment>数值代码表 1=新建; 2=编辑; 4=删除</#comment>-->
+    <#--<#assign createArray = [1,3,5]>-->
+    <#--<#assign updateArray = [2,3,6]>-->
+    <#--<#assign deleteArray=[4,5,6]>-->
+    <#--<#assign result="">-->
+    <#--<#if dataSync.getEventType?? && dataSync.getEventType()??>-->
+        <#--<#assign type=dataSync.getEventType()>-->
+        <#--<#assign isCreate=createArray?seq_contains(type)>-->
+        <#--<#assign isUpdate=updateArray?seq_contains(type)>-->
+        <#--<#assign isDelete=deleteArray?seq_contains(type)>-->
+        <#--<#if isCreate>-->
+            <#--<#assign result="execution(*"+pub.getPKGCodeName()+".core.*.service.*"+dataEntity.codeName+"*.create*(..))">-->
+        <#--</#if>-->
+        <#--<#if isUpdate>-->
+            <#--<#if result!="">-->
+                <#--<#assign result=result+"||">-->
+            <#--</#if>-->
+            <#--<#assign result=result+"execution(*"+pub.getPKGCodeName()+".core.*.service.*"+dataEntity.codeName+"*.update*(..))">-->
+        <#--</#if>-->
+        <#--<#if isDelete>-->
+            <#--<#if result!="">-->
+                <#--<#assign result=result+"||">-->
+            <#--</#if>-->
+            <#--<#assign result=result+"execution(*"+pub.getPKGCodeName()+".core.*.service.*"+dataEntity.codeName+"*.remove*(..))">-->
+        <#--</#if>-->
+    <#--</#if>-->
+    <#--<#return "("+result+")">-->
+<#--</#function>-->
\ No newline at end of file