1.修改月度拉取

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

@@ -5,6 +5,7 @@ import cn.afterturn.easypoi.excel.entity.ExportParams;
 import cn.afterturn.easypoi.excel.entity.enmus.ExcelType;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollectionUtil;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -221,11 +222,9 @@ public class Jnsp7xtmDqsjServiceImpl extends ServiceImpl<Jnsp7xtmDqsjRepository,
                         Jnsp7xtmDqsjPageHandleDto jnsp7xtmDqsjPageHandleDto = Jnsp7xtmDqsjPageHandleDto.builder().page(i).rows(pageQuerySize).build();
                         addJnsp7xtmDqsjByPage(jnsp7xtmDqsjPageHandleDto);
                     }
-                    QueryWrapper<TaskInfo> queryWrapper = new QueryWrapper<>();
-                    queryWrapper.eq("tack_id",taskId);
-                    TaskInfo taskInfo = taskInfoRepository.selectOne(queryWrapper);
-                    taskInfo.setStatus("1");
-                    taskInfoRepository.updateById(taskInfo);
+                    LambdaUpdateWrapper<TaskInfo> updateWrapper = new LambdaUpdateWrapper<>();
+                    updateWrapper.eq(TaskInfo::getTackId,taskId).set(TaskInfo::getStatus,"1");
+                    taskInfoRepository.update(null,updateWrapper);
                     log.info("数据同步需要多少秒" + stopwatch.elapsed().getSeconds());
                 } catch (Exception e) {
                     e.printStackTrace();