项目启动优化

train-server/README.md

@@ -1,4 +1,23 @@
 ## 硬件设备
+- 信号灯 signal
+    - 编号 id
+    - 名称 name
+    - 公里标 kilometer
+    - 状态：红、绿、黄、红黄 colorState
+    - 区段号 selectionId
+    - 类型：上行、下行 direction
+    - 车站编号 stationId
+- 道岔 switch
+    - 编号 id
+    - 名称 name
+    - 公里标 kilometer
+    - 类型 type
+    - 岔前区段号 preSelectionId
+    - 岔后区段号 nextSelectionId
+    - 岔后侧向区段号 nextSideSelectionId
+    - 所属车站编号 stationId
+
+
 - 车站 station
   - 编号 id
   - 名称 name
@@ -25,23 +44,6 @@
   - 编号 id
   - 所属站台 stationId
   - 上下行 direction
-- 信号灯 signal
-  - 编号 id
-  - 名称 name
-  - 公里标 kilometer
-  - 状态：红、绿、黄、红黄 colorState
-  - 区段号 selectionId
-  - 类型：上行、下行 direction
-  - 车站编号 stationId
-- 道岔 switch
-    - 编号 id
-    - 名称 name
-    - 公里标 kilometer
-    - 类型 type
-    - 岔前区段号 preSelectionId
-    - 岔后区段号 nextSelectionId
-    - 岔后侧向区段号 nextSideSelectionId
-    - 所属车站编号 stationId
 - 进路 route
     - 编号 id
     - 进路名称 name

train-server/src/main/java/top/haijunit/train/TrainServerMain.java

@@ -2,14 +2,15 @@ package top.haijunit.train;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.scheduling.annotation.EnableAsync;
-import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.boot.context.metrics.buffering.BufferingApplicationStartup;
 
 @SpringBootApplication
 public class TrainServerMain {
 
     public static void main(String[] args) {
-        SpringApplication.run(TrainServerMain.class, args);
+        SpringApplication application = new SpringApplication(TrainServerMain.class);
+        application.setApplicationStartup(new BufferingApplicationStartup(2048));
+        application.run(args);
     }
 
 }

train-server/src/main/java/top/haijunit/train/domain/constant/DirectionEnum.java

@@ -0,0 +1,19 @@
+package top.haijunit.train.domain.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author zhanghaijun
+ * @date 2023/11/8 12:09
+ * @description 方向枚举
+ */
+@Getter
+@AllArgsConstructor
+public enum DirectionEnum {
+    top("top", "上行，从右向左"),
+    down("down", "下行，从左向右");
+
+    private final String code;
+    private final String describe;
+}

train-server/src/main/java/top/haijunit/train/domain/constant/SignEnum.java

@@ -0,0 +1,21 @@
+package top.haijunit.train.domain.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author zhanghaijun
+ * @date 2023/11/8 11:54
+ * @description 道路标志枚举
+ */
+@Getter
+@AllArgsConstructor
+public enum SignEnum {
+
+    MachineSign("MachineSign", "信号机"),
+    forkSign("forkSign", "道岔"),
+    stopSign("stopSign", "停车标");
+
+    private final String code;
+    private final String describe;
+}

train-server/src/main/java/top/haijunit/train/domain/entity/SignEntity.java

@@ -0,0 +1,26 @@
+package top.haijunit.train.domain.entity;
+
+import lombok.Data;
+import top.haijunit.train.domain.constant.DirectionEnum;
+
+/**
+ * @author zhanghaijun
+ * @version 1.0
+ * @date 2023/11/8 11:52
+ * @description [一句话描述该类的功能]
+ */
+@Data
+public class SignEntity {
+
+    /** 名称 */
+    private String name;
+    /** 编号 */
+    private String code;
+    /** 公里标 */
+    private Long kilometer;
+    /** 上行/下行 */
+    private DirectionEnum direction;
+    /** 状态 */
+    private String status;
+
+}

train-server/src/main/java/top/haijunit/train/domain/UserDO.java

