treshenkov/indic-search-service
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: treshenkov:v1
Branches Tags
treshenkov:dev
treshenkov:v4-async
treshenkov:v4
treshenkov:v3
treshenkov:v2
treshenkov:v1
..
compare: treshenkov:dev
Branches Tags
treshenkov:v4-async
treshenkov:v4
treshenkov:v3
treshenkov:v2
treshenkov:v1
treshenkov:dev

No commits in common. "v1" and "dev" have entirely different histories.
v1 ... dev

6 changed files with 0 additions and 209 deletions
Show stats Expand all files Collapse all files

26
src/main/java/ru/nbch/indicsearchservice/service/IndicSearchService.java
View file

@ -1,40 +1,14 @@
package ru.nbch.indicsearchservice.service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import ru.nbch.indicsearchservice.dto.request.AddSearchJobRequestDto;
import ru.nbch.indicsearchservice.dto.response.AddSearchJobResponseDto;
import ru.nbch.indicsearchservice.dto.response.JobStatusResponseDto;
import ru.nbch.indicsearchservice.service.tableloader.AbstractTableLoader;
import ru.nbch.indicsearchservice.service.tableloader.TableLoaderName;
import ru.nbch.indicsearchservice.util.TableData;
@Service
public class IndicSearchService {
private final List<AbstractTableLoader> tableLoaders;
public IndicSearchService(List<AbstractTableLoader> tableLoaders) {
this.tableLoaders = tableLoaders;
}
public AddSearchJobResponseDto addSearchJob(AddSearchJobRequestDto request) {
List<TableLoaderName> foundTableLoaderNames = TableLoaderName
.getTableLoaderNamesByDataTypeAndSearchParameter(request.getDataType(), request.getSearchParameter());
List<AbstractTableLoader> suitableTableLoaders = tableLoaders.stream()
.filter(tl -> foundTableLoaderNames.contains(tl.getTableLoaderName()) || foundTableLoaderNames.contains(tl.getChildLoaders()))
.toList();
List<TableData> result = new ArrayList<>();
for (AbstractTableLoader tableLoader : suitableTableLoaders) {
TableData tableData = tableLoader.fetchData(Map.of());
tableLoader.fetchChildLoaders(tableData);
result.add(tableData);
}
return null;
}

17
src/main/java/ru/nbch/indicsearchservice/service/tableloader/AbstractTableLoader.java
View file

@ -1,17 +0,0 @@
package ru.nbch.indicsearchservice.service.tableloader;
import java.util.List;
import java.util.Map;
import ru.nbch.indicsearchservice.util.TableData;
public abstract class AbstractTableLoader {
public abstract TableLoaderName getTableLoaderName();
public abstract List<TableLoaderName> getChildLoaders();
public abstract TableData fetchData(Map<String, Object> inputData);
public abstract void fetchChildLoaders(TableData tableData);
public abstract Long countData(Map<String, Object> inputData);
}

27
src/main/java/ru/nbch/indicsearchservice/service/tableloader/RuTradeTableLoader.java
View file

@ -1,27 +0,0 @@
package ru.nbch.indicsearchservice.service.tableloader;
import java.util.List;
import java.util.Map;
import ru.nbch.indicsearchservice.util.TableData;
public class RuTradeTableLoader extends AbstractTableLoader {
@Override
public TableLoaderName getTableLoaderName() {
return TableLoaderName.RU_TRADE;
}
@Override
public List<TableLoaderName> getChildLoaders() {
return List.of();
}
@Override
public TableData fetchData(Map<String, Object> inputData) {
return null;
}
@Override
public Long countData(Map<String, Object> inputData) {
return 0L;
}
}

38
src/main/java/ru/nbch/indicsearchservice/service/tableloader/RuUidTableLoader.java
View file

@ -1,38 +0,0 @@
package ru.nbch.indicsearchservice.service.tableloader;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Component;
import ru.nbch.indicsearchservice.util.TableData;
@Component
public class RuUidTableLoader extends AbstractTableLoader {
@Override
public TableLoaderName getTableLoaderName() {
return TableLoaderName.RU_UID;
}
@Override
public List<TableLoaderName> getChildLoaders() {
return List.of(TableLoaderName.RU_TRADE);
}
@Override
public TableData fetchData(Map<String, Object> inputData) {
return null;
}
@Override
public void fetchChildLoaders(TableData tableData) {
Object val = tableData.getFieldData().stream().anyMatch(fieldDataDto -> fieldDataDto.key().equals("serialNumber"));
}
@Override
public Long countData(Map<String, Object> inputData) {
return 0L;
}
public void collector(List<Map<String, Object>> mapperQueryResult, Subject subject) {
subject.addResultByTable()
}
}

44
src/main/java/ru/nbch/indicsearchservice/service/tableloader/TableLoaderName.java
View file

@ -1,44 +0,0 @@
package ru.nbch.indicsearchservice.service.tableloader;
import java.util.ArrayList;
import java.util.List;
import ru.nbch.indicsearchservice.model.enums.DataType;
import ru.nbch.indicsearchservice.model.enums.SearchParameter;
public enum TableLoaderName {
RU_UID( // 1st level table
List.of(DataType.GUTDF, DataType.RUTDF, DataType.TUTDF),
List.of(SearchParameter.FID)
),
RU_TRADE(List.of(), List.of()), // 2nd level table
;
private final List<DataType> suitableForDataType;
private final List<SearchParameter> suitableForSearchParameter;
TableLoaderName(List<DataType> suitableForDataType, List<SearchParameter> suitableForSearchParameter) {
this.suitableForDataType = suitableForDataType;
this.suitableForSearchParameter = suitableForSearchParameter;
}
public List<DataType> getSuitableForDataType() {
return suitableForDataType;
}
public List<SearchParameter> getSuitableForSearchParameter() {
return suitableForSearchParameter;
}
public static List<TableLoaderName> getTableLoaderNamesByDataTypeAndSearchParameter(DataType dataType, SearchParameter searchParameter) {
List<TableLoaderName> result = new ArrayList<>();
for (TableLoaderName tableLoaderName : TableLoaderName.values()) {
if (tableLoaderName.getSuitableForDataType().contains(dataType) &&
tableLoaderName.getSuitableForSearchParameter().contains(searchParameter)) {
result.add(tableLoaderName);
}
}
return result;
}
}

57
src/main/java/ru/nbch/indicsearchservice/util/TableData.java
View file

@ -1,57 +0,0 @@
package ru.nbch.indicsearchservice.util;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
public class TableData {
private String tableName;
private List<FieldDataDto> fieldData = new ArrayList<>();
private List<TableData> relatedData = new ArrayList<>();
public TableData() {
}
public TableData(String tableName, List<FieldDataDto> fieldData, List<TableData> relatedData) {
this.tableName = tableName;
this.fieldData = fieldData;
this.relatedData = relatedData;
}
public String getTableName() {
return tableName;
}
public List<FieldDataDto> getFieldData() {
return fieldData;
}
public List<TableData> getRelatedData() {
return relatedData;
}
@Override
public boolean equals(Object o) {
if (o == null || getClass() != o.getClass()) return false;
TableData tableData = (TableData) o;
return Objects.equals(tableName, tableData.tableName) && Objects.equals(fieldData, tableData.fieldData) && Objects.equals(relatedData, tableData.relatedData);
}
@Override
public int hashCode() {
return Objects.hash(tableName, fieldData, relatedData);
}
@Override
public String toString() {
return "TableData{" +
"tableName='" + tableName + '\'' +
", fieldData=" + fieldData +
", relatedData=" + relatedData +
'}';
}
public record FieldDataDto(String key,
Object value) {
}
}