springcloud-02支付模块


创建子模块


创建完子模块,父工程的pom文件

改pom文件

<?xml version="1.0" encoding="UTF-8"?>

	
		cloud2020
		edu.dj.springcloud
		1.0-SNAPSHOT
	
	4.0.0

	cloud-provider-payment8001

	
		
			org.springframework.boot
			spring-boot-starter-web
		
		
			org.springframework.boot
			spring-boot-starter-actuator
		
		
			org.mybatis.spring.boot
			mybatis-spring-boot-starter
		
		
			com.alibaba
			druid-spring-boot-starter
		
		
		
		
			mysql
			mysql-connector-java
		

		
			org.springframework.boot
			spring-boot-starter-jdbc
		
		
			org.springframework.boot
			spring-boot-devtools
		
		
			org.projectlombok
			lombok
		
		
			org.springframework.boot
			spring-boot-starter-test
		
	


yml配置文件(properties也行)

port: 8001

spring:
  application:
    name: cloud-payment-service
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/db2019?serverTimezone=GMT&useSSL=false

    username: root
    password: 123456

mybatis:
  mapper-locations: classpath:mapper/*.xml
  type-aliases-package: edu.dj.springcloud.entites

主启动类

@SpringBootApplication
public class PaymentMain8001 {

    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8001.class,args);
    }
}

业务类

建表

CREATE TABLE `payment` ( 
	`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'ID',
	`serial` varchar(200) DEFAULT '',
	PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8

entities

支付的实体类

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Payment implements Serializable {
    private Long id;
    private String serial;
}

json返回的结果

@Data
@AllArgsConstructor
@NoArgsConstructor
public class CommonResult{
    private Integer code;
    private String message;
    private T data;

    public CommonResult(Integer code, String message){
        this(code, message, null);
    }
}

dao

接口

@Mapper
public interface PaymentDao {

    public int create(Payment payment);

    public Payment getPaymentById(@Param("id") Long id);
}

mapper.xml文件

<?xml version="1.0" encoding="UTF-8"?>




	
		insert into db2019.payment(serial) values (#{serial});
	
	
	
		
		
	
	

service

接口

public interface PaymentService {
    public int create(Payment payment);

    public Payment getPaymentById(@Param("id") Long id);
}

接口实现

@Service
public class PaymentServiceImpl implements PaymentService {

    //@Autowired是Spring的,@Resource是Java自带的
    @Resource
    private PaymentDao paymentDao;

    @Override
    public int create(Payment payment) {
        return paymentDao.create(payment);
    }

    @Override
    public Payment getPaymentById(Long id) {
        return paymentDao.getPaymentById(id);
    }
}

controller

@RestController
@Slf4j
public class PaymentController {

    @Resource
    private PaymentService paymentService;

    @PostMapping("/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(444,"插入数据库失败",null);
        }
    }

    @GetMapping("/payment/create/{id}")
    public CommonResult getPaymentById(@PathVariable("id") Long id){
        Payment payment = paymentService.getPaymentById(id);
        log.info("========>插入结果:"+payment);

        if (payment != null){
            return new CommonResult(200,"查询成功",payment);
        }else {
            return new CommonResult(444,"无记录,查询"+id,null);
        }
    }
}

测试