fixed 侵权协同办公

src/main/java/cn/cslg/pas/controller/TortController.java

@@ -87,7 +87,7 @@ public class TortController {
 
     @Operation(summary = "添加侵权分析协同任务")
     @PostMapping("/addTortTask")
-    public Response addTortTask(@RequestBody TortTaskDTO tortTaskDTO){
+    public Response addTortTask(@RequestBody TortTaskDTO tortTaskDTO) throws Exception {
         Integer id = projectTaskService.addTortTask(tortTaskDTO);
         Records records = new Records();
         records.setData(id);

src/main/java/cn/cslg/pas/service/business/ProjectTaskService.java

@@ -34,6 +34,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.multipart.MultipartFile;
@@ -807,7 +808,10 @@ public class ProjectTaskService extends ServiceImpl<ProjectTaskMapper, ProjectTa
     /**
      * 添加侵权分析协同任务
      */
-    public Integer addTortTask(TortTaskDTO tortTaskDTO) {
+    @Transactional(propagation = Propagation.REQUIRED,rollbackFor = Throwable.class)
+    public Integer addTortTask(TortTaskDTO tortTaskDTO) throws Exception {
+        Integer projectId = tortTaskDTO.getProjectId();
+        List<String> patentNos = tortTaskDTO.getPatentNos();
         //1.保存任务信息 project_task表
         if (tortTaskDTO == null) {
             throw new XiaoShiException("入参不能为空！");
@@ -850,7 +854,8 @@ public class ProjectTaskService extends ServiceImpl<ProjectTaskMapper, ProjectTa
         //3.从侵权分析中获得对比结果，并复制保存
         tortCompareRecordService.copyTortCompareRecords(tortTaskDTO.getProjectId(), taskId, personnelVO.getId());
         //4.发送邮件通知协同人和抄送人
-        //TODO
+        //保存es
+        this.addCompareLiteratureByNosToEs(patentNos, taskId, projectId);
         return projectTask.getId();
     }