微服务拆分

用户服务

创建项目

在hmall下新建一个module，定名为user-service：

依靠

user-service的pom.xml文件内容如下：

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5.     <parent>
6.         <artifactId>hmall</artifactId>
7.         <groupId>com.heima</groupId>
8.         <version>1.0.0</version>
9.     </parent>
10.     <modelVersion>4.0.0</modelVersion>
12.     <artifactId>user-service</artifactId>
14.     <properties>
15.         <maven.compiler.source>11</maven.compiler.source>
16.         <maven.compiler.target>11</maven.compiler.target>
17.     </properties>
19.     <dependencies>
20.         <!--common-->
21.         <dependency>
22.             <groupId>com.heima</groupId>
23.             <artifactId>hm-common</artifactId>
24.             <version>1.0.0</version>
25.         </dependency>
26.         <!--api-->
27.         <dependency>
28.             <groupId>com.heima</groupId>
29.             <artifactId>hm-api</artifactId>
30.             <version>1.0.0</version>
31.         </dependency>
32.         <!--web-->
33.         <dependency>
34.             <groupId>org.springframework.boot</groupId>
35.             <artifactId>spring-boot-starter-web</artifactId>
36.         </dependency>
37.         <!--数据库-->
38.         <dependency>
39.             <groupId>mysql</groupId>
40.             <artifactId>mysql-connector-java</artifactId>
41.         </dependency>
42.         <!--mybatis-->
43.         <dependency>
44.             <groupId>com.baomidou</groupId>
45.             <artifactId>mybatis-plus-boot-starter</artifactId>
46.         </dependency>
47.         <!--nacos 服务注册发现-->
48.         <dependency>
49.             <groupId>com.alibaba.cloud</groupId>
50.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
51.         </dependency>
52.     </dependencies>
53.     <build>
54.         <finalName>${project.artifactId}</finalName>
55.         <plugins>
56.             <plugin>
57.                 <groupId>org.springframework.boot</groupId>
58.                 <artifactId>spring-boot-maven-plugin</artifactId>
59.             </plugin>
60.         </plugins>
61.     </build>
62. </project>

复制代码

启动类

在user-service中的com.hmall.user包下创建启动类：

1. package com.hmall.user;
3. import org.mybatis.spring.annotation.MapperScan;
4. import org.springframework.boot.SpringApplication;
5. import org.springframework.boot.autoconfigure.SpringBootApplication;
7. @MapperScan("com.hmall.user.mapper")
8. @SpringBootApplication
9. public class UserApplication {
10.     public static void main(String[] args) {
11.         SpringApplication.run(UserApplication.class, args);
12.     }
13. }

复制代码

设置文件

从hm-service项目中复制3个yaml设置文件到user-service的resource目次。
此中application-dev.yaml和application-local.yaml保持稳固。application.yaml如下：

1. server:
2.   port: 8084
3. spring:
4.   application:
5.     name: user-service # 服务名称
6.   profiles:
7.     active: dev
8.   datasource:
9.     url: jdbc:mysql://${hm.db.host}:3306/hm-user?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
10.     driver-class-name: com.mysql.cj.jdbc.Driver
11.     username: root
12.     password: ${hm.db.pw}
13.   cloud:
14.     nacos:
15.       server-addr: 192.168.150.101 # nacos地址
16. mybatis-plus:
17.   configuration:
18.     default-enum-type-handler: com.baomidou.mybatisplus.core.handlers.MybatisEnumTypeHandler
19.   global-config:
20.     db-config:
21.       update-strategy: not_null
22.       id-type: auto
23. logging:
24.   level:
25.     com.hmall: debug
26.   pattern:
27.     dateformat: HH:mm:ss:SSS
28.   file:
29.     path: "logs/${spring.application.name}"
30. knife4j:
31.   enable: true
32.   openapi:
33.     title: 用户服务接口文档
34.     description: "信息"
35.     email: [email protected]
36.     concat: Charlie
37.     url: https://www.itcast.cn
38.     version: v1.0.0
39.     group:
40.       default:
41.         group-name: default
42.         api-rule: package
43.         api-rule-resources:
44.           - com.hmall.user.controller
45. hm:
46.   jwt:
47.     location: classpath:hmall.jks
48.     alias: hmall
49.     password: hmall123
50.     tokenTTL: 30m

