This commit is contained in:
+25
-5
@@ -2,9 +2,13 @@ package com.eactive.eai.rms.onl.manage.rule.layoutsync;
|
||||
|
||||
import java.util.HashMap;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import com.eactive.eai.common.util.UUIDGenerator;
|
||||
|
||||
import lombok.RequiredArgsConstructor;
|
||||
|
||||
@Service
|
||||
@@ -13,6 +17,10 @@ import lombok.RequiredArgsConstructor;
|
||||
class KJBInterfaceService {
|
||||
|
||||
private final KJBInterfaceDao dao;
|
||||
|
||||
@Autowired
|
||||
@Qualifier("layoutSyncService")
|
||||
private LayoutSyncService service;
|
||||
|
||||
public void lazyInsertToIF01(HashMap<String, Object> param) throws Exception {
|
||||
HashMap detail = dao.selectDetail(param);
|
||||
@@ -21,13 +29,25 @@ class KJBInterfaceService {
|
||||
}
|
||||
}
|
||||
|
||||
public void insertInterface(HashMap<String, Object> param) throws Exception {
|
||||
HashMap detail = dao.selectDetailAPI(param);
|
||||
public void insertInterface(HashMap<String, Object> info) throws Exception {
|
||||
HashMap detail = dao.selectDetailAPI(info);
|
||||
if (detail == null) {
|
||||
dao.insertToHE01(param);
|
||||
dao.insertToHE01(info);
|
||||
|
||||
dao.deleteToHE02(param);
|
||||
dao.insertToHE02(param);
|
||||
dao.deleteToHE02(info);
|
||||
dao.insertToHE02(info);
|
||||
|
||||
HashMap<String, String> logParam = new HashMap<String,String>();
|
||||
logParam.put("logPrcssSeqno", UUIDGenerator.getUUID());
|
||||
logParam.put("serviceName", (String)info.get("serviceName"));
|
||||
logParam.put("command", "interface");
|
||||
logParam.put("loutName", (String)info.get("EAISVCNAME"));
|
||||
logParam.put("recvData", (String)info.get("recvData"));
|
||||
logParam.put("recvAmndHMS", (String)info.get("recvAmndHMS"));
|
||||
logParam.put("prcssRslt", "S");
|
||||
logParam.put("prcssRsltCmnt", "");
|
||||
|
||||
service.addLayoutSyncLog(logParam);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
+13
-17
@@ -1234,10 +1234,10 @@ public class LayoutSyncController extends OnlBaseAnnotationController implements
|
||||
boolean isDevMake = this.isDevMake(interfaceId);
|
||||
|
||||
if (command.equals("insert")) {
|
||||
insertInterfaceDjb(interfaceId, body);
|
||||
insertInterfaceDjb(interfaceId, body, param);
|
||||
if (isDevMake) {
|
||||
interfaceId = interfaceId.substring(0,8) + "D" + interfaceId.substring(8);
|
||||
insertInterfaceDjb(interfaceId, body);
|
||||
insertInterfaceDjb(interfaceId, body, param);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1281,26 +1281,22 @@ public class LayoutSyncController extends OnlBaseAnnotationController implements
|
||||
String devInterfaceId = interfaceId.substring(0,8) + "D" + interfaceId.substring(8);
|
||||
return interfaceService.existsInterface(devInterfaceId);
|
||||
}
|
||||
|
||||
private boolean isDevMake(JSONObject layout) throws Exception {
|
||||
String loutName = (String) layout.get("id");
|
||||
String[] parts = loutName.split("_");
|
||||
String interfaceId = parts[1];
|
||||
return isDevMake(interfaceId);
|
||||
}
|
||||
|
||||
private void insertInterfaceDjb(String interfaceId, JSONObject body) throws Exception
|
||||
private void insertInterfaceDjb(String interfaceId, JSONObject body, HashMap<String, String> param) 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);
|
||||
HashMap<String, Object> info = new HashMap<String, Object>();
|
||||
info.put("EAISVCNAME", interfaceId);
|
||||
info.put("EAIBZWKDSTCD", bizCode);
|
||||
info.put("EAISVCDESC", interfaceDesc);
|
||||
|
||||
info.put("serviceName", param.get("serviceName"));
|
||||
info.put("recvData", body.toJSONString());
|
||||
info.put("recvAmndHMS", param.get("recvAmndHMS"));
|
||||
|
||||
interfaceService.insertInterface(info);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user