适配rocketmq

SLN/%PUBPRJ%-core/src/main/java/%SYS_PKGPATH%/core/util/config/RocketMQConfig.java.ftl

@@ -73,6 +73,7 @@ public class RocketMQConfig {
                 <#if dataSync.getInPSSysDataSyncAgent?? && dataSync.getInPSSysDataSyncAgent()??>
                     <#assign syncAgent=dataSync.getInPSSysDataSyncAgent()>
                     <#assign consumer=dataEntity.codeName+syncAgent.codeName+"consumer">
+                    <#assign entityName=dataEntity.getCodeName()>
                     <#if ((syncAgent.getAgentTag())!'')!=''>
                         <#assign nameAddress=syncAgent.getAgentTag()>
                     </#if>
@@ -80,7 +81,7 @@ public class RocketMQConfig {
                         <#assign instanceName=syncAgent.getAgentTag2()>
                     </#if>
     @Autowired
-    ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.service.I${dataEntity}Service ${dataEntity}Service;
+    ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.service.I${entityName}Service ${entityName}Service;
 
     @Bean("${consumer}")
     public DefaultMQPushConsumer ${srfmethodname(consumer)}(){
@@ -97,8 +98,8 @@ public class RocketMQConfig {
                     for (MessageExt msg : msgs) {
                         <#if dataSync.getInTestPSDEAction()??>
                         <#assign inputAction=srfmethodname(dataSync.getInTestPSDEAction().codeName)>
-                        ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.domain.${dataEntity.getCodeName()} domain = JSON.parseObject(new String(msg.getBody()),${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.domain.${dataEntity.getCodeName()}.class);
-                        ${dataEntity}Service.${inputAction}(domain);
+                        ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.domain.${entityName} domain = JSON.parseObject(new String(msg.getBody()),${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.domain.${entityName}.class);
+                        ${entityName}Service.${inputAction}(domain);
                         <#else>
                         log.info("接收到[]消息，但未配置实体输入过滤行为，消息将被忽略。"+new String(msg.getBody()));
                         </#if>