Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.services;

import com.spice.profitmandi.common.web.client.RestClient;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;

/**
 * Quality check for visit remarks, backed by the analyze service.
 *
 * POST /apis/analyze/v1/remarks/score
 *   {"remark":"...","asm_id":41292,"visit_id":"98213","agenda":"Credit dues","commit":true}
 * →  {"verdict":"good|bad","score":0.899,"authored_by_asm":true,
 *     "counts_toward_scorecard":true,"reasons":[{"code":"TOO_SHORT","detail":"..."}],
 *     "model_version":"...","visit_id":"98213"}
 *
 * commit=true tells the scorer to persist the score on its side, so pass it only
 * for a real checkout — probes should use false.
 */
@Service
public class RemarkScoreService {

    private static final Logger LOGGER = LogManager.getLogger(RemarkScoreService.class);

    private static final String SCORE_URL = "https://team.smartdukaan.com/apis/analyze/v1/remarks/score";

    @Autowired
    private RestClient restClient;

    /**
     * Score one remark. Never throws and never returns null: a checkout is not
     * allowed to fail because the scorer is slow or down — the caller stores
     * whatever comes back, and an unreachable scorer is recorded as
     * {"error":"..."} so the gap is visible in remark_response instead of silent.
     */
    public JSONObject score(String remark, int asmId, String visitId, String agenda, boolean commit) {
        Map<String, Object> body = new LinkedHashMap<>();
        body.put("remark", remark);
        body.put("asm_id", asmId);
        body.put("visit_id", visitId);
        body.put("agenda", agenda != null ? agenda : "");
        body.put("commit", commit);

        Map<String, String> headers = new HashMap<>();
        headers.put("Content-Type", "application/json");

        try {
            String response = restClient.postJson(SCORE_URL, body, headers);
            JSONObject json = new JSONObject(response);
            if (!json.has("verdict")) {
                LOGGER.warn("Remark scorer returned no verdict for visitId={}: {}", visitId, response);
                return error("scorer returned no verdict");
            }
            return json;
        } catch (Exception e) {
            LOGGER.warn("Remark scoring failed for visitId={} agenda={}: {}", visitId, agenda, e.toString());
            return error(e.getClass().getSimpleName() + ": " + e.getMessage());
        }
    }

    private JSONObject error(String message) {
        return new JSONObject().put("error", message);
    }
}