复制代码

将hm-service下的hmall.jks文件拷贝到user-service下的resources目次，这是JWT加密的秘钥文件：

代码

复制hm-service中全部与user、address、jwt有关的代码，终极项目结构如下：

数据库

user-service也须要本身的独立的database，向MySQL中导入课前资料提供的SQL：
通过网盘分享的文件：hm-user.sql
链接:  提取码: ii6b
–来自百度网盘超等会员v5的分享

导入结果如下：

设置启动项

给user-service设置启动项，设置profile为local：

测试

启动UserApplication，访问http://localhost:8084/doc.html#/default/用户相干接口/loginUsingPOST，测试登录接口：

用户服务测试通过。
交易业务服务

创建项目

在hmall下新建一个module，定名为trade-service：

依靠

trade-service的pom.xml文件内容如下：

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5.     <parent>
6.         <artifactId>hmall</artifactId>
7.         <groupId>com.heima</groupId>
8.         <version>1.0.0</version>
9.     </parent>
10.     <modelVersion>4.0.0</modelVersion>
12.     <artifactId>trade-service</artifactId>
14.     <properties>
15.         <maven.compiler.source>11</maven.compiler.source>
16.         <maven.compiler.target>11</maven.compiler.target>
17.     </properties>
19.     <dependencies>
20.         <!--common-->
21.         <dependency>
22.             <groupId>com.heima</groupId>
23.             <artifactId>hm-common</artifactId>
24.             <version>1.0.0</version>
25.         </dependency>
26.         <!--api-->
27.         <dependency>
28.             <groupId>com.heima</groupId>
29.             <artifactId>hm-api</artifactId>
30.             <version>1.0.0</version>
31.         </dependency>
32.         <!--web-->
33.         <dependency>
34.             <groupId>org.springframework.boot</groupId>
35.             <artifactId>spring-boot-starter-web</artifactId>
36.         </dependency>
37.         <!--数据库-->
38.         <dependency>
39.             <groupId>mysql</groupId>
40.             <artifactId>mysql-connector-java</artifactId>
41.         </dependency>
42.         <!--mybatis-->
43.         <dependency>
44.             <groupId>com.baomidou</groupId>
45.             <artifactId>mybatis-plus-boot-starter</artifactId>
46.         </dependency>
47.         <!--nacos 服务注册发现-->
48.         <dependency>
49.             <groupId>com.alibaba.cloud</groupId>
50.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
51.         </dependency>
52.     </dependencies>
53.     <build>
54.         <finalName>${project.artifactId}</finalName>
55.         <plugins>
56.             <plugin>
57.                 <groupId>org.springframework.boot</groupId>
58.                 <artifactId>spring-boot-maven-plugin</artifactId>
59.             </plugin>
60.         </plugins>
61.     </build>
62. </project>

复制代码

启动类

在trade-service中的com.hmall.trade包下创建启动类：

1. package com.hmall.trade;
3. import org.mybatis.spring.annotation.MapperScan;
4. import org.springframework.boot.SpringApplication;
5. import org.springframework.boot.autoconfigure.SpringBootApplication;
6. import org.springframework.cloud.openfeign.EnableFeignClients;
8. @EnableFeignClients(basePackages = "com.hmall.api.client", defaultConfiguration = DefaultFeignConfig.class)
9. @MapperScan("com.hmall.trade.mapper")
10. @SpringBootApplication
11. public class TradeApplication {
12.     public static void main(String[] args) {
13.         SpringApplication.run(TradeApplication.class, args);
14.     }
15. }

复制代码

设置文件

从hm-service项目中复制3个yaml设置文件到trade-service的resource目次。
此中application-dev.yaml和application-local.yaml保持稳固。application.yaml如下：

