Skip to content

T
ty-weekly
提交 331a7d7e authored 作者: 朱旭欣's avatar 朱旭欣
浏览文件
操作

第一次提交

上级
全部展开 显示空白字符变更
内嵌 并排
正在显示 包含 1224 行增加 和 0 行删除
.gitignore 0 → 100644
浏览文件 @ 331a7d7e
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/
.mvn/wrapper/maven-wrapper.properties 0 → 100644
浏览文件 @ 331a7d7e
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.5/apache-maven-3.8.5-bin.zip
wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar
mvnw 0 → 100644
浏览文件 @ 331a7d7e
差异被折叠。
mvnw.cmd 0 → 100644
浏览文件 @ 331a7d7e
@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%
pom.xml 0 → 100644
浏览文件 @ 331a7d7e
<?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.4.1</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>ty-weekly</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>ty-weekly</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.10</version>
</dependency>
<dependency>
<groupId>javax.validation</groupId>
<artifactId>validation-api</artifactId>
<version>2.0.1.Final</version>
</dependency>
<dependency>
<groupId>org.hibernate</groupId>
<artifactId>hibernate-validator</artifactId>
<version>5.1.2.Final</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web-services</artifactId>
</dependency>
<dependency>
<groupId>org.jetbrains</groupId>
<artifactId>annotations</artifactId>
<version>20.1.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</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>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.9.1</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.9.1</version>
</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>
src/main/java/com/example/tyweekly/TyWeeklyApplication.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
/**
* @author tykj
*/
@SpringBootApplication
@EnableSwagger2
public class TyWeeklyApplication {
public static void main(String[] args) {
SpringApplication.run(TyWeeklyApplication.class, args);
}
}
src/main/java/com/example/tyweekly/config/Swagger2Config.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.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 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 {
@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:8084")
.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/");
// }
}
src/main/java/com/example/tyweekly/config/TimedTask.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.config;
import com.example.tyweekly.dao.WeeklyFileDao;
import com.example.tyweekly.entity.WeeklyFile;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;
/**
* @author tykj
*/
@Component
@Slf4j
@EnableScheduling
public class TimedTask {
private static final int BUFFER_SIZE = 2 * 1024;
@Autowired
private WeeklyFileDao weeklyFileDao;
@Scheduled(cron = "0 0 0/24 * * *")
public void save() {
List<WeeklyFile> all = weeklyFileDao.findAll();
List<Integer> ids =new ArrayList<>();
for (WeeklyFile weeklyFile : all) {
Integer id = weeklyFile.getId();
ids.add(id);
}
for (Integer id : ids){
String videoUpload = weeklyFileDao.findById(id).get().getUploadAddress();
File file = new File(videoUpload);
file.delete();
}
weeklyFileDao.deleteAll();
log.info("定时删除");
}
/**
* 递归压缩方法
* @param sourceFile 源文件
* @param zos zip输出流
* @param name 压缩后的名称
* @param KeepDirStructure 是否保留原来的目录结构,true:保留目录结构;
* false:所有文件跑到压缩包根目录下(注意：不保留目录结构可能会出现同名文件,会压缩失败)
* @throws Exception
*/
private static void compress(File sourceFile, ZipOutputStream zos, String name,
boolean KeepDirStructure) throws Exception{
byte[] buf = new byte[BUFFER_SIZE];
if(sourceFile.isFile()){
// 向zip输出流中添加一个zip实体，构造器中name为zip实体的文件的名字
zos.putNextEntry(new ZipEntry(name));
// copy文件到zip输出流中
int len;
FileInputStream in = new FileInputStream(sourceFile);
while ((len = in.read(buf)) != -1){
zos.write(buf, 0, len);
}
// Complete the entry
zos.closeEntry();
in.close();
} else {
File[] listFiles = sourceFile.listFiles();
if(listFiles == null || listFiles.length == 0){
// 需要保留原来的文件结构时,需要对空文件夹进行处理
if(KeepDirStructure){
// 空文件夹的处理
zos.putNextEntry(new ZipEntry(name + "/"));
// 没有文件，不需要文件的copy
zos.closeEntry();
}
}else {
for (File file : listFiles) {
// 判断是否需要保留原来的文件结构
if (KeepDirStructure) {
// 注意：file.getName()前面需要带上父文件夹的名字加一斜杠,
// 不然最后压缩包中就不能保留原来的文件结构,即：所有文件都跑到压缩包根目录下了
compress(file, zos, name + "/" + file.getName(),KeepDirStructure);
} else {
compress(file, zos, file.getName(),KeepDirStructure);
}
}
}
}
}
/**
* 压缩成ZIP 方法2
* @param srcFiles 需要压缩的文件列表
* @param out 压缩文件输出流
* @throws RuntimeException 压缩失败会抛出运行时异常
*/
public static void toZip(List<File> srcFiles , OutputStream out)throws RuntimeException {
long start = System.currentTimeMillis();
ZipOutputStream zos = null ;
try {
zos = new ZipOutputStream(out);
for (File srcFile : srcFiles) {
byte[] buf = new byte[BUFFER_SIZE];
zos.putNextEntry(new ZipEntry(srcFile.getName()));
int len;
FileInputStream in = new FileInputStream(srcFile);
while ((len = in.read(buf)) != -1){
zos.write(buf, 0, len);
}
zos.closeEntry();
in.close();
}
long end = System.currentTimeMillis();
System.out.println("压缩完成，耗时：" + (end - start) +" ms");
} catch (Exception e) {
throw new RuntimeException("zip error from ZipUtils",e);
}finally{
if(zos != null){
try {
zos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
src/main/java/com/example/tyweekly/config/WebMvcConfig.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.CorsRegistry;
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import java.io.File;
/**
* @author zsp
* @version V1.0
* @data 2020/6/11
**/
@Configuration
public class WebMvcConfig {
@Bean
public WebMvcConfigurer corsConfigurer() {
return new WebMvcConfigurer() {
@Override
public void addCorsMappings(CorsRegistry registry) {
registry.addMapping("/**")
.allowCredentials(true)
.allowedOriginPatterns("*")
.allowedMethods("GET", "POST", "DELETE", "PUT", "PATCH")
.maxAge(3600);
}
@Override
public void addResourceHandlers(ResourceHandlerRegistry registry) {
registry.addResourceHandler("/file/**")
.addResourceLocations("file:" + "C:\\Intel\\" +File.separator);
}
};
}
}
src/main/java/com/example/tyweekly/controller/UserController.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.controller;
import com.example.tyweekly.entity.ReturnPojo;
import com.example.tyweekly.entity.WeeklyUser;
import com.example.tyweekly.service.WeeklyUserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
/**
* @author tykj
*/
@RestController
@RequestMapping("/ty-weekly/user")
@Api(tags = "周报管理系统",description = "用户信息接口")
@Validated
public class UserController {
@Autowired
private WeeklyUserService weeklyUserService;
@PostMapping("/saveUser")
@ApiOperation(value = "新增用户")
public WeeklyUser saveOne(@RequestBody WeeklyUser weeklyUser){
return weeklyUserService.saveOne(weeklyUser);
}
@DeleteMapping("/deleteUser/{id}")
@ApiOperation(value = "删除用户")
public ReturnPojo deleteUser(@PathVariable("id")Integer id){
weeklyUserService.deleteUser(id);
return ReturnPojo.ok("删除成功");
}
}
src/main/java/com/example/tyweekly/controller/WeeklyController.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.controller;
import com.example.tyweekly.entity.PagePojo;
import com.example.tyweekly.entity.ReturnPojo;
import com.example.tyweekly.entity.WeeklyCondition;
import com.example.tyweekly.entity.WeeklyFile;
import com.example.tyweekly.service.WeeklyFileService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import java.io.FileNotFoundException;
import java.io.IOException;
/**
* @author tykj
*/
@RestController
@RequestMapping("/ty-weekly/weekly")
@Api(tags = "周报管理系统",description = "周报信息接口")
@Validated
public class WeeklyController {
@Autowired
private WeeklyFileService weeklyFileService;
@PostMapping("/saveFile")
@ApiOperation(value = "周报文件上传")
public ReturnPojo saveFile2(@RequestParam("multipartFile2") MultipartFile multipartFile2){
try {
return ReturnPojo.ok(weeklyFileService.uploadDatum(multipartFile2),"上传成功") ;
} catch (IOException e) {
e.printStackTrace();
}return ReturnPojo.error(404,"上传失败");
}
@DeleteMapping("/deleteFile")
@ApiOperation(value = "周报文件删除")
public ReturnPojo deleteFile(@PathVariable("id")Integer id){
weeklyFileService.deleteFile(id);
return ReturnPojo.ok("删除成功");
}
@PostMapping("/findAllWeekly")
@ApiOperation(value = "周报情况动态查询")
public PagePojo findAllWeekly(@RequestBody WeeklyCondition weeklyCondition){
return weeklyFileService.findAllWeekly(weeklyCondition);
}
@PostMapping("/download")
@ApiOperation(value = "一键下载")
public ReturnPojo downloadZip() throws FileNotFoundException {
weeklyFileService.downloadZip();
return ReturnPojo.ok("下载成功");
}
}
src/main/java/com/example/tyweekly/dao/WeeklyFileDao.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.dao;
import com.example.tyweekly.entity.WeeklyFile;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
/**
* @author tykj
*/
public interface WeeklyFileDao extends JpaRepository<WeeklyFile,Integer>, JpaSpecificationExecutor<WeeklyFile> {
}
src/main/java/com/example/tyweekly/dao/WeeklyUserDao.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.dao;
import com.example.tyweekly.entity.WeeklyUser;
import org.springframework.data.jpa.repository.JpaRepository;
/**
* @author tykj
*/
public interface WeeklyUserDao extends JpaRepository<WeeklyUser,Integer> {
}
src/main/java/com/example/tyweekly/entity/PagePojo.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.entity;
import io.swagger.annotations.ApiModel;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("分页显示")
public class PagePojo {
/**
*数量
*/
private Long total;
/**
*页码
*/
private Integer page;
/**
*请求数量
*/
private Integer pageSize;
/**
*周报数据
*/
private List<WeeklyFileVO> weeklyFileVOList;
}
src/main/java/com/example/tyweekly/entity/ReturnPojo.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
public class ReturnPojo {
private Integer code;
private String message;
private Object data;
private ReturnPojo() { }
public static ReturnPojo ok(Object data, String message) {
return new ReturnPojo(200, message,data);
}
public static ReturnPojo ok(String data) {
return ReturnPojo.ok(data, "success");
}
public static ReturnPojo error( Integer code, String message) {
return new ReturnPojo(code, message, "");
}
}
src/main/java/com/example/tyweekly/entity/WeeklyCondition.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.entity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import javax.validation.constraints.NotNull;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("查询条件")
public class WeeklyCondition {
@NotNull(message = "页码不能为空")
@ApiModelProperty(value = "页码",example = "1")
private Integer page;
@NotNull(message = "请求数量不能为空")
@ApiModelProperty(value = "请求数量",example = "1")
private Integer pageSize;
@ApiModelProperty(value = "状态",example = "ture")
private Boolean state;
}
src/main/java/com/example/tyweekly/entity/WeeklyFile.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.entity;
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.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import java.time.LocalDateTime;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Entity
@ApiModel("周报文件")
public class WeeklyFile {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@ApiModelProperty(value = "文件主键ID",example = "1")
private Integer id;
@ApiModelProperty(value = "文件名字",example = "2022年1月1日xxx")
private String weeklyName;
@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 = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime uploadTime;
@ApiModelProperty(value = "文件保存路径",example = "文件地址")
private String uploadAddress;
@ApiModelProperty(value = "状态",example = "ture")
private Boolean state;
}
src/main/java/com/example/tyweekly/entity/WeeklyFileVO.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.entity;
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 java.time.LocalDateTime;
/**
* @author tykj
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("后台显示")
public class WeeklyFileVO {
@ApiModelProperty(value = "用户名称",example = "小明")
private String userName;
@ApiModelProperty(value = "文件名字",example = "2022年1月1日xxx")
private String weeklyName;
@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 = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime uploadTime;
@ApiModelProperty(value = "状态",example = "ture")
private Boolean state;
}
src/main/java/com/example/tyweekly/entity/WeeklyUser.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.entity;
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 WeeklyUser {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@ApiModelProperty(value = "用户主键ID",example = "1")
private Integer id;
@ApiModelProperty(value = "用户名称",example = "小明")
private String userName;
}
src/main/java/com/example/tyweekly/service/WeeklyFileService.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.service;
import com.example.tyweekly.entity.PagePojo;
import com.example.tyweekly.entity.ReturnPojo;
import com.example.tyweekly.entity.WeeklyCondition;
import com.example.tyweekly.entity.WeeklyFile;
import org.springframework.web.multipart.MultipartFile;
import java.io.FileNotFoundException;
import java.io.IOException;
/**
* @author tykj
*/
public interface WeeklyFileService {
/**
* 周报上传
* @param file
* @return
* @throws IOException
*/
WeeklyFile uploadDatum(MultipartFile file) throws IOException;
/**
* 删除周报
* @param id
* @return
*/
void deleteFile(Integer id);
/**
* 分页查询
* @param weeklyCondition
* @return
*/
PagePojo findAllWeekly(WeeklyCondition weeklyCondition);
/**
* 下载
* @throws FileNotFoundException
*/
void downloadZip() throws FileNotFoundException;
}
src/main/java/com/example/tyweekly/service/WeeklyUserService.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.service;
import com.example.tyweekly.entity.ReturnPojo;
import com.example.tyweekly.entity.WeeklyUser;
/**
* @author tykj
*/
public interface WeeklyUserService {
/**
* 添加用户
* @param weeklyUser
* @return
*/
WeeklyUser saveOne(WeeklyUser weeklyUser);
/**
* 删除用户
* @param id
* @return
*/
void deleteUser(Integer id);
}
src/main/java/com/example/tyweekly/service/impl/WeeklyFileServiceImpl.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.service.impl;
import com.example.tyweekly.config.TimedTask;
import com.example.tyweekly.dao.WeeklyFileDao;
import com.example.tyweekly.dao.WeeklyUserDao;
import com.example.tyweekly.entity.*;
import com.example.tyweekly.service.WeeklyFileService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.time.LocalDateTime;
import java.util.*;
/**
* @author tykj
*/
@Service
@Slf4j
public class WeeklyFileServiceImpl implements WeeklyFileService {
@Autowired
private WeeklyFileDao weeklyFileDao;
@Autowired
private WeeklyUserDao weeklyUserDao;
@Override
public WeeklyFile uploadDatum(MultipartFile file) throws IOException {
//MultipartFile 接收前端传过来的文件
// 注意 前端传参的name要和MultipartFile的对象名保持一直 比如此处对象名为file 则前端传参的name也要为file
//获取上传文件的文件名
String oldName=file.getOriginalFilename();
List<WeeklyFile> all = weeklyFileDao.findAll();
//删除重名文件
for (WeeklyFile weeklyFile : all) {
if (weeklyFile.getWeeklyName().equals(oldName)){
weeklyFileDao.deleteById(weeklyFile.getId());
}
}
//指定上传路径
String path="C:\\Intel\\周报文件夹\\";
//拼接成为新文件的路径
String filePath=path+oldName;
//创建新文件对象 指定文件路径为拼接好的路径
File newFile=new File(filePath);
//将前端传递过来的文件输送给新文件 这里需要抛出IO异常 throws IOException
file.transferTo(newFile);
//上传完成后将文件路径返回给前端用作图片回显或增加时的文件路径值等
WeeklyFile weeklyFile1 = new WeeklyFile();
weeklyFile1.setUploadAddress(filePath);
weeklyFile1.setWeeklyName(oldName);
weeklyFile1.setUploadTime(LocalDateTime.now());
weeklyFile1.setState(false);
return weeklyFileDao.save(weeklyFile1);
}
@Override
public void deleteFile(Integer id) {
weeklyFileDao.deleteById(id);
}
@Override
public PagePojo findAllWeekly(WeeklyCondition weeklyCondition) {
//根据传入的数据，进行分页数据查询
PageRequest of1 = PageRequest.of(weeklyCondition.getPage()-1, weeklyCondition.getPageSize());
//动态查询构造器
Specification<WeeklyFile> queryCondition = new Specification<WeeklyFile>(){
@Override
public Predicate toPredicate(Root<WeeklyFile> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
List<Predicate> predicateList = new ArrayList<>();
if (weeklyCondition.getState()!=null){
predicateList.add(criteriaBuilder.equal(root.get("state"),weeklyCondition.getState()));
}
return criteriaBuilder.and(predicateList.toArray(new Predicate[predicateList.size()]));
}
};
Page<WeeklyFile> all = weeklyFileDao.findAll(queryCondition, of1);
List<WeeklyFile> content = all.getContent();
List<WeeklyFileVO> weeklyFileVOList = new ArrayList<>();
List<WeeklyUser> userList = weeklyUserDao.findAll();
for (WeeklyUser weeklyUser : userList) {
String userName = weeklyUser.getUserName();
WeeklyFileVO weeklyFileVO =new WeeklyFileVO();
weeklyFileVO.setUserName(userName);
weeklyFileVO.setState(false);
for (WeeklyFile weeklyFile : content) {
if (weeklyFile.getWeeklyName().contains(userName)){
weeklyFileVO.setState(true);
WeeklyFile weeklyFile1 = weeklyFileDao.findById(weeklyFile.getId()).get();
weeklyFile1.setState(true);
weeklyFileDao.save(weeklyFile1);
weeklyFileVO.setUploadTime(weeklyFile.getUploadTime());
weeklyFileVO.setWeeklyName(weeklyFile.getWeeklyName());
}
}
weeklyFileVOList.add(weeklyFileVO);
}
PagePojo pagePojo =new PagePojo();
pagePojo.setPage(weeklyCondition.getPage());
pagePojo.setPageSize(weeklyCondition.getPageSize());
pagePojo.setTotal(all.getTotalElements());
pagePojo.setWeeklyFileVOList(weeklyFileVOList);
return pagePojo;
}
@Override
public void downloadZip() throws FileNotFoundException {
List<WeeklyFile> all = weeklyFileDao.findAll();
List<File> fileList = new ArrayList<>();
for (WeeklyFile weeklyFile : all) {
fileList.add(new File(weeklyFile.getUploadAddress()));
}
FileOutputStream fos2 = new FileOutputStream(new File("C:\\Intel\\周报文件夹\\ty-weekly.zip"));
TimedTask.toZip(fileList,fos2);
}
}
src/main/java/com/example/tyweekly/service/impl/WeeklyUserServiceImpl.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly.service.impl;
import com.example.tyweekly.dao.WeeklyUserDao;
import com.example.tyweekly.entity.ReturnPojo;
import com.example.tyweekly.entity.WeeklyUser;
import com.example.tyweekly.service.WeeklyUserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @author tykj
*/
@Service
@Slf4j
public class WeeklyUserServiceImpl implements WeeklyUserService {
@Autowired
private WeeklyUserDao weeklyUserDao;
@Override
public WeeklyUser saveOne(WeeklyUser weeklyUser) {
return weeklyUserDao.save(weeklyUser);
}
@Override
public void deleteUser(Integer id) {
weeklyUserDao.deleteById(id);
}
}
src/main/resources/application.properties 0 → 100644
浏览文件 @ 331a7d7e
server.port=8088
# 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
src/test/java/com/example/tyweekly/TyWeeklyApplicationTests.java 0 → 100644
浏览文件 @ 331a7d7e
package com.example.tyweekly;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class TyWeeklyApplicationTests {
@Test
void contextLoads() {
}
}
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论