Explorar el Código

获取订单列表

zhaoxian hace 7 meses
padre
commit
8d54034f68

+ 39 - 2
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuixuanJob.java

@@ -17,6 +17,9 @@ public class RuixuanJob {
 
 
     private static final String RX_IP = "http://ruixuan.api.tjyourong.com.cn/";
     private static final String RX_IP = "http://ruixuan.api.tjyourong.com.cn/";
 
 
+    /**
+     * 昨天到今天的数据 kwaixiaodian_order_cursor_list
+     */
     @XxlJob("querykwaiOrderList")
     @XxlJob("querykwaiOrderList")
     public void querykwaiOrderList() {
     public void querykwaiOrderList() {
         String param = XxlJobHelper.getJobParam(); // 执行参数
         String param = XxlJobHelper.getJobParam(); // 执行参数
@@ -46,7 +49,7 @@ public class RuixuanJob {
     }
     }
 
 
     /**
     /**
-     * 获取两小时内的数据
+     * 获取两小时内的数据 kwaixiaodian_order_cursor_list
      */
      */
     @XxlJob("queryNowdayKWaiOrderList")
     @XxlJob("queryNowdayKWaiOrderList")
     public void queryNowDaykwaiOrderList() {
     public void queryNowDaykwaiOrderList() {
@@ -64,7 +67,7 @@ public class RuixuanJob {
     }
     }
 
 
     /**
     /**
-     * 获取30天内的数据
+     * 获取30天内的数据 kwaixiaodian_order_cursor_list
      */
      */
     @XxlJob("querykwaiOrderListMonth")
     @XxlJob("querykwaiOrderListMonth")
     public void querykwaiOrderListMonth() {
     public void querykwaiOrderListMonth() {
@@ -81,4 +84,38 @@ public class RuixuanJob {
         HttpUtils.httpGet(listUrl, createMap, null);
         HttpUtils.httpGet(listUrl, createMap, null);
     }
     }
 
 
+    /**
+     * 插入昨天数据 kuaishou_supply_chain
+     */
+    @XxlJob("insertOrderList")
+    public void insertOrderList() {
+        String today = DateUtils.getNowDate("yyyy-MM-dd");
+        String yesterday = DateUtils.getAnotherDay("yyyy-MM-dd", today, -1);
+
+        Map<String, Object> createMap = new HashMap<>();
+        createMap.put("queryType", 1);
+        createMap.put("beginDate", yesterday);
+        createMap.put("endDate", yesterday);
+
+        //获取订单列表
+        String listUrl = RX_IP + "isv/supply_chain/insertOrderList";
+        HttpUtils.httpGet(listUrl, createMap, null);
+
+        Map<String, Object> updateMap = new HashMap<>();
+        updateMap.put("queryType", 2);
+        updateMap.put("beginDate", yesterday);
+        updateMap.put("endDate", today);
+        HttpUtils.httpGet(listUrl, updateMap, null);
+    }
+
+    /**
+     * 获取两小时内的数据 kuaishou_supply_chain
+     */
+    @XxlJob("insertNowdayOrderList")
+    public void insertNowdayOrderList() {
+        //获取订单列表
+        String listUrl = RX_IP + "isv/supply_chain/insertNowdayOrderList";
+        HttpUtils.httpGet(listUrl, null, null);
+    }
+
 }
 }