清除审核状态不正确的加分记录

srs-admin/src/main/java/com/srs/web/controller/comprehensive/CphAuditDetailsController.java

@@ -52,6 +52,13 @@ public class CphAuditDetailsController extends BaseController {
     @Autowired
     private ISrsStudentService _student;
 
+    //清除审核状态不正确的加分记录
+    @PostMapping("/cleanCancelRecord")
+    public AjaxResult cleanCancelRecord(){
+        return cphAuditDetailsService.cleanCancelRecord();
+    }
+
+
     /***
      * 重新提交 （学生）
      * @author zhy

srs-comprehensive/src/main/java/com/srs/comprehensive/mapper/CphAuditDetailsMapper.java

@@ -2,6 +2,7 @@ package com.srs.comprehensive.mapper;
 
 import java.util.List;
 import com.srs.comprehensive.domain.CphAuditDetails;
+import com.srs.comprehensive.domain.SrsAddRecord;
 import org.apache.ibatis.annotations.Mapper;
 
 /**
@@ -81,4 +82,7 @@ public interface CphAuditDetailsMapper
     public int deleteCphAuditDetailsByIds(Long[] ids);
     public int cancelAuditById(Long id);
     public int cancelCphAudiDetailsById(Long id);
+
+    //查询审核状态不对的加分记录
+    public List<SrsAddRecord> listCancelRecord();
 }

srs-comprehensive/src/main/java/com/srs/comprehensive/service/ICphAuditDetailsService.java

@@ -18,6 +18,8 @@ import com.srs.comprehensive.domain.Vo.CphSearch;
 public interface ICphAuditDetailsService
 {
 
+    public AjaxResult cleanCancelRecord();
+
     public int reSub(CphResub param);
     public AjaxResult cancelProcess(CphCancel param);
     public List<CphApply> listOwnProcessed(CphSearch param);

srs-comprehensive/src/main/java/com/srs/comprehensive/service/impl/CphAuditDetailsServiceImpl.java

@@ -4,6 +4,8 @@ import java.math.BigDecimal;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.srs.common.core.domain.AjaxResult;
@@ -519,13 +521,40 @@ public class CphAuditDetailsServiceImpl implements ICphAuditDetailsService {
     public int deleteCphAuditDetailsByIds(Long[] ids) {
         return cphAuditDetailsMapper.deleteCphAuditDetailsByIds(ids);
     }
+
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public int cancelAuditById(Long id) {
         int result=0;
         result=cphAuditDetailsMapper.cancelAuditById(id);
         result+= cphAuditDetailsMapper.cancelCphAudiDetailsById(id);
+        List<SrsAddRecord> cancelList = cphAuditDetailsMapper.listCancelRecord();
+        Set<Long> recordIds = cancelList.stream().map(SrsAddRecord::getId).collect(Collectors.toSet());
+
+        QueryWrapper<SrsAddRecord> queryWrapper = new QueryWrapper<>();
+        queryWrapper.in("id", recordIds);
+        _addRecordMapper.delete(queryWrapper);
+
         return  result;
     }
+
+
+    @Override
+    public AjaxResult cleanCancelRecord(){
+        try{
+            List<SrsAddRecord> cancelList = cphAuditDetailsMapper.listCancelRecord();
+            if(!cancelList.isEmpty()){
+                Set<Long> recordIds = cancelList.stream().map(SrsAddRecord::getId).collect(Collectors.toSet());
+                QueryWrapper<SrsAddRecord> queryWrapper = new QueryWrapper<>();
+                queryWrapper.in("id", recordIds);
+                _addRecordMapper.delete(queryWrapper);
+            }
+            return AjaxResult.success();
+        }catch(Exception ex){
+            return AjaxResult.error(ex.getMessage());
+        }
+    }
+
     /**
      * 删除审核明细信息
      *

srs-comprehensive/src/main/resources/mapper/comprehensive/CphAuditDetailsMapper.xml

@@ -170,4 +170,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <update id="cancelCphAudiDetailsById" parameterType="Long">
         update   cph_audit_details set status_code=1 where project_id=#{id}
     </update>
+
+    <select id="listCancelRecord" resultType="SrsAddRecord">
+        select a.*
+        from srs_add_record as a
+        left join cph_iam as b on a.iam_id = b.id
+        where b.audit_status not in (6,12)
+    </select>
 </mapper>