Subversion Repositories SmartDukaan

package com.spice.profitmandi.service;

import com.google.gson.Gson;

import com.google.gson.reflect.TypeToken;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.dao.entity.user.AgendaRuleConfig;

import com.spice.profitmandi.dao.repository.dtr.AgendaRuleConfigRepository;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import java.lang.reflect.Type;

import java.util.LinkedHashMap;

import java.util.Map;

@Service

@Transactional

public class AgendaConfigServiceImpl implements AgendaConfigService {

    private static final Gson GSON = new Gson();

    private static final Type PARAMS_TYPE = new TypeToken<Map<String, Double>>() {

    }.getType();

    @Autowired

    AgendaRuleConfigRepository agendaRuleConfigRepository;

    @Override

    public Map<String, Double> getParams(String agendaType, int fofoId) throws ProfitMandiBusinessException {

        AgendaRuleConfig defaultRow = agendaRuleConfigRepository.selectByTypeAndFofo(agendaType, 0);

        if (defaultRow == null) {

            throw new ProfitMandiBusinessException("agendaType", agendaType,

                    "No default agenda_rule_config row for " + agendaType);

        }

        AgendaRuleConfig overrideRow = fofoId != 0

                ? agendaRuleConfigRepository.selectByTypeAndFofo(agendaType, fofoId)

                : null;

        return mergeParams(defaultRow.getParams(), overrideRow != null ? overrideRow.getParams() : null);

    }

    // Package-visible + static so it is unit-testable without a Spring context.

    static Map<String, Double> mergeParams(String defaultJson, String overrideJson) {

        Map<String, Double> merged = new LinkedHashMap<>();

        Map<String, Double> defaults = GSON.fromJson(defaultJson, PARAMS_TYPE);

        if (defaults != null) merged.putAll(defaults);

        if (overrideJson != null && !overrideJson.trim().isEmpty()) {

            Map<String, Double> overrides = GSON.fromJson(overrideJson, PARAMS_TYPE);

            if (overrides != null) merged.putAll(overrides);

        }

        return merged;

    }

    @Override

    public void saveParams(String agendaType, int fofoId, Map<String, Double> params, String updatedBy)

            throws ProfitMandiBusinessException {

        AgendaRuleConfig row = agendaRuleConfigRepository.selectByTypeAndFofo(agendaType, fofoId);

        boolean emptyParams = params == null || params.isEmpty();

        if (emptyParams) {

            if (fofoId == 0) {

                throw new ProfitMandiBusinessException("agendaType", agendaType,

                        "Default config cannot be emptied");

            }

            if (row != null) agendaRuleConfigRepository.delete(row);

            return;

        }

        if (row == null) {

            row = new AgendaRuleConfig();

            row.setAgendaType(agendaType);

            row.setFofoId(fofoId);

        }

        row.setParams(GSON.toJson(params));

        row.setUpdatedBy(updatedBy);

        agendaRuleConfigRepository.persist(row);

    }

}