增加事务

xieb

2024-01-08 df69fd116c170c0e91da5b985a030cb824259c41

 src/main/java/org/springblade/modules/assessment/service/impl/AssessmentTaskServiceImpl.java

@@ -16,7 +16,13 @@
 */
package org.springblade.modules.assessment.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.AllArgsConstructor;
import org.springblade.modules.assessment.entity.AssessmentSetEntity;
import org.springblade.modules.assessment.entity.AssessmentTaskEntity;
import org.springblade.modules.assessment.service.IAssessmentScoreService;
import org.springblade.modules.assessment.service.IAssessmentSetAssessorService;
import org.springblade.modules.assessment.service.IAssessmentSetService;
import org.springblade.modules.assessment.vo.AssessmentTaskVO;
import org.springblade.modules.assessment.excel.AssessmentTaskExcel;
import org.springblade.modules.assessment.mapper.AssessmentTaskMapper;
@@ -25,6 +31,9 @@
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springframework.transaction.annotation.Transactional;

import javax.validation.constraints.NotEmpty;
import java.util.List;

/**
@@ -34,7 +43,12 @@
 * @since 2023-12-07
 */
@Service
@AllArgsConstructor
public class AssessmentTaskServiceImpl extends BaseServiceImpl<AssessmentTaskMapper, AssessmentTaskEntity> implements IAssessmentTaskService {

   private final IAssessmentSetService assessmentSetService;
   private final IAssessmentSetAssessorService assessmentSetAssessorService;
   private final IAssessmentScoreService assessmentScoreService;

   @Override
   public IPage<AssessmentTaskVO> selectAssessmentTaskPage(IPage<AssessmentTaskVO> page, AssessmentTaskVO assessmentTask) {
@@ -51,4 +65,27 @@
      return assessmentTaskList;
   }

   @Override
   @Transactional
   public boolean deleteLogic(@NotEmpty List<Long> ids) {
      boolean ret = super.deleteLogic(ids);
      if (ret) {
         for (Long id: ids) {
            QueryWrapper queryWrapper = new QueryWrapper();
            queryWrapper.eq("assessment_task_id", id);
            List<AssessmentSetEntity> list = assessmentSetService.list(queryWrapper);
            assessmentSetService.remove(queryWrapper);
            assessmentScoreService.remove(queryWrapper);
            for (AssessmentSetEntity po: list
                ) {
               QueryWrapper qw = new QueryWrapper();
               qw.eq("assessment_set_id", po.getId());
               assessmentSetAssessorService.remove(qw);
            }
         }

      }
      return ret;
   }

}