| | |
| | | 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; |
| | | |
| | | /** |
| | | * 企业付款到个人 |
| | | * @throws InterruptedException |
| | | */ |
| | | @Test |
| | | public void testPay() throws InterruptedException { |
| | | weixinServiceUtil.comPay("提现","TX123",1,"oJkRK4yelehsY4S7I6Ee1ydWtQMI",36L); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 发送订阅消息 |
| | | * @throws InterruptedException |
| | | */ |
| | | @Test |
| | | public void testTopic() throws InterruptedException { |
| | | rabiitMqTemplate.sendTopicMsg(RabbitMqConfig.MQ_EXCHANGE_TOPIC +"dev", MQTaskRouting.CREATE_ORDER+"dev", "123"); |
| | | Thread.sleep(10000); |
| | | } |
| | | |
| | | @Test |
| | | @Transactional |
| | |
| | | } |
| | | } |
| | | |
| | | @Autowired |
| | | private ShopSalesmanApplyDao salesmanApplyDao; |
| | | |
| | | |
| | | |
| | | } |