1. server:
2.   port: 8085
3. spring:
4.   application:
5.     name: trade-service # 服务名称
6.   profiles:
7.     active: dev
8.   datasource:
9.     url: jdbc:mysql://${hm.db.host}:3306/hm-trade?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
10.     driver-class-name: com.mysql.cj.jdbc.Driver
11.     username: root
12.     password: ${hm.db.pw}
13.   cloud:
14.     nacos:
15.       server-addr: 192.168.150.101 # nacos地址
16. mybatis-plus:
17.   configuration:
18.     default-enum-type-handler: com.baomidou.mybatisplus.core.handlers.MybatisEnumTypeHandler
19.   global-config:
20.     db-config:
21.       update-strategy: not_null
22.       id-type: auto
23. logging:
24.   level:
25.     com.hmall: debug
26.   pattern:
27.     dateformat: HH:mm:ss:SSS
28.   file:
29.     path: "logs/${spring.application.name}"
30. knife4j:
31.   enable: true
32.   openapi:
33.     title: 交易服务接口文档
34.     description: "信息"
35.     email: [email protected]
36.     concat: 虎哥
37.     url: https://www.itcast.cn
38.     version: v1.0.0
39.     group:
40.       default:
41.         group-name: default
42.         api-rule: package
43.         api-rule-resources:
44.           - com.hmall.trade.controller

复制代码

代码

根本代码

复制hm-service中全部与trade有关的代码，终极项目结构如下：

在交易业务服务中，用户下单时须要做下列变乱：

• 根据id查询商品列表
  
• 盘算商品总价
  
• 生存订单
  
• 扣减库存
  
• 清算购物车商品
  

此中，查询商品、扣减库存都是与商品有关的业务，在item-service中有相干功能；清算购物车商品是购物车业务，在cart-service中有相干功能。
因此交易业务服务要调用他们，必须通过OpenFeign长途调用。我们须要将上述功能抽取为FeignClient.
抽取ItemClient接口

起首是扣减库存，在item-service中的对应业务接口如下：

我们将这个接口抽取到hm-api模块的com.hmall.api.client.ItemClient中:

将接口参数的OrderDetailDTO抽取到hm-api模块的com.hmall.api.dto包下：

抽取CartClient接口

接下来是清算购物车商品，在cart-service中的对应业务接口如下：

我们在hm-api模块的com.hmall.api.client包下界说一个CartClient接口：

代码如下：

1. package com.hmall.api.client;
3. import org.springframework.cloud.openfeign.FeignClient;
4. import org.springframework.web.bind.annotation.DeleteMapping;
5. import org.springframework.web.bind.annotation.RequestParam;
7. import java.util.Collection;
9. @FeignClient("cart-service")
10. public interface CartClient {
11.     @DeleteMapping("/carts")
12.     void deleteCartItemByIds(@RequestParam("ids") Collection<Long> ids);
13. }

复制代码

改造OrderServiceImpl

接下来，就可以改造OrderServiceImpl中的逻辑，将本地方法调用改造为基于FeignClient的调用，完备代码如下：

