فهرست منبع

获取订单列表 添加分发

zhaoxian 7 ماه پیش
والد
کامیت
9691deaad8
1فایلهای تغییر یافته به همراه60 افزوده شده و 22 حذف شده
  1. 60 22
      job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuixuanJob.java

+ 60 - 22
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuixuanJob.java

@@ -34,7 +34,7 @@ public class RuixuanJob {
         createMap.put("shopId", param);
         createMap.put("queryType", 1);
         createMap.put("beginDate", yesterday);
-        createMap.put("endDate", today);
+        createMap.put("endDate", yesterday);
 
         //获取订单列表
         String listUrl = RX_IP + "kwaixiaodian/item/querykwaiOrderList";
@@ -44,7 +44,7 @@ public class RuixuanJob {
         updateMap.put("shopId", param);
         updateMap.put("queryType", 2);
         updateMap.put("beginDate", yesterday);
-        updateMap.put("endDate", today);
+        updateMap.put("endDate", yesterday);
         HttpUtils.httpGet(listUrl, updateMap, null);
     }
 
@@ -84,28 +84,47 @@ public class RuixuanJob {
         HttpUtils.httpGet(listUrl, createMap, null);
     }
 
+    private static final String COMMON_IP = ".api.tjyourong.com.cn/isv/supply_chain/insertNowdayOrderList";
+
     /**
      * 插入昨天数据 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);
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+        String[] arr = param.split("_");
+        if (arr.length > 1) {
+            String dbType = arr[0];
+            String tokenId = arr[1];
+            String url = null;
+            if ("miaogousi".equals(dbType)) {
+                url = "http://mgs" + COMMON_IP;
+            } else {
+                url = "http://" + dbType + COMMON_IP;
+            }
+            log.info("---tokenId:{},订单URL:{}", tokenId, url);
+            String today = DateUtils.getNowDate("yyyy-MM-dd");
+            String yesterday = DateUtils.getAnotherDay("yyyy-MM-dd", today, -1);
+
+            Map<String, Object> createMap = new HashMap<>();
+            createMap.put("tokenId", tokenId);
+            createMap.put("queryType", 1);
+            createMap.put("beginDate", yesterday);
+            createMap.put("endDate", yesterday);
+            //获取订单列表
+            HttpUtils.httpGet(url, createMap, null);
+
+            Map<String, Object> updateMap = new HashMap<>();
+            updateMap.put("tokenId", tokenId);
+            updateMap.put("queryType", 2);
+            updateMap.put("beginDate", yesterday);
+            updateMap.put("endDate", yesterday);
+            HttpUtils.httpGet(url, updateMap, null);
+        }
     }
 
     /**
@@ -113,9 +132,28 @@ public class RuixuanJob {
      */
     @XxlJob("insertNowdayOrderList")
     public void insertNowdayOrderList() {
-        //获取订单列表
-        String listUrl = RX_IP + "isv/supply_chain/insertNowdayOrderList";
-        HttpUtils.httpGet(listUrl, null, null);
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+        String[] arr = param.split("_");
+        if (arr.length > 1) {
+            String dbType = arr[0];
+            String tokenId = arr[1];
+            String url = null;
+            if ("miaogousi".equals(dbType)) {
+                url = "http://mgs" + COMMON_IP;
+            } else {
+                url = "http://" + dbType + COMMON_IP;
+            }
+
+            //获取订单列表
+            Map<String, Object> createMap = new HashMap<>();
+            createMap.put("tokenId", tokenId);
+            HttpUtils.httpGet(url, createMap, null);
+            log.info("---tokenId:{},订单URL:{}", tokenId, url);
+        }
     }
 
 }