package comhundsunepayebsreconciliationserviceimpl;import javautilArrayList;import javautilHashMap;import javautilList;import javautilMap;import orgspringframeworkbeansfactoryDisposableBean;import org
这段代码是一个对账任务的初始化实现类。它实现了InitReconciliationCheckingService接口,并使用了ThreadPoolTaskExecutor来执行对账任务。
在execute()方法中,首先记录日志,然后调用process()方法来执行对账任务。
在process()方法中,首先调用yunpayReconciliationTaskManager.selectReconciliationCheckingTask()方法来筛选可执行的对账任务。如果没有可执行的任务,则返回。
接下来调用init()方法来初始化任务。该方法首先创建了appointedMap和taskSrcStatus两个Map对象,用于保存任务的指定日期对账标志和对账状态。然后遍历所有任务,根据任务的指定日期对账标志和对账状态来更新任务的对账状态,并将更新后的任务添加到updateTasks列表中。最后调用yunpayReconciliationTaskManager.batchUpdateReconciliationTask()方法批量更新任务的对账状态。
在init()方法执行完成后,根据任务的指定日期对账标志和对账状态,遍历所有任务,并创建一个YunpayReconciliationCheckingTask对象,然后使用threadPool.execute()方法来执行该任务。
在destroy()方法中,销毁线程池
原文地址: https://www.cveoy.top/t/topic/ibRH 著作权归作者所有。请勿转载和采集!