yangshj
/
zhongwei
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

优化智能诊断列表页查询速度

zhongwei
ty 2 years ago
parent
2753a76c04
commit
2ff1e14ce5
1 changed files with 64 additions and 56 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 120
      hzims-service/equipment/src/main/java/com/hnac/hzims/fdp/service/impl/FdpListTableDataServiceImpl.java

120
hzims-service/equipment/src/main/java/com/hnac/hzims/fdp/service/impl/FdpListTableDataServiceImpl.java
Unescape View File

@ -38,61 +38,69 @@ import java.util.Map;
@RequiredArgsConstructor
@Slf4j
public class FdpListTableDataServiceImpl implements IFdpListTableDataService {
@Resource
private IStationClient stationClient;
@Value("${url.getNeoFaultPropertyList}")
private String getNeoFaultPropertyList;
@Value("${url.getNeoFaultTableData}")
private String getNeoFaultTableData;
@Override
public R getProperty(String property) {
Map<String,Object> params = new HashMap<>();
params.put("property",property);
String result = HttpRequestUtil.postCall(params,getNeoFaultPropertyList,"POST");
if ("STATION".equals(property)){
List<StationEntity> list=new ArrayList<>();
R<List<String>> res = JSONObject.parseObject(result, new TypeReference<R<List<String>>>() {
});
if (res.isSuccess()&& CollectionUtil.isNotEmpty(res.getData())){
for (String s : res.getData()) {
R<StationEntity> stationEntityR = stationClient.getStationByCode(s);
if (stationEntityR.isSuccess()&&ObjectUtil.isNotEmpty(stationEntityR.getData())){
StationEntity station = stationEntityR.getData();
list.add(station);
}
}
}
return R.data(list);
}
R<List<String>> res = JSONObject.parseObject(result, new TypeReference<R<List<String>>>() {
});
return res;
}
@Resource
private IStationClient stationClient;
@Value("${url.getNeoFaultPropertyList}")
private String getNeoFaultPropertyList;
@Value("${url.getNeoFaultTableData}")
private String getNeoFaultTableData;
@Override
public R getListByProperty(FDPFaultListInfoDTO req) {
IPage<FdpFaultTableListEntity> page = new Page<>();
req.setPageIndex(req.getPageIndex()-1);
page.setSize(req.getPageSize());
page.setCurrent(req.getPageIndex()+1);
req.setDisplay(1);
req.setIsRoot(0);
req.setOrderBy("NAME");
req.setOrderKind("desc");
String result = HttpRequestUtil.postCallObjectParam(req, getNeoFaultTableData, "POST");
if (StringUtil.isNotBlank(result)) {
R<FdpFaultTableDataVo> fdpFaultHistoryDataVoR = JSONObject.parseObject(result, new TypeReference<R<FdpFaultTableDataVo>>() {
});
if (!fdpFaultHistoryDataVoR.isSuccess()){
throw new WebServiceException("请求失败，请紧急联系管理员！！！");
}
if (fdpFaultHistoryDataVoR.isSuccess()&&ObjectUtil.isNotEmpty(fdpFaultHistoryDataVoR.getData())
&&ObjectUtil.isNotEmpty(fdpFaultHistoryDataVoR.getData().getList())){
List<FdpFaultTableListEntity> list = fdpFaultHistoryDataVoR.getData().getList();
page.setTotal(fdpFaultHistoryDataVoR.getData().getTotalCount());
page.setRecords(list);
}
}
return R.data(page);
}
@Override
public R getProperty(String property) {
Map<String, Object> params = new HashMap<>();
params.put("property", property);
Long startMillis=System.currentTimeMillis();
String result = HttpRequestUtil.postCall(params, getNeoFaultPropertyList, "POST");
log.info("fdp查询列表项"+property+"耗时："+(System.currentTimeMillis()-startMillis)+"ms");
Long endMillis=System.currentTimeMillis();
if ("STATION".equals(property)) {
List<StationEntity> list = new ArrayList<>();
R<List<String>> res = JSONObject.parseObject(result, new TypeReference<R<List<String>>>() {
});
if (res.isSuccess() && CollectionUtil.isNotEmpty(res.getData())) {
R<List<StationEntity>> listAll = stationClient.getListAll();
if (listAll.isSuccess() && ObjectUtil.isNotEmpty(listAll.getData())) {
for (String s : res.getData()) {
for (StationEntity station : listAll.getData()) {
if (station.getCode().equals(s)) {
list.add(station);
}
}
}
}
}
log.info("fdp查询站点列表项：耗时："+(System.currentTimeMillis()-endMillis)+"ms");
return R.data(list);
}
R<List<String>> res = JSONObject.parseObject(result, new TypeReference<R<List<String>>>() {
});
return res;
}
@Override
public R getListByProperty(FDPFaultListInfoDTO req) {
IPage<FdpFaultTableListEntity> page = new Page<>();
req.setPageIndex(req.getPageIndex() - 1);
page.setSize(req.getPageSize());
page.setCurrent(req.getPageIndex() + 1);
req.setDisplay(1);
req.setIsRoot(0);
req.setOrderBy("NAME");
req.setOrderKind("desc");
String result = HttpRequestUtil.postCallObjectParam(req, getNeoFaultTableData, "POST");
if (StringUtil.isNotBlank(result)) {
R<FdpFaultTableDataVo> fdpFaultHistoryDataVoR = JSONObject.parseObject(result, new TypeReference<R<FdpFaultTableDataVo>>() {
});
if (!fdpFaultHistoryDataVoR.isSuccess()) {
throw new WebServiceException("请求失败，请紧急联系管理员！！！");
}
if (fdpFaultHistoryDataVoR.isSuccess() && ObjectUtil.isNotEmpty(fdpFaultHistoryDataVoR.getData())
&& ObjectUtil.isNotEmpty(fdpFaultHistoryDataVoR.getData().getList())) {
List<FdpFaultTableListEntity> list = fdpFaultHistoryDataVoR.getData().getList();
page.setTotal(fdpFaultHistoryDataVoR.getData().getTotalCount());
page.setRecords(list);
}
}
return R.data(page);
}
}

Write Preview
Loading…
Cancel
Save