Browse Source

获取售后单信息

zhaoxian 6 months ago
parent
commit
f336d22f01

+ 70 - 34
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuixuanJob.java

@@ -19,34 +19,55 @@ public class RuixuanJob {
     private static final String COMMON_IP = ".api.tjyourong.com.cn/isv/supply_chain/insertNowdayOrderList";
 
     /**
-     * 昨天到今天的数据 kwaixiaodian_order_cursor_list
+     * 昨天的数据 kwaixiaodian_order_cursor_list
      */
     @XxlJob("querykwaiOrderList")
     public void querykwaiOrderList() {
-        String param = XxlJobHelper.getJobParam(); // 执行参数
-        if (Check.isNull(param)) {
-            log.error("入参为空");
-            return;
-        }
-        String today = DateUtils.getNowDate("yyyy-MM-dd");
-        String yesterday = DateUtils.getAnotherDay("yyyy-MM-dd", today, -1);
+        try {
+            String param = XxlJobHelper.getJobParam(); // 执行参数
+            if (Check.isNull(param)) {
+                log.error("入参为空");
+                return;
+            }
+            String today = DateUtils.getNowDate("yyyy-MM-dd");
+            String yesterday = DateUtils.getAnotherDay("yyyy-MM-dd", today, -1);
 
-        Map<String, Object> createMap = new HashMap<>();
-        createMap.put("shopId", param);
-        createMap.put("queryType", 1);
-        createMap.put("beginDate", yesterday);
-        createMap.put("endDate", yesterday);
+            //queryType:1按创建时间查找 2按更新时间查找 ,默认创建时间
 
-        //获取订单列表
-        String listUrl = RX_IP + "kwaixiaodian/item/querykwaiOrderList";
-        HttpUtils.httpGet(listUrl, createMap, null);
+            Map<String, Object> createMap = new HashMap<>();
+            createMap.put("shopId", param);
+            createMap.put("queryType", 1);
+            createMap.put("beginDate", yesterday);
+            createMap.put("endDate", yesterday);
+
+            //获取订单列表
+            String listUrl = RX_IP + "kwaixiaodian/item/querykwaiOrderList";
+            HttpUtils.httpGet(listUrl, createMap, null);
+
+            /* -----------获取售后单列表 ↓↓↓ begin*/
+
+            Thread.sleep(10000);
+            //获取售后单列表
+            String rxAfterIp = RX_IP + "kwaixiaodian/item/afterSalesList";
+            HttpUtils.httpGet(rxAfterIp, createMap, null);
+            /* -----------获取售后单列表 ↑↑↑ end*/
 
-        Map<String, Object> updateMap = new HashMap<>();
-        updateMap.put("shopId", param);
-        updateMap.put("queryType", 2);
-        updateMap.put("beginDate", yesterday);
-        updateMap.put("endDate", yesterday);
-        HttpUtils.httpGet(listUrl, updateMap, null);
+            Thread.sleep(10000);
+            Map<String, Object> updateMap = new HashMap<>();
+            updateMap.put("shopId", param);
+            updateMap.put("queryType", 2);
+            updateMap.put("beginDate", yesterday);
+            updateMap.put("endDate", yesterday);
+            HttpUtils.httpGet(listUrl, updateMap, null);
+
+            /* -----------获取售后单列表 ↓↓↓ begin*/
+            Thread.sleep(10000);
+            HttpUtils.httpGet(rxAfterIp, updateMap, null);
+            /* -----------获取售后单列表 ↑↑↑ end*/
+
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
     }
 
     /**
@@ -54,21 +75,33 @@ public class RuixuanJob {
      */
     @XxlJob("queryNowdayKWaiOrderList")
     public void queryNowDaykwaiOrderList() {
-        String param = XxlJobHelper.getJobParam(); // 执行参数
-        if (Check.isNull(param)) {
-            log.error("入参为空");
-            return;
+        try {
+            String param = XxlJobHelper.getJobParam(); // 执行参数
+            if (Check.isNull(param)) {
+                log.error("入参为空");
+                return;
+            }
+            Map<String, Object> createMap = new HashMap<>();
+            createMap.put("shopId", param);
+
+            //获取订单列表
+            String listUrl = RX_IP + "kwaixiaodian/item/queryNowdayKWaiOrderList";
+            HttpUtils.httpGet(listUrl, createMap, null);
+
+            /* -----------获取售后单列表 ↓↓↓ begin*/
+            Thread.sleep(10000);
+            //获取售后单列表
+            String rxAfterIp = RX_IP + "kwaixiaodian/item/afterSalesList";
+            HttpUtils.httpGet(rxAfterIp, createMap, null);
+            /* -----------获取售后单列表 ↑↑↑ end*/
+        } catch (InterruptedException e) {
+            e.printStackTrace();
         }
-        Map<String, Object> createMap = new HashMap<>();
-        createMap.put("shopId", param);
 
-        //获取订单列表
-        String listUrl = RX_IP + "kwaixiaodian/item/queryNowdayKWaiOrderList";
-        HttpUtils.httpGet(listUrl, createMap, null);
     }
 
     /**
-     * 获取30天内的数据 kwaixiaodian_order_cursor_list
+     * 获取90天内的数据 kwaixiaodian_order_cursor_list
      */
     @XxlJob("querykwaiOrderListMonth")
     public void querykwaiOrderListMonth() {
@@ -80,8 +113,11 @@ public class RuixuanJob {
         Map<String, Object> createMap = new HashMap<>();
         createMap.put("shopId", param);
 
-        //获取订单列表
-        String listUrl = RX_IP + "kwaixiaodian/item/querykwaiOrderListMonth";
+//        //获取订单列表
+//        String listUrl = RX_IP + "kwaixiaodian/item/querykwaiOrderListMonth";
+//
+        //获取售后单列表
+        String listUrl = RX_IP + "kwaixiaodian/item/queryAfterSalesListMonth";
         HttpUtils.httpGet(listUrl, createMap, null);
     }