Trigger Goods Purchasing

/**
 *
 */
package org.jleaf.erp.purch.services.goodspurchasing.triggers;

import java.util.ArrayList;

import org.jleaf.core.BusinessTransaction;
import org.jleaf.core.Dto;
import org.jleaf.erp.master.MasterConstants;
import org.jleaf.erp.purch.PurchasingConstants;
import org.jleaf.serviceflow.util.MessageForwardingUtil;
import org.jleaf.workflow.core.engine.TriggerCall;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;

/**
 * @author Deo, 13 Juli 2020
 *
 */
@Component
public class ApprovedGoodsPurchasingPostEventFired implements TriggerCall {

    public static final Logger log = LoggerFactory.getLogger(ApprovedGoodsPurchasingPostEventFired.class);

//  @Autowired
//  @Qualifier("prepareProcessQueue")
//  BusinessTransaction prepareProcessQueue;

    @Autowired
    @Qualifier("sendProcessToQueue")
    private BusinessTransaction sendProcessToQueue;

    @Autowired
    @Qualifier("generateAutoNum")
    private BusinessTransaction generateAutoNum;

    @Override
    public void execute(Dto inputDto) throws Exception {
        log.info("[TRIGGER] ApprovedGoodsPurchasingPostEventFired.beginExecute");

        log.info("[TRIGGER] ApprovedGoodsPurchasingPostEventFired.beginExecute inputDto>>>"+inputDto);

        String processName = PurchasingConstants.FUNCTION_SUBMIT_GOODS_PURCHASING;
        Dto param = inputDto.getDto("param");

        log.info("PARAM: " + param.toString());

        String processNo = param.getLong("goodsPurchasingId").toString() + "_" + inputDto.getString("docNo");
        Long tenantId = inputDto.getLong("tenantId");
        Long userId = inputDto.getLong("userId");

        Dto paramSubmitGoodsPurchasingDto = new Dto();

//      // Adding completing message forwarding
//      if (MessageForwardingUtil.isForwardEnabled(param)) {
//          Dto inputDtoForGenerateAutoNum = new Dto();
//          inputDtoForGenerateAutoNum.put("tenantId", tenantId);
//          inputDtoForGenerateAutoNum.put("scheme", param.getString("autonumScheme"));
//          inputDtoForGenerateAutoNum.put("docDate", param.getString("autonumDocDate"));
//          inputDtoForGenerateAutoNum.put("docData", param.getString("autonumDocData"));
//          inputDtoForGenerateAutoNum.put("userId", param.getLong("userId"));
//          inputDtoForGenerateAutoNum.put("datetime", param.getString("datetime"));
//
//          Dto outputDtoForGenerateAutoNum = generateAutoNum.execute(inputDtoForGenerateAutoNum);
//
//          Dto paramForwardDto = new Dto();
//          paramForwardDto.put(MasterConstants.FORWARD_KEY_LINE_QUEUE, param.getString("forwardLineQueue"));
//          paramForwardDto.put(MasterConstants.FORWARD_KEY_PROCESS_NAME, param.getString("forwardProcessName"));
//          paramForwardDto.put(MasterConstants.FORWARD_KEY_SEPARATOR + "poId", param.getLong("poId"));
//          paramForwardDto.put(MasterConstants.FORWARD_KEY_SEPARATOR + "userId", param.getLong("userId"));
//          paramForwardDto.put(MasterConstants.FORWARD_KEY_SEPARATOR + "datetime", param.getString("datetime"));
//          paramForwardDto.put(MasterConstants.FORWARD_KEY_SEPARATOR + "autoNumId", outputDtoForGenerateAutoNum.getLong("autoNumId"));
//          paramForwardDto.put(MasterConstants.FORWARD_KEY_SEPARATOR + "jobOrderNo", outputDtoForGenerateAutoNum.getString("autoNumValue"));
//
//          MessageForwardingUtil.putForwardingData(paramForwardDto, paramSubmitGoodsPurchasingDto);
//      }

        log.debug("END IF: " + param.toString());
        log.info("END IF: " + param.toString());

        paramSubmitGoodsPurchasingDto.put("goodsPurchasingId", param.getLong("goodsPurchasingId"));
        paramSubmitGoodsPurchasingDto.put("userId", param.getLong("userId"));
        paramSubmitGoodsPurchasingDto.put("datetime", param.getString("datetime"));

        log.debug("paramSubmitGoodsPurchasingDto>>>" + paramSubmitGoodsPurchasingDto.toString());
        log.info("paramSubmitGoodsPurchasingDto>>>" + paramSubmitGoodsPurchasingDto.toString());

        Dto paramQueueDto = new Dto();

        paramQueueDto.put("processName", processName);
        paramQueueDto.put("processNo", processNo);
        paramQueueDto.put("tenantId", tenantId);
        paramQueueDto.put("parameterDto", paramSubmitGoodsPurchasingDto);
        paramQueueDto.put("parameterList", new ArrayList<Dto>());
        paramQueueDto.put("lineQueue", PurchasingConstants.PURCHASING_LINE_QUEUE);
        paramQueueDto.put("propertiesPath", PurchasingConstants.SERVER_CONFIG_PATH);
        paramQueueDto.put("userLoginId", userId);

        sendProcessToQueue.execute(paramQueueDto);

        log.debug("sendProcessToQueue>>>" + paramQueueDto.toString());
        log.info("sendProcessToQueue>>>" + paramQueueDto.toString());

        // log.debug("Sending data to Queue..");
        // QueueUtil.sendToQueue(processName, processNo, tenantId, PurchasingConstants.PURCHASING_LINE_QUEUE, PurchasingConstants.SERVER_CONFIG_PATH);

        log.info("[TRIGGER] ApprovedGoodsPurchasingPostEventFired.endExecute");
        log.debug("[TRIGGER] ApprovedGoodsPurchasingPostEventFired.endExecute");
    }

}