zhc077
/
projectManagement
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

加入导入前校验中文名称英文名重复，将功能编码改为自动添加，解决任务时长、实际时长为负数问题

Browse Source
dev^2
guilongma 1 year ago
parent ff8e8754b9
commit 679dc7dd15
2 changed files with 119 additions and 78 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 5
      jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/entity/FunctionxTest.java
  2. 180
      jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/service/impl/FunctionXTestServiceImpl.java

5
jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/entity/FunctionxTest.java
Unescape View File

@ -24,8 +24,7 @@ public class FunctionxTest implements Serializable {
/**
* 对应上级模块
*/
@TableField("p_module_name")
private String pModuleName;
private String project;
/**
* 对应模块
@ -45,7 +44,7 @@ public class FunctionxTest implements Serializable {
/**
* 功能编码
*/
private String functionCode;
// private String functionCode;
/**
* 功能类型

180
jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/service/impl/FunctionXTestServiceImpl.java
Unescape View File

@ -23,13 +23,14 @@ import org.jeecg.modules.modulex.entity.Modulex;
import org.jeecg.modules.modulex.service.IModulexService;
import org.jeecg.modules.projectUserRole.entity.ProjectUserRole;
import org.jeecg.modules.projectUserRole.service.IProjectUserRoleService;
import org.jeecg.modules.projectx.entity.Projectx;
import org.jeecg.modules.projectx.service.IProjectxService;
import org.jeecg.modules.system.entity.SysUser;
import org.jeecg.modules.system.service.ISysUserService;
import org.jeecg.modules.tablex.vo.TablexVo;
import org.jeecg.modules.tablex.ws.WebSocketUtils;
import org.jeecgframework.poi.excel.entity.ImportParams;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
@ -49,8 +50,11 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
private ISysUserService sysUserService;
@Autowired
private WebSocketUtils webSocketUtils;
@Autowired
private IProjectxService projectxService;
@Override
@Transactional
public Result<?> importExcel(MultipartFile file) {
// 获取当前操作用户
@ -137,46 +141,51 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
}
//------------接收-------------
FunctionxTest fun = new FunctionxTest();
fun.setPModuleName(list.get(0));
fun.setProject(list.get(0)); // 对应项目
fun.setModuleName(list.get(1)); // 对应模块
fun.setFunctionName(list.get(2)); // 中文名称
fun.setFunctionEnName(list.get(3)); // 英文名称
fun.setFunctionCode(list.get(4)); // 功能编码
fun.setFunctionType(list.get(5)); // 功能类型
fun.setPmDescribe(list.get(6)); // 功能描述
fun.setUserRole(list.get(7)); // 用户角色
fun.setManagerUsers(list.get(8)); // 责任人
fun.setWorkLevel(list.get(9)); // 任务等级
fun.setWorkStatus(list.get(10)); // 任务状态
fun.setPublishTime(list.get(11)); // 发布时间
fun.setStartTime(list.get(12)); // 开始时间
fun.setDuration(list.get(13)); // 任务时长
fun.setSubmitTime(list.get(14)); // 提交时间
fun.setRealDuration(list.get(15)); // 实际时长
fun.setStatus(list.get(16)); // 功能状态
fun.setVerisonStatus(list.get(17)); // 版本状态
fun.setVerison(list.get(18)); // 版本号
// fun.setFunctionCode(list.get(4)); // 功能编码
fun.setFunctionType(list.get(4)); // 功能类型
fun.setPmDescribe(list.get(5)); // 功能描述
fun.setUserRole(list.get(6)); // 用户角色
fun.setManagerUsers(list.get(7)); // 责任人
fun.setWorkLevel(list.get(8)); // 任务等级
fun.setWorkStatus(list.get(9)); // 任务状态
fun.setPublishTime(list.get(10)); // 发布时间
fun.setStartTime(list.get(11)); // 开始时间
fun.setDuration(list.get(12)); // 任务时长
fun.setSubmitTime(list.get(13)); // 提交时间
fun.setRealDuration(list.get(14)); // 实际时长
fun.setStatus(list.get(15)); // 功能状态
fun.setVerisonStatus(list.get(16)); // 版本状态
fun.setVerison(list.get(17)); // 版本号
fun.setCreatName(username);
listVo.add(fun);
}
}
boolean isSuccessSave = this.saveBatch(listVo);
if (!isSuccessSave) {
LambdaQueryWrapper<FunctionxTest> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(username != null, FunctionxTest::getCreatName, username);
List<FunctionxTest> list = this.list(queryWrapper);
int isSaveTestSuccess = saveTest(listVo);
if (isSaveTestSuccess != -1){
this.remove(queryWrapper);
message.put("isError", "true");
message.put("status", "文件读入失败");
message.put("status", "第" + (isSaveTestSuccess+1) + "行中文名或英文名有重复");
message.put("closeable", "true");
webSocketUtils.sendMessage(loginUser.getId(), message);
return Result.error("文件读入失败");
return Result.error("中文名或英文名有重复");
}
message.put("status", "数据校验");
webSocketUtils.sendMessage(loginUser.getId(), message);
//************************具体字段校验******************************
LambdaQueryWrapper<FunctionxTest> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(username != null, FunctionxTest::getCreatName, username);
List<FunctionxTest> list = this.list(queryWrapper);
boolean remove = this.remove(queryWrapper);
if (!remove) {
@ -193,11 +202,11 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
for (int i = 0; i < list.size(); i++) {
FunctionxTest function = list.get(i);
Functionx functionx = new Functionx();
String pModuleId = function.getPModuleName();
String project = function.getProject();
String moduleId = function.getModuleName();
String functionName = function.getFunctionName();
String functionEnName = function.getFunctionEnName();
String functionCode = function.getFunctionCode();
// String functionCode = function.getFunctionCode();
String functionType = function.getFunctionType();
String pmDescribe = function.getPmDescribe();
String userRole = function.getUserRole();
@ -214,41 +223,46 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
String verison = function.getVerison();
String moduleName = ""; // 模块编码
String moduleCode= ""; // 模块编码
functionx.setCreateBy(username); // 创建人
functionx.setCreateTime(new Date()); //创建日期
if (StringUtils.isBlank(moduleId)) {
if (StringUtils.isBlank(project)) {
message.put("isError", "true");
message.put("status", "第" + i + "行数据对应模块不能为空");
message.put("status", "第" + (i+1) + "行数据项目名称不能为空");
message.put("closeable", "true");
webSocketUtils.sendMessage(loginUser.getId(), message);
return Result.error("对应模块不能为空");
return Result.error("项目名称不能为空");
} else {
if (pModuleId != null && pModuleId.length()>0) {
String pid = "";
for (Modulex modulex : modulexList) {
if (modulex.getModuleName().equals(pModuleId)) {
pid = modulex.getId();
break;
}
}
for (Modulex modulex : modulexList) {
if (modulex.getModuleName().equals(moduleId) && modulex.getPid().equals(pid)) {
functionx.setModuleId(modulex.getId());
moduleId = modulex.getId();
moduleName = modulex.getModuleName();
break;
LambdaQueryWrapper<Projectx> projectxQueryWrapper =new LambdaQueryWrapper<>();
projectxQueryWrapper.eq(Projectx::getProjectName,project);
List<Projectx> list1 = projectxService.list(projectxQueryWrapper);
if (list1.size()==0){
message.put("isError", "true");
message.put("status", "第" + i + "行数据项目名称错误");
message.put("closeable", "true");
webSocketUtils.sendMessage(loginUser.getId(), message);
return Result.error("项目名称错误");
}
project = list1.get(0).getId(); // 此时project为项目id
}
if (StringUtils.isBlank(moduleId)) {
message.put("isError", "true");
message.put("status", "第" + i + "行数据对应模块不能为空");
message.put("closeable", "true");
webSocketUtils.sendMessage(loginUser.getId(), message);
return Result.error("对应模块不能为空");
} else {
for (Modulex modulex : modulexList) {
if (modulex.getModuleName().equals(moduleId) && modulex.getPid() == null) {
if (modulex.getModuleName().equals(moduleId) && modulex.getProjectId().equals(project)) {
functionx.setModuleId(modulex.getId());
moduleId = modulex.getId();
moduleName = modulex.getModuleName();
moduleCode = modulex.getModuleCode();
break;
}
}
}
if (functionx.getModuleId() == null) {
message.put("isError", "true");
message.put("status", "第" + (i+1) + "行数据数据对应模块有错误");
@ -342,30 +356,32 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
}
functionx.setFunctionType(type);
}
// 模块编码+功能缩写；自动填充+手动修改
if (StringUtils.isBlank(functionCode)) {
message.put("isError", "true");
message.put("status", "第" + (i+1) + "行数据数据功能编码不能为空");
message.put("closeable", "true");
webSocketUtils.sendMessage(loginUser.getId(), message);
return Result.error("功能编码不能为空");
} else {
LambdaQueryWrapper<Modulex> queryWrapperModulex = new LambdaQueryWrapper<>();
queryWrapperModulex.eq(Modulex::getModuleName, moduleName);
Modulex modulex = modulexService.getOne(queryWrapperModulex);
String moduleCode = modulex.getModuleCode();
String firstChar = toFirstChar(functionType);
String str = moduleCode + firstChar;
if (!str.equals(functionCode)) {
message.put("isError", "true");
message.put("status", "第" + (i+1) + "行数据数据功能编码错误");
message.put("closeable", "true");
webSocketUtils.sendMessage(loginUser.getId(), message);
return Result.error("功能编码错误");
}
// 模块编码+功能缩写；自动填充+手动修改 // 改为自动生成
String firstChar = toFirstChar(functionName);
String functionCode = moduleCode + firstChar;
functionx.setFunctionCode(functionCode);
}
// if (StringUtils.isBlank(functionCode)) {
// message.put("isError", "true");
// message.put("status", "第" + (i+1) + "行数据数据功能编码不能为空");
// message.put("closeable", "true");
// webSocketUtils.sendMessage(loginUser.getId(), message);
// return Result.error("功能编码不能为空");
// } else {
// LambdaQueryWrapper<Modulex> queryWrapperModulex = new LambdaQueryWrapper<>();
// queryWrapperModulex.eq(Modulex::getModuleName, moduleName);
// Modulex modulex = modulexService.getOne(queryWrapperModulex);
// String moduleCode = modulex.getModuleCode();
// String firstChar = toFirstChar(functionName);
// String str = moduleCode + firstChar;
// if (!str.equals(functionCode)) {
// message.put("isError", "true");
// message.put("status", "第" + (i+1) + "行数据数据功能编码错误");
// message.put("closeable", "true");
// webSocketUtils.sendMessage(loginUser.getId(), message);
// return Result.error("功能编码错误");
// }
// functionx.setFunctionCode(functionCode);
// }
if (StringUtils.isNotBlank(pmDescribe)) { // 功能描述
functionx.setPmDescribe(pmDescribe);
@ -514,6 +530,13 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
if (StringUtils.isNotBlank(duration)) {
Double aDouble = Double.valueOf(duration);
if (aDouble <= 0){
message.put("isError", "true");
message.put("status", "第" + (i+1) + "行数据任务时长错误");
message.put("closeable", "true");
webSocketUtils.sendMessage(loginUser.getId(), message);
return Result.error("任务时长错误");
}
functionx.setDuration(aDouble);
}
@ -609,6 +632,13 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
return Result.error("版本号不能为空");
} else {
Integer integer = Integer.valueOf(verison);
if (integer<1){
message.put("isError", "true");
message.put("status", "第" + (i+1) + "行数据数据版本号不能小于1");
message.put("closeable", "true");
webSocketUtils.sendMessage(loginUser.getId(), message);
return Result.error("版本号不能小于1");
}
functionx.setStatus(integer);
}
@ -639,6 +669,18 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
return Result.OK("导入成功");
}
@Transactional
int saveTest(List<FunctionxTest> listVo) {
for (int i = 0; i < listVo.size(); i++) {
try {
this.save(listVo.get(i));
} catch (Exception e) {
return i;
}
}
return -1;
}
private boolean funCheck(List<String> list) {
for (int i=0;i<list.size();i++){
if(list.get(i)!=null && list.get(i).length()>0){

Write Preview
Loading…
Cancel
Save