实体数据同步逻辑优化（remove）

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

@@ -95,7 +95,7 @@ public class RocketMQListenerProcessor implements MessageListenerOrderly {
                                 <#if inputAction?lower_case == 'get' || inputAction?lower_case == 'remove'>
                     body = toObject(messageExt.getBody());
                     if (!ObjectUtils.isEmpty(body)) {
-                        ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.domain.${entityName} domain = new ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.domain.${entityName};
+                        ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.domain.${entityName} domain = new ${pub.getPKGCodeName()}.core.${dataEntity.getPSSystemModule().getCodeName()?lower_case}.domain.${entityName}();
                         domain.set("${columnname}",body);
                         ${entityName}Service.${inputAction}(domain.get${srfcaseformat(dataEntity.getKeyPSDEField().codeName,'l_u2lC')?cap_first}());
                     }
@@ -106,7 +106,6 @@ public class RocketMQListenerProcessor implements MessageListenerOrderly {
                     body = strBody;
                                 </#if>
                 }
-                log.info("MQ消息topic={}, tags={}, 消息内容={}", topic, tags, body);
                             <#else>
                 log.info("接收到[{}]消息，但未配置实体输入过滤行为，消息将被忽略。"+new String(messageExt.getBody()));
                             </#if>
@@ -114,6 +113,7 @@ public class RocketMQListenerProcessor implements MessageListenerOrderly {
                     </#list>
                 </#if>
             </#list>
+                log.info("MQ消息topic={}, tags={}, 消息内容={}", topic, tags, body);
             } catch (Exception e) {
                 log.error("获取MQ消息内容异常{}", e);
             }