适配rocketmq

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

@@ -80,7 +80,7 @@ public class RocketMQConfig {
                         <#assign instanceName=syncAgent.getAgentTag2()>
                     </#if>
     @Autowired
-    ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.service.I${pub.getPKGCodeName()}Service ${pub.getPKGCodeName()}Service;
+    ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.service.I${dataEntity}Service ${dataEntity}Service;
 
     @Bean("${consumer}")
     public DefaultMQPushConsumer ${srfmethodname(consumer)}(){
@@ -98,7 +98,7 @@ public class RocketMQConfig {
                         <#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);
-                        ${pub.getPKGCodeName()}Service.${inputAction}(domain);
+                        ${dataEntity}Service.${inputAction}(domain);
                         <#else>
                         log.info("接收到[]消息，但未配置实体输入过滤行为，消息将被忽略。"+new String(msg.getBody()));
                         </#if>