xservice/xservice-script
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf:节假日校验

Browse Source
This commit is contained in:
Zhujx
2025-10-04 13:09:41 +08:00
parent 357f1e3a44
commit f4d3b93717
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
script/src/main/java/com/xiang/xservice/fwd/schedule/PullDataFromFWDJob.java
View File

@@ -66,15 +66,15 @@ public class PullDataFromFWDJob {
private final ExecutorService es = private final ExecutorService es =
new ThreadPoolExecutor( new ThreadPoolExecutor(
5, 1,
10, 1,
1000, 1000,
TimeUnit.MILLISECONDS, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<>(), new LinkedBlockingQueue<>(),
new MyThreadFactory("fwd-pull-data-http", Boolean.TRUE), new MyThreadFactory("fwd-pull-data-http", Boolean.TRUE),
new ThreadPoolExecutor.AbortPolicy()); new ThreadPoolExecutor.AbortPolicy());
private void saveProjectInfo(ProjectList project, ProjectInfoResp projectInfoFromHttp) { private FPerformProjectInfo saveProjectInfo(ProjectList project, ProjectInfoResp projectInfoFromHttp) {
FPerformProjectInfo fPerformProjectInfo = new FPerformProjectInfo(); FPerformProjectInfo fPerformProjectInfo = new FPerformProjectInfo();
fPerformProjectInfo.setNameDisplay(projectInfoFromHttp.getNameDisplay()); fPerformProjectInfo.setNameDisplay(projectInfoFromHttp.getNameDisplay());
fPerformProjectInfo.setStatus(projectInfoFromHttp.getStatus()); fPerformProjectInfo.setStatus(projectInfoFromHttp.getStatus());
@@ -103,6 +103,7 @@ public class PullDataFromFWDJob {
fPerformProjectInfo.setPreSaleTime(DateUtils.getDateTimeFromStr(projectInfoFromHttp.getPreSaleTime(), "yyyy/MM/dd HH:mm:ss")); fPerformProjectInfo.setPreSaleTime(DateUtils.getDateTimeFromStr(projectInfoFromHttp.getPreSaleTime(), "yyyy/MM/dd HH:mm:ss"));
} }
performProjectInfoMapper.insert(fPerformProjectInfo); performProjectInfoMapper.insert(fPerformProjectInfo);
return fPerformProjectInfo;
} }
/** /**
@@ -212,7 +213,7 @@ public class PullDataFromFWDJob {
FPerformProjectInfo projectInfo = performProjectInfoMapper.getProjectByProjectId(performsByProjectIdFromHttp.getProjectId()); FPerformProjectInfo projectInfo = performProjectInfoMapper.getProjectByProjectId(performsByProjectIdFromHttp.getProjectId());
if (Objects.isNull(projectInfo)) { if (Objects.isNull(projectInfo)) {
// 不存在则新增 // 不存在则新增
saveProjectInfo(project, projectInfoFromHttp); projectInfo = saveProjectInfo(project, projectInfoFromHttp);
} else { } else {
// 存在则更新 // 存在则更新
buildUpdateProjectInfo(project, projectInfo, projectInfoFromHttp); buildUpdateProjectInfo(project, projectInfo, projectInfoFromHttp);