From 679dc7dd1552f0c0679321418abb4e986df2584f Mon Sep 17 00:00:00 2001
From: guilongma <3307671311@qq.com>
Date: Fri, 28 Jul 2023 17:02:26 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=85=A5=E5=AF=BC=E5=85=A5=E5=89=8D?=
 =?UTF-8?q?=E6=A0=A1=E9=AA=8C=E4=B8=AD=E6=96=87=E5=90=8D=E7=A7=B0=E8=8B=B1?=
 =?UTF-8?q?=E6=96=87=E5=90=8D=E9=87=8D=E5=A4=8D=EF=BC=8C=E5=B0=86=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD=E7=BC=96=E7=A0=81=E6=94=B9=E4=B8=BA=E8=87=AA=E5=8A=A8?=
 =?UTF-8?q?=E6=B7=BB=E5=8A=A0=EF=BC=8C=E8=A7=A3=E5=86=B3=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E6=97=B6=E9=95=BF=E3=80=81=E5=AE=9E=E9=99=85=E6=97=B6=E9=95=BF?=
 =?UTF-8?q?=E4=B8=BA=E8=B4=9F=E6=95=B0=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../demo/functionx/entity/FunctionxTest.java  |   5 +-
 .../impl/FunctionXTestServiceImpl.java        | 192 +++++++++++-------
 2 files changed, 119 insertions(+), 78 deletions(-)

diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/entity/FunctionxTest.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/entity/FunctionxTest.java
index 54ecb0e..2cfb58a 100644
--- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/entity/FunctionxTest.java
+++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/entity/FunctionxTest.java
@@ -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;
 
     /**
      * 功能类型
diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/service/impl/FunctionXTestServiceImpl.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/service/impl/FunctionXTestServiceImpl.java
index 1ea2434..6c0f80f 100644
--- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/service/impl/FunctionXTestServiceImpl.java
+++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/demo/functionx/service/impl/FunctionXTestServiceImpl.java
@@ -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,8 +223,30 @@ 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(project)) {
+                    message.put("isError", "true");
+                    message.put("status", "第" + (i+1) + "行数据项目名称不能为空");
+                    message.put("closeable", "true");
+                    webSocketUtils.sendMessage(loginUser.getId(), message);
+                    return Result.error("项目名称不能为空");
+                } else {
+                    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 + "行数据对应模块不能为空");
@@ -223,30 +254,13 @@ public class FunctionXTestServiceImpl extends ServiceImpl<FunctionxTestMapper, F
                     webSocketUtils.sendMessage(loginUser.getId(), message);
                     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;
-                            }
-                        }
-                    } else {
-                        for (Modulex modulex : modulexList) {
-                            if (modulex.getModuleName().equals(moduleId) && modulex.getPid() == null) {
-                                functionx.setModuleId(modulex.getId());
-                                moduleId = modulex.getId();
-                                moduleName = modulex.getModuleName();
-                                break;
-                            }
+                    for (Modulex modulex : modulexList) {
+                        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) {
@@ -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("功能编码错误");
-                    }
-
-                    functionx.setFunctionCode(functionCode);
-                }
+                // 模块编码+功能缩写；自动填充+手动修改  // 改为自动生成
+                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){