package com.talentcard.server.service;
|
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Locale;
|
import java.util.Map;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.talentcard.server.business.PageResult;
|
import com.talentcard.server.business.merchant.MerchantTypeCatalog;
|
import com.talentcard.server.common.BusinessException;
|
import com.talentcard.server.common.ErrorCode;
|
import com.talentcard.server.entity.BenefitFamilyCardApplication;
|
import com.talentcard.server.entity.BenefitTalentCard;
|
import com.talentcard.server.entity.MerchantDisplayPolicyEvent;
|
import com.talentcard.server.mapper.BenefitFamilyCardApplicationMapper;
|
import com.talentcard.server.mapper.BenefitTalentCardMapper;
|
import com.talentcard.server.mapper.MerchantDisplayPolicyEventMapper;
|
import com.talentcard.server.mapper.MerchantDisplayPolicyMerchantMapper;
|
import com.talentcard.server.request.MerchantDisplayPolicyEventRequest;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
@Service
|
public class MerchantDisplayPolicyPortalService {
|
private final MerchantDisplayPolicyMerchantMapper merchantMapper;
|
private final MerchantDisplayPolicyEventMapper eventMapper;
|
private final BenefitTalentCardMapper cardMapper;
|
private final BenefitFamilyCardApplicationMapper familyMapper;
|
|
public MerchantDisplayPolicyPortalService(
|
MerchantDisplayPolicyMerchantMapper merchantMapper,
|
MerchantDisplayPolicyEventMapper eventMapper,
|
BenefitTalentCardMapper cardMapper,
|
BenefitFamilyCardApplicationMapper familyMapper
|
) {
|
this.merchantMapper = merchantMapper;
|
this.eventMapper = eventMapper;
|
this.cardMapper = cardMapper;
|
this.familyMapper = familyMapper;
|
}
|
|
@Transactional(readOnly = true)
|
public PageResult<Map<String, Object>> page(Long talentId, Long cardId, String merchantType, String keyword, int page, int size) {
|
CardContext card = cardContext(talentId, cardId);
|
int safePage = Math.max(page, 1);
|
int safeSize = Math.min(Math.max(size, 1), 100);
|
List<String> aliases = cardLevelAliases(card.cardLevel());
|
List<Map<String, Object>> records = merchantMapper.selectPortalPage(
|
aliases,
|
merchantTypeCode(merchantType),
|
clean(keyword),
|
safeSize,
|
(safePage - 1) * safeSize
|
).stream().map(row -> portalView(row, card)).toList();
|
Long total = merchantMapper.countPortalPage(aliases, merchantTypeCode(merchantType), clean(keyword));
|
return new PageResult<>(records, safePage, safeSize, total == null ? 0 : total);
|
}
|
|
@Transactional(readOnly = true)
|
public Map<String, Object> detail(Long merchantId, Long talentId, Long cardId) {
|
Long id = requireMerchantId(merchantId);
|
CardContext card = cardContext(talentId, cardId);
|
Map<String, Object> row = merchantMapper.selectPortalDetail(id, cardLevelAliases(card.cardLevel()));
|
if (row == null || row.isEmpty()) {
|
throw new BusinessException(ErrorCode.NOT_FOUND, "商户优惠政策不存在或当前人才卡类型不可用");
|
}
|
return portalView(row, card);
|
}
|
|
private String merchantTypeCode(String value) {
|
String cleaned = clean(value);
|
return cleaned.isBlank() ? "" : MerchantTypeCatalog.canonicalCode(cleaned);
|
}
|
|
@Transactional
|
public Map<String, Object> recordEvent(Long merchantId, MerchantDisplayPolicyEventRequest request) {
|
Long id = requireMerchantId(merchantId);
|
String eventType = normalizeEventType(request.eventType());
|
CardContext card = cardContext(request.talentId(), request.cardId());
|
Map<String, Object> row = merchantMapper.selectPortalDetail(id, cardLevelAliases(card.cardLevel()));
|
if (row == null || row.isEmpty()) {
|
throw new BusinessException(ErrorCode.NOT_FOUND, "商户优惠政策不存在或当前人才卡类型不可用");
|
}
|
MerchantDisplayPolicyEvent event = new MerchantDisplayPolicyEvent();
|
event.setMerchantId(id);
|
event.setTalentId(card.sourceTalentId());
|
event.setCardId(card.sourceCardId());
|
event.setPrimaryCardId(card.primaryCardId());
|
event.setCardLevel(card.cardLevel());
|
event.setEventType(eventType);
|
event.setRemark(trimToLength(request.remark(), 255));
|
event.setCreatedAt(LocalDateTime.now());
|
event.setDeleted(0);
|
if (eventMapper.insert(event) != 1) {
|
throw new BusinessException(ErrorCode.INTERNAL_ERROR, "浏览/咨询记录保存失败");
|
}
|
Map<String, Object> result = new LinkedHashMap<>();
|
result.put("id", event.getId());
|
result.put("merchantId", event.getMerchantId());
|
result.put("eventType", event.getEventType());
|
result.put("eventTypeName", "CONSULT".equals(event.getEventType()) ? "咨询" : "浏览");
|
result.put("talentId", event.getTalentId());
|
result.put("cardId", event.getCardId());
|
result.put("primaryCardId", event.getPrimaryCardId());
|
result.put("cardLevel", event.getCardLevel());
|
result.put("createdAt", event.getCreatedAt());
|
return result;
|
}
|
|
private Map<String, Object> portalView(Map<String, Object> row, CardContext card) {
|
Map<String, Object> result = new LinkedHashMap<>();
|
result.put("merchantId", value(row, "merchantId"));
|
result.put("merchantName", text(row, "merchantName"));
|
result.put("merchantType", text(row, "merchantType"));
|
result.put("contactName", text(row, "contactName"));
|
result.put("contactMobile", text(row, "contactMobile"));
|
result.put("logoUrl", text(row, "logoUrl"));
|
result.put("coverUrl", text(row, "coverUrl"));
|
result.put("address", text(row, "address"));
|
result.put("longitude", value(row, "longitude"));
|
result.put("latitude", value(row, "latitude"));
|
result.put("policyId", value(row, "benefitId"));
|
result.put("policyText", text(row, "policyText"));
|
result.put("benefitText", text(row, "policyText"));
|
result.put("rightsText", text(row, "rightsText"));
|
result.put("handlingInstructions", text(row, "handlingInstructions"));
|
result.put("serviceLabel", text(row, "serviceLabel"));
|
result.put("cardLevel", text(row, "cardLevel"));
|
result.put("cardName", text(row, "cardName"));
|
result.put("theme", text(row, "theme"));
|
result.put("available", intValue(value(row, "status")) == 1);
|
result.put("sourceTalentId", card.sourceTalentId());
|
result.put("sourceCardId", card.sourceCardId());
|
result.put("sourceCardType", card.sourceCardType());
|
result.put("primaryCardId", card.primaryCardId());
|
result.put("primaryCardLevel", card.cardLevel());
|
result.put("familyCard", card.familyCard());
|
result.put("policyUpdatedAt", value(row, "policyUpdatedAt"));
|
return result;
|
}
|
|
private CardContext cardContext(Long talentId, Long cardId) {
|
if ((talentId == null || talentId <= 0) && (cardId == null || cardId <= 0)) {
|
throw new BusinessException(ErrorCode.BAD_REQUEST, "人才用户ID或人才卡ID不能为空");
|
}
|
BenefitTalentCard source = cardId == null ? activeCardForTalent(talentId) : activeCard(cardId, talentId);
|
String sourceType = clean(source.getCardType()).toUpperCase(Locale.ROOT);
|
if (sourceType.isBlank() || "PERSONAL".equals(sourceType)) {
|
return new CardContext(source.getTalentId(), source.getId(), sourceType, source.getId(), text(source.getCardLevel()), false);
|
}
|
BenefitFamilyCardApplication owner = familyMapper.selectOne(new QueryWrapper<BenefitFamilyCardApplication>()
|
.eq("deleted", 0)
|
.eq("family_card_id", source.getId())
|
.isNotNull("talent_id")
|
.orderByDesc("id")
|
.last("limit 1"));
|
if (owner == null) {
|
throw new BusinessException(ErrorCode.CONFLICT, "亲属附属卡未找到绑定的主卡");
|
}
|
BenefitTalentCard primary = activePersonalCard(owner.getTalentId());
|
return new CardContext(source.getTalentId(), source.getId(), sourceType, primary.getId(), text(primary.getCardLevel()), true);
|
}
|
|
private BenefitTalentCard activeCard(Long cardId, Long talentId) {
|
QueryWrapper<BenefitTalentCard> query = activeCardQuery()
|
.eq("id", cardId);
|
if (talentId != null && talentId > 0) {
|
query.eq("talent_id", talentId);
|
}
|
BenefitTalentCard card = cardMapper.selectOne(query.last("limit 1"));
|
if (card == null) {
|
throw new BusinessException(ErrorCode.NOT_FOUND, "有效人才卡不存在");
|
}
|
return card;
|
}
|
|
private BenefitTalentCard activeCardForTalent(Long talentId) {
|
BenefitTalentCard card = cardMapper.selectOne(activeCardQuery()
|
.eq("talent_id", talentId)
|
.last("order by case when card_type = 'PERSONAL' then 0 else 1 end, id desc limit 1"));
|
if (card == null) {
|
throw new BusinessException(ErrorCode.NOT_FOUND, "当前用户未持有有效人才卡");
|
}
|
return card;
|
}
|
|
private BenefitTalentCard activePersonalCard(Long talentId) {
|
BenefitTalentCard card = cardMapper.selectOne(activeCardQuery()
|
.eq("talent_id", talentId)
|
.eq("card_type", "PERSONAL")
|
.orderByDesc("id")
|
.last("limit 1"));
|
if (card == null) {
|
throw new BusinessException(ErrorCode.CONFLICT, "未找到有效主卡");
|
}
|
return card;
|
}
|
|
private QueryWrapper<BenefitTalentCard> activeCardQuery() {
|
LocalDate today = LocalDate.now();
|
LocalDateTime now = LocalDateTime.now();
|
return new QueryWrapper<BenefitTalentCard>()
|
.eq("deleted", 0)
|
.eq("status", 1)
|
.and(wrapper -> wrapper.isNull("valid_start").or().le("valid_start", today))
|
.and(wrapper -> wrapper.isNull("valid_end").or().ge("valid_end", today))
|
.and(wrapper -> wrapper.isNull("expire_time").or().gt("expire_time", now));
|
}
|
|
private List<String> cardLevelAliases(String cardLevel) {
|
String normalized = normalizeCardLevel(cardLevel);
|
if ("EXCELLENT".equals(normalized)) {
|
return List.of("EXCELLENT", "卓越人才卡", "卓越");
|
}
|
if ("OUTSTANDING".equals(normalized)) {
|
return List.of("OUTSTANDING", "杰出人才卡", "杰出");
|
}
|
if ("ELITE".equals(normalized)) {
|
return List.of("ELITE", "菁英人才卡", "菁英");
|
}
|
return List.of(normalized);
|
}
|
|
private String normalizeCardLevel(String value) {
|
String raw = clean(value);
|
String upper = raw.toUpperCase(Locale.ROOT);
|
if (upper.contains("EXCELLENT") || raw.contains("卓越")) {
|
return "EXCELLENT";
|
}
|
if (upper.contains("OUTSTANDING") || raw.contains("杰出")) {
|
return "OUTSTANDING";
|
}
|
if (upper.contains("ELITE") || raw.contains("菁英")) {
|
return "ELITE";
|
}
|
return upper;
|
}
|
|
private String normalizeEventType(String value) {
|
String raw = clean(value);
|
String upper = raw.toUpperCase(Locale.ROOT);
|
if ("VIEW".equals(upper) || "浏览".equals(raw)) {
|
return MerchantDisplayPolicyEvent.EVENT_VIEW;
|
}
|
if ("CONSULT".equals(upper) || "咨询".equals(raw)) {
|
return MerchantDisplayPolicyEvent.EVENT_CONSULT;
|
}
|
throw new BusinessException(ErrorCode.BAD_REQUEST, "事件类型只能为VIEW浏览或CONSULT咨询");
|
}
|
|
private Long requireMerchantId(Long merchantId) {
|
if (merchantId == null || merchantId <= 0) {
|
throw new BusinessException(ErrorCode.BAD_REQUEST, "商户ID不能为空");
|
}
|
return merchantId;
|
}
|
|
private String trimToLength(String value, int maxLength) {
|
String text = clean(value);
|
return text.length() <= maxLength ? text : text.substring(0, maxLength);
|
}
|
|
private Object value(Map<String, Object> row, String key) {
|
return row == null ? null : row.get(key);
|
}
|
|
private String text(Map<String, Object> row, String key) {
|
return text(value(row, key));
|
}
|
|
private String text(Object value) {
|
return value == null ? "" : String.valueOf(value).trim();
|
}
|
|
private int intValue(Object value) {
|
return value instanceof Number number ? number.intValue() : 0;
|
}
|
|
private String clean(String value) {
|
return value == null ? "" : value.trim();
|
}
|
|
private record CardContext(
|
Long sourceTalentId,
|
Long sourceCardId,
|
String sourceCardType,
|
Long primaryCardId,
|
String cardLevel,
|
boolean familyCard
|
) {
|
}
|
}
|
