From eb3f8587aa7466fd6d2d3ca712d0f9baf4e27dcb Mon Sep 17 00:00:00 2001
From: 王佳豪 <g675230687@126.com>
Date: 星期五, 25 六月 2021 11:01:58 +0800
Subject: [PATCH] 1.sap请求日志记录
---
src/main/java/com/slcf/filter/UpdateThread.java | 133 +++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 130 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/slcf/filter/UpdateThread.java b/src/main/java/com/slcf/filter/UpdateThread.java
index 50fcb96..0aa93d5 100644
--- a/src/main/java/com/slcf/filter/UpdateThread.java
+++ b/src/main/java/com/slcf/filter/UpdateThread.java
@@ -5,11 +5,16 @@
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
+import java.util.Date;
import javax.annotation.Resource;
+import com.slcf.pojo.SapRequestLogBean;
+import com.slcf.service.SapRequestLogService;
+import net.sf.json.JSONString;
import org.activiti.engine.impl.transformer.IntegerToString;
import org.apache.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -40,6 +45,8 @@
// WaitPakOutService waitPakOutService;
// @Resource
// private static WaitPakInServiceImpl waitPakInService;
+ @Autowired
+ SapRequestLogService sapRequestLogService;
Logger logger=Logger.getLogger(UpdateThread.class);
@@ -66,9 +73,9 @@
waitPakOutService = getWaitPakOutService();
while(true) {
try {
- updateWaitPakInData();
- sendPickPrintCmd();
- updateWaitPakOutData();
+ updateWaitPakInData(); // 鍏ュ簱
+ sendPickPrintCmd(); // 鎵撳嵃
+ updateWaitPakOutData(); // 鍑哄簱
// updateWaitCheckData();
Thread.sleep(5000);
} catch (InterruptedException e) {
@@ -124,6 +131,14 @@
if(sessionCookie==null || sessionCookie.length()<1)
{
logger.error("SAP ERROR-----璋冪敤涓婃灦瀹屾垚鎺ュ彛锛実et璇锋眰鑾峰彇cookie澶辫触");
+ // SAP INFO-----璋冪敤涓婃灦瀹屾垚鎺ュ彛锛屾棩蹇楄褰�
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakIn.getMatnr());
+ logInfo.setRequest("鑾峰彇cookie澶辫触,cookie鍊�:" + sessionCookie);
+ logInfo.setResponse("SAP ERROR-----璋冪敤涓婃灦瀹屾垚鎺ュ彛锛実et璇锋眰鑾峰彇cookie澶辫触");
+ logInfo.setCreate_time(new Date());
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
return result;
}
String[] sessionId = sessionCookie.split(";");
@@ -133,6 +148,14 @@
// token = map.get("x-csrf-token").toString();
} catch (Exception e1) {
logger.error("SAP ERROR-----璋冪敤涓婃灦瀹屾垚鎺ュ彛1锛実et璇锋眰鑾峰彇cookie澶辫触銆�" + e1.getMessage());
+ // SAP INFO-----璋冪敤涓婃灦瀹屾垚鎺ュ彛锛屾棩蹇楄褰�
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakIn.getMatnr());
+ logInfo.setRequest("鑾峰彇cookie澶辫触");
+ logInfo.setResponse("SAP ERROR-----璋冪敤涓婃灦瀹屾垚鎺ュ彛1锛実et璇锋眰鑾峰彇cookie澶辫触銆�" + e1.getMessage());
+ logInfo.setCreate_time(new Date());
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
// e1.printStackTrace();
}finally {
if(connection1!=null){
@@ -221,11 +244,29 @@
}catch(Exception em) {
}
if(zstatus.equals("s") || message.contains("宸茬粡瀹屽叏鎻愪緵")) {//涓婃姤SAP鎴愬姛,杞巻鍙叉。
+ // SAP INFO-----璋冪敤涓婃灦瀹屾垚鎺ュ彛锛屾棩蹇楄褰�
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakIn.getMatnr());
+ logInfo.setRequest(jsObj.toString());
+ logInfo.setResponse(sb.toString());
+ logInfo.setCreate_time(new Date());
+ logInfo.setRemark("涓婃灦瀹屾垚鎺ュ彛:" + message);
+ logInfo.setType(1);
+ sapRequestLogService.addSapLog(logInfo);
// if(zstatus.equals("s")) {
waitPakIn.setIo_status("Y");
waitPakInService.upWaitPakIn(waitPakIn);
waitPakInService.moveToLog(waitPakIn);
}else if(zstatus.equals("e")) {//涓婃姤SAP澶辫触,鏇存柊io_status=X
+ // SAP INFO-----璋冪敤涓婃灦瀹屾垚鎺ュ彛锛屾棩蹇楄褰�
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakIn.getMatnr());
+ logInfo.setRequest(jsObj.toString());
+ logInfo.setResponse(sb.toString());
+ logInfo.setCreate_time(new Date());
+ logInfo.setRemark("涓婃灦瀹屾垚鎺ュ彛:" + message);
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
waitPakIn.setIo_status("X");
waitPakIn.setMemo(message);
waitPakInService.upWaitPakIn(waitPakIn);
@@ -300,6 +341,14 @@
if(sessionCookie==null || sessionCookie.length()<1)
{
logger.error("璋冪敤涓嬫灦瀹屾垚鎺ュ彛锛実et璇锋眰鑾峰彇cookie澶辫触");
+ // SAP INFO-----璋冪敤涓婃灦瀹屾垚鎺ュ彛锛屾棩蹇楄褰�
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest("鑾峰彇cookie鍊煎け璐�,cookie锛�" + sessionCookie);
+ logInfo.setResponse("璋冪敤鍑哄簱瀹屾垚鎺ュ彛锛実et璇锋眰鑾峰彇cookie澶辫触");
+ logInfo.setCreate_time(new Date());
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
return result;
}
String[] sessionId = sessionCookie.split(";");
@@ -310,6 +359,14 @@
// token = map.get("x-csrf-token").toString();
} catch (Exception e1) {
logger.error("璋冪敤涓嬫灦瀹屾垚鎺ュ彛锛実et璇锋眰鑾峰彇cookie澶辫触" + e1.getMessage());
+ // SAP INFO-----璋冪敤涓婃灦瀹屾垚鎺ュ彛锛屾棩蹇楄褰�
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest("鑾峰彇cookie澶辫触");
+ logInfo.setResponse("璋冪敤鍑哄簱瀹屾垚鎺ュ彛锛実et璇锋眰鑾峰彇cookie澶辫触");
+ logInfo.setCreate_time(new Date());
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
// e1.printStackTrace();
}finally{
if(connection1!=null){
@@ -411,11 +468,29 @@
}catch(Exception em) {
}
if(zstatus.equals("s") || message.contains("宸茬粡瀹屽叏鎻愪緵") || message.contains("宸茬‘璁�")) {
+ // SAP INFO-----璋冪敤涓嬫灦瀹屾垚鎺ュ彛锛屾棩蹇楄褰�
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest(jsObj.toString());
+ logInfo.setResponse(sb.toString());
+ logInfo.setCreate_time(new Date());
+ logInfo.setType(1);
+ logInfo.setRemark("鍑哄簱瀹屾垚鎺ュ彛:" + message);
+ sapRequestLogService.addSapLog(logInfo);
// if(zstatus.equals("s")) {//涓婃姤SAP鎴愬姛,杞巻鍙叉。
waitPakOut.setIo_status("Y");
waitPakOutService.upWaitPakOut(waitPakOut,0);
waitPakOutService.moveToLog(waitPakOut);
}else if(zstatus.equals("e")) {//涓婃姤SAP澶辫触,鏇存柊io_status=X
+ // SAP INFO-----璋冪敤涓嬫灦瀹屾垚鎺ュ彛锛屾棩蹇楄褰�
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest(jsObj.toString());
+ logInfo.setResponse(sb.toString());
+ logInfo.setCreate_time(new Date());
+ logInfo.setType(2);
+ logInfo.setRemark("鍑哄簱瀹屾垚鎺ュ彛:" + message);
+ sapRequestLogService.addSapLog(logInfo);
waitPakOut.setIo_status("X");
waitPakOut.setMemo(message);
waitPakOutService.upWaitPakOut(waitPakOut,0);
@@ -491,6 +566,14 @@
if(sessionCookie==null || sessionCookie.length()<1)
{
logger.error("璋冪敤鎵撳嵃鎺ュ彛锛実et璇锋眰鑾峰彇cookie澶辫触");
+ // 璋冪敤sap鎵撳嵃鎺ュ彛,璁板綍鏃ュ織
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest("璋冪敤鎵撳嵃鎺ュ彛锛実et璇锋眰鑾峰彇cookie澶辫触");
+ logInfo.setResponse(sessionCookie);
+ logInfo.setCreate_time(new Date());
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
return result;
}
String[] sessionId = sessionCookie.split(";");
@@ -500,6 +583,14 @@
// token = map.get("x-csrf-token").toString();
} catch (Exception e1) {
logger.error("sendPrinCommand1-----璋冪敤鎵撳嵃鎺ュ彛璇锋眰cookie澶辫触" + waitPakOut.getMaktx() + e1.getMessage());
+ // 璋冪敤sap鎵撳嵃鎺ュ彛,璁板綍鏃ュ織
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest("sendPrinCommand1-----璋冪敤鎵撳嵃鎺ュ彛璇锋眰cookie澶辫触" + waitPakOut.getMaktx());
+ logInfo.setResponse(e1.getMessage());
+ logInfo.setCreate_time(new Date());
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
e1.printStackTrace();
}finally{
if(connection1!=null){
@@ -600,11 +691,29 @@
waitPakOutService.upWaitPakOut(waitPakOut,0);
logger.error("sendPrinCommand5---璋冪敤鎵撳嵃鎺ュ彛鎴愬姛锛岃姹俲son鏁版嵁--" + jsObj.toString());
logger.info("sendPrinCommand5---璋冪敤鎵撳嵃鎺ュ彛鎴愬姛锛岃繑鍥瀓son鏁版嵁--" + sb.toString());
+ // 璋冪敤sap鎵撳嵃鎺ュ彛,璁板綍鏃ュ織
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest(jsObj.toString());
+ logInfo.setResponse(sb.toString());
+ logInfo.setCreate_time(new Date());
+ logInfo.setRemark(message);
+ logInfo.setType(1);
+ sapRequestLogService.addSapLog(logInfo);
}else if(zstatus.equals("e")) {//涓婃姤SAP澶辫触,鏇存柊io_status=X
waitPakOut.setPrnstatus(3); //鎵撳嵃澶辫触
waitPakOut.setMemo(message);
waitPakOutService.upWaitPakOut(waitPakOut,0);
logger.error("sendPrinCommand6---璋冪敤鎵撳嵃鎺ュ彛澶辫触锛岃姹俲son鏁版嵁--" + message);
+ // 璋冪敤sap鎵撳嵃鎺ュ彛,璁板綍鏃ュ織
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest(jsObj.toString());
+ logInfo.setResponse(sb.toString());
+ logInfo.setCreate_time(new Date());
+ logInfo.setRemark(message);
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
}
}
}
@@ -614,6 +723,15 @@
waitPakOut.setMemo(e.getMessage());
waitPakOutService.upWaitPakOut(waitPakOut,0);
logger.error("sendPrinCommand7---璋冪敤鎵撳嵃鎺ュ彛鍥炴姤寮傚父--"+waitPakOut.getMatnr() + "---" + e.getMessage());
+ // 璋冪敤sap鎵撳嵃鎺ュ彛,璁板綍鏃ュ織
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest(jsObj.toString());
+ logInfo.setResponse("sendPrinCommand7---璋冪敤鎵撳嵃鎺ュ彛鍥炴姤寮傚父--"+waitPakOut.getMatnr() + "---");
+ logInfo.setCreate_time(new Date());
+ logInfo.setRemark(e.getMessage());
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
// System.out.println(e.getMessage());
}finally{
if(connection!=null){
@@ -625,6 +743,15 @@
waitPakOut.setMemo(e.getMessage());
waitPakOutService.upWaitPakOut(waitPakOut,0);
logger.error("sendPrinCommand8---璋冪敤鎵撳嵃鎺ュ彛鍥炴姤寮傚父--"+waitPakOut.getMatnr() + "---" + e.getMessage());
+ // 璋冪敤sap鎵撳嵃鎺ュ彛,璁板綍鏃ュ織
+ SapRequestLogBean logInfo = new SapRequestLogBean();
+ logInfo.setMatnr(waitPakOut.getMatnr());
+ logInfo.setRequest("鎵撳嵃璇锋眰澶辫触");
+ logInfo.setResponse("sendPrinCommand8---璋冪敤鎵撳嵃鎺ュ彛鍥炴姤寮傚父--"+waitPakOut.getMatnr() + "---");
+ logInfo.setCreate_time(new Date());
+ logInfo.setRemark(e.getMessage());
+ logInfo.setType(2);
+ sapRequestLogService.addSapLog(logInfo);
// System.out.println(e.getMessage());
}
return result;
--
Gitblit v1.9.1