1、oapi-sdk包移动到common-core包

pom.xml

@@ -108,21 +108,24 @@
             <scope>test</scope>
         </dependency>
 
-        <dependency>
-            <groupId>com.larksuite.oapi</groupId>
-            <artifactId>oapi-sdk</artifactId>
-        </dependency>
+
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
             <scope>test</scope>
         </dependency>
 
+
         <!-- https://mvnrepository.com/artifact/com.squareup.okhttp3/okhttp -->
         <dependency>
             <groupId>com.squareup.okhttp3</groupId>
             <artifactId>okhttp</artifactId>
         </dependency>
+        <!-- RuoYi wangxiaolu-link-module-bi -->
+        <dependency>
+            <groupId>com.wangxiaolu.sfa</groupId>
+            <artifactId>wangxiaolu-link-module-bi</artifactId>
+        </dependency>
 
     </dependencies>
 

src/main/java/com/sfa/job/SfaJobApplication.java

@@ -5,6 +5,7 @@ import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import com.sfa.common.security.annotation.EnableCustomConfig;
 import com.sfa.common.security.annotation.EnableRyFeignClients;
+import org.springframework.context.annotation.ComponentScan;
 
 /**
  * 定时任务
@@ -14,7 +15,8 @@ import com.sfa.common.security.annotation.EnableRyFeignClients;
 @EnableCustomConfig
 @EnableRyFeignClients
 @SpringBootApplication
-@MapperScan({"com.sfa.job.domain.job.mapper","com.sfa.job.domain.system.mapper"})
+@ComponentScan(value = {"com.sfa.job","com.link.bi.domain.*","com.link.bi.service.*","com.link.bi.pojo.*"})
+@MapperScan({"com.sfa.job.domain.job.mapper","com.sfa.job.domain.system.mapper","com.link.bi.domain.mapper"})
 public class SfaJobApplication
 {
     public static void main(String[] args) {

src/main/java/com/sfa/job/controller/finance/FinanceOrderDetailSyncController.java

+package com.sfa.job.controller.finance;
+
+import com.link.bi.pojo.response.FinanceSyncOrderDetailDto;
+import com.link.bi.service.FinanceOrderService;
+import com.sfa.common.core.web.controller.BaseController;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Date;
+
+/**
+ * 调度任务信息操作处理
+ *
+ * @author ruoyi
+ */
+@RestController
+@RequestMapping("/finance/order")
+public class FinanceOrderDetailSyncController extends BaseController {
+    @Autowired
+    private FinanceOrderService orderService;
+
+    @GetMapping("/syncWandiantongOrderDeatail")
+    public FinanceSyncOrderDetailDto syncWandiantongOrderDeatail(Date startTime, Date endTime) {
+        // 可以传参开始时间和结束时间，用于补充特定时间的数据采集
+        FinanceSyncOrderDetailDto syncWdtOrderDetailDto = orderService.syncWandiantongOrder(startTime, endTime, 1);
+        return syncWdtOrderDetailDto;
+    }
+
+
+}

src/main/java/com/sfa/job/xxljob/order/FinanceOrderTask.java

+package com.sfa.job.xxljob.order;
+
+import com.link.bi.pojo.response.FinanceSyncOrderDetailDto;
+import com.link.bi.service.FinanceOrderDetailService;
+import com.link.bi.service.FinanceOrderService;
+import com.xxl.job.core.context.XxlJobContext;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author : 吕本才
+ * @date : 2025-01-15 13:03:51
+ * @describe : 财务订单数据
+ */
+@Component
+@Slf4j
+public class FinanceOrderTask {
+
+    @Autowired
+    FinanceOrderDetailService orderDetailService;
+    @Autowired
+    FinanceOrderService orderService;
+
+    /**
+     * 同步部门数据
+     */
+    @XxlJob("syncWandiantongOrderDeatail")
+    public FinanceSyncOrderDetailDto syncWandiantongOrderDeatail() {
+        // 暂不考虑分片
+        XxlJobContext xxlJobContext = XxlJobContext.getXxlJobContext();
+        int shardingTotalCount = xxlJobContext.getShardTotal();
+        int shardingItem = xxlJobContext.getShardIndex();
+
+        // 简单模拟分片处理，这里输出每个分片的信息
+        System.out.println("分片总数: " + shardingTotalCount + ", 当前分片: " + shardingItem);
+
+        log.info("开始同步-旺店通订单明细api接口数据");
+        // 定时任务不设定开始时间和结束时间
+        FinanceSyncOrderDetailDto syncWdtOrderDetailDto = orderService.syncWandiantongOrder(null, null,0);
+
+        log.info("结束同步-旺店通订单明细api接口数据, 共同步订单{}条数据，订单明细{}条", syncWdtOrderDetailDto.getOrderCount(),syncWdtOrderDetailDto.getOrderDetailCount());
+        return syncWdtOrderDetailDto;
+    }
+
+}