1. package com.hmall.trade.service.impl;
3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
4. import com.hmall.api.client.CartClient;
5. import com.hmall.api.client.ItemClient;
6. import com.hmall.api.dto.ItemDTO;
7. import com.hmall.api.dto.OrderDetailDTO;
8. import com.hmall.common.exception.BadRequestException;
9. import com.hmall.common.utils.UserContext;
10. import com.hmall.trade.domain.dto.OrderFormDTO;
11. import com.hmall.trade.domain.po.Order;
12. import com.hmall.trade.domain.po.OrderDetail;
13. import com.hmall.trade.mapper.OrderMapper;
14. import com.hmall.trade.service.IOrderDetailService;
15. import com.hmall.trade.service.IOrderService;
16. import lombok.RequiredArgsConstructor;
17. import org.springframework.stereotype.Service;
18. import org.springframework.transaction.annotation.Transactional;
20. import java.util.ArrayList;
21. import java.util.List;
22. import java.util.Map;
23. import java.util.Set;
24. import java.util.stream.Collectors;
26. /**
27. * <p>
28. * 服务实现类
29. * </p>
30. */
31. @Service
32. @RequiredArgsConstructor
33. public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements IOrderService {
35.     private final ItemClient itemClient;
36.     private final IOrderDetailService detailService;
37.     private final CartClient cartClient;
39.     @Override
40.     @Transactional
41.     public Long createOrder(OrderFormDTO orderFormDTO) {
42.         // 1.订单数据
43.         Order order = new Order();
44.         // 1.1.查询商品
45.         List<OrderDetailDTO> detailDTOS = orderFormDTO.getDetails();
46.         // 1.2.获取商品id和数量的Map
47.         Map<Long, Integer> itemNumMap = detailDTOS.stream()
48.                 .collect(Collectors.toMap(OrderDetailDTO::getItemId, OrderDetailDTO::getNum));
49.         Set<Long> itemIds = itemNumMap.keySet();
50.         // 1.3.查询商品
51.         List<ItemDTO> items = itemClient.queryItemByIds(itemIds);
52.         if (items == null || items.size() < itemIds.size()) {
53.             throw new BadRequestException("商品不存在");
54.         }
55.         // 1.4.基于商品价格、购买数量计算商品总价：totalFee
56.         int total = 0;
57.         for (ItemDTO item : items) {
58.             total += item.getPrice()  itemNumMap.get(item.getId());
59.         }
60.         order.setTotalFee(total);
61.         // 1.5.其它属性
62.         order.setPaymentType(orderFormDTO.getPaymentType());
63.         order.setUserId(UserContext.getUser());
64.         order.setStatus(1);
65.         // 1.6.将Order写入数据库order表中
66.         save(order);
68.         // 2.保存订单详情
69.         List<OrderDetail> details = buildDetails(order.getId(), items, itemNumMap);
70.         detailService.saveBatch(details);
72.         // 3.扣减库存
73.         try {
74.             itemClient.deductStock(detailDTOS);
75.         } catch (Exception e) {
76.             throw new RuntimeException("库存不足！");
77.         }
79.         // 4.清理购物车商品
80.         cartClient.deleteCartItemByIds(itemIds);
81.         return order.getId();
82.     }
84.     private List<OrderDetail> buildDetails(Long orderId, List<ItemDTO> items, Map<Long, Integer> numMap) {
85.         List<OrderDetail> details = new ArrayList<>(items.size());
86.         for (ItemDTO item : items) {
87.             OrderDetail detail = new OrderDetail();
88.             detail.setName(item.getName());
89.             detail.setSpec(item.getSpec());
90.             detail.setPrice(item.getPrice());
91.             detail.setNum(numMap.get(item.getId()));
92.             detail.setItemId(item.getId());
93.             detail.setImage(item.getImage());
94.             detail.setOrderId(orderId);
95.             details.add(detail);
96.         }
97.         return details;
98.     }
99. }

复制代码

数据库

trade-service也须要本身的独立的database，向MySQL中导入课前资料提供的SQL：

导入结果如下：

设置启动项

给trade-service设置启动项，设置profile为local：

测试

启动TradeApplication，访问http://localhost:8085/doc.html，测试查询订单接口：

哀求参数：1654779387523936258，交易业务服务测试通过。注意，创建订单接口无法测试，由于无法获取登任命户信息。
付出服务

创建项目

在hmall下新建一个module，定名为pay-service：

依靠

pay-service的pom.xml文件内容如下：

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5.     <parent>
6.         <artifactId>hmall</artifactId>
7.         <groupId>com.heima</groupId>
8.         <version>1.0.0</version>
9.     </parent>
10.     <modelVersion>4.0.0</modelVersion>
12.     <artifactId>pay-service</artifactId>
14.     <properties>
15.         <maven.compiler.source>11</maven.compiler.source>
16.         <maven.compiler.target>11</maven.compiler.target>
17.     </properties>
19.     <dependencies>
20.         <!--common-->
21.         <dependency>
22.             <groupId>com.heima</groupId>
23.             <artifactId>hm-common</artifactId>
24.             <version>1.0.0</version>
25.         </dependency>
26.         <!--api-->
27.         <dependency>
28.             <groupId>com.heima</groupId>
29.             <artifactId>hm-api</artifactId>
30.             <version>1.0.0</version>
31.         </dependency>
32.         <!--web-->
33.         <dependency>
34.             <groupId>org.springframework.boot</groupId>
35.             <artifactId>spring-boot-starter-web</artifactId>
36.         </dependency>
37.         <!--数据库-->
38.         <dependency>
39.             <groupId>mysql</groupId>
40.             <artifactId>mysql-connector-java</artifactId>
41.         </dependency>
42.         <!--mybatis-->
43.         <dependency>
44.             <groupId>com.baomidou</groupId>
45.             <artifactId>mybatis-plus-boot-starter</artifactId>
46.         </dependency>
47.         <!--nacos 服务注册发现-->
48.         <dependency>
49.             <groupId>com.alibaba.cloud</groupId>
50.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
51.         </dependency>
52.     </dependencies>
53.     <build>
54.         <finalName>${project.artifactId}</finalName>
55.         <plugins>
56.             <plugin>
57.                 <groupId>org.springframework.boot</groupId>
58.                 <artifactId>spring-boot-maven-plugin</artifactId>
59.             </plugin>
60.         </plugins>
61.     </build>
62. </project>

