Github user avikganguly01 commented on a diff in the pull request:
https://github.com/apache/fineract/pull/415#discussion_r143358749
--- Diff:
fineract-provider/src/main/java/org/apache/fineract/infrastructure/bulkimport/importhandler/center/CenterImportHandler.java
---
@@ -0,0 +1,288 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.infrastructure.bulkimport.importhandler.center;
+
+import com.google.common.reflect.TypeToken;
+import com.google.gson.GsonBuilder;
+import org.apache.fineract.commands.domain.CommandWrapper;
+import org.apache.fineract.commands.service.CommandWrapperBuilder;
+import
org.apache.fineract.commands.service.PortfolioCommandSourceWritePlatformService;
+import
org.apache.fineract.infrastructure.bulkimport.constants.CenterConstants;
+import
org.apache.fineract.infrastructure.bulkimport.constants.TemplatePopulateImportConstants;
+import org.apache.fineract.infrastructure.bulkimport.data.Count;
+import
org.apache.fineract.infrastructure.bulkimport.importhandler.ImportHandler;
+import
org.apache.fineract.infrastructure.bulkimport.importhandler.ImportHandlerUtils;
+import
org.apache.fineract.infrastructure.bulkimport.importhandler.helper.DateSerializer;
+import
org.apache.fineract.infrastructure.bulkimport.importhandler.helper.EnumOptionDataValueSerializer;
+import
org.apache.fineract.infrastructure.bulkimport.importhandler.helper.GroupIdSerializer;
+import
org.apache.fineract.infrastructure.core.data.CommandProcessingResult;
+import org.apache.fineract.infrastructure.core.data.EnumOptionData;
+import org.apache.fineract.infrastructure.core.exception.*;
+import org.apache.fineract.portfolio.calendar.data.CalendarData;
+import org.apache.fineract.portfolio.group.data.CenterData;
+import org.apache.fineract.portfolio.group.data.GroupGeneralData;
+import org.apache.poi.ss.usermodel.*;
+import org.joda.time.LocalDate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.lang.reflect.Type;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+@Service
+public class CenterImportHandler implements ImportHandler {
+
+
+ private List<CenterData> centers;
+ private List<CalendarData> meetings;
+ private List<String>statuses;
+ private Workbook workbook;
+
+ private final PortfolioCommandSourceWritePlatformService
commandsSourceWritePlatformService;
+
+ @Autowired
+ public CenterImportHandler(final
PortfolioCommandSourceWritePlatformService
+ commandsSourceWritePlatformService) {
+ this.commandsSourceWritePlatformService =
commandsSourceWritePlatformService;
+ }
+
+ @Override
+ public Count process(Workbook workbook, String locale, String
dateFormat) {
+ this.centers=new ArrayList<>();
+ this.meetings=new ArrayList<>();
+ this.statuses=new ArrayList<>();
+ this.workbook=workbook;
+ readExcelFile(locale, dateFormat);
+ return importEntity(dateFormat);
+ }
+
+ public void readExcelFile(final String locale, final String
dateFormat) {
+
+ Sheet centersSheet =
workbook.getSheet(TemplatePopulateImportConstants.CENTER_SHEET_NAME);
+ Integer noOfEntries =
ImportHandlerUtils.getNumberOfRows(centersSheet,
TemplatePopulateImportConstants.FIRST_COLUMN_INDEX);
+ for (int rowIndex = 1; rowIndex <=noOfEntries; rowIndex++) {
+ Row row;
+ row = centersSheet.getRow(rowIndex);
+ if(ImportHandlerUtils.isNotImported(row,
CenterConstants.STATUS_COL)) {
+ centers.add(readCenter(row,locale,dateFormat));
+ meetings.add(readMeeting(row,locale,dateFormat));
+ }
+ }
+ }
+
+ private CalendarData readMeeting(Row row,final String locale, final
String dateFormat) {
+ LocalDate meetingStartDate =
ImportHandlerUtils.readAsDate(CenterConstants.MEETING_START_DATE_COL, row);
+ Boolean isRepeating =
ImportHandlerUtils.readAsBoolean(CenterConstants.IS_REPEATING_COL, row);
+ String frequency =
ImportHandlerUtils.readAsString(CenterConstants.FREQUENCY_COL, row);
+ EnumOptionData frequencyEnum=new
EnumOptionData(null,null,ImportHandlerUtils.getFrequencyId(frequency));
+ Integer interval =
ImportHandlerUtils.readAsInt(CenterConstants.INTERVAL_COL, row);
+ String repeatsOnDay =
ImportHandlerUtils.readAsString(CenterConstants.REPEATS_ON_DAY_COL, row);
+ EnumOptionData repeatsOnDayEnum=new
EnumOptionData(null,null,ImportHandlerUtils.getRepeatsOnDayId(repeatsOnDay));
+ if(meetingStartDate==null)
+ return null;
+ else {
+ if(repeatsOnDay==null)
+ return
CalendarData.importInstanceNoRepeatsOnDay(meetingStartDate, isRepeating,
+ frequencyEnum, interval,
row.getRowNum(),locale,dateFormat);
+ else
+ return
CalendarData.importInstanceWithRepeatsOnDay(meetingStartDate, isRepeating,
+ frequencyEnum, interval, repeatsOnDayEnum,
row.getRowNum(),locale,dateFormat);
+ }
+ }
+
+ private CenterData readCenter(Row row,final String locale, final
String dateFormat) {
+ String status =
ImportHandlerUtils.readAsString(CenterConstants.STATUS_COL, row);
+ String officeName =
ImportHandlerUtils.readAsString(CenterConstants.OFFICE_NAME_COL, row);
+ Long officeId =
ImportHandlerUtils.getIdByName(workbook.getSheet(TemplatePopulateImportConstants.OFFICE_SHEET_NAME),
officeName);
+ String staffName =
ImportHandlerUtils.readAsString(CenterConstants.STAFF_NAME_COL, row);
+ Long staffId =
ImportHandlerUtils.getIdByName(workbook.getSheet(TemplatePopulateImportConstants.STAFF_SHEET_NAME),
staffName);
+
+ String externalId =
ImportHandlerUtils.readAsString(CenterConstants.EXTERNAL_ID_COL, row);
+ Boolean active =
ImportHandlerUtils.readAsBoolean(CenterConstants.ACTIVE_COL, row);
+ LocalDate
submittedOn=ImportHandlerUtils.readAsDate(CenterConstants.SUBMITTED_ON_DATE_COL,row);
+ LocalDate activationDate = null;
+ if (active){
+
activationDate=ImportHandlerUtils.readAsDate(CenterConstants.ACTIVATION_DATE_COL,
row);
+ }else {
+ activationDate=submittedOn;
+ }
+ String centerName =
ImportHandlerUtils.readAsString(CenterConstants.CENTER_NAME_COL, row);
+ if(centerName==null||centerName.equals("")) {
+ throw new IllegalArgumentException("Name is blank");
+ }
+ List<GroupGeneralData> groupMembers = new
ArrayList<GroupGeneralData>();
+ for (int cellNo =CenterConstants. GROUP_NAMES_STARTING_COL; cellNo
< CenterConstants.GROUP_NAMES_ENDING_COL; cellNo++) {
+ String groupName = ImportHandlerUtils.readAsString(cellNo,
row);
+ if (groupName==null||groupName.equals(""))
+ break;
+ Long groupId =
ImportHandlerUtils.getIdByName(workbook.getSheet(TemplatePopulateImportConstants.GROUP_SHEET_NAME),
groupName);
+ GroupGeneralData group = new GroupGeneralData(groupId);
+ if (!containsGroupId(groupMembers,groupId)) {
+ groupMembers.add(group);
+ }
+ }
+
+ statuses.add(status);
+ return
CenterData.importInstance(centerName,groupMembers,activationDate,
active,submittedOn, externalId,
+ officeId, staffId, row.getRowNum(),dateFormat,locale);
+ }
+
+ private boolean containsGroupId(List<GroupGeneralData>
groupMembers,Long groupId){
+ for (GroupGeneralData group: groupMembers) {
+ if (group.getId()==groupId){
+ return true;
+ }
+ }
+ return false;
+ }
+
+ public Count importEntity(String dateFormat) {
+ Sheet centerSheet =
workbook.getSheet(TemplatePopulateImportConstants.CENTER_SHEET_NAME);
+ int progressLevel = 0;
+ String centerId = "";
+ int successCount = 0;
+ int errorCount = 0;
+ String errorMessage = "";
+ for (int i = 0; i < centers.size(); i++) {
+ Row row = centerSheet.getRow(centers.get(i).getRowIndex());
+ Cell errorReportCell =
row.createCell(CenterConstants.FAILURE_COL);
+ Cell statusCell = row.createCell(CenterConstants.STATUS_COL);
+ CommandProcessingResult result = null;
+ try {
+ String status = statuses.get(i);
+ progressLevel = getProgressLevel(status);
+
+ if (progressLevel == 0) {
+ result = importCenter(i, dateFormat);
+ centerId = result.getGroupId().toString();
+ progressLevel = 1;
+ } else
+ centerId =
ImportHandlerUtils.readAsInt(CenterConstants.CENTER_ID_COL,
centerSheet.getRow(centers.get(i).getRowIndex())).toString();
+
+ if (meetings.get(i) != null)
+ progressLevel = importCenterMeeting(result, i,
dateFormat);
+ successCount++;
+
statusCell.setCellValue(TemplatePopulateImportConstants.STATUS_CELL_IMPORTED);
+
statusCell.setCellStyle(ImportHandlerUtils.getCellStyle(workbook,
IndexedColors.LIGHT_GREEN));
+ } catch (AbstractPlatformDomainRuleException e) {
+ errorCount++;
+ e.printStackTrace();
+ errorMessage = e.getDefaultUserMessage();
+
writeCenterErrorMessage(centerId,errorMessage,progressLevel,statusCell,errorReportCell,row);
--- End diff --
Move all the catch blocks to a functions in your Utils class and call it to
get the error message. Call this function from all your import handler classes.
---
