提交 ff1bdcac authored 作者: 朱旭欣's avatar 朱旭欣

第一次提交

上级
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.4/apache-maven-3.8.4-bin.zip
wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar
差异被折叠。
@REM ----------------------------------------------------------------------------
@REM Licensed to the Apache Software Foundation (ASF) under one
@REM or more contributor license agreements. See the NOTICE file
@REM distributed with this work for additional information
@REM regarding copyright ownership. The ASF licenses this file
@REM to you under the Apache License, Version 2.0 (the
@REM "License"); you may not use this file except in compliance
@REM with the License. You may obtain a copy of the License at
@REM
@REM https://www.apache.org/licenses/LICENSE-2.0
@REM
@REM Unless required by applicable law or agreed to in writing,
@REM software distributed under the License is distributed on an
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@REM KIND, either express or implied. See the License for the
@REM specific language governing permissions and limitations
@REM under the License.
@REM ----------------------------------------------------------------------------
@REM ----------------------------------------------------------------------------
@REM Maven Start Up Batch script
@REM
@REM Required ENV vars:
@REM JAVA_HOME - location of a JDK home dir
@REM
@REM Optional ENV vars
@REM M2_HOME - location of maven2's installed home dir
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
@REM e.g. to debug Maven itself, use
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
@REM ----------------------------------------------------------------------------
@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
@echo off
@REM set title of command window
title %0
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
@REM set %HOME% to equivalent of $HOME
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
@REM Execute a user defined script before this one
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
:skipRcPre
@setlocal
set ERROR_CODE=0
@REM To isolate internal variables from possible post scripts, we use another setlocal
@setlocal
@REM ==== START VALIDATION ====
if not "%JAVA_HOME%" == "" goto OkJHome
echo.
echo Error: JAVA_HOME not found in your environment. >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
:OkJHome
if exist "%JAVA_HOME%\bin\java.exe" goto init
echo.
echo Error: JAVA_HOME is set to an invalid directory. >&2
echo JAVA_HOME = "%JAVA_HOME%" >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
@REM ==== END VALIDATION ====
:init
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
@REM Fallback to current working directory if not found.
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
set EXEC_DIR=%CD%
set WDIR=%EXEC_DIR%
:findBaseDir
IF EXIST "%WDIR%"\.mvn goto baseDirFound
cd ..
IF "%WDIR%"=="%CD%" goto baseDirNotFound
set WDIR=%CD%
goto findBaseDir
:baseDirFound
set MAVEN_PROJECTBASEDIR=%WDIR%
cd "%EXEC_DIR%"
goto endDetectBaseDir
:baseDirNotFound
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
cd "%EXEC_DIR%"
:endDetectBaseDir
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
@setlocal EnableExtensions EnableDelayedExpansion
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
:endReadAdditionalConfig
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
)
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
if exist %WRAPPER_JAR% (
if "%MVNW_VERBOSE%" == "true" (
echo Found %WRAPPER_JAR%
)
) else (
if not "%MVNW_REPOURL%" == "" (
SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
)
if "%MVNW_VERBOSE%" == "true" (
echo Couldn't find %WRAPPER_JAR%, downloading it ...
echo Downloading from: %DOWNLOAD_URL%
)
powershell -Command "&{"^
"$webclient = new-object System.Net.WebClient;"^
"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
"}"^
"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
"}"
if "%MVNW_VERBOSE%" == "true" (
echo Finished downloading %WRAPPER_JAR%
)
)
@REM End of extension
@REM Provide a "standardized" way to retrieve the CLI args that will
@REM work with both Windows and non-Windows executions.
set MAVEN_CMD_LINE_ARGS=%*
%MAVEN_JAVA_EXE% ^
%JVM_CONFIG_MAVEN_PROPS% ^
%MAVEN_OPTS% ^
%MAVEN_DEBUG_OPTS% ^
-classpath %WRAPPER_JAR% ^
"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
%WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
if ERRORLEVEL 1 goto error
goto end
:error
set ERROR_CODE=1
:end
@endlocal & set ERROR_CODE=%ERROR_CODE%
if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
@REM check for post script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
:skipRcPost
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
if "%MAVEN_BATCH_PAUSE%"=="on" pause
if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
cmd /C exit /B %ERROR_CODE%
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.6.8</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>demo4</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>demo4</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.9.2</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.9.2</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>
package com.example.demo4;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.servlet.config.annotation.EnableWebMvc;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
/**
* @author tykj
*/
@SpringBootApplication
@EnableWebMvc
@EnableSwagger2
public class Demo4Application {
public static void main(String[] args) {
SpringApplication.run(Demo4Application.class, args);
}
}
package com.example.demo4.config;
import com.google.common.collect.Sets;
import io.swagger.annotations.Api;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
/**
* @author tykj
*/
@Configuration
public class Swagger2Config extends WebMvcConfigurationSupport {
@Bean
public Docket createRestApi() {
return new Docket(DocumentationType.SWAGGER_2)
.produces(Sets.newHashSet("application/json"))
.consumes(Sets.newHashSet("application/json"))
.protocols(Sets.newHashSet("http", "https"))
.apiInfo(apiInfo())
.forCodeGeneration(true)
.useDefaultResponseMessages(true)
.select()
.apis(RequestHandlerSelectors.withClassAnnotation(Api.class))
.paths(PathSelectors.any())
.build()
;
}
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
// 文档标题
.title("XX系统接口文档")
// 文档描述
.description("XX系统接口文档与测试页面")
.termsOfServiceUrl("http://localhost:8083")
.version("v1")
.build();
}
/**
* 我们使用的 @Configuration 继承了WebMvcConfigurationSupport,导致默认的Swagger静态资源被覆盖,而缺失了配置。
* @param registry registry
*/
@Override
public void addResourceHandlers(ResourceHandlerRegistry registry) {
registry.addResourceHandler("doc.html")
.addResourceLocations("classpath:/META-INF/resources/");
registry.addResourceHandler("swagger-ui.html")
.addResourceLocations("classpath:/META-INF/resources/");
registry.addResourceHandler("/webjars/**")
.addResourceLocations("classpath:/META-INF/resources/webjars/");
registry.addResourceHandler("/static/**").addResourceLocations("classpath:/static/");
}
}
package com.example.demo4.controller;
import com.example.demo4.pojo.Anomaly;
import com.example.demo4.pojo.Condition;
import com.example.demo4.pojo.HomePage;
import com.example.demo4.pojo.Supervise;
import com.example.demo4.service.AnomalyService;
import com.example.demo4.service.DetailsService;
import com.example.demo4.service.SuperviseService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.text.ParseException;
import java.util.List;
/**
* @author tykj
*/
@RestController
@RequestMapping("/model3")
@Api(tags = "粮仓AI智能检测系统",description = "基础接口")
public class Controller {
@Autowired
private SuperviseService superviseService;
@Autowired
private DetailsService detailsService;
@Autowired
private AnomalyService anomalyService;
@GetMapping("/findSupervise")
@ApiOperation(value = "根据模块ID查询监管类型")
public List<Supervise> findSupervise(Integer titleId){
return superviseService.findSupervise(titleId);
}
@PostMapping("/findAll")
@ApiOperation(value = "动态查询数据")
public HomePage findAll(Condition condition) throws ParseException {
return anomalyService.findAll(condition);
}
@GetMapping("/findAnomaly")
@ApiOperation(value = "根据ID查询异常详情")
public Anomaly findAnomalyId(Integer id){
return anomalyService.findAnomalyId(id);
}
@PostMapping("/saveProcess")
@ApiOperation(value = "添加处理方式和备注")
public Anomaly saveProcess(Anomaly anomaly){
return anomalyService.saveProcess(anomaly);
}
}
package com.example.demo4.dao;
import com.example.demo4.pojo.Anomaly;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
/**
* @author tykj
*/
public interface AnomalyDao extends JpaRepository<Anomaly,Integer>, JpaSpecificationExecutor<Anomaly> {
}
package com.example.demo4.dao;
import com.example.demo4.pojo.Details;
import org.springframework.data.jpa.repository.JpaRepository;
import java.util.List;
/**
* @author tykj
*/
public interface DetailsDao extends JpaRepository<Details,Integer> {
/**
* 根据ID获取对象
* @param id
* @return
*/
Details findDetailsById(Integer id);
/**
* 根据父ID获取对象
* @param regionId
* @return
*/
List<Details> findDetailsByRegionId(Integer regionId);
}
package com.example.demo4.dao;
import com.example.demo4.pojo.Supervise;
import org.springframework.data.jpa.repository.JpaRepository;
import java.util.List;
/**
* @author tykj
*/
public interface SuperviseDao extends JpaRepository<Supervise,Integer> {
/**
* 根据模块ID查询监管名称
* @param titleId
* @return
*/
List<Supervise> findSuperviseByTitleId(Integer titleId);
}
package com.example.demo4.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import javax.persistence.*;
import java.util.Date;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Entity
@ApiModel("异常详情")
public class Anomaly {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@ApiModelProperty(value = "主键ID",example = "1")
private Integer id;
@JsonFormat(shape =JsonFormat.Shape.STRING,pattern = "yyyy-MM-dd HH:mm:ss",timezone ="GMT+8")
@DateTimeFormat(pattern= "yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value = "时间",example = "2020-1-1")
private Date date;
@ApiModelProperty(value = "图片路径",example = "http://localhost:8083/static/2E6B0C92.png")
private String images;
@ApiModelProperty(value = "模块ID",example = "1")
private Integer titleId;
@Transient
@ApiModelProperty(value = "模块名",example = "人员监管")
private String title;
@ApiModelProperty(value = "地区ID",example = "1")
private Integer regionId;
@Transient
@ApiModelProperty(value = "地区",example = "杭州")
private String region;
@ApiModelProperty(value = "粮仓ID",example = "1")
private Integer granaryId;
@Transient
@ApiModelProperty(value = "粮仓",example = "径山粮仓")
private String granaryName;
@ApiModelProperty(value = "区域ID",example = "1")
private Integer area;
@Transient
@ApiModelProperty(value = "区域",example = "A区")
private String areaName;
@ApiModelProperty(value = "监管ID",example = "1")
private Integer action;
@Transient
@ApiModelProperty(value = "监管名称",example = "人员入仓")
private String superviseName;
@ApiModelProperty(value = "处理方式",example = "劝阻")
private String processTitle;
@ApiModelProperty(value = "备注",example = "一段文字")
private String process;
}
package com.example.demo4.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import javax.persistence.Transient;
import java.util.Date;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("显示页面")
public class AnomalyVO {
@ApiModelProperty(value = "图片路径",example = "http://localhost:8083/static/2E6B0C92.png")
private String images;
@Transient
@ApiModelProperty(value = "粮仓",example = "径山粮仓")
private String granaryName;
@Transient
@ApiModelProperty(value = "区域",example = "A区")
private String areaName;
@JsonFormat(shape =JsonFormat.Shape.STRING,pattern ="yyyy-MM-dd HH:mm:ss",timezone ="GMT+8")
@DateTimeFormat(pattern ="yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value = "时间",example = "2020-1-1 00:00:00")
private Date date;
}
package com.example.demo4.pojo;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import javax.persistence.Id;
import java.util.Date;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("查询条件")
public class Condition {
@ApiModelProperty(value = "模块ID",example = "1")
private Integer titleId;
@ApiModelProperty(value = "页码",example = "1")
private Integer page;
@ApiModelProperty(value = "请求数量",example = "1")
private Integer pageSize;
@ApiModelProperty(value = "地区ID",example = "1")
private Integer regionId;
@ApiModelProperty(value = "粮仓ID",example = "1")
private Integer granary;
@ApiModelProperty(value = "区域ID",example = "1")
private Integer area;
@ApiModelProperty(value = "监管ID",example = "1")
private Integer supervise;
@JsonFormat(shape =JsonFormat.Shape.STRING,pattern ="yyyy-MM-dd HH:mm:ss",timezone ="GMT+8")
@DateTimeFormat(pattern= "yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value = "开始时间",example = "2020-1-1 00:00:00")
private Date startDate;
@JsonFormat(shape =JsonFormat.Shape.STRING,pattern ="yyyy-MM-dd HH:mm:ss",timezone ="GMT+8")
@DateTimeFormat(pattern= "yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value = "结束时间",example = "2020-1-1 00:00:00")
private Date endDate;
}
package com.example.demo4.pojo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import javax.persistence.*;
import java.util.List;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Entity
@ApiModel("地区")
public class Details {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@ApiModelProperty(value = "主键ID",example = "1")
private Integer id;
@ApiModelProperty(value = "父键ID",example = "1")
private Integer regionId;
@ApiModelProperty(value = "地区名",example = "杭州")
private String detailsName;
@Transient
private List<Details> children;
}
package com.example.demo4.pojo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.domain.Page;
import javax.persistence.*;
import java.util.List;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("主模块")
public class HomePage {
@ApiModelProperty(value = "模块ID",example = "1")
private Integer titleId;
@ApiModelProperty(value = "模块名",example = "人员监管")
private String title;
@ApiModelProperty(value = "今日条数",example = "99")
private int today;
@ApiModelProperty(value = "总条数",example = "999")
private Long quantity;
@Transient
private PagePojo anomalyVOList;
}
package com.example.demo4.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class PagePojo {
/**
*数量
*/
private Long total;
/**
*页码
*/
private Integer page;
/**
*请求数量
*/
private Integer pageSize;
/**
*数据
*/
private List<AnomalyVO> anomalyVOList;
}
package com.example.demo4.pojo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Entity
@ApiModel("监管类型")
public class Supervise {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@ApiModelProperty(value = "主键ID",example = "1")
private Integer id;
@ApiModelProperty(value = "模块ID",example = "1")
private Integer titleId;
@ApiModelProperty(value = "监管名称",example = "人员入仓")
private String superviseName;
}
package com.example.demo4.service;
import com.example.demo4.pojo.Anomaly;
import com.example.demo4.pojo.Condition;
import com.example.demo4.pojo.HomePage;
import java.text.ParseException;
/**
* @author tykj
*/
public interface AnomalyService {
/**
* 根据ID查询异常详情
* @param id
* @return
*/
Anomaly findAnomalyId(Integer id);
/**
* 添加处理方式和备注
* @param anomaly
* @return
*/
Anomaly saveProcess(Anomaly anomaly);
/**
* 动态查询
* @param condition
* @return
*/
HomePage findAll(Condition condition) throws ParseException;
}
package com.example.demo4.service;
import com.example.demo4.pojo.Details;
import java.util.List;
/**
* @author tykj
*/
public interface DetailsService {
/**
* 根据ID查询地区名
* @param id
* @return
*/
String saveName(Integer id);
/**
* 根据父键ID查询粮仓和区域
* @param regionId
* @return
*/
List<Details> saveDetailsName(Integer regionId);
}
package com.example.demo4.service;
import com.example.demo4.pojo.Supervise;
import java.util.List;
/**
* @author tykj
*/
public interface SuperviseService {
/**
* 根据模块ID查询监管
* @param titleId
* @return
*/
List<Supervise> findSupervise(Integer titleId);
}
package com.example.demo4.service.imlp;
import com.example.demo4.dao.AnomalyDao;
import com.example.demo4.dao.DetailsDao;
import com.example.demo4.dao.SuperviseDao;
import com.example.demo4.pojo.*;
import com.example.demo4.service.AnomalyService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import javax.persistence.criteria.*;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Optional;
/**
* @author tykj
*/
@Service
@Slf4j
public class AnomalyServiceImpl implements AnomalyService {
@Autowired
private AnomalyDao anomalyDao;
@Autowired
private DetailsDao detailsDao;
@Autowired
private SuperviseDao superviseDao;
/**
* 名称转换方法
* @param anomaly
* @return
*/
private Anomaly getAnomaly(Anomaly anomaly){
//根据地区ID,获取地区名
String detailsName = detailsDao.findById(anomaly.getRegionId()).get().getDetailsName();
anomaly.setRegion(detailsName);
//根据粮仓ID,获取粮仓名
String detailsName1 = detailsDao.findById(anomaly.getGranaryId()).get().getDetailsName();
anomaly.setGranaryName(detailsName1);
//根据区域ID,获取区域名
String detailsName2 = detailsDao.findById(anomaly.getArea()).get().getDetailsName();
anomaly.setAreaName(detailsName2);
//根据监管ID,获取监管名称
String superviseName = superviseDao.findById(anomaly.getAction()).get().getSuperviseName();
anomaly.setSuperviseName(superviseName);
return anomaly;
}
@Override
public Anomaly findAnomalyId(Integer id) {
log.info("查询id为:{}的异常详情",id);
Anomaly anomaly = new Anomaly();
Optional<Anomaly> byId = anomalyDao.findById(id);
Anomaly anomaly1 = byId.orElse(anomaly);
return getAnomaly(anomaly1);
}
@Override
public Anomaly saveProcess(Anomaly anomaly) {
Integer anomalyId = anomaly.getId();
Anomaly anomalyId1 = findAnomalyId(anomalyId);
anomaly.setDate(anomalyId1.getDate());
return getAnomaly(anomalyDao.save(anomaly));
}
@Override
public HomePage findAll(Condition condition) throws ParseException {
//根据用户传入的参数,进行分页,获取分页后的数据
Pageable pageable = PageRequest.of(condition.getPage(), condition.getPageSize());
//动态查询构造器
Specification<Anomaly> queryCondition = new Specification<Anomaly>() {
@Override
public Predicate toPredicate(Root<Anomaly> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
List<Predicate> predicateList = new ArrayList<>();
if (condition.getTitleId()!=null){
predicateList.add(criteriaBuilder.equal(root.get("titleId"), condition.getTitleId()));
}
if (condition.getRegionId() != null) {
predicateList.add(criteriaBuilder.equal(root.get("regionId"), condition.getRegionId()));
}
if (condition.getGranary() != null) {
predicateList.add(criteriaBuilder.equal(root.get("granaryId"), condition.getGranary()));
}
if (condition.getArea() != null) {
predicateList.add(criteriaBuilder.equal(root.get("area"), condition.getArea()));
}
if (condition.getSupervise() != null) {
predicateList.add(criteriaBuilder.equal(root.get("action"), condition.getSupervise()));
}
if (condition.getStartDate() != null) {
//使用criteriaBuilder.greaterThan方法,进行比较date,greaterThan大于等于,lessThan小于等于
predicateList.add(criteriaBuilder.greaterThan(root.get("date").as(Date.class),condition.getStartDate()));
}
if (condition.getEndDate() != null) {
predicateList.add(criteriaBuilder.lessThan(root.get("date").as(Date.class),condition.getEndDate()));
}
return criteriaBuilder.and(predicateList.toArray(new Predicate[predicateList.size()]));
}
};
Page<Anomaly> page = anomalyDao.findAll(queryCondition, pageable);
List<AnomalyVO> anomalyVoList = new ArrayList<>();
List<Anomaly> content = page.getContent();
//循环赋值,把属性注入VO
for (Anomaly anomaly : content) {
AnomalyVO anomalyVO = new AnomalyVO();
BeanUtils.copyProperties(getAnomaly(anomaly),anomalyVO);
anomalyVoList.add(anomalyVO);
}
PagePojo pagePojo = new PagePojo();
pagePojo.setPage(condition.getPage());
pagePojo.setPageSize(condition.getPageSize());
pagePojo.setTotal(page.getTotalElements());
pagePojo.setAnomalyVOList(anomalyVoList);
HomePage homePage =new HomePage();
homePage.setTitleId(condition.getTitleId());
Optional<Anomaly> byId = anomalyDao.findById(condition.getTitleId());
Anomaly anomaly = new Anomaly();
Anomaly anElse = byId.orElse(anomaly);
homePage.setTitle(anElse.getTitle());
List<Anomaly> all = anomalyDao.findAll();
List<Anomaly> o = new ArrayList<>();
//时间转换,把时间转化为年月日
SimpleDateFormat simpleDateFormat=new SimpleDateFormat("yyyy-MM-dd");
String transformDate=simpleDateFormat.format(new Date());
Date afterDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(transformDate + " 00:00:00");
Date endDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(transformDate+" 23:59:59");
for (Anomaly anomaly1 :all){
//判读时间是否在当日内
if (anomaly1.getDate().after(afterDate) && anomaly1.getDate().before(endDate)){
o.add(anomaly1);
}
}
// 通过page获取数据总条数
long totalElements = page.getTotalElements();
homePage.setToday(o.size());
homePage.setQuantity(totalElements);
homePage.setAnomalyVOList(pagePojo);
return homePage;
}
}
package com.example.demo4.service.imlp;
import com.example.demo4.dao.DetailsDao;
import com.example.demo4.pojo.Details;
import com.example.demo4.service.DetailsService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* @author tykj
*/
@Service
@Slf4j
public class DetailsServiceImpl implements DetailsService {
@Autowired
private DetailsDao detailsDao;
@Override
public String saveName(Integer id) {
Details detailsById = detailsDao.findDetailsById(id);
return detailsById.getDetailsName();
}
@Override
public List<Details> saveDetailsName(Integer regionId) {
return detailsDao.findDetailsByRegionId(regionId) ;
}
}
package com.example.demo4.service.imlp;
import com.example.demo4.dao.SuperviseDao;
import com.example.demo4.pojo.Supervise;
import com.example.demo4.service.SuperviseService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* @author tykj
*/
@Service
@Slf4j
public class SuperviseServiceImpl implements SuperviseService {
@Autowired
private SuperviseDao superviseDao;
@Override
public List<Supervise> findSupervise(Integer titleId) {
return superviseDao.findSuperviseByTitleId(titleId);
}
}
server.port=8083
# mysql jdbc
spring.datasource.url=jdbc:mysql://localhost:3306/user?serverTimezone=Asia/Shanghai&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.username=root
spring.datasource.password=123456
spring.jpa.hibernate.ddl-auto=update
spring.jpa.show-sql=true
spring.jpa.properties.hibernate.format_sql=true
package com.example.demo4;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class Demo4ApplicationTests {
@Test
void contextLoads() {
}
}
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论