|
|
|
@ -54,13 +54,13 @@ public class GenderConversionTask {
|
|
|
|
|
private final GenderRecordService genderRecordService;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Scheduled(cron = "0 0/30 * * * ? ")
|
|
|
|
|
@Scheduled(cron = "0 0/30 0-6 * * ? ")
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
|
|
public void exchangeResource() {
|
|
|
|
|
String fileUrl = deliveryProperties.getFileUrl();
|
|
|
|
|
// 单次查询10000
|
|
|
|
|
List<Map<Long, String>> resourceList = clueService.queryUnconvertedResource
|
|
|
|
|
(DefaultNumberConstants.ZERO_NUMBER, DefaultNumberConstants.TEN_THOUSAND);
|
|
|
|
|
(DefaultNumberConstants.ZERO_NUMBER, DefaultNumberConstants.FIVE_THOUSAND);
|
|
|
|
|
if (CollUtil.isNotEmpty(resourceList)) {
|
|
|
|
|
// 对应转换
|
|
|
|
|
List<QueryClueDTO> list = Convert.toList(QueryClueDTO.class, resourceList);
|
|
|
|
@ -85,7 +85,7 @@ public class GenderConversionTask {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@SneakyThrows
|
|
|
|
|
@Scheduled(cron = "0 0/10 * * * ? ")
|
|
|
|
|
@Scheduled(cron = "0 0/10 0-6 * * ? ")
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
|
|
public void receiveMail() {
|
|
|
|
|
// 获取邮件内容
|
|
|
|
@ -120,7 +120,6 @@ public class GenderConversionTask {
|
|
|
|
|
String unzipPath =
|
|
|
|
|
CompressUtil.unzipFiles(deliveryProperties.getFileUrl(),
|
|
|
|
|
path, deliveryProperties.getZipPassword());
|
|
|
|
|
|
|
|
|
|
File file = new File(unzipPath);
|
|
|
|
|
File parseFile = Objects.requireNonNull
|
|
|
|
|
(file.listFiles())[DefaultNumberConstants.ZERO_NUMBER];
|
|
|
|
|