1.修改月度拉取

src/main/java/org/rcisoft/bus/jnsp7xtmdqsj/service/impl/Jnsp7xtmDqsjServiceImpl.java

@@ -221,9 +221,12 @@ public class Jnsp7xtmDqsjServiceImpl extends ServiceImpl<Jnsp7xtmDqsjRepository,
                         Jnsp7xtmDqsjPageHandleDto jnsp7xtmDqsjPageHandleDto = Jnsp7xtmDqsjPageHandleDto.builder().page(i).rows(pageQuerySize).build();
                         addJnsp7xtmDqsjByPage(jnsp7xtmDqsjPageHandleDto);
                     }
-                    Thread.sleep(5000);
-                    log.info("查询耗时秒" + stopwatch.elapsed().getSeconds());
-                    log.info("查询耗时毫秒" + stopwatch.elapsed(TimeUnit.MILLISECONDS));
+                    QueryWrapper<TaskInfo> queryWrapper = new QueryWrapper<>();
+                    queryWrapper.eq("tack_id",taskId);
+                    TaskInfo taskInfo = taskInfoRepository.selectOne(queryWrapper);
+                    taskInfo.setStatus("1");
+                    taskInfoRepository.updateById(taskInfo);
+                    log.info("数据同步需要多少秒" + stopwatch.elapsed().getSeconds());
                 } catch (Exception e) {
                     e.printStackTrace();
                     throw new CyServiceException(501,"数据同步异常");
@@ -266,6 +269,7 @@ public class Jnsp7xtmDqsjServiceImpl extends ServiceImpl<Jnsp7xtmDqsjRepository,
                 try {
                     taskInfo.setStatus("0");
                     taskInfo.setTackId(CyIdGenUtil.uuid());
+                    taskInfo.setFlag("1");
                     taskInfoRepository.insert(taskInfo);
                     return taskInfo;
                 } catch (Exception e) {