RelatedRelationShipServiceImpl.java
3.36 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
package com.lhcredit.project.business.relatedRelation.service;
import com.alibaba.fastjson2.JSONObject;
import com.lhcredit.common.utils.http.DBHttpTemplate;
import com.lhcredit.project.business.TianYC.entity.param.RequestParams;
import com.lhcredit.project.business.searchLog.domain.SearchLog;
import com.lhcredit.project.business.searchLog.service.SearchLogServiceImpl;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
@Service
public class RelatedRelationShipServiceImpl implements RelatedRelationShipService {
private static Logger logger = LoggerFactory.getLogger(RelatedRelationShipServiceImpl.class);
@Autowired
private SearchLogServiceImpl searchLogService;
@Value("${NX.user}")
private String user;
@Value("${NX.url}")
private String dbUrl;
@Autowired
private DBHttpTemplate dbTemplate;
/**
* 根据 企业名称 查询两个企业之间关联关系
* @param requestParams
* @return
*/
@Override
public JSONObject getEnterpriseRelationShipsByName(RequestParams requestParams ){
//拼接url设置参数
String name = requestParams.getName();
String id = requestParams.getId();
//保存 查询日志 到日志表
SearchLog searchLog = new SearchLog();
JSONObject object = new JSONObject();
object.put("ename",requestParams.getName());
object.put("id",requestParams.getId());
searchLog.setSearchParams(object.toJSONString());
searchLog.setCreateBy(requestParams.getHumanName());
//类型设设置
searchLog.setType(SearchLog.SearchType.RELATED_RELATIONSHIP_SEARCH.getKey());
searchLogService.insertSearchLog(searchLog);
StringBuilder builder = new StringBuilder(dbUrl);
builder.append("/lhdb/relation/xygj?");
builder.append("keyword=");
builder.append(name);
builder.append("&attIds=");
builder.append(id);
builder.append("&level=3");
JSONObject result = JSONObject.from(dbTemplate.getResult(builder.toString()));
logger.info("关联关系接口返回： " + result.toJSONString());
if (result != null && result.getString("code").equals("2000")){
return result;
}
return null;
}
/**
*
* 根据企业名称，查询 企业关联关系的链路列表
* @param requestParams
* @return
*/
@Override
public JSONObject getRelationShipLinkListByName(RequestParams requestParams) {
//拼接url设置参数
String name = requestParams.getName();
String id = requestParams.getId();
StringBuilder builder = new StringBuilder(dbUrl);
builder.append("/lhdb/relationship/nx?");
builder.append("keyword=");
builder.append(name);
builder.append("&attIds=");
builder.append(id);
builder.append("&level=3");
JSONObject result = JSONObject.from(dbTemplate.getResult(builder.toString()));
logger.info("关联关系链路列表接口返回： " + result.toJSONString());
if (result != null && result.getString("code").equals("2000")){
return result;
}
return null;
}
}