WorkOrderOrafinHystrixService.java

package com.eksad.masterdata.service;

import com.eksad.ddms.common.dto.CreationalSpecificationDTO;
import com.eksad.ddms.common.dto.OrafinMessageDTO;
import com.eksad.ddms.common.dto.ResponseOrafinDTO;
import com.eksad.ddms.common.h2.dto.apigateway.response.ResponseAPIPushAHMDTO;
import com.eksad.ddms.common.h2.uri.hotline.PartWOHotlineURI;
import com.eksad.ddms.common.h2.uri.integrasi.IntegrasiURI;
import com.eksad.ddms.common.h2.uri.orafin.workorder.WorkOrderOrafinURI;
import com.eksad.ddms.common.uri.DealerURI;
import com.eksad.ddms.common.uri.SalesOrderURI;
import com.eksad.ddms.common.util.DateUtil;
import com.eksad.ddms.common.util.StringUtil;
import com.eksad.ddms.common.util.response.ResponseDTO;
import com.eksad.ddms.common.util.status.DataStatus;
import com.eksad.ddms.common.util.uri.pickslip.PickSlipURI;
import com.eksad.ddms.masterdata.h2.common.util.NumberwordsUtil;
import com.eksad.masterdata.common.RequestUtil;
import com.eksad.masterdata.common.dto.*;
import com.eksad.masterdata.common.listEnum.*;
import com.eksad.masterdata.domain.CreationalSpecification;
import com.eksad.masterdata.domain.Payload;
import com.eksad.masterdata.domain.PaymentOrafin;
import com.eksad.masterdata.domain.Sequence;
import com.eksad.masterdata.domain.assembler.WorkOrderAssembler;
import com.eksad.masterdata.domain.workorder.WorkOrder;
import com.eksad.masterdata.domain.workorder.WorkOrderOrafin;
import com.eksad.masterdata.repository.PayloadRepository;
import com.eksad.masterdata.repository.PaymentOrafinRepository;
import com.eksad.masterdata.repository.SequenceRepository;
import com.eksad.masterdata.repository.WorkOrderRepository;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.PropertySource;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.HttpStatusCodeException;
import org.springframework.web.client.RestTemplate;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.stream.Collectors;

@Service
@PropertySource("classpath:error-message.properties")
public class WorkOrderOrafinHystrixService {

    @Autowired
    PullNJBNSCHystrixService pullNJBNSCHystrixService;

    @Value("${ddms.h2.service.slave}")
    private String DDMS_H2_SERVICE_SLAVE;

    @Value("${dam.receipt.query.h3}")
    private String receipt_query_url;

    @Value("${dam.receipt.command.h3}")
    private String receipt_command_url;

    @Value("${dam.masterdata.h1}")
    private String md_h1_url;

    @Value("${dam.masterdata.h2}")
    private String md_h2;

    @Autowired
    WorkOrderRepository workOrderRepository;

    @Autowired
    PaymentOrafinRepository paymentOrafinRepository;

    @Autowired
    SequenceRepository sequenceRepository;

    @Autowired
    WorkOrderHystrixService workOrderHystrixService;

    @Autowired
    PayloadRepository payloadRepository;

    RestTemplate restTemplate = new RestTemplate();

