| | |
| | | package com.xcong.excoin; |
| | | |
| | | import cn.hutool.crypto.SecureUtil; |
| | | import com.xcong.excoin.common.system.dto.RegisterDto; |
| | | import com.xcong.excoin.modules.member.dao.MemberDao; |
| | | import com.xcong.excoin.modules.member.dao.MemberPaymentMethodDao; |
| | | import com.xcong.excoin.modules.member.entity.MemberEntity; |
| | | import com.xcong.excoin.modules.member.entity.MemberPaymentMethodEntity; |
| | | import com.xcong.excoin.modules.otc.dao.OtcMarketBussinessDao; |
| | | import com.xcong.excoin.modules.otc.entity.OtcMarketBussiness; |
| | | import com.xcong.excoin.quartz.job.OtcOrderJob; |
| | | import com.xcong.excoin.rabbit.consumer.OtcConsumer; |
| | | import com.xcong.excoin.rabbit.producer.OtcProducter; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.junit.jupiter.api.Test; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.boot.test.context.SpringBootTest; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.util.concurrent.TimeUnit; |
| | | |
| | | @Slf4j |
| | | @SpringBootTest |
| | |
| | | |
| | | @Test |
| | | public void rabbitTest() { |
| | | otcProducter.sendMarketBussinessMsg("123456"); |
| | | otcProducter.sendDelayOrderMsg("123456"); |
| | | |
| | | while(true){ |
| | | try { |
| | | TimeUnit.SECONDS.sleep(1); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | | } |
| | | } |
| | | |
| | | @Autowired |
| | | // private OtcOrderJob otcOrderJob; |
| | | |
| | | @Test |
| | | public void jobTest() { |
| | | // otcOrderJob.marketBussinessJob(); |
| | | } |
| | | |
| | | @Test |
| | | public void mbProducterTest() { |
| | | // otcProducter.sendMarketBussinessMsg(11L, 3); |
| | | } |
| | | |
| | | @Autowired |
| | | private MemberDao memberDao; |
| | | |
| | | @Autowired |
| | | private OtcMarketBussinessDao otcMarketBussinessDao; |
| | | |
| | | @Autowired |
| | | private MemberPaymentMethodDao memberPaymentMethodDao; |
| | | |
| | | @Test |
| | | // @Transactional(rollbackFor = Exception.class) |
| | | public void mbInsertTest() { |
| | | for(int i = 0; i < 50; i++) { |
| | | String phonePrefix = "199999999"; |
| | | if (i < 10) { |
| | | phonePrefix = phonePrefix + "0" + i; |
| | | } else { |
| | | phonePrefix = phonePrefix + i; |
| | | } |
| | | |
| | | MemberEntity member = memberDao.selectMemberInfoByAccount(phonePrefix); |
| | | |
| | | OtcMarketBussiness otcMb = new OtcMarketBussiness(); |
| | | otcMb.setMemberId(member.getId()); |
| | | otcMb.setAvgCoinTime(0); |
| | | otcMb.setAvgPayTime(0); |
| | | otcMb.setTotalOrderCnt(0); |
| | | otcMb.setBuyCnt(0); |
| | | otcMb.setFinishRatio(BigDecimal.ZERO); |
| | | otcMb.setStatus(OtcMarketBussiness.CHECK_PASS); |
| | | |
| | | member.setIsTrader(1); |
| | | member.setCertifyStatus(2); |
| | | member.setTradePassword(SecureUtil.md5("123456")); |
| | | |
| | | memberDao.updateById(member); |
| | | otcMarketBussinessDao.insert(otcMb); |
| | | |
| | | MemberPaymentMethodEntity memberPaymentMethodEntity = new MemberPaymentMethodEntity(); |
| | | memberPaymentMethodEntity.setMemberId(member.getId()); |
| | | memberPaymentMethodEntity.setAccount("123456789"); |
| | | memberPaymentMethodEntity.setBank("中国银行"); |
| | | memberPaymentMethodEntity.setName("无名"); |
| | | memberPaymentMethodEntity.setPaymentType(MemberPaymentMethodEntity.PAYMENTTYPE_CARD.toString()); |
| | | memberPaymentMethodEntity.setSubBank("中国银行"); |
| | | memberPaymentMethodEntity.setIsDefualt("1"); |
| | | memberPaymentMethodDao.insert(memberPaymentMethodEntity); |
| | | } |
| | | } |
| | | |
| | | @Test |
| | | public void bigdecimalTest() { |
| | | BigDecimal one = BigDecimal.valueOf(6.39); |
| | | BigDecimal two = BigDecimal.valueOf(3129.860025); |
| | | BigDecimal three = BigDecimal.valueOf(19999.80); |
| | | |
| | | BigDecimal cny = one.multiply(two).setScale(2, BigDecimal.ROUND_DOWN); |
| | | BigDecimal usdt = three.divide(one, 2, BigDecimal.ROUND_DOWN); |
| | | System.out.println(cny.compareTo(three) != 0 && usdt.compareTo(two) != 0); |
| | | } |
| | | |
| | | // @Autowired |
| | | // private OtcConsumer otcConsumer; |
| | | |
| | | @Test |
| | | public void returnMoneyTest() { |
| | | // otcConsumer.orderReturn("20210605446780002"); |
| | | // otcProducter.sendOrderReturn("20210605446780002"); |
| | | } |
| | | } |