得物社区活动业务通过组件化和系统化，打破潮流文化与电商的壁垒，构建更紧密的用户、品牌、文化生态。文章探讨了活动业务的演进、组件化实践，以及如何通过技术创新引领潮流社区电商发展。通过活动玩法、任务、激励的灵活组合，提升运营效率，实现业务的持续迭代和创新。

💡 得物社区活动业务的核心在于融合潮流文化与电商，通过社区活动吸引用户分享和互动，增强用户粘性，从而强化品牌形象和文化。

⚙️ 为了提高活动效果和效率，得物采用了组件化方法，将复杂功能拆解为可复用组件，以适应高频业务迭代，降低开发成本，并提升市场响应速度。

🧩 组件化实践中，得物构建了活动、任务和激励的三层概念，通过抽象激励值、构建关联框架、以及任务判定抽离等方式，实现了灵活的任务配置和业务扩展。

🚀 规则引擎的应用是关键，它将业务决策逻辑从任务模块中抽离，使得业务逻辑可以独立维护和动态更新，提高了系统的可维护性和可扩展性。

原创 小龙 2025-06-12 12:04 上海

得物社区活动业务将以组件化、系统化成果为基石，持续深化创新，进一步打破潮流文化与电商消费的壁垒，通过活动业务构建更紧密的用户、品牌、文化生态闭环。得物将凭借不断进化的技术与创新模式，持续引领潮流社区电商的发展风向，书写行业新篇章。

// TaskMode 任务模型
type TaskMode interface {
    // TaskType 任务类型
    TaskType() consts.ActTaskType
    // TaskUniqueFlag 事件唯一标识
    TaskUniqueFlag() string
    // ExpressFunctions 自定义函数集
    ExpressFunctions(ctx context.Context) map[string]govaluate.ExpressionFunction
    // ExpressArguments 任务条件参数搜集器
    ExpressArguments(ctx context.Context, pending []db.PendingTasks) (dto.ExpressArguments, error)
}

type TaskPublishTimes struct {
    event *dto.TaskPublishEvent
}

func NewTaskPublishTimes(event *dto.TaskPublishEvent) (taskMode TaskMode, err error) {
    if event.ContentId == 0 {
       return nil, errors.New("missing necessary parameters")
    }
    taskMode = &TaskPublishTimes{
       event: event,
    }
    return
}

// TaskType 任务类型
func (t *TaskPublishTimes) TaskType() consts.ActTaskType {
    return consts.ActTaskTypePublishTimes
}

// TaskUniqueFlag 任务唯一标识
func (t *TaskPublishTimes) TaskUniqueFlag() string {
    return fmt.Sprintf("CNT_ID_%d", t.event.ContentId)
}

// ExpressFunctions 自定义函数集
func (t *TaskPublishTimes) ExpressFunctions(ctx context.Context) map[string]govaluate.ExpressionFunction {
    return map[string]govaluate.ExpressionFunction{
       // "WITH_ANY_TOPIC(tag_ids, (1001,1002)) == TRUE"
       "WITH_ANY_TOPIC": func(args ...interface{}) (interface{}, error) {
          // ...
          var intersect, _ = arrayx.Intersect(carryIds, condIds)
          return float64(len(intersect.Interface().([]uint64))) > 0, nil
       },
       // 省略部分...
    }
}

// ExpressArguments 条件参数搜集器
func (t *TaskPublishTimes) ExpressArguments(ctx context.Context, pending []db.PendingTasks) (dto.ExpressArguments, error) {
    var eg = gox.NewErrGroup(ctx)
    var args = dto.ExpressArguments{}
   
    // 基础信息
    eg.Go(func() error { /**/ })
    // 互动信息
    eg.Go(func() error { /**/ })
    // 审核信息
    eg.Go(func() error { /**/ })
    // ...

    err = eg.Wait()
    return args, err
}

// TaskTrigger 任务触发器
func (s *ActSysTaskService) TaskTrigger(ctx context.Context, taskMode act_sys.TaskMode) (err error) {
    // 用户粒度任务锁
    // ...
    
    // 列表用户任务
    var pending, err = dao.ListUserTasks(ctx, event.UserId)
    if err != nil {
       return
    }
    
    // 二次过滤（任务状态、活动时间）
    // ...
   
    // 自定义函数集 & 条件参数搜集
    var condFunc = taskMode.ExpressFunctions(ctx)
    var condArgs, err = taskMode.ExpressArguments(ctx, pending)
    if err != nil {
       return
    }

    // 任务达成判定
    for _, v := range pending {
       var reach bool
       reach, err = act_sys.RunTaskExpress(ctx, v.TaskCondExpr, condFunc, condArgs)
       if err != nil {
          continue
       }

       if reach {
           // 更新or写入任务明细记录 & 任务进展 & 发放/回退奖励值
           // ...

           // 执行HOOKS（这里是不同业务的个性化订阅者）
           // ...
       }
    }
    return
}

// ActSysObserver4TaskDetail 任务明细进展转发
type ActSysObserver4TaskDetail interface {
    Unique() string
    Forward(ctx context.Context, detail *db.ActUserTaskDetail) error
}

type ActSysSubject4TaskDetail struct {
    mutex     sync.Mutex
    observers []ActSysObserver4TaskDetail
}

func (sj *ActSysSubject4TaskDetail) Attach(observer ActSysObserver4TaskDetail) {
    if uk := observer.Unique(); len(uk) > 0 {
       sj.mutex.Lock()
       sj.observers = append(sj.observers, observer)
       sj.mutex.Unlock()
    }
}

func (sj *ActSysSubject4TaskDetail) Notify(ctx context.Context, detail *db.ActUserTaskDetail) error {
    for _, observer := range sj.observers {
      if err := observer.Forward(ctx, detail); err != nil {
         return err
      }
    }
    return nil
}

// ActTaskDetailObserver2CheckinReach 任务明细进展·打卡玩法的私信HOOK
type ActTaskDetailObserver2CheckinReach struct {
}

func (ob *ActTaskDetailObserver2CheckinReach) Forward(ctx context.Context, detail *db.ActUserTaskDetail) error {
    // 兜底判断任务明细未完成
    if detail.Status != consts.ActTaskDetailStatusDone {
        return nil
    }
    // 触达用户（动态达标提醒）
   return NewReachClient().Send(ctx, "act_checkin_task_detail_done", detail.userId)
}

阅读原文

跳转微信打开

Fish AI Reader

Fish AI Reader

AI辅助创作，多种专业模板，深度分析，高质量内容生成。从观点提取到深度思考，FishAI为您提供全方位的创作支持。新版本引入自定义参数，让您的创作更加个性化和精准。

FishAI

鱼阅，AI 时代的下一个智能信息助手，助你摆脱信息焦虑

联系邮箱 441953276@qq.com