package com.talentcard.server.business.admin;
|
|
import com.talentcard.server.business.DatabaseRows;
|
import com.talentcard.server.business.PageResult;
|
import com.talentcard.server.business.payment.PaymentReconciliationService;
|
import com.talentcard.server.common.BusinessException;
|
import com.talentcard.server.common.ErrorCode;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class PaymentReconciliationAdminService {
|
private final JdbcTemplate jdbc;
|
private final PaymentReconciliationService reconciliation;
|
public PaymentReconciliationAdminService(JdbcTemplate jdbc, PaymentReconciliationService reconciliation) { this.jdbc = jdbc; this.reconciliation = reconciliation; }
|
|
public PageResult<Map<String, Object>> issues(String status, int page, int size) {
|
int current = Math.max(1, page), limit = Math.min(Math.max(1, size), 100);
|
String value = status == null || status.isBlank() ? "open" : status.trim().toLowerCase();
|
if (!List.of("open", "resolved", "ignored", "all").contains(value)) throw new BusinessException(ErrorCode.BAD_REQUEST, "Invalid reconciliation status");
|
boolean all = "all".equals(value);
|
List<Map<String, Object>> records = DatabaseRows.normalize(jdbc.queryForList("select * from payment_reconciliation_issue" + (all ? "" : " where status = ?") + " order by detected_at desc, id desc limit ? offset ?", all ? new Object[] { limit, (current - 1) * limit } : new Object[] { value, limit, (current - 1) * limit }));
|
Long total = all ? jdbc.queryForObject("select count(*) from payment_reconciliation_issue", Long.class) : jdbc.queryForObject("select count(*) from payment_reconciliation_issue where status = ?", Long.class, value);
|
return new PageResult<>(records, current, limit, total == null ? 0 : total);
|
}
|
public Map<String, Object> close(Long id, String status, String operator) {
|
String target = status == null ? "" : status.trim().toLowerCase();
|
if (!List.of("resolved", "ignored").contains(target)) throw new BusinessException(ErrorCode.BAD_REQUEST, "Invalid reconciliation resolution");
|
int affected = jdbc.update("update payment_reconciliation_issue set status = ?, resolved_at = now(), resolved_by = ? where id = ? and status = 'open'", target, operator == null || operator.isBlank() ? "admin" : operator.trim(), id);
|
if (affected == 0) throw new BusinessException(ErrorCode.CONFLICT, "Reconciliation issue is already closed or does not exist");
|
return Map.of("id", id, "status", target);
|
}
|
public Map<String, Object> run(int pendingAfterMinutes) { return reconciliation.reconcile(Math.max(1, Math.min(pendingAfterMinutes, 1440))); }
|
}
|
