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 public class OtcTest { @Autowired private OtcProducter otcProducter; @Test public void rabbitTest() { 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"); } }