Browse Source

获取kwaixiaodian订单列表

zhaoxian 7 tháng trước cách đây
mục cha
commit
3d7157f153

+ 54 - 0
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/data/utils/HttpUtils.java

@@ -9,6 +9,7 @@ import org.apache.http.client.CookieStore;
 import org.apache.http.client.HttpClient;
 import org.apache.http.client.HttpClient;
 import org.apache.http.client.config.CookieSpecs;
 import org.apache.http.client.config.CookieSpecs;
 import org.apache.http.client.config.RequestConfig;
 import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.HttpGet;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
 import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
 import org.apache.http.conn.ssl.TrustStrategy;
 import org.apache.http.conn.ssl.TrustStrategy;
@@ -20,6 +21,7 @@ import org.apache.http.ssl.SSLContextBuilder;
 import org.apache.http.util.EntityUtils;
 import org.apache.http.util.EntityUtils;
 
 
 import javax.net.ssl.SSLContext;
 import javax.net.ssl.SSLContext;
+import java.net.URLEncoder;
 import java.nio.charset.Charset;
 import java.nio.charset.Charset;
 import java.security.cert.CertificateException;
 import java.security.cert.CertificateException;
 import java.security.cert.X509Certificate;
 import java.security.cert.X509Certificate;
@@ -140,4 +142,56 @@ public class HttpUtils {
     }
     }
     return strReturn;
     return strReturn;
   }
   }
+
+
+  public static String httpGet(String url, Map<String, Object> paramsMap, Map<String, String> headers) {
+    String result = null;
+    try {
+      // CloseableHttpClient httpClient = HttpClients.createDefault();
+      //创建参数列表
+      HttpClient httpclient = getHttpclient();
+      StringBuilder postBody = null;
+      if (!Check.isNull(paramsMap)) {
+        postBody = new StringBuilder();
+        for (Map.Entry<String, Object> entry : paramsMap.entrySet()) {
+          if (entry.getValue() == null) {
+            continue;
+          }
+          postBody.append(entry.getKey()).append("=").append(URLEncoder.encode(entry.getValue().toString(),
+                  "utf-8")).append("&");
+        }
+        if (!paramsMap.isEmpty()) {
+          postBody.deleteCharAt(postBody.length() - 1);
+        }
+      }
+      String urlStr;
+      if (!Check.isNull(postBody)) {
+        urlStr = url + "?" + postBody;
+      } else {
+        urlStr = url;
+      }
+      HttpGet httpget = new HttpGet(urlStr);
+      httpget.setHeader("User-Agent", USER_AGENT);
+      if (!Check.isNullMap(headers)) {
+        for (String key : headers.keySet()) {
+          httpget.setHeader(key, headers.get(key));
+        }
+      }
+      HttpEntity respEntity;
+      HttpResponse response = httpclient.execute(httpget);
+      respEntity = response.getEntity();
+      result = EntityUtils.toString(respEntity);
+    } catch (Exception e) {
+      log.error("http get请求异常");
+      e.printStackTrace();
+    }
+    return result;
+  }
+
+
+  public static HttpClient getHttpclient() {
+    RequestConfig defaultRequestConfig = RequestConfig.custom().setSocketTimeout(180000).setConnectTimeout(30000)
+            .setConnectionRequestTimeout(30000).setStaleConnectionCheckEnabled(true).build();
+    return HttpClients.custom().setDefaultRequestConfig(defaultRequestConfig).build();
+  }
 }
 }

+ 41 - 0
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuixuanJob.java

@@ -0,0 +1,41 @@
+package cn.com.ctop.job.kuaishou.handler;
+
+import cn.com.ctop.job.kuaishou.data.utils.Check;
+import cn.com.ctop.job.kuaishou.data.utils.DateUtils;
+import cn.com.ctop.job.kuaishou.data.utils.HttpUtils;
+import com.xxl.job.core.context.XxlJobHelper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+@Component
+public class RuixuanJob {
+
+    private static final String RX_IP = "http://ruixuan.api.tjyourong.com.cn/";
+
+    @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);
+
+        Map<String, Object> requestMap = new HashMap<>();
+        requestMap.put("shopId", param);
+        requestMap.put("beginDate", yesterday);
+        requestMap.put("endDate", today);
+
+        //获取订单列表
+        String listUrl = RX_IP + "kwaixiaodian/item/querykwaiOrderList";
+        HttpUtils.httpGet(listUrl, requestMap, null);
+
+    }
+
+}