复制代码

启动类

在pay-service中的com.hmall.pay包下创建启动类：

1. package com.hmall.pay;
3. import org.mybatis.spring.annotation.MapperScan;
4. import org.springframework.boot.SpringApplication;
5. import org.springframework.boot.autoconfigure.SpringBootApplication;
6. import org.springframework.cloud.openfeign.EnableFeignClients;
8. @EnableFeignClients(basePackages = "com.hmall.api.client", defaultConfiguration = DefaultFeignConfig.class)
9. @MapperScan("com.hmall.pay.mapper")
10. @SpringBootApplication
11. public class PayApplication {
12.     public static void main(String[] args) {
13.         SpringApplication.run(PayApplication.class, args);
14.     }
15. }

复制代码

设置文件

从hm-service项目中复制3个yaml设置文件到trade-service的resource目次。
此中application-dev.yaml和application-local.yaml保持稳固。application.yaml如下：

1. server:
2.   port: 8086
3. spring:
4.   application:
5.     name: pay-service
6.   profiles:
7.     active: dev
8.   datasource:
9.     url: jdbc:mysql://${hm.db.host}:3306/hm-pay?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
10.     driver-class-name: com.mysql.cj.jdbc.Driver
11.     username: root
12.     password: ${hm.db.pw}
13.   cloud:
14.     nacos:
15.       server-addr: 192.168.150.101
16. mybatis-plus:
17.   configuration:
18.     default-enum-type-handler: com.baomidou.mybatisplus.core.handlers.MybatisEnumTypeHandler
19.   global-config:
20.     db-config:
21.       update-strategy: not_null
22.       id-type: auto
23. logging:
24.   level:
25.     com.hmall: debug
26.   pattern:
27.     dateformat: HH:mm:ss:SSS
28.   file:
29.     path: "logs/${spring.application.name}"
30. knife4j:
31.   enable: true
32.   openapi:
33.     title: 支付服务接口文档
34.     description: "支付服务接口文档"
35.     email: [email protected]
36.     concat: 虎哥
37.     url: https://www.itcast.cn
38.     version: v1.0.0
39.     group:
40.       default:
41.         group-name: default
42.         api-rule: package
43.         api-rule-resources:
44.           - com.hmall.pay.controller

复制代码

代码

根本代码

复制hm-service中全部与付出有关的代码，终极项目结构如下：

在付出服务中，基于用户余额付出时须要做下列变乱：

• 扣减用户余额
  
• 标志付出单状态为已付出
  
• 标志订单状态为已付出
  

此中，扣减用户余额是在user-service中有相干功能；标志订单状态则是在trade-service中有相干功能。因此交易业务服务要调用他们，必须通过OpenFeign长途调用。我们须要将上述功能抽取为FeignClient.
抽取UserClient接口

起首是扣减用户余额，在user-service中的对应业务接口如下：

我们将这个接口抽取到hm-api模块的com.hmall.api.client.UserClient中:

详细代码如下：

1. package com.hmall.api.client;
3. import org.springframework.cloud.openfeign.FeignClient;
4. import org.springframework.web.bind.annotation.PutMapping;
5. import org.springframework.web.bind.annotation.RequestParam;
7. @FeignClient("user-service")
8. public interface UserClient {
9.     @PutMapping("/users/money/deduct")
10.     void deductMoney(@RequestParam("pw") String pw,@RequestParam("amount") Integer amount);
11. }

