openbilibili/app/job/main/activity/service/kfc.go

package service

import (
	"context"

	"go-common/library/log"
)

// kfcActionDeal.
func (s *Service) kfcActionDeal(j int) {
	defer s.waiter.Done()
	var (
		ch = s.kfcActionCh[j]
		c  = context.Background()
	)
	log.Info("kfcActionDeal goroutine(%d) start", j)
	for {
		ms, ok := <-ch
		if !ok {
			log.Warn("kfcActionDeal(%d): quit", j)
			return
		}
		if err := s.kfcDao.KfcDelver(c, ms.CouponID, ms.UID); err != nil {
			log.Error("kfcActionDeal(%d):s.kfcDao.KfcDelver(%d %d) error(%v)", j, ms.CouponID, ms.UID, err)
			return
		}
		log.Info("kfcActionDeal(%d) success id(%d) uid(%d)", j, ms.CouponID, ms.UID)
	}
}