Compare commits

...

2 Commits

9 changed files with 51 additions and 23 deletions

View File

@ -22,9 +22,9 @@ public class MybatisPlusConfig {
@Bean @Bean
public MybatisPlusInterceptor mybatisPlusInterceptor() { public MybatisPlusInterceptor mybatisPlusInterceptor() {
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); //分页插件
interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor()); interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor()); //乐观锁插件
interceptor.addInnerInterceptor(new BlockAttackInnerInterceptor()); interceptor.addInnerInterceptor(new BlockAttackInnerInterceptor()); //防全表更新删除插件
return interceptor; return interceptor;
} }
} }

View File

@ -17,7 +17,7 @@ import java.time.*;
import java.util.Map; import java.util.Map;
/** /**
* Jackson{@link LocalDateTime} {@link LocalDate} {@link LocalTime} * JacksonSpringboot Converter
* *
* @author * @author
* @since 2022/6/28 23:59 * @since 2022/6/28 23:59
@ -103,7 +103,6 @@ public class SerializeConfig {
return javaTimeModule; return javaTimeModule;
} }
//TODO: Redis可能改成tostringSerializer
private SimpleModule customClassModule() { private SimpleModule customClassModule() {
SimpleModule customClassModule = new SimpleModule("CustomClassModule"); SimpleModule customClassModule = new SimpleModule("CustomClassModule");
customClassModule.addSerializer(IPAddress.class, new JsonSerializer<>() { customClassModule.addSerializer(IPAddress.class, new JsonSerializer<>() {
@ -117,7 +116,7 @@ public class SerializeConfig {
customClassModule.addDeserializer(IPAddress.class, new JsonDeserializer<>() { customClassModule.addDeserializer(IPAddress.class, new JsonDeserializer<>() {
@Override @Override
public IPAddress deserialize(JsonParser p, DeserializationContext ctxt) throws IOException { public IPAddress deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
return IPAddress.of(Long.decode(p.getValueAsString())); return IPAddress.of(Long.decode('#' + p.getValueAsString()));
} }
}); });
return customClassModule; return customClassModule;

View File

@ -70,7 +70,6 @@ public class ProjectGroupController {
)); ));
} }
//TODO: test
@Operation(description = "body中只传staffUsername和projectStaffPosition") @Operation(description = "body中只传staffUsername和projectStaffPosition")
@SneakyThrows @SneakyThrows
@PostMapping @PostMapping
@ -98,7 +97,6 @@ public class ProjectGroupController {
throw new BadRequestException(BadRequestException.OPERATE_FAILED); throw new BadRequestException(BadRequestException.OPERATE_FAILED);
} }
//TODO: test
@Operation(description = "body中只传projectStaffPosition") @Operation(description = "body中只传projectStaffPosition")
@SneakyThrows @SneakyThrows
@PutMapping("/{staffId}") @PutMapping("/{staffId}")
@ -123,7 +121,6 @@ public class ProjectGroupController {
return ResponseMap.ofSuccess(projectGroupService.collectStatsForGroupPositions(token, projectId)); return ResponseMap.ofSuccess(projectGroupService.collectStatsForGroupPositions(token, projectId));
} }
//TODO: TEST
@Operation(description = "请求体是一个key为taskIdvalue为staffId的map") @Operation(description = "请求体是一个key为taskIdvalue为staffId的map")
@SneakyThrows @SneakyThrows
@PutMapping("/{staffId}/transfer") @PutMapping("/{staffId}/transfer")

View File

@ -4,7 +4,6 @@ import cn.edu.hfut.rmdjzz.projectmanagement.entity.Staff;
import cn.edu.hfut.rmdjzz.projectmanagement.exception.BadRequestException; import cn.edu.hfut.rmdjzz.projectmanagement.exception.BadRequestException;
import cn.edu.hfut.rmdjzz.projectmanagement.exception.TokenException; import cn.edu.hfut.rmdjzz.projectmanagement.exception.TokenException;
import cn.edu.hfut.rmdjzz.projectmanagement.service.IStaffService; import cn.edu.hfut.rmdjzz.projectmanagement.service.IStaffService;
import cn.edu.hfut.rmdjzz.projectmanagement.utils.FileUtils;
import cn.edu.hfut.rmdjzz.projectmanagement.utils.TokenUtils; import cn.edu.hfut.rmdjzz.projectmanagement.utils.TokenUtils;
import cn.edu.hfut.rmdjzz.projectmanagement.utils.http.HttpUtils; import cn.edu.hfut.rmdjzz.projectmanagement.utils.http.HttpUtils;
import cn.edu.hfut.rmdjzz.projectmanagement.utils.http.ResponseMap; import cn.edu.hfut.rmdjzz.projectmanagement.utils.http.ResponseMap;
@ -54,7 +53,7 @@ public class StaffController {
@PostMapping(value = "/import") @PostMapping(value = "/import")
public ResponseMap importStaffs( public ResponseMap importStaffs(
@RequestHeader(TokenUtils.HEADER_TOKEN) String token, @RequestHeader(TokenUtils.HEADER_TOKEN) String token,
@RequestHeader(FileUtils.HEADER_FILE_DIGEST) String digest, @RequestParam("fileDigest") String digest,
@RequestParam("uploadFile") MultipartFile uploadFile @RequestParam("uploadFile") MultipartFile uploadFile
) { ) {
if (null == uploadFile) { if (null == uploadFile) {

View File

@ -1,6 +1,7 @@
package cn.edu.hfut.rmdjzz.projectmanagement.controller; package cn.edu.hfut.rmdjzz.projectmanagement.controller;
import cn.edu.hfut.rmdjzz.projectmanagement.entity.Task; import cn.edu.hfut.rmdjzz.projectmanagement.entity.Task;
import cn.edu.hfut.rmdjzz.projectmanagement.entity.dto.StaffProcessDTO;
import cn.edu.hfut.rmdjzz.projectmanagement.entity.dto.TaskDTO; import cn.edu.hfut.rmdjzz.projectmanagement.entity.dto.TaskDTO;
import cn.edu.hfut.rmdjzz.projectmanagement.exception.BadRequestException; import cn.edu.hfut.rmdjzz.projectmanagement.exception.BadRequestException;
import cn.edu.hfut.rmdjzz.projectmanagement.service.IProjectService; import cn.edu.hfut.rmdjzz.projectmanagement.service.IProjectService;
@ -122,10 +123,9 @@ public class TaskController {
return ResponseMap.ofSuccess("查询成功", taskService.getProjectProcessOfEveryone(token, projectId)); return ResponseMap.ofSuccess("查询成功", taskService.getProjectProcessOfEveryone(token, projectId));
} }
//TODO:
@SneakyThrows @SneakyThrows
@GetMapping({"/stats", "/stats/{staffId}"}) @GetMapping({"/stats", "/stats/{staffId}"})
public ResponseList getProjectStatistics( public ResponseList<StaffProcessDTO> getProjectStatistics(
@RequestHeader(TokenUtils.HEADER_TOKEN) String token, @RequestHeader(TokenUtils.HEADER_TOKEN) String token,
@PathVariable Integer projectId, @PathVariable Integer projectId,
@PathVariable(required = false) Integer staffId @PathVariable(required = false) Integer staffId

View File

@ -10,10 +10,13 @@ import cn.edu.hfut.rmdjzz.projectmanagement.utils.MapBuilder;
import cn.edu.hfut.rmdjzz.projectmanagement.utils.TimeUtils; import cn.edu.hfut.rmdjzz.projectmanagement.utils.TimeUtils;
import cn.edu.hfut.rmdjzz.projectmanagement.utils.TokenUtils; import cn.edu.hfut.rmdjzz.projectmanagement.utils.TokenUtils;
import cn.edu.hfut.rmdjzz.projectmanagement.utils.http.IPAddress; import cn.edu.hfut.rmdjzz.projectmanagement.utils.http.IPAddress;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.lang3.RandomStringUtils;
import org.apache.poi.ss.usermodel.CellType;
import org.apache.poi.xssf.usermodel.XSSFCell;
import org.apache.poi.xssf.usermodel.XSSFSheet; import org.apache.poi.xssf.usermodel.XSSFSheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook; import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -159,11 +162,9 @@ public class StaffServiceImpl extends ServiceImpl<StaffMapper, Staff> implements
throw new BadRequestException("读取列staffGlobalLevel失败"); throw new BadRequestException("读取列staffGlobalLevel失败");
} }
System.out.println(staffGlobalLevelC); System.out.println(staffGlobalLevelC);
for (int i = 0; i < totalCount; i++) { if (staffGlobalLevelC.stream().anyMatch(level -> Integer.parseInt(level) < 2)) {
if (Integer.parseInt(staffGlobalLevelC.get(i)) != 2 && Integer.parseInt(staffGlobalLevelC.get(i)) != 3) {
throw new BadRequestException("列staffGlobalLevel无效"); throw new BadRequestException("列staffGlobalLevel无效");
} }
}
for (int i = 0; i < totalCount; i++) { for (int i = 0; i < totalCount; i++) {
Staff staff = new Staff(); Staff staff = new Staff();
@ -198,10 +199,12 @@ public class StaffServiceImpl extends ServiceImpl<StaffMapper, Staff> implements
return false; return false;
} }
for (int i = 1; i <= sheet.getLastRowNum(); i++) { for (int i = 1; i <= sheet.getLastRowNum(); i++) {
String value = sheet.getRow(i).getCell(columnIndex).getStringCellValue(); XSSFCell cell = sheet.getRow(i).getCell(columnIndex);
if (value == null || value.length() <= 2) cell.setCellType(CellType.STRING);
String value = cell.getStringCellValue();
if (StringUtils.isEmpty(value))
return true; return true;
result.add(value.substring(1, value.length() - 1)); result.add(value);
} }
return true; return true;
} catch (Exception e) { } catch (Exception e) {

View File

@ -16,6 +16,7 @@ public class IPAddress {
public static IPAddress of(String ip) { public static IPAddress of(String ip) {
long ipHex = 0; long ipHex = 0;
ip = ip.substring(0, ip.indexOf(':'));
String[] split = ip.split("\\."); String[] split = ip.split("\\.");
for (String s : split) { for (String s : split) {
ipHex = (ipHex << 8) + Integer.parseInt(s); ipHex = (ipHex << 8) + Integer.parseInt(s);
@ -38,6 +39,6 @@ public class IPAddress {
@Override @Override
public String toString() { public String toString() {
return "#" + Long.toHexString(ipHex); return Long.toHexString(ipHex);
} }
} }

View File

@ -0,0 +1,29 @@
package cn.edu.hfut.rmdjzz.projectmanagement;
import cn.edu.hfut.rmdjzz.projectmanagement.service.IStaffService;
import cn.edu.hfut.rmdjzz.projectmanagement.utils.FileUtils;
import lombok.SneakyThrows;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.mock.web.MockMultipartFile;
import org.springframework.web.multipart.MultipartFile;
/**
* @author
* @since 2022/7/13 10:05
*/
@SpringBootTest
public class ExcelTests {
@Autowired
private IStaffService staffService;
@SneakyThrows
@Test
public void importTest() {
MultipartFile excelFile = new MockMultipartFile("账户导入模板.xlsx",
FileUtils.class.getClassLoader().getResourceAsStream("static/public/账户导入模板.xlsx"));
staffService.multiImport("", excelFile);
}
}