package org.jleaf.erp.sls.services.deliveryorder.triggers;

import java.util.ArrayList;

import org.jleaf.erp.master.MasterConstants;
import org.jleaf.erp.sls.SalesConstants;
import org.jleaf.erp.sls.services.SalesServiceAppContext;
import org.jleaf.core.BusinessTransaction;
import org.jleaf.core.Dto;
import org.jleaf.serviceflow.util.MessageForwardingUtil;
import org.jleaf.util.DateUtil;
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;

import id.co.sts.webpos_intgr.publishers.CustomPublisher;


/**
 * @author fredie, 02 June 2013
 */
@Component
public class ApprovedDeliveryOrderPostEventFired implements TriggerCall {
	private final static Logger log = LoggerFactory.getLogger(ApprovedDeliveryOrderPostEventFired.class);

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

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

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

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

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

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

		Dto paramDto = 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 + "doId", param.getLong("doId"));
			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, paramDto);
		}

		paramDto.put("doId", param.getLong("doId"));
		paramDto.put("userId", param.getLong("userId"));
		paramDto.put("datetime", param.getString("datetime"));

		log.info("paramDto: " + paramDto.toString());

		Dto paramQueueDto = new Dto();

		paramQueueDto.put("processName", processName);
		paramQueueDto.put("processNo", processNo);
		paramQueueDto.put("tenantId", tenantId);
		paramQueueDto.put("parameterDto", paramDto);
		paramQueueDto.put("parameterList", new ArrayList<Dto>());
		paramQueueDto.put("lineQueue", SalesConstants.SALES_LINE_QUEUE);
		paramQueueDto.put("propertiesPath", SalesConstants.SERVER_CONFIG_PATH);
		paramQueueDto.put("userLoginId", userId);

		log.info("paramQueueDto: " + paramQueueDto.toString());

		log.info("Start sendProcessToQueue: " + DateUtil.dateTimeNow());

		log.info("CALL CustomPublisher() ");
		CustomPublisher ctx = SalesServiceAppContext.getInstance().getContext().getBean(CustomPublisher.class);

		ctx.publish();
		log.info("END CustomPublisher() ");

		sendProcessToQueue.execute(paramQueueDto);

		log.info("End sendProcessToQueue: " + DateUtil.dateTimeNow());

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

}