Browse Source

/* 淘宝订单抓取 优化
1.新建 订单插入 mvc类
2.日志记录
1.服务挂掉
2.确实没有录入订单
3.新增单号字段, 录入日期记录当天 ,淘宝订单ID,修改了订单表 alter table sale add sa_tradeid number;
4.增加定时任务 每隔10分钟自动执行一次
author by shenl 2020-11-16 */ 实时sessionKEY待获取

sl 5 years ago
parent
commit
79e57cad4d

+ 11 - 1
src/main/java/com/uas/eis/serviceImpl/InsertServiceImpl.java

@@ -20,7 +20,8 @@ import java.util.TimerTask;
 
 import com.taobao.api.request.TradesSoldGetRequest;
 import com.taobao.api.response.TradesSoldGetResponse;
-
+import com.uas.eis.utils.HttpUtil;
+import com.uas.eis.utils.HttpUtil.Response;
 
 
 @Service
@@ -82,6 +83,15 @@ public class InsertServiceImpl implements InsertService {
 //                    OpenTradesSoldGetResponse rsp = client.execute(req, sessionKey);
 
         try {
+
+            try {
+                Response response = HttpUtil.sendGetRequest2("http://container.open.taobao.com/container?appkey=31921866",
+                        null, true,"2c1ea08986cd796fe050007f01002ea6");
+                System.out.print(response.getResponseText());
+            } catch (Exception e) {
+                logger.info(this.getClass() + "response");
+                e.printStackTrace();
+            }
             TradesSoldGetResponse rsp = client.execute(req, sessionKey);
 
             System.out.println(rsp.getBody());

+ 40 - 2
src/main/java/com/uas/eis/utils/HttpUtil.java

@@ -128,8 +128,13 @@ public class HttpUtil {
 	 * @throws Exception
 	 */
 	public static Response sendGetRequest(String url, HashMap<String, String> header, Map<String, String> params, boolean sign, String signKey) throws Exception {
-		return sendRequest(RequestMethod.GET, url, header, params, sign, signKey);
-	}
+        return sendRequest(RequestMethod.GET, url, header, params, sign, signKey);
+    }
+
+
+    public static Response sendGetRequest2( String url,Map<String, String> params, boolean sign, String signKey) throws Exception {
+        return sendRequest2(RequestMethod.GET, url, params, sign, signKey);
+    }
 
 	/**
 	 * 发送GET请求
@@ -145,6 +150,8 @@ public class HttpUtil {
 		return sendRequest(RequestMethod.GET, url, header, params, sign, null);
 	}
 
+
+
 	/**
 	 * 发送POST请求
 	 * 
@@ -481,6 +488,37 @@ public class HttpUtil {
 		}
 	}
 
+
+    public static Response sendRequest2(RequestMethod method, String url, Map<String, String> params, boolean sign, String signKey)
+            throws Exception {
+
+        switch (method) {
+            case GET: {
+                HttpRequestBase request = new HttpGet(getRequestUrl(url, params, sign, signKey));
+                return sendHttpUriRequest(request);
+            }
+            case POST: {
+                HttpPost request = new HttpPost(getRequestUrl(url, sign, signKey));
+                return sendHttpEntityEnclosingRequest(request, params);
+            }
+            case PUT: {
+                HttpPut request = new HttpPut(getRequestUrl(url, sign, signKey));
+                return sendHttpEntityEnclosingRequest(request, params);
+            }
+            case DELETE: {
+                HttpDelete request = new HttpDelete(getRequestUrl(url, params, sign, signKey));
+                return sendHttpUriRequest(request);
+            }
+            default: {
+                HttpGet request = new HttpGet(getRequestUrl(url, params, sign, signKey));
+                return sendHttpUriRequest(request);
+            }
+        }
+    }
+
+
+
+
 	/**
 	 * 发起http请求
 	 *