复制代码

抽取TradeClient接口

接下来是标志订单状态，在trade-service中的对应业务接口如下：

我们将这个接口抽取到hm-api模块的com.hmall.api.client.TradeClient中:

代码如下：

1. package com.hmall.api.client;
3. import org.springframework.cloud.openfeign.FeignClient;
4. import org.springframework.web.bind.annotation.PathVariable;
5. import org.springframework.web.bind.annotation.PutMapping;
7. @FeignClient("trade-service")
8. public interface TradeClient {
9.     @PutMapping("/orders/{orderId}")
10.     void markOrderPaySuccess(@PathVariable("orderId") Long orderId);
11. }

复制代码

改造PayOrderServiceImpl

接下来，就可以改造PayOrderServiceImpl中的逻辑，将本地方法调用改造为基于FeignClient的调用，完备代码如下：

1. package com.hmall.pay.service.impl;
3. import com.baomidou.mybatisplus.core.toolkit.IdWorker;
4. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
5. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
6. import com.hmall.api.client.TradeClient;
7. import com.hmall.api.client.UserClient;
8. import com.hmall.common.exception.BizIllegalException;
9. import com.hmall.common.utils.BeanUtils;
10. import com.hmall.common.utils.UserContext;
11. import com.hmall.pay.domain.dto.PayApplyDTO;
12. import com.hmall.pay.domain.dto.PayOrderFormDTO;
13. import com.hmall.pay.domain.po.PayOrder;
14. import com.hmall.pay.enums.PayStatus;
15. import com.hmall.pay.mapper.PayOrderMapper;
16. import com.hmall.pay.service.IPayOrderService;
17. import lombok.RequiredArgsConstructor;
18. import org.springframework.stereotype.Service;
19. import org.springframework.transaction.annotation.Transactional;
21. import java.time.LocalDateTime;
23. /**
24. * <p>
25. * 支付订单 服务实现类
26. * </p>
27. *
28. */
29. @Service
30. @RequiredArgsConstructor
31. public class PayOrderServiceImpl extends ServiceImpl<PayOrderMapper, PayOrder> implements IPayOrderService {
33.     private final UserClient userClient;
35.     private final TradeClient tradeClient;
37.     @Override
38.     public String applyPayOrder(PayApplyDTO applyDTO) {
39.         // 1.幂等性校验
40.         PayOrder payOrder = checkIdempotent(applyDTO);
41.         // 2.返回结果
42.         return payOrder.getId().toString();
43.     }
45.     @Override
46.     @Transactional
47.     public void tryPayOrderByBalance(PayOrderFormDTO payOrderDTO) {
48.         // 1.查询支付单
49.         PayOrder po = getById(payOrderDTO.getId());
50.         // 2.判断状态
51.         if(!PayStatus.WAIT_BUYER_PAY.equalsValue(po.getStatus())){
52.             // 订单不是未支付，状态异常
53.             throw new BizIllegalException("交易已支付或关闭！");
54.         }
55.         // 3.尝试扣减余额
56.         userClient.deductMoney(payOrderDTO.getPw(), po.getAmount());
57.         // 4.修改支付单状态
58.         boolean success = markPayOrderSuccess(payOrderDTO.getId(), LocalDateTime.now());
59.         if (!success) {
60.             throw new BizIllegalException("交易已支付或关闭！");
61.         }
62.         // 5.修改订单状态
63.         tradeClient.markOrderPaySuccess(po.getBizOrderNo());
64.     }
66.     public boolean markPayOrderSuccess(Long id, LocalDateTime successTime) {
67.         return lambdaUpdate()
68.                 .set(PayOrder::getStatus, PayStatus.TRADE_SUCCESS.getValue())
69.                 .set(PayOrder::getPaySuccessTime, successTime)
70.                 .eq(PayOrder::getId, id)
71.                 // 支付状态的乐观锁判断
72.                 .in(PayOrder::getStatus, PayStatus.NOT_COMMIT.getValue(), PayStatus.WAIT_BUYER_PAY.getValue())
73.                 .update();
74.     }
76.     private PayOrder checkIdempotent(PayApplyDTO applyDTO) {
77.         // 1.首先查询支付单
78.         PayOrder oldOrder = queryByBizOrderNo(applyDTO.getBizOrderNo());
79.         // 2.判断是否存在
80.         if (oldOrder == null) {
81.             // 不存在支付单，说明是第一次，写入新的支付单并返回
82.             PayOrder payOrder = buildPayOrder(applyDTO);
83.             payOrder.setPayOrderNo(IdWorker.getId());
84.             save(payOrder);
85.             return payOrder;
86.         }
87.         // 3.旧单已经存在，判断是否支付成功
88.         if (PayStatus.TRADE_SUCCESS.equalsValue(oldOrder.getStatus())) {
89.             // 已经支付成功，抛出异常
90.             throw new BizIllegalException("订单已经支付！");
91.         }
92.         // 4.旧单已经存在，判断是否已经关闭
93.         if (PayStatus.TRADE_CLOSED.equalsValue(oldOrder.getStatus())) {
94.             // 已经关闭，抛出异常
95.             throw new BizIllegalException("订单已关闭");
96.         }
97.         // 5.旧单已经存在，判断支付渠道是否一致
98.         if (!StringUtils.equals(oldOrder.getPayChannelCode(), applyDTO.getPayChannelCode())) {
99.             // 支付渠道不一致，需要重置数据，然后重新申请支付单
100.             PayOrder payOrder = buildPayOrder(applyDTO);
101.             payOrder.setId(oldOrder.getId());
102.             payOrder.setQrCodeUrl("");
103.             updateById(payOrder);
104.             payOrder.setPayOrderNo(oldOrder.getPayOrderNo());
105.             return payOrder;
106.         }
107.         // 6.旧单已经存在，且可能是未支付或未提交，且支付渠道一致，直接返回旧数据
108.         return oldOrder;
109.     }
111.     private PayOrder buildPayOrder(PayApplyDTO payApplyDTO) {
112.         // 1.数据转换
113.         PayOrder payOrder = BeanUtils.toBean(payApplyDTO, PayOrder.class);
114.         // 2.初始化数据
115.         payOrder.setPayOverTime(LocalDateTime.now().plusMinutes(120L));
116.         payOrder.setStatus(PayStatus.WAIT_BUYER_PAY.getValue());
117.         payOrder.setBizUserId(UserContext.getUser());
118.         return payOrder;
119.     }
120.     public PayOrder queryByBizOrderNo(Long bizOrderNo) {
121.         return lambdaQuery()
122.                 .eq(PayOrder::getBizOrderNo, bizOrderNo)
123.                 .one();
124.     }
125. }

复制代码

数据库

pay-service也须要本身的独立的database，向MySQL中导入课前资料提供的SQL：

导入结果如下：

设置启动项

启动类开启FeignClient：

1. package com.hamll.pay;
3. import com.hmall.api.client.TradeClient;
4. import com.hmall.api.client.UserClient;
5. import com.hmall.api.config.DefaultFeignConfig;
6. import org.mybatis.spring.annotation.MapperScan;
7. import org.springframework.boot.autoconfigure.SpringBootApplication;
8. import org.springframework.cloud.openfeign.EnableFeignClients;
10. @SpringBootApplication
11. @EnableFeignClients(clients = {UserClient.class, TradeClient.class},defaultConfiguration = DefaultFeignConfig.class)
12. @MapperScan("com.hamll.pay.mapper")
13. public class PayApplication {
14.     public static void main(String[] args) {
15.         org.springframework.boot.SpringApplication.run(PayApplication.class, args);
16.     }
17. }

复制代码

给pay-service设置启动项，设置profile为local：

测试

在付出服务的PayController中添加一个接口方便测试：

1. @ApiOperation("查询支付单")
2. @GetMapping
3. public List<PayOrderVO> queryPayOrders(){
4.     return BeanUtils.copyList(payOrderService.list(), PayOrderVO.class);
5. }

复制代码

启动PayApplication，访问http://localhost:8086/doc.html，测试查询订单接口：

付出服务测试通过。