push

src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java

@@ -135,6 +135,7 @@ public class AfCollectTaskServiceImpl extends ServiceImpl<AfCollectTaskMapper, A
     @Transactional
     @Override
     public void insert(ReportDownDto reportDownDto) {
+
             if (reportDownDto.getScanfiles().get(0).getFiletype() == 1) {
                 log.info("新增任务表初始数据：" + reportDownDto);
             }
@@ -150,6 +151,7 @@ public class AfCollectTaskServiceImpl extends ServiceImpl<AfCollectTaskMapper, A
                 long l = System.currentTimeMillis();
 
                 // 判断任务是否已存在
+                synchronized (this) {
                     afCollectTask = afCollectTaskMapper.selectOne(new QueryWrapper<AfCollectTask>().eq("C1", scanfile.getSerialnum()).eq("sysflag", reportDownDto.getCollectorid()));
                     if (afCollectTask == null || afCollectTask.getId() == null) {
                         //不存在 新增
@@ -176,6 +178,7 @@ public class AfCollectTaskServiceImpl extends ServiceImpl<AfCollectTaskMapper, A
                         save = afCollectTaskMapper.updateById(afCollectTask);
 
                     }
+                }
 
                 if (save <= 0) {
                     log.info("任务表操作出错");
@@ -189,6 +192,7 @@ public class AfCollectTaskServiceImpl extends ServiceImpl<AfCollectTaskMapper, A
                 }
             }
             reportDownDto.setScanfiles(scanfiles);
+
     }
 
     @Override