检查记录表判空处理

airport-check/src/main/java/com/sundot/airport/check/service/impl/CheckRecordServiceImpl.java

@@ -8,6 +8,7 @@ import java.util.stream.Collectors;
 
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjUtil;
+import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sundot.airport.check.domain.CheckCorrection;
@@ -351,6 +352,9 @@ public class CheckRecordServiceImpl extends ServiceImpl<CheckRecordMapper, Check
     @Transactional(rollbackFor = Exception.class)
     @Override
     public int insertOrUpdateCheckRecord(CheckRecord checkRecord, boolean isLaunch) {
+        if (isLaunch) {
+            checkParam(checkRecord);
+        }
         int result;
         if (ObjUtil.isEmpty(checkRecord.getId())) {
             if (CollUtil.isNotEmpty(checkRecord.getCheckProjectItemList())) {
@@ -412,6 +416,63 @@ public class CheckRecordServiceImpl extends ServiceImpl<CheckRecordMapper, Check
     }
 
     /**
+     * 检查参数
+     *
+     * @param checkRecord 检查记录
+     */
+    private static void checkParam(CheckRecord checkRecord) {
+        if (ObjUtil.isEmpty(checkRecord.getCheckerId()) || StrUtil.isEmpty(checkRecord.getCheckerName())) {
+            throw new ServiceException("检查人不能为空");
+        }
+        if (StrUtil.isEmpty(checkRecord.getTerminlCode()) || StrUtil.isEmpty(checkRecord.getTerminlName())
+                || StrUtil.isEmpty(checkRecord.getRegionalCode()) || StrUtil.isEmpty(checkRecord.getRegionalName())
+                || StrUtil.isEmpty(checkRecord.getChannelCode()) || StrUtil.isEmpty(checkRecord.getChannelName())) {
+            throw new ServiceException("检查地点不能为空");
+        }
+        if (ObjUtil.isEmpty(checkRecord.getCheckTime())) {
+            throw new ServiceException("检查时间不能为空");
+        }
+        if (StrUtil.isEmpty(checkRecord.getCheckedLevel()) || StrUtil.isEmpty(checkRecord.getCheckedLevelDesc())) {
+            throw new ServiceException("被检查级别不能为空");
+        }
+        if (StrUtil.equals(checkRecord.getCheckedLevel(), CheckLevelEnum.PERSONNEL_LEVEL.getCode()) &&
+                (ObjUtil.isEmpty(checkRecord.getCheckedPersonnelId()) || StrUtil.isEmpty(checkRecord.getCheckedPersonnelName()))) {
+            throw new ServiceException("被检查人不能为空");
+        }
+        if (StrUtil.equals(checkRecord.getCheckedLevel(), CheckLevelEnum.TEAM_LEVEL.getCode()) &&
+                (ObjUtil.isEmpty(checkRecord.getCheckedTeamId()) || StrUtil.isEmpty(checkRecord.getCheckedTeamName()))) {
+            throw new ServiceException("被检查班组不能为空");
+        }
+        if (StrUtil.equals(checkRecord.getCheckedLevel(), CheckLevelEnum.DEPARTMENT_LEVEL.getCode()) &&
+                (ObjUtil.isEmpty(checkRecord.getCheckedDepartmentId()) || StrUtil.isEmpty(checkRecord.getCheckedDepartmentName()))) {
+            throw new ServiceException("被检查科室不能为空");
+        }
+        if (StrUtil.equals(checkRecord.getCheckedLevel(), CheckLevelEnum.BRIGADE_LEVEL.getCode()) &&
+                (ObjUtil.isEmpty(checkRecord.getCheckedBrigadeId()) || StrUtil.isEmpty(checkRecord.getCheckedBrigadeName()))) {
+            throw new ServiceException("被检查大队不能为空");
+        }
+        if (CollUtil.isNotEmpty(checkRecord.getCheckProjectItemList())) {
+            List<CheckProjectItem> unQualifiedList = checkRecord.getCheckProjectItemList().stream().filter(checkProjectItem -> StrUtil.equals(CheckScoreLevelEnum.UNQUALIFIED.getCode(), checkProjectItem.getScoreLevel())).collect(Collectors.toList());
+            if (CollUtil.isNotEmpty(unQualifiedList)) {
+                if (ObjUtil.isEmpty(checkRecord.getResponsibleUserId()) && StrUtil.isEmpty(checkRecord.getResponsibleUserName())) {
+                    throw new ServiceException("负责人不能为空");
+                }
+                if (ObjUtil.isEmpty(checkRecord.getRectificationDeadline())) {
+                    throw new ServiceException("整改期限不能为空");
+                }
+                if (StrUtil.isEmpty(checkRecord.getRectificationSuggestions())) {
+                    throw new ServiceException("整改要求不能为空");
+                }
+                unQualifiedList.forEach(checkProjectItem -> {
+                    if (CollUtil.isEmpty(checkProjectItem.getCheckUserList()) && StringUtils.isEmpty(checkProjectItem.getProblemDescription())) {
+                        throw new ServiceException("不合格人员及问题描述不能同时为空");
+                    }
+                });
+            }
+        }
+    }
+
+    /**
      * 处理被检查部门信息
      *
      * @param checkRecord 检查单