Skip to content

T
traffic-signal-platform
Commit 95b8300b authored by hanbing's avatar hanbing
Browse files
Options

集成统一信控V0.1版web-service代码

parent 75c8d89f
Expand all Show whitespace changes
Inline Side-by-side
Showing with 9438 additions and 69 deletions
Jenkinsfile
View file @ 95b8300b
...@@ -16,12 +16,17 @@ pipeline { ...@@ -16,12 +16,17 @@ pipeline {
checkout([$class: 'GitSCM', branches: [[name: '*/master']], extensions: [], userRemoteConfigs: [[credentialsId: 'aa123658-f2bd-4079-9735-65b3f31d4d0e', url: 'http://10.100.1.74:56002/signal/traffic-signal-platform.git']]]) checkout([$class: 'GitSCM', branches: [[name: '*/master']], extensions: [], userRemoteConfigs: [[credentialsId: 'aa123658-f2bd-4079-9735-65b3f31d4d0e', url: 'http://10.100.1.74:56002/signal/traffic-signal-platform.git']]])
} }
} }
stage('编译构建') { stage('编译构建utc模块') {
steps { steps {
sh 'mvn -pl signal-utc-service clean package -Dmaven.test.skip=true jib:build -DsendCredentialsOverHttp=true' sh 'mvn -pl signal-utc-service clean package -Dmaven.test.skip=true jib:build -DsendCredentialsOverHttp=true'
} }
} }
stage('删除镜像和容器') { stage('编译构建web模块') {
steps {
sh 'mvn -pl signal-web-service clean package -Dmaven.test.skip=true jib:build -DsendCredentialsOverHttp=true'
}
}
stage('删除utc模块镜像和容器') {
steps { steps {
sh ''' sh '''
echo \'检查容器是否存在\' echo \'检查容器是否存在\'
...@@ -39,15 +44,43 @@ pipeline { ...@@ -39,15 +44,43 @@ pipeline {
''' '''
} }
} }
stage('拉取镜像') { stage('删除web模块镜像和容器') {
steps {
sh '''
echo \'检查容器是否存在\'
containerid=`docker ps -a|grep signal-web-service|awk \'{print $1}\'`
if [ "$containerid" != "" ];then
echo \'容器存在，删除容器\'
docker rm -f $containerid
fi
echo \'检查镜像是否存在\'
imageid=`docker images|grep signal-web-service|awk \'{print $3}\'`
if [ "$imageid" != "" ];then
echo \'删除镜像\'
docker rmi -f $imageid
fi
'''
}
}
stage('拉取utc模块镜像') {
steps { steps {
sh 'docker pull 10.100.1.87:5000/xinkong/signal-utc-service:0.2.1' sh 'docker pull 10.100.1.87:5000/xinkong/signal-utc-service:0.2.1'
} }
} }
stage('运行容器') { stage('拉取web模块镜像') {
steps {
sh 'docker pull 10.100.1.87:5000/xinkong/signal-web-service:0.2.1'
}
}
stage('运行utc模块容器') {
steps { steps {
sh 'docker run -p 32000:32000 -p 15115:15115 -itd --name signal-utc-service 10.100.1.87:5000/xinkong/signal-utc-service:0.2.1' sh 'docker run -p 32000:32000 -p 15115:15115 -itd --name signal-utc-service 10.100.1.87:5000/xinkong/signal-utc-service:0.2.1'
} }
} }
stage('运行web模块容器') {
steps {
sh 'docker run -p 32001:32001 -p 15116:15116 -itd --name signal-web-service 10.100.1.87:5000/xinkong/signal-web-service:0.2.1'
}
}
} }
} }
pom.xml
View file @ 95b8300b
...@@ -37,9 +37,6 @@ ...@@ -37,9 +37,6 @@
<properties> <properties>
<spring-cloud.version>2021.0.0</spring-cloud.version> <spring-cloud.version>2021.0.0</spring-cloud.version>
<spring-cloud-alibaba.version>0.2.1.RELEASE</spring-cloud-alibaba.version> <spring-cloud-alibaba.version>0.2.1.RELEASE</spring-cloud-alibaba.version>
<mybatis.version>2.2.2</mybatis.version>
<mapper.springboot.version>2.1.5</mapper.springboot.version>
<mybatis.typehandlers.version>1.0.2</mybatis.typehandlers.version>
<druid.version>1.1.5</druid.version> <druid.version>1.1.5</druid.version>
<swagger.version>2.9.2</swagger.version> <swagger.version>2.9.2</swagger.version>
<lombok.version>1.16.18</lombok.version> <lombok.version>1.16.18</lombok.version>
...@@ -73,23 +70,6 @@ ...@@ -73,23 +70,6 @@
<type>pom</type> <type>pom</type>
<scope>import</scope> <scope>import</scope>
</dependency> </dependency>
<!-- Mybatis 依赖 -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>${mybatis.version}</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-typehandlers-jsr310</artifactId>
<version>${mybatis.typehandlers.version}</version>
</dependency>
<!-- TK MyBatis -->
<dependency>
<groupId>tk.mybatis</groupId>
<artifactId>mapper-spring-boot-starter</artifactId>
<version>${mapper.springboot.version}</version>
</dependency>
<!-- MySQL --> <!-- MySQL -->
<dependency> <dependency>
<groupId>com.alibaba</groupId> <groupId>com.alibaba</groupId>
...@@ -170,6 +150,18 @@ ...@@ -170,6 +150,18 @@
<artifactId>artemis-sdk</artifactId> <artifactId>artemis-sdk</artifactId>
<version>${artemis.version}</version> <version>${artemis.version}</version>
</dependency> </dependency>
<!-- pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>${pagehelper.boot.version}</version>
</dependency>
<!-- Gson -->
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>${gson.version}</version>
</dependency>
</dependencies> </dependencies>
</dependencyManagement> </dependencyManagement>
......
signal-utc-service/src/main/java/net/wanji/utc/common/constant/Constants.java
View file @ 95b8300b
...@@ -885,8 +885,8 @@ public class Constants { ...@@ -885,8 +885,8 @@ public class Constants {
public static final String BPMN_CANDIDATES = "candidates"; public static final String BPMN_CANDIDATES = "candidates";
public static final String BPMN_COMPLETION_CONDITION = "completionCondition"; public static final String BPMN_COMPLETION_CONDITION = "completionCondition";
public static final String BPMN_COMPLETION_CONDITION_CONTENT = "${userTaskHandler.dealComplete(execution)}"; public static final String BPMN_COMPLETION_CONDITION_CONTENT = "${userTaskHandler.dealComplete(execution)}";
public static final String BPMN_PROCESS_EXECUTION_LISTENER_NAME = "com.wanji.design.engine.operate.impl.ProcessExecutionListener"; public static final String BPMN_PROCESS_EXECUTION_LISTENER_NAME = "net.wanji.design.engine.operate.impl.ProcessExecutionListener";
public static final String BPMN_ACTIVITI_CLASS_NAME = "com.wanji.design.engine.operate.impl.AutoNodeServiceTask"; public static final String BPMN_ACTIVITI_CLASS_NAME = "net.wanji.design.engine.operate.impl.AutoNodeServiceTask";
/*bpmn20.xml节点定义 end*/ /*bpmn20.xml节点定义 end*/
......
signal-utc-service/src/main/java/net/wanji/utc/entity/TCrossInfo.java
View file @ 95b8300b
...@@ -76,7 +76,7 @@ public class TCrossInfo implements Serializable { ...@@ -76,7 +76,7 @@ public class TCrossInfo implements Serializable {
/** /**
* 型号 * 型号
*/ */
@TableField("model") @TableField("po")
private String model; private String model;
/** /**
......
signal-web-service/pom.xml
View file @ 95b8300b
...@@ -22,6 +22,8 @@ ...@@ -22,6 +22,8 @@
<properties> <properties>
<java.version>1.8</java.version> <java.version>1.8</java.version>
<mybatis-plus-version>3.5.1</mybatis-plus-version> <mybatis-plus-version>3.5.1</mybatis-plus-version>
<mybatis.generator.version>1.3.2</mybatis.generator.version>
<mysql.connector.version>5.1.41</mysql.connector.version>
</properties> </properties>
<dependencies> <dependencies>
...@@ -78,26 +80,219 @@ ...@@ -78,26 +80,219 @@
<artifactId>hibernate-validator</artifactId> <artifactId>hibernate-validator</artifactId>
<version>6.0.1.Final</version> <version>6.0.1.Final</version>
</dependency> </dependency>
<!-- apache commons-->
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
</dependency>
<dependency>
<groupId>commons-collections</groupId>
<artifactId>commons-collections</artifactId>
</dependency>
<dependency>
<groupId>commons-beanutils</groupId>
<artifactId>commons-beanutils</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
<!-- redis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- ws rs -->
<dependency>
<groupId>jakarta.ws.rs</groupId>
<artifactId>jakarta.ws.rs-api</artifactId>
</dependency>
<!-- pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
</dependency>
<!-- Hutool -->
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
</dependency>
<!-- Gson -->
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
</dependency>
</dependencies> </dependencies>
<build> <build>
<plugins> <plugins>
<!-- 编译插件 -->
<plugin> <plugin>
<groupId>org.springframework.boot</groupId> <groupId>org.apache.maven.plugins</groupId>
<artifactId>spring-boot-maven-plugin</artifactId> <artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>${maven.compiler.source}</source>
<target>${maven.compiler.target}</target>
<compilerArguments>
<encoding>${project.build.sourceEncoding}</encoding>
</compilerArguments>
</configuration>
</plugin>
<!-- 项目打包插件 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<configuration> <configuration>
<includeSystemScope>true</includeSystemScope> <archive>
<fork>true</fork> <!-- 如果没有该配置，devtools不会生效 --> <manifest>
<addClasspath>true</addClasspath>
<classpathPrefix>lib/</classpathPrefix>
<mainClass>com.wanji.web.SignalApplication</mainClass>
</manifest>
</archive>
<excludes>
<exclude>generate_code_vm/**</exclude>
<exclude>mybatis-generator/**</exclude>
<exclude>**/*.yml</exclude>
</excludes>
</configuration>
</plugin>
<plugin>
<artifactId>maven-assembly-plugin</artifactId>
<!-- 主类 -->
<configuration>
<finalName>signal-web-service</finalName>
<descriptors>
<descriptor>src/main/assembly/package.xml</descriptor>
</descriptors>
</configuration> </configuration>
<executions> <executions>
<execution> <execution>
<id>make-assembly</id>
<phase>package</phase>
<goals> <goals>
<goal>repackage</goal> <goal>single</goal>
</goals> </goals>
</execution> </execution>
</executions> </executions>
</plugin> </plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<configuration>
<skip>true</skip>
</configuration>
</plugin>
<plugin>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-maven-plugin</artifactId>
<version>${mybatis.generator.version}</version>
<configuration>
<configurationFile>${basedir}/src/main/resources/mybatis-generator/generatorConfig.xml</configurationFile>
<verbose>true</verbose>
<overwrite>true</overwrite>
</configuration>
<dependencies>
<!-- 数据库驱动 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql.connector.version}</version>
</dependency>
</dependencies>
</plugin>
<!-- swagger 导出配置 -->
<plugin>
<groupId>io.github.swagger2markup</groupId>
<artifactId>swagger2markup-maven-plugin</artifactId>
<version>1.3.3</version>
<configuration>
<swaggerInput>http://10.100.1.87:30003/utcsystem/v2/api-docs</swaggerInput>
<outputDir>src/docs/asciidoc/generated</outputDir>
<config>
<swagger2markup.markupLanguage>ASCIIDOC</swagger2markup.markupLanguage>
</config>
</configuration>
</plugin>
<plugin>
<groupId>org.asciidoctor</groupId>
<artifactId>asciidoctor-maven-plugin</artifactId>
<version>1.5.6</version>
<configuration>
<sourceDirectory>src/docs/asciidoc/generated</sourceDirectory>
<outputDirectory>src/docs/asciidoc/html</outputDirectory>
<backend>html</backend>
<sourceHighlighter>coderay</sourceHighlighter>
<attributes>
<toc>left</toc>
</attributes>
</configuration>
</plugin>
<!-- mvn clean package -Dmaven.test.skip=true jib:build -DsendCredentialsOverHttp=true -->
<!-- 使用jib 无需深入学习docker, 无需编写Dockerfile -->
<plugin>
<groupId>com.google.cloud.tools</groupId>
<artifactId>jib-maven-plugin</artifactId>
<version>2.5.2</version>
<configuration>
<!--from节点用来设置镜像的基础镜像，相当于Docerkfile中的FROM关键字-->
<from>
<!--使用harbor上的openjdk镜像-->
<image>10.100.1.87:5000/xinkong/openjdk:8-alpine3.9</image>
<!--harbor服务器的登录信息-->
<auth>
<username>admin</username>
<password>Wanji300552</password>
</auth>
</from>
<to>
<image>10.100.1.87:5000/xinkong/${artifactId}:${version}</image>
<auth>
<username>admin</username>
<password>Wanji300552</password>
</auth>
</to>
<container>
<!--配置jvm虚拟机参数-->
<jvmFlags>
<jvmFlag>-Xms512m</jvmFlag>
<jvmFlag>-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=15116</jvmFlag>
</jvmFlags>
<!--配置使用的时区-->
<environment>
<TZ>Asia/Shanghai</TZ>
</environment>
<!--要暴露的端口-->
<ports>
<port>32001</port>
<port>15116</port>
</ports>
<!-- <creationTime>2022-10-14T10:08:59.304+08:00</creationTime>-->
<creationTime>${maven.build.timestamp}</creationTime>
<mainClass>com.wanji.web.SignalApplication</mainClass>
</container>
<!--可以进行HTTP-->
<allowInsecureRegistries>true</allowInsecureRegistries>
</configuration>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>build</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins> </plugins>
</build> </build>
......
signal-web-service/src/main/assembly/package.xml 0 → 100644
View file @ 95b8300b
<assembly
xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0 http://maven.apache.org/xsd/assembly-1.1.0.xsd">
<id>1.0</id>
<formats>
<format>tar.gz</format>
<format>dir</format>
</formats>
<includeBaseDirectory>true</includeBaseDirectory>
<fileSets>
<!-- for bin -->
<fileSet>
<directory>src/main/bin</directory>
<includes>
<include>*.*</include>
</includes>
<directoryMode>775</directoryMode>
<outputDirectory>bin/</outputDirectory>
</fileSet>
<!-- for configs -->
<fileSet>
<directory>src/main/resources</directory>
<includes>
<include>*.yml</include>
<include>*.xml</include>
</includes>
<outputDirectory>/</outputDirectory>
</fileSet>
<!-- for jar -->
<fileSet>
<directory>${project.build.directory}</directory>
<outputDirectory>/</outputDirectory>
<includes>
<include>*.jar</include>
</includes>
</fileSet>
</fileSets>
<!-- for lib -->
<dependencySets>
<dependencySet>
<outputDirectory>lib/</outputDirectory>
<scope>runtime</scope>
<excludes>
<exclude>${groupId}:${artifactId}</exclude>
</excludes>
</dependencySet>
</dependencySets>
</assembly>
signal-web-service/src/main/bin/signal-web-service-1.0.0.sh 0 → 100644
View file @ 95b8300b
#!/bin/bash
jarName="signal-web-service-1.0.0.jar"
NR=$(ps -ef | grep "${jarName}" | grep -v grep | wc -l)
if [ ${NR} != 0 ]
then
ps -ef | grep -v grep | grep "${jarName}" |
while read u p o
do
echo "结束Java程序进程..."
kill -9 $p
done
fi
sleep 2
echo "重启Java程序进程..."
nohup java -Xms2048m -Xmx2048m -jar -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=/home/javaApp/heapdump.hprof -agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=15115 -Djava.rmi.server.hostname=10.100.1.87 -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=12345 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false signal-web-service-1.0.0.jar --spring.profiles.active=dev >/dev/null 2>&1 &
signal-web-service/src/main/java/net/wanji/web/WebApplication.java → signal-web-service/src/main/java/net/wanji/web/SignalApplication.java
View file @ 95b8300b
...@@ -3,16 +3,23 @@ package net.wanji.web; ...@@ -3,16 +3,23 @@ package net.wanji.web;
import org.mybatis.spring.annotation.MapperScan; import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.transaction.annotation.EnableTransactionManagement;
/** /**
* @author wj * @author
* @date 2022/11/28 9:31:34
*/ */
@MapperScan("net.wanji.web.mapper") @SpringBootApplication(scanBasePackages = "net.wanji.web")
@SpringBootApplication @MapperScan(basePackages = "net.wanji.web.mapper")
public class WebApplication { @EnableTransactionManagement
@EnableScheduling
@EnableAsync
//@EnableDiscoveryClient
public class SignalApplication {
public static void main(String[] args) { public static void main(String[] args) {
SpringApplication.run(WebApplication.class, args); SpringApplication.run(SignalApplication.class, args);
} }
} }
signal-web-service/src/main/java/net/wanji/web/common/annotation/AspectLog.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.annotation;
import net.wanji.web.common.enums.BaseEnum;
import java.lang.annotation.*;
/**
* @Description: [自定义注解-系统操作日志，拦截Controller请求]
* @author hfx
* @version 1.0
* Created on 2019/4/17 14:06
*/
@Target({ElementType.PARAMETER, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface AspectLog {
/**
* 操作描述 业务名称description
* @return
*/
String description() default "";
/**
* 操作类型 query create modify delete
* @return
*/
BaseEnum.OperationTypeEnum operationType();
}
signal-web-service/src/main/java/net/wanji/web/common/annotation/Ignore.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.annotation;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* @Description: [构造Example时忽略此条件]
* Created on: 2019/5/5
* @author hfx
* @version 1.0
*/
@Target({ElementType.TYPE, ElementType.FIELD})
@Retention(RetentionPolicy.RUNTIME)
public @interface Ignore {
}
signal-web-service/src/main/java/net/wanji/web/common/annotation/Like.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.annotation;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* @Description: [构造Example时，此字段为like]
* Created on: 2019/5/5
* @author hfx
* @version 1.0
*/
@Target({ElementType.TYPE, ElementType.FIELD})
@Retention(RetentionPolicy.RUNTIME)
public @interface Like {
}
signal-web-service/src/main/java/net/wanji/web/common/constant/Const.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.constant;
/**
* @Description: [常量类]
* @author hfx
* @version 1.0
* Created on 2019/4/16 15:07
*/
public class Const {
/**
* UTC 城市交通信号控制系统简称
*/
public static final String SYSTEM_TYPE = "UTC";
/**
* 未删除
*/
public static final Boolean IS_DELETE_NO = false;
/**
* 已删除
*/
public static final Boolean IS_DELETE_YES = true;
/**
* 失败-false
*/
public static final int FALSE = 0;
/**
* 成功-true
*/
public static final int TRUE = 1;
/**
* 不下发
*/
public static final String NOT_SEND = "2";
/**
* 全部：-1
*/
public static final Integer ALL = -1;
/**
* 分隔符：逗号
**/
public static final String SEPARATOR_COMMA = ",";
/**
* 分隔符：冒号
**/
public static final String SEPARATOR_COLON = ":";
/**
* 分隔符：减号
**/
public static final String SEPARATOR_MINUS = "-";
/**
* 分隔符：下划线
**/
public static final String SEPARATOR_UNDER_LINE = "_";
/**
* 下划线，作为查询条件时，将"_"转化为"\_"
*/
public static final String TRANS_UNDERLINE = "\\\\_";
/**
* 分隔符：空格
**/
public static final String SEPARATOR_SPACE = " ";
/**
* 分隔符：分号
**/
public static final String SEPARATOR_SEMICOLON = ";";
/**
* 分隔符：@
*/
public static final String SEPARATOR_AT = "@";
/**
* 分隔符：左括号
*/
public static final String SEPARATOR_LEFTBRACES = "(";
/**
* 分隔符：右括号
*/
public static final String SEPARATOR_RIGHTBRACES = ")";
/**
* 分隔符：大于号 >
*/
public static final String SEPARATOR_GREATER_THAN = ">";
/**
* webSocket topic 信号机状态分组
*/
public static final String WEBSOCKET_TOPIC_SIGNAL_STATE = "topic_signal_state";
/**
* webSocket topic 下发结果状态分组
*/
public static final String WEBSOCKET_TOPIC_PLAN_ISSUED = "topic_plan_issued";
/**
* 海康返回成功码
*/
public static final Integer HK_TRUE_CODE = 0;
/**
* 海康返回成功码的 key
*/
public static final String HK_KEY_CODE = "code";
}
signal-web-service/src/main/java/net/wanji/web/common/constant/RedisKeyConst.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.constant;
/**
* @author hfx
* @version 1.0
* Created on 2019/5/8 16:35
* @description: [redis key常量类]
*/
public interface RedisKeyConst {
/**
* Redis存储Key前缀
*/
String KEY_PREFIX = "utcsystem_";
//redis时段方案版本号
String SECTIM_VERSION = "sectim_version_";
//redis相位方案版本号
String PHASE_VERSION = "phase_version_";
//token存储Redis有效时长
int TOKEN_EXPIRE_TIME = 7200;
//信号机状态
String TELESEME_STATUS = "teleseme_status";
//信号机灯组方向信息
String CROSS_LIGHTS = "cross_lights";
//信号灯线圈车道
String CROSS_COIL_LANE = "cross_coil_lane";
//信号机列表
String SIGNAL_LIST = "signal_list";
//优化配置管理
String SET_OPT_CONFIG = "set_opt_config";
//最小绿时长
String MIN_GREEN_TIME = "min_green_time";
//最大绿时长
String MAX_GREEN_TIME = "max_green_time";
//绿信比是否下发
String IS_SEND = "is_send";
//绿信比优化时段
String OPT_TIME = "opt_time";
}
signal-web-service/src/main/java/net/wanji/web/common/entity/JsonViewObject.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.entity;
import net.wanji.web.common.Constants;
import net.wanji.web.common.enums.HttpCode;
import lombok.Data;
import java.io.Serializable;
//没有get set方法会导致feign 接口调用时，无法使用JsonViewObject作为返回值
@Data
public class JsonViewObject implements Serializable {
private Object content;
private String message;
private String status;
private Integer code;
private Long timestamp;
public Object getContent() {
return content;
}
public String getMessage() {
return message;
}
public String getStatus() {
return status;
}
private JsonViewObject() {
}
public static JsonViewObject newInstance() {
return new JsonViewObject();
}
public JsonViewObject success() {
return success((Object) "");
}
public JsonViewObject success(Object content) {
return success(content, "");
}
public JsonViewObject success(String message) {
return success("", message);
}
public JsonViewObject success(Object content, String message) {
return pack(content, message, Constants.JsonView.STATUS_SUCCESS);
}
public JsonViewObject fail() {
return fail("", "");
}
public JsonViewObject fail(Exception e) {
String message = e.getMessage();
int index = message.indexOf(":");
return fail(index == -1 ? message : message.substring(index + 1));
}
public JsonViewObject fail(String errMsg) {
return fail("", errMsg);
}
public JsonViewObject fail(Object content, String message) {
return pack(content, message, Constants.JsonView.STATUS_FAIL);
}
private JsonViewObject pack(Object content, String message, String status) {
this.content = content;
this.message = message;
this.status = status;
//增加服务返回状态码，后期待完善
this.code=(status.equals(Constants.JsonView.STATUS_SUCCESS) ? HttpCode.SUCCESS.value():HttpCode.INTERNAL_SERVER_ERROR.value());
return this;
}
}
\ No newline at end of file
signal-web-service/src/main/java/net/wanji/web/common/entity/Result.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.entity;
import net.wanji.web.common.enums.StatusCode;
/**
* HTTP响应类
*
* @author Kent HAN
* @date 2022/10/26 15:48
*/
public class Result<T> {
private String status;
private String msg;
private T data;
private Result(T data) {
this.status = StatusCode.SUCCESS.getStatus();
this.msg = StatusCode.SUCCESS.getMsg();
this.data = data;
}
private Result(StatusCode statusCode) {
if (statusCode == null) {
return;
}
this.status = statusCode.getStatus();
this.msg = statusCode.getMsg();
}
private Result(StatusCode statusCode, String msg) {
if (statusCode == null) {
return;
}
this.status = statusCode.getStatus();
this.msg = statusCode.getMsg() + "--" + msg;
}
/**
* 成功时候的调用
*/
public static <T> Result<T> success(T data) {
return new Result<T>(data);
}
/**
* 成功，不需要传入参数
*/
@SuppressWarnings("unchecked")
public static <T> Result<T> success() {
return (Result<T>) success("");
}
/**
* 失败时候的调用
*/
public static <T> Result<T> error(StatusCode statusCode) {
return new Result<T>(statusCode);
}
/**
* 失败时候的调用,扩展消息参数
*/
public static <T> Result<T> error(StatusCode statusCode, String msg) {
return new Result<T>(statusCode, msg);
}
public T getData() {
return data;
}
public String getStatus() {
return status;
}
public String getMsg() {
return msg;
}
}
\ No newline at end of file
signal-web-service/src/main/java/net/wanji/web/common/enums/ControlHistEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
/**
* @author Kent HAN
* @date 2022/10/27 10:10
*/
public enum ControlHistEnum {
ONE(1, "时间表"),
TWO(2, "全红"),
THREE(3, "黄闪"),
FOUR(4, "锁定"),
FIVE(5, "中心优化"),
SIX(6, "MEC优化"),
SEVEN(7, "现场手动");
private Integer code;
private String msg;
ControlHistEnum(Integer code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(Integer code) {
for (ControlHistEnum value : ControlHistEnum.values()) {
if (value.code.equals(code)) {
return value.msg;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/CrossAlarmEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
/**
* @author Kent HAN
* @date 2022/10/27 10:10
*/
public enum CrossAlarmEnum {
ZERO("0", "正常"),
ONE("1", "失衡"),
TWO("2", "拥堵"),
THREE("3", "溢出"),
FOUR("4", "死锁");
private String code;
private String msg;
CrossAlarmEnum(String code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(String codeStr) {
for (CrossAlarmEnum value : CrossAlarmEnum.values()) {
if (value.code.equals(codeStr)) {
return value.msg;
}
}
return null;
}
public static Integer getCodeIntByMsg(String msg) {
for (CrossAlarmEnum value : CrossAlarmEnum.values()) {
if (value.msg.equals(msg)) {
String code = value.code;
int codeInt = Integer.parseInt(code);
return codeInt;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/CrossPhasePlanTurnTypeEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
import java.util.Objects;
/**
* @author Kent HAN
* @date 2022/11/8 17:20
*/
public enum CrossPhasePlanTurnTypeEnum {
ONE("1", "l"),
TWO("2", "r"),
THREE("3", "s"),
FOUR("4", "u");
private final String code;
private final String msg;
CrossPhasePlanTurnTypeEnum(String code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(String code) {
for (CrossPhasePlanTurnTypeEnum value : CrossPhasePlanTurnTypeEnum.values()) {
if (Objects.equals(value.code, code)) {
return value.msg;
}
}
return null;
}
public static String getCodeByMsg(String msg) {
for (CrossPhasePlanTurnTypeEnum value : CrossPhasePlanTurnTypeEnum.values()) {
if (Objects.equals(value.msg, msg)) {
return value.code;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/DeviceStatusEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
/**
* @author Kent HAN
* @date 2022/10/27 10:10
*/
public enum DeviceStatusEnum {
NORMAL(1, "在线"),
WRONG(2, "故障"),
OFFLINE(0, "离线");
private final Integer code;
private final String msg;
DeviceStatusEnum(Integer code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(Integer code) {
for (DeviceStatusEnum value : DeviceStatusEnum.values()) {
if (value.code.equals(code)) {
return value.msg;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/DeviceTypeEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
/**
* @author Kent HAN
* @date 2022/10/27 10:10
*/
public enum DeviceTypeEnum {
ONE(1, "信号"),
TWO(2, "卡口"),
THREE(3, "地磁"),
FOUR(4, "视频"),
FIVE(5, "微波"),
SIX(6, "激光"),
SEVEN(7, "电警"),
EIGHT(8, "MEC");
private final Integer code;
private final String msg;
DeviceTypeEnum(Integer code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(Integer code) {
for (DeviceTypeEnum value : DeviceTypeEnum.values()) {
if (value.code.equals(code)) {
return value.msg;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/EventAlarmEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
/**
* @author Kent HAN
* @date 2022/10/27 10:10
*/
public enum EventAlarmEnum {
ONE(1, "事故"),
TWO(2, "拥堵"),
THREE(3, "管制"),
FOUR(4, "施工");
private final int code;
private final String msg;
EventAlarmEnum(int code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(int code) {
for (EventAlarmEnum value : EventAlarmEnum.values()) {
if (value.code == code) {
return value.msg;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/EventAlarmSourceEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
/**
* @author Kent HAN
* @date 2022/10/27 10:10
*/
public enum EventAlarmSourceEnum {
ONE(1, "接处警"),
TWO(2, "交管部门"),
THREE(3, "互联网");
private final int code;
private final String msg;
EventAlarmSourceEnum(int code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(int code) {
for (EventAlarmSourceEnum value : EventAlarmSourceEnum.values()) {
if (value.code == code) {
return value.msg;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/HttpCode.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
public enum HttpCode {
/** 200请求成功 */
SUCCESS(200),
/** 207频繁操作 */
MULTI_STATUS(207),
/** 400请求参数出错 */
BAD_REQUEST(400),
/** 401没有登录 */
UNAUTHORIZED(401),
/** 402登录失败 */
LOGIN_FAIL(402),
/** 403没有权限 */
FORBIDDEN(403),
/** 404找不到页面 */
NOT_FOUND(404),
/** 405请求方法不能被用于请求相应的资源 */
METHOD_NOT_ALLOWED(405),
/** 406内容特性不满足 */
NOT_ACCEPTABLE(406),
/** token过期 */
TOKEN_EXPIRED(407),
/** 408请求超时 */
REQUEST_TIMEOUT(408),
/** 409发生冲突 */
CONFLICT(409),
/** 410已被删除 */
GONE(410),
/** 411没有定义长度 */
LENGTH_REQUIRED(411),
/** 412条件不满足 */
PRECONDITION_FAILED(412),
/** 413数据太大 */
ENTITY_TOO_LARGE(413),
/** 415不是服务器中所支持的格式 */
UNSUPPORTED_MEDIA_TYPE(415),
/** 421连接数过多 */
TOO_MANY_CONNECTIONS(421),
/** 423已被锁定 */
LOCKED(423),
/** 451法律不允许 */
UNAVAILABLE_LEGAL(451),
/** 500服务器出错 */
INTERNAL_SERVER_ERROR(500),
/** 501不支持当前请求所需要的某个功能 */
NOT_IMPLEMENTED(501),
/** 503服务器升级中,暂时不可用 */
SERVICE_UNAVAILABLE(503),
/** 501获取资源所需要的策略并没有被满足 */
NOT_EXTENDED(510);
private final Integer value;
private HttpCode(Integer value) {
this.value = value;
}
/**
* Return the integer value of this status code.
*/
public Integer value() {
return this.value;
}
@Override
public String toString() {
return this.value.toString();
}
}
\ No newline at end of file
signal-web-service/src/main/java/net/wanji/web/common/enums/SpecialServiceCrossDirEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
import java.util.Objects;
/**
* @author Kent HAN
* @date 2022/11/8 17:20
*/
public enum SpecialServiceCrossDirEnum {
ONE(1, "北"),
TWO(2, "东北"),
THREE(3, "东"),
FOUR(4, "东南"),
FIVE(5, "南"),
SIX(6, "西南"),
SEVEN(7, "西"),
EIGHT(3, "西北");
private final int code;
private final String msg;
SpecialServiceCrossDirEnum(int code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(int code) {
for (SpecialServiceCrossDirEnum value : SpecialServiceCrossDirEnum.values()) {
if (value.code == code) {
return value.msg;
}
}
return null;
}
public static Integer getCodeByMsg(String msg) {
for (SpecialServiceCrossDirEnum value : SpecialServiceCrossDirEnum.values()) {
if (Objects.equals(value.msg, msg)) {
return value.code;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/SpecialServiceCrossInOutEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
/**
* @author Kent HAN
* @date 2022/11/8 17:20
*/
public enum SpecialServiceCrossInOutEnum {
ONE(1, "出口"),
TWO(2, "进口");
private final int code;
private final String msg;
SpecialServiceCrossInOutEnum(int code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(int code) {
for (SpecialServiceCrossInOutEnum value : SpecialServiceCrossInOutEnum.values()) {
if (value.code == code) {
return value.msg;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/SpecialServiceCrossTurnEnum.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
import java.util.Objects;
/**
* @author Kent HAN
* @date 2022/11/8 17:20
*/
public enum SpecialServiceCrossTurnEnum {
LEFT("l", "左转"),
STRAIGHT("s", "直行"),
RIGHT("r", "右转"),
UTURN("u", "掉头");
private final String code;
private final String msg;
SpecialServiceCrossTurnEnum(String code, String msg) {
this.code = code;
this.msg = msg;
}
public static String getMsgByCode(String code) {
for (SpecialServiceCrossTurnEnum value : SpecialServiceCrossTurnEnum.values()) {
if (Objects.equals(value.code, code)) {
return value.msg;
}
}
return null;
}
public String getMsg() {
return msg;
}
}
signal-web-service/src/main/java/net/wanji/web/common/enums/StatusCode.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.enums;
public enum StatusCode {
SUCCESS("success", "成功"),
ERROR("fail", "失败");
private String status;
private String msg;
StatusCode(String status, String msg) {
this.status = status;
this.msg = msg;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
}
\ No newline at end of file
signal-web-service/src/main/java/net/wanji/web/common/exception/CrossRelationException.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.exception;
/**
* 路段关系异常
*
* @author Kent HAN
* @date 2022/11/10 9:09
*/
public class CrossRelationException extends RuntimeException {
public CrossRelationException(String message) {
super(message);
}
public CrossRelationException(String message, Exception e) {
super(message,e);
}
}
signal-web-service/src/main/java/net/wanji/web/common/exception/WarnException.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.exception;
/**
* @Description: [自定义异常，用于提示警告的Exception]
* @author hfx
* @version 1.0
* Created on 2019/4/17 11:07
*/
public class WarnException extends RuntimeException {
public WarnException(String message) {
super(message);
}
public WarnException(String message, Exception e) {
super(message,e);
}
}
signal-web-service/src/main/java/net/wanji/web/common/util/CrossUtil.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.util;
import java.util.List;
/**
* @author Kent HAN
* @date 2022/11/9 16:48
*/
public class CrossUtil {
// 从路口信息中分离经纬度
public static double[] getLonLat(String location) {
List<String> result = RegexUtils.getMatchGroups(location,
"^POINT\\(([0-9]*\\.?[0-9]+) ([0-9]*\\.?[0-9]+)\\)$", 2);
String longitudeStr = result.get(1);
double longitude = Double.parseDouble(longitudeStr);
String latitudeStr = result.get(2);
double latitude = Double.parseDouble(latitudeStr);
double[] lonLat = {longitude, latitude};
return lonLat;
}
}
signal-web-service/src/main/java/net/wanji/web/common/util/RedisUtils.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.util;
import net.wanji.web.common.constant.Const;
import net.wanji.web.common.constant.RedisKeyConst;
import net.wanji.web.common.util.date.DateStyle;
import net.wanji.web.common.util.date.DateUtils;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.support.atomic.RedisAtomicLong;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.text.DecimalFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
/**
* @description: redis工具类
* @author hfx
* @version 1.0
* Created on 2019/4/29 20:34
*/
@Component
public class RedisUtils {
/**
* 注入redisTemplate
*/
@Resource
private RedisTemplate<String, Object> redisTemplate;
/**
* @description: 判断是否存在Key
* @param key redis的Key
* @return boolean true:有 false:无
*/
public boolean hasKey(String key) {
return redisTemplate.hasKey(key);
}
/**
* @description: 添加字符串
* @param key redis的Key
* @param value 添加redis的value
*/
public void set(String key, String value) {
redisTemplate.opsForValue().set(key, value);
}
/**
* @description: 添加对象
* @param key redis的Key
* @param object 添加redis的value
*/
public void set(String key, Object object) {
redisTemplate.opsForValue().set(key, object);
}
/**
* @description: 添加带生命周期的对象
* @param key redis的Key
* @param object 添加redis的value
* @param seconds 失效时间
*/
public void setAndExpire(String key, Object object, int seconds) {
redisTemplate.opsForValue().set(key, object);
redisTemplate.expire(key, seconds, TimeUnit.SECONDS);
}
/**
* @description: 添加带生命周期的对象
* @param key redis的Key
* @param value 添加redis的value
* @param seconds 失效时间
*/
public void setAndExpire(String key, String value, int seconds) {
redisTemplate.opsForValue().set(key, value);
redisTemplate.expire(key, seconds, TimeUnit.SECONDS);
}
/**
* @description: 获取对象
* @param key redis的Key
* @return Object 返回对象
*/
public Object get(String key) {
return redisTemplate.opsForValue().get(key);
}
/**
* @description: 存入redis的hash
* @param key redis的Key
* @param field 字段值
* @param value 存入的值
*/
public void setHash(String key, String field, String value) {
redisTemplate.opsForHash().put(key, field, value);
}
/**
* @description: 存入redis的hash
* @param key redis的Key
* @param field 字段值
* @param value 存入的值
*/
public void setHash(String key, String field, Object value) {
redisTemplate.opsForHash().put(key, field, value);
}
/**
* @description: 根据key和字段值获取内容值
* @param key redis的Key
* @param field 字段值
* @return String 返回字符串
*/
public String getHash(String key, String field) {
return (String)redisTemplate.opsForHash().get(key, field);
}
/**
* @description: 根据field删除值
* @param key redis的Key
* @param field 字段值
*/
public void delHashMap(String key, String field) {
redisTemplate.boundHashOps(key).delete(field);
}
/**
* @description: 存入hash集合
* @param key redis的Key
* @param hashmap 存入的Map集合
*/
public void setHashMap(String key, Map<String, Object> hashmap){
redisTemplate.opsForHash().putAll(key, hashmap);;
}
/**
* @description: 取出hash集合
* @param key redis的Key
* @return Map<Object, Object> 返回Map集合
*/
public Map<Object, Object> getHashMap(String key) {
return redisTemplate.opsForHash().entries(key);
}
/**
* @description: 存入redis的Set
* @param key redis的Key
* @param object 对象
*/
public void setSet(String key,Object object){
redisTemplate.opsForSet().add(key, object);
}
/**
* @description: 获取redis的Set
* @param key redis的Key
* @return Set<Object> Set集合
*/
public Set<Object> getSet(String key){
return redisTemplate.opsForSet().members(key);
}
/**
* @discription: 查看值是否是set成员
* @param key set的key
* @param value set的成员
* @return 是否是set成员
*/
public Boolean isSetMember(String key, Object value) {
return redisTemplate.opsForSet().isMember(key, value);
}
/**
* @description:设置key的过期时间，endTime格式：yyyy-MM-dd hh:mm:ss
* @param key redis的Key
* @param endTime 结束时间
*/
public void setExpire(String key, Date endTime) {
long seconds = endTime.getTime() - System.currentTimeMillis();
redisTemplate.expire(key, (int) (seconds / 1000), TimeUnit.SECONDS);
}
/**
* @description: 设置key的过期时间
* @param key redis的Key
* @param time 过期时间（秒）
*/
public void setExpire(String key, int time) {
redisTemplate.expire(key, time, TimeUnit.SECONDS);
}
/**
* <p>Discription:获取key的过期时间
* @param key redis的Key
* @return 过期时间（秒）
*/
public Long getExpire(String key) {
return redisTemplate.getExpire(key, TimeUnit.SECONDS);
}
/**
* @description: 在redis消息队列队尾插入数据
* @param key redis的Key
* @param object 添加的对象
*/
public void tailPush(String key, Object object){
redisTemplate.opsForList().rightPush(key, object);
}
/**
* @description: 在redis消息队列对头插入数据
* @param key redis的Key
* @param object 添加的对象
*/
public void headPush(String key,Object object){
redisTemplate.opsForList().leftPush(key, object);
}
/**
* @description: 在redis消息队列队尾删除数据
* @param key redis的Key
* @return Object 删除的对象
*/
public Object tailPop(String key){
return redisTemplate.opsForList().rightPop(key);
}
/**
* @description: 在redis消息队列队头删除数据
* @param key redis的Key
* @return Object 删除的对象
*/
public Object headPop(String key){
return redisTemplate.opsForList().leftPop(key);
}
/**
* @description: 删除redis的值
* @param key redis的Key
*/
public void del(String key) {
if (hasKey(key)) {
redisTemplate.delete(key);
}
}
/**
* @description: 清理redis缓存
*/
public void flushDB(){
redisTemplate.getConnectionFactory().getConnection().flushDb();
}
/**
* @description: 根据类型生成版本号
* @param type 类型key区分
* @return 版本号
* @author hfx
* @date 2019/5/5 19:26
*/
public String getVersion(String type) {
String formatDate = DateUtils.dateToString(new Date(), DateStyle.YYYYMMDD);
String key = RedisKeyConst.KEY_PREFIX + type + formatDate;
//当前时间到第二天还剩多少时间
Date newDate = DateUtils.dateForMat(DateUtils.addDay(new Date(), 1), DateStyle.YYYY_MM_DD);
int liveTime = DateUtils.dayDiff(newDate, new Date(), Calendar.MILLISECOND);
//获取自增号
Long incr = getIncr(key, liveTime);
if(incr == 0) {
incr = getIncr(key, liveTime);//从001开始
}
DecimalFormat df = new DecimalFormat("000");//三位序列号
return formatDate + Const.SEPARATOR_MINUS + df.format(incr);
}
/**
* 自增ID
* @param key 建
* @param liveTime 过期时间
* @return 自增结果
*/
public Long getIncr(String key, long liveTime) {
RedisAtomicLong entityIdCounter = new RedisAtomicLong(key, redisTemplate.getConnectionFactory());
Long increment = entityIdCounter.getAndIncrement();
if ((null == increment || increment.longValue() == 0) && liveTime > 0) {//初始设置过期时间
entityIdCounter.expire(liveTime, TimeUnit.MILLISECONDS);//单位毫秒
}
return increment;
}
/**
* 获取全部Redis的key
* @return
*/
public Set<String> keys() {
return redisTemplate.keys("*");
}
}
signal-web-service/src/main/java/net/wanji/web/common/util/RegexUtils.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.util;
import java.util.ArrayList;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
public class RegexUtils {
/**
* 匹配第一个字符串
*
* @param text
* @param regex
* @return
*/
public static String getMatchGroupString(String text, String regex) {
String result = "";
Pattern pattern = Pattern.compile(regex);
Matcher matcher = pattern.matcher(text);
if (matcher.find()) {
result = matcher.group();
}
return result;
}
/**
* 捕获组
*
* @param text
* @param regex
* @param group
* @return
*/
public static String getMatchGroupString(String text, String regex, int group) {
String result = "";
Pattern pattern = Pattern.compile(regex);
Matcher matcher = pattern.matcher(text);
if (matcher.find()) {
result = matcher.group(group);
}
return result;
}
/**
* 匹配所有结果
*
* @param text
* @param regex
* @return
*/
public static List<String> getMatchStrings(String text, String regex) {
List<String> results = new ArrayList<>();
Pattern pattern = Pattern.compile(regex);
Matcher matcher = pattern.matcher(text);
while (matcher.find()) {
results.add(matcher.group());
}
return results;
}
/**
* 捕获所有分组结果,包含第0组
* 应用场景：需要的信息分别包含在各个分组内
* @param text
* @param regex
* @param totalGroup 分组数量，即正则中小括号的对数，从0开始计数
* @return
*/
public static List<String> getMatchGroups(String text, String regex,int totalGroup) {
List<String> results = new ArrayList<>();
Pattern pattern = Pattern.compile(regex);
Matcher matcher = pattern.matcher(text);
matcher.find();
for (int i=0;i<=totalGroup;i++) {
results.add(matcher.group(i));
}
return results;
}
}
\ No newline at end of file
signal-web-service/src/main/java/net/wanji/web/common/util/date/DateStyle.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.util.date;
/**
* @author hfx
* @version 1.0
* @Description: [日期风格工具类]
* Created on 2019/4/16 15:07
*/
public enum DateStyle {
YYYY_MM("yyyy-MM", false),
YYYY_MM_DD("yyyy-MM-dd", false),
YYYY_MM_DD_HH_MM("yyyy-MM-dd HH:mm", false),
YYYY_MM_DD_HH_MM_SS("yyyy-MM-dd HH:mm:ss", false),
YYYYMMDDHHMMSS("yyyyMMddHHmmss", false),
YYYYMMDDHHMMSSSSS("yyyyMMddHHmmssSSS", false),
YYYYMMDD("yyyyMMdd", false),
YYYY_MM_EN("yyyy/MM", false),
YYYY_MM_DD_EN("yyyy/MM/dd", false),
YYYY_MM_DD_HH_MM_EN("yyyy/MM/dd HH:mm", false),
YYYY_MM_DD_HH_MM_SS_EN("yyyy/MM/dd HH:mm:ss", false),
DD_MM_YYYY_EN("dd/MM/yyyy", false),
YYYY_MM_CN("yyyy年MM月", false),
YYYY_MM_DD_CN("yyyy年MM月dd日", false),
YYYY_MM_DD_HH_MM_CN("yyyy年MM月dd日 HH:mm", false),
YYYY_MM_DD_HH_MM_SS_CN("yyyy年MM月dd日 HH:mm:ss", false),
HH_MM("HH:mm", true),
HH_MM_SS("HH:mm:ss", true),
MM_DD("MM-dd", true),
MM_DD_HH_MM("MM-dd HH:mm", true),
MM_DD_HH_MM_SS("MM-dd HH:mm:ss", true),
MM_DD_EN("MM/dd", true),
MM_DD_HH_MM_EN("MM/dd HH:mm", true),
MM_DD_HH_MM_SS_EN("MM/dd HH:mm:ss", true),
MM_DD_CN("MM月dd日", true),
MM_DD_HH_MM_CN("MM月dd日 HH:mm", true),
MM_DD_HH_MM_SS_CN("MM月dd日 HH:mm:ss", true);
private String value;
private boolean isShowOnly;
DateStyle(String value, boolean isShowOnly) {
this.value = value;
this.isShowOnly = isShowOnly;
}
public String getValue() {
return value;
}
public boolean isShowOnly() {
return isShowOnly;
}
}
\ No newline at end of file
signal-web-service/src/main/java/net/wanji/web/common/util/date/TimeArrayUtil.java 0 → 100644
View file @ 95b8300b
package net.wanji.web.common.util.date;
import java.util.ArrayList;
import java.util.List;
/**
* @author Kent HAN
* @date 2022/11/3 16:29
*/
public class TimeArrayUtil {
/**
* 返回一天的时间数组，按小时。如 ["00:00", "01:00" ... "23:00"]
*
* @author Kent HAN
* @date 2022/11/3 16:30
*/
public static List<String> getTimeArray() {
List<String> res = new ArrayList<>();
for (int i = 0; i < 24; i++) {
if (i < 10) {
res.add("0" + i + ":00");
} else {
res.add(i + ":00");
}
}
return res;
}
public static void main(String[] args) {
List<String> timeArray = TimeArrayUtil.getTimeArray();
}
}
signal-web-service/src/main/resources/application-dev.yml 0 → 100644
View file @ 95b8300b
This diff is collapsed.
signal-web-service/src/main/resources/application-pro.yml 0 → 100644
View file @ 95b8300b
This diff is collapsed.
signal-web-service/src/main/resources/logback-spring.xml 0 → 100644
View file @ 95b8300b
This diff is collapsed.
signal-web-service/src/main/resources/mapper/RidInfoMapper.xml 0 → 100644
View file @ 95b8300b
This diff is collapsed.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment