This commit is contained in:
Leo
2025-12-23 18:46:26 +08:00
parent c56b911db0
commit dfa6109788
2 changed files with 7 additions and 5 deletions

View File

@@ -13,7 +13,7 @@ import java.util.List;
/** /**
* 物流信息扫描定时任务 * 物流信息扫描定时任务
* 每1小时扫描一次分销标记为F或PDD的订单获取物流信息并推送 * 每20分钟扫描一次分销标记为F或PDD的订单最近30天,获取物流信息并推送
*/ */
@Component @Component
public class LogisticsScanTask { public class LogisticsScanTask {
@@ -26,15 +26,16 @@ public class LogisticsScanTask {
private ILogisticsService logisticsService; private ILogisticsService logisticsService;
/** /**
* 定时任务:每1小时执行一次 * 定时任务:每20分钟执行一次
* Cron表达式0 0 * * * ? 表示每小时的第0分钟执行 * Cron表达式0 */20 * * * ? 表示每20分钟执行一次
* 只扫描最近30天的订单
*/ */
@Scheduled(cron = "0 */20 * * * ?") @Scheduled(cron = "0 */20 * * * ?")
public void scanAndFetchLogistics() { public void scanAndFetchLogistics() {
logger.info("========== 开始执行物流信息扫描定时任务 =========="); logger.info("========== 开始执行物流信息扫描定时任务最近30天订单 ==========");
try { try {
// 查询分销标记为F或PDD且有物流链接的订单 // 查询分销标记为F或PDD且有物流链接的订单最近30天
List<JDOrder> orders = jdOrderService.selectJDOrderListByDistributionMarkFOrPDD(); List<JDOrder> orders = jdOrderService.selectJDOrderListByDistributionMarkFOrPDD();
if (orders == null || orders.isEmpty()) { if (orders == null || orders.isEmpty()) {

View File

@@ -212,6 +212,7 @@
(distribution_mark = 'F' OR distribution_mark = 'PDD' OR distribution_mark = 'H' OR distribution_mark = 'W' OR distribution_mark = 'PDD-W') (distribution_mark = 'F' OR distribution_mark = 'PDD' OR distribution_mark = 'H' OR distribution_mark = 'W' OR distribution_mark = 'PDD-W')
AND logistics_link IS NOT NULL AND logistics_link IS NOT NULL
AND logistics_link != '' AND logistics_link != ''
AND create_time >= DATE_SUB(NOW(), INTERVAL 30 DAY)
</where> </where>
ORDER BY create_time DESC ORDER BY create_time DESC
</select> </select>