@@ -1,4 +1,4 @@
-package top.haijunit.train.domain;
+package top.haijunit.train.domain.entity;
 
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
@@ -11,7 +11,7 @@ import lombok.Data;
  */
 @Data
 @TableName("db_user")
-public class UserDO {
+public class UserEntity {
 
     @TableId(value = "user_id")
     private Long userId;

train-server/src/main/java/top/haijunit/train/mapper/UserMapper.java

@@ -1,12 +1,12 @@
 package top.haijunit.train.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import top.haijunit.train.domain.UserDO;
+import top.haijunit.train.domain.entity.UserEntity;
 
 /**
  * @author zhanghaijun
  * @date 2023/11/3 16:36
  * @description user数据库操作
  */
-public interface UserMapper extends BaseMapper<UserDO> {
+public interface UserMapper extends BaseMapper<UserEntity> {
 }

train-server/src/main/resources/train.proto

@@ -0,0 +1,5 @@
+syntax = "proto3";
+
+option java_package = "top.haijunit.train.protobuf";
+option java_outer_classname = "StoreTrain";
+

train-server/src/test/java/top/haijunit/train/mapper/UserMapperTest.java

@@ -11,7 +11,7 @@ import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
-import top.haijunit.train.domain.UserDO;
+import top.haijunit.train.domain.entity.UserEntity;
 
 import java.util.List;
 
@@ -28,7 +28,7 @@ public class UserMapperTest {
      */
     @Test
     public void testSelectOne() {
-        UserDO user = userMapper.selectById(1L);
+        UserEntity user = userMapper.selectById(1L);
         System.out.println(user);
     }
 
@@ -37,7 +37,7 @@ public class UserMapperTest {
      */
     @Test
     public void testInsert() {
-        UserDO user = new UserDO();
+        UserEntity user = new UserEntity();
         user.setUsername("kk");
         user.setEmail("kk@qq.com");
         assertThat(userMapper.insert(user)).isGreaterThan(0);
@@ -50,8 +50,8 @@ public class UserMapperTest {
     @Test
     public void testDelete() {
         assertThat(userMapper.deleteById(3L)).isGreaterThan(0);
-        assertThat(userMapper.delete(new QueryWrapper<UserDO>()
-            .lambda().eq(UserDO::getUsername, "kk"))).isGreaterThan(0);
+        assertThat(userMapper.delete(new QueryWrapper<UserEntity>()
+            .lambda().eq(UserEntity::getUsername, "kk"))).isGreaterThan(0);
     }
 
     /**
@@ -59,9 +59,9 @@ public class UserMapperTest {
      */
     @Test
     public void testUpdate() {
-        UserDO user = userMapper.selectById(2);
+        UserEntity user = userMapper.selectById(2);
         assertThat(user.getUsername()).isEqualTo("Jack");
-        userMapper.update(null, Wrappers.<UserDO>lambdaUpdate().set(UserDO::getEmail, "zz@qq.com").eq(UserDO::getUserId, 1));
+        userMapper.update(null, Wrappers.<UserEntity>lambdaUpdate().set(UserEntity::getEmail, "zz@qq.com").eq(UserEntity::getUserId, 1));
         Assertions.assertThat(userMapper.selectById(2).getEmail()).isEqualTo("11@qq.com");
     }
 
@@ -70,7 +70,7 @@ public class UserMapperTest {
      */
     @Test
     public void testSelect() {
-        List<UserDO> userList = userMapper.selectList(null);
+        List<UserEntity> userList = userMapper.selectList(null);
         Assert.assertEquals(5, userList.size());
     }
 
@@ -79,8 +79,8 @@ public class UserMapperTest {
      */
     @Test
     public void testPage() {
-        Page<UserDO> page = new Page<>(1, 2);
-        IPage<UserDO> userIPage = userMapper.selectPage(page, new QueryWrapper<>());
+        Page<UserEntity> page = new Page<>(1, 2);
+        IPage<UserEntity> userIPage = userMapper.selectPage(page, new QueryWrapper<>());
         assertThat(page).isSameAs(userIPage);
         System.out.println("总条数: " + userIPage.getTotal());
         System.out.println("当前页数: " + userIPage.getCurrent());