|
|
|
@ -1,5 +1,6 @@
|
|
|
|
|
package com.glxp.api.task;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
|
import cn.hutool.core.thread.ThreadUtil;
|
|
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
@ -11,6 +12,7 @@ import com.glxp.api.entity.system.SystemParamConfigEntity;
|
|
|
|
|
import com.glxp.api.req.basic.WorkBindBusTypeRequest;
|
|
|
|
|
import com.glxp.api.req.collect.CollectOrderRequest;
|
|
|
|
|
import com.glxp.api.req.system.ScheduledRequest;
|
|
|
|
|
import com.glxp.api.req.system.SysParamConfigSaveRequest;
|
|
|
|
|
import com.glxp.api.res.basic.SysWorkplaceDocumentResponse;
|
|
|
|
|
import com.glxp.api.service.collect.IoCollectOriginService;
|
|
|
|
|
import com.glxp.api.service.inv.InvProductRationService;
|
|
|
|
@ -53,7 +55,7 @@ public class AsyncIoCollectOrderDownloadTask implements SchedulingConfigurer {
|
|
|
|
|
ScheduledRequest scheduledRequest = new ScheduledRequest();
|
|
|
|
|
scheduledRequest.setCronName("ioCollectOrderDownloadTask");
|
|
|
|
|
ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
|
|
|
|
|
String cron = scheduledEntity != null ? scheduledEntity.getCron() : "0 */30 * * * ?";
|
|
|
|
|
String cron = scheduledEntity != null ? scheduledEntity.getCron() : "0 */10 * * * ?";
|
|
|
|
|
if (cron.isEmpty()) {
|
|
|
|
|
logger.error("cron is null");
|
|
|
|
|
}
|
|
|
|
@ -77,8 +79,6 @@ public class AsyncIoCollectOrderDownloadTask implements SchedulingConfigurer {
|
|
|
|
|
WorkBindBusTypeRequest workBindBusTypeRequest = new WorkBindBusTypeRequest();
|
|
|
|
|
List<SysWorkplaceDocumentResponse> sysWorkplaceDocumentResponses = sysWorkplaceDocumentDao.filterList(workBindBusTypeRequest);
|
|
|
|
|
if (CollUtil.isNotEmpty(sysWorkplaceDocumentResponses)) {
|
|
|
|
|
//包装开始和结束的日期
|
|
|
|
|
|
|
|
|
|
for (SysWorkplaceDocumentResponse sysWorkplaceDocumentResponse : sysWorkplaceDocumentResponses) {
|
|
|
|
|
String documentTypeCode = sysWorkplaceDocumentResponse.getDocumentTypeCode();
|
|
|
|
|
collectOrderRequest.setBusType(documentTypeCode);
|
|
|
|
@ -86,7 +86,9 @@ public class AsyncIoCollectOrderDownloadTask implements SchedulingConfigurer {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
startDownloadTime.setParamValue(nowTime);
|
|
|
|
|
systemParamConfigService.updateById(startDownloadTime);
|
|
|
|
|
SysParamConfigSaveRequest sysParamConfigSaveRequest = new SysParamConfigSaveRequest();
|
|
|
|
|
BeanUtil.copyProperties(startDownloadTime,sysParamConfigSaveRequest);
|
|
|
|
|
systemParamConfigService.updateById(sysParamConfigSaveRequest);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|