You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
80 lines
3.5 KiB
Java
80 lines
3.5 KiB
Java
10 months ago
|
package com.glxp.api.task;
|
||
|
|
|
||
|
|
import cn.hutool.core.collection.CollUtil;
|
||
|
|
import cn.hutool.core.thread.ThreadUtil;
|
||
|
|
import com.glxp.api.dao.basic.SysWorkplaceDocumentDao;
|
||
|
|
import com.glxp.api.dao.schedule.ScheduledDao;
|
||
|
|
import com.glxp.api.entity.inv.InvProductRationEntity;
|
||
|
|
import com.glxp.api.entity.system.ScheduledEntity;
|
||
|
|
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.res.basic.SysWorkplaceDocumentResponse;
|
||
|
|
import com.glxp.api.service.collect.IoCollectOriginService;
|
||
|
|
import com.glxp.api.service.inv.InvProductRationService;
|
||
|
|
import com.glxp.api.util.MsDateUtil;
|
||
|
|
import org.slf4j.Logger;
|
||
|
|
import org.slf4j.LoggerFactory;
|
||
|
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
||
|
|
import org.springframework.scheduling.annotation.SchedulingConfigurer;
|
||
|
|
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
|
||
|
|
import org.springframework.scheduling.support.CronTrigger;
|
||
|
|
import org.springframework.stereotype.Component;
|
||
|
|
|
||
|
|
import javax.annotation.Resource;
|
||
|
|
import java.util.List;
|
||
|
|
import java.util.Map;
|
||
|
|
import java.util.stream.Collectors;
|
||
|
|
|
||
|
|
|
||
|
|
@Component
|
||
|
|
@EnableScheduling
|
||
|
|
public class AsyncIoCollectOrderDownloadTask implements SchedulingConfigurer {
|
||
|
|
|
||
|
|
final Logger logger = LoggerFactory.getLogger(AsyncIoCollectOrderDownloadTask.class);
|
||
|
|
|
||
|
|
@Resource
|
||
|
|
private ScheduledDao scheduledDao;
|
||
|
|
@Resource
|
||
|
|
SysWorkplaceDocumentDao sysWorkplaceDocumentDao;
|
||
|
|
@Resource
|
||
|
|
IoCollectOriginService collectOriginService;
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
|
||
|
|
scheduledTaskRegistrar.addTriggerTask(() -> process(),
|
||
|
|
triggerContext -> {
|
||
|
|
ScheduledRequest scheduledRequest = new ScheduledRequest();
|
||
|
|
scheduledRequest.setCronName("ioCollectOrderDownloadTask");
|
||
|
|
ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
|
||
|
|
String cron = scheduledEntity != null ? scheduledEntity.getCron() : "0 */10 * * * ?";
|
||
|
|
if (cron.isEmpty()) {
|
||
|
|
logger.error("cron is null");
|
||
|
|
}
|
||
|
|
return new CronTrigger(cron).nextExecutionTime(triggerContext);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
private void process() {
|
||
|
|
ThreadUtil.execAsync(() -> {
|
||
|
|
WorkBindBusTypeRequest workBindBusTypeRequest = new WorkBindBusTypeRequest();
|
||
|
|
List<SysWorkplaceDocumentResponse> sysWorkplaceDocumentResponses = sysWorkplaceDocumentDao.filterList(workBindBusTypeRequest);
|
||
|
|
if (CollUtil.isNotEmpty(sysWorkplaceDocumentResponses)) {
|
||
|
|
//包装开始和结束的日期
|
||
|
|
CollectOrderRequest collectOrderRequest = new CollectOrderRequest();
|
||
|
|
String date = MsDateUtil.getDate();
|
||
|
|
collectOrderRequest.setStartTime(date);
|
||
|
|
collectOrderRequest.setEndTime(date);
|
||
|
|
for (SysWorkplaceDocumentResponse sysWorkplaceDocumentResponse : sysWorkplaceDocumentResponses) {
|
||
|
|
Long workplaceCode = sysWorkplaceDocumentResponse.getWorkplaceCode();
|
||
|
|
String documentTypeCode = sysWorkplaceDocumentResponse.getDocumentTypeCode();
|
||
|
|
collectOrderRequest.setBusType(documentTypeCode);
|
||
|
|
collectOrderRequest.setWorkPlaceCode(workplaceCode);
|
||
|
|
collectOriginService.downloadOrderV2(collectOrderRequest);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|