Browse Source

【博思达】【小米库存对接 记录日志】

samhoo 3 years ago
parent
commit
51f3f3e404
1 changed files with 14 additions and 0 deletions
  1. 14 0
      src/main/java/com/uas/eis/httpclient/X5JsonHttpClient.java

+ 14 - 0
src/main/java/com/uas/eis/httpclient/X5JsonHttpClient.java

@@ -2,6 +2,7 @@ package com.uas.eis.httpclient;
 
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSON;
 import com.uas.eis.beans.x5domain.*;
 import com.uas.eis.beans.x5domain.*;
+import com.uas.eis.dao.BaseDao;
 import com.uas.eis.utils.X5StringUtils;
 import com.uas.eis.utils.X5StringUtils;
 import org.apache.commons.codec.digest.DigestUtils;
 import org.apache.commons.codec.digest.DigestUtils;
 import org.apache.http.Header;
 import org.apache.http.Header;
@@ -12,11 +13,20 @@ import org.apache.http.client.fluent.Form;
 import org.apache.http.client.fluent.Request;
 import org.apache.http.client.fluent.Request;
 import org.apache.http.client.fluent.Response;
 import org.apache.http.client.fluent.Response;
 import org.apache.http.util.EntityUtils;
 import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
 
 
 import javax.xml.bind.DatatypeConverter;
 import javax.xml.bind.DatatypeConverter;
 import java.io.UnsupportedEncodingException;
 import java.io.UnsupportedEncodingException;
+import java.util.Date;
 
 
 public class X5JsonHttpClient extends X5HttpClient {
 public class X5JsonHttpClient extends X5HttpClient {
+
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Autowired
+    private BaseDao baseDao;
+
     /**
     /**
      * 构造器
      * 构造器
      */
      */
@@ -68,7 +78,11 @@ public class X5JsonHttpClient extends X5HttpClient {
             String responseContent = EntityUtils.toString(httpResponse.getEntity(), "utf-8");
             String responseContent = EntityUtils.toString(httpResponse.getEntity(), "utf-8");
             if (statusCode == 200) {
             if (statusCode == 200) {
                 x5Response = JSON.parseObject(responseContent, X5Response.class);
                 x5Response = JSON.parseObject(responseContent, X5Response.class);
+                baseDao.execute("insert into XIAOMIDOCKINGLOG(ML_ID,ML_DATE,ML_CONTENT,)" +
+                        "values(XIAOMIDOCKINGLOG_seq.next,sysdate,'上传成功!')");
+                logger.info("时间:"+new Date()+"状态码:"+statusCode);
             } else {
             } else {
+                logger.info("时间:"+new Date()+"状态码:"+statusLine.getStatusCode()+"错误:"+statusLine.getReasonPhrase());
                 throw new HttpResponseException(statusLine.getStatusCode(), statusLine.getStatusCode() + " " + statusLine.getReasonPhrase());
                 throw new HttpResponseException(statusLine.getStatusCode(), statusLine.getStatusCode() + " " + statusLine.getReasonPhrase());
             }
             }
         } catch (Exception ex) {
         } catch (Exception ex) {