    @HystrixCommand(fallbackMethod = "defaultPostFallback")
    public ResponseEntity<Object> postWorkOrderOrafin(WorkOrderOrafinDTO dto) throws JsonProcessingException {
        Map<Integer, String> responseMap = null;
        try {
            WorkOrderOrafin orafin = getNjbNscPullByWoID(dto.getNoWorkOrder());
            if (orafin != null && orafin.getNoWorkOrder() != null) {
                String validateNotNull = validateNotNull(dto);
                if (StringUtil.hasValue(validateNotNull)) {
                    return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse(validateNotNull, Boolean.FALSE));
                }
                String validateNoNscNjb = validateNjbNscHeader(dto, orafin);
                if (StringUtil.hasValue(validateNoNscNjb)) {
                    return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse(validateNoNscNjb, Boolean.FALSE));
                }
                String prefix = orafin.getNoWorkOrder().substring(0, 2);
                if (prefix.equalsIgnoreCase("SO")) {
                    SalesOrderDTO so = findSalesOrderByID(orafin.getNoWorkOrder());
                    if (so == null) {
                        return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("No Salesorder tidak ditemukan.", Boolean.FALSE));
                    } else if (so.getSalesOrderLastKnownStatus().equals(SalesOrderStatus.COMPLETE) ||
                            so.getSalesOrderLastKnownStatus().equals(SalesOrderStatus.BO_COMPLETE)) {
                        return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("Gagal. Pembayaran Invoice sudah dilakukan sebelumnya.", Boolean.FALSE));
                    } else if (so.getSalesOrderLastKnownStatus().equals(SalesOrderStatus.CANCEL)) {
                        return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("Gagal. Salesorder telah dibatalkan.", Boolean.FALSE));
                    }
                    responseMap = updateTrx_Salesorder(orafin, so);
                } else if (prefix.equalsIgnoreCase("WO") || prefix.equalsIgnoreCase("JR") || orafin.getNoWorkOrder().substring(0, 3).equalsIgnoreCase("VST")) {
                    WorkOrder wo = workOrderRepository.findOneByWoID(orafin.getNoWorkOrder());
                    if (wo == null) {
                        return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("No Workorder tidak ditemukan.", Boolean.FALSE));
                    } else if (!wo.getWoLastKnownState().equals(WoState.PAYMENT)) {
                        if (wo.getWoLastKnownState().equals(WoState.COMPLETE)) {
                            return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("Gagal. Pembayaran Invoice sudah dilakukan sebelumnya.", Boolean.FALSE));
                        }
                        return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("Gagal. Workorder telah " + wo.getWoLastKnownState().toString() + ".", Boolean.FALSE));
                    }

                    /* Cek Sales order di WO */
                    if (StringUtil.hasValue(wo.getSoID())) {
                        DealerDTO dealer = findDealer(wo.getAhassID(), null);
                        if (!checkSOStatus(wo.getWoID(), dealer.getDealerCode())) {
                            return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("Salesorder belum Complete.", Boolean.FALSE));
                        }
                        List<SalesOrderDTO> listSO = findSalesOrderByWoID(wo.getWoID(), dealer.getDealerCode());
                        List<ReceiptSOTaskDTO> receiptSOFromWO = new ArrayList<>();

                        String statusSo = updateStatusSOFromWO(wo.getWoID(), dealer.getDealerCode());
                        if (statusSo.equalsIgnoreCase("ERROR")) {
                            return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("Terjadi kesalahan saat Complete Salesorder.", Boolean.FALSE));
                        }
                    }
                    responseMap = updateTrx_Wo(wo);
                }
            } else {
                // Validasi Complete
                if (pullNJBNSCHystrixService.checkIfTransactionsComplete(dto.getNoWorkOrder())) {
                    return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("Pembayaran Invoice sudah dilakukan sebelumnya.", Boolean.FALSE));
                }
                return ResponseEntity.status(HttpStatus.ACCEPTED).body(getPushNjbNscResponse("No Workorder tidak ditemukan.", Boolean.FALSE));
            }
            savePayload(dto);
            ResponseOrafinDTO msg = new ResponseOrafinDTO();
            msg.setData(null);
            Boolean successResponse = Boolean.FALSE;
            if (responseMap.containsKey(0)) {
                msg.setStatus(0);
                msg.setMessage(new OrafinMessageDTO(responseMap.get(0)));
            } else if (responseMap.containsKey(1)) {
                msg.setStatus(1);
                msg.setMessage(new OrafinMessageDTO(responseMap.get(1)));
                successResponse = Boolean.TRUE;
            }
            return ResponseEntity.status(successResponse ? HttpStatus.FOUND : HttpStatus.ACCEPTED).body(msg);
        } catch (Exception e) {
            e.printStackTrace();
            return ResponseEntity.status(HttpStatus.ACCEPTED).body(new ResponseAPIPushAHMDTO("0", "Gagal. Terjadi kesalahan " + e.getMessage()));
        }
    }

    private String validateNotNull(WorkOrderOrafinDTO dto) {
        String prefix = dto.getNoWorkOrder().substring(0, 2);
        if (!StringUtil.hasValue(dto.getDealerId())) {
            return "Dealer Id tidak boleh kosong.";
        }
        if ((prefix.equals("WO") || prefix.equals("JR") || prefix.equals("VST")) && !StringUtil.hasValue(dto.getNoNJB())) {
            return "No NJB tidak boleh kosong.";
        }
        if (prefix.equals("SO") && !StringUtil.hasValue(dto.getNoNSC())) {
            return "No NSC tidak boleh kosong.";
        }
        if (StringUtil.hasValue(dto.getNoNJB()) && dto.getTotalHargaNJB() == null) {
            return "Total harga NJB tidak boleh kosong.";
        }
        if (StringUtil.hasValue(dto.getNoNSC()) && dto.getTotalHargaNSC() == null) {
            return "Total harga NSC tidak boleh kosong.";
        }
        if (StringUtil.hasValue(dto.getNoNJB()) && !StringUtil.hasValue(dto.getTanggalNJB())) {
            return "Tanggal NJB tidak boleh kosong.";
        }
        if (StringUtil.hasValue(dto.getNoNSC()) && !StringUtil.hasValue(dto.getTanggalNSC())) {
            return "Tanggal NSC tidak boleh kosong.";
        }
        if (dto.getCreatedTime() == null) {
            return "Tanggal created time tidak boleh kosong.";
        }
        if (dto.getModifiedTime() == null) {
            return "Tanggal modified time tidak boleh kosong.";
        }
        return "";
    }

    private String validateNjbNscHeader(WorkOrderOrafinDTO dto, WorkOrderOrafin data) {
        // Validasi No NSC dan No NJB
        String dtoNsc = dto.getNoNSC() == null ? "" : dto.getNoNSC();
        String dtoNjb = dto.getNoNJB() == null ? "" : dto.getNoNJB();
        String dataNsc = data.getNoNSC() == null ? "" : data.getNoNSC();
        String dataNjb = data.getNoNJB() == null ? "" : data.getNoNJB();

        if (!Objects.equals(dtoNjb, dataNjb)) {
            return "Data NJB tidak ditemukan.";
        } else if (!Objects.equals(dtoNsc, dataNsc)) {
            return "Data NSC tidak ditemukan.";
        }

        // Validasi dealerid
        if (!dto.getDealerId().equals(data.getDealerId())) {
            return "DealerId tidak ditemukan.";
        }

        // Validasi Nominal NSC dan NJB
        Double dtoTotalNSC = dto.getTotalHargaNSC() == null ? 0d : dto.getTotalHargaNSC();
        Double dataTotalNSC = data.getTotalHargaNSC() == null ? 0d : data.getTotalHargaNSC();
        Double dtoTotalNJB = dto.getTotalHargaNJB() == null ? 0d : dto.getTotalHargaNJB();
        Double dataTotalNJB = data.getTotalHargaNJB() == null ? 0d : data.getTotalHargaNJB();

        if (!Objects.equals(dtoTotalNJB, dataTotalNJB)) {
            return "Total Harga NJB tidak valid.";
        } else if (!Objects.equals(dtoTotalNSC, dataTotalNSC)) {
            return "Total Harga NSC tidak valid.";
        }

        // Validasi Tanggal NJB dan NSC
        Date dtoTglNjb = null;
        Date dtoTglNsc = null;
        try {
            if (StringUtil.hasValue(dto.getTanggalNJB()))
                dtoTglNjb = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss").parse(dto.getTanggalNJB());
            if (StringUtil.hasValue(dto.getTanggalNSC()))
                dtoTglNsc = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss").parse(dto.getTanggalNSC());
        } catch (ParseException ex) {
            Logger.getLogger(WorkOrderOrafinHystrixService.class.getName()).log(Level.SEVERE, null, ex);
        }

        if (!Objects.equals(data.getTanggalNJB(), dtoTglNjb)) {
            return "Tanggal NJB tidak valid.";
        } else if (!Objects.equals(data.getTanggalNSC(), dtoTglNsc)) {
            return "Tanggal NSC tidak valid.";
        }

        // Validasi id SA dan Mekanik
        String dtoIdSA = dto.getHondaIdSA() == null ? "" : dto.getHondaIdSA();
        String dataIdSA = data.getHondaIdSA() == null ? "" : data.getHondaIdSA();
        String dtoIdMek = dto.getHondaIdMekanik() == null ? "" : dto.getHondaIdMekanik();
        String dataIdMek = data.getHondaIdMekanik() == null ? "" : data.getHondaIdMekanik();
        if (!Objects.equals(dtoIdSA, dataIdSA)) {
            return "Data Honda ID SA tidak valid.";
        } else if (!Objects.equals(dtoIdMek, dataIdMek)) {
            return "Data Honda ID Mekanik tidak valid.";
        }

        // Validasi data creational
        SimpleDateFormat sdf = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss");
        String dataCreated = sdf.format(data.getCreatedTime());
        String dataModified = sdf.format(data.getModifiedTime());
        String dtoCreated = sdf.format(dto.getCreatedTime());
        String dtoModified = sdf.format(dto.getModifiedTime());
        if (!Objects.equals(dataCreated, dtoCreated)) {
            return "Tanggal Created time tidak valid.";
        } else if (!Objects.equals(dataModified, dtoModified)) {
            return "Tanggal Modified time tidak valid.";
        }

        return "";
    }

    private WorkOrderOrafin getNjbNscPullByWoID(String woID) {
        try {
            WorkOrderOrafin data = null;
            PullNotaJBSCRequestDTO request = new PullNotaJBSCRequestDTO();
            request.setDealerId("");
            request.setFromTime(PullNJBNSCHystrixService.getCurrentDate());
            request.setToTime(PullNJBNSCHystrixService.getCurrentDate());
            request.setNoWorkOrder(woID);
            ResponseEntity<Object> resp = pullNJBNSCHystrixService.postRequestPullNJBNSCv2(request);
            ResponsePullNJBNSCGetListDTO resData = new ObjectMapper().convertValue(resp.getBody(), ResponsePullNJBNSCGetListDTO.class);
            if (resData.getStatus() == 1) {
                data = convertPullNjbNscToWorkOrderOrafin(resData.getData().get(0));
            }
            return data;
        } catch (Exception e) {
            return null;
        }
    }

    private WorkOrderOrafin convertPullNjbNscToWorkOrderOrafin(PullNotaJBSCResponseDTO dto) throws ParseException {
        WorkOrderOrafin data = new WorkOrderOrafin();
        SimpleDateFormat sdf = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss");
        data.setNoWorkOrder(dto.getWoid());
        data.setNoNJB(dto.getNoNJB());
        data.setNoNSC(dto.getNoNSC());
        data.setTotalHargaNJB(dto.getTotalharganjb().doubleValue());
        data.setTotalHargaNSC(dto.getTotalhargansc().doubleValue());
        data.setTanggalNJB(!StringUtil.hasValue(dto.getTanggalnjb()) ? null : sdf.parse(dto.getTanggalnjb()));
        data.setTanggalNSC(!StringUtil.hasValue(dto.getTanggalnsc()) ? null : sdf.parse(dto.getTanggalnsc()));
        data.setHondaIdSA(dto.getHondaidsa());
        data.setHondaIdMekanik(dto.getHondaidmekanik());
        data.setDealerId(dto.getDealerid());
        data.setCreatedTime(dto.getCreatedtime());
        data.setModifiedTime(dto.getModifiedtime());
        return data;
    }

    private ResponseOrafinDTO getPushNjbNscResponse(String message, Boolean success) {
        ResponseOrafinDTO res = new ResponseOrafinDTO();
        res.setMessage(new OrafinMessageDTO(message));
        res.setStatus(success ? 1 : 0);
        res.setData(null);
        return res;
    }

    private SalesOrderDTO findSalesOrderByID(String salesOrderID) {
        try {
            if (StringUtil.hasValue(salesOrderID)) {
                ResponseEntity<ResponseSalesOrderGetDTO> resp = restTemplate.exchange(
                        DDMS_H2_SERVICE_SLAVE +
                                SalesOrderURI.SALES_ORDER_GET_BY_ID.getUri(),
                        HttpMethod.GET,
                        RequestUtil.getPreFormattedRequestWithUserPassword(),
                        ResponseSalesOrderGetDTO.class, salesOrderID);
                if (resp.getBody().getData() != null) {
                    return resp.getBody().getData();
                }
            }
        } catch (Exception ex) {
            Logger.getLogger(WorkOrderOrafinHystrixService.class.getName()).log(Level.SEVERE, null, ex);
        }
        return null;
    }

    private Map<Integer, String> updateTrx_Salesorder(WorkOrderOrafin orafin, SalesOrderDTO so) {
        Map<Integer, String> response = new HashMap<>();
        ReceiptSOTunaiChangeCommandDTO receiptTunai = null;
        ReceiptSOTaskDTO receiptSO = null;
        ReceiptSOTunaiDTO currentReceipt = null;
        String msg = "Berhasil melakukan complete Salesorder.";
        if (so.getSalesOrderLastKnownStatus().equals(SalesOrderStatus.PICKED) && so.getSalesOrderType().equals(SalesOrderType.BO)) {
            receiptSO = getReceiptSoDP(orafin.getNoWorkOrder(), so.getAhassCode());
            if (receiptSO == null) {
                response.put(0, "Receipt tidak ditemukan.");
                return response;
            } else if (receiptSO.getReceiptType() == null) {
                response.put(0, "Receipt belum melakukan Down Payment (DP).");
                return response;
            } else if (receiptSO.getReceiptStatus().equals(ReceiptStatus.COMPLETE)) {
                response.put(0, "Gagal. Pelunasan Invoice sudah dilakukan sebelumnya.");
                return response;
            }
            currentReceipt = getSalesOrderByReceiptID(receiptSO.getReceiptid());
            if (currentReceipt.getReceiptID() == null) {
                response.put(0, "Data Receipt tidak ditemukan.");
                return response;
            }
            receiptTunai = initReceiptSOTunaiDP();
            receiptTunai.setUpdatedBy("PUSH_NJB_NSC");
            receiptTunai.setUpdatedDate(new Date());
            receiptTunai.setAhassCode(so.getAhassCode());
            receiptTunai.setReceiptStatus(ReceiptStatus.COMPLETE);
            receiptTunai.setReceiptAmount(currentReceipt.getReceiptAmount());
            receiptTunai.setReceiptID(currentReceipt.getReceiptID());
            receiptTunai.setReceiptPaidAmount(currentReceipt.getReceiptAmount());
            receiptTunai.setKembalian(0d);
            receiptTunai.setVersion(currentReceipt.getVersion());
            msg = "Berhasil melakukan complete Hotline order.";
        } else {
            receiptSO = getReceiptSo(orafin.getNoWorkOrder(), so.getAhassCode());
            currentReceipt = getSalesOrderByReceiptID(receiptSO.getReceiptid());
            PickSlipDTO ps = getPickslipBySoID(so.getSalesOrderID(), so.getAhassCode());
            Map<String, Double> priceMap = getPriceMap(so.getSalesOrderDetailDTOs(), ps.getPickSlipDetailDTOs());
            if (currentReceipt.getReceiptID() == null) {
                response.put(0, "Data Receipt tidak ditemukan.");
                return response;
            }
            receiptTunai = initReceiptSOTunai();
            receiptTunai.setUpdatedBy("PUSH_NJB_NSC");
            receiptTunai.setUpdatedDate(new Date());
            receiptTunai.setAhassCode(so.getAhassCode());
            receiptTunai.setReceiptStatus(ReceiptStatus.COMPLETE);
            receiptTunai.setReceiptAmount(currentReceipt.getReceiptAmount());
            receiptTunai.setReceiptID(currentReceipt.getReceiptID());
            receiptTunai.setKembalian(0d);
            receiptTunai.setVersion(currentReceipt.getVersion());
        }
        saveReceiptSOTunai(receiptTunai);

        String code = completeSO(so.getSalesOrderID(), so.getAhassCode());
//        if(code.equals("201")) {
        response.put(1, msg);         // Hard code karena balikan nya SOID
        return response;
    }

    private ReceiptSOTaskDTO getReceiptSoDP(String soid, String ahassCode) {
        if (StringUtil.hasValue(soid)) {
            ResponseEntity<ResponseReceiptSOTaskGetListDTO> response = restTemplate.exchange(
                    receipt_query_url +
                            "api/receipt/so/task/query/getbyahasscodeandsoid/{ahassCode}/{soID}",
                    HttpMethod.GET,
                    RequestUtil.getPreFormattedRequestWithUserPassword(),
                    ResponseReceiptSOTaskGetListDTO.class,
                    ahassCode, soid);
            if (response.getBody() != null) {
                ReceiptSOTaskDTO data = response.getBody().getDatas().stream().filter(p -> p.getReceiptType().equals(ReceiptType.SO_SETTLEMENT)).findFirst().orElse(new ReceiptSOTaskDTO());
                return data;
            }
        }
        return null;
    }

    public ReceiptSOTunaiDTO getSalesOrderByReceiptID(String receiptID) {
        if (StringUtil.hasValue(receiptID)) {
            ResponseEntity<ReceiptSOTunaiDTO> data = restTemplate.exchange(
                    receipt_query_url +
                            "api/receipt/so/tunai/query/getByReceiptID/{receiptID}",
                    HttpMethod.GET,
                    RequestUtil.getPreFormattedRequestWithUserPassword(),
                    ReceiptSOTunaiDTO.class,
                    receiptID);
            return data.getBody() == null ? new ReceiptSOTunaiDTO() : data.getBody();
        }
        return new ReceiptSOTunaiDTO();
    }

    private ReceiptSOTunaiChangeCommandDTO initReceiptSOTunaiDP() throws NumberFormatException {
        ReceiptSOTunaiChangeCommandDTO receiptTunaiCreateDTO = new ReceiptSOTunaiChangeCommandDTO();
        receiptTunaiCreateDTO.setRecordID(UUID.randomUUID().toString());
        receiptTunaiCreateDTO.setReceiptID(UUID.randomUUID().toString().substring(0, 10));
        receiptTunaiCreateDTO.setReceiptDocDate(new Date());
        receiptTunaiCreateDTO.setReceiptType(ReceiptType.SO_SETTLEMENT);
        receiptTunaiCreateDTO.setReceiptCategory(ReceiptCategory.TUNAI);
        receiptTunaiCreateDTO.setReceiptKind(ReceiptKind.SETTLEMENT);
        receiptTunaiCreateDTO.setReceiptStatus(ReceiptStatus.COMPLETE);
        receiptTunaiCreateDTO.setPaymentType(PaymentType.CASH);
        return receiptTunaiCreateDTO;
    }

    private ReceiptSOTaskDTO getReceiptSo(String soid, String ahassCode) {
        if (StringUtil.hasValue(soid)) {
            ResponseEntity<ResponseReceiptSOTaskGetListDTO> response = restTemplate.exchange(
                    receipt_query_url +
                            "api/receipt/so/task/query/getbyahasscodeandsoid/{ahassCode}/{soID}",
                    HttpMethod.GET,
                    RequestUtil.getPreFormattedRequestWithUserPassword(),
                    ResponseReceiptSOTaskGetListDTO.class,
                    ahassCode, soid);
            if (response.getBody() != null) {
                return response.getBody().getDatas().get(0);
            }
        }
        return null;
    }

    private PickSlipDTO getPickslipBySoID(String soID, String ahassCode) {
        PickSlipDTO ps = new PickSlipDTO();
        if (soID != null && !soID.isEmpty()) {
            ResponseEntity<ResponsePickSlipGetDTO> resp = restTemplate.exchange(
                    DDMS_H2_SERVICE_SLAVE +
                            PickSlipURI.PICKSLIP_GET_BY_SALESORDERID.getUri(),
                    HttpMethod.GET,
                    RequestUtil.getPreFormattedRequestWithUserPassword(),
                    ResponsePickSlipGetDTO.class, soID, ahassCode);
            if (resp.getBody() != null) {
                ps = resp.getBody().getData();
            }
        }
        return ps;
    }

    private void saveReceiptSOTunai(ReceiptSOTunaiChangeCommandDTO receiptTunaiCreateDTO) {
        try {
            ResponseEntity<ResponseDTO> response = restTemplate.exchange(
                    receipt_command_url +
                            "api/receiptsotunai/command/updateCriteriaReceipt",
                    HttpMethod.PUT,
                    new HttpEntity<>(receiptTunaiCreateDTO, RequestUtil.getPreFormattedRequestWithUserPassword().getHeaders()),
                    ResponseDTO.class);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private Map<String, Double> getPriceMap(List<SalesOrderDetailDTO> soD, List<PickSlipDetailDTO> psD) {
        Map<String, Double> res = new HashMap<>();
        Double totalSebelumDiskon = 0d;
        Double diskon = 0d;
        Double totalSesudahDiskon = 0d;
        for (SalesOrderDetailDTO p : soD) {
            PickSlipDetailDTO temp = psD.stream().filter(a -> a.getPartID().equals(p.getPartID())).findFirst().orElse(null);
            Integer actualQty = temp == null ? 0 : temp.getActualQty();
            totalSebelumDiskon = totalSebelumDiskon + p.getPrice() * actualQty;
            diskon = diskon + p.getDiscount() * actualQty;
        }
        totalSesudahDiskon = totalSebelumDiskon - diskon;
        res.put("totalSebelumDiskon", totalSebelumDiskon);
        res.put("diskon", diskon);
        res.put("totalSesudahDiskon", totalSesudahDiskon);
        return res;
    }

    private ReceiptSOTunaiChangeCommandDTO initReceiptSOTunai() throws NumberFormatException {
        ReceiptSOTunaiChangeCommandDTO receiptTunaiCreateDTO = new ReceiptSOTunaiChangeCommandDTO();
        receiptTunaiCreateDTO.setRecordID(UUID.randomUUID().toString());
        receiptTunaiCreateDTO.setReceiptID(UUID.randomUUID().toString().substring(0, 10));
        receiptTunaiCreateDTO.setReceiptDocDate(new Date());
        receiptTunaiCreateDTO.setReceiptType(ReceiptType.SO);
        receiptTunaiCreateDTO.setReceiptCategory(ReceiptCategory.TUNAI);
        receiptTunaiCreateDTO.setReceiptKind(ReceiptKind.DP);
        receiptTunaiCreateDTO.setReceiptStatus(ReceiptStatus.COMPLETE);
        receiptTunaiCreateDTO.setPaymentType(PaymentType.CASH);
        return receiptTunaiCreateDTO;
    }

    private String completeSO(String soNumber, String ahassCode) {
        String code = "";
        try {
            ResponseEntity<String> response = restTemplate.exchange(
                    DDMS_H2_SERVICE_SLAVE +
                            SalesOrderURI.SOCOMPLETE.getUri(),
                    HttpMethod.PUT,
                    RequestUtil.getPreFormattedRequestWithUserPassword(),
                    String.class, soNumber, ahassCode);
            code = response.getBody();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return code;
    }

    private DealerDTO findDealer(String ahassID, String dealerCode) {
        if (StringUtil.hasValue(ahassID)) {
            ResponseEntity<DealerDTO> response = restTemplate.exchange(
                    md_h1_url +
                            DealerURI.DEALER_GET_BY_AHASS_ID.getUri(),
                    HttpMethod.GET,
                    RequestUtil.getPreFormattedRequestWithUserPassword(),
                    DealerDTO.class,
                    ahassID);
            return response.getBody() == null ? new DealerDTO() : response.getBody();
        } else if (StringUtil.hasValue(dealerCode)) {
            ResponseEntity<DealerDTO> response = restTemplate.exchange(
                    md_h1_url +
                            DealerURI.DEALER_GET_BY_ID.getUri(),
                    HttpMethod.GET,
                    RequestUtil.getPreFormattedRequestWithUserPassword(),
                    DealerDTO.class,
                    dealerCode);
            return response.getBody() == null ? new DealerDTO() : response.getBody();
        }
        return new DealerDTO();
    }

    private Boolean checkSOStatus(String woID, String dealerCode) {
        final List<SalesOrderStatus> validasiStatus = Arrays.asList(SalesOrderStatus.COMPLETE, SalesOrderStatus.BO_COMPLETE, SalesOrderStatus.CANCEL, SalesOrderStatus.PICKED);

        Boolean excludeHOValid = Boolean.TRUE;
        Boolean localPurchaseValid = Boolean.TRUE;

        //EXCLUDE YANG HO DULU
        List<SalesOrderDTO> listSalesOrderDTO = findSalesOrderByWoID(woID, dealerCode);
        List<WorkOrderSOHotlineDTO> listSOHotline = getSOHotlineMap(woID);
        List<SalesOrderDTO> listSOExclHo = new ArrayList<>();
        listSOHotline = listSOHotline.stream().filter(p -> p.getHotlineFlag()).collect(Collectors.toList());
        if (listSalesOrderDTO != null && !listSalesOrderDTO.isEmpty()) {
            if (listSOHotline != null && !listSOHotline.isEmpty()) {
                for (WorkOrderSOHotlineDTO s : listSOHotline) {
                    listSOExclHo = listSalesOrderDTO.stream().filter(p -> !p.getSalesOrderID().equals(s.getSoID())).collect(Collectors.toList());
                }
            } else {
                listSOExclHo = listSalesOrderDTO;
            }

            if (!listSOExclHo.isEmpty()) {
                Optional<SalesOrderDTO> unallowedSO = listSOExclHo.stream().filter(p -> !validasiStatus.contains(p.getSalesOrderLastKnownStatus())).findFirst();
                if (unallowedSO.isPresent()) {
                    excludeHOValid = Boolean.FALSE;
                    return Boolean.FALSE;
                }
            }
        }

        if (excludeHOValid && localPurchaseValid) {
            return true;
        } else {
            return false;
        }
    }

    private List<SalesOrderDTO> findSalesOrderByWoID(String woID, String dealerCode) {
        try {
            if (StringUtil.hasValue(woID)) {
                ResponseEntity<ResponseSalesOrderGetListDTO> resp = restTemplate.exchange(
                        DDMS_H2_SERVICE_SLAVE +
                                IntegrasiURI.GET_SO_BY_WO_AND_AHASSCODE.getUri(),
                        HttpMethod.GET,
                        RequestUtil.getPreFormattedRequestWithUserPassword(),
                        ResponseSalesOrderGetListDTO.class, woID, dealerCode);
                if (resp.getBody().getDatas() != null) {
                    return resp.getBody().getDatas();
                }
            }
        } catch (Exception ex) {
            Logger.getLogger(WorkOrderOrafinHystrixService.class.getName()).log(Level.SEVERE, null, ex);
        }

        return null;
    }

    private List<WorkOrderSOHotlineDTO> getSOHotlineMap(String woID) {
        ResponseEntity<WorkOrderSOHotlineDTO[]> response = restTemplate.exchange(
                DDMS_H2_SERVICE_SLAVE +
                        PartWOHotlineURI.GET_SO_HOTLINE_BY_WOID.getUri(),
                HttpMethod.GET,
                RequestUtil.getPreFormattedRequestWithUserPassword(),
                WorkOrderSOHotlineDTO[].class,
                woID);
        if (response.getBody() != null) {
            return Arrays.asList(response.getBody());
        }

        return new ArrayList<>();
    }

    private String updateStatusSOFromWO(String woID, String ahassCode) {
        String status = "";
        try {
            ResponseEntity<String> response = restTemplate.exchange(
                    DDMS_H2_SERVICE_SLAVE +
                            IntegrasiURI.UPDATE_COMPLETE_SO_BY_WO.getUri(),
                    HttpMethod.PUT,
                    RequestUtil.getPreFormattedRequestWithUserPassword(),
                    String.class,
                    woID,
                    ahassCode);
            System.out.println("Berhasil Update SO. Body = " + response.getBody());
            status = response.getBody() == null ? "ERROR" : response.getBody();
        } catch (HttpStatusCodeException ex) {
            ex.printStackTrace();
            status = "ERROR " + ex.getMessage();
        }
        return status;
    }

    private Map<Integer, String> updateTrx_Wo(WorkOrder wo) {
        Map<Integer, String> response = new HashMap<>();
        RequestCompletePaymentWorkOrderDTO requestComplete = new RequestCompletePaymentWorkOrderDTO();
        PaymentH2DTO createPayment = initPayment(wo);
        WorkOrderDTO woDTO = new WorkOrderAssembler().toDTO(wo);
        woDTO.setWoLastKnownState(WoState.COMPLETE);
        woDTO.setWoLastKnownStatus(WoStatus.COMPLETE);
        woDTO.getWoCreationalDTO().setModifiedAt(new Date());
        woDTO.getWoCreationalDTO().setModifiedBy("PUSH_NJB_NSC");

        requestComplete.setIsPaymentComplete(Boolean.FALSE);
        requestComplete.setPaymentDTO(createPayment);
        requestComplete.setWorkOrderDTO(woDTO);
        String code = completeWo(requestComplete);
        if (code.equals("201")) {
            response.put(1, "Berhasil melakukan complete Workorder.");
            return response;
        } else {
            response.put(0, "Terjadi kegagalan saat complete Workorder.");
            return response;
        }
    }

    private PaymentH2DTO initPayment(WorkOrder wo) {
        Double totalHargaJasa = wo.getListJasa().stream().mapToDouble(mapper -> mapper.getTotal()).sum();
        Double totalHargaPart = wo.getListPart().stream().mapToDouble(mapper -> mapper.getTotal()).sum();
        Double totalBayar = totalHargaJasa + totalHargaPart;
        PaymentH2DTO insertPayment = new PaymentH2DTO();
        insertPayment.setPaymentID(UUID.randomUUID().toString().substring(0, 8).toUpperCase());
        insertPayment.setWoID(wo.getWoID());
        insertPayment.setPaymentMethod(PaymentType.CASH.getLabel());
        insertPayment.setPaymentStatus(PaymentStatus.PAID);
        insertPayment.setVoucherCode(null);
        insertPayment.setJumlahPembayaran(totalBayar);
        insertPayment.setNoTransfer(null);
        insertPayment.setNokartuKredit(null);
        insertPayment.setTerbilang(new NumberwordsUtil().convert(totalBayar).toUpperCase());
        insertPayment.setPaymentDate(new Date());
        insertPayment.setDateReport(DateUtil.dateToString(insertPayment.getPaymentDate(), "dd MMMM yyyy"));
        insertPayment.setAngka(null);
        insertPayment.setPresentase(null);
        insertPayment.setTotalBayar(totalBayar);
        insertPayment.setJumlahDiskon(null);
        insertPayment.setNoKwitansi(generateNoKwitansi(wo.getWoID()).getNoKwitansi());
        insertPayment.setPaymentCreationalDTO(new CreationalSpecificationDTO(new Date(), "ORAFIN", null, null));
        return insertPayment;
    }

    public PaymentOrafin generateNoKwitansi(String WOID) {
        try {
            PaymentOrafin pyoData = paymentOrafinRepository.findOneByWoID(WOID);

            String delimiter[] = WOID.split("-");
            String ahassID = delimiter[1];
            String type = "KWT";
            long seqNumber = 0L;
            Sequence seq = null;
            List<Sequence> datas = sequenceRepository.findAllByDealerIDAndTypeOrderBySequenceDesc(ahassID, type);
            if (datas.size() > 0) {
                seq = datas.get(0);
            }

            if (seq == null) {
                seqNumber = 1L;
                seq = new Sequence();
                seq.setDealerID(ahassID);
                seq.setType(type);
                seq.setSequence(seqNumber);
            } else {
                seqNumber = seq.getSequence() == null ? 1L : seq.getSequence() + 1;
                seq.setSequence(seqNumber);
            }

            if (pyoData == null) {
                pyoData = new PaymentOrafin();
                pyoData.setNoKwitansi(ahassID + "-" + String.format("%08d", seqNumber));
                pyoData.setWoID(WOID);
                pyoData.setPaymentOrafinID(UUID.randomUUID().toString().toUpperCase().replace("-", ""));
                pyoData.setKwitansiDate(new Date());

                CreationalSpecification auditTrailData = new CreationalSpecification();
                auditTrailData.setCreatedAt(new Date());
                auditTrailData.setCreatedBy("SYSTEM");
                auditTrailData.setModifiedAt(new Date());
                auditTrailData.setModifiedBy("SYSTEM");

                pyoData.setPaymentOrafinCreational(auditTrailData);

                sequenceRepository.save(seq);
                paymentOrafinRepository.save(pyoData);
            }
            System.out.println("saveSequenceNoKwitansi save = " + new ObjectMapper().writeValueAsString(seq));
            return pyoData;

        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    private String completeWo(RequestCompletePaymentWorkOrderDTO request) {
        ResponseEntity<ResponseDTO> res = workOrderHystrixService.completeWorkOrder(request);
        try {
            Logger.getLogger(WorkOrderOrafinHystrixService.class.getName()).log(Level.INFO, "Response Complete Workorder Push NJBNSC= {0}", new ObjectMapper().writeValueAsString(res));
        } catch (JsonProcessingException ex) {
            Logger.getLogger(WorkOrderOrafinHystrixService.class.getName()).log(Level.SEVERE, null, ex);
        }
        return res.getBody().getCode();
    }

    private void savePayload(WorkOrderOrafinDTO dto) {
        try {
            Payload payload = new Payload();
            payload.setSourceId(dto.getNoWorkOrder());
            payload.setSourceType(SourceType.ORAFIN);
            payload.setEvent("POST_ORAFIN_RECEIPT");
            payload.setEventDate(new Date());
            payload.setPayloadStatus(DataStatus.ACTIVE);
            payload.setType("WO");
            payload.setReqPayload(new ObjectMapper().writeValueAsString(dto));
            payload.setResPayload(new ObjectMapper().writeValueAsString(null));
            payload.setPayloadCreational(new CreationalSpecification(new Date(), "ADMIN", null, null));
            payload.setUrl(md_h2 + WorkOrderOrafinURI.POST_WO_ORAFIN);
            payloadRepository.save(payload);
        } catch (Exception e) {

        }
    }

}