break
333ba4b647
All checks were successful
构建并部署到测试环境（无 SSH） / build-and-deploy (push) Successful in 9m23s
新增 000225 迁移：运营弹窗配置表 tb_h5_popup_configuration（页面/范围/优先级/频率/受控动作/启停/有效期/版本） 与 tb_notification 可空 JSONB 列 popup_snapshot。 新增通知直建窄接口 DirectWriter.CreateOrGetPersonal：与 Outbox 消费共用 prepareDelivery 的渲染、 展示期与 CreateIdempotent 规则，冲突时回查返回既有行；同步扩展个人通知查询与已读两处类型白名单， 并按个人客户入口补齐投递审计来源。 新增 H5 候选与风险换卡：GET /api/c/v1/popup-candidates 先判风险资格（广电卡 + 风险停机 + 无活动物流换货单），命中只返回风险候选；未命中再按时间/启停/页面/店铺/设备类型/卡类型范围/频率 匹配运营配置。POST /api/c/v1/risk-exchanges/:asset_id/address 锁资产行后幂等创建待发货物流换货单， 首次地址锁定，不沿用资产级群发通知。 新增后台运营弹窗配置 CRUD 与启停（仅超级管理员与平台账号），更新递增版本并刷新最近更新时间， 标题与正文统一拒绝 URL 与前端路由，全部写操作记录操作者、前后值、版本与时间。 同步 OpenAPI（cmd/gendocs、cmd/api/docs.go、pkg/openapi/handlers.go）与参数校验中文提示共用实现。
64 lines
2.8 KiB
Go
64 lines
2.8 KiB
Go
package notification
|
|
|
|
import (
|
|
"context"
|
|
"strconv"
|
|
"time"
|
|
|
|
"github.com/break/junhong_cmp_fiber/internal/infrastructure/audit"
|
|
"github.com/break/junhong_cmp_fiber/internal/model"
|
|
"github.com/break/junhong_cmp_fiber/pkg/constants"
|
|
"github.com/break/junhong_cmp_fiber/pkg/errors"
|
|
)
|
|
|
|
// PersonalDirectRequest 是当次直投或复用个人客户通知的请求参数。
|
|
// PopupSnapshot 只允许弹窗投放类型携带，其余类型必须为空。
|
|
type PersonalDirectRequest struct {
|
|
NotificationType string
|
|
TemplateData map[string]string
|
|
RefType string
|
|
RefID string
|
|
RefKey string
|
|
ExpiresAt *time.Time
|
|
PopupSnapshot *model.NotificationPopupSnapshot
|
|
}
|
|
|
|
// DirectWriter 是「当次创建或复用个人客户通知」的窄接口。
|
|
// 候选查询必须当次拿到可用通知标识，不能依赖 Outbox 消费延迟，因此需要这条同步入口。
|
|
type DirectWriter interface {
|
|
CreateOrGetPersonal(ctx context.Context, eventID string, customerID uint, request PersonalDirectRequest) (*model.Notification, error)
|
|
}
|
|
|
|
// CreateOrGetPersonal 当次渲染并幂等写入个人客户通知；事件键已存在时不重复投放，回查并返回既有行。
|
|
// 与 Outbox 消费共用同一渲染、展示期与幂等写入规则，避免两条链路规则漂移。
|
|
func (s *DeliveryService) CreateOrGetPersonal(ctx context.Context, eventID string, customerID uint, request PersonalDirectRequest) (*model.Notification, error) {
|
|
if customerID == 0 || eventID == "" {
|
|
return nil, errors.New(errors.CodeInvalidParam, "个人客户通知参数不完整")
|
|
}
|
|
delivery := deliveryRequest{
|
|
notificationType: request.NotificationType, templateData: request.TemplateData,
|
|
refType: request.RefType, refID: request.RefID, refKey: request.RefKey,
|
|
expiresAt: request.ExpiresAt, popupSnapshot: request.PopupSnapshot,
|
|
}
|
|
if err := validateDeliveryRequest(delivery); err != nil {
|
|
return nil, err
|
|
}
|
|
// API 直投不经过 Outbox 消费，自行提供渲染结果与展示期，但仍复用同一落库规则。
|
|
// 个人客户请求上下文不携带审计上下文，直投必须显式声明操作者与入口，否则投递审计会被入口规则拒绝并静默降级。
|
|
prepared, err := s.prepareDelivery(eventID, constants.NotificationRecipientKindPersonalCustomer, delivery, deliveryOrigin{
|
|
actor: audit.ActorInput{Kind: constants.AuditActorPersonalCustomer, ID: strconv.FormatUint(uint64(customerID), 10)},
|
|
source: constants.AuditSourcePersonalAPI,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
notification, _, err := s.deliverOne(ctx, eventID, constants.NotificationRecipientKindPersonalCustomer, customerID, delivery, prepared)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if notification == nil {
|
|
return nil, errors.New(errors.CodeInvalidStatus, "个人客户通知接收人不可用")
|
|
}
|
|
return notification, nil
|
|
}
|