Skip to content

Commit

Permalink
Add support to:
Browse files Browse the repository at this point in the history 
- Drill table
- Report View
  • Loading branch information
@yamelsenih
yamelsenih committed Nov 22, 2019
1 parent 21cc6d1 commit 3052125
Show file tree
Hide file tree
Showing 2 changed files with 217 additions and 3 deletions.
171 changes: 168 additions & 3 deletions src/main/java/org/spin/grpc/util/BusinessDataServiceImplementation.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,7 @@
import org.compiere.model.MTable;
import org.compiere.model.MUser;
import org.compiere.model.MWindow;
import org.compiere.model.M_Element;
import org.compiere.model.PO;
import org.compiere.model.POInfo;
import org.compiere.model.Query;
Expand Down Expand Up @@ -601,6 +602,46 @@ public void listPrintFormats(ListPrintFormatsRequest request, StreamObserver<Lis
}
}

@Override
public void listReportViews(ListReportViewsRequest request, StreamObserver<ListReportViewsResponse> responseObserver) {
try {
if(request == null) {
throw new AdempiereException("Object Request Null");
}
Properties context = getContext(request.getClientRequest());
ListReportViewsResponse.Builder reportViewsList = convertReportViewsList(context, request);
responseObserver.onNext(reportViewsList.build());
responseObserver.onCompleted();
} catch (Exception e) {
log.severe(e.getLocalizedMessage());
responseObserver.onError(Status.INTERNAL
.withDescription(e.getMessage())
.augmentDescription(e.getMessage())
.withCause(e)
.asRuntimeException());
}
}

@Override
public void listDrillTables(ListDrillTablesRequest request, StreamObserver<ListDrillTablesResponse> responseObserver) {
try {
if(request == null) {
throw new AdempiereException("Object Request Null");
}
Properties context = getContext(request.getClientRequest());
ListDrillTablesResponse.Builder drillTablesList = convertDrillTablesList(context, request);
responseObserver.onNext(drillTablesList.build());
responseObserver.onCompleted();
} catch (Exception e) {
log.severe(e.getLocalizedMessage());
responseObserver.onError(Status.INTERNAL
.withDescription(e.getMessage())
.augmentDescription(e.getMessage())
.withCause(e)
.asRuntimeException());
}
}

/**
* Get private access from table, record id and user id
* @param context
Expand Down Expand Up @@ -752,7 +793,125 @@ private ListPendingDocumentsResponse.Builder convertPendingDocumentList(Properti
}

/**
* Convert favorites to gRPC
* Convert Report View to gRPC
* @param context
* @param request
* @return
*/
private ListReportViewsResponse.Builder convertReportViewsList(Properties context, ListReportViewsRequest request) {
ListReportViewsResponse.Builder builder = ListReportViewsResponse.newBuilder();
// Get entity
if(Util.isEmpty(request.getTableName())
&& Util.isEmpty(request.getProcessUuid())) {
throw new AdempiereException("@TableName@ / @AD_Process_ID@ @NotFound@");
}
String whereClause = null;
List<Object> parameters = new ArrayList<>();
// For Table Name
if(!Util.isEmpty(request.getTableName())) {
MTable table = MTable.get(context, request.getTableName());
whereClause = "AD_Table_ID = ?";
parameters.add(table);
} else if(!Util.isEmpty(request.getProcessUuid())) {
whereClause = "EXISTS(SELECT 1 FROM AD_Process p WHERE p.UUID = ? AND p.AD_ReportView_ID = AD_ReportView.AD_ReportView_ID)";
parameters.add(request.getProcessUuid());
}
// Get List
new Query(context, I_AD_ReportView.Table_Name, whereClause, null)
.setParameters(parameters)
.<MReportView>list().forEach(reportViewReference -> {
ReportView.Builder reportViewBuilder = ReportView.newBuilder();
String name = reportViewReference.getName();
String description = reportViewReference.getDescription();
if(!Env.isBaseLanguage(context, "")) {
String translation = reportViewReference.get_Translation("Name");
if(!Util.isEmpty(translation)) {
name = translation;
}
translation = reportViewReference.get_Translation("Description");
if(!Util.isEmpty(translation)) {
description = translation;
}
}
reportViewBuilder.setUuid(validateNull(reportViewReference.getUUID()));
reportViewBuilder.setName(validateNull(name));
reportViewBuilder.setDescription(validateNull(description));
MTable table = MTable.get(context, reportViewReference.getAD_Table_ID());
reportViewBuilder.setTableName(validateNull(table.getTableName()));
// add
builder.addReportViews(reportViewBuilder);
});
// Return
return builder;
}

