diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java index 3ed39bb..69d5514 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java @@ -1,6 +1,7 @@ package cn.estsh.i3plus.core.apiservice.mq; import cn.estsh.i3plus.platform.common.util.CommonConstWords; +import cn.estsh.i3plus.platform.common.util.PlatformConstWords; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.amqp.core.*; @@ -71,4 +72,29 @@ public class I3CoreQueueConfig { //LOGGER.info("【DEMO_CLOUD_WMS】"); return new Queue(DEMO_CLOUD_WMS); } + + @Bean + public Queue getQueueIMPP_MESSAGE_LETTER_QUEUE() throws Exception { + return new Queue(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE); + } + + @Bean + public Queue getQueueIMPP_MESSAGE_LETTER_QUEUE_BAK() throws Exception { + return new Queue(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK); + } + + @Bean + public Queue getQueueIMPP_MESSAGE_MAIL_QUEUE() throws Exception { + return new Queue(PlatformConstWords.IMPP_MESSAGE_MAIL_QUEUE); + } + + @Bean + public Queue getQueueSWEB_NOTICE_QUEUE() throws Exception { + return new Queue(PlatformConstWords.SWEB_NOTICE_QUEUE); + } + + @Bean + public Queue getQueueIMPP_SCHEDULE_QUEUE() throws Exception { + return new Queue(PlatformConstWords.IMPP_SCHEDULE_QUEUE); + } } diff --git a/modules/i3plus-core-apiservice/src/test/java/test/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/TestMongoDb.java b/modules/i3plus-core-apiservice/src/test/java/test/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/TestMongoDb.java new file mode 100644 index 0000000..148bbb3 --- /dev/null +++ b/modules/i3plus-core-apiservice/src/test/java/test/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/TestMongoDb.java @@ -0,0 +1,66 @@ +package test.cn.estsh.i3plus.core.apiservice.serviceimpl.busi; + +import cn.estsh.i3plus.core.api.iservice.busi.ISysLogExceptionService; +import cn.estsh.i3plus.core.api.iservice.busi.ISysLogSystemService; +import cn.estsh.i3plus.core.apiservice.serviceimpl.busi.TestBase; +import cn.estsh.i3plus.pojo.base.bean.ListPager; +import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.platform.platbean.SysLogException; +import cn.estsh.i3plus.pojo.platform.platbean.SysLogSystem; +import com.alibaba.fastjson.JSON; +import org.junit.Test; +import org.springframework.beans.factory.annotation.Autowired; + +import javax.transaction.Transactional; +import java.util.List; + +/** + * @Description : + * @Reference : + * @Author : alwaysfrin + * @CreateDate : 2019-04-09 14:38 + * @Modify: + **/ +public class TestMongoDb extends TestBase { + + + @Autowired + private ISysLogExceptionService sysLogExceptionService; + + @Autowired + private ISysLogSystemService syslogSystemService; + + /** + * 测试 查询所有系统参数 + */ + @Test + @Transactional + public void testListSysConfig() { + Pager pager = new Pager(); + pager.setStartRow(0); + pager.setPageSize(10); + + SysLogException sysLogException = new SysLogException(); + + ListPager logExceptionList = sysLogExceptionService.querySysLogExceptionByPager(sysLogException, pager); + System.out.println(logExceptionList); + } + + + @Test + @Transactional + public void testListSysLogSystem() { + Pager pager = new Pager(); + pager.setStartRow(0); + pager.setPageSize(10); + + SysLogSystem logSystem = new SysLogSystem(); + logSystem.setLogLevel(1); + logSystem.setLogModuleId(1); + + System.out.println("2==============="); + ListPager logSystemList = syslogSystemService.querySysLogSystemByPager(logSystem,pager); + System.out.println(logSystemList.getObjectList().size()); + System.out.println("===============pager:" + pager); + } +}