diff --git a/mhd_product/src/main/java/com/linke/product/application/event/menu/publish/MenuPublish.java b/mhd_product/src/main/java/com/linke/product/application/event/menu/publish/MenuPublish.java index cc75227ae..e0b66266b 100644 --- a/mhd_product/src/main/java/com/linke/product/application/event/menu/publish/MenuPublish.java +++ b/mhd_product/src/main/java/com/linke/product/application/event/menu/publish/MenuPublish.java @@ -1,3 +1,4 @@ +/* package com.linke.product.application.event.menu.publish; import com.linke.product.infrastructure.util.mq.MenuChannel; @@ -6,13 +7,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding; import org.springframework.messaging.support.MessageBuilder; import org.springframework.stereotype.Service; +*/ /** * 消息发布 * * 2022-12-21 * * @author 王子豪 - */ + *//* + @EnableBinding(value = { MenuChannel.class }) @Service public class MenuPublish { @@ -27,3 +30,4 @@ public class MenuPublish { source.outputLog().send(MessageBuilder.withPayload(content).build()); } } +*/ diff --git a/mhd_product/src/main/java/com/linke/product/application/event/menu/subscribe/MenuSubscribe.java b/mhd_product/src/main/java/com/linke/product/application/event/menu/subscribe/MenuSubscribe.java index 2cf9163ac..1ad67b19d 100644 --- a/mhd_product/src/main/java/com/linke/product/application/event/menu/subscribe/MenuSubscribe.java +++ b/mhd_product/src/main/java/com/linke/product/application/event/menu/subscribe/MenuSubscribe.java @@ -1,3 +1,4 @@ +/* package com.linke.product.application.event.menu.subscribe; import com.linke.product.infrastructure.util.mq.MenuChannel; @@ -5,13 +6,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding; import org.springframework.cloud.stream.annotation.StreamListener; import org.springframework.messaging.Message; +*/ /** * 消息接收 * * 2022-12-1 * * @author 王子豪 - */ + *//* + @EnableBinding(value = { MenuChannel.class }) public class MenuSubscribe { @@ -29,3 +32,4 @@ public class MenuSubscribe { // menuApplicationService.selectTreeMenu(); } } +*/ diff --git a/mhd_product/src/main/java/com/linke/product/application/event/modules/publish/ModulesPublish.java b/mhd_product/src/main/java/com/linke/product/application/event/modules/publish/ModulesPublish.java index b632b7a98..2e6e7de6c 100644 --- a/mhd_product/src/main/java/com/linke/product/application/event/modules/publish/ModulesPublish.java +++ b/mhd_product/src/main/java/com/linke/product/application/event/modules/publish/ModulesPublish.java @@ -1,3 +1,4 @@ +/* package com.linke.product.application.event.modules.publish; import com.linke.product.infrastructure.util.mq.ModulesChannel; @@ -6,13 +7,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding; import org.springframework.messaging.support.MessageBuilder; import org.springframework.stereotype.Service; +*/ /** * 消息发布 * * 2022-12-1 * * @author 王子豪 - */ + *//* + @EnableBinding(value = { ModulesChannel.class }) @Service public class ModulesPublish { @@ -27,3 +30,4 @@ public class ModulesPublish { source.outputLog().send(MessageBuilder.withPayload(content).build()); } } +*/ diff --git a/mhd_product/src/main/java/com/linke/product/application/event/modules/subscribe/ModulesSubscribe.java b/mhd_product/src/main/java/com/linke/product/application/event/modules/subscribe/ModulesSubscribe.java index 3994b5299..1c54cab68 100644 --- a/mhd_product/src/main/java/com/linke/product/application/event/modules/subscribe/ModulesSubscribe.java +++ b/mhd_product/src/main/java/com/linke/product/application/event/modules/subscribe/ModulesSubscribe.java @@ -1,3 +1,4 @@ +/* package com.linke.product.application.event.modules.subscribe; import com.linke.product.infrastructure.util.mq.ModulesChannel; @@ -5,13 +6,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding; import org.springframework.cloud.stream.annotation.StreamListener; import org.springframework.messaging.Message; +*/ /** * 消息接收 * * 2022-12-1 * * @author 王子豪 - */ + *//* + @EnableBinding(value = { ModulesChannel.class }) public class ModulesSubscribe { @@ -29,3 +32,4 @@ public class ModulesSubscribe { // sysModulesApplicationService.selectTreeModules(); } } +*/ diff --git a/mhd_product/src/main/java/com/linke/product/application/event/organization/publish/OrganizationPublish.java b/mhd_product/src/main/java/com/linke/product/application/event/organization/publish/OrganizationPublish.java index bb3c36235..fc20a9edb 100644 --- a/mhd_product/src/main/java/com/linke/product/application/event/organization/publish/OrganizationPublish.java +++ b/mhd_product/src/main/java/com/linke/product/application/event/organization/publish/OrganizationPublish.java @@ -1,3 +1,4 @@ +/* package com.linke.product.application.event.organization.publish; import com.linke.product.infrastructure.util.mq.OrganizationChannel; @@ -6,13 +7,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding; import org.springframework.messaging.support.MessageBuilder; import org.springframework.stereotype.Service; +*/ /** * 消息发布 * * 2022-11-22 * * @author 王子豪 - */ + *//* + @EnableBinding(value = { OrganizationChannel.class }) @Service public class OrganizationPublish { @@ -27,3 +30,4 @@ public class OrganizationPublish { source.outputLog().send(MessageBuilder.withPayload(content).build()); } } +*/ diff --git a/mhd_product/src/main/java/com/linke/product/application/event/organization/subscribe/OrganizationSubscribe.java b/mhd_product/src/main/java/com/linke/product/application/event/organization/subscribe/OrganizationSubscribe.java index 515b995f9..e8639c9f9 100644 --- a/mhd_product/src/main/java/com/linke/product/application/event/organization/subscribe/OrganizationSubscribe.java +++ b/mhd_product/src/main/java/com/linke/product/application/event/organization/subscribe/OrganizationSubscribe.java @@ -1,3 +1,4 @@ +/* package com.linke.product.application.event.organization.subscribe; import com.linke.product.application.service.organization.OrganizationApplicationService; @@ -8,13 +9,15 @@ import org.springframework.cloud.stream.annotation.EnableBinding; import org.springframework.cloud.stream.annotation.StreamListener; import org.springframework.messaging.Message; +*/ /** * 消息接收 * * 2022-11-25 * * @author 王子豪 - */ + *//* + @EnableBinding(value = { OrganizationChannel.class }) public class OrganizationSubscribe { @@ -32,3 +35,4 @@ public class OrganizationSubscribe { // organizationASvc.selectTreeOrganization(); } } +*/ diff --git a/mhd_product/src/main/java/com/linke/product/application/service/modules/SysModulesApplicationService.java b/mhd_product/src/main/java/com/linke/product/application/service/modules/SysModulesApplicationService.java index 1ea76498a..31142f0dc 100644 --- a/mhd_product/src/main/java/com/linke/product/application/service/modules/SysModulesApplicationService.java +++ b/mhd_product/src/main/java/com/linke/product/application/service/modules/SysModulesApplicationService.java @@ -1,6 +1,6 @@ package com.linke.product.application.service.modules; -import com.linke.product.application.event.modules.publish.ModulesPublish; +//import com.linke.product.application.event.modules.publish.ModulesPublish; import com.linke.product.domain.modules.entity.ModulesMenu; import com.linke.product.domain.modules.entity.SysModules; import com.linke.product.domain.modules.service.ModulesMenuDomainService; @@ -27,8 +27,8 @@ public class SysModulesApplicationService { private SysModulesDomainService iSysModulesSvc; @Autowired private ModulesMenuDomainService iModulesMenuSvc; - @Autowired - private ModulesPublish modulesPublish; + /*@Autowired + private ModulesPublish modulesPublish;*/ /** * 查询产品中台-模块 diff --git a/mhd_product/src/main/java/com/linke/product/application/service/organization/OrganizationApplicationService.java b/mhd_product/src/main/java/com/linke/product/application/service/organization/OrganizationApplicationService.java index cfe26b550..674dd75a7 100644 --- a/mhd_product/src/main/java/com/linke/product/application/service/organization/OrganizationApplicationService.java +++ b/mhd_product/src/main/java/com/linke/product/application/service/organization/OrganizationApplicationService.java @@ -4,7 +4,7 @@ import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson2.JSONObject; -import com.linke.product.application.event.organization.publish.OrganizationPublish; +//import com.linke.product.application.event.organization.publish.OrganizationPublish; import com.linke.product.domain.common.entity.DataPermission; import com.linke.product.domain.customAuth.service.CustomAuthDomainService; import com.linke.product.domain.customAuth.service.CustomAuthOrganizationDomainService; @@ -72,8 +72,8 @@ public class OrganizationApplicationService { private OrganizationWlhyDomainService organizationWlhyDomainService; @Autowired private OrganizationMenuDomainService iOrganizationMenuSvc; - @Autowired - private OrganizationPublish organizationPublish; + /* @Autowired + private OrganizationPublish organizationPublish;*/ @Autowired private MenuDomainService menuDomainService; @Autowired diff --git a/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/MenuChannel.java b/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/MenuChannel.java index c2c548144..34a7d6369 100644 --- a/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/MenuChannel.java +++ b/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/MenuChannel.java @@ -1,3 +1,4 @@ +/* package com.linke.product.infrastructure.util.mq; import org.springframework.cloud.stream.annotation.Input; @@ -5,6 +6,7 @@ import org.springframework.cloud.stream.annotation.Output; import org.springframework.messaging.MessageChannel; import org.springframework.messaging.SubscribableChannel; +*/ /** * 自定义消息通道 * @@ -12,7 +14,8 @@ import org.springframework.messaging.SubscribableChannel; * 2022-12-1 * * @author 王子豪 - */ + *//* + public interface MenuChannel { String INPUT_LOG = "inputMenu"; @@ -22,3 +25,4 @@ public interface MenuChannel { @Output(OUTPUT_LOG) MessageChannel outputLog(); } +*/ diff --git a/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/ModulesChannel.java b/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/ModulesChannel.java index f53d325a6..ed98671cf 100644 --- a/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/ModulesChannel.java +++ b/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/ModulesChannel.java @@ -1,3 +1,4 @@ +/* package com.linke.product.infrastructure.util.mq; import org.springframework.cloud.stream.annotation.Input; @@ -5,6 +6,7 @@ import org.springframework.cloud.stream.annotation.Output; import org.springframework.messaging.MessageChannel; import org.springframework.messaging.SubscribableChannel; +*/ /** * 自定义消息通道 * @@ -12,7 +14,8 @@ import org.springframework.messaging.SubscribableChannel; * 2022-12-1 * * @author 王子豪 - */ + *//* + public interface ModulesChannel { String INPUT_LOG = "inputModules"; @@ -22,3 +25,4 @@ public interface ModulesChannel { @Output(OUTPUT_LOG) MessageChannel outputLog(); } +*/ diff --git a/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/OrganizationChannel.java b/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/OrganizationChannel.java index 4d9e6539c..5c92a1cef 100644 --- a/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/OrganizationChannel.java +++ b/mhd_product/src/main/java/com/linke/product/infrastructure/util/mq/OrganizationChannel.java @@ -1,3 +1,4 @@ +/* package com.linke.product.infrastructure.util.mq; import org.springframework.cloud.stream.annotation.Input; @@ -5,6 +6,7 @@ import org.springframework.cloud.stream.annotation.Output; import org.springframework.messaging.MessageChannel; import org.springframework.messaging.SubscribableChannel; +*/ /** * 自定义消息通道 * @@ -12,7 +14,8 @@ import org.springframework.messaging.SubscribableChannel; * 2022-11-22 * * @author 王子豪 - */ + *//* + public interface OrganizationChannel { String INPUT_LOG = "inputOrganization"; @@ -22,3 +25,4 @@ public interface OrganizationChannel { @Output(OUTPUT_LOG) MessageChannel outputLog(); } +*/