| | |
| | | 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.constance.Dictionary; |
| | | import com.matrix.system.fenxiao.dao.ShopSalesmanApplyDao; |
| | | import com.matrix.system.fenxiao.entity.ShopSalesmanApply; |
| | | import com.matrix.system.hive.bean.*; |
| | | import com.matrix.system.hive.dao.*; |
| | | import com.matrix.system.hive.service.CodeService; |
| | | import com.matrix.system.hive.service.SysOrderService; |
| | | 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 |
| | |
| | | |
| | | for (SysOrder sysOrder : sysOrders) { |
| | | sysOrder.setCashPay(sysOrder.getZkTotal()); |
| | | sysOrder.setCardPay(0); |
| | | sysOrder.setCardPay(0D); |
| | | sysOrderDao.update(sysOrder); |
| | | |
| | | List<SysOrderItem> items = sysOrderItemDao.selectByOrderId(sysOrder.getId()); |
| | |
| | | @Autowired |
| | | private ShopSalesmanApplyDao salesmanApplyDao; |
| | | |
| | | @Test |
| | | public void inPageTest() { |
| | | Page<ShopSalesmanApply> page = new Page<>(1, 10); |
| | | salesmanApplyDao.selectInvitationuserInPage(page, "oLdgp47g7SXJnmti1iDzQaJpXNz4"); |
| | | } |
| | | |
| | | |
| | | } |