|
@@ -16,6 +16,7 @@ import org.springframework.scheduling.annotation.Scheduled;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.util.StringUtils;
|
|
|
|
|
|
+import java.time.Instant;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
|
|
@@ -59,7 +60,8 @@ public class ChuanyunHumanResourceScheduledTask {
|
|
|
/**
|
|
|
* 每天3点更新日志记录
|
|
|
*/
|
|
|
- @Scheduled(cron = "0 0 3 * * *")
|
|
|
+// @Scheduled(cron = "0 0 3 * * *")
|
|
|
+ @Scheduled(fixedDelay = 3600000L)
|
|
|
private void updateLog() {
|
|
|
var objectMapper = new ObjectMapper();
|
|
|
var start = 0;
|
|
@@ -70,6 +72,7 @@ public class ChuanyunHumanResourceScheduledTask {
|
|
|
// matchersString.add("Status_2,1");
|
|
|
matchersString.add("Status_6,[1;2]");
|
|
|
while (flag) {
|
|
|
+ Long startTime= Instant.now().getEpochSecond();
|
|
|
try {
|
|
|
//从氚云查询数据
|
|
|
var filter= Filter.instance(start,start+pageSize,true,Filter.AND,matchersString);
|
|
@@ -129,6 +132,7 @@ public class ChuanyunHumanResourceScheduledTask {
|
|
|
log.error(e.getMessage());
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
+ log.info(Instant.now().getEpochSecond()-startTime+"日志100条保存时间");
|
|
|
}
|
|
|
log.info("日志信息保存" + totalCount);
|
|
|
}
|