发票详情更新定时任务

admin/src/main/java/com/kym/admin/jobs/InvoiceStatusJob.java

@@ -37,11 +37,16 @@ public class InvoiceStatusJob {
         this.wxPayService = wxPayService;
     }
 
-    // 每天18:00执行一次
+    /**
+     * 每天18:00执行，处理微信发票开票结果通知不到的情况，主动查询发票信息更新数据
+     */
     @Scheduled(cron = "0 0 18 * * ?")
     public void execute() {
+        log.info("执行发票状态处理定时任务...开始");
         // 所有开票中状态的发票
-        var invoiceList = invoiceService.lambdaQuery().eq(Invoice::getStatus, Invoice.STATUS_已开票).list();
+        DynamicDataSourceContextHolder.push("db-miniapp");
+        var invoiceList = invoiceService.lambdaQuery().eq(Invoice::getStatus, Invoice.STATUS_开票中).list();
+        DynamicDataSourceContextHolder.poll();
         invoiceList.forEach(invoice -> {
             var fapiaoApplications = wxPayService.queryFapiao(invoice.getApplyId());
             // 更新发票详情
@@ -54,6 +59,7 @@ public class InvoiceStatusJob {
                 DynamicDataSourceContextHolder.poll();
             }
         });
+        log.info("执行发票状态处理定时任务...结束");
     }
 
 }