IIM연동시 개발 인터페이스를 추가로 만들어 준다

src/main/java/com/eactive/eai/rms/onl/manage/rule/layoutsync/KJBInterfaceDao.java

@@ -14,12 +14,29 @@ class KJBInterfaceDao extends SqlMapClientTemplateDao {
 
 	private static final Logger logger = LoggerFactory.getLogger(InterfaceDao.class);
 
-	public void lazyInsertToIF01(HashMap paramMap) throws Exception {
-		this.template.insert("Interface.insertToIF01", paramMap);
-	}
-
 	public HashMap selectDetail(HashMap paramMap) throws Exception {
 		return (HashMap) template.queryForObject("Interface.selectDetail", paramMap);
 	}
+	
+	public void lazyInsertToIF01(HashMap paramMap) throws Exception {
+		this.template.insert("Interface.insertToIF01", paramMap);
+	}
+	
+	public HashMap selectDetailAPI(HashMap paramMap) throws Exception {
+		return (HashMap) template.queryForObject("Interface.selectDetailAPI", paramMap);
+	}
+	
+	public void insertToHE01(HashMap paramMap) throws Exception {
+		this.template.insert("Interface.insertToHE01", paramMap);
+	}
 
+	public void insertToHE02(HashMap paramMap) throws Exception {
+		this.template.insert("Interface.insertToHE02", paramMap);
+	}
+	
+	public void deleteToHE02(HashMap paramMap) throws Exception {
+		this.template.insert("Interface.deleteToHE02", paramMap);
+	}
+	
+	
 }

src/main/java/com/eactive/eai/rms/onl/manage/rule/layoutsync/KJBInterfaceService.java

@@ -20,5 +20,15 @@ class KJBInterfaceService {
 			dao.lazyInsertToIF01(param);
 		}
 	}
+	
+	public void insertInterface(HashMap<String, Object> param) throws Exception {
+		HashMap detail = dao.selectDetailAPI(param);
+		if (detail == null) {
+			dao.insertToHE01(param);
+			
+			dao.deleteToHE02(param);
+			dao.insertToHE02(param);
+		}
+	}
 
 }

src/main/java/com/eactive/eai/rms/onl/manage/rule/layoutsync/LayoutSyncController.java

@@ -1223,22 +1223,64 @@ public class LayoutSyncController extends OnlBaseAnnotationController implements
 		
 		String serviceName = (String) header.get("ServiceName");
 		String command = (String) header.get("Command");
+		String interfaceId = (String) body.get("interfaceCode");
 		
 		Object layoutObject = body.get("Layout");
 		
 		param.put("serviceName", serviceName);
 		param.put("command", command);
 		param.put("recvAmndHMS", recvTime);
+		
+		//interfaceId 9번째 글자가 D가 아니면 interfaceId의 8번째 자리에 D를 추가하여 insert한다
+		boolean isDevMake = !"D".equals(interfaceId.substring(7,8));
+		
+		if (command.equals("insert")) {
+			insertInterfaceDjb(interfaceId, body);
+			if (isDevMake) {
+				interfaceId = interfaceId.substring(0,8) + "D" + interfaceId.substring(8);
+				insertInterfaceDjb(interfaceId, body);
+			}
+		}
 				
 		JSONArray layoutArray = null;
 		if (layoutObject instanceof JSONArray) {
 			layoutArray = (JSONArray) layoutObject;
 			for (int i = 0; i < layoutArray.size(); i++) {
-				syncLayout(param, body, command, (JSONObject) layoutArray.get(i));
+				JSONObject layout = (JSONObject) layoutArray.get(i);
+				syncLayout(param, body, command, layout);
+				
+				if (isDevMake) {
+					String layoutName = (String) layout.get("id");
+					layoutName = layoutName.substring(0,12) + "D" + layoutName.substring(12);
+					layout.put("id", layoutName);
+					syncLayout(param, body, command, layout);
+				}
 			}
 		} else {
-			syncLayout(param, body, command, (JSONObject) layoutObject);
+			JSONObject layout =  (JSONObject) layoutObject;
+			syncLayout(param, body, command, layout);
+
+			if (isDevMake) {
+				String layoutName = (String) layout.get("id");
+				layoutName = layoutName.substring(0,12) + "D" + layoutName.substring(12);
+				layout.put("id", layoutName);
+				syncLayout(param, body, command, layout);
+			}
 		}
     }
