Skip to content
项目
群组
代码片段
帮助
正在加载...
帮助
提交反馈
为 GitLab 提交贡献
登录
切换导航
iBiz4j Spring R7
项目
项目
详情
动态
版本
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
计划
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
统计图
创建新议题
作业
提交
议题看板
打开侧边栏
iBiz-R7后台标准模板
iBiz4j Spring R7
提交
14e1f4b1
提交
14e1f4b1
编写于
11月 11, 2020
作者:
zhouweidong
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
适配rocketmq
上级
96d71e84
变更
2
隐藏空白字符变更
内嵌
并排
正在显示
2 个修改的文件
包含
6 行增加
和
4 行删除
+6
-4
RocketMQConfig.java.ftl
...va/%SYS_PKGPATH%/core/util/config/RocketMQConfig.java.ftl
+2
-1
RocketMQAspect.java.ftl
...in/java/%SYS_PKGPATH%/util/aspect/RocketMQAspect.java.ftl
+4
-3
未找到文件。
SLN/%PUBPRJ%-core/src/main/java/%SYS_PKGPATH%/core/util/config/RocketMQConfig.java.ftl
浏览文件 @
14e1f4b1
...
@@ -26,6 +26,7 @@ import lombok.extern.slf4j.Slf4j;
...
@@ -26,6 +26,7 @@ import lombok.extern.slf4j.Slf4j;
import
org
.
springframework
.
beans
.
factory
.
annotation
.
Autowired
;
import
org
.
springframework
.
beans
.
factory
.
annotation
.
Autowired
;
import
org
.
springframework
.
context
.
annotation
.
Bean
;
import
org
.
springframework
.
context
.
annotation
.
Bean
;
import
org
.
springframework
.
context
.
annotation
.
Configuration
;
import
org
.
springframework
.
context
.
annotation
.
Configuration
;
import
org
.
springframework
.
context
.
annotation
.
Lazy
;
import
java
.
util
.
List
;
import
java
.
util
.
List
;
@
Slf4j
@
Slf4j
...
@@ -77,13 +78,13 @@ public class RocketMQConfig {
...
@@ -77,13 +78,13 @@ public class RocketMQConfig {
<#
assign
instanceName
=
syncAgent
.
getAgentTag2
()>
<#
assign
instanceName
=
syncAgent
.
getAgentTag2
()>
</#
if
>
</#
if
>
@
Autowired
@
Autowired
@
Lazy
${
pub
.
getPKGCodeName
()}.
core
.${
dataEntity
.
getPSSystemModule
().
getCodeName
()?
lower_case
}.
service
.
I
${
entityName
}
Service
${
entityName
}
Service
;
${
pub
.
getPKGCodeName
()}.
core
.${
dataEntity
.
getPSSystemModule
().
getCodeName
()?
lower_case
}.
service
.
I
${
entityName
}
Service
${
entityName
}
Service
;
@
Bean
(
"${consumer}"
)
@
Bean
(
"${consumer}"
)
public
DefaultMQPushConsumer
${
srfmethodname
(
consumer
)}(){
public
DefaultMQPushConsumer
${
srfmethodname
(
consumer
)}(){
DefaultMQPushConsumer
consumer
=
null
;
DefaultMQPushConsumer
consumer
=
null
;
try
{
try
{
log
.
info
(
"消息消费者"
);
consumer
=
new
DefaultMQPushConsumer
();
consumer
=
new
DefaultMQPushConsumer
();
consumer
.
setNamesrvAddr
(
"${nameAddress}"
);
consumer
.
setNamesrvAddr
(
"${nameAddress}"
);
consumer
.
setInstanceName
(
"${instanceName}"
);
consumer
.
setInstanceName
(
"${instanceName}"
);
...
...
SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/aspect/RocketMQAspect.java.ftl
浏览文件 @
14e1f4b1
...
@@ -17,16 +17,15 @@ package ${pub.getPKGCodeName()}.util.aspect;
...
@@ -17,16 +17,15 @@ package ${pub.getPKGCodeName()}.util.aspect;
import
com
.
alibaba
.
fastjson
.
JSON
;
import
com
.
alibaba
.
fastjson
.
JSON
;
import
com
.
alibaba
.
rocketmq
.
client
.
producer
.
DefaultMQProducer
;
import
com
.
alibaba
.
rocketmq
.
client
.
producer
.
DefaultMQProducer
;
import
com
.
alibaba
.
rocketmq
.
client
.
producer
.
SendResult
;
import
com
.
alibaba
.
rocketmq
.
common
.
message
.
Message
;
import
com
.
alibaba
.
rocketmq
.
common
.
message
.
Message
;
import
lombok
.
extern
.
slf4j
.
Slf4j
;
import
lombok
.
extern
.
slf4j
.
Slf4j
;
import
${
pub
.
getPKGCodeName
()}.
util
.
domain
.
EntityBase
;
import
${
pub
.
getPKGCodeName
()}.
util
.
domain
.
EntityBase
;
import
${
pub
.
getPKGCodeName
()}.
util
.
errors
.
BadRequestAlertException
;
import
org
.
aspectj
.
lang
.
JoinPoint
;
import
org
.
aspectj
.
lang
.
JoinPoint
;
import
org
.
aspectj
.
lang
.
annotation
.
AfterReturning
;
import
org
.
aspectj
.
lang
.
annotation
.
AfterReturning
;
import
org
.
aspectj
.
lang
.
annotation
.
Aspect
;
import
org
.
aspectj
.
lang
.
annotation
.
Aspect
;
import
org
.
springframework
.
beans
.
factory
.
annotation
.
Autowired
;
import
org
.
springframework
.
beans
.
factory
.
annotation
.
Autowired
;
import
org
.
springframework
.
beans
.
factory
.
annotation
.
Qualifier
;
import
org
.
springframework
.
beans
.
factory
.
annotation
.
Qualifier
;
import
org
.
springframework
.
context
.
annotation
.
Lazy
;
import
org
.
springframework
.
expression
.
EvaluationContext
;
import
org
.
springframework
.
expression
.
EvaluationContext
;
import
org
.
springframework
.
expression
.
Expression
;
import
org
.
springframework
.
expression
.
Expression
;
import
org
.
springframework
.
expression
.
ExpressionParser
;
import
org
.
springframework
.
expression
.
ExpressionParser
;
...
@@ -55,13 +54,15 @@ public class RocketMQAspect
...
@@ -55,13 +54,15 @@ public class RocketMQAspect
<#
assign
producer
=
dataEntity
.
codeName
+
syncAgent
.
codeName
+
"producer"
>
<#
assign
producer
=
dataEntity
.
codeName
+
syncAgent
.
codeName
+
"producer"
>
@
Autowired
@
Autowired
@
Qualifier
(
"${producer}"
)
@
Qualifier
(
"${producer}"
)
@
Lazy
DefaultMQProducer
${
producer
};
DefaultMQProducer
${
producer
};
@
AfterReturning
(
value
=
"(execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.create*(..))||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.update*(..))||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.save*(..)) ||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.remove*(..))) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.create*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.update*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.save*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.remove*(..))"
)
@
AfterReturning
(
value
=
"(execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.create*(..))||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.update*(..))||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.save*(..)) ||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.remove*(..))) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.create*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.update*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.save*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.remove*(..))"
)
@
Async
@
Async
public
void
${
srfmethodname
(
producer
)}(
JoinPoint
point
){
public
void
${
srfmethodname
(
producer
)}(
JoinPoint
point
){
<#
if
dataSync
.
getOutTestPSDEAction
??
&&
dataSync
.
getOutTestPSDEAction
()??>
<#
if
dataSync
.
getOutTestPSDEAction
??
&&
dataSync
.
getOutTestPSDEAction
()??>
outputAction
(
point
,
"${dataSync.getOutTestPSDEAction().codeName}"
);
<#
assign
actionName
=
srfmethodname
(
dataSync
.
getOutTestPSDEAction
().
codeName
)>
outputAction
(
point
,
"${actionName}"
);
</#
if
>
</#
if
>
sendMsg
(${
producer
},
"${dataSync.codeName}"
,
"${dataSync.codeName}"
,
getEntity
(
point
));
sendMsg
(${
producer
},
"${dataSync.codeName}"
,
"${dataSync.codeName}"
,
getEntity
(
point
));
}
}
...
...
编辑
预览
Markdown
格式
0%
请重试
or
添加新附件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
先完成此消息的编辑!
取消
想要评论请
注册
或
登录