From 1a20adbee4043a7b4a9e51565e7ac0f99d06c36d Mon Sep 17 00:00:00 2001 From: wzy <wzy19931122ai@163.com> Date: Sat, 24 Apr 2021 20:21:24 +0800 Subject: [PATCH] Merge branch 'data_move' of http://120.27.238.55:7000/r/beauty-erp into data_move --- zq-erp/src/test/java/com/matrix/SourceFlowTests.java | 44 +++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 41 insertions(+), 3 deletions(-) diff --git a/zq-erp/src/test/java/com/matrix/SourceFlowTests.java b/zq-erp/src/test/java/com/matrix/SourceFlowTests.java index 6cc43c8..11b72f6 100644 --- a/zq-erp/src/test/java/com/matrix/SourceFlowTests.java +++ b/zq-erp/src/test/java/com/matrix/SourceFlowTests.java @@ -1,11 +1,16 @@ 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.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; @@ -48,7 +53,31 @@ @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 @@ -124,7 +153,7 @@ for (SysOrder sysOrder : sysOrders) { sysOrder.setCashPay(sysOrder.getZkTotal()); - sysOrder.setCardPay(0); + sysOrder.setCardPay(0D); sysOrderDao.update(sysOrder); List<SysOrderItem> items = sysOrderItemDao.selectByOrderId(sysOrder.getId()); @@ -171,4 +200,13 @@ } } + @Autowired + private ShopSalesmanApplyDao salesmanApplyDao; + + @Test + public void inPageTest() { + Page<SalesmanVo> page = new Page<>(1, 10); + salesmanApplyDao.selectInvitationuserInPage(page, "oLdgp47g7SXJnmti1iDzQaJpXNz4"); + } + } -- Gitblit v1.9.1