From 5846a7ad9fec004afccd48b65e0e5e9193b35c24 Mon Sep 17 00:00:00 2001 From: Jeong-Yoon Date: Mon, 13 Sep 2021 10:34:38 +0900 Subject: [PATCH] [#210] type : feature body : [fix #210] Agent CDC Monitoring add kafka restart process --- .../com/k4m/dx/tcontrol/server/DxT044.java | 36 +++++++++++++++---- .../listener/DXTcontrolSocketExecute.java | 1 - 2 files changed, 29 insertions(+), 8 deletions(-) diff --git a/eXperDB-Management-Agent/src/main/java/com/k4m/dx/tcontrol/server/DxT044.java b/eXperDB-Management-Agent/src/main/java/com/k4m/dx/tcontrol/server/DxT044.java index a68e20b85..092b3e980 100644 --- a/eXperDB-Management-Agent/src/main/java/com/k4m/dx/tcontrol/server/DxT044.java +++ b/eXperDB-Management-Agent/src/main/java/com/k4m/dx/tcontrol/server/DxT044.java @@ -9,6 +9,7 @@ import org.slf4j.LoggerFactory; import org.springframework.context.ApplicationContext; +import com.k4m.dx.tcontrol.db.repository.vo.TransVO; import com.k4m.dx.tcontrol.socket.ProtocolID; import com.k4m.dx.tcontrol.socket.SocketCtl; import com.k4m.dx.tcontrol.socket.TranCodeType; @@ -25,9 +26,9 @@ * * 수정일 수정자 수정내용 * ------- -------- --------------------------- - * 2021.08.31 최초 생성 + * 2021.09.06 최초 생성 * - */ + */ public class DxT044 extends SocketCtl { private Logger errLogger = LoggerFactory.getLogger("errorToFile"); @@ -49,14 +50,22 @@ public void execute(String strDxExCode, JSONObject jObj) throws Exception { String strErrCode = ""; String strErrMsg = ""; String strSuccessCode = "0"; - + socketLogger.info("[123456789132136547654] " + jObj.toJSONString()); +// String strExeStatusIng = "" + // 정보 넣어주고 insert 하는거 하기! + +// TransVO transVO = new TransVO(); +// transVO.setKc_id((int) jObj.get("kc_id")); + + JSONObject outputObj = new JSONObject(); try { - String strCmd = "docker restart `docker ps -a --format \"table {{.Names}}\" | grep kafka`"; + String strCmd = "docker restart `docker ps -a --format \"table {{.Names}}\" | grep connect`"; +// String strCmd = "docker ps -a --format \"table {{.Names}}\" | grep kafka"; RunCommandExec r = new RunCommandExec(strCmd); - r.run(); + r.start(); try { r.join(); @@ -64,11 +73,23 @@ public void execute(String strDxExCode, JSONObject jObj) throws Exception { ie.printStackTrace(); } + String retVal = r.call(); + String strResultMessge = r.getMessage(); + + socketLogger.info("[RESULT] " + retVal); + socketLogger.info("[MSG] " + strResultMessge); + + socketLogger.info("##### 결과 : " + retVal + " message : " +strResultMessge); +// jObj.put("",); + if(retVal.equals("success")){ + + } + outputObj.put(ProtocolID.DX_EX_CODE, strDxExCode); outputObj.put(ProtocolID.RESULT_CODE, strSuccessCode); outputObj.put(ProtocolID.ERR_CODE, strErrCode); outputObj.put(ProtocolID.ERR_MSG, strErrMsg); -// outputObj.put(ProtocolID.RESULT_DATA, strResultMessge); + outputObj.put(ProtocolID.RESULT_DATA, retVal); sendBuff = outputObj.toString().getBytes(); send(4, sendBuff); @@ -79,7 +100,8 @@ public void execute(String strDxExCode, JSONObject jObj) throws Exception { outputObj.put(ProtocolID.RESULT_CODE, "1"); outputObj.put(ProtocolID.ERR_CODE, TranCodeType.DxT044); outputObj.put(ProtocolID.ERR_MSG, "DxT044 Error [" + e.toString() + "]"); - + outputObj.put(ProtocolID.RESULT_DATA, "fail"); + sendBuff = outputObj.toString().getBytes(); send(4, sendBuff); } finally { diff --git a/eXperDB-Management-Agent/src/main/java/com/k4m/dx/tcontrol/socket/listener/DXTcontrolSocketExecute.java b/eXperDB-Management-Agent/src/main/java/com/k4m/dx/tcontrol/socket/listener/DXTcontrolSocketExecute.java index 24ca44e40..e15aa867f 100644 --- a/eXperDB-Management-Agent/src/main/java/com/k4m/dx/tcontrol/socket/listener/DXTcontrolSocketExecute.java +++ b/eXperDB-Management-Agent/src/main/java/com/k4m/dx/tcontrol/socket/listener/DXTcontrolSocketExecute.java @@ -422,7 +422,6 @@ public void run() { case TranCodeType.DxT044 : - DxT044 dxT044 = new DxT044(client, is, os); dxT044.execute(strDX_EX_CODE, jObj);