更改了import的参数和模板,更改了banIP中IP的存储格式,修复了import的一个bug,删掉了一打todo
parent
468fa90184
commit
d704845357
|
@ -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;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -17,7 +17,7 @@ import java.time.*;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Jackson序列化配置,主要配置了{@link LocalDateTime} {@link LocalDate} {@link LocalTime}转为秒级时间戳的序列化
|
* Jackson序列化配置以及Springboot 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;
|
||||||
|
|
|
@ -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为taskId,value为staffId的map")
|
@Operation(description = "请求体是一个key为taskId,value为staffId的map")
|
||||||
@SneakyThrows
|
@SneakyThrows
|
||||||
@PutMapping("/{staffId}/transfer")
|
@PutMapping("/{staffId}/transfer")
|
||||||
|
|
|
@ -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) {
|
||||||
|
@ -92,7 +91,7 @@ public class StaffController {
|
||||||
@ResponseStatus(HttpStatus.SEE_OTHER)
|
@ResponseStatus(HttpStatus.SEE_OTHER)
|
||||||
public ResponseMap downloadTemplate() {
|
public ResponseMap downloadTemplate() {
|
||||||
return ResponseMap.of(HttpStatus.SEE_OTHER.value(),
|
return ResponseMap.of(HttpStatus.SEE_OTHER.value(),
|
||||||
HttpStatus.SEE_OTHER.getReasonPhrase())
|
HttpStatus.SEE_OTHER.getReasonPhrase())
|
||||||
.put("URI","/public/账户导入模板.xlsx");
|
.put("URI", "/public/账户导入模板.xlsx");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -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
|
||||||
|
|
|
@ -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,10 +162,8 @@ 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++) {
|
||||||
|
@ -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) {
|
||||||
|
|
|
@ -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);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Binary file not shown.
|
@ -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);
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue