通过E呼即办数据统计

linwe

2024-05-29 c10d6358b9f014375a13821465bc978d0c0da22e

 src/main/java/org/springblade/modules/task/service/impl/TaskPlaceSelfCheckServiceImpl.java

@@ -48,6 +48,7 @@

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.stream.Collectors;

/**
@@ -142,9 +143,28 @@
      // 1.保存任务表
      ITaskService iTaskService = SpringUtils.getBean(ITaskService.class);
      Long restults;
      if (taskPlaceSelfCheck.getType().equals("2")) {
      AtomicBoolean isState = new AtomicBoolean(false);
      List<TaskPlaceRecordVO> taskPlaceRecordList = taskPlaceSelfCheck.getTaskPlaceRecordVOList();
      for (TaskPlaceRecordVO taskPlaceRecordVO : taskPlaceRecordList) {
         // 判断类型
         if (StringUtils.isNotBlank(taskPlaceSelfCheck.getType()) && taskPlaceSelfCheck.getType().equals("2")) {
            taskPlaceRecordVO.setType("3");
         } else {
            taskPlaceRecordVO.setType("1");
         }
         // 判断是否有隐患
         if (taskPlaceRecordVO.getState().equals(0)) {
            isState.set(true);
         }
      }
      if (StringUtils.isNotBlank(taskPlaceSelfCheck.getType()) && taskPlaceSelfCheck.getType().equals("2")) {
         // 不存在隐患。状态直接为已审核
         if (!isState.get()) {
            taskPlaceSelfCheck.setStatus(2);
            taskPlaceSelfCheck.setRectificationFlag(3);
         }
         restults = iTaskService.saveTask(CommonConstant.NUMBER_ONE, DictConstant.FIRE_SCHOOL_CHECK_NOTICE, 1,
            "", AuthUtil.getUserId(), taskPlaceSelfCheck.getHouseCode(), CommonConstant.NUMBER_FOUR, 1);
            "", AuthUtil.getUserId(), taskPlaceSelfCheck.getHouseCode(), CommonConstant.NUMBER_FOUR, taskPlaceSelfCheck.getStatus());
      } else {
         restults = iTaskService.saveTask(CommonConstant.NUMBER_ONE, DictConstant.FIRE_SELF_CHECK_NOTICE, 1,
            "", AuthUtil.getUserId(), taskPlaceSelfCheck.getHouseCode(), CommonConstant.NUMBER_SEVEN, 1);
@@ -157,16 +177,14 @@
      boolean save = save(taskPlaceSelfCheck);
      if (save) {
         // 3.保存题目记录
         List<TaskPlaceRecordVO> taskPlaceRecordList = taskPlaceSelfCheck.getTaskPlaceRecordVOList();
         ITaskPlaceRecordService bean = SpringUtil.getBean(ITaskPlaceRecordService.class);
         taskPlaceRecordList.stream().forEach(item -> {
            item.setTaskPlaceSelfCheckId(taskPlaceSelfCheck.getId());
            item.setCreateUser(AuthUtil.getUserId());
            item.setType("1");
         });
         List<TaskPlaceRecordEntity> collect = taskPlaceRecordList.stream().filter(item -> item.getState().equals(0)).collect(Collectors.toList());
         ITaskPlaceRecordService taskPlaceRecordService = SpringUtil.getBean(ITaskPlaceRecordService.class);
         List<TaskPlaceRecordEntity> collect = taskPlaceRecordList.stream().collect(Collectors.toList());
         if (collect.size() > 0) {
            bean.saveBatch(collect);
            taskPlaceRecordService.saveBatch(collect);
         }
         updateById(taskPlaceSelfCheck);
         return save;
@@ -190,10 +208,10 @@
         List<TaskPlaceRecordVO> taskPlaceRecordList = taskPlaceSelfCheck.getTaskPlaceRecordVOList();
         if (taskPlaceRecordList != null && taskPlaceRecordList.size() > 0) {
            ITaskPlaceRecordService bean = SpringUtil.getBean(ITaskPlaceRecordService.class);
            List<TaskPlaceRecordEntity> copy = BeanUtil.copy(taskPlaceRecordList, TaskPlaceRecordEntity.class);
            boolean b = bean.saveOrUpdateBatch(copy);
            if (b) {
               return b;
            List<TaskPlaceRecordEntity> placeRecordEntityList = BeanUtil.copy(taskPlaceRecordList, TaskPlaceRecordEntity.class);
            boolean updateBatch = bean.saveOrUpdateBatch(placeRecordEntityList);
            if (updateBatch) {
               return updateBatch;
            }
            throw new CustomException("保存失败！");
         }