diff --git a/service-passenger-user/pom.xml b/service-passenger-user/pom.xml
index 1660ac7..1e3c03a 100644
--- a/service-passenger-user/pom.xml
+++ b/service-passenger-user/pom.xml
@@ -24,6 +24,16 @@
spring-cloud-starter-alibaba-nacos-discovery
+
+ com.baomidou
+ mybatis-plus-boot-starter
+ 3.4.1
+
+
+ mysql
+ mysql-connector-java
+
+
\ No newline at end of file
diff --git a/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/ServicePassengerUserApplication.java b/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/ServicePassengerUserApplication.java
index c508634..828b1a7 100644
--- a/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/ServicePassengerUserApplication.java
+++ b/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/ServicePassengerUserApplication.java
@@ -1,9 +1,13 @@
package com.mashibing.servicepassengeruser;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@SpringBootApplication
+@MapperScan("com.mashibing.servicepassengeruser.mapper")
+@EnableDiscoveryClient
public class ServicePassengerUserApplication {
public static void main(String[] args) {
diff --git a/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/dto/PassengerUser.java b/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/dto/PassengerUser.java
new file mode 100644
index 0000000..8a165b7
--- /dev/null
+++ b/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/dto/PassengerUser.java
@@ -0,0 +1,23 @@
+package com.mashibing.servicepassengeruser.dto;
+
+import lombok.Data;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+
+@Data
+@Component
+public class PassengerUser {
+
+
+ private Long id;
+ private String passenger_name;
+ private String passenger_phone;
+ // 0:女 1:男
+ private Byte passenger_gender;
+ // 0:有效,1:失效
+ private Byte state;
+ private LocalDateTime gmt_create;
+ private LocalDateTime gmt_modified;
+
+}
diff --git a/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/mapper/PassengerUserMapper.java b/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/mapper/PassengerUserMapper.java
new file mode 100644
index 0000000..ec46d8e
--- /dev/null
+++ b/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/mapper/PassengerUserMapper.java
@@ -0,0 +1,11 @@
+package com.mashibing.servicepassengeruser.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.mashibing.servicepassengeruser.dto.PassengerUser;
+import org.springframework.stereotype.Repository;
+import org.springframework.stereotype.Service;
+
+@Repository
+public interface PassengerUserMapper extends BaseMapper {
+
+}
diff --git a/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/service/UserService.java b/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/service/UserService.java
index 7f58382..f2590b4 100644
--- a/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/service/UserService.java
+++ b/service-passenger-user/src/main/java/com/mashibing/servicepassengeruser/service/UserService.java
@@ -1,20 +1,44 @@
package com.mashibing.servicepassengeruser.service;
import com.mashibing.internalcommon.dto.ResponseResult;
+import com.mashibing.servicepassengeruser.dto.PassengerUser;
+import com.mashibing.servicepassengeruser.mapper.PassengerUserMapper;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
@Service
public class UserService {
+ @Autowired
+ private PassengerUserMapper mapper;
+
public ResponseResult loginOrRegister(String passengerPhone){
System.out.println("user service 被调用,手机号码为:"+passengerPhone);
- //根据手机号查询用户信息
-
- //判断用户信息是否存在
+ //根据手机号 校验 用户信息 是否存在
+ Map map =new HashMap<>();
+ map.put("passenger_phone",passengerPhone);
+ List passengerUserList = mapper.selectByMap(map);
+// System.out.println(passengerUserList);
//如果不存在,插入用户信息
+ if(passengerUserList.size() == 0){
+ PassengerUser passengerUser = new PassengerUser();
+ passengerUser.setPassenger_name("张三");
+ passengerUser.setPassenger_phone(passengerPhone);
+ passengerUser.setPassenger_gender((byte)0);
+ passengerUser.setState((byte)0);
+ passengerUser.setGmt_create(LocalDateTime.now());
+ passengerUser.setGmt_modified(LocalDateTime.now());
+
+ int insertStatus = mapper.insert(passengerUser);
+ }
return ResponseResult.success();
}
diff --git a/service-passenger-user/src/main/resources/application.yml b/service-passenger-user/src/main/resources/application.yml
index 94b866f..466f3a3 100644
--- a/service-passenger-user/src/main/resources/application.yml
+++ b/service-passenger-user/src/main/resources/application.yml
@@ -7,3 +7,8 @@ spring:
nacos:
discovery:
server-addr: 127.0.0.1:8848
+ datasource:
+ driver-class-name: com.mysql.cj.jdbc.Driver
+ url: jdbc:mysql://localhost:3306/service-passenger-user?characterEncoding=utf-8&serverTimezone=GMT%2B8
+ username: root
+ password: 123456