+    
+    private void insertInterfaceDjb(String interfaceId, JSONObject body) throws Exception
+	{
+		HashMap<String, Object> param = new HashMap<String, Object>();
+
+		String bizCode = (String) body.get("bzSystemCode");
+		String interfaceDesc = (String) body.get("interfaceDesc");
+		
+		param.put("EAISVCNAME", interfaceId); 
+		param.put("EAIBZWKDSTCD", bizCode);
+		param.put("EAISVCDESC", interfaceDesc);
+
+		interfaceService.insertInterface(param);
+	}
 
 }

src/main/resources/com/eactive/eai/rms/onl/transaction/Interface-oracle.xml

@@ -322,5 +322,38 @@
       VALUES
       (#eaiSvcName#, #eaiBzwkDstCd#, #interfaceId#, #interfaceDesc#, #io#, #splizdmndDstCd#, #inExtnlDstCd#, #svcMotivuseDstCd#, #bzwksvckeyName#, #layoutMappingName#, #loginId#, #loginId# ) 
   	</statement>
+  	
+  	
+  	
+  	
+  	<statement id="selectDetailAPI"  parameterClass="java.util.HashMap" resultClass="java.util.HashMap">
+	 	 SELECT EAISvcName 
+	 	      , EAIBzwkDstcd
+	 	   FROM $schemaId$.TSEAIHE01
+		 WHERE EAISvcName = #EAISVCNAME#  
+  </statement>
+  	
+  	<statement id="insertToHE01" parameterClass="java.util.HashMap">
+	  INSERT INTO  $schemaId$.TSEAIHE01 
+	  	(EAISVCNAME, EAIBZWKDSTCD, SVCHMSEONOT, SVCMOTIVUSEDSTCD, SVCPRCESDSTICNAME, FLOWCTRLROUTNAME, INTGRADSTICNAME, 
+	  	SVCBFCLMNLOGYN, GSTATSYSADPTRBZWKGROUPNAME, SEVRLOGLVELNO, SVCLOGLVELNO, EAISVCDESC, EAILASTAMNDYMS, TRANTYPE, USEYN, AUTHOR, AUTHTYPE, APIENABLEDYN) 
+	  	VALUES
+	  	(#EAISVCNAME#, #EAIBZWKDSTCD#, '0', 'SYNC', 'SINGLE', 'BASEFC', 'ONLINE', 
+	  	'0', #GSTATSYSADPTRBZWKGROUPNAME#, 0, 0, #EAISVCDESC#, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF3'), 'R', '1', 'IIM', 'none', 'N')
+  	</statement>
+  	
+  	<statement id="insertToHE02" parameterClass="java.util.HashMap">
+	  INSERT INTO  $schemaId$.TSEAIHE02
+	  (EAISVCNAME, SVCPRCSSNO, PSVINTFACDSTICNAME, PSVSYSBZWKDSTCD, PSVSYSIDNAME, PSVSYSADPTRBZWKGROUPNAME, FLOVRYN, CHNGEONOT, 
+	   BASCRSPNSCHNGEONOT, ERRRSPNSCHNGEONOT, NEXTSVCPRCSSNO, OUTBNDROUTNAME, TOUTVAL,  SUPPLDELYN, HDRCTRLDSTCD,  RESTOPTION) 
+ 		VALUES
+      (#EAISVCNAME#, 1, 'SYNC', #EAIBZWKDSTCD#, 'EAIDOM', #PSVSYSADPTRBZWKGROUPNAME#, 0, 0, 
+      0, 0, 1, #OUTBNDROUTNAME#, 30, '0', '01', #RESTOPTION#) 
+  	</statement>
+  	
+  	<statement id="deleteToHE02" parameterClass="java.util.HashMap">
+	  DELETE FROM  $schemaId$.TSEAIHE02
+	  WHERE EAISVCNAME = #EAISVCNAME# 
+  	</statement>
 </sqlMap>