|  |  | 
 |  |  | package com.matrix; | 
 |  |  |  | 
 |  |  | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; | 
 |  |  | import com.matrix.component.rabbitmq.RabiitMqTemplate; | 
 |  |  | import com.matrix.component.wechat.externalInterface.weixinUtil.WeixinServiceUtil; | 
 |  |  | import com.matrix.config.RabbitMqConfig; | 
 |  |  | import com.matrix.core.tools.StringUtils; | 
 |  |  | import com.matrix.system.fenxiao.dao.ShopSalesmanApplyDao; | 
 |  |  | import com.matrix.system.hive.bean.*; | 
 |  |  | import com.matrix.system.hive.dao.*; | 
 |  |  | import com.matrix.system.hive.service.CodeService; | 
 |  |  | import com.matrix.system.shopXcx.mqTask.MQTaskRouting; | 
 |  |  | import com.matrix.system.shopXcx.vo.SalesmanVo; | 
 |  |  | import org.junit.Test; | 
 |  |  | import org.junit.runner.RunWith; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | 
 |  |  |    @Autowired | 
 |  |  |    private SysVipInfoDao vipInfoDao; | 
 |  |  |  | 
 |  |  |    @Autowired | 
 |  |  |    RabiitMqTemplate rabiitMqTemplate; | 
 |  |  | @Autowired | 
 |  |  | WeixinServiceUtil weixinServiceUtil; | 
 |  |  |  | 
 |  |  | 
 |  |  |     */ | 
 |  |  |    @Test | 
 |  |  |    public void testTopic() throws InterruptedException { | 
 |  |  |       rabiitMqTemplate.sendTopicMsg(RabbitMqConfig.MQ_EXCHANGE_TOPIC +"dev", MQTaskRouting.CREATE_ORDER+"dev", "123"); | 
 |  |  |       // rabiitMqTemplate.sendTopicMsg(RabbitMqConfig.MQ_EXCHANGE_TOPIC +"dev", MQTaskRouting.CREATE_ORDER+"dev", "123"); | 
 |  |  |       Thread.sleep(10000); | 
 |  |  |    } | 
 |  |  |  | 
 |  |  | 
 |  |  |    @Autowired | 
 |  |  |    private ShopSalesmanApplyDao salesmanApplyDao; | 
 |  |  |  | 
 |  |  |    @Test | 
 |  |  |    public void inPageTest() { | 
 |  |  |       Page<SalesmanVo> page = new Page<>(1, 10); | 
 |  |  |       salesmanApplyDao.selectInvitationuserInPage(page, "oLdgp47g7SXJnmti1iDzQaJpXNz4"); | 
 |  |  |    } | 
 |  |  |  | 
 |  |  |  | 
 |  |  | } |