优化代码增加默认值

master
bynt 3 years ago
parent e637234e7f
commit 78245d16b2

@ -122,9 +122,10 @@ public interface BuildRecordRepository extends JpaRepository<BuildRecord, Intege
/** /**
* *
* @param oneMonthAhead * @param oneMonthAhead
* @param threeNumber
* @return * @return
* *
*/ */
@Query(value = "select b from BuildRecord b where b.gmtCreate < ?1 and b.isDeleted is null order by b.id ") @Query(value = "select b from BuildRecord b where b.gmtCreate < ?1 and b.level = ?2 and b.isDeleted = false order by b.id ")
List<BuildRecord> getBuildRecordByTime(DateTime oneMonthAhead); List<BuildRecord> getBuildRecordByTime(DateTime oneMonthAhead, int threeNumber);
} }

@ -129,9 +129,10 @@ public interface BuildRecordService {
/** /**
* *
* @param oneMonthAhead * @param oneMonthAhead
* @param threeNumber
* @return * @return
*/ */
List<BuildRecord> getBuildRecordByTime(DateTime oneMonthAhead); List<BuildRecord> getBuildRecordByTime(DateTime oneMonthAhead, int threeNumber);
/** /**
* *

@ -191,8 +191,8 @@ public class BuildRecordServiceImpl implements BuildRecordService {
} }
@Override @Override
public List<BuildRecord> getBuildRecordByTime(DateTime oneMonthAhead) { public List<BuildRecord> getBuildRecordByTime(DateTime oneMonthAhead, int threeNumber) {
return buildRecordRepository.getBuildRecordByTime(oneMonthAhead); return buildRecordRepository.getBuildRecordByTime(oneMonthAhead,threeNumber);
} }
@Override @Override

@ -69,6 +69,7 @@ public class ProduceBigDataTask {
private void runTask(BuildRecord task) { private void runTask(BuildRecord task) {
// 先对任务表进行记录 // 先对任务表进行记录
// fixme 尝试修复id造成的冲突问题 // fixme 尝试修复id造成的冲突问题
task.setIsDeleted(Boolean.FALSE);
BuildRecordDto buildRecordDto = buildRecordService.create(task); BuildRecordDto buildRecordDto = buildRecordService.create(task);
if (buildRecordDto == null || buildRecordDto.getId() == null || buildRecordDto.getId() <= 0) { if (buildRecordDto == null || buildRecordDto.getId() == null || buildRecordDto.getId() <= 0) {
log.error("============ [create build rec is fail, please check it.] ============"); log.error("============ [create build rec is fail, please check it.] ============");

@ -27,8 +27,6 @@ import org.springframework.util.CollectionUtils;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.sql.Timestamp; import java.sql.Timestamp;
import java.time.LocalTime; import java.time.LocalTime;
import java.util.Calendar;
import java.util.Date;
import java.util.List; import java.util.List;
/** /**
@ -182,7 +180,7 @@ public class BuildRecordScheduled {
public void deleteBuildRecordTask() { public void deleteBuildRecordTask() {
// 偏移一个月 // 偏移一个月
DateTime oneMonthAhead = DateUtil.offsetMonth(DateUtil.date(), -1); DateTime oneMonthAhead = DateUtil.offsetMonth(DateUtil.date(), -1);
List<BuildRecord> buildRecordList = buildRecordService.getBuildRecordByTime(oneMonthAhead); List<BuildRecord> buildRecordList = buildRecordService.getBuildRecordByTime(oneMonthAhead,DefaultConstant.THREE_NUMBER);
if (!CollectionUtils.isEmpty(buildRecordList)) { if (!CollectionUtils.isEmpty(buildRecordList)) {
for (BuildRecord buildRecord : buildRecordList) { for (BuildRecord buildRecord : buildRecordList) {
if (buildRecord.getId() != null) { if (buildRecord.getId() != null) {

@ -307,7 +307,7 @@ public class TagServiceImpl implements TagService {
String replaceStr = StringUtils.replace(deleteStr, " = ", " < "); String replaceStr = StringUtils.replace(deleteStr, " = ", " < ");
Query deleteTagByQuery = entityManager.createNativeQuery(replaceStr); Query deleteTagByQuery = entityManager.createNativeQuery(replaceStr);
deleteTagByQuery.setParameter("id", id); deleteTagByQuery.setParameter("id", id);
CompletableFuture.runAsync(deleteTagByQuery::executeUpdate); deleteTagByQuery.executeUpdate();
} }
return result; return result;
} }

Loading…
Cancel
Save