test-version22
/
MeterSphere
mirror of https://gitee.com/fit2cloud-feizhiyun/MeterSphere.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix:定时插入缺陷修改

This commit is contained in:
wenyann 2021-06-25 18:40:57 +08:00 committed by 刘瑞斌
parent 8c7ffb7db1
commit a349e3f52a
1 changed files with 22 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
backend/src/main/java/io/metersphere/job/sechedule/IssuesJob.java
View File

@ -1,11 +1,16 @@
package io.metersphere.job.sechedule;
import com.fit2cloud.quartz.anno.QuartzScheduled;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import io.metersphere.base.domain.IssuesDao;
import io.metersphere.base.domain.TestPlanTestCase;
import io.metersphere.base.domain.TestPlanTestCaseWithBLOBs;
import io.metersphere.commons.utils.LogUtil;
import io.metersphere.track.service.IssuesService;
import io.metersphere.track.service.TestPlanTestCaseService;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.List;
@ -19,17 +24,22 @@ public class IssuesJob {
@QuartzScheduled(fixedDelay = 3600 * 1000)
//@Scheduled(fixedDelay = 120 * 1000)
public void IssuesCount() {
/*int pageSize = 100;
int pages = 0;
Page<List<TestPlanTestCase>> page = PageHelper.startPage(pages, pageSize, true);
pages = page.getPages();
for (int i = 0; i < pages; i++) {*/
List<TestPlanTestCaseWithBLOBs> list = testPlanTestCaseService.listAll();
list.forEach(l -> {
List<IssuesDao> issues = issuesService.getIssues(l.getCaseId());
int issuesCount = issues.size();
testPlanTestCaseService.updateIssues(issuesCount, l.getPlanId(), l.getCaseId(), issues.toString());
});
}
int pageSize = 100;
int pages = 1;
for (int i = 0; i < pages; i++) {
Page<List<TestPlanTestCase>> page = PageHelper.startPage(i, pageSize, true);
List<TestPlanTestCaseWithBLOBs> list = testPlanTestCaseService.listAll();
pages = page.getPages();// 替换成真实的值
list.forEach(l -> {
try {
List<IssuesDao> issues = issuesService.getIssues(l.getCaseId());
int issuesCount = issues.size();
testPlanTestCaseService.updateIssues(issuesCount, l.getPlanId(), l.getCaseId(), issues.toString());
} catch (Exception e) {
LogUtil.error("定时任务处理bug数量报错planId: " + l.getPlanId(), e);
}
});
}
}
}