【SpinrgCloud】支付模块构建(上)

布满荆棘的人生 2023-01-08 04:21 60阅读 0赞

需求：客户端消费者 下订单，订单可以调用微服务的提供者payment支付模块  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70]  
cloud-provider-payment8001：微服务提供者支付module模块  
微服务模块

1.  建module
2.  改pom
3.  写YML
4.  业务类  
    ![在这里插入图片描述][20210118221558818.png]![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70 1]  
    在子项目的POM.xml文件中添加依赖后记得构建一下maven

<dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.21</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
            </dependency>
        </dependencies>

在resources目录信下编写YML文件application.yml

server:
      port: 8001
    
    spring:
      application:
        name: cloud-payment-service
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        username: root
        password: 111111
        url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai
    
    mybatis:
      mapper-locations: classpath:mapper/*.xml
      type-aliases-package: com.xiang.springcloud.entities

添加启动类  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70 2]添加实体类，dao controller层  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70 3]

实体类编写

package com.xiang.springcloud.entities;
    
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    import java.io.Serializable;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class Payment implements Serializable {
        
        private Long id;
        private String serial;
    }

dao层

package com.xiang.springcloud.dao;
    
    import com.xiang.springcloud.entities.Payment;
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Param;
    
    
    @Mapper
    public interface PaymentDao {
        
    
        int create(Payment payment);
    
        Payment getPaymentById(@Param("id") Long id);
    }

service层

package com.xiang.springcloud.service;
    
    import com.xiang.springcloud.entities.Payment;
    import org.apache.ibatis.annotations.Param;
    import org.springframework.stereotype.Service;
    
    
    public interface PaymentService {
        
    
        int create(Payment payment);
    
        Payment getPaymentById(@Param("id") Long id);
    }

service实现类

package com.xiang.springcloud.service.impl;
    
    import com.xiang.springcloud.dao.PaymentDao;
    import com.xiang.springcloud.entities.Payment;
    import com.xiang.springcloud.service.PaymentService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    
    @Service
    public class PaymentServiceImpl implements PaymentService {
        
    
        @Autowired
        private PaymentDao paymentDao;
    
        /**
         * 新建订单
         * @param payment
         * @return
         */
        @Override
        public int create(Payment payment) {
        
            return paymentDao.create(payment);
        }
    
        /**
         * 通过id查询订单
         * @param id
         * @return
         */
        @Override
        public Payment getPaymentById(Long id) {
        
            return paymentDao.getPaymentById(id);
        }
    }

controller层

package com.xiang.springcloud.controller;
    
    import com.xiang.springcloud.entities.CommonResult;
    import com.xiang.springcloud.entities.Payment;
    import com.xiang.springcloud.service.PaymentService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    
    @Slf4j
    @RestController
    public class PaymentController {
        
    
        @Autowired
        private PaymentService paymentService;
    
        /**
         * 新建订单
         * @param payment
         * @return
         */
        @PostMapping(value = "/payment/create")
        public CommonResult create(Payment payment){
        
            int result = paymentService.create(payment);
            log.info("插入成功："+result);
    
            if (result > 0){
        
                return  new CommonResult(200,"插入数据库成功",result);
            }else {
        
                return new CommonResult(400,"插入数据失败",null);
            }
        }
    
        /**
         * 通过id查询订单
         * @param id
         * @return
         */
        @GetMapping("/payment/get/{id}")
        public CommonResult getPaymentById(@PathVariable("id") Long id){
        
            Payment payment = paymentService.getPaymentById(id);
            if (payment != null){
        
                return  new CommonResult(200,"查询成功",payment);
            }else {
        
                return new CommonResult(400,"查询失败，没有对应id："+id,null);
            }
        }
    
    }

新建传给前端的类commentresult类

package com.xiang.springcloud.entities;
    
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class CommonResult<T> {
        
        private Integer code;
        private String message;
        private T data;
    
        public CommonResult(Integer code, String message){
        
            this(code,message,null);
        }
    }

在resources目录下新建mapper文件夹 编写xml文件

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC
            "-//mybatis.org//DTD Mapper 3.0//EN"
            "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="com.xiang.springcloud.dao.PaymentDao">
    
    
        <insert id="create" parameterType="Payment" useGeneratedKeys="true" keyProperty="id">
            insert into payment (serial)
            values (#{
        serial});
        </insert>
    
        <resultMap id="BaseResultMap" type="com.xiang.springcloud.entities.Payment">
            <id column="id" property="id" jdbcType="BIGINT"></id>
            <id column="serial" property="serial" jdbcType="VARCHAR"></id>
        </resultMap>
        <select id="getPaymentById" parameterType="Long" resultMap="BaseResultMap">
            select * from payment where id = #{
        id}
        </select>
    </mapper>

启动项目并测试  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70 4]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70]: /images/20221119/a5f3c924e8e44bbe910f1f4368047d81.png
[20210118221558818.png]: https://img-blog.csdnimg.cn/20210118221558818.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70 1]: /images/20221119/e77c0868fad74e13ad60e2d4ac59dceb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70 2]: /images/20221119/33b85cd91246448c8d9eb28a1637f225.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70 3]: /images/20221119/2d7bf5e6da7b4a9dafed8b5bb98e43aa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3hpYW5nanVueWVz_size_16_color_FFFFFF_t_70 4]: /images/20221119/5dd780624c4c4df185c8e842848b8644.png