diff --git a/srs-quartz/src/main/java/com/srs/quartz/task/RegTask.java b/srs-quartz/src/main/java/com/srs/quartz/task/RegTask.java index f8ebb00..65803e3 100644 --- a/srs-quartz/src/main/java/com/srs/quartz/task/RegTask.java +++ b/srs-quartz/src/main/java/com/srs/quartz/task/RegTask.java @@ -1,5 +1,6 @@ package com.srs.quartz.task; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.srs.stureg.domain.SrsStuCheck; import com.srs.stureg.service.ISrsStuCheckDataSyncService; @@ -10,6 +11,8 @@ import org.springframework.stereotype.Component; import java.util.List; import java.util.Map; +import static com.srs.common.utils.DateUtils.getNowDate; + @Component("RegTask") public class RegTask { @@ -23,13 +26,22 @@ public class RegTask { { List list= srsStuCheckService.getSrsStucheckList(); for (SrsStuCheck m:list) { - SrsStuCheck srsStuCheck=new SrsStuCheck(); - srsStuCheck.setIsCheck(m.getIsCheck()); - srsStuCheck.setKsh(m.getKsh()); - srsStuCheck.setCheckTime(m.getCheckTime()); -// UpdateWrapper updateWrapper = new UpdateWrapper<>(); -// updateWrapper.eq("ksh",m.getKsh()); - checkService.saveOrUpdate(srsStuCheck); + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("ksh",m.getKsh()); + queryWrapper.last("limit 1"); + SrsStuCheck srsStuCheck=checkService.getOne(queryWrapper); + if(srsStuCheck!=null){ + continue; + }else{ + SrsStuCheck addSrsStuCheck=new SrsStuCheck(); + addSrsStuCheck.setIsCheck(m.getIsCheck()); + addSrsStuCheck.setKsh(m.getKsh()); + addSrsStuCheck.setCheckTime(m.getCheckTime()); + addSrsStuCheck.setCreateTime(getNowDate()); + addSrsStuCheck.setCreateBy("RegTask"); + checkService.saveOrUpdate(addSrsStuCheck); + } + } }