消息配置

SLN/%PUBPRJ%-util/src/main/resources/application-sys.yml.ftl

@@ -12,6 +12,8 @@ TARGET=PSSYSTEM
 <#assign bDynamicDS=false>
 <#assign bmogo=false>
 <#assign mongodbUri="mongodb://"+sys.name+":"+sys.name+"@127.0.0.1:27017/"+sys.name>
+<#assign hasMQProducer=false>
+<#assign hasMQConsumer=false>
 <#if sys.getAllPSDataEntities()??>
     <#list sys.getAllPSDataEntities() as de>
         <#if de.getStorageMode()?? && de.getStorageMode()==2>
@@ -323,6 +325,64 @@ seata:
       password: "${nacosPassWord}"     #密码
 </#if>
 
+<#assign producerMQServer="127.0.0.1:9876">
+<#assign consumerMQServer="127.0.0.1:9876">
+<#assign producerisOnOff="off">
+<#assign consumerisOnOff="off">
+<#assign producerGroupName="default">
+<#assign consumerGroupName="default">
+<#assign producerTopic="default">
+<#assign consumerTopic="default">
+<#if sys.getAllPSDevSlnMSDepAPIs()??>
+    <#list sys.getAllPSDevSlnMSDepAPIs() as depSysApi>
+        <#if depSysApi.getPSDCMSPlatform()?? >
+            <#if depSysApi.getUserParam("rocketmq.producer.namesrvAddr","")??>
+                <#assign hasMQProducer=true>
+                <#assign producerMQServer=depSysApi.getUserParam("rocketmq.producer.namesrvAddr","")>
+                <#if depSysApi.getUserParam("rocketmq.producer.isOnOff","")??>
+                    <#assign producerMQServer=depSysApi.getUserParam("rocketmq.producer.isOnOff","")>
+                </#if>
+                <#if depSysApi.getUserParam("rocketmq.producer.groupName","")??>
+                    <#assign producerGroupName=depSysApi.getUserParam("rocketmq.producer.groupName","")>
+                </#if>
+                <#if depSysApi.getUserParam("rocketmq.producer.topic","")??>
+                    <#assign producerTopic=depSysApi.getUserParam("rocketmq.producer.topic","")>
+                </#if>
+            </#if>
+            <#if depSysApi.getUserParam("rocketmq.consumer.namesrvAddr","")??>
+                <#assign hasMQConsumer=true>
+                <#assign consumerMQServer=depSysApi.getUserParam("rocketmq.consumer.namesrvAddr","")>
+                <#if depSysApi.getUserParam("rocketmq.consumer.isOnOff","")??>
+                    <#assign consumerisOnOff=depSysApi.getUserParam("rocketmq.consumer.isOnOff","")>
+                </#if>
+                <#if depSysApi.getUserParam("rocketmq.consumer.groupName","")??>
+                    <#assign consumerGroupName=depSysApi.getUserParam("rocketmq.consumer.groupName","")>
+                </#if>
+                <#if depSysApi.getUserParam("rocketmq.consumer.topic","")??>
+                    <#assign consumerTopic=depSysApi.getUserParam("rocketmq.consumer.topic","")>
+                </#if>
+            </#if>
+        </#if>
+    </#list>
+</#if>
+<#if hasMQProducer ||hasMQConsumer>
+rocketmq:
+    <#if hasMQProducer>
+  producer:
+    namesrvAddr: ${producerMQServer}
+    isOnOff: '${producerisOnOff}'
+    groupName: ${producerGroupName}
+    topic: ${producerTopic}
+    </#if>
+    <#if hasMQConsumer>
+  consumer:
+    namesrvAddr: ${consumerMQServer}
+    isOnOff: '${consumerisOnOff}'
+    groupName: ${consumerGroupName}
+    topic: ${consumerTopic}
+    </#if>
+</#if>
+
 <#macro singleDatasourceConfig>
   datasource:
     username: ${dbUserName}