飞滴出行网约车2022-乘客用户服务 连接MySQL进行登录或注册登录以及注册服务到nacos

service-passenger-user/pom.xml

@@ -24,6 +24,16 @@
             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.4.1</version>
+        </dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+
     </dependencies>
 
 </project>

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) {

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;
+    
+}

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<PassengerUser> {
+
+}

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<String,Object> map =new HashMap<>();
-        //判断用户信息是否存在
+        map.put("passenger_phone",passengerPhone);
+        List<PassengerUser> 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();
     }

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