创建交易微服务

一时失言乱红尘 2021-07-24 15:25 453阅读 0赞

# 一 数据库 #

## 1 数据库 ##

创建数据库：guli\_trade

## 2 数据表 ##

执行sql脚本

CREATE TABLE `trade_order` (
      `id` char(19) NOT NULL DEFAULT '',
      `order_no` varchar(20) NOT NULL DEFAULT '' COMMENT '订单号',
      `course_id` varchar(19) NOT NULL DEFAULT '' COMMENT '课程id',
      `course_title` varchar(100) DEFAULT NULL COMMENT '课程名称',
      `course_cover` varchar(255) DEFAULT NULL COMMENT '课程封面',
      `teacher_name` varchar(20) DEFAULT NULL COMMENT '讲师名称',
      `member_id` varchar(19) NOT NULL DEFAULT '' COMMENT '会员id',
      `nickname` varchar(50) DEFAULT NULL COMMENT '会员昵称',
      `mobile` varchar(11) DEFAULT NULL COMMENT '会员手机',
      `total_fee` decimal(20,2) DEFAULT NULL COMMENT '订单金额（分）',
      `pay_type` tinyint(3) DEFAULT NULL COMMENT '支付类型（1：微信 2：支付宝）',
      `status` tinyint(3) DEFAULT NULL COMMENT '订单状态（0：未支付 1：已支付）',
      `is_deleted` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '逻辑删除 1（true）已删除， 0（false）未删除',
      `gmt_create` datetime NOT NULL COMMENT '创建时间',
      `gmt_modified` datetime NOT NULL COMMENT '更新时间',
      PRIMARY KEY (`id`),
      UNIQUE KEY `ux_order_no` (`order_no`),
      KEY `idx_course_id` (`course_id`),
      KEY `idx_member_id` (`member_id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='订单';
    
    CREATE TABLE `trade_pay_log` (
      `id` char(19) NOT NULL DEFAULT '',
      `order_no` varchar(20) NOT NULL DEFAULT '' COMMENT '订单号',
      `pay_time` datetime DEFAULT NULL COMMENT '支付完成时间',
      `total_fee` bigint(20) DEFAULT NULL COMMENT '支付金额（分）',
      `transaction_id` varchar(30) DEFAULT NULL COMMENT '交易流水号',
      `trade_state` char(20) DEFAULT NULL COMMENT '交易状态',
      `pay_type` tinyint(3) NOT NULL DEFAULT '0' COMMENT '支付类型（1：微信 2：支付宝）',
      `attr` text COMMENT '其他属性',
      `is_deleted` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '逻辑删除 1（true）已删除， 0（false）未删除',
      `gmt_create` datetime NOT NULL COMMENT '创建时间',
      `gmt_modified` datetime NOT NULL COMMENT '更新时间',
      PRIMARY KEY (`id`),
      UNIQUE KEY `uk_order_no` (`order_no`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='支付日志表';

由于交易模块与教学模块、会员模块是不同的服务模块和不同数据库，所以我们在订单表冗余了课程与会员相关的表字段，这样有利于数据库表查询效率。支付成功后我们会把支付平台返回的数据全部记录，并且更新订单状态。二、创建交易微服务

课程分为免费观看与付费观看，如果是付费观看的课程，会员需下单支付后才可以观看

# 二 创建交易微服务 #

## 1 创建模块 ##

service\_trade

## 2 配置 pom.xml ##

<build>
        
        <resources>
            <resource>
                <directory>src/main/java</directory>
                <includes>
                    <include>**/*.xml</include>
                </includes>
                <filtering>false</filtering>
            </resource>
        </resources>
    </build>

## 3 application.yml ##

resources目录下创建文件

server:
      port: 8170 # 服务端口
    spring:
      profiles:
        active: dev # 环境设置
      application:
        name: service-trade # 服务名
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848 # nacos服务地址
        sentinel:
          transport:
            port: 8081
            dashboard: localhost:8080
      redis:
        host: 127.0.0.1
        port: 6379
        database: 0
        password:
        lettuce:
          pool:
            max-active: 20  #最大连接数，负值表示没有限制，默认8
            max-wait: -1    #最大阻塞等待时间，负值表示没限制，默认-1
            max-idle: 8     #最大空闲连接，默认8
            min-idle: 0     #最小空闲连接，默认0
      datasource: # mysql数据库连接
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/guli_trade?serverTimezone=GMT%2B8
        username: root
        password: 123456
    #spring:
      jackson: #返回json的全局时间格式
        date-format: yyyy-MM-dd HH:mm:ss
        time-zone: GMT+8
    mybatis-plus:
      configuration:
        log-impl: org.apache.ibatis.logging.stdout.StdOutImpl #mybatis日志
      mapper-locations: classpath:com/atguigu/guli/service/trade/mapper/xml/*.xml
    ribbon:
      ConnectTimeout: 10000 #连接建立的超时时长，默认1秒
      ReadTimeout: 10000 #处理请求的超时时间，默认为1秒
    feign:
      sentinel:
        enabled: true

## 4 logback-spring.xml ##

修改日志路径为 guli\_log/trade

## 5 创建启动类 ##

@SpringBootApplication
    @ComponentScan({"com.atguigu.guli"})
    @EnableDiscoveryClient
    @EnableFeignClients
    public class ServiceTradeApplication {
        public static void main(String[] args) {
            SpringApplication.run(ServiceTradeApplication.class, args);
        }
    }