1 năm trước cách đây
mục cha
commit
8d11bea117

+ 2 - 0
platform-rest/src/main/java/com/platform/rest/task/CheckJobTask.java

@@ -54,5 +54,7 @@ public class CheckJobTask {
         checkJobService.checkJobStatus();
     }
 
+    public void deleteScrapSbCheckJobs(){checkJobService.deleteScrapSbCheckJobs();}
+
 
 }

+ 1 - 0
platform-service/src/main/java/com/platform/service/check/CheckJobService.java

@@ -27,6 +27,7 @@ import java.util.List;
  * @Version Copyright (c) 2020,北京乾元坤和科技有限公司 All rights reserved.
  */
 public interface CheckJobService extends IBaseService<CheckJob, CheckJobDTO> {
+    void deleteScrapSbCheckJobs();
 
     CheckJobVO getCheckJobVODetail(CheckJobDTO checkJobDTO);
 

+ 14 - 0
platform-service/src/main/java/com/platform/service/check/impl/CheckJobServiceImpl.java

@@ -91,6 +91,20 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
     private SbInfoMapper sbInfoMapper;
     private SbPositionMapper sbPositionMapper;
 
+    @Override
+    public void deleteScrapSbCheckJobs() {
+        CheckJobDTO dto = new CheckJobDTO();
+        dto.setSbStatus(SbInfoStatusEnum.SCRAPED.getValue());
+        List<CheckJobVO> list = mapper.selectList(dto);
+        if (list.size()>0){
+            List<String> ids = list.stream().map(CheckJobVO::getId).collect(Collectors.toList());
+            Weekend<CheckJob> weekend = new Weekend<>(CheckJob.class);
+            WeekendCriteria<CheckJob,Object> weekendCriteria = weekend.weekendCriteria();
+            weekendCriteria.andIn(CheckJob::getId,ids);
+            mapper.deleteByExample(weekend);
+        }
+    }
+
     @Override
     public CheckJobVO getCheckJobVODetail(CheckJobDTO checkJobDTO) {
         CheckJobVO checkJobVO = new CheckJobVO();