getTaskExecutor().execute(() -> {
// boolean value to control whether to mark the job is failed in the finally block
boolean exception = true;
try {
handleCopyAdjusments(spID, uC sPBID, tPBID, tPBName, selectedTab, jobId,
originalRequest.getContext());
<DataSource ID="PriceAdjustmentSQLNoSpring"
serverType="sql"
tableName="aa_bb"
dropExtraFields="false"
xmlns:fmt="WEB-INF/">
<fmt:bundle basename="com.aa.pp.client.DSMessages"/>
<serverObject lookupStyle="new" className="com.aa.pp.server.services.impl.PriceAdjustmentSQLDS"/>
<fields>
<field name="price_adjustment_id" type="sequence" primaryKey="true" hidden="true"/>
<field name="system" type="boolean" sqlStorageStrategy="integer" hidden="true"/>
<field name="company_id" type="text" length="36" hidden="true" foreignKey="CompanySQL.company_id" joinType="outer">
<title>
<fmt:message key="company"/>
</title>
</field>
<field name="vendor_id" type="integer" foreignKey="VVSQL.vendor_id" joinType="outer" required="true"/>
<field name="price_book_id" type="integer" foreignKey="PBSQL.price_book_id" joinType="outer" required="true"/>
<field name="project_id" type="integer" hidden="true" foreignKey="ProSQL.project_id" joinType="outer"/>
<field name="item_id" type="text" length="50" required="true"/>
<field name="description" type="text" length="100"/>
<field name="item_type" type="integer" foreignKey="CodeSQL.code_id" joinType="outer"/>
<field name="modifier_id" type="integer"/>
<field name="typeDescription" type="text" align="left" includeFrom="CodeSQL.description" canEdit="false">
<title>
<fmt:message key="productType"/>
</title>
</field>
<field name="adjustment1" type="float" precision="12" decimalPrecision="2" format="0.0#'%'" javaClass="BigDecimal">
<title>
<fmt:message key="adjust1"/>
</title>
<validators>
<validator type="required">
<applyWhen operator="and">
<criteria>
<criterion fieldName="adjustment2" operator="notBlank"/>
<criterion fieldName="callFrom" operator="equals" value="single"/>
</criteria>
</applyWhen>
</validator>
<validator type="floatRange" min="0" max="100"/>
</validators>
</field>
<field name="adjustment2" type="float" precision="12" decimalPrecision="2" format="0.0#'%'" javaClass="BigDecimal">
<title>
<fmt:message key="adjust2"/>
</title>
<validators>
<validator type="required">
<applyWhen operator="and">
<criteria>
<criterion fieldName="adjustment3" operator="notBlank"/>
<criterion fieldName="callFrom" operator="equals" value="single"/>
</criteria>
</applyWhen>
</validator>
<validator type="floatRange" min="0" max="100"/>
</validators>
</field>
<field name="adjustment3" type="float" precision="12" decimalPrecision="2" format="0.0#'%'" javaClass="BigDecimal">
<title>
<fmt:message key="adjust3"/>
</title>
<validators>
<validator type="floatRange" min="0" max="100"/>
</validators>
</field>
<field name="adjustment4" type="float" precision="12" decimalPrecision="2" javaClass="BigDecimal">
<validators>
<validator type="floatRange" min="0" max="360"/>
</validators>
</field>
<field name="special_net" type="boolean" sqlStorageStrategy="integer"/>
<field name="special_net_cost" type="localeCurrency" precision="12" decimalPrecision="2" javaClass="BigDecimal">
<validators>
<validator type="required">
<applyWhen fieldName="special_net" operator="equals" value="true"/>
</validator>
</validators>
</field>
<field name="labor" type="integer">
<title>
<fmt:message key="laborMinutes"/>
</title>
<validators>
<validator type="integerRange" min="0"/>
</validators>
</field>
<field name="installation" type="integer">
<title>
<fmt:message key="installMinutes"/>
</title>
<validators>
<validator type="integerRange" min="0"/>
</validators>
</field>
<field name="markup" type="float" precision="12" decimalPrecision="2" javaClass="BigDecimal"/>
<field name="created_by" type="creator" hidden="true">
<title>
<fmt:message key="createdBy"/>
</title>
</field>
<field name="created_time" type="creatorTimestamp" hidden="true">
<title>
<fmt:message key="createdTime"/>
</title>
</field>
<field name="modified_by" type="modifier" hidden="true">
<title>
<fmt:message key="modifiedBy"/>
</title>
</field>
<field name="modified_time" type="modifierTimestamp" hidden="true">
<title>
<fmt:message key="modifiedTime"/>
</title>
</field>
<field name="hdwAttrId" type="integer" customSQL="true"/>
<field name="hdwTypeId" type="text" customSQL="true">
<title>
<fmt:message key="intType"/>
</title>
</field>
</fields>
<operationBindings>
<operationBinding operationType="update" operationId="copyAdjustments" serverMethod="copyAdjustments"/>
</operationBindings>
</DataSource>
package com.aa.pp.server.services.impl;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import com.isomorphic.criteria.AdvancedCriteria;
import com.isomorphic.criteria.Criterion;
import com.isomorphic.criteria.criterion.IsNullCriterion;
import com.isomorphic.criteria.criterion.SetCriterion;
import com.isomorphic.criteria.criterion.SimpleCriterion;
import com.isomorphic.datasource.DSRequest;
import com.isomorphic.datasource.DSResponse;
import com.isomorphic.datasource.DSTransaction;
import com.isomorphic.servlet.RequestContext;
import com.isomorphic.sql.SQLDataSource;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class PriceAdjustmentSQLDS extends SQLDataSource {
/**
* Block add operation.
*
* @param dsRequest {@link DSRequest}
* @return {@link DSResponse}
*/
public DSResponse add(final DSRequest dsRequest) {
throw new UnsupportedOperationException();
}
/**
* Block Fetch operation in this call
*
* @param dsRequest {@link DSRequest}
* @return {@link DSResponse}
*/
public DSResponse fetch(final DSRequest dsRequest) {
throw new UnsupportedOperationException();
}
/**
* Block update operation.
*
* @param dsRequest {@link DSRequest}
* @return {@link DSResponse}
*/
public DSResponse update(final DSRequest dsRequest) {
throw new UnsupportedOperationException();
}
/**
* Block remove operation.
*
* @param dsRequest {@link DSRequest}
* @return {@link DSResponse}
*/
public DSResponse remove(final DSRequest dsRequest) {
throw new UnsupportedOperationException();
}
public DSResponse copyAdjustments(final DSRequest priceAdjustmentDSRequest) throws ApplicationException {
log.info("copyAdjustment - Start");
final DSResponse hdwStdAdjustmentData = new DSResponse();
final long sourcePriceBookID = (Long) DSUtil.getValue(DSConst.PriceAdjustmentSQL.SOURCE_PRICE_BOOK_ID, priceAdjustmentDSRequest.getOldValues(),
priceAdjustmentDSRequest.getValues());
final long targetPriceBookID = (Long) DSUtil.getValue(DSConst.PriceAdjustmentSQL.TARGET_PRICE_BOOK_ID, priceAdjustmentDSRequest.getOldValues(),
priceAdjustmentDSRequest.getValues());
final Long selectedProjectId = (Long) DSUtil.getValue(DSConst.PriceAdjustmentSQL.PROJECT_ID, priceAdjustmentDSRequest.getOldValues(),
priceAdjustmentDSRequest.getValues());
final String sourcePriceBookName = (String) DSUtil.getValue(DSConst.PriceAdjustmentSQL.SOURCE_PRICE_BOOK_NAME, priceAdjustmentDSRequest.getOldValues(),
priceAdjustmentDSRequest.getValues());
final String targetPriceBookName = (String) DSUtil.getValue(DSConst.PriceAdjustmentSQL.TARGET_PRICE_BOOK_NAME, priceAdjustmentDSRequest.getOldValues(),
priceAdjustmentDSRequest.getValues());
final String selectedTab = (String) DSUtil.getValue(DSConst.PriceAdjustmentSQL.SELECTED_TAB, priceAdjustmentDSRequest.getOldValues(),
priceAdjustmentDSRequest.getValues());
final String userCompany = getCompanyId();
log.debug(
"The Source price book id is {} with name {}. The target price book id is {} with name {}. "
+ "The project is {} and selected tab is {} , for the company {}",
sourcePriceBookID, sourcePriceBookName, targetPriceBookID, targetPriceBookName, selectedProjectId, selectedTab, userCompany);
final long jobId = getJobSql().add("CopyAdjustments", BatchJobStatusConstants.IN_PROGRESS);
// Process the copy adjustment logic in another thread
getTaskExecutor().execute(() -> {
// boolean value to control whether to mark the job is failed in the finally block
boolean exception = true;
try {
handleCopyAdjusments(selectedProjectId, userCompany, sourcePriceBookID, targetPriceBookID, targetPriceBookName, selectedTab, jobId,
priceAdjustmentDSRequest.getContext());
exception = false;
} catch (final ApplicationException e) {
// Handle exceptions, send back the exception as the job note
exception = false;
log.error("Error copying adjustments", e);
getJobSql().update(jobId, BatchJobStatusConstants.ERROR, e.getMessage());
} finally {
// Mark the job as error if something else went wrong
if (exception) {
getJobSql().update(jobId, BatchJobStatusConstants.ERROR);
}
}
});
// Handle all the three lists with PriceAdjustment data in a single transaction
hdwStdAdjustmentData.setData(jobId);
return hdwStdAdjustmentData;
}
private void handleCopyAdjusments(final Long selectedProjectId, final String userCompany, final long sourcePriceBookId, final long targetPriceBookId,
final String targetPriceBookName, final String selectedTab, final long jobId, final RequestContext context) throws ApplicationException {
log.info("handleCopyAdjusments - START");
String message = Constants.SUCCESS_WITH_OUT_DELETE;
final List<Map<String, Object>> toBeAddedList = new ArrayList<>();
final List<Map<String, Object>> toBeUpdatedList = new ArrayList<>();
final List<Map<String, Object>> toBeDeletedList = new ArrayList<>();
final DSTransaction dsTransaction = new DSTransaction();
try {
// Remember that the price books will have same vendor material and hence the adjustments Item Types will always be same for both target and source
// price books.
// Step 1: Get discounts if present for the source & target price book id and project ID (if null then only company)
final Map<Long, List<Map<String, Object>>> sourcePerItemTypeMap = fetchData(selectedProjectId, userCompany,
dsTransaction, sourcePriceBookId);
final Map<Long, List<Map<String, Object>>> targetPerItemTypeMap = fetchData(selectedProjectId, userCompany,
dsTransaction, targetPriceBookId);
// Step 3: If source and target does not have discount entries for any level, just return a message can not be copied
// Step 5: If the source does not have price adjustment entries and the target has, then remove the target entries completely. By the virtue of
// Database cascading, the values from price_adjustment_attribute tables will also be deleted for target price books.
// Step 6:If both the source price book and target price book has price_adjustment entries, then classify the entries based on item_type.
// Step 6.a: For Item Type Hdw_price_book, just check of the source and target has entries, update, if only soyrce then add else remove.
// Step 6.b: For material_price_book same as above. FOr price_adjustment_attributes fetch entries and handle similarly as above.
// Step 6.c: For hdw_tpe entries just check by the item_id and same as 6.a
// Step 6.d: for hdw_line entries just check by item_id and same as 6.a
// Stem 6.e: for hdw_std entries, check if the ones from source are present for target (based on hdwXREFId). If presentthen update the entry
// else , add the entry. For all the unmatched entries in target, delete them
// based on the key of source map, pass the list of values from source and target maps to specific handlers.
/// Specific handlers will determine the list of records to be updated, added and deleted. The specific handlers will convert the list to map
// corresponding to enitityId->Record.
// the all the keys from source will be looked into target price book.
// We will call handlers for all the ItemType Enum entries and will then decide upon the entries to be handled
if (Constants.HARDWARE.equals(selectedTab)) {
// Hardware specific handling
// Call the hardware price book handler
handlePriceBookPriceAdjustmentsEntries(sourcePerItemTypeMap.get(ItemTypeEnum.PRICE_BOOK_ADJ.getTitanCodeId()),
targetPerItemTypeMap.get(ItemTypeEnum.PRICE_BOOK_ADJ.getTitanCodeId()), toBeAddedList, toBeUpdatedList, toBeDeletedList,
sourcePriceBookId, targetPriceBookId, targetPriceBookName);
handleHdwTypePriceAdjustmentsEntries(sourcePerItemTypeMap.get(ItemTypeEnum.HDW_TYPE_ADJ.getTitanCodeId()),
targetPerItemTypeMap.get(ItemTypeEnum.HDW_TYPE_ADJ.getTitanCodeId()), toBeAddedList, toBeUpdatedList, toBeDeletedList,
sourcePriceBookId, targetPriceBookId, dsTransaction);
handleHdwLinePriceAdjustmentsEntries(sourcePerItemTypeMap.get(ItemTypeEnum.HDW_LINE_ADJ.getTitanCodeId()),
targetPerItemTypeMap.get(ItemTypeEnum.HDW_LINE_ADJ.getTitanCodeId()), toBeAddedList, toBeUpdatedList, toBeDeletedList,
sourcePriceBookId, targetPriceBookId, dsTransaction);
handleHdwStdPriceAdjustmentsEntries(sourcePerItemTypeMap.get(ItemTypeEnum.HDW_STD_ADJ.getTitanCodeId()),
targetPerItemTypeMap.get(ItemTypeEnum.HDW_STD_ADJ.getTitanCodeId()), toBeAddedList, toBeUpdatedList, toBeDeletedList, sourcePriceBookId,
targetPriceBookId, dsTransaction);
handleHdwModifierPriceAdjustmentsEntries(sourcePerItemTypeMap.get(ItemTypeEnum.HARDWARE_MODIFIERS.getTitanCodeId()),
targetPerItemTypeMap.get(ItemTypeEnum.HARDWARE_MODIFIERS.getTitanCodeId()), toBeAddedList, toBeUpdatedList, toBeDeletedList,
sourcePriceBookId, targetPriceBookId, dsTransaction);
} else if (Constants.MATERIAL.equals(selectedTab)) {
// Material specific handling
handlePriceBookPriceAdjustmentsEntries(sourcePerItemTypeMap.get(ItemTypeEnum.MATERIAL_PRICE_BOOK_ADJ.getTitanCodeId()),
targetPerItemTypeMap.get(ItemTypeEnum.MATERIAL_PRICE_BOOK_ADJ.getTitanCodeId()), toBeAddedList, toBeUpdatedList, toBeDeletedList,
sourcePriceBookId, targetPriceBookId, targetPriceBookName);
handleMaterialAttributePriceAdjustmentsEntries(sourcePerItemTypeMap.get(ItemTypeEnum.MATERIAL_ATTR_ADJ.getTitanCodeId()),
targetPerItemTypeMap.get(ItemTypeEnum.MATERIAL_ATTR_ADJ.getTitanCodeId()), toBeAddedList, toBeUpdatedList, toBeDeletedList,
sourcePriceBookId, targetPriceBookId, dsTransaction);
}
if (CollectionUtils.isNotEmpty(toBeAddedList)) {
for (final Map<String, Object> rec : toBeAddedList) {
final DSRequest addRequest = new DSRequest(DSConst.PriceAdjustmentSQL.DATASOURCE, DSOperationType.UPDATE.getValue());
addRequest.setDsTransaction(dsTransaction);
addRequest.setOperationId(DSConst.PriceAdjustmentSQL.ADD_ADJUSTMENT_OPERATION);
addRequest.setValues(rec);
addRequest.setContext(context);
addRequest.execute();
}
}
if (CollectionUtils.isNotEmpty(toBeUpdatedList)) {
for (final Map<String, Object> rec : toBeUpdatedList) {
final DSRequest updateRequest = new DSRequest(DSConst.PriceAdjustmentSQL.DATASOURCE, DSOperationType.UPDATE.getValue());
updateRequest.setDsTransaction(dsTransaction);
updateRequest.setValues(rec);
updateRequest.setCriteria(DSConst.PriceAdjustmentSQL.PRICE_ADJUSTMENT_ID, rec.get(DSConst.PriceAdjustmentSQL.PRICE_ADJUSTMENT_ID));
updateRequest.setContext(context);
updateRequest.execute();
}
}
if (CollectionUtils.isNotEmpty(toBeDeletedList)) {
final Set<Long> priceadustmemtIdsTobeDeleted = toBeDeletedList.stream()
.map(rec -> (Long) rec.get(DSConst.PriceAdjustmentSQL.PRICE_ADJUSTMENT_ID)).collect(Collectors.toSet());
final DSRequest deleteRequest = new DSRequest(DSConst.PriceAdjustmentSQL.DATASOURCE, DSOperationType.REMOVE.getValue());
deleteRequest.setDsTransaction(dsTransaction);
// TODO deleteRequest.setAllowMultiUpdate(true);
deleteRequest.addToCriteria(DSConst.PriceAdjustmentSQL.PRICE_ADJUSTMENT_ID, OperatorId.IN_SET.getValue(), priceadustmemtIdsTobeDeleted);
deleteRequest.setContext(context);
deleteRequest.execute();
message = Constants.SUCCESS_WITH_DELETE;
}
getJobSql().update(jobId, BatchJobStatusConstants.COMPLETED, message);
} catch (final Exception ex) {
throw new ApplicationException("Error while Copying discounts", ex, SmartGWTStatusCode.STATUS_FAILURE);
} finally {
// We put this in a "finally" block to ensure it always runs even on exceptions.
dsTransaction.complete();
}
log.info("handleCopyAdjusments - END");
}
/**
* Returns the {@link JobSQLService} bean from the Spring context.
*
* @return {@link JobSQLService}
*/
private JobSQLService getJobSql() {
return ApplicationContextProvider.getApplicationContext().getBean(JobSQLService.class);
}
/**
* Returns the CompanyId from {@link UserAccountService} bean.
*
* @return companyId of currently logged in user
*/
private String getCompanyId() {
return ApplicationContextProvider.getApplicationContext().getBean(UserAccountService.class).getCurrentLoggedInUserDetails().getCompany();
}
/**
* Returns the {@link ThreadPoolTaskExecutor} bean from the Spring context.
*
* @return {@link ThreadPoolTaskExecutor}
*/
private ThreadPoolTaskExecutor getTaskExecutor() {
return ApplicationContextProvider.getApplicationContext().getBean("psTaskExecutor", ThreadPoolTaskExecutor.class);
}
}
public DSResponse copyAdjustments(final DSRequest priceAdjustmentDSRequest, final RPCManager rpcManager) throws ApplicationException {
log.info("copyAdjustment - Start");
final long jobId = jobSQLService.add("CopyAdjustments", BatchJobStatusConstants.IN_PROGRESS);
// Process the copy adjustment logic in another thread
taskExecutor.execute(() -> {
// boolean value to control whether to mark the job is failed in the finally block
boolean exception = true;
try {
handleCopyAdjusments(priceAdjustmentDSRequest.getContext());
exception = false;
} catch (final ApplicationException e) {
// Handle exceptions, send back the exception as the job note
exception = false;
log.error("Error copying adjustments", e);
jobSQLService.update(jobId, BatchJobStatusConstants.ERROR, e.getMessage());
} finally {
// Mark the job as error if something else went wrong
if (exception) {
jobSQLService.update(jobId, BatchJobStatusConstants.ERROR);
}
}
});
// Handle all the three lists with PriceAdjustment data in a single transaction
hdwStdAdjustmentData.setData(jobId);
return hdwStdAdjustmentData;
}
handleCopyAdjustment(RequestContext context){
DsTransaction dsTransaction = new DSTransaction();
List<Object> tobeAddedList = methodFetch1(dsTransaction);
if (CollectionUtils.isNotEmpty(toBeAddedList)) {
for (final Map<String, Object> rec : toBeAddedList) {
final DSRequest addRequest = new DSRequest(DSConst.PriceAdjustmentSQL.DATASOURCE, DSOperationType.UPDATE.getValue());
addRequest.setDsTransaction(dsTransaction);
addRequest.setOperationId(DSConst.PriceAdjustmentSQL.ADD_ADJUSTMENT_OPERATION);
addRequest.setValues(rec);
addRequest.setContext(context);
addRequest.execute();
}
}
}
// schematic nestedRequest.setContext(primaryRequest.getContext()); // in your code addRequest.setContext(priceAdjustmentDSRequest.getContext());
Leave a comment: