消息队列切点

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

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