/**
* Convert Report View to gRPC
* @param context
* @param request
* @return
*/
private ListDrillTablesResponse.Builder convertDrillTablesList(Properties context, ListDrillTablesRequest request) {
ListDrillTablesResponse.Builder builder = ListDrillTablesResponse.newBuilder();
// Get entity
if(Util.isEmpty(request.getTableName())) {
throw new AdempiereException("@TableName@ @NotFound@");
}
MTable table = MTable.get(context, request.getTableName());
String sql = "SELECT t.TableName, e.ColumnName, NULLIF(e.PO_PrintName,e.PrintName) "
+ "FROM AD_Column c "
+ " INNER JOIN AD_Column used ON (c.ColumnName=used.ColumnName)"
+ " INNER JOIN AD_Table t ON (used.AD_Table_ID=t.AD_Table_ID AND t.IsView='N' AND t.AD_Table_ID <> c.AD_Table_ID)"
+ " INNER JOIN AD_Column cKey ON (t.AD_Table_ID=cKey.AD_Table_ID AND cKey.IsKey='Y')"
+ " INNER JOIN AD_Element e ON (cKey.ColumnName=e.ColumnName) "
+ "WHERE c.AD_Table_ID=? AND c.IsKey='Y' "
+ "ORDER BY 3";
PreparedStatement pstmt = null;
ResultSet resultSet = null;
try {
pstmt = DB.prepareStatement(sql, null);
pstmt.setInt(1, table.getAD_Table_ID());
resultSet = pstmt.executeQuery();
while (resultSet.next()) {
String drillTableName = resultSet.getString("TableName");
String columnName = resultSet.getString("ColumnName");
M_Element element = M_Element.get(context, columnName);
// Add here
DrillTable.Builder drillTable = DrillTable.newBuilder();
drillTable.setTableName(validateNull(drillTableName));
String name = element.getPrintName();
String poName = element.getPO_PrintName();
if(!Env.isBaseLanguage(context, "")) {
String translation = element.get_Translation("PrintName");
if(!Util.isEmpty(translation)) {
name = translation;
}
translation = element.get_Translation("PO_PrintName");
if(!Util.isEmpty(translation)) {
poName = translation;
}
}
if(!Util.isEmpty(poName)) {
name = name + "/" + poName;
}
// Print Name
drillTable.setPrintName(validateNull(name));
// Add to list
builder.addDrillTables(drillTable);
}
resultSet.close();
pstmt.close();
} catch (SQLException e) {
log.log(Level.SEVERE, sql, e);
} finally {
DB.close(resultSet, pstmt);
}
// Return
return builder;
}

/**
* Convert print formats to gRPC
* @param context
* @param request
* @return
Expand Down Expand Up @@ -838,8 +997,14 @@ private ListFavoritesResponse.Builder convertFavoritesList(Properties context, L
menuName = menu.getName();
menuDescription = menu.getDescription();
if(!Env.isBaseLanguage(context, "")) {
menuName = menu.get_Translation("Name");
menuDescription = menu.get_Translation("Description");
String translation = menu.get_Translation("Name");
if(!Util.isEmpty(translation)) {
menuName = translation;
}
translation = menu.get_Translation("Description");
if(!Util.isEmpty(translation)) {
menuDescription = translation;
}
}
}
// Set name and description
Expand Down
49 changes: 49 additions & 0 deletions src/main/proto/businessdata.proto
View file
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,10 @@ service BusinessDataService {
rpc ListPendingDocuments(ListPendingDocumentsRequest) returns (ListPendingDocumentsResponse) {}
// Request Print Format List
rpc ListPrintFormats(ListPrintFormatsRequest) returns (ListPrintFormatsResponse) {}
// Request Report View List
rpc ListReportViews(ListReportViewsRequest) returns (ListReportViewsResponse) {}
// Request Drill Tables List
rpc ListDrillTables(ListDrillTablesRequest) returns (ListDrillTablesResponse) {}
}

// The client request contains client info for request.
Expand Down Expand Up @@ -476,6 +480,51 @@ message ListPrintFormatsResponse {
string next_page_token = 3;
}

// Report Views Request
message ListReportViewsRequest {
ClientRequest clientRequest = 1;
string tableName = 2;
string processUuid = 3;
int32 page_size = 4;
string page_token = 5;
}

// Report View
message ReportView {
string uuid = 1;
string name = 2;
string description = 3;
string tableName = 4;
}

// Report View List
message ListReportViewsResponse {
int64 recordCount = 1;
repeated ReportView reportViews = 2;
string next_page_token = 3;
}

// Drill table Request
message ListDrillTablesRequest {
ClientRequest clientRequest = 1;
string tableName = 2;
int32 page_size = 3;
string page_token = 4;
}

// Drill Table
message DrillTable {
string tableName = 1;
string printName = 2;
}

// Drill Tables List
message ListDrillTablesResponse {
int64 recordCount = 1;
repeated DrillTable drillTables = 2;
string next_page_token = 3;
}

// BusinessProcess Response List
message ListActivitiesResponse {
int64 recordCount = 1;
Expand Down

0 comments on commit 3052125

Please sign in to comment.