基于区块链技术的在线购物平台源码+项目说明+数据库（使用加密货币进行支付+可用于商品追溯）.zip

package com.snow.chainshop.module.pay.service.order; import cn.hutool.extra.spring.SpringUtil; import com.snow.chainshop.framework.common.pojo.PageResult; import com.snow.chainshop.framework.pay.core.client.PayClient; import com.snow.chainshop.framework.pay.core.client.PayClientFactory; import com.snow.chainshop.framework.pay.core.client.dto.order.PayOrderRespDTO; import com.snow.chainshop.framework.pay.core.enums.channel.PayChannelEnum; import com.snow.chainshop.framework.pay.core.enums.order.PayOrderDisplayModeEnum; import com.snow.chainshop.framework.pay.core.enums.order.PayOrderStatusRespEnum; import com.snow.chainshop.framework.test.core.ut.BaseDbAndRedisUnitTest; import com.snow.chainshop.module.pay.api.order.dto.PayOrderCreateReqDTO; import com.snow.chainshop.module.pay.controller.admin.order.vo.PayOrderExportReqVO; import com.snow.chainshop.module.pay.controller.admin.order.vo.PayOrderPageReqVO; import com.snow.chainshop.module.pay.controller.admin.order.vo.PayOrderSubmitReqVO; import com.snow.chainshop.module.pay.controller.admin.order.vo.PayOrderSubmitRespVO; import com.snow.chainshop.module.pay.dal.dataobject.app.PayAppDO; import com.snow.chainshop.module.pay.dal.dataobject.channel.PayChannelDO; import com.snow.chainshop.module.pay.dal.dataobject.order.PayOrderDO; import com.snow.chainshop.module.pay.dal.dataobject.order.PayOrderExtensionDO; import com.snow.chainshop.module.pay.dal.mysql.order.PayOrderExtensionMapper; import com.snow.chainshop.module.pay.dal.mysql.order.PayOrderMapper; import com.snow.chainshop.module.pay.dal.redis.no.PayNoRedisDAO; import com.snow.chainshop.module.pay.enums.notify.PayNotifyTypeEnum; import com.snow.chainshop.module.pay.enums.order.PayOrderStatusEnum; import com.snow.chainshop.module.pay.framework.pay.config.PayProperties; import com.snow.chainshop.module.pay.service.app.PayAppService; import com.snow.chainshop.module.pay.service.channel.PayChannelService; import com.snow.chainshop.module.pay.service.notify.PayNotifyService; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.mockito.MockedStatic; import org.springframework.boot.test.mock.mockito.MockBean; import org.springframework.context.annotation.Import; import javax.annotation.Resource; import java.time.Duration; import java.time.LocalDateTime; import java.util.List; import static com.snow.chainshop.framework.common.util.date.LocalDateTimeUtils.*; import static com.snow.chainshop.framework.common.util.json.JsonUtils.toJsonString; import static com.snow.chainshop.framework.common.util.object.ObjectUtils.cloneIgnoreId; import static com.snow.chainshop.framework.test.core.util.AssertUtils.assertPojoEquals; import static com.snow.chainshop.framework.test.core.util.AssertUtils.assertServiceException; import static com.snow.chainshop.framework.test.core.util.RandomUtils.*; import static com.snow.chainshop.module.pay.enums.ErrorCodeConstants.*; import static org.assertj.core.api.Assertions.assertThat; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.mockito.ArgumentMatchers.*; import static org.mockito.Mockito.*; /** * {@link PayOrderServiceImpl} 的单元测试类 * * @author 芋艿 */ @Import({PayOrderServiceImpl.class, PayNoRedisDAO.class}) public class PayOrderServiceTest extends BaseDbAndRedisUnitTest { @Resource private PayOrderServiceImpl orderService; @Resource private PayOrderMapper orderMapper; @Resource private PayOrderExtensionMapper orderExtensionMapper; @MockBean private PayClientFactory payClientFactory; @MockBean private PayProperties properties; @MockBean private PayAppService appService; @MockBean private PayChannelService channelService; @MockBean private PayNotifyService notifyService; @BeforeEach public void setUp() { when(properties.getOrderNotifyUrl()).thenReturn("http://127.0.0.1"); } @Test public void testGetOrder_id() { // mock 数据（PayOrderDO） PayOrderDO order = randomPojo(PayOrderDO.class); orderMapper.insert(order); // 准备参数 Long id = order.getId(); // 调用 PayOrderDO dbOrder = orderService.getOrder(id); // 断言 assertPojoEquals(dbOrder, order); } @Test public void testGetOrder_appIdAndMerchantOrderId() { // mock 数据（PayOrderDO） PayOrderDO order = randomPojo(PayOrderDO.class); orderMapper.insert(order); // 准备参数 Long appId = order.getAppId(); String merchantOrderId = order.getMerchantOrderId(); // 调用 PayOrderDO dbOrder = orderService.getOrder(appId, merchantOrderId); // 断言 assertPojoEquals(dbOrder, order); } @Test public void testGetOrderCountByAppId() { // mock 数据（PayOrderDO） PayOrderDO order01 = randomPojo(PayOrderDO.class); orderMapper.insert(order01); PayOrderDO order02 = randomPojo(PayOrderDO.class); orderMapper.insert(order02); // 准备参数 Long appId = order01.getAppId(); // 调用 Long count = orderService.getOrderCountByAppId(appId); // 断言 assertEquals(count, 1L); } @Test public void testGetOrderPage() { // mock 数据 PayOrderDO dbOrder = randomPojo(PayOrderDO.class, o -> { // 等会查询到 o.setAppId(1L); o.setChannelCode(PayChannelEnum.WX_PUB.getCode()); o.setMerchantOrderId("110"); o.setChannelOrderNo("220"); o.setNo("330"); o.setStatus(PayOrderStatusEnum.SUCCESS.getStatus()); o.setCreateTime(buildTime(2018, 1, 15)); }); orderMapper.insert(dbOrder); // 测试 appId 不匹配 orderMapper.insert(cloneIgnoreId(dbOrder, o -> o.setAppId(2L))); // 测试 channelCode 不匹配 orderMapper.insert(cloneIgnoreId(dbOrder, o -> o.setChannelCode(PayChannelEnum.ALIPAY_APP.getCode()))); // 测试 merchantOrderId 不匹配 orderMapper.insert(cloneIgnoreId(dbOrder, o -> o.setMerchantOrderId(randomString()))); // 测试 channelOrderNo 不匹配 orderMapper.insert(cloneIgnoreId(dbOrder, o -> o.setChannelOrderNo(randomString()))); // 测试 no 不匹配 orderMapper.insert(cloneIgnoreId(dbOrder, o -> o.setNo(randomString()))); // 测试 status 不匹配 orderMapper.insert(cloneIgnoreId(dbOrder, o -> o.setStatus(PayOrderStatusEnum.CLOSED.getStatus()))); // 测试 createTime 不匹配 orderMapper.insert(cloneIgnoreId(dbOrder, o -> o.setCreateTime(buildTime(2019, 1, 1)))); // 准备参数 PayOrderPageReqVO reqVO = new PayOrderPageReqVO(); reqVO.setAppId(1L); reqVO.setChannelCode(PayChannelEnum.WX_PUB.getCode()); reqVO.setMerchantOrderId("11"); reqVO.setChannelOrderNo("22"); reqVO.setNo("33"); reqVO.setStatus(PayOrderStatusEnum.SUCCESS.getStatus()); reqVO.setCreateTime(buildBetweenTime(2018, 1, 10, 2018, 1, 30)); // 调用 PageResult<PayOrderDO> pageResult = orderService.getOrderPage(reqVO); // 断言 assertEquals(1, pageResult.getTotal()); assertEquals(1, pageResult.getList().size()); assertPojoEquals(dbOrder, pageResult.getList().get(0)); } @Test public void testGetOrderList() { // mock 数据 PayOrderDO dbOrder = randomPojo(PayOrderDO.class, o -> { // 等会查询到 o.setAppId(1L); o.setChannelCode(PayChannelEnum.WX_PUB.getCode()); o.setMerchantOrderId("110"); o.setChannelOrderNo("220"); o.setNo("330"); o.setStatus(PayOrderStatusEnum.SUCCESS.getStatus()); o.setCreateTime(buildTime(2018, 1, 